EvalUpdateProcessor stub

Author: madhead

eval/build.gradle.kts

@@ -0,0 +1,18 @@
+plugins {
+    kotlin("jvm")
+}
+
+dependencies {
+    api(project.projects.core)
+    api(libs.tgbotapi.core)
+    implementation(project.projects.votes.tgbotapiExtensions)
+    implementation(libs.tgbotapi.extensions.api)
+    implementation(libs.tgbotapi.extensions.utils)
+    implementation(libs.log4j.api)
+
+    testImplementation(libs.junit.jupiter.api)
+    testImplementation(libs.junit.jupiter.params)
+    testImplementation(libs.mockk)
+    testRuntimeOnly(libs.junit.jupiter.engine)
+    testRuntimeOnly(libs.log4j.core)
+}

eval/src/main/kotlin/by/jprof/telegram/bot/eval/EvalUpdateProcessor.kt

@@ -0,0 +1,26 @@
+package by.jprof.telegram.bot.eval
+
+import by.jprof.telegram.bot.core.UpdateProcessor
+import dev.inmo.tgbotapi.extensions.utils.asBaseMessageUpdate
+import dev.inmo.tgbotapi.extensions.utils.asContentMessage
+import dev.inmo.tgbotapi.extensions.utils.asPreTextSource
+import dev.inmo.tgbotapi.extensions.utils.asTextContent
+import dev.inmo.tgbotapi.types.update.abstracts.Update
+import org.apache.logging.log4j.LogManager
+
+class EvalUpdateProcessor : UpdateProcessor {
+    companion object {
+        private val logger = LogManager.getLogger(EvalUpdateProcessor::class.java)!!
+    }
+
+    override suspend fun process(update: Update) {
+        val message = update.asBaseMessageUpdate() ?: return
+        val content = message.data.asContentMessage() ?: return
+        val text = content.content.asTextContent() ?: return
+        val codes = text.textSources.mapNotNull { it.asPreTextSource() }
+
+        codes.forEach {
+            logger.debug(it)
+        }
+    }
+}

runners/lambda/build.gradle.kts

@@ -15,4 +15,5 @@ dependencies {
     implementation(project.projects.kotlin.dynamodb)
     implementation(project.projects.dialogs.dynamodb)
     implementation(project.projects.quizoji.dynamodb)
+    implementation(project.projects.eval)
 }

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

@@ -2,10 +2,16 @@ package by.jprof.telegram.bot.runners.lambda.config
 
 import by.jprof.telegram.bot.core.UpdateProcessingPipeline
 import by.jprof.telegram.bot.core.UpdateProcessor
+import by.jprof.telegram.bot.eval.EvalUpdateProcessor
 import by.jprof.telegram.bot.jep.JEPUpdateProcessor
 import by.jprof.telegram.bot.jep.JsoupJEPSummary
 import by.jprof.telegram.bot.kotlin.KotlinMentionsUpdateProcessor
-import by.jprof.telegram.bot.quizoji.*
+import by.jprof.telegram.bot.quizoji.QuizojiDoneCommandUpdateProcessor
+import by.jprof.telegram.bot.quizoji.QuizojiInlineQueryUpdateProcessor
+import by.jprof.telegram.bot.quizoji.QuizojiOptionUpdateProcessor
+import by.jprof.telegram.bot.quizoji.QuizojiQuestionUpdateProcessor
+import by.jprof.telegram.bot.quizoji.QuizojiStartCommandUpdateProcessor
+import by.jprof.telegram.bot.quizoji.QuizojiVoteUpdateProcessor
 import by.jprof.telegram.bot.youtube.YouTubeUpdateProcessor
 import org.koin.core.qualifier.named
 import org.koin.dsl.module
@@ -83,4 +89,8 @@ val pipelineModule = module {
             bot = get(),
         )
     }
+
+    single<UpdateProcessor>(named("EvalUpdateProcessor")) {
+        EvalUpdateProcessor()
+    }
 }

settings.gradle.kts

@@ -20,4 +20,5 @@ include(":kotlin")
 include(":kotlin:dynamodb")
 include(":quizoji")
 include(":quizoji:dynamodb")
+include(":eval")
 include(":runners:lambda")