tidy up code

This commit is contained in:
Adam 2022-04-20 17:54:54 +02:00
parent b0a6151c36
commit 2287582880
2 changed files with 1 additions and 23 deletions

View file

@ -56,31 +56,9 @@ fun groupMapChunks(builder: StreamsBuilder): Topology {
val mapChunksStream: KStream<FactorioServerId, MapChunkUpdate> = builder.streamPacketData() val mapChunksStream: KStream<FactorioServerId, MapChunkUpdate> = builder.streamPacketData()
val protosStream: KStream<FactorioServerId, PrototypesUpdate> = builder.streamPacketData() val protosStream: KStream<FactorioServerId, PrototypesUpdate> = builder.streamPacketData()
// val protosStream: KStream<FactorioServerId, KafkatorioPacket2> =
// builder.stream<FactorioServerId?, KafkatorioPacket2?>(
// prototypesTopicName,
// consumedAs("consume.factorio-protos.all", jsonMapper.serde(), jsonMapper.serde())
// ).filter { key: FactorioServerId?, value: KafkatorioPacket2? ->
// key != null
// && value != null
// && value.data ==
// }
// .map
val tileProtoColourDict: KTable<FactorioServerId, TileColourDict> = val tileProtoColourDict: KTable<FactorioServerId, TileColourDict> =
tileProtoColourDictionary(protosStream) tileProtoColourDictionary(protosStream)
// val mapChunksUpdatesStream: KStream<FactorioServerId, FactorioEventUpdatePacket> =
// builder.stream(
// mapChunkUpdatesTopicName,
// consumedAs(
// "consume.map-chunk-updates",
// jsonMapper.serde<FactorioServerId>(),
// jsonMapper.serde<FactorioEventUpdatePacket>(),
// )
// )
val groupedMapChunkTiles: KTable<ServerMapChunkId, ServerMapChunkTiles<ColourHex>> = val groupedMapChunkTiles: KTable<ServerMapChunkId, ServerMapChunkTiles<ColourHex>> =
groupTilesIntoChunksWithColours( groupTilesIntoChunksWithColours(
mapChunksStream, mapChunksStream,

View file

@ -7,7 +7,7 @@ import kotlinx.serialization.Serializable
@JvmInline @JvmInline
@Serializable @Serializable
value class FactorioServerId(val id: String) { value class FactorioServerId(private val id: String) {
override fun toString() = id override fun toString() = id
} }