Add shop module

Author: madhead

README.adoc

@@ -12,6 +12,8 @@ Official Telegram bot of Java Professionals BY community.
 * Converts some currencies to EUR and USD
 * Posts scheduled messages from this repo's `posts` branch
 * Expand LeetCode links
+* Tell users' local times
+* Sell pins and custom statuses 🤑
 
 So, it just brings some fun and interactivity in our chat.
 

launchers/lambda/build.gradle.kts

@@ -24,4 +24,5 @@ dependencies {
     implementation(project.projects.leetcode)
     implementation(project.projects.times.timezones.dynamodb)
     implementation(project.projects.times)
+    implementation(project.projects.shop)
 }

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

@@ -17,6 +17,10 @@ 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.shop.PinsShopCommandUpdateProcessor
+import by.jprof.telegram.bot.shop.RichCommandUpdateProcessor
+import by.jprof.telegram.bot.shop.SupportCommandUpdateProcessor
+import by.jprof.telegram.bot.shop.TitleCommandUpdateProcessor
 import by.jprof.telegram.bot.times.TimeCommandUpdateProcessor
 import by.jprof.telegram.bot.times.TimeZoneCommandUpdateProcessor
 import by.jprof.telegram.bot.youtube.YouTubeUpdateProcessor
@@ -153,4 +157,28 @@ val pipelineModule = module {
             bot = get(),
         )
     }
+
+    single<UpdateProcessor>(named("PinsShopCommandUpdateProcessor")) {
+        PinsShopCommandUpdateProcessor(
+            bot = get(),
+        )
+    }
+
+    single<UpdateProcessor>(named("RichCommandUpdateProcessor")) {
+        RichCommandUpdateProcessor(
+            bot = get(),
+        )
+    }
+
+    single<UpdateProcessor>(named("TitleCommandUpdateProcessor")) {
+        TitleCommandUpdateProcessor(
+            bot = get(),
+        )
+    }
+
+    single<UpdateProcessor>(named("SupportCommandUpdateProcessor")) {
+        SupportCommandUpdateProcessor(
+            bot = get(),
+        )
+    }
 }

pins/src/main/kotlin/by/jprof/telegram/bot/pins/utils/messages.kt

@@ -3,6 +3,7 @@ package by.jprof.telegram.bot.pins.utils
 import java.text.ChoiceFormat
 import java.text.MessageFormat
 
