From e26327547970156cba17522f8e2031bb544ed373 Mon Sep 17 00:00:00 2001
From: Adam <897017+aSemy@users.noreply.github.com>
Date: Wed, 9 Feb 2022 23:02:16 +0100
Subject: [PATCH] update kafka-resetter for the 3 applications

---
 modules/events-server/build.gradle.kts | 25 ++++++++++++++++++++-----
 1 file changed, 20 insertions(+), 5 deletions(-)

diff --git a/modules/events-server/build.gradle.kts b/modules/events-server/build.gradle.kts
index d6299a4..5a35bec 100644
--- a/modules/events-server/build.gradle.kts
+++ b/modules/events-server/build.gradle.kts
@@ -66,16 +66,31 @@ tasks.withType<KotlinCompile> {
   )
 }
 
-val kafkatorioEventsServerKafkaForceReset by tasks.registering(Exec::class) {
+val kafkatorioEventsServerKafkaForceReset by tasks.registering {
   group = project.name
 
-  val cmd = """
-    /kafka/bin/kafka-streams-application-reset.sh --application-id kafkatorio-events-processor --input-topics factorio-server-log --force
+  fun reset(applicationId: String) = """
+    /kafka/bin/kafka-streams-application-reset.sh --application-id $applicationId --force
   """.trimIndent()
 
-  logging.captureStandardOutput(LogLevel.LIFECYCLE)
+  doLast {
 
-  commandLine = parseSpaceSeparatedArgs(""" docker exec -d kafka $cmd """)
+    exec {
+      val cmd = reset("kafkatorio-events-processor.saveTiles")
+      logging.captureStandardOutput(LogLevel.LIFECYCLE)
+      commandLine = parseSpaceSeparatedArgs(""" docker exec -d kafka $cmd """)
+    }
+    exec {
+      val cmd = reset("kafkatorio-events-processor.splitPackets")
+      logging.captureStandardOutput(LogLevel.LIFECYCLE)
+      commandLine = parseSpaceSeparatedArgs(""" docker exec -d kafka $cmd  --input-topics factorio-server-log  """)
+    }
+    exec {
+      val cmd = reset("kafkatorio-events-processor.playerUpdates")
+      logging.captureStandardOutput(LogLevel.LIFECYCLE)
+      commandLine = parseSpaceSeparatedArgs(""" docker exec -d kafka $cmd """)
+    }
+  }
 }
 
 //tasks.run.configure {