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

tidying up

Browse source
This commit is contained in:
Adam 2021-12-28 17:05:52 +01:00
parent 7813756c69
commit 08ab1c582c
24 changed files with 105 additions and 324 deletions
Download patch file Download diff file Expand all files Collapse all files

7
modules/events-processor/src/main/kotlin/dev/adamko/kafkatorio/processor/FactorioEventLogConsumer.kt
View file

@ -1,7 +0,0 @@
package dev.adamko.kafkatorio.processor
/**
* Process the raw messages from a server.
*/
class FactorioEventLogConsumer {
}

4
modules/events-processor/src/main/kotlin/dev/adamko/kafkatorio/processor/FactorioEventsTopology.kt
View file

@ -13,8 +13,8 @@ import org.apache.kafka.streams.kstream.Consumed
import org.apache.kafka.streams.kstream.Produced
class FactorioEventsTopology(
val websocketServer: WebsocketServer,
val builder: StreamsBuilder = StreamsBuilder(),
private val websocketServer: WebsocketServer,
private val builder: StreamsBuilder = StreamsBuilder(),
) {
private val sourceTopic = "factorio-server-log"

2
modules/events-processor/src/main/kotlin/dev/adamko/kafkatorio/processor/WebsocketServer.kt
View file

@ -47,7 +47,7 @@ class WebsocketServer {
messages.emit(msg)
}
suspend fun start(): PolyHandler = supervisorScope builder@{
suspend fun build(): PolyHandler = supervisorScope builder@{
coroutineContext.job.invokeOnCompletion { e ->
e?.let { serverJob.completeExceptionally(it) } ?: serverJob.complete()

8
modules/events-processor/src/main/kotlin/dev/adamko/kafkatorio/processor/config/ApplicationProperties.kt
View file

@ -1,19 +1,11 @@
package dev.adamko.kafkatorio.processor.config
import com.fasterxml.jackson.databind.JsonNode
import dev.adamko.kafkatorio.processor.config.PortVal.Companion.portVal
import java.io.StringReader
import java.time.Clock
import java.util.Properties
import org.http4k.cloudnative.env.Environment
import org.http4k.cloudnative.env.EnvironmentKey
import org.http4k.core.Credentials
import org.http4k.core.Uri
import org.http4k.format.Json
import org.http4k.lens.boolean
import org.http4k.lens.map
import org.http4k.lens.nonEmptyString
import org.http4k.lens.uri
/**
* Load properties, in descending priority order, from

15
modules/events-processor/src/main/kotlin/dev/adamko/kafkatorio/processor/eventProcessor.kt
View file

@ -15,18 +15,5 @@ fun main() = runBlocking {
val topology = FactorioEventsTopology(wsServer)
topology.build()
wsServer.start().asServer(Undertow(9073)).start().block()
wsServer.build().asServer(Undertow(9073)).start().block()
}
//
//
//// a standard websocket app
//val websocketServer = websockets(
// "/lua-objects" bind { ws: Websocket ->
// ws.send(WsMessage("bob"))
// ws.onMessage {
// println("server received: $it")
// ws.send(it)
// }
// }
//).asServer(Undertow(9097)).start()