echo bot code

Author: wtsiamruk

telegram-bot/src/main/kotlin/by/jprof/coding/problems/bot/config/ApplicationConfiguration.kt

@@ -1,5 +1,11 @@
 package by.jprof.coding.problems.bot.config
 
+import dev.inmo.tgbotapi.bot.Ktor.telegramBot
+import dev.inmo.tgbotapi.bot.RequestsExecutor
+import dev.inmo.tgbotapi.bot.TelegramBot
+import dev.inmo.tgbotapi.types.message.abstracts.ContentMessage
+import dev.inmo.tgbotapi.types.message.abstracts.Message
+import dev.inmo.tgbotapi.types.message.content.TextContent
 import io.r2dbc.spi.ConnectionFactories
 import io.r2dbc.spi.ConnectionFactory
 import org.springframework.context.annotation.Bean
@@ -10,8 +16,18 @@ import org.springframework.data.r2dbc.repository.config.EnableR2dbcRepositories
 @Configuration
 @EnableR2dbcRepositories
 class ApplicationConfiguration : AbstractR2dbcConfiguration() {
+    companion object {
+        val BOT_TOKEN = System.getenv("BOT_TOKEN")!!
+    }
     @Bean
     override fun connectionFactory() : ConnectionFactory {
         return ConnectionFactories.get(System.getenv("DB_URL"))
     }
-}
+
+    @Bean
+    fun tgBot() : TelegramBot {
+        return telegramBot(BOT_TOKEN)
+    }
+}
+
+val Message.text get() = ((this as? ContentMessage<*>)?.content as? TextContent)?.text

telegram-bot/src/main/kotlin/by/jprof/coding/problems/bot/hook/WebhookListener.kt

@@ -0,0 +1,24 @@
+package by.jprof.coding.problems.bot.hook
+
+import by.jprof.coding.problems.bot.service.TgUpdateHandlingService
+import dev.inmo.tgbotapi.types.update.abstracts.Update
+import org.springframework.http.HttpStatus
+import org.springframework.http.MediaType
+import org.springframework.web.bind.annotation.RequestMapping
+import org.springframework.web.bind.annotation.RequestMethod
+import org.springframework.web.bind.annotation.ResponseStatus
+import org.springframework.web.bind.annotation.RestController
+import reactor.core.publisher.Mono
+
+@RestController
+@RequestMapping("/")
+class WebhookListener(private val tgUpdateHandlingService: TgUpdateHandlingService) {
+
+    @RequestMapping(method = [RequestMethod.POST], produces = [MediaType.APPLICATION_JSON_VALUE])
+    @ResponseStatus(HttpStatus.OK)
+    suspend fun processUpdate(update: Update) : Mono<String> {
+        tgUpdateHandlingService.handleUpdate(update);
+        return Mono.just("{}")
+    }
+
+}

telegram-bot/src/main/kotlin/by/jprof/coding/problems/bot/service/TgUpdateHandlingService.kt

@@ -0,0 +1,21 @@
+package by.jprof.coding.problems.bot.service
+
+import by.jprof.coding.problems.bot.config.text
+import dev.inmo.tgbotapi.bot.TelegramBot
+import dev.inmo.tgbotapi.extensions.api.send.sendMessage
+import dev.inmo.tgbotapi.types.update.MessageUpdate
+import dev.inmo.tgbotapi.types.update.abstracts.Update
+import org.springframework.stereotype.Service
+
+@Service
+class TgUpdateHandlingService(private val telegramBot: TelegramBot) {
+    suspend fun handleUpdate(update: Update) {
+        if (update is MessageUpdate) {
+            update.data.text?.let {
+                telegramBot.sendMessage(update.data.chat.id, it)
+            }
+        }
+    }
+}
+
+

telegram-bot/src/main/resources/application.yml

@@ -1,8 +1,6 @@
 spring:
   application:
     name: coding-problems-bot
-
-=DEBUG
 logging:
   level:
     root: ${LOG_LEVEL:ERROR}