Update gradle.properties

Update dependency dev.inmo:micro_utils.ktor.server to v0.16.2

ChatAvatarSetter/README.md

@@ -0,0 +1,9 @@
+# ChatAvatarSetter
+
+This bot will set the chat avatar based on the image sent to bot
+
+## Launch
+
+```bash
+../gradlew run --args="BOT_TOKEN"
+```

ChatAvatarSetter/build.gradle

@@ -0,0 +1,21 @@
+buildscript {
+    repositories {
+        mavenCentral()
+    }
+
+    dependencies {
+        classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version"
+    }
+}
+
+apply plugin: 'kotlin'
+apply plugin: 'application'
+
+mainClassName="ChatAvatarSetterKt"
+
+
+dependencies {
+    implementation "org.jetbrains.kotlin:kotlin-stdlib:$kotlin_version"
+
+    implementation "dev.inmo:tgbotapi:$telegram_bot_api_version"
+}

ChatAvatarSetter/src/main/kotlin/ChatAvatarSetter.kt

@@ -0,0 +1,36 @@
+import dev.inmo.micro_utils.coroutines.runCatchingSafely
+import dev.inmo.tgbotapi.bot.ktor.telegramBot
+import dev.inmo.tgbotapi.extensions.api.chat.modify.setChatPhoto
+import dev.inmo.tgbotapi.extensions.api.files.downloadFile
+import dev.inmo.tgbotapi.extensions.api.send.reply
+import dev.inmo.tgbotapi.extensions.behaviour_builder.buildBehaviourWithLongPolling
+import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onPhoto
+import dev.inmo.tgbotapi.extensions.utils.*
+import dev.inmo.tgbotapi.requests.abstracts.asMultipartFile
+import kotlinx.coroutines.*
+
+suspend fun main(args: Array<String>) {
+    val bot = telegramBot(args.first())
+
+    bot.buildBehaviourWithLongPolling(scope = CoroutineScope(Dispatchers.IO)) {
+        onPhoto {
+            val bytes = downloadFile(it.content)
+            runCatchingSafely {
+                setChatPhoto(
+                    it.chat.id,
+                    bytes.asMultipartFile("sample.jpg")
+                )
+            }.onSuccess { b ->
+                if (b) {
+                    reply(it, "Done")
+                } else {
+                    reply(it, "Something went wrong")
+                }
+            }.onFailure { e ->
+                e.printStackTrace()
+
+                reply(it, "Something went wrong (see logs)")
+            }
+        }
+    }.join()
+}

FSMBot/src/main/kotlin/SimpleFSMBot.kt

@@ -6,17 +6,21 @@ import dev.inmo.tgbotapi.extensions.behaviour_builder.*
 import dev.inmo.tgbotapi.extensions.behaviour_builder.expectations.*
 import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.*
 import dev.inmo.tgbotapi.extensions.utils.extensions.parseCommandsWithParams
+import dev.inmo.tgbotapi.extensions.utils.extensions.sameThread
 import dev.inmo.tgbotapi.extensions.utils.formatting.*
-import dev.inmo.tgbotapi.types.ChatId
+import dev.inmo.tgbotapi.types.IdChatIdentifier
+import dev.inmo.tgbotapi.types.MessageThreadId
 import dev.inmo.tgbotapi.types.message.abstracts.CommonMessage
 import dev.inmo.tgbotapi.types.message.content.TextContent
 import dev.inmo.tgbotapi.utils.botCommand
+import dev.inmo.tgbotapi.utils.extensions.threadIdOrNull
 import kotlinx.coroutines.*
+import kotlinx.coroutines.flow.filter
 import kotlinx.coroutines.flow.first
 
 sealed interface BotState : State
