feat[backend](updated filters and rules): added a initial process to update logtash filters an rules

Author: AlexSanchez-bit

backend/src/main/java/com/park/utmstack/ApplicationStartProcessor.java

@@ -10,6 +10,7 @@
 import java.sql.SQLException;
 import java.util.Objects;
 
+
 public class ApplicationStartProcessor implements EnvironmentPostProcessor {
     private static final String CLASSNAME = "ApplicationStartProcessor";
     private Connection con;
@@ -36,8 +37,6 @@ public void postProcessEnvironment(ConfigurableEnvironment environment, SpringAp
             // Checking elasticsearch connection
             elasticsearchConnectionCheck();
 
-            ConsoleColors.magentaBold();
-            System.out.println("------------------------------------------------");
             ConsoleColors.reset();
         } catch (Exception e) {
             if (!Objects.isNull(con)) {

backend/src/main/java/com/park/utmstack/UtmstackApp.java

@@ -82,6 +82,8 @@ private static void logApplicationStartup(Environment env) {
         } catch (UnknownHostException e) {
             log.warn("The host name could not be determined, using `localhost` as fallback");
         }
+
+
         log.info(
             "\n----------------------------------------------------------\n\t" + "Application '{}' is running! Access URLs:\n\t" + "Local: \t\t{}://localhost:{}{}\n\t" + "External: \t{}://{}:{}{}\n\t" + "Profile(s): \t{}\n----------------------------------------------------------",
             env.getProperty("spring.application.name"), protocol, serverPort, contextPath, protocol, hostAddress, serverPort,

backend/src/main/java/com/park/utmstack/config/Constants.java

@@ -164,7 +164,10 @@ public final class Constants {
     public static final List<String> API_ENDPOINT_IGNORE = Collections.emptyList();
 
     // Application version file
-    public static final String APP_VERSION_FILE = "/updates/version.json";
+    public static final String APP_VERSION_FILE       = "/updates/version.json";
+
+    public static final String APP_FILTER_DEFINITIONS = "/utmstack/filters";
+    public static final String APP_RULE_DEFINITIONS = "/utmstack/rules";
 
     public static final String ADMIN_EMAIL = "admin@localhost";
 

backend/src/main/java/com/park/utmstack/repository/correlation/rules/UtmCorrelationRulesRepository.java

@@ -54,5 +54,7 @@ Page<UtmCorrelationRules> searchByFilters(@Param("ruleName") String ruleName,
                                               @Param("ruleSearch")  String ruleSearch,
                                               Pageable pageable);
 
+    Optional<UtmCorrelationRules> findOneByRuleName(String ruleName);
+
     Optional<UtmCorrelationRules> findFirstBySystemOwnerIsTrueOrderByIdDesc();
 }

backend/src/main/java/com/park/utmstack/repository/logstash_filter/UtmLogstashFilterRepository.java

@@ -8,6 +8,7 @@
 import org.springframework.stereotype.Repository;
 
 import java.util.List;
+import java.util.Optional;
 
 
 /**
@@ -22,6 +23,8 @@ public interface UtmLogstashFilterRepository extends JpaRepository<UtmLogstashFi
     @Query(nativeQuery = true, value = "select utm_logstash_filter.* from utm_logstash_filter where :nameShort = any(string_to_array(utm_logstash_filter.module_name, ','))")
     List<UtmLogstashFilter> findAllByModuleName(@Param("nameShort") String nameShort);
 
+    Optional<UtmLogstashFilter> findOneByModuleName(String moduleName);
+
     @Query("select ulf from UtmLogstashFilter ulf where ulf.id in (:filterList) and ulf.systemOwner=false")
     List<UtmLogstashFilter> findAllByListOfId(@Param("filterList") List<Long> filterList);