From 39ad4a8a13245e6d91ebd64d3a55d26877fd19aa Mon Sep 17 00:00:00 2001 From: gauravmann Date: Thu, 16 Oct 2025 16:07:38 +0400 Subject: [PATCH 1/3] add host check --- .../java/com/akto/action/IngestionAction.java | 28 +++++++++---------- 1 file changed, 14 insertions(+), 14 deletions(-) diff --git a/apps/data-ingestion-service/src/main/java/com/akto/action/IngestionAction.java b/apps/data-ingestion-service/src/main/java/com/akto/action/IngestionAction.java index b448ce37d6..8aa6030923 100644 --- a/apps/data-ingestion-service/src/main/java/com/akto/action/IngestionAction.java +++ b/apps/data-ingestion-service/src/main/java/com/akto/action/IngestionAction.java @@ -31,20 +31,20 @@ private boolean sendLogsToCustomAccount(List batchData){ } - // for (IngestDataBatch batch : batchData) { - // String requestHeaders = batch.getRequestHeaders(); - // if (requestHeaders != null) { - // String lowerHeaders = requestHeaders.toLowerCase(); - // if (lowerHeaders.contains("\"host\":") || lowerHeaders.contains("\"host \":")) { - // if (lowerHeaders.contains("hollywoodbets") || - // lowerHeaders.contains("betsolutions") || - // lowerHeaders.contains("betnix") || - // lowerHeaders.contains("betsoft")) { - // return true; - // } - // } - // } - // } + for (IngestDataBatch batch : batchData) { + String requestHeaders = batch.getRequestHeaders(); + if (requestHeaders != null) { + String lowerHeaders = requestHeaders.toLowerCase(); + if (lowerHeaders.contains("\"host\":") || lowerHeaders.contains("\"host \":")) { + if (lowerHeaders.contains("hollywoodbets") || + lowerHeaders.contains("betsolutions") || + lowerHeaders.contains("betnix") || + lowerHeaders.contains("betsoft")) { + return true; + } + } + } + } return true; } From 2efa04e58e8f92c66b28d5433deb4338aa5dbd2f Mon Sep 17 00:00:00 2001 From: gauravmann Date: Thu, 16 Oct 2025 16:38:15 +0400 Subject: [PATCH 2/3] add version forcefully --- libs/utils/src/main/java/com/akto/metrics/ModuleInfoWorker.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/libs/utils/src/main/java/com/akto/metrics/ModuleInfoWorker.java b/libs/utils/src/main/java/com/akto/metrics/ModuleInfoWorker.java index 841ece9d09..52755baa2d 100644 --- a/libs/utils/src/main/java/com/akto/metrics/ModuleInfoWorker.java +++ b/libs/utils/src/main/java/com/akto/metrics/ModuleInfoWorker.java @@ -59,7 +59,7 @@ public static void init(ModuleInfo.ModuleType moduleType, DataActor dataActor) { return; } loggerMaker.infoAndAddToDb("Starting heartbeat update for module:" + moduleType.name()); - ModuleInfoWorker infoWorker = new ModuleInfoWorker(moduleType, version, dataActor); + ModuleInfoWorker infoWorker = new ModuleInfoWorker(moduleType, "1.1.7-DIS-1.1.7", dataActor); infoWorker.scheduleHeartBeatUpdate(); } } From 29c5fd879c6e291eecfc5c1237def0a9cad5513b Mon Sep 17 00:00:00 2001 From: gauravmann Date: Thu, 16 Oct 2025 16:39:00 +0400 Subject: [PATCH 3/3] comment --- .../java/com/akto/action/IngestionAction.java | 28 +++++++++---------- 1 file changed, 14 insertions(+), 14 deletions(-) diff --git a/apps/data-ingestion-service/src/main/java/com/akto/action/IngestionAction.java b/apps/data-ingestion-service/src/main/java/com/akto/action/IngestionAction.java index 8aa6030923..b448ce37d6 100644 --- a/apps/data-ingestion-service/src/main/java/com/akto/action/IngestionAction.java +++ b/apps/data-ingestion-service/src/main/java/com/akto/action/IngestionAction.java @@ -31,20 +31,20 @@ private boolean sendLogsToCustomAccount(List batchData){ } - for (IngestDataBatch batch : batchData) { - String requestHeaders = batch.getRequestHeaders(); - if (requestHeaders != null) { - String lowerHeaders = requestHeaders.toLowerCase(); - if (lowerHeaders.contains("\"host\":") || lowerHeaders.contains("\"host \":")) { - if (lowerHeaders.contains("hollywoodbets") || - lowerHeaders.contains("betsolutions") || - lowerHeaders.contains("betnix") || - lowerHeaders.contains("betsoft")) { - return true; - } - } - } - } + // for (IngestDataBatch batch : batchData) { + // String requestHeaders = batch.getRequestHeaders(); + // if (requestHeaders != null) { + // String lowerHeaders = requestHeaders.toLowerCase(); + // if (lowerHeaders.contains("\"host\":") || lowerHeaders.contains("\"host \":")) { + // if (lowerHeaders.contains("hollywoodbets") || + // lowerHeaders.contains("betsolutions") || + // lowerHeaders.contains("betnix") || + // lowerHeaders.contains("betsoft")) { + // return true; + // } + // } + // } + // } return true; }