Redirect users to the PM chat for quizojis

Author: madhead

quizoji/build.gradle.kts

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

quizoji/src/main/kotlin/by/jprof/telegram/bot/quizoji/QuizojiUpdateProcessor.kt

@@ -0,0 +1,28 @@
+package by.jprof.telegram.bot.quizoji
+
+import by.jprof.telegram.bot.core.UpdateProcessor
+import dev.inmo.tgbotapi.bot.RequestsExecutor
+import dev.inmo.tgbotapi.extensions.api.answers.answerInlineQuery
+import dev.inmo.tgbotapi.extensions.utils.asInlineQueryUpdate
+import dev.inmo.tgbotapi.types.update.abstracts.Update
+import org.apache.logging.log4j.LogManager
+
+class QuizojiUpdateProcessor(
+    private val bot: RequestsExecutor,
+) : UpdateProcessor {
+    companion object {
+        private val logger = LogManager.getLogger(QuizojiUpdateProcessor::class.java)!!
+    }
+
+    override suspend fun process(update: Update) {
+        val inlineQuery = update.asInlineQueryUpdate()?.data ?: return
+
+        if (inlineQuery.query.equals("quizoji", ignoreCase = true)) {
+            bot.answerInlineQuery(
+                inlineQuery = inlineQuery,
+                switchPmText = "Create new quizoji",
+                switchPmParameter = "quizoji",
+            )
+        }
+    }
+}

quizoji/src/test/kotlin/by/jprof/telegram/bot/quizoji/QuizojiUpdateProcessorTest.kt

@@ -0,0 +1,89 @@
+package by.jprof.telegram.bot.quizoji
+
+import dev.inmo.tgbotapi.bot.RequestsExecutor
+import dev.inmo.tgbotapi.extensions.api.answers.answerInlineQuery
+import dev.inmo.tgbotapi.types.InlineQueries.query.BaseInlineQuery
+import dev.inmo.tgbotapi.types.update.InlineQueryUpdate
+import dev.inmo.tgbotapi.types.update.MessageUpdate
+import io.mockk.*
+import io.mockk.impl.annotations.MockK
+import io.mockk.junit5.MockKExtension
+import kotlinx.coroutines.runBlocking
+import org.junit.jupiter.api.BeforeEach
+import org.junit.jupiter.api.Test
+import org.junit.jupiter.api.extension.ExtendWith
+
+@ExtendWith(MockKExtension::class)
+internal class QuizojiUpdateProcessorTest {
+    @MockK(relaxed = true)
+    private lateinit var bot: RequestsExecutor
+
+    lateinit var sut: QuizojiUpdateProcessor
+
+    @BeforeEach
+    fun setUp() {
+        sut = QuizojiUpdateProcessor(
+            bot = bot,
+        )
+    }
+
+    @Test
+    fun processNonInilineQuery() = runBlocking {
+        sut.process(
+            MessageUpdate(
+                updateId = 1L,
+                data = mockk()
+            )
+        )
+
+        verify { listOf(bot) wasNot called }
+
+        clearAllMocks()
+    }
+
+    @Test
+    fun processAlienInilineQuery() = runBlocking {
+        sut.process(
+            InlineQueryUpdate(
+                updateId = 1L,
+                data = BaseInlineQuery(
+                    id = "1",
+                    from = mockk(),
+                    query = "alien",
+                    offset = "",
+                )
+            )
+        )
+
+        verify { listOf(bot) wasNot called }
+
+        clearAllMocks()
+    }
+
+    @Test
+    fun processQuizojiInilineQuery() = runBlocking {
+        val inlineQuery = BaseInlineQuery(
+            id = "1",
+            from = mockk(),
+            query = "quizoji",
+            offset = "",
+        )
+
+        sut.process(
+            InlineQueryUpdate(
+                updateId = 1L,
+                data = inlineQuery
+            )
+        )
+
+        coVerify(exactly = 1) {
+            bot.answerInlineQuery(
+                inlineQuery = inlineQuery,
+                switchPmText = "Create new quizoji",
+                switchPmParameter = "quizoji",
+            )
+        }
+
+        clearAllMocks()
+    }
+}

runners/lambda/build.gradle.kts

@@ -13,4 +13,5 @@ dependencies {
     implementation(project.projects.jep)
     implementation(project.projects.youtube.dynamodb)
     implementation(project.projects.kotlin.dynamodb)
+    implementation(project.projects.quizoji)
 }

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

@@ -5,6 +5,7 @@ import by.jprof.telegram.bot.core.UpdateProcessor
 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.QuizojiUpdateProcessor
 import by.jprof.telegram.bot.youtube.YouTubeUpdateProcessor
 import org.koin.core.qualifier.named
 import org.koin.dsl.module
@@ -37,4 +38,10 @@ val pipelineModule = module {
             bot = get(),
         )
     }
+
+    single<UpdateProcessor>(named("QuizojiUpdateProcessor")) {
+        QuizojiUpdateProcessor(
+            bot = get(),
+        )
+    }
 }

settings.gradle.kts

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