Dummy update processor

Author: madhead

core/build.gradle.kts

@@ -1,3 +1,8 @@
 plugins {
     kotlin("jvm")
 }
+
+dependencies {
+    api(libs.bundles.tgbotapi)
+    implementation(libs.log4j.api)
+}

core/src/main/kotlin/by/jprof/telegram/bot/core/DummyUpdateProcessor.kt

@@ -0,0 +1,14 @@
+package by.jprof.telegram.bot.core
+
+import dev.inmo.tgbotapi.types.update.abstracts.Update
+import org.apache.logging.log4j.LogManager
+
+class DummyUpdateProcessor : UpdateProcessor {
+    companion object {
+        private val logger = LogManager.getLogger(DummyUpdateProcessor::class.java)
+    }
+
+    override suspend fun process(update: Update) {
+        logger.debug("Doing nothing with {}", update)
+    }
+}

core/src/main/kotlin/by/jprof/telegram/bot/core/UpdateProcessingPipeline.kt

@@ -0,0 +1,29 @@
+package by.jprof.telegram.bot.core
+
+import dev.inmo.tgbotapi.types.update.abstracts.Update
+import kotlinx.coroutines.CoroutineExceptionHandler
+import kotlinx.coroutines.joinAll
+import kotlinx.coroutines.launch
+import kotlinx.coroutines.runBlocking
+import kotlinx.coroutines.supervisorScope
+import org.apache.logging.log4j.LogManager
+
+class UpdateProcessingPipeline(
+        private val processors: List<UpdateProcessor>
+) {
+    companion object {
+        private val logger = LogManager.getLogger(UpdateProcessingPipeline::class.java)!!
+    }
+
+    fun process(update: Update) = runBlocking {
+        supervisorScope {
+            processors
+                    .map { launch(exceptionHandler(it)) { it.process(update) } }
+                    .joinAll()
+        }
+    }
+
+    private fun exceptionHandler(updateProcessor: UpdateProcessor) = CoroutineExceptionHandler { _, exception ->
+        logger.error("{} failed!", updateProcessor::class.simpleName, exception)
+    }
+}

core/src/main/kotlin/by/jprof/telegram/bot/core/UpdateProcessor.kt

@@ -0,0 +1,7 @@
+package by.jprof.telegram.bot.core
+
+import dev.inmo.tgbotapi.types.update.abstracts.Update
+
+interface UpdateProcessor {
+    suspend fun process(update: Update)
+}

gradle/libs.versions.toml

@@ -6,6 +6,8 @@ aws-lambda-java-core = "1.2.1"
 aws-lambda-java-log4j2 = "1.2.0"
 awssdk = "2.16.43"
 
+koin = "3.0.1"
+
 jackson = "2.12.3"
 
 tgbotapi = "0.33.3"
