Merge branch 'develop' into csa-1.12.0-cdh-7.1.9

Author: stas-panasiuk

.github/workflows/build_and_test.yml

@@ -28,9 +28,26 @@ jobs:
           restore-keys: |
             ${{ runner.os }}-maven-
       - name: Build and Test with Maven
-        run: mvn -B package --file flink-cyber/pom.xml
+        run: mvn -P '!add-depebdencies-for-IDEA,!full-build,!include-front-end' -B package --file flink-cyber/pom.xml
+
       # Optional: Uploads the full dependency graph to GitHub to improve the quality of Dependabot alerts this repository can receive
       - name: Update dependency graph
-        uses: advanced-security/maven-dependency-submission-action@571e99aab1055c2e71a1e2309b9691de18d6b7d6
+        uses: advanced-security/maven-dependency-submission-action@v3
         with:
           directory: /home/runner/work/cybersec/cybersec/flink-cyber
+  build_and_test_angular:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - name: Use Node.js
+        uses: actions/setup-node@v4
+        with:
+          node-version: '20.x'
+      - name: Install Angular CLI
+        run: npm install -g @angular/cli
+      - name: Install dependencies
+        run: npm install
+        working-directory: ./flink-cyber/metron-parser-chain/parser-chains-config-service/frontend/parser-chains-client
+      - name: Run test
+        run: npm run test:headless
+        working-directory: ./flink-cyber/metron-parser-chain/parser-chains-config-service/frontend/parser-chains-client

.idea/codeStyles/codeStyleConfig.xml

@@ -0,0 +1,46 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>com.cloudera.cyber</groupId>
+        <artifactId>cyber-services</artifactId>
+        <version>2.3.1</version>
+    </parent>
+    <artifactId>cyber-service-common</artifactId>
+    <name>Archetype - cyber-service-common</name>
+    <url>http://maven.apache.org</url>
+    <properties>
+        <commons-compress.version>1.24.0</commons-compress.version>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-compress</artifactId>
+            <version>${commons-compress.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.assertj</groupId>
+            <artifactId>assertj-core</artifactId>
+            <scope>test</scope>
+            <version>${assertj.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-autoconfigure</artifactId>
+        </dependency>
+    </dependencies>
+</project>

.idea/cybersec.iml

@@ -0,0 +1,36 @@
+package com.cloudera.service.common;
+
+import lombok.experimental.UtilityClass;
+import org.apache.commons.lang3.StringUtils;
+
+import java.util.Arrays;
+import java.util.function.Function;
+
+@UtilityClass
+public class Utils {
+
+    /**
+     * Retrieves an enum constant of the specified enum type based on a case-insensitive search of a string representation,
+     * using a custom mapping function to extract the string representation from the enum constant.
+     *
+     * @param <T>           the enum type
+     * @param name          the string representation to search for
+     * @param enumClass       the Class object representing the enum type
+     * @param nameFunction  a function that extracts the string representation from an enum constant
+     * @return              the enum constant matching the provided string representation, or null if not found
+     * @throws NullPointerException if {@code name}, {@code enumClass}, or {@code nameFunction} is null
+     */
+    public static <T extends Enum<T>> T getEnumFromString(String name, Class<T> enumClass, Function<T, String> nameFunction) {
+        return Arrays.stream(enumClass.getEnumConstants())
+                .filter(type -> StringUtils.equalsIgnoreCase(name, nameFunction.apply(type)))
+                .findFirst()
+                .orElse(null);
+    }
+
+    public static <T extends Enum<T>> T getEnumFromStringContains(String name, Class<T> enumClass, Function<T, String> nameFunction) {
+        return Arrays.stream(enumClass.getEnumConstants())
+                .filter(type -> StringUtils.containsIgnoreCase(name, nameFunction.apply(type)))
+                .findFirst()
+                .orElse(null);
+    }
+}

.idea/modules.xml

@@ -0,0 +1,14 @@
+package com.cloudera.service.common.config.kafka;
+
+import lombok.Getter;
+import lombok.Setter;
+import org.springframework.boot.autoconfigure.kafka.KafkaProperties;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+@Getter
+@Setter
+public class ClouderaKafkaProperties extends KafkaProperties {
+  private String replyTopic;
+  private String requestTopic;
+}