+// TODO: Add a link to the `/pinshop` command here when it's ready
 private val helpMessages = listOf(
     """Эту команду нужно вызывать реплаем на какое\-нибудь сообщение\.
         |

settings.gradle.kts

@@ -35,4 +35,5 @@ include(":leetcode")
 include(":times:timezones")
 include(":times:timezones:dynamodb")
 include(":times")
+include(":shop")
 include(":launchers:lambda")

shop/README.adoc

@@ -0,0 +1,3 @@
+= Shop
+
+This feature allows users to buy link:../pins[pins] and custom titles.

shop/build.gradle.kts

@@ -0,0 +1,17 @@
+plugins {
+    kotlin("jvm")
+}
+
+dependencies {
+    api(project.projects.core)
+    api(libs.tgbotapi.core)
+    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)
+}

shop/src/main/kotlin/by/jprof/telegram/bot/shop/PinsShopCommandUpdateProcessor.kt

@@ -0,0 +1,33 @@
+package by.jprof.telegram.bot.shop
+
+import by.jprof.telegram.bot.core.UpdateProcessor
+import dev.inmo.tgbotapi.bot.RequestsExecutor
+import dev.inmo.tgbotapi.extensions.api.send.reply
+import dev.inmo.tgbotapi.extensions.utils.asBaseMessageUpdate
+import dev.inmo.tgbotapi.extensions.utils.asBotCommandTextSource
+import dev.inmo.tgbotapi.extensions.utils.asContentMessage
+import dev.inmo.tgbotapi.extensions.utils.asTextContent
+import dev.inmo.tgbotapi.types.ParseMode.MarkdownV2ParseMode
+import dev.inmo.tgbotapi.types.update.abstracts.Update
+import dev.inmo.tgbotapi.utils.PreviewFeature
+
+@OptIn(PreviewFeature::class)
+class PinsShopCommandUpdateProcessor(
+    private val bot: RequestsExecutor,
+) : UpdateProcessor {
+    override suspend fun process(update: Update) {
+        @Suppress("NAME_SHADOWING") val update = update.asBaseMessageUpdate() ?: return
+        val message = update.data.asContentMessage() ?: return
+        val text = message.content.asTextContent() ?: return
+
+        if (text.textSources.mapNotNull { it.asBotCommandTextSource() }.none { it.command == "pinsshop" || it.command == "pinshop" }) {
+            return
+        }
+
+        val reply = """
+            TODO: Sell pins
+        """.trimIndent().trim()
+
+        bot.reply(to = message, text = reply, parseMode = MarkdownV2ParseMode)
+    }
+}

shop/src/main/kotlin/by/jprof/telegram/bot/shop/RichCommandUpdateProcessor.kt

@@ -0,0 +1,33 @@
+package by.jprof.telegram.bot.shop
+
+import by.jprof.telegram.bot.core.UpdateProcessor
+import dev.inmo.tgbotapi.bot.RequestsExecutor
+import dev.inmo.tgbotapi.extensions.api.send.reply
+import dev.inmo.tgbotapi.extensions.utils.asBaseMessageUpdate
+import dev.inmo.tgbotapi.extensions.utils.asBotCommandTextSource
+import dev.inmo.tgbotapi.extensions.utils.asContentMessage
+import dev.inmo.tgbotapi.extensions.utils.asTextContent
+import dev.inmo.tgbotapi.types.ParseMode.MarkdownV2ParseMode
+import dev.inmo.tgbotapi.types.update.abstracts.Update
+import dev.inmo.tgbotapi.utils.PreviewFeature
+
+@OptIn(PreviewFeature::class)
+class RichCommandUpdateProcessor(
+    private val bot: RequestsExecutor,
+) : UpdateProcessor {
+    override suspend fun process(update: Update) {
+        @Suppress("NAME_SHADOWING") val update = update.asBaseMessageUpdate() ?: return
+        val message = update.data.asContentMessage() ?: return
+        val text = message.content.asTextContent() ?: return
+
+        if (text.textSources.mapNotNull { it.asBotCommandTextSource() }.none { it.command == "rich" || it.command == "vip" }) {
+            return
+        }
+
+        val reply = """
+            TODO: Sell "I AM RICH" \/ "V\.I\.P\." custom titles
+        """.trimIndent().trim()
+
+        bot.reply(to = message, text = reply, parseMode = MarkdownV2ParseMode)
+    }
+}

shop/src/main/kotlin/by/jprof/telegram/bot/shop/SupportCommandUpdateProcessor.kt

@@ -0,0 +1,33 @@
+package by.jprof.telegram.bot.shop
+
+import by.jprof.telegram.bot.core.UpdateProcessor
+import dev.inmo.tgbotapi.bot.RequestsExecutor
+import dev.inmo.tgbotapi.extensions.api.send.reply
+import dev.inmo.tgbotapi.extensions.utils.asBaseMessageUpdate
+import dev.inmo.tgbotapi.extensions.utils.asBotCommandTextSource
+import dev.inmo.tgbotapi.extensions.utils.asContentMessage
+import dev.inmo.tgbotapi.extensions.utils.asTextContent
+import dev.inmo.tgbotapi.types.ParseMode.MarkdownV2ParseMode
+import dev.inmo.tgbotapi.types.update.abstracts.Update
+import dev.inmo.tgbotapi.utils.PreviewFeature
+
+@OptIn(PreviewFeature::class)
+class SupportCommandUpdateProcessor(
+    private val bot: RequestsExecutor,
+) : UpdateProcessor {
+    override suspend fun process(update: Update) {
+        @Suppress("NAME_SHADOWING") val update = update.asBaseMessageUpdate() ?: return
+        val message = update.data.asContentMessage() ?: return
+        val text = message.content.asTextContent() ?: return
+
+        if (text.textSources.mapNotNull { it.asBotCommandTextSource() }.none { it.command == "support" }) {
+            return
+        }
+
+        val reply = """
+            TODO: Sell "Supporter" custom title
+        """.trimIndent().trim()
+
+        bot.reply(to = message, text = reply, parseMode = MarkdownV2ParseMode)
+    }
+}