@@ -23,10 +25,13 @@ aws-lambda-java-core = { group = "com.amazonaws", name = "aws-lambda-java-core",
 aws-lambda-java-log4j2 = { group = "com.amazonaws", name = "aws-lambda-java-log4j2", version.ref = "aws-lambda-java-log4j2" }
 dynamodb = { group = "software.amazon.awssdk", name = "dynamodb", version.ref = "awssdk" }
 
+koin-core = { group = "io.insert-koin", name = "koin-core", version.ref = "koin" }
+
 jackson-databind = { group = "com.fasterxml.jackson.core", name = "jackson-databind", version.ref = "jackson" }
 
 tgbotapi-core = { group = "dev.inmo", name = "tgbotapi.core", version.ref = "tgbotapi" }
 
+log4j-api = { group = "org.apache.logging.log4j", name = "log4j-api", version.ref = "log4j" }
 log4j-core = { group = "org.apache.logging.log4j", name = "log4j-core", version.ref = "log4j" }
 log4j-slf4j-impl = { group = "org.apache.logging.log4j", name = "log4j-slf4j-impl", version.ref = "log4j" }
 

runners/lambda/build.gradle.kts

@@ -5,6 +5,8 @@ plugins {
 
 dependencies {
     implementation(libs.bundles.aws.lambda)
+    implementation(libs.koin.core)
     implementation(libs.bundles.tgbotapi)
     implementation(libs.bundles.log4j)
+    implementation(project(":core"))
 }

runners/lambda/src/main/kotlin/by/jprof/telegram/bot/runners/lambda/JProf.kt

@@ -1,17 +1,51 @@
 package by.jprof.telegram.bot.runners.lambda
 
+import by.jprof.telegram.bot.core.UpdateProcessingPipeline
+import by.jprof.telegram.bot.runners.lambda.config.envModule
+import by.jprof.telegram.bot.runners.lambda.config.pipelineModule
 import com.amazonaws.services.lambda.runtime.Context
 import com.amazonaws.services.lambda.runtime.RequestHandler
 import com.amazonaws.services.lambda.runtime.events.APIGatewayV2HTTPEvent
 import com.amazonaws.services.lambda.runtime.events.APIGatewayV2HTTPResponse
+import dev.inmo.tgbotapi.types.update.abstracts.UpdateDeserializationStrategy
+import kotlinx.serialization.json.Json
+import org.apache.logging.log4j.LogManager
+import org.koin.core.component.KoinComponent
+import org.koin.core.component.inject
+import org.koin.core.context.startKoin
 
 @Suppress("unused")
-class JProf : RequestHandler<APIGatewayV2HTTPEvent, APIGatewayV2HTTPResponse> {
-    override fun handleRequest(input: APIGatewayV2HTTPEvent, context: Context): APIGatewayV2HTTPResponse {
-        return APIGatewayV2HTTPResponse
+class JProf : RequestHandler<APIGatewayV2HTTPEvent, APIGatewayV2HTTPResponse>, KoinComponent {
+    companion object {
+        private val logger = LogManager.getLogger(JProf::class.java)
+        private val OK = APIGatewayV2HTTPResponse
                 .builder()
                 .withStatusCode(200)
-                .withBody("Hello, world!")
+                .withHeaders(mapOf(
+                        "Content-Type" to "application/json"
+                ))
+                .withBody("{}")
                 .build()
     }
+
+    init {
+        startKoin {
+            modules(envModule, pipelineModule)
+        }
+    }
+
+    private val json: Json by inject()
+    private val pipeline: UpdateProcessingPipeline by inject()
+
+    override fun handleRequest(input: APIGatewayV2HTTPEvent, context: Context): APIGatewayV2HTTPResponse {
+        logger.debug("Incoming request: {}", input)
+
+        val update = json.decodeFromString(UpdateDeserializationStrategy, input.body ?: return OK)
+
+        logger.debug("Parsed update: {}", update)
+
+        pipeline.process(update)
+
+        return OK
+    }
 }

runners/lambda/src/main/kotlin/by/jprof/telegram/bot/runners/lambda/config/env.kt

@@ -0,0 +1,12 @@
+package by.jprof.telegram.bot.runners.lambda.config
+
+import org.koin.core.qualifier.named
+import org.koin.dsl.module
+
+val envModule = module {
+    emptyList<String>().forEach { variable ->
+        single(named(variable)) {
+            System.getenv(variable)!!
+        }
+    }
+}

runners/lambda/src/main/kotlin/by/jprof/telegram/bot/runners/lambda/config/pipeline.kt

@@ -0,0 +1,17 @@
+package by.jprof.telegram.bot.runners.lambda.config
+
+import by.jprof.telegram.bot.core.DummyUpdateProcessor
+import by.jprof.telegram.bot.core.UpdateProcessingPipeline
+import by.jprof.telegram.bot.core.UpdateProcessor
+import org.koin.core.qualifier.named
+import org.koin.dsl.module
+
+val pipelineModule = module {
+    single {
+        UpdateProcessingPipeline(getAll())
+    }
+
+    single<UpdateProcessor>(named("DummyUpdateProcessor")) {
+        DummyUpdateProcessor()
+    }
+}

settings.gradle.kts

@@ -5,4 +5,5 @@ rootProject.name = "jprof_by_bot"
 include(":utils:dynamodb")
 include(":votes")
 include(":votes:dynamodb")
+include(":core")
 include(":runners:lambda")