lazzexus/Kafkatorio
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

KafkaAdmin - make all event-update topics

Browse source
This commit is contained in:
Adam 2022-03-12 01:38:00 +01:00
parent e3954c184a
commit b6f8d2e422
1 changed files with 7 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

9
modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/admin/KafkatorioKafkaAdmin.kt
View file

@ -1,5 +1,6 @@
package dev.adamko.kafkatorio.processor.admin 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.FactorioObjectData
import dev.adamko.kafkatorio.events.schema.KafkatorioPacket import dev.adamko.kafkatorio.events.schema.KafkatorioPacket
import dev.adamko.kafkatorio.processor.KafkatorioTopology import dev.adamko.kafkatorio.processor.KafkatorioTopology
@ -42,10 +43,14 @@ object KafkatorioKafkaAdmin {
} }
KafkatorioPacket.PacketType.CONFIG -> add("$base.FactorioConfigurationUpdate") KafkatorioPacket.PacketType.CONFIG -> add("$base.FactorioConfigurationUpdate")
KafkatorioPacket.PacketType.PROTOTYPES -> add("$base.all") 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()) }.minus(currentTopics.toSet())