From b6f8d2e4227dd879a1e0e129969f155cf8f2d37d Mon Sep 17 00:00:00 2001
From: Adam <897017+aSemy@users.noreply.github.com>
Date: Sat, 12 Mar 2022 01:38:00 +0100
Subject: [PATCH] KafkaAdmin - make all event-update topics

---
 .../kafkatorio/processor/admin/KafkatorioKafkaAdmin.kt   | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/admin/KafkatorioKafkaAdmin.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/admin/KafkatorioKafkaAdmin.kt
index a51916f..fb89dbc 100644
--- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/admin/KafkatorioKafkaAdmin.kt
+++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/admin/KafkatorioKafkaAdmin.kt
@@ -1,5 +1,6 @@
 package dev.adamko.kafkatorio.processor.admin
 
+import dev.adamko.kafkatorio.events.schema.FactorioEventUpdate
 import dev.adamko.kafkatorio.events.schema.FactorioObjectData
 import dev.adamko.kafkatorio.events.schema.KafkatorioPacket
 import dev.adamko.kafkatorio.processor.KafkatorioTopology
@@ -42,10 +43,14 @@ object KafkatorioKafkaAdmin {
             }
           KafkatorioPacket.PacketType.CONFIG     -> add("$base.FactorioConfigurationUpdate")
           KafkatorioPacket.PacketType.PROTOTYPES -> add("$base.all")
-          KafkatorioPacket.PacketType.UPDATE     -> add("$base.all")
+          KafkatorioPacket.PacketType.UPDATE     -> {
+            add("$base.all")
+            FactorioEventUpdate.FactorioEventUpdateType.values.forEach { objectName ->
+              add("$base.${objectName.name}")
+            }
+          }
         }
 
-
       }
     }.minus(currentTopics.toSet())