-data class ExpectContentOrStopState(override val context: ChatId, val sourceMessage: CommonMessage<TextContent>) : BotState
+data class ExpectContentOrStopState(override val context: IdChatIdentifier, val sourceMessage: CommonMessage<TextContent>) : BotState
-data class StopState(override val context: ChatId) : BotState
+data class StopState(override val context: IdChatIdentifier) : BotState
 
 suspend fun main(args: Array<String>) {
     val botToken = args.first()
@@ -39,12 +43,14 @@ suspend fun main(args: Array<String>) {
     ) {
         strictlyOn<ExpectContentOrStopState> {
             send(
-                it.context
+                it.context,
             ) {
                 +"Send me some content or " + botCommand("stop") + " if you want to stop sending"
             }
 
-            val contentMessage = waitContentMessage().first()
+            val contentMessage = waitContentMessage().filter { message ->
+                message.sameThread(it.sourceMessage)
+            }.first()
             val content = contentMessage.content
 
             when {
@@ -61,7 +67,9 @@ suspend fun main(args: Array<String>) {
             null
         }
 
-        command("start") {
+        command(
+            "start"
+        ) {
             startChain(ExpectContentOrStopState(it.chat.id, it))
         }
     }.second.join()

GetMeBot/src/main/kotlin/GetMeBot.kt

@@ -1,5 +1,16 @@
 import dev.inmo.tgbotapi.bot.ktor.telegramBot
 import dev.inmo.tgbotapi.extensions.api.bot.getMe
+import dev.inmo.tgbotapi.extensions.api.chat.forum.closeForumTopic
+import dev.inmo.tgbotapi.extensions.api.chat.forum.createForumTopic
+import dev.inmo.tgbotapi.extensions.api.chat.forum.deleteForumTopic
+import dev.inmo.tgbotapi.extensions.api.chat.forum.reopenForumTopic
+import dev.inmo.tgbotapi.extensions.behaviour_builder.buildBehaviour
+import dev.inmo.tgbotapi.extensions.behaviour_builder.buildBehaviourWithLongPolling
+import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onForumTopicClosed
+import dev.inmo.tgbotapi.types.ChatId
+import dev.inmo.tgbotapi.types.CustomEmojiId
+import dev.inmo.tgbotapi.types.ForumTopic
+import kotlinx.coroutines.delay
 
 /**
  * This is one of the most easiest bot - it will just print information about itself

ResenderBot/ResenderBotLib/src/commonMain/kotlin/ResenderBot.kt

@@ -8,6 +8,7 @@ import dev.inmo.tgbotapi.extensions.behaviour_builder.filters.CommonMessageFilte
 import dev.inmo.tgbotapi.extensions.behaviour_builder.filters.MessageFilterByChat
 import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.*
 import dev.inmo.tgbotapi.extensions.utils.shortcuts.*
+import dev.inmo.tgbotapi.utils.extensions.threadIdOrNull
 import kotlinx.coroutines.*
 
 suspend fun activateResenderBot(
@@ -20,33 +21,23 @@ suspend fun activateResenderBot(
 
     bot.buildBehaviourWithLongPolling(CoroutineScope(currentCoroutineContext() + SupervisorJob())) {
         onContentMessage(
-            initialFilter = CommonMessageFilterExcludeMediaGroups,
+            subcontextUpdatesFilter = MessageFilterByChat,
-            subcontextUpdatesFilter = MessageFilterByChat
         ) {
             val chat = it.chat
-            withTypingAction(chat) {
+
-                executeUnsafe(it.content.createResend(chat.id, replyToMessageId = it.messageId)) {
+            val answer = withTypingAction(chat) {
+                executeUnsafe(
+                    it.content.createResend(
+                        chat.id,
+                        messageThreadId = it.threadIdOrNull,
+                        replyToMessageId = it.messageId
+                    )
+                ) {
                     it.forEach(print)
                 }
             }
-        }
+
-        onVisualGallery {
+            println("Answer info: $answer")
-            val chat = it.chat ?: return@onVisualGallery
-            withUploadPhotoAction(chat) {
-                send(chat, it.map { it.content.toMediaGroupMemberTelegramMedia() })
-            }
-        }
-        onPlaylist {
-            val chat = it.chat ?: return@onPlaylist
-            withUploadDocumentAction(chat) {
-                send(chat, it.map { it.content.toMediaGroupMemberTelegramMedia() })
-            }
-        }
-        onDocumentsGroup {
-            val chat = it.chat ?: return@onDocumentsGroup
-            withUploadDocumentAction(chat) {
-                send(chat, it.map { it.content.toMediaGroupMemberTelegramMedia() })
-            }
         }
 
         allUpdatesFlow.subscribeSafelyWithoutExceptions(this) {

TopicsHandling/README.md

@@ -0,0 +1,9 @@
+# HelloBot
+
+The main purpose of this bot is just to answer "Oh, hi, " and add user mention here
+
+## Launch
+
+```bash
+../gradlew run --args="BOT_TOKEN"
+```

TopicsHandling/build.gradle

@@ -0,0 +1,21 @@
+buildscript {
+    repositories {
+        mavenCentral()
+    }
+
+    dependencies {
+        classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version"
+    }
+}
+
+apply plugin: 'kotlin'
+apply plugin: 'application'
+
+mainClassName="TopicsHandlingKt"
+
+
+dependencies {
+    implementation "org.jetbrains.kotlin:kotlin-stdlib:$kotlin_version"
+
+    implementation "dev.inmo:tgbotapi:$telegram_bot_api_version"
+}

TopicsHandling/src/main/kotlin/TopicsHandling.kt

@@ -0,0 +1,145 @@
+import com.benasher44.uuid.uuid4
+import dev.inmo.micro_utils.common.repeatOnFailure
+import dev.inmo.micro_utils.coroutines.runCatchingSafely
+import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions
+import dev.inmo.tgbotapi.extensions.api.bot.setMyCommands
+import dev.inmo.tgbotapi.extensions.api.chat.forum.closeForumTopic
+import dev.inmo.tgbotapi.extensions.api.chat.forum.closeGeneralForumTopic
+import dev.inmo.tgbotapi.extensions.api.chat.forum.createForumTopic
+import dev.inmo.tgbotapi.extensions.api.chat.forum.deleteForumTopic
+import dev.inmo.tgbotapi.extensions.api.chat.forum.editForumTopic
+import dev.inmo.tgbotapi.extensions.api.chat.forum.editGeneralForumTopic
+import dev.inmo.tgbotapi.extensions.api.chat.forum.hideGeneralForumTopic
+import dev.inmo.tgbotapi.extensions.api.chat.forum.reopenForumTopic
+import dev.inmo.tgbotapi.extensions.api.chat.forum.reopenGeneralForumTopic
+import dev.inmo.tgbotapi.extensions.api.chat.forum.unhideGeneralForumTopic
+import dev.inmo.tgbotapi.extensions.api.send.reply
+import dev.inmo.tgbotapi.extensions.behaviour_builder.telegramBotWithBehaviourAndLongPolling
+import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onCommand
+import dev.inmo.tgbotapi.extensions.utils.updates.retrieving.flushAccumulatedUpdates
+import dev.inmo.tgbotapi.types.BotCommand
+import dev.inmo.tgbotapi.types.ForumTopic
+import dev.inmo.tgbotapi.types.commands.BotCommandScope
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.delay
+
+suspend fun main(vararg args: String) {
+    telegramBotWithBehaviourAndLongPolling(
+        args.first(),
+        CoroutineScope(Dispatchers.Default),
+        defaultExceptionsHandler = {
+            it.printStackTrace()
+        }
+    ) {
+        flushAccumulatedUpdates()
+        allUpdatesFlow.subscribeSafelyWithoutExceptions(this) {
+            println(it)
+        }
+        onCommand("start_test_topics") {
+            val forumTopic = createForumTopic(
+                it.chat,
+                "Test",
+                ForumTopic.GREEN
+            )
+
+            reply(it, "Test topic has been created")
+
+            delay(1000L)
+            editForumTopic(
+                it.chat.id,
+                forumTopic.messageThreadId,
+                "Test 01"
+            )
+
+            reply(it, "Test topic has changed its name to Test 01")
+
+            delay(1000L)
+            closeForumTopic(
+                it.chat.id,
+                forumTopic.messageThreadId,
+            )
+
+            reply(it, "Test topic has been closed")
+
+            delay(1000L)
+            reopenForumTopic(
+                it.chat.id,
+                forumTopic.messageThreadId,
+            )
+
+            reply(it, "Test topic has been reopened")
+
+            delay(1000L)
+            deleteForumTopic(
+                it.chat.id,
+                forumTopic.messageThreadId,
+            )
+
+            reply(it, "Test topic has been deleted")
+
+            delay(1000L)
+            hideGeneralForumTopic(
+                it.chat.id,
+            )
+
+            reply(it, "General topic has been hidden")
+
+            delay(1000L)
+            unhideGeneralForumTopic(
+                it.chat.id
+            )
+
+            reply(it, "General topic has been shown")
+
+            delay(1000L)
+            runCatchingSafely(
+                { _ ->
+                    reopenGeneralForumTopic(
+                        it.chat.id
+                    )
+
+                    closeGeneralForumTopic(
+                        it.chat.id
+                    )
+                }
+            ) {
+                closeGeneralForumTopic(
+                    it.chat.id
+                )
+            }
+
+            reply(it, "General topic has been closed")
+
+            delay(1000L)
+            reopenGeneralForumTopic(
+                it.chat.id
+            )
+
+            reply(it, "General topic has been opened")
+
+            delay(1000L)
+            editGeneralForumTopic(
+                it.chat.id,
+                uuid4().toString().take(10)
+            )
+
+            reply(it, "General topic has been renamed")
+
+            delay(1000L)
+            editGeneralForumTopic(
+                it.chat.id,
+                "Main topic"
+            )
+
+            reply(it, "General topic has been renamed")
+
+            delay(1000L)
+        }
+
+        setMyCommands(
+            BotCommand("start_test_topics", "start test topics"),
+            scope = BotCommandScope.AllGroupChats
+        )
+    }.second.join()
+}

build.gradle

@@ -22,5 +22,7 @@ allprojects {
                 }
             }
         }
+
+        maven { url "https://git.inmo.dev/api/packages/InsanusMokrassar/maven" }
     }
 }

gradle.properties

@@ -4,8 +4,8 @@ org.gradle.parallel=true
 org.gradle.jvmargs=-Xmx768m
 
 
-kotlin_version=1.7.20
+kotlin_version=1.7.22
-telegram_bot_api_version=3.3.0
+telegram_bot_api_version=5.0.0
-micro_utils_version=0.13.1
+micro_utils_version=0.16.4
 serialization_version=1.4.1
-ktor_version=2.1.2
+ktor_version=2.2.1

gradle/wrapper/gradle-wrapper.properties

@@ -2,4 +2,4 @@ distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-7.5.1-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-7.6-bin.zip

settings.gradle

@@ -21,6 +21,10 @@ include ":StickerInfoBot:jvm_launcher"
 
 include ":SlotMachineDetectorBot"
 
+include ":ChatAvatarSetter"
+
 include ":WebApp"
 
 include ":FSMBot"
+
+include ":TopicsHandling"