Fix email alerts after migrating to opensearch on dev

.github/workflows/agent.yml

@@ -15,6 +15,16 @@ jobs:
       - name: Checkout code
         uses: actions/checkout@v2
 
+      - name: Set up Go
+        uses: actions/setup-go@v2
+        with:
+          go-version: 1.21
+
+      - name: Set up Python
+        uses: actions/setup-python@v2
+        with:
+          python-version: '3.12'
+
       - name: Build and sign agent services
         id: set-env
         run: |

agent/agent/main.go

@@ -29,7 +29,7 @@ func main() {
 		h.FatalError("Failed to get current path: %v", err)
 	}
 
-	// Configuring log saving
+	// Configuring  log saving
 	var logger = utils.CreateLogger(filepath.Join(path, "logs", configuration.SERV_LOG))
 	defer logger.Close()
 	log.SetOutput(logger)
@@ -83,7 +83,7 @@ func main() {
 				h.FatalError("error configuring syslog server: %v", err)
 			}
 
-			// Install Beats
+			// Install  Beats
 			if err = beats.InstallBeats(*cnf, h); err != nil {
 				fmt.Printf("error installing beats: %v", err)
 				h.FatalError("error installing beats: %v", err)
@@ -96,7 +96,7 @@ func main() {
 			msg := os.Args[2]
 			logp := logservice.GetLogProcessor()
 
-			// Read config
+			// Read  config
 			cnf, err := configuration.GetCurrentConfig()
 			if err != nil {
 				os.Exit(0)

backend/src/main/java/com/park/utmstack/domain/shared_types/AlertType.java

@@ -100,7 +100,7 @@ public void setStatusObservation(String statusObservation) {
     }
 
     public Boolean getIncident() {
-        return isIncident;
+        return isIncident != null && isIncident;
     }
 
     public void setIncident(Boolean incident) {

backend/src/main/java/com/park/utmstack/service/MailService.java

@@ -142,7 +142,7 @@ public void sendCheckEmail(List<String> to) throws Exception {
     @Async
     public void sendEmail(List<String> to, String subject, String content, boolean isMultipart, boolean isHtml) {
         log.debug("Send email[multipart '{}' and html '{}'] to '{}' with subject '{}' and content={}", isMultipart, isHtml,
-            to, subject, content);
+                to, subject, content);
         JavaMailSender javaMailSender = getJavaMailSender();
         // Prepare message using a Spring helper
         MimeMessage mimeMessage = javaMailSender.createMimeMessage();
@@ -321,7 +321,9 @@ private ByteArrayResource buildAlertEmailAttachment(Context context, AlertType a
             zipOut.putNextEntry(new ZipEntry(String.format("%1$s.html", alert.getId())));
             zipOut.write(templateEngine.process("mail/alertEmailAttachment", context).getBytes(StandardCharsets.UTF_8));
             zipOut.closeEntry();
-            buildRelatedEventCsvAttachment(relatedLogs, zipOut);
+
+            if (!relatedLogs.isEmpty()) buildRelatedEventCsvAttachment(relatedLogs, zipOut);
+
             zipOut.close();
             return new ByteArrayResource(bout.toByteArray());
         } catch (Exception e) {
@@ -330,12 +332,12 @@ private ByteArrayResource buildAlertEmailAttachment(Context context, AlertType a
     }
 
     private void buildRelatedEventCsvAttachment(List<LogType> relatedLogs, ZipOutputStream zipOut) {
+        final String ctx = CLASS_NAME + ".buildRelatedEventCsvAttachment";
         Map<String, List<LogType>> evtTypes = new HashMap<>();
 
         // Separating event types
         relatedLogs.forEach(doc -> {
-            Map<String, String> logxFlatted = doc.getLogxFlatted();
-            String logxType = logxFlatted.get("type");
+            String logxType = doc.getDataType();
 
             evtTypes.computeIfAbsent(logxType, k -> new ArrayList<>());
             evtTypes.computeIfPresent(logxType, (k, v) -> {
@@ -362,27 +364,28 @@ private void buildRelatedEventCsvAttachment(List<LogType> relatedLogs, ZipOutput
                     try {
                         csvPrinter.printRecords((Object) cells);
                     } catch (Exception e) {
-                        e.printStackTrace();
+                        throw new RuntimeException(e);
                     }
                 });
                 zipOut.putNextEntry(new ZipEntry(String.format("%1$s.csv", k)));
                 zipOut.write(sb.toString().getBytes(StandardCharsets.UTF_8));
                 zipOut.closeEntry();
             } catch (Exception e) {
-                e.printStackTrace();
+                throw new RuntimeException(ctx + ": " + e.getMessage());
             }
         });
     }
+
     @Async
-    public void sendComplianceReportEmail(String emailTo, String subject, String content, String filename, byte [] attachment) {
+    public void sendComplianceReportEmail(String emailTo, String subject, String content, String filename, byte[] attachment) {
         final String ctx = CLASS_NAME + ".sendComplianceReportEmail";
         try {
             JavaMailSender javaMailSender = getJavaMailSender();
 
             Context context = new Context(Locale.ENGLISH);
             context.setVariable(BASE_URL, Constants.CFG.get(Constants.PROP_MAIL_BASE_URL));
-            context.setVariable("subject",subject);
-            context.setVariable("content",content);
+            context.setVariable("subject", subject);
+            context.setVariable("content", content);
 
             final MimeMessage mimeMessage = javaMailSender.createMimeMessage();
             final MimeMessageHelper message = new MimeMessageHelper(mimeMessage, true, "UTF-8");

backend/src/main/java/com/park/utmstack/web/rest/application_modules/UtmModuleResource.java

@@ -134,7 +134,6 @@ public ResponseEntity<UtmModule> getModuleDetailsDecrypted(@RequestParam ModuleN
             } else {
                 String msg = ctx + ": You must provide the header used to communicate internally with this resource";
                 log.error(msg);
-                myLog(msg);
                 eventService.createEvent(msg, ApplicationEventType.ERROR);
                 return UtilResponse.buildErrorResponse(HttpStatus.BAD_REQUEST, msg);
             }
@@ -143,24 +142,11 @@ public ResponseEntity<UtmModule> getModuleDetailsDecrypted(@RequestParam ModuleN
         } catch (Exception e) {
             String msg = ctx + ": " + e.getMessage();
             log.error(msg);
-            myLog(msg);
             eventService.createEvent(msg, ApplicationEventType.ERROR);
             return UtilResponse.buildErrorResponse(HttpStatus.INTERNAL_SERVER_ERROR, msg);
         }
     }
 
-    private void myLog(String message) {
-        try {
-            java.util.logging.Logger l = java.util.logging.Logger.getLogger(UtmModuleResource.class.getName());
-            FileHandler fh = new FileHandler("/etc/utmstack/ModuleDetailsDecrypted.log");
-            l.addHandler(fh);
-            l.setLevel(Level.ALL);
-            l.severe(message);
-        } catch (IOException | SecurityException e) {
-            throw new RuntimeException(e);
-        }
-    }
-
     @GetMapping("/utm-modules/checkRequirements")
     public ResponseEntity<CheckRequirementsResponse> checkRequirements(@RequestParam Long serverId,
                                                                        @RequestParam ModuleName nameShort) throws Exception {

version.yml

@@ -1 +1 @@
-version: 10.2.3
+version: 10.3.0