Refactor WAF detection logic in LogConsumerService to restore functionality...

Refactor WAF detection logic in LogConsumerService to restore functionality for generating WAF detections and events. This update re-enables the processing of attacked logs and improves error handling, ensuring that failures during detection generation are logged for better visibility.

internal/service/log_consumer.go

@@ -249,14 +249,14 @@ func (s *LogConsumerService) Handle(ctx context.Context, message []byte) error {
 		// WafDetections[i].WafDetectionAttackedLog = WafDetectionMessage.AttackedLog[i]
 		// WafDetections[i].WafDetectionAttackedLog.ID = id.Str()
 		// WafDetections[i].CreatedAt = WafDetectionMessage.CreatedAt
-		// wafDetection, err := s.genWafDetection(WafDetectionMessage, WafDetectionMessage.AttackedLog[i])
-		// if err != nil {
-		// 	log.Err(err).Str("message.Value", string(message)).Msg("gen waf detection fails")
-		// 	continue
-		// }
+		wafDetection, err := s.genWafDetection(WafDetectionMessage, WafDetectionMessage.AttackedLog[i])
+		if err != nil {
+			log.Err(err).Str("message.Value", string(message)).Msg("gen waf detection fails")
+			continue
+		}
 
-		// bulkIndexSignal := es.NewBulkIndexRequest().Index(EsIndexWafDetectionsAlias)
-		// bulkableRequests = append(bulkableRequests, bulkIndexSignal.Id(wafDetection.WafDetectionAttackedLog.ID).Doc(wafDetection))
+		bulkIndexSignal := es.NewBulkIndexRequest().Index(EsIndexWafDetectionsAlias)
+		bulkableRequests = append(bulkableRequests, bulkIndexSignal.Id(wafDetection.WafDetectionAttackedLog.ID).Doc(wafDetection))
 
 		event, err := s.genWafDetectionEvent(WafDetectionMessage, WafDetectionMessage.AttackedLog[i])
 		if err != nil {