optimizations

akto-api-security · Jan 3, 2025 · eb9f899 · eb9f899
1 parent fb3e1b6
commit eb9f899
Showing 1 changed file with 6 additions and 15 deletions.
diff --git a/...detection/src/main/java/com/akto/threat/detection/tasks/MaliciousTrafficDetectorTask.java b/...detection/src/main/java/com/akto/threat/detection/tasks/MaliciousTrafficDetectorTask.java
@@ -290,22 +290,13 @@ private void generateAndPushMaliciousEventRequest(
             .setLatestApiMethod(maliciousReq.getMethod())
             .setDetectedAt(responseParam.getTime())
             .build();
-    try {
       MaliciousEventKafkaEnvelope envelope =
-          MaliciousEventKafkaEnvelope.newBuilder()
-              .setActor(actor)
-              .setAccountId(responseParam.getAccountId())
-              .setMaliciousEvent(maliciousEvent)
-              .build();
-      MessageEnvelope.generateEnvelope(responseParam.getAccountId(), actor, maliciousEvent)
-          .marshal()
-          .ifPresent(
-              data -> {
-                internalKafka.send(KafkaTopic.ThreatDetection.ALERTS, envelope);
-              });
-    } catch (InvalidProtocolBufferException e) {
-      e.printStackTrace();
-    }
+        MaliciousEventKafkaEnvelope.newBuilder()
+            .setActor(actor)
+            .setAccountId(responseParam.getAccountId())
+            .setMaliciousEvent(maliciousEvent)
+            .build();
+    internalKafka.send(KafkaTopic.ThreatDetection.ALERTS, envelope);
   }
 
   public static HttpResponseParams buildHttpResponseParam(HttpResponseParam httpResponseParamProto) {