diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/colourMapChunks.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/colourMapChunks.kt index c471d18..b790ffc 100644 --- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/colourMapChunks.kt +++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/colourMapChunks.kt @@ -187,7 +187,7 @@ private fun KTable>.enr val missingProtos = mutableSetOf() val tileColours = tiles.map.mapValues { (_, code) -> - colourDict.map.getOrElse(code) { + colourDict.getOrElse(code) { missingProtos.add(code) ColourHex.TRANSPARENT } diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/groupMapChunks.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/groupMapChunks.kt deleted file mode 100644 index 272d386..0000000 --- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/groupMapChunks.kt +++ /dev/null @@ -1 +0,0 @@ -package dev.adamko.kafkatorio.processor.topology diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/prototypes.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/prototypes.kt index 56b9e7b..85401e5 100644 --- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/prototypes.kt +++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/prototypes.kt @@ -29,7 +29,9 @@ value class TileProtoHashCode private constructor(val code: Int) { @JvmInline @Serializable -value class TileColourDict(val map: Map) +value class TileColourDict( + private val map: Map +) : Map by map /** Get the latest map-tile colours per server. */ @@ -48,9 +50,9 @@ fun KStream.createTilePrototypeTable() TileColourDict(map) }.filter("$pid.filterMapTileProtos") { _, dict: TileColourDict -> - dict.map.isNotEmpty() + dict.isNotEmpty() }.peek { serverId, dict: TileColourDict -> - println("$pid: server $serverId has TileColourDict[${dict.map.size}]: ${dict.map.entries.joinToString()}") + println("$pid: server $serverId has TileColourDict[${dict.size}]: ${dict.entries.joinToString()}") }.repartition( repartitionedAs( "$pid.pre-table-repartition", diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/playerUpdates.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/websocketBroadcast.kt similarity index 100% rename from modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/playerUpdates.kt rename to modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/websocketBroadcast.kt