Update kotlin_version to v1.6.20

.github/workflows/build.yml

@@ -8,13 +8,9 @@ jobs:
 
     steps:
       - uses: actions/checkout@v2
-      - name: Install dependencies
-        run: |
-          sudo apt update
-          sudo apt install -y libcurl4-openssl-dev
-      - name: Set up JDK 17
+      - name: Set up JDK 1.8
         uses: actions/setup-java@v1
         with:
-          java-version: 17
+          java-version: 1.8
       - name: Build with Gradle
-        run: ./gradlew build --no-daemon
+        run: ./gradlew build

.gitignore

@@ -1,5 +1,4 @@
 .idea
-.kotlin
 out/*
 *.iml
 target
@@ -11,6 +10,3 @@ build/
 out/
 
 kotlin-js-store/
-
-local.*
-local.*/

.template/bot/.env

@@ -1,2 +0,0 @@
-title=$prompt
-subtitle=Subtitle of {{$title}}

.template/bot/{{$title}}/README.md

@@ -1,9 +0,0 @@
-# {{$title}}
-
-
-
-## Launch
-
-```bash
-../gradlew run --args="BOT_TOKEN"
-```

.template/bot/{{$title}}/build.gradle

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

.template/bot/{{$title}}/src/main/kotlin/{{$title}}.kt

@@ -1,34 +0,0 @@
-import dev.inmo.kslog.common.KSLog
-import dev.inmo.kslog.common.LogLevel
-import dev.inmo.kslog.common.defaultMessageFormatter
-import dev.inmo.kslog.common.setDefaultKSLog
-import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions
-import dev.inmo.tgbotapi.extensions.api.bot.getMe
-import dev.inmo.tgbotapi.extensions.behaviour_builder.telegramBotWithBehaviourAndLongPolling
-import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.Dispatchers
-
-/**
- * This place can be the playground for your code.
- */
-suspend fun main(vararg args: String) {
-    val botToken = args.first()
-
-    val isDebug = args.any { it == "debug" }
-
-    if (isDebug) {
-        setDefaultKSLog(
-            KSLog { level: LogLevel, tag: String?, message: Any, throwable: Throwable? ->
-                println(defaultMessageFormatter(level, tag, message, throwable))
-            }
-        )
-    }
-
-    telegramBotWithBehaviourAndLongPolling(botToken, CoroutineScope(Dispatchers.IO)) {
-        // start here!!
-        val me = getMe()
-        println(me)
-
-        allUpdatesFlow.subscribeSafelyWithoutExceptions(this) { println(it) }
-    }.second.join()
-}

.template/module_generator.main.kts

@@ -1,208 +0,0 @@
-#!/usr/bin/env kotlin
-/**
- * Generates files and folders as they have been put in the folder. Envs uses common syntax, but
- * values may contains {{${'$'}sampleVariable}} parts, where {{${'$'}sampleVariable}} will be replaced with variable value.
- * Example:
- *
- * .env:
- * sampleVariable=${'$'}prompt # require request from command line
- *         sampleVariable2=just some value
- * sampleVariable3=${'$'}{sampleVariable}.${'$'}{sampleVariable2}
- *
- * Result variables:
- * sampleVariable=your input in console # lets imagine you typed it
- * sampleVariable2=just some value
- * sampleVariable3=your input in console.just some value
- *
- * To use these variables in template, you will need to write {{${'$'}sampleVariable}}.
- * You may use it in text of files as well as in files/folders names.
- *
- * Usage: kotlin generator.kts [args] folders...
- * Args:
- * -e, --env: Path to file with args for generation; Use "${'$'}prompt" as values to read variable value from console
- * -o, --outputFolder: Folder where templates should be used. Folder of calling by default
- *         folders: Folders-templates
- */
-import java.io.File
-
-val console = System.console()
-
-fun String.replaceWithVariables(envs: Map<String, String>): String {
-    var currentString = this
-    var changed = false
-
-    do {
-        changed = false
-        envs.forEach { (k, v) ->
-            val previousString = currentString
-            currentString = currentString.replace("{{$${k}}}", v)
-            changed = changed || currentString != previousString
-        }
-    } while (changed)
-
-    return currentString
-}
-
-fun requestVariable(variableName: String, defaultValue: String?): String {
-    console.printf("Enter value for variable $variableName${defaultValue ?.let { " [$it]" } ?: ""}: ")
-    return console.readLine().ifEmpty { defaultValue } ?: ""
-}
-
-fun readEnvs(content: String, presets: Map<String, String>): Map<String, String> {
-    val initialEnvs = mutableMapOf<String, String>()
-    content.split("\n").forEach {
-        val withoutComment = it.replace(Regex("\\#.*"), "")
-
-        runCatching {
-            val (key, value) = withoutComment.split("=")
-            val existsValue = presets[key]
-            if (value == "\$prompt") {
-                initialEnvs[key] = requestVariable(key, existsValue)
-            } else {
-                initialEnvs[key] = requestVariable(key, value.replaceWithVariables(initialEnvs))
-            }
-        }
-    }
-    var i = 0
-    val readEnvs = initialEnvs.toMutableMap()
-    while (i < readEnvs.size) {
-        val key = readEnvs.keys.elementAt(i)
-        val currentValue = readEnvs.getValue(key)
-        val withReplaced = currentValue.replaceWithVariables(readEnvs)
-        var changed = false
-        if (withReplaced != currentValue) {
-            i = 0
-            readEnvs[key] = withReplaced
-        } else {
-            i++
-        }
-    }
-    return presets + readEnvs
-}
-
-var envFile: File? = null
-var outputFolder: File = File("./") // current folder by default
-val templatesFolders = mutableListOf<File>()
-var extensions: List<String>? = null
-
-fun readParameters() {
-    var i = 0
-    while (i < args.size) {
-        val arg = args[i]
-        when (arg) {
-            "--env",
-            "-e" -> {
-                i++
-                envFile = File(args[i])
-            }
-            "--extensions",
-            "-ex" -> {
-                i++
-                extensions = args[i].split(",")
-            }
-            "--outputFolder",
-            "-o" -> {
-                i++
-                outputFolder = File(args[i])
-            }
-            "--help",
-            "-h" -> {
-                println("""
-                    Generates files and folders as the have been put in the folder. Envs uses common syntax, but
-                    values may contains {{${'$'}sampleVariable}} parts, where {{${'$'}sampleVariable}} will be replaced with variable value.
-                    Example:
-                    
-                    .env:
-                    sampleVariable=${'$'}prompt # require request from command line
-                    sampleVariable2=just some value
-                    sampleVariable3=${'$'}{sampleVariable}.${'$'}{sampleVariable2}
-                    
-                    Result variables:
-                    sampleVariable=your input in console # lets imagine you typed it
-                    sampleVariable2=just some value
-                    sampleVariable3=your input in console.just some value
-                    
-                    To use these variables in template, you will need to write {{${'$'}sampleVariable}}.
-                    You may use it in text of files as well as in files/folders names.
-                    
-                    Usage: kotlin generator.kts [args] folders...
-                    Args:
-                        -e, --env: Path to file with args for generation; Use "${'$'}prompt" as values to read variable value from console
-                        -o, --outputFolder: Folder where templates should be used. Folder of calling by default
-                        folders: Folders-templates
-                """.trimIndent())
-                Runtime.getRuntime().exit(0)
-            }
-            else -> {
-                val potentialFile = File(arg)
-                println("Potential file/folder as template: ${potentialFile.absolutePath}")
-                runCatching {
-                    if (potentialFile.exists()) {
-                        println("Adding file/folder as template: ${potentialFile.absolutePath}")
-                        templatesFolders.add(potentialFile)
-                    }
-                }.onFailure { e ->
-                    println("Unable to use folder $arg as template folder")
-                    e.printStackTrace()
-                }
-            }
-        }
-        i++
-    }
-}
-
-readParameters()
-
-val envs: MutableMap<String, String> = envFile ?.let { readEnvs(it.readText(), emptyMap()) } ?.toMutableMap() ?: mutableMapOf()
-
-println(
-    """
-    Result environments:
-        ${envs.toList().joinToString("\n        ") { (k, v) -> "$k=$v" }}
-    Result extensions:
-        ${extensions ?.joinToString()}
-    Input folders:
-        ${templatesFolders.joinToString("\n        ") { it.absolutePath }}
-    Output folder:
-        ${outputFolder.absolutePath}
-    """.trimIndent()
-)
-
-fun File.handleTemplate(targetFolder: File, envs: Map<String, String>) {
-    println("Handling $absolutePath")
-    val localEnvs = File(absolutePath, ".env").takeIf { it.exists() } ?.let {
-        println("Reading .env in ${absolutePath}")
-        readEnvs(it.readText(), envs)
-    } ?: envs
-    println(
-        """
-    Local environments:
-        ${localEnvs.toList().joinToString("\n        ") { (k, v) -> "$k=$v" }}
-    """.trimIndent()
-    )
-    val newName = name.replaceWithVariables(localEnvs)
-    println("New name $newName")
-    when {
-        !exists() -> return
-        isFile -> {
-            val content = useLines {
-                it.map { it.replaceWithVariables(localEnvs) }.toList()
-            }.joinToString("\n")
-            val targetFile = File(targetFolder, newName)
-            targetFile.writeText(content)
-            println("Target file: ${targetFile.absolutePath}")
-        }
-        else -> {
-            val folder = File(targetFolder, newName)
-            println("Target folder: ${folder.absolutePath}")
-            folder.mkdirs()
-            listFiles() ?.forEach { fileOrFolder ->
-                fileOrFolder.handleTemplate(folder, localEnvs)
-            }
-        }
-    }
-}
-
-templatesFolders.forEach { folderOrFile ->
-    folderOrFile.handleTemplate(outputFolder, envs)
-}

BoostsInfoBot/README.md

@@ -1,9 +0,0 @@
-# UserChatShared
-
-Showing info about boosts
-
-## Launch
-
-```bash
-../gradlew run --args="BOT_TOKEN"
-```

BoostsInfoBot/build.gradle

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

BoostsInfoBot/src/main/kotlin/BoostsInfo.kt

@@ -1,72 +0,0 @@
-import dev.inmo.kslog.common.KSLog
-import dev.inmo.kslog.common.LogLevel
-import dev.inmo.kslog.common.defaultMessageFormatter
-import dev.inmo.kslog.common.setDefaultKSLog
-import dev.inmo.tgbotapi.bot.ktor.telegramBot
-import dev.inmo.tgbotapi.extensions.api.get.getUserChatBoosts
-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.onChatBoostUpdated
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onChatShared
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onCommand
-import dev.inmo.tgbotapi.extensions.utils.types.buttons.flatReplyKeyboard
-import dev.inmo.tgbotapi.extensions.utils.types.buttons.requestChannelButton
-import dev.inmo.tgbotapi.types.request.RequestId
-import dev.inmo.tgbotapi.utils.regular
-import korlibs.time.DateFormat
-import korlibs.time.format
-
-suspend fun main(args: Array<String>) {
-    val isDebug = args.getOrNull(1) == "debug"
-
-    if (isDebug) {
-        setDefaultKSLog(
-            KSLog { level: LogLevel, tag: String?, message: Any, throwable: Throwable? ->
-                println(defaultMessageFormatter(level, tag, message, throwable))
-            }
-        )
-    }
-
-    val requestChatId = RequestId(1)
-
-    val bot = telegramBot(args.first())
-
-    bot.buildBehaviourWithLongPolling (defaultExceptionsHandler = { it.printStackTrace() }) {
-        onChatBoostUpdated {
-            println(it)
-        }
-
-        onCommand("start") {
-            reply(
-                it,
-                replyMarkup = flatReplyKeyboard {
-                    requestChannelButton(
-                        "Click me :)",
-                        requestChatId,
-                        botIsMember = true
-                    )
-                }
-            ) {
-                regular("Select chat to get know about your boosts")
-            }
-        }
-
-        onChatShared(initialFilter = { it.chatEvent.requestId == requestChatId }) {
-            val boostsInfoContrainer = runCatching {
-                getUserChatBoosts(it.chatEvent.chatId, it.chat.id)
-            }.getOrNull()
-
-            reply(it) {
-                when {
-                    boostsInfoContrainer == null -> +"Unable to take info about boosts in shared chat"
-                    boostsInfoContrainer.boosts.isEmpty() -> +"There is no any boosts in passed chat"
-                    else -> {
-                        boostsInfoContrainer.boosts.forEach {
-                            regular("Boost added: ${DateFormat.FORMAT1.format(it.addDate.asDate)}; Boost expire: ${DateFormat.FORMAT1.format(it.expirationDate.asDate)}; Unformatted: $it") + "\n"
-                        }
-                    }
-                }
-            }
-        }
-    }.join()
-}

BusinessConnectionsBot/README.md

@@ -1,9 +0,0 @@
-# BusinessConnectionBotBot
-
-When bot connected or disconnected to the business chat, it will notify this chat
-
-## Launch
-
-```bash
-../gradlew run --args="BOT_TOKEN"
-```

BusinessConnectionsBot/build.gradle

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

BusinessConnectionsBot/src/main/kotlin/BusinessConnectionsBot.kt

@@ -1,487 +0,0 @@
-import dev.inmo.kslog.common.KSLog
-import dev.inmo.kslog.common.LogLevel
-import dev.inmo.kslog.common.defaultMessageFormatter
-import dev.inmo.kslog.common.setDefaultKSLog
-import dev.inmo.micro_utils.common.Percentage
-import dev.inmo.tgbotapi.extensions.api.answers.answer
-import dev.inmo.tgbotapi.extensions.api.bot.getMe
-import dev.inmo.tgbotapi.extensions.api.business.getBusinessAccountStarBalance
-import dev.inmo.tgbotapi.extensions.api.business.deleteBusinessMessages
-import dev.inmo.tgbotapi.extensions.api.business.getBusinessAccountGifts
-import dev.inmo.tgbotapi.extensions.api.business.getBusinessAccountGiftsFlow
-import dev.inmo.tgbotapi.extensions.api.business.readBusinessMessage
-import dev.inmo.tgbotapi.extensions.api.business.removeBusinessAccountProfilePhoto
-import dev.inmo.tgbotapi.extensions.api.business.setBusinessAccountBio
-import dev.inmo.tgbotapi.extensions.api.business.setBusinessAccountName
-import dev.inmo.tgbotapi.extensions.api.business.setBusinessAccountProfilePhoto
-import dev.inmo.tgbotapi.extensions.api.business.setBusinessAccountUsername
-import dev.inmo.tgbotapi.extensions.api.business.transferBusinessAccountStars
-import dev.inmo.tgbotapi.extensions.api.chat.get.getChat
-import dev.inmo.tgbotapi.extensions.api.chat.modify.pinChatMessage
-import dev.inmo.tgbotapi.extensions.api.chat.modify.unpinChatMessage
-import dev.inmo.tgbotapi.extensions.api.files.downloadFileToTemp
-import dev.inmo.tgbotapi.extensions.api.get.getBusinessConnection
-import dev.inmo.tgbotapi.extensions.api.send.reply
-import dev.inmo.tgbotapi.extensions.api.send.send
-import dev.inmo.tgbotapi.extensions.api.stories.deleteStory
-import dev.inmo.tgbotapi.extensions.api.stories.postStory
-import dev.inmo.tgbotapi.extensions.behaviour_builder.telegramBotWithBehaviourAndLongPolling
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.*
-import dev.inmo.tgbotapi.extensions.utils.commonMessageOrNull
-import dev.inmo.tgbotapi.extensions.utils.extendedPrivateChatOrThrow
-import dev.inmo.tgbotapi.extensions.utils.ifAccessibleMessage
-import dev.inmo.tgbotapi.extensions.utils.ifBusinessContentMessage
-import dev.inmo.tgbotapi.extensions.utils.textContentOrNull
-import dev.inmo.tgbotapi.extensions.utils.types.buttons.dataButton
-import dev.inmo.tgbotapi.extensions.utils.types.buttons.inlineKeyboard
-import dev.inmo.tgbotapi.extensions.utils.updates.retrieving.flushAccumulatedUpdates
-import dev.inmo.tgbotapi.extensions.utils.withContentOrNull
-import dev.inmo.tgbotapi.requests.abstracts.multipartFile
-import dev.inmo.tgbotapi.requests.business_connection.InputProfilePhoto
-import dev.inmo.tgbotapi.requests.stories.PostStory
-import dev.inmo.tgbotapi.types.ChatId
-import dev.inmo.tgbotapi.types.MessageId
-import dev.inmo.tgbotapi.types.RawChatId
-import dev.inmo.tgbotapi.types.business_connection.BusinessConnectionId
-import dev.inmo.tgbotapi.types.chat.PrivateChat
-import dev.inmo.tgbotapi.types.message.abstracts.CommonMessage
-import dev.inmo.tgbotapi.types.message.content.PhotoContent
-import dev.inmo.tgbotapi.types.message.content.StoryContent
-import dev.inmo.tgbotapi.types.message.content.TextContent
-import dev.inmo.tgbotapi.types.message.content.VideoContent
-import dev.inmo.tgbotapi.types.message.content.VisualMediaGroupPartContent
-import dev.inmo.tgbotapi.types.stories.InputStoryContent
-import dev.inmo.tgbotapi.types.stories.StoryArea
-import dev.inmo.tgbotapi.types.stories.StoryAreaPosition
-import dev.inmo.tgbotapi.types.stories.StoryAreaType
-import dev.inmo.tgbotapi.utils.botCommand
-import dev.inmo.tgbotapi.utils.code
-import dev.inmo.tgbotapi.utils.extensions.splitForText
-import dev.inmo.tgbotapi.utils.row
-import korlibs.time.seconds
-import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.Dispatchers
-import kotlinx.coroutines.delay
-import kotlinx.coroutines.sync.Mutex
-import kotlinx.coroutines.sync.withLock
-import kotlinx.serialization.json.Json
-
-suspend fun main(args: Array<String>) {
-    val botToken = args.first()
-    val isDebug = args.getOrNull(1) == "debug"
-
-    if (isDebug) {
-        setDefaultKSLog(
-            KSLog { level: LogLevel, tag: String?, message: Any, throwable: Throwable? ->
-                println(defaultMessageFormatter(level, tag, message, throwable))
-            }
-        )
-    }
-
-    val businessConnectionsChats = mutableMapOf<BusinessConnectionId, ChatId>()
-    val chatsBusinessConnections = mutableMapOf<ChatId, BusinessConnectionId>()
-    val businessConnectionsChatsMutex = Mutex()
-
-    telegramBotWithBehaviourAndLongPolling(botToken, CoroutineScope(Dispatchers.IO)) {
-        val me = getMe()
-        println(me)
-        flushAccumulatedUpdates()
-
-        onBusinessConnectionEnabled {
-            businessConnectionsChatsMutex.withLock {
-                businessConnectionsChats[it.id] = it.userChatId
-                chatsBusinessConnections[it.userChatId] = it.id
-            }
-            send(it.userChatId, "Business connection ${it.businessConnectionId.string} has been enabled")
-        }
-        onBusinessConnectionDisabled {
-            businessConnectionsChatsMutex.withLock {
-                businessConnectionsChats.remove(it.id)
-                chatsBusinessConnections.remove(it.userChatId)
-            }
-            send(it.userChatId, "Business connection ${it.businessConnectionId.string} has been disabled")
-        }
-
-        onContentMessage {
-            it.ifBusinessContentMessage { businessContentMessage ->
-                if (businessContentMessage.content.textContentOrNull() ?.text ?.startsWith("/pin") == true) {
-                    businessContentMessage.replyTo ?.ifAccessibleMessage {
-                        pinChatMessage(it)
-                        return@ifBusinessContentMessage
-                    }
-                }
-                if (businessContentMessage.content.textContentOrNull() ?.text ?.startsWith("/unpin") == true) {
-                    businessContentMessage.replyTo ?.ifAccessibleMessage {
-                        unpinChatMessage(it)
-                        return@ifBusinessContentMessage
-                    }
-                }
-                val sent = execute(it.content.createResend(businessContentMessage.from.id))
-                if (businessContentMessage.sentByBusinessConnectionOwner) {
-                    reply(sent, "You have sent this message to the ${businessContentMessage.businessConnectionId.string} related chat")
-                } else {
-                    reply(
-                        to = sent,
-                        text = "User have sent this message to you in the ${businessContentMessage.businessConnectionId.string} related chat",
-                    )
-                    send(
-                        chatId = businessConnectionsChats[it.businessConnectionId] ?: return@ifBusinessContentMessage,
-                        text = "User have sent this message to you in the ${businessContentMessage.businessConnectionId.string} related chat",
-                        replyMarkup = inlineKeyboard {
-                            row {
-                                dataButton("Read message", "read ${it.chat.id.chatId.long} ${it.messageId.long}")
-                                dataButton("Delete message", "delete ${it.chat.id.chatId.long} ${it.messageId.long}")
-                            }
-                        }
-                    )
-                }
-            }
-        }
-        onEditedContentMessage {
-            it.ifBusinessContentMessage { businessContentMessage ->
-                val sent = execute(businessContentMessage.content.createResend(businessContentMessage.from.id))
-                if (businessContentMessage.sentByBusinessConnectionOwner) {
-                    reply(sent, "You have edited this message in the ${businessContentMessage.businessConnectionId.string} related chat")
-                } else {
-                    reply(sent, "User have edited this message to you in the ${businessContentMessage.businessConnectionId.string} related chat")
-                }
-            }
-        }
-        onBusinessMessagesDeleted {
-            var businessConnectionOwnerChat = businessConnectionsChatsMutex.withLock {
-                businessConnectionsChats[it.businessConnectionId]
-            }
-            if (businessConnectionOwnerChat == null) {
-                val businessConnection = getBusinessConnection(it.businessConnectionId)
-                businessConnectionsChatsMutex.withLock {
-                    businessConnectionsChats[businessConnection.businessConnectionId] = businessConnection.userChatId
-                }
-                businessConnectionOwnerChat = businessConnection.userChatId
-            }
-            send(businessConnectionOwnerChat, "There are several removed messages in chat ${it.chat.id}: ${it.messageIds}")
-        }
-        onCommand("get_business_account_info", initialFilter = { it.chat is PrivateChat }) {
-            val businessConnectionId = chatsBusinessConnections[it.chat.id]
-            val businessConnectionInfo = businessConnectionId ?.let { getBusinessConnection(it) }
-            reply(it) {
-                if (businessConnectionInfo == null) {
-                    +"There is no business connection for current chat"
-                } else {
-                    +(Json { prettyPrint = true; encodeDefaults = true }.encodeToString(businessConnectionInfo))
-                }
-            }
-        }
-        onMessageDataCallbackQuery(Regex("read \\d+ \\d+")) {
-            val (_, chatIdString, messageIdString) = it.data.split(" ")
-            val chatId = chatIdString.toLongOrNull() ?.let(::RawChatId) ?.let(::ChatId) ?: return@onMessageDataCallbackQuery
-            val messageId = messageIdString.toLongOrNull() ?.let(::MessageId) ?: return@onMessageDataCallbackQuery
-            val businessConnectionId = chatsBusinessConnections[it.message.chat.id]
-
-            val readResponse = businessConnectionId ?.let { readBusinessMessage(it, chatId, messageId) }
-            answer(
-                it,
-                if (readResponse == null) {
-                    "There is no business connection for current chat"
-                } else {
-                    "Message has been read"
-                }
-            )
-        }
-        onMessageDataCallbackQuery(Regex("delete \\d+ \\d+")) {
-            val (_, chatIdString, messageIdString) = it.data.split(" ")
-            val chatId = chatIdString.toLongOrNull() ?.let(::RawChatId) ?.let(::ChatId) ?: return@onMessageDataCallbackQuery
-            val messageId = messageIdString.toLongOrNull() ?.let(::MessageId) ?: return@onMessageDataCallbackQuery
-            val businessConnectionId = chatsBusinessConnections[it.message.chat.id]
-
-            val readResponse = businessConnectionId ?.let { deleteBusinessMessages(it, listOf(messageId)) }
-            answer(
-                it,
-                if (readResponse == null) {
-                    "There is no business connection for current chat"
-                } else {
-                    "Message has been deleted"
-                }
-            )
-        }
-        onCommandWithArgs("set_business_account_name", initialFilter = { it.chat is PrivateChat }) { it, args ->
-            val firstName = args[0]
-            val secondName = args.getOrNull(1)
-            val businessConnectionId = chatsBusinessConnections[it.chat.id] ?: return@onCommandWithArgs
-            val set = runCatching {
-                setBusinessAccountName(
-                    businessConnectionId,
-                    firstName,
-                    secondName
-                )
-            }.getOrElse { false }
-            reply(it) {
-                if (set) {
-                    +"Account name has been set"
-                } else {
-                    +"Account name has not been set"
-                }
-            }
-        }
-        onCommandWithArgs("set_business_account_username", initialFilter = { it.chat is PrivateChat }) { it, args ->
-            val username = args[0]
-            val businessConnectionId = chatsBusinessConnections[it.chat.id] ?: return@onCommandWithArgs
-            val set = runCatching {
-                setBusinessAccountUsername(
-                    businessConnectionId,
-                    username
-                )
-            }.getOrElse {
-                it.printStackTrace()
-                false
-            }
-            reply(it) {
-                if (set) {
-                    +"Account username has been set"
-                } else {
-                    +"Account username has not been set"
-                }
-            }
-        }
-        onCommand("get_business_account_star_balance", initialFilter = { it.chat is PrivateChat }) {
-            val businessConnectionId = chatsBusinessConnections[it.chat.id] ?: return@onCommand
-            val starAmount = runCatching {
-                getBusinessAccountStarBalance(businessConnectionId)
-            }.getOrElse {
-                it.printStackTrace()
-                null
-            }
-            reply(it) {
-                if (starAmount != null) {
-                    +"Account stars amount: $starAmount"
-                } else {
-                    +"Account stars amount has not been got"
-                }
-            }
-        }
-        onCommandWithArgs("transfer_business_account_stars", initialFilter = { it.chat is PrivateChat }) { it, args ->
-            val businessConnectionId = chatsBusinessConnections[it.chat.id] ?: return@onCommandWithArgs
-            val count = args.firstOrNull() ?.toIntOrNull() ?: reply(it) {
-                "Pass amount of stars to transfer to bot with command"
-            }.let {
-                return@onCommandWithArgs
-            }
-            val transferred = runCatching {
-                transferBusinessAccountStars(businessConnectionId, count)
-            }.getOrElse {
-                it.printStackTrace()
-                false
-            }
-            reply(it) {
-                if (transferred) {
-                    +"Stars have been transferred"
-                } else {
-                    +"Stars have not been transferred"
-                }
-            }
-        }
-        onCommand("get_business_account_gifts", initialFilter = { it.chat is PrivateChat }) {
-            val businessConnectionId = chatsBusinessConnections[it.chat.id] ?: return@onCommand
-            val giftsFlow = runCatching {
-                getBusinessAccountGiftsFlow(businessConnectionId)
-            }.getOrElse {
-                it.printStackTrace()
-                null
-            }
-            if (giftsFlow == null) {
-                reply(it) {
-                    +"Error in receiving of gifts"
-                }
-            } else {
-                giftsFlow.collect { giftsPage ->
-                    giftsPage.gifts.joinToString {
-                        it.toString()
-                    }.splitForText().forEach { message ->
-                        reply(it, message)
-                    }
-                }
-            }
-        }
-        onCommand("set_business_account_bio", requireOnlyCommandInMessage = false, initialFilter = { it.chat is PrivateChat }) {
-            val initialBio = getChat(it.chat).extendedPrivateChatOrThrow().bio
-            val bio = it.content.text.removePrefix("/set_business_account_bio").trim()
-            val businessConnectionId = chatsBusinessConnections[it.chat.id] ?: return@onCommand
-            val set = runCatching {
-                setBusinessAccountBio(
-                    businessConnectionId,
-                    bio
-                )
-            }.getOrElse {
-                it.printStackTrace()
-                false
-            }
-            reply(it) {
-                if (set) {
-                    +"Account bio has been set. It will be reset within 15 seconds.\n\nInitial bio: " + code(initialBio)
-                } else {
-                    +"Account bio has not been set"
-                }
-            }
-            delay(15.seconds)
-            val reset = runCatching {
-                setBusinessAccountBio(
-                    businessConnectionId,
-                    initialBio
-                )
-            }.getOrElse {
-                it.printStackTrace()
-                false
-            }
-            reply(it) {
-                if (reset) {
-                    +"Account bio has been reset"
-                } else {
-                    +"Account bio has not been set. Set it manually: " + code(initialBio)
-                }
-            }
-        }
-        suspend fun handleSetProfilePhoto(it: CommonMessage<TextContent>, isPublic: Boolean) {
-            val businessConnectionId = chatsBusinessConnections[it.chat.id] ?: return@handleSetProfilePhoto
-            val replyTo = it.replyTo ?.commonMessageOrNull() ?.withContentOrNull<PhotoContent>()
-            if (replyTo == null) {
-                reply(it) {
-                    +"Reply to photo for using of this command"
-                }
-                return@handleSetProfilePhoto
-            }
-
-            val set = runCatching {
-                val file = downloadFileToTemp(replyTo.content)
-                setBusinessAccountProfilePhoto(
-                    businessConnectionId,
-                    InputProfilePhoto.Static(
-                        file.multipartFile()
-                    ),
-                    isPublic = isPublic
-                )
-            }.getOrElse {
-                it.printStackTrace()
-                false
-            }
-            reply(it) {
-                if (set) {
-                    +"Account profile photo has been set. It will be reset within 15 seconds"
-                } else {
-                    +"Account profile photo has not been set"
-                }
-            }
-            if (set == false) { return@handleSetProfilePhoto }
-            delay(15.seconds)
-            val reset = runCatching {
-                removeBusinessAccountProfilePhoto(
-                    businessConnectionId,
-                    isPublic = isPublic
-                )
-            }.getOrElse {
-                it.printStackTrace()
-                false
-            }
-            reply(it) {
-                if (reset) {
-                    +"Account profile photo has been reset"
-                } else {
-                    +"Account profile photo has not been set. Set it manually"
-                }
-            }
-        }
-        onCommand("set_business_account_profile_photo", initialFilter = { it.chat is PrivateChat }) {
-            handleSetProfilePhoto(it, false)
-        }
-        onCommand("set_business_account_profile_photo_public", initialFilter = { it.chat is PrivateChat }) {
-            handleSetProfilePhoto(it, true)
-        }
-
-        onCommand("post_story", initialFilter = { it.chat is PrivateChat }) {
-            val businessConnectionId = chatsBusinessConnections[it.chat.id] ?: return@onCommand
-            val replyTo = it.replyTo ?.commonMessageOrNull() ?.withContentOrNull<VisualMediaGroupPartContent>()
-            if (replyTo == null) {
-                reply(it) {
-                    +"Reply to photo or video for using of this command"
-                }
-                return@onCommand
-            }
-
-            val posted = runCatching {
-                val file = downloadFileToTemp(replyTo.content)
-                postStory(
-                    businessConnectionId,
-                    when (replyTo.content) {
-                        is PhotoContent -> InputStoryContent.Photo(
-                            file.multipartFile()
-                        )
-                        is VideoContent -> InputStoryContent.Video(
-                            file.multipartFile()
-                        )
-                    },
-                    activePeriod = PostStory.ACTIVE_PERIOD_6_HOURS,
-                    areas = listOf(
-                        StoryArea(
-                            StoryAreaPosition(
-                                x = Percentage.of100(50.0),
-                                y = Percentage.of100(50.0),
-                                width = Percentage.of100(8.0),
-                                height = Percentage.of100(8.0),
-                                rotationAngle = 45.0,
-                                cornerRadius = Percentage.of100(4.0),
-                            ),
-                            StoryAreaType.Link(
-                                "https://github.com/InsanusMokrassar/TelegramBotAPI-examples/blob/master/BusinessConnectionsBot/src/main/kotlin/BusinessConnectionsBot.kt"
-                            )
-                        )
-                    )
-                ) {
-                    +"It is test of postStory :)"
-                }
-            }.getOrElse {
-                it.printStackTrace()
-                null
-            }
-            reply(it) {
-                if (posted != null) {
-                    +"Story has been posted. You may unpost it with " + botCommand("remove_story")
-                } else {
-                    +"Story has not been posted"
-                }
-            }
-        }
-
-        onCommand("delete_story", initialFilter = { it.chat is PrivateChat }) {
-            val businessConnectionId = chatsBusinessConnections[it.chat.id] ?: return@onCommand
-            val replyTo = it.replyTo ?.commonMessageOrNull() ?.withContentOrNull<StoryContent>()
-            if (replyTo == null) {
-                reply(it) {
-                    +"Reply to photo or video for using of this command"
-                }
-                return@onCommand
-            }
-
-            val deleted = runCatching {
-                deleteStory(businessConnectionId, replyTo.content.story.id)
-            }.getOrElse {
-                it.printStackTrace()
-                false
-            }
-            reply(it) {
-                if (deleted) {
-                    +"Story has been deleted"
-                } else {
-                    +"Story has not been deleted"
-                }
-            }
-        }
-
-        // Will work when some premium user sending to some other user checklist
-        onChecklistContent {
-            execute(
-                it.content.createResend(
-                    it.chat.id,
-                    businessConnectionId = it.chat.id.businessConnectionId ?: chatsBusinessConnections[it.chat.id] ?: return@onChecklistContent
-                )
-            )
-        }
-    }.second.join()
-}

ChatAvatarSetter/README.md

@@ -1,9 +0,0 @@
-# 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

@@ -1,21 +0,0 @@
-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

@@ -1,36 +0,0 @@
-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.requests.abstracts.asMultipartFile
-import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.Dispatchers
-
-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()
-}

ChecklistsBot/build.gradle

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

ChecklistsBot/src/main/kotlin/ChecklistsBot.kt

@@ -1,120 +0,0 @@
-import dev.inmo.kslog.common.KSLog
-import dev.inmo.kslog.common.LogLevel
-import dev.inmo.kslog.common.defaultMessageFormatter
-import dev.inmo.kslog.common.setDefaultKSLog
-import dev.inmo.micro_utils.coroutines.runCatchingLogging
-import dev.inmo.micro_utils.coroutines.subscribeLoggingDropExceptions
-import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions
-import dev.inmo.tgbotapi.extensions.api.bot.getMe
-import dev.inmo.tgbotapi.extensions.api.bot.getMyStarBalance
-import dev.inmo.tgbotapi.extensions.api.chat.get.getChat
-import dev.inmo.tgbotapi.extensions.api.send.reply
-import dev.inmo.tgbotapi.extensions.api.send.resend
-import dev.inmo.tgbotapi.extensions.api.send.send
-import dev.inmo.tgbotapi.extensions.api.suggested.approveSuggestedPost
-import dev.inmo.tgbotapi.extensions.behaviour_builder.BehaviourContextData
-import dev.inmo.tgbotapi.extensions.behaviour_builder.buildSubcontextInitialAction
-import dev.inmo.tgbotapi.extensions.behaviour_builder.expectations.waitSuggestedPostApproved
-import dev.inmo.tgbotapi.extensions.behaviour_builder.expectations.waitSuggestedPostDeclined
-import dev.inmo.tgbotapi.extensions.behaviour_builder.telegramBotWithBehaviourAndLongPolling
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onChannelDirectMessagesConfigurationChanged
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onChecklistContent
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onChecklistTasksAdded
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onChecklistTasksDone
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onCommand
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onContentMessage
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onSuggestedPostApprovalFailed
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onSuggestedPostApproved
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onSuggestedPostDeclined
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onSuggestedPostPaid
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onSuggestedPostRefunded
-import dev.inmo.tgbotapi.extensions.utils.channelDirectMessagesContentMessageOrNull
-import dev.inmo.tgbotapi.extensions.utils.previewChannelDirectMessagesChatOrNull
-import dev.inmo.tgbotapi.extensions.utils.suggestedChannelDirectMessagesContentMessageOrNull
-import dev.inmo.tgbotapi.types.checklists.ChecklistTaskId
-import dev.inmo.tgbotapi.types.message.SuggestedPostParameters
-import dev.inmo.tgbotapi.types.message.abstracts.CommonMessage
-import dev.inmo.tgbotapi.types.message.content.ChecklistContent
-import dev.inmo.tgbotapi.types.message.textsources.TextSourcesList
-import dev.inmo.tgbotapi.types.update.abstracts.Update
-import dev.inmo.tgbotapi.utils.bold
-import dev.inmo.tgbotapi.utils.buildEntities
-import dev.inmo.tgbotapi.utils.code
-import dev.inmo.tgbotapi.utils.firstOf
-import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.Dispatchers
-import kotlinx.coroutines.delay
-import kotlinx.coroutines.flow.filter
-import kotlinx.coroutines.flow.first
-
-suspend fun main(vararg args: String) {
-    val botToken = args.first()
-
-    val isDebug = args.any { it == "debug" }
-    val isTestServer = args.any { it == "testServer" }
-
-    if (isDebug) {
-        setDefaultKSLog(
-            KSLog { level: LogLevel, tag: String?, message: Any, throwable: Throwable? ->
-                println(defaultMessageFormatter(level, tag, message, throwable))
-            }
-        )
-    }
-
-    telegramBotWithBehaviourAndLongPolling(
-        botToken,
-        CoroutineScope(Dispatchers.Default),
-        testServer = isTestServer,
-    ) {
-        // start here!!
-        val me = getMe()
-        println(me)
-
-        fun ChecklistContent.textBuilderTextSources(): TextSourcesList {
-            return buildEntities {
-                +checklist.textSources + "\n\n"
-                checklist.tasks.forEach { task ->
-                    +"• "
-                    code(
-                        if (task.completionDate != null) {
-                            "[x] "
-                        } else {
-                            "[ ] "
-                        }
-                    )
-
-                    bold(task.textSources) + "\n"
-                }
-            }
-        }
-
-        onChecklistContent { messageWithContent ->
-            reply(messageWithContent) {
-                +messageWithContent.content.textBuilderTextSources()
-            }
-        }
-
-        onChecklistTasksDone { eventMessage ->
-            reply(
-                eventMessage,
-                checklistTaskId = eventMessage.chatEvent.markedAsDone ?.firstOrNull()
-            ) {
-                eventMessage.chatEvent.checklistMessage.content.checklist
-                +eventMessage.chatEvent.checklistMessage.content.textBuilderTextSources()
-            }
-        }
-
-        onChecklistTasksAdded { messageWithContent ->
-            reply(
-                messageWithContent.chatEvent.checklistMessage,
-                checklistTaskId = messageWithContent.chatEvent.tasks.firstOrNull() ?.id
-            ) {
-                +messageWithContent.chatEvent.checklistMessage.content.textBuilderTextSources()
-            }
-        }
-
-        allUpdatesFlow.subscribeLoggingDropExceptions(this) {
-            println(it)
-        }
-    }.second.join()
-}

CustomBot/README.md

@@ -1,9 +0,0 @@
-# CustomBot
-
-This bot basically have no any useful behaviour, but you may customize it as a playground
-
-## Launch
-
-```bash
-../gradlew run --args="BOT_TOKEN"
-```

CustomBot/build.gradle

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

CustomBot/src/main/kotlin/CustomBot.kt

@@ -1,100 +0,0 @@
-import dev.inmo.kslog.common.KSLog
-import dev.inmo.kslog.common.LogLevel
-import dev.inmo.kslog.common.defaultMessageFormatter
-import dev.inmo.kslog.common.setDefaultKSLog
-import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions
-import dev.inmo.tgbotapi.extensions.api.bot.getMe
-import dev.inmo.tgbotapi.extensions.api.bot.getMyStarBalance
-import dev.inmo.tgbotapi.extensions.api.chat.get.getChat
-import dev.inmo.tgbotapi.extensions.api.send.reply
-import dev.inmo.tgbotapi.extensions.behaviour_builder.BehaviourContextData
-import dev.inmo.tgbotapi.extensions.behaviour_builder.buildSubcontextInitialAction
-import dev.inmo.tgbotapi.extensions.behaviour_builder.telegramBotWithBehaviourAndLongPolling
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onChannelDirectMessagesConfigurationChanged
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onCommand
-import dev.inmo.tgbotapi.types.message.abstracts.CommonMessage
-import dev.inmo.tgbotapi.types.update.abstracts.Update
-import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.Dispatchers
-
-private var BehaviourContextData.update: Update?
-    get() = get("update") as? Update
-    set(value) = set("update", value)
-
-private var BehaviourContextData.commonMessage: CommonMessage<*>?
-    get() = get("commonMessage") as? CommonMessage<*>
-    set(value) = set("commonMessage", value)
-
-/**
- * This place can be the playground for your code.
- */
-suspend fun main(vararg args: String) {
-    val botToken = args.first()
-
-    val isDebug = args.any { it == "debug" }
-    val isTestServer = args.any { it == "testServer" }
-
-    if (isDebug) {
-        setDefaultKSLog(
-            KSLog { level: LogLevel, tag: String?, message: Any, throwable: Throwable? ->
-                println(defaultMessageFormatter(level, tag, message, throwable))
-            }
-        )
-    }
-
-    telegramBotWithBehaviourAndLongPolling(
-        botToken,
-        CoroutineScope(Dispatchers.IO),
-        testServer = isTestServer,
-        builder = {
-            includeMiddlewares {
-                addMiddleware {
-                    doOnRequestReturnResult { result, request, _ ->
-                        println("Result of $request:\n\n$result")
-                        null
-                    }
-                }
-            }
-        },
-        subcontextInitialAction = buildSubcontextInitialAction {
-            add {
-                data.update = it
-            }
-        }
-    ) {
-        // start here!!
-        val me = getMe()
-        println(me)
-
-        onCommand("start") {
-            println(data.update)
-            println(data.commonMessage)
-            println(getChat(it.chat))
-        }
-
-        onCommand(
-            "additional_command",
-            additionalSubcontextInitialAction = { update, commonMessage ->
-                data.commonMessage = commonMessage
-            }
-        ) {
-            println(data.update)
-            println(data.commonMessage)
-        }
-
-        onCommand("getMyStarBalance") {
-            reply(
-                to = it,
-                text = getMyStarBalance().toString()
-            )
-        }
-
-        onChannelDirectMessagesConfigurationChanged {
-            println(it.chatEvent)
-        }
-
-        allUpdatesFlow.subscribeSafelyWithoutExceptions(this) {
-            println(it)
-        }
-    }.second.join()
-}

DeepLinksBot/README.md

@@ -1,9 +0,0 @@
-# DeepLinksBot
-
-This bot will send you deeplink to this bot when you send some text message and react on the `start` button
-
-## Launch
-
-```bash
-../gradlew run --args="BOT_TOKEN"
-```

DeepLinksBot/build.gradle

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

DeepLinksBot/src/main/kotlin/DeepLinksBot.kt

@@ -1,44 +0,0 @@
-import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions
-import dev.inmo.tgbotapi.extensions.api.bot.getMe
-import dev.inmo.tgbotapi.extensions.api.send.reply
-import dev.inmo.tgbotapi.extensions.behaviour_builder.expectations.waitDeepLinks
-import dev.inmo.tgbotapi.extensions.behaviour_builder.telegramBotWithBehaviourAndLongPolling
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onCommand
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onDeepLink
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onText
-import dev.inmo.tgbotapi.extensions.utils.formatting.makeTelegramDeepLink
-import dev.inmo.tgbotapi.types.message.textsources.BotCommandTextSource
-
-/**
- * This bot will send you deeplink to this bot when you send some text message and react on the `start` button
- */
-suspend fun main(vararg args: String) {
-    val botToken = args.first()
-
-    telegramBotWithBehaviourAndLongPolling(botToken) {
-        val me = bot.getMe()
-        val username = me.username
-        println(me)
-
-        if (username == null) {
-            error("Unable to start bot work: it have no username")
-        }
-
-        onText(
-            initialFilter = { it.content.textSources.none { it is BotCommandTextSource } } // excluding messages with commands
-        ) {
-            reply(it, makeTelegramDeepLink(username, it.content.text))
-        }
-
-        onCommand("start", requireOnlyCommandInMessage = true) { // handling of `start` without args
-            reply(it, "Hi :) Send me any text and I will try hard to create deeplink for you")
-        }
-        onDeepLink { (it, deepLink) ->
-            reply(it, "Ok, I got deep link \"${deepLink}\" in trigger")
-        }
-        waitDeepLinks().subscribeSafelyWithoutExceptions(this) { (it, deepLink) ->
-            reply(it, "Ok, I got deep link \"${deepLink}\" in waiter")
-            println(triggersHolder.handleableCommandsHolder.handleable)
-        }
-    }.second.join()
-}

FSMBot/src/main/kotlin/SimpleFSMBot.kt

@@ -1,104 +1,48 @@
-import dev.inmo.micro_utils.coroutines.awaitFirst
-import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions
 import dev.inmo.micro_utils.fsm.common.State
-import dev.inmo.tgbotapi.extensions.api.send.send
-import dev.inmo.tgbotapi.extensions.behaviour_builder.expectations.waitAnyContentMessage
-import dev.inmo.tgbotapi.extensions.behaviour_builder.expectations.waitCommandMessage
-import dev.inmo.tgbotapi.extensions.behaviour_builder.telegramBotWithBehaviourAndFSMAndStartLongPolling
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.command
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onContentMessage
-import dev.inmo.tgbotapi.extensions.behaviour_builder.utils.containsCommand
-import dev.inmo.tgbotapi.extensions.utils.extensions.parseCommandsWithArgs
-import dev.inmo.tgbotapi.extensions.utils.extensions.sameThread
-import dev.inmo.tgbotapi.extensions.utils.textContentOrNull
-import dev.inmo.tgbotapi.extensions.utils.withContentOrNull
-import dev.inmo.tgbotapi.types.IdChatIdentifier
+import dev.inmo.tgbotapi.extensions.api.send.sendMessage
+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.formatting.*
+import dev.inmo.tgbotapi.types.ChatId
 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.firstOf
-import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.Dispatchers
-import kotlinx.coroutines.flow.filter
-import kotlinx.coroutines.flow.first
-import kotlinx.coroutines.flow.map
+import kotlinx.coroutines.*
 
 sealed interface BotState : State
-data class ExpectContentOrStopState(override val context: IdChatIdentifier, val sourceMessage: CommonMessage<TextContent>) : BotState
-data class StopState(override val context: IdChatIdentifier) : BotState
+data class ExpectContentOrStopState(override val context: ChatId, val sourceMessage: CommonMessage<TextContent>) : BotState
+data class StopState(override val context: ChatId) : BotState
 
 suspend fun main(args: Array<String>) {
     val botToken = args.first()
 
-    telegramBotWithBehaviourAndFSMAndStartLongPolling<BotState>(
-        botToken,
-        CoroutineScope(Dispatchers.IO),
-        onStateHandlingErrorHandler = { state, e ->
-            when (state) {
-                is ExpectContentOrStopState -> {
-                    println("Thrown error on ExpectContentOrStopState")
-                }
-                is StopState -> {
-                    println("Thrown error on StopState")
-                }
-            }
-            e.printStackTrace()
-            state
-        }
-    ) {
+    telegramBotWithBehaviourAndFSMAndStartLongPolling<BotState>(botToken, CoroutineScope(Dispatchers.IO)) {
         strictlyOn<ExpectContentOrStopState> {
-            send(
+            sendMessage(
                 it.context,
-            ) {
-                +"Send me some content or " + botCommand("stop") + " if you want to stop sending"
-            }
-
-            val contentMessage = firstOf(
-                {
-                    waitCommandMessage("stop").filter { message ->
-                        message.sameThread(it.sourceMessage)
-                    }.first()
-                    null
-                },
-                {
-                    waitAnyContentMessage().filter { message ->
-                        message.sameThread(it.sourceMessage)
-                    }.filter {
-                        containsCommand(
-                            "stop",
-                            it.withContentOrNull<TextContent>() ?.content ?.textSources ?: return@filter false
-                        ) == false
-                    }.first()
+                buildEntities {
+                    +"Send me some content or " + botCommand("stop") + " if you want to stop sending"
                 }
-            ) ?: return@strictlyOn StopState(it.context)
+            )
 
-            val content = contentMessage.content
-
-            execute(content.createResend(it.context))
-            it
+            val content = waitContentMessage().first()
+            when {
+                content is TextContent && content.parseCommandsWithParams().keys.contains("stop") -> StopState(it.context)
+                else -> {
+                    execute(content.createResend(it.context))
+                    it
+                }
+            }
         }
         strictlyOn<StopState> {
-            send(it.context) { +"You have stopped sending of content" }
+            sendMessage(it.context, "You have stopped sending of content")
 
             null
         }
 
-        command(
-            "start"
-        ) {
+        command("start") {
             startChain(ExpectContentOrStopState(it.chat.id, it))
         }
-
-        onContentMessage(
-            {
-                it.content.textContentOrNull() ?.text == "/start"
-            }
-        ) {
-            startChain(ExpectContentOrStopState(it.chat.id, it.withContentOrNull() ?: return@onContentMessage))
-        }
-
-        allUpdatesFlow.subscribeSafelyWithoutExceptions(this) {
-            println(it)
-        }
     }.second.join()
 }

FilesLoaderBot/build.gradle

@@ -1,6 +1,6 @@
 buildscript {
     repositories {
-        mavenCentral()
+        jcenter()
     }
 
     dependencies {

FilesLoaderBot/src/main/kotlin/FilesLoaderBot.kt

@@ -1,18 +1,10 @@
-import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions
 import dev.inmo.tgbotapi.extensions.api.files.downloadFile
-import dev.inmo.tgbotapi.extensions.api.files.downloadFileToTemp
 import dev.inmo.tgbotapi.extensions.api.get.getFileAdditionalInfo
-import dev.inmo.tgbotapi.extensions.api.send.*
+import dev.inmo.tgbotapi.extensions.api.send.reply
+import dev.inmo.tgbotapi.extensions.behaviour_builder.telegramBotWithBehaviour
 import dev.inmo.tgbotapi.extensions.behaviour_builder.telegramBotWithBehaviourAndLongPolling
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onCommand
+import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onContentMessage
 import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onMedia
-import dev.inmo.tgbotapi.requests.abstracts.asMultipartFile
-import dev.inmo.tgbotapi.types.actions.*
-import dev.inmo.tgbotapi.types.media.TelegramMediaAudio
-import dev.inmo.tgbotapi.types.media.TelegramMediaDocument
-import dev.inmo.tgbotapi.types.media.TelegramMediaPhoto
-import dev.inmo.tgbotapi.types.media.TelegramMediaVideo
-import dev.inmo.tgbotapi.types.message.content.*
 import dev.inmo.tgbotapi.utils.filenameFromUrl
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.Dispatchers
@@ -23,94 +15,18 @@ import java.io.File
  */
 suspend fun main(args: Array<String>) {
     val botToken = args.first()
-    val directoryOrFile = args.getOrNull(1) ?.let { File(it) } ?: File("/tmp/")
+    val directoryOrFile = args.getOrNull(1) ?.let { File(it) } ?: File("")
     directoryOrFile.mkdirs()
 
     telegramBotWithBehaviourAndLongPolling(botToken, CoroutineScope(Dispatchers.IO)) {
-        onCommand("start") {
-            reply(it, "Send me any media (like photo or video) to download it")
-        }
         onMedia(initialFilter = null) {
-            val content = it.content
-            val pathedFile = bot.getFileAdditionalInfo(content.media)
-            val outFile = File(directoryOrFile, pathedFile.filePath.filenameFromUrl)
-            withTypingAction(it.chat.id) {
-                runCatching {
-                    bot.downloadFile(content.media, outFile)
-                }.onFailure {
-                    it.printStackTrace()
-                }.onSuccess { _ ->
-                    reply(it, "Saved to ${outFile.absolutePath}")
-                }
-            }.onSuccess { _ ->
-                val action = when (content) {
-                    is PhotoContent -> UploadPhotoAction
-                    is AnimationContent,
-                    is VideoContent -> UploadVideoAction
-                    is StickerContent -> ChooseStickerAction
-                    is MediaGroupContent<*> -> UploadPhotoAction
-                    is DocumentContent -> UploadDocumentAction
-                    is VoiceContent,
-                    is AudioContent -> RecordVoiceAction
-                    is VideoNoteContent -> UploadVideoNoteAction
-                }
-                withAction(it.chat.id, action) {
-                    when (content) {
-                        is PhotoContent -> replyWithPhoto(
-                            it,
-                            outFile.asMultipartFile()
-                        )
-                        is AnimationContent -> replyWithAnimation(
-                            it,
-                            outFile.asMultipartFile()
-                        )
-                        is VideoContent -> replyWithVideo(
-                            it,
-                            outFile.asMultipartFile()
-                        )
-                        is StickerContent -> replyWithSticker(
-                            it,
-                            outFile.asMultipartFile()
-                        )
-                        is MediaGroupContent<*> -> replyWithMediaGroup(
-                            it,
-                            content.group.map {
-                                when (val innerContent = it.content) {
-                                    is AudioContent -> TelegramMediaAudio(
-                                        downloadFileToTemp(innerContent.media).asMultipartFile()
-                                    )
-                                    is DocumentContent -> TelegramMediaDocument(
-                                        downloadFileToTemp(innerContent.media).asMultipartFile()
-                                    )
-                                    is PhotoContent -> TelegramMediaPhoto(
-                                        downloadFileToTemp(innerContent.media).asMultipartFile()
-                                    )
-                                    is VideoContent -> TelegramMediaVideo(
-                                        downloadFileToTemp(innerContent.media).asMultipartFile()
-                                    )
-                                }
-                            }
-                        )
-                        is AudioContent -> replyWithAudio(
-                            it,
-                            outFile.asMultipartFile()
-                        )
-                        is DocumentContent -> replyWithDocument(
-                            it,
-                            outFile.asMultipartFile()
-                        )
-                        is VoiceContent -> replyWithVoice(
-                            it,
-                            outFile.asMultipartFile()
-                        )
-                        is VideoNoteContent -> replyWithVideoNote(
-                            it,
-                            outFile.asMultipartFile()
-                        )
-                    }
-                }
+            val pathedFile = bot.getFileAdditionalInfo(it.content.media)
+            val file = File(directoryOrFile, pathedFile.filePath.filenameFromUrl).apply {
+                createNewFile()
+                writeBytes(bot.downloadFile(pathedFile))
             }
+            reply(it, "Saved to ${file.absolutePath}")
         }
-        allUpdatesFlow.subscribeSafelyWithoutExceptions(this) { println(it) }
+        onContentMessage { println(it) }
     }.second.join()
 }

ForwardInfoSenderBot/build.gradle

@@ -1,6 +1,6 @@
 buildscript {
     repositories {
-        mavenCentral()
+        jcenter()
     }
 
     dependencies {

ForwardInfoSenderBot/src/main/kotlin/ForwardInfoSenderBot.kt

@@ -1,15 +1,9 @@
 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.onContentMessage
-import dev.inmo.tgbotapi.extensions.utils.formatting.makeLink
-import dev.inmo.tgbotapi.types.chat.CommonBot
-import dev.inmo.tgbotapi.types.chat.CommonUser
-import dev.inmo.tgbotapi.types.chat.ExtendedBot
+import dev.inmo.tgbotapi.extensions.utils.formatting.*
+import dev.inmo.tgbotapi.types.*
 import dev.inmo.tgbotapi.types.message.*
-import dev.inmo.tgbotapi.utils.buildEntities
-import dev.inmo.tgbotapi.utils.code
-import dev.inmo.tgbotapi.utils.link
-import dev.inmo.tgbotapi.utils.regular
 import kotlinx.coroutines.*
 
 /**
@@ -20,41 +14,28 @@ suspend fun main(vararg args: String) {
     val botToken = args.first()
 
     telegramBotWithBehaviourAndLongPolling(botToken, CoroutineScope(Dispatchers.IO)) {
-        onContentMessage {
+        onContentMessage(subcontextUpdatesFilter = { _, _ -> true }) {
             val toAnswer = buildEntities {
                 when (val forwardInfo = it.forwardInfo) {
                     null -> +"There is no forward info"
-                    is ForwardInfo.ByAnonymous -> {
+                    is AnonymousForwardInfo -> {
                         regular("Anonymous user which signed as \"") + code(forwardInfo.senderName) + "\""
                     }
-                    is ForwardInfo.ByUser -> {
+                    is UserForwardInfo -> {
                         val user = forwardInfo.from
                         when (user) {
-                            is CommonUser -> {
-                                if (user.isPremium) {
-                                    regular("Premium user ")
-                                } else {
-                                    regular("User ")
-                                }
-                            }
-
+                            is CommonUser -> regular("User ")
                             is CommonBot,
                             is ExtendedBot -> regular("Bot ")
-                        } + code(user.id.chatId.toString()) + " (${user.firstName} ${user.lastName}: ${user.username?.username ?: "Without username"})"
+                        } + code(user.id.chatId.toString()) + " (${user.firstName} ${user.lastName}: ${user.username ?.username ?: "Without username"})"
                     }
-                    is ForwardInfo.PublicChat.FromChannel -> {
-                        regular("Channel (") + (forwardInfo.channelChat.username ?.let {
-                            link(
-                                forwardInfo.channelChat.title,
-                                makeLink(it)
-                            )
-                        } ?: code(forwardInfo.channelChat.title)) + ")"
-                    }
-                    is ForwardInfo.PublicChat.FromSupergroup -> regular("Supergroup (") + code(forwardInfo.group.title) + ")"
-                    is ForwardInfo.PublicChat.SentByChannel -> regular("Sent by channel (") + code(forwardInfo.channelChat.title) + ")"
+                    is ForwardFromChannelInfo -> regular("Channel (") + code((forwardInfo.channelChat).title) + ")"
+                    is ForwardFromSupergroupInfo -> regular("Supergroup (") + code((forwardInfo.group).title) + ")"
                 }
             }
             reply(it, toAnswer)
+            coroutineContext.job.invokeOnCompletion { println("completance of onContentMessage") }
         }
+        coroutineContext.job.invokeOnCompletion { println("Completed :)") }
     }.second.join()
 }

GetMeBot/build.gradle

@@ -1,6 +1,6 @@
 buildscript {
     repositories {
-        mavenCentral()
+        jcenter()
     }
 
     dependencies {
@@ -11,7 +11,7 @@ buildscript {
 apply plugin: 'kotlin'
 apply plugin: 'application'
 
-mainClassName="GetMeBotKt"
+mainClassName="HelloBotKt"
 
 
 dependencies {

GetMeBot/src/main/kotlin/GetMeBot.kt

@@ -1,29 +1,13 @@
-import dev.inmo.kslog.common.KSLog
-import dev.inmo.kslog.common.LogLevel
-import dev.inmo.kslog.common.defaultMessageFormatter
-import dev.inmo.kslog.common.setDefaultKSLog
-import dev.inmo.tgbotapi.bot.ktor.telegramBot
+import dev.inmo.tgbotapi.bot.Ktor.telegramBot
 import dev.inmo.tgbotapi.extensions.api.bot.getMe
-import dev.inmo.tgbotapi.extensions.api.chat.get.getChat
 
 /**
- * This is one of the easiest bots - it will just print information about itself
+ * This is one of the most easiest bot - it will just print information about itself
  */
 suspend fun main(vararg args: String) {
     val botToken = args.first()
-    val isDebug = args.getOrNull(1) == "debug"
-
-    if (isDebug) {
-        setDefaultKSLog(
-            KSLog { level: LogLevel, tag: String?, message: Any, throwable: Throwable? ->
-                println(defaultMessageFormatter(level, tag, message, throwable))
-            }
-        )
-    }
 
     val bot = telegramBot(botToken)
 
-    val me = bot.getMe()
-    println(me)
-    println(bot.getChat(me))
-}
+    println(bot.getMe())
+}

GiveawaysBot/README.md

@@ -1,9 +0,0 @@
-# CustomBot
-
-Printing giveaways
-
-## Launch
-
-```bash
-../gradlew run --args="BOT_TOKEN"
-```

GiveawaysBot/build.gradle

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

GiveawaysBot/src/main/kotlin/GiveawaysBot.kt

@@ -1,57 +0,0 @@
-import dev.inmo.kslog.common.KSLog
-import dev.inmo.kslog.common.LogLevel
-import dev.inmo.kslog.common.defaultMessageFormatter
-import dev.inmo.kslog.common.setDefaultKSLog
-import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions
-import dev.inmo.tgbotapi.extensions.api.bot.getMe
-import dev.inmo.tgbotapi.extensions.behaviour_builder.telegramBotWithBehaviourAndLongPolling
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onGiveawayCompleted
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onGiveawayContent
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onGiveawayCreated
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onGiveawayWinners
-import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.Dispatchers
-
-/**
- * This place can be the playground for your code.
- */
-suspend fun main(vararg args: String) {
-    val botToken = args.first()
-
-    val isDebug = args.any { it == "debug" }
-    val isTestServer = args.any { it == "testServer" }
-
-    if (isDebug) {
-        setDefaultKSLog(
-            KSLog { level: LogLevel, tag: String?, message: Any, throwable: Throwable? ->
-                println(defaultMessageFormatter(level, tag, message, throwable))
-            }
-        )
-    }
-
-    telegramBotWithBehaviourAndLongPolling(botToken, testServer = isTestServer) {
-        // start here!!
-        val me = getMe()
-        println(me)
-
-        onGiveawayCreated {
-            println(it)
-        }
-
-        onGiveawayCompleted {
-            println(it)
-        }
-
-        onGiveawayWinners {
-            println(it)
-        }
-
-        onGiveawayContent {
-            println(it)
-        }
-
-//        allUpdatesFlow.subscribeSafelyWithoutExceptions(this) {
-//            println(it)
-//        }
-    }.second.join()
-}

HelloBot/build.gradle

@@ -1,6 +1,6 @@
 buildscript {
     repositories {
-        mavenCentral()
+        jcenter()
     }
 
     dependencies {

HelloBot/src/main/kotlin/HelloBot.kt

@@ -1,75 +1,41 @@
 import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions
-import dev.inmo.tgbotapi.extensions.api.bot.getMe
 import dev.inmo.tgbotapi.extensions.api.chat.get.getChat
 import dev.inmo.tgbotapi.extensions.api.send.reply
+import dev.inmo.tgbotapi.extensions.api.send.sendTextMessage
 import dev.inmo.tgbotapi.extensions.behaviour_builder.telegramBotWithBehaviourAndLongPolling
 import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onContentMessage
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onMentionWithAnyContent
-import dev.inmo.tgbotapi.extensions.utils.extensions.raw.sender_chat
-import dev.inmo.tgbotapi.extensions.utils.extensions.raw.text
 import dev.inmo.tgbotapi.extensions.utils.formatting.linkMarkdownV2
 import dev.inmo.tgbotapi.extensions.utils.formatting.textMentionMarkdownV2
-import dev.inmo.tgbotapi.extensions.utils.ifFromChannelGroupContentMessage
-import dev.inmo.tgbotapi.types.chat.*
-import dev.inmo.tgbotapi.types.message.MarkdownV2
-import dev.inmo.tgbotapi.utils.PreviewFeature
+import dev.inmo.tgbotapi.types.ParseMode.MarkdownV2
+import dev.inmo.tgbotapi.types.User
+import dev.inmo.tgbotapi.types.chat.abstracts.*
 import dev.inmo.tgbotapi.utils.extensions.escapeMarkdownV2Common
-import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.*
 
 /**
  * The main purpose of this bot is just to answer "Oh, hi, " and add user mention here
  */
-@OptIn(PreviewFeature::class)
 suspend fun main(vararg args: String) {
     val botToken = args.first()
 
     telegramBotWithBehaviourAndLongPolling(botToken, CoroutineScope(Dispatchers.IO)) {
-        val me = getMe()
-        onContentMessage(
-            initialFilter = initialFilter@{ it.text ?.contains(me.username ?.full ?: return@initialFilter false) == true }
-        ) { message ->
-            val answerText = when (val chat = message.chat) {
-                is PreviewChannelChat -> {
-                    val sender = message.sender_chat
-                    val answer = "Hi everybody in this channel \"${chat.title}\"" + if (sender != null) {
-                        " and you, " + when (sender) {
-                            is BusinessChat -> "business chat (wat) ${sender.original}"
-                            is PrivateChat -> "${sender.lastName} ${sender.firstName}"
-                            is GroupChat -> "group ${sender.title}"
-                            is ChannelChat ->  "channel ${sender.title}"
-                            is UnknownChatType -> "wat chat (${sender})"
-                        }
-                    } else {
-                        ""
-                    }
-                    reply(message, answer.escapeMarkdownV2Common(), MarkdownV2)
-                    return@onContentMessage
-                }
-                is PreviewPrivateChat -> {
-                    reply(message, "Hi, " + "${chat.firstName} ${chat.lastName}".textMentionMarkdownV2(chat.id), MarkdownV2)
-                    return@onContentMessage
-                }
-                is PreviewGroupChat -> {
-                    message.ifFromChannelGroupContentMessage<Unit> {
-                        val answer = "Hi, ${it.senderChat.title}"
-                        reply(message, answer, MarkdownV2)
-                        return@onContentMessage
-                    }
-                    "Oh, hi, " + when (chat) {
-                        is SupergroupChat -> (chat.username ?.username ?: getChat(chat).inviteLink) ?.let {
-                            chat.title.linkMarkdownV2(it)
-                        } ?: chat.title
-                        else -> bot.getChat(chat).inviteLink ?.let {
-                            chat.title.linkMarkdownV2(it)
-                        } ?: chat.title
-                    }
-                }
-                is PreviewBusinessChat -> {
-                    reply(message, "Hi, " + "${chat.original.firstName} ${chat.original.lastName} (as business chat :) )".textMentionMarkdownV2(chat.original.id), MarkdownV2)
-                    return@onContentMessage
-                }
-                is UnknownChatType -> "Unknown :(".escapeMarkdownV2Common()
+        onContentMessage { message ->
+            val chat = message.chat
+            if (chat is ChannelChat) {
+                val answer = "Hi everybody in this channel \"${chat.title}\""
+                sendTextMessage(chat, answer, MarkdownV2)
+                return@onContentMessage
+            }
+            val answerText = "Oh, hi, " + when (chat) {
+                is PrivateChat -> "${chat.firstName} ${chat.lastName}".textMentionMarkdownV2(chat.id)
+                is User -> "${chat.firstName} ${chat.lastName}".textMentionMarkdownV2(chat.id)
+                is SupergroupChat -> (chat.username ?.username ?: getChat(chat).inviteLink) ?.let {
+                    chat.title.linkMarkdownV2(it)
+                } ?: chat.title
+                is GroupChat -> bot.getChat(chat).inviteLink ?.let {
+                    chat.title.linkMarkdownV2(it)
+                } ?: chat.title
+                else -> "Unknown :(".escapeMarkdownV2Common()
             }
             reply(
                 message,

InlineQueriesBot/README.md

@@ -1,9 +0,0 @@
-# InlineQueriesBot
-
-This bot will form the inline queries for you. For that feature you should explicitly enable inline queries in bot settings
-
-## Launch
-
-```bash
-../gradlew run --args="BOT_TOKEN"
-```

InlineQueriesBot/build.gradle

@@ -1,37 +0,0 @@
-buildscript {
-    repositories {
-        mavenCentral()
-    }
-
-    dependencies {
-        classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version"
-    }
-}
-
-plugins {
-    id "org.jetbrains.kotlin.multiplatform"
-}
-
-apply from: "$nativePartTemplate"
-
-kotlin {
-    jvm {
-        binaries {
-            executable {
-                mainClass.set("InlineQueriesBotKt")
-            }
-        }
-    }
-
-    sourceSets {
-        commonMain {
-            dependencies {
-                implementation kotlin('stdlib')
-
-                api "dev.inmo:tgbotapi:$telegram_bot_api_version"
-                api "io.ktor:ktor-client-logging:$ktor_version"
-            }
-        }
-    }
-}
-

InlineQueriesBot/src/commonMain/kotlin/Bot.kt

@@ -1,68 +0,0 @@
-import dev.inmo.micro_utils.coroutines.subscribeLoggingDropExceptions
-import dev.inmo.tgbotapi.extensions.api.answers.answer
-import dev.inmo.tgbotapi.extensions.api.bot.getMe
-import dev.inmo.tgbotapi.extensions.api.send.reply
-import dev.inmo.tgbotapi.extensions.api.telegramBot
-import dev.inmo.tgbotapi.extensions.behaviour_builder.buildBehaviourWithLongPolling
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onBaseInlineQuery
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onDeepLink
-import dev.inmo.tgbotapi.requests.answers.InlineQueryResultsButton
-import dev.inmo.tgbotapi.types.InlineQueries.InlineQueryResult.InlineQueryResultArticle
-import dev.inmo.tgbotapi.types.InlineQueries.InputMessageContent.InputTextMessageContent
-import dev.inmo.tgbotapi.types.InlineQueryId
-import dev.inmo.tgbotapi.types.inlineQueryAnswerResultsLimit
-import dev.inmo.tgbotapi.utils.buildEntities
-
-/**
- * Thi bot will create inline query answers. You
- * should enable inline queries in bot settings
- */
-suspend fun doInlineQueriesBot(token: String) {
-    val bot = telegramBot(token)
-
-    bot.buildBehaviourWithLongPolling(
-        defaultExceptionsHandler = { it.printStackTrace() },
-    ) {
-        onBaseInlineQuery {
-            val page = it.offset.toIntOrNull() ?: 0
-            val results = (0 until inlineQueryAnswerResultsLimit.last).map {
-                (page * inlineQueryAnswerResultsLimit.last) + it
-            }
-
-            answer(
-                it,
-                results = results.map { resultNumber ->
-                    val inlineQueryId = InlineQueryId(resultNumber.toString())
-                    InlineQueryResultArticle(
-                        inlineQueryId,
-                        "Title $resultNumber",
-                        InputTextMessageContent(
-                            buildEntities {
-                                +"Result text of " + resultNumber.toString() + " result:\n"
-                                +it.query
-                            }
-                        ),
-                        description = "Description of $resultNumber result"
-                    )
-                },
-                cachedTime = 0,
-                isPersonal = true,
-                button = InlineQueryResultsButton.Start(
-                    "Text of button with page $page",
-                    "deep_link_for_page_$page"
-                ),
-                nextOffset = (page + 1).toString()
-            )
-        }
-
-        onDeepLink { (message, deepLink) ->
-            reply(message, deepLink)
-        }
-
-        allUpdatesFlow.subscribeLoggingDropExceptions(scope = this) {
-            println(it)
-        }
-
-        println(getMe())
-    }.join()
-}

InlineQueriesBot/src/jvmMain/kotlin/InlineQueriesBot.kt

@@ -1,3 +0,0 @@
-suspend fun main(args: Array<String>) {
-    doInlineQueriesBot(args.first())
-}

InlineQueriesBot/src/nativeMain/kotlin/InlineQueriesBot.kt

@@ -1,7 +0,0 @@
-import kotlinx.coroutines.runBlocking
-
-fun main(args: Array<String>) {
-    runBlocking {
-        doInlineQueriesBot(args.first())
-    }
-}

KeyboardsBot/KeyboardsBotLib/build.gradle

@@ -1,32 +0,0 @@
-buildscript {
-    repositories {
-        mavenCentral()
-    }
-
-    dependencies {
-        classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version"
-    }
-}
-
-plugins {
-    id "org.jetbrains.kotlin.multiplatform"
-}
-
-
-kotlin {
-    jvm()
-    js(IR) {
-        browser()
-        binaries.executable()
-    }
-
-    sourceSets {
-        commonMain {
-            dependencies {
-                implementation kotlin('stdlib')
-
-                api "dev.inmo:tgbotapi:$telegram_bot_api_version"
-            }
-        }
-    }
-}

KeyboardsBot/KeyboardsBotLib/src/commonMain/kotlin/KeyboardsBot.kt

@@ -1,178 +0,0 @@
-import dev.inmo.micro_utils.coroutines.subscribeLoggingDropExceptions
-import dev.inmo.tgbotapi.bot.ktor.telegramBot
-import dev.inmo.tgbotapi.extensions.api.answers.answer
-import dev.inmo.tgbotapi.extensions.api.bot.getMe
-import dev.inmo.tgbotapi.extensions.api.bot.setMyCommands
-import dev.inmo.tgbotapi.extensions.api.edit.edit
-import dev.inmo.tgbotapi.extensions.api.edit.text.editMessageText
-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.*
-import dev.inmo.tgbotapi.extensions.utils.types.buttons.*
-import dev.inmo.tgbotapi.extensions.utils.withContent
-import dev.inmo.tgbotapi.types.BotCommand
-import dev.inmo.tgbotapi.types.InlineQueries.InlineQueryResult.InlineQueryResultArticle
-import dev.inmo.tgbotapi.types.InlineQueries.InputMessageContent.InputTextMessageContent
-import dev.inmo.tgbotapi.types.InlineQueryId
-import dev.inmo.tgbotapi.types.message.content.TextContent
-import dev.inmo.tgbotapi.utils.PreviewFeature
-import dev.inmo.tgbotapi.utils.botCommand
-import dev.inmo.tgbotapi.utils.regular
-import dev.inmo.tgbotapi.utils.row
-import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.SupervisorJob
-import kotlinx.coroutines.currentCoroutineContext
-
-fun String.parsePageAndCount(): Pair<Int, Int>? {
-    val (pageString, countString) = split(" ").takeIf { it.count() > 1 } ?: return null
-    return Pair(
-        pageString.toIntOrNull() ?: return null,
-        countString.toIntOrNull() ?: return null
-    )
-}
-
-fun InlineKeyboardBuilder.includePageButtons(page: Int, count: Int) {
-    val numericButtons = listOfNotNull(
-        page - 1,
-        page,
-        page + 1,
-    )
-    row {
-        val numbersRange = 1 .. count
-        numericButtons.forEach {
-            if (it in numbersRange) {
-                dataButton(it.toString(), "$it $count")
-            }
-        }
-    }
-    row {
-        copyTextButton("Command copy button", "/inline $page $count")
-    }
-
-    row {
-        if (page - 1 > 2) {
-            dataButton("<<", "1 $count")
-        }
-        if (page - 1 > 1) {
-            dataButton("<", "${page - 2} $count")
-        }
-
-        if (page + 1 < count) {
-            dataButton(">", "${page + 2} $count")
-        }
-        if (page + 2 < count) {
-            dataButton(">>", "$count $count")
-        }
-    }
-    row {
-        inlineQueryInChosenChatButton(
-            "Send somebody page",
-            query = "$page $count",
-            allowUsers = true,
-            allowBots = true,
-            allowGroups = true,
-            allowChannels = true,
-        )
-    }
-}
-
-@OptIn(PreviewFeature::class)
-suspend fun activateKeyboardsBot(
-    token: String,
-    print: (Any) -> Unit
-) {
-    val bot = telegramBot(token)
-
-    print(bot.getMe())
-
-    bot.buildBehaviourWithLongPolling(CoroutineScope(currentCoroutineContext() + SupervisorJob())) {
-        onCommandWithArgs("inline") { message, args ->
-            val numberArgs = args.mapNotNull { it.toIntOrNull() }
-            val numberOfPages = numberArgs.getOrNull(1) ?: numberArgs.firstOrNull() ?: 10
-            val page = numberArgs.firstOrNull()?.takeIf { numberArgs.size > 1 }?.coerceAtLeast(1) ?: 1
-            reply(
-                message,
-                replyMarkup = inlineKeyboard {
-                    includePageButtons(page, numberOfPages)
-                }
-            ) {
-                regular("Your inline keyboard with $numberOfPages pages")
-            }
-        }
-
-        onMessageDataCallbackQuery {
-            val (page, count) = it.data.parsePageAndCount() ?: it.let {
-                answer(it, "Unsupported data :(")
-                return@onMessageDataCallbackQuery
-            }
-
-            edit(
-                it.message.withContent<TextContent>() ?: it.let {
-                    answer(it, "Unsupported message type :(")
-                    return@onMessageDataCallbackQuery
-                },
-                replyMarkup = inlineKeyboard {
-                    includePageButtons(page, count)
-                }
-            ) {
-                regular("This is $page of $count")
-            }
-            answer(it)
-        }
-        onInlineMessageIdDataCallbackQuery {
-            val (page, count) = it.data.parsePageAndCount() ?: it.let {
-                answer(it, "Unsupported data :(")
-                return@onInlineMessageIdDataCallbackQuery
-            }
-
-            editMessageText(
-                it.inlineMessageId,
-                replyMarkup = inlineKeyboard {
-                    includePageButtons(page, count)
-                }
-            ) {
-                regular("This is $page of $count")
-            }
-            answer(it)
-        }
-
-        onBaseInlineQuery {
-            val page = it.query.takeWhile { it.isDigit() }.toIntOrNull() ?: return@onBaseInlineQuery
-            val count = it.query.removePrefix(page.toString()).dropWhile { !it.isDigit() }.takeWhile { it.isDigit() }
-                .toIntOrNull() ?: return@onBaseInlineQuery
-
-            answer(
-                it,
-                results = listOf(
-                    InlineQueryResultArticle(
-                        InlineQueryId(it.query),
-                        "Send buttons",
-                        InputTextMessageContent("It is sent via inline mode inline buttons"),
-                        replyMarkup = inlineKeyboard {
-                            includePageButtons(page, count)
-                        }
-                    )
-                )
-            )
-        }
-
-        onUnhandledCommand {
-            reply(
-                it,
-                replyMarkup = replyKeyboard(resizeKeyboard = true, oneTimeKeyboard = true) {
-                    row {
-                        simpleButton("/inline")
-                    }
-                }
-            ) {
-                +"Use " + botCommand("inline") + " to get pagination inline keyboard"
-            }
-        }
-
-        setMyCommands(BotCommand("inline", "Creates message with pagination inline keyboard"))
-
-        allUpdatesFlow.subscribeLoggingDropExceptions(scope = this) {
-            println(it)
-        }
-    }.join()
-}

KeyboardsBot/KeyboardsBotLib/src/jsMain/kotlin/KeyboardsBot.kt

@@ -1,32 +0,0 @@
-import kotlinx.browser.document
-import kotlinx.coroutines.*
-import org.w3c.dom.*
-
-private val scope = CoroutineScope(Dispatchers.Default)
-
-fun main() {
-    document.addEventListener(
-        "DOMContentLoaded",
-        {
-            val botsContainer = document.getElementById("bots_container") ?: return@addEventListener
-
-            (document.getElementById("bot_token_form") as? HTMLFormElement) ?.onsubmit = {
-                (document.getElementById("bot_token") as? HTMLInputElement) ?.value ?.let { token ->
-                    val botContainer = document.createElement("div") as HTMLDivElement
-                    botsContainer.append(botContainer)
-
-                    val infoDiv = document.createElement("div") as HTMLDivElement
-                    botContainer.append(infoDiv)
-
-                    scope.launch {
-                        activateKeyboardsBot(token) {
-                            infoDiv.innerHTML = it.toString()
-                        }
-                    }
-                }
-
-                false
-            }
-        }
-    )
-}

KeyboardsBot/KeyboardsBotLib/src/jsMain/resources/index.html

@@ -1,16 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <title>Keyboards bot</title>
-</head>
-<body>
-    <form id="bot_token_form">
-        <input type="text" id="bot_token">
-        <input type="submit" value="Start bot">
-    </form>
-    <div id="start_offer">Type your bot token to the input above to start its work</div>
-    <script type="text/javascript" src="KeyboardsBotLib.js"></script>
-    <div id="bots_container"></div>
-</body>
-</html>

KeyboardsBot/jvm_launcher/build.gradle

@@ -1,21 +0,0 @@
-buildscript {
-    repositories {
-        mavenCentral()
-    }
-
-    dependencies {
-        classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version"
-    }
-}
-
-apply plugin: 'kotlin'
-apply plugin: 'application'
-
-mainClassName="KeyboardsBotJvmKt"
-
-
-dependencies {
-    implementation "org.jetbrains.kotlin:kotlin-stdlib:$kotlin_version"
-
-    implementation project(":KeyboardsBot:KeyboardsBotLib")
-}

KeyboardsBot/jvm_launcher/src/main/kotlin/KeyboardsBotJvm.kt

@@ -1,24 +0,0 @@
-import dev.inmo.kslog.common.KSLog
-import dev.inmo.kslog.common.LogLevel
-import dev.inmo.kslog.common.defaultMessageFormatter
-import dev.inmo.kslog.common.setDefaultKSLog
-import kotlinx.coroutines.Dispatchers
-import kotlinx.coroutines.withContext
-
-suspend fun main(args: Array<String>) {
-    val isDebug = args.any { it == "debug" }
-
-    if (isDebug) {
-        setDefaultKSLog(
-            KSLog { level: LogLevel, tag: String?, message: Any, throwable: Throwable? ->
-                println(defaultMessageFormatter(level, tag, message, throwable))
-            }
-        )
-    }
-
-    withContext(Dispatchers.IO) { // IO for inheriting of it in side of activateKeyboardsBot
-        activateKeyboardsBot(args.first()) {
-            println(it)
-        }
-    }
-}

LinkPreviewsBot/README.md

@@ -1,9 +0,0 @@
-# ReactionsInfoBot
-
-This bot will resend messages with links with all variants of `LinkPreviewOptions`
-
-## Launch
-
-```bash
-../gradlew run --args="BOT_TOKEN"
-```

LinkPreviewsBot/build.gradle

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

LinkPreviewsBot/src/main/kotlin/LinkPreviewsBot.kt

@@ -1,84 +0,0 @@
-import dev.inmo.kslog.common.KSLog
-import dev.inmo.kslog.common.LogLevel
-import dev.inmo.kslog.common.defaultMessageFormatter
-import dev.inmo.kslog.common.setDefaultKSLog
-import dev.inmo.tgbotapi.bot.ktor.telegramBot
-import dev.inmo.tgbotapi.extensions.api.send.reply
-import dev.inmo.tgbotapi.extensions.api.send.send
-import dev.inmo.tgbotapi.extensions.behaviour_builder.buildBehaviourWithLongPolling
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onContentMessage
-import dev.inmo.tgbotapi.extensions.utils.textLinkTextSourceOrNull
-import dev.inmo.tgbotapi.extensions.utils.uRLTextSourceOrNull
-import dev.inmo.tgbotapi.extensions.utils.withContentOrNull
-import dev.inmo.tgbotapi.types.LinkPreviewOptions
-import dev.inmo.tgbotapi.types.message.content.TextedContent
-import dev.inmo.tgbotapi.utils.regular
-
-/**
- * This bot will reply with the same
- */
-suspend fun main(vararg args: String) {
-    val botToken = args.first()
-    val isDebug = args.getOrNull(1) == "debug"
-
-    if (isDebug) {
-        setDefaultKSLog(
-            KSLog { level: LogLevel, tag: String?, message: Any, throwable: Throwable? ->
-                println(defaultMessageFormatter(level, tag, message, throwable))
-            }
-        )
-    }
-
-    val bot = telegramBot(botToken)
-
-    bot.buildBehaviourWithLongPolling {
-        onContentMessage { contentMessage ->
-            val url = contentMessage.withContentOrNull<TextedContent>() ?.let { message ->
-                message.content.textSources.firstNotNullOfOrNull {
-                    it.textLinkTextSourceOrNull() ?.url ?: it.uRLTextSourceOrNull() ?.source
-                }
-            } ?: null.apply {
-                reply(contentMessage) {
-                    regular("I am support only content with text contains url only")
-                }
-            } ?: return@onContentMessage
-            contentMessage.withContentOrNull<TextedContent>() ?.let {
-                send(
-                    it.chat,
-                    it.content.textSources,
-                    linkPreviewOptions = LinkPreviewOptions.Disabled
-                )
-                send(
-                    it.chat,
-                    it.content.textSources,
-                    linkPreviewOptions = LinkPreviewOptions.Large(url, showAboveText = true)
-                )
-                send(
-                    it.chat,
-                    it.content.textSources,
-                    linkPreviewOptions = LinkPreviewOptions.Large(url, showAboveText = false)
-                )
-                send(
-                    it.chat,
-                    it.content.textSources,
-                    linkPreviewOptions = LinkPreviewOptions.Small(url, showAboveText = true)
-                )
-                send(
-                    it.chat,
-                    it.content.textSources,
-                    linkPreviewOptions = LinkPreviewOptions.Small(url, showAboveText = false)
-                )
-                send(
-                    it.chat,
-                    it.content.textSources,
-                    linkPreviewOptions = LinkPreviewOptions.Default(url, showAboveText = true)
-                )
-                send(
-                    it.chat,
-                    it.content.textSources,
-                    linkPreviewOptions = LinkPreviewOptions.Default(url, showAboveText = false)
-                )
-            }
-        }
-    }.join()
-}

LiveLocationsBot/README.md

@@ -1,9 +0,0 @@
-# LiveLocationsBot
-
-This bot will send you live location and update it from time to time
-
-## Launch
-
-```bash
-../gradlew run --args="BOT_TOKEN"
-```

LiveLocationsBot/build.gradle

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

LiveLocationsBot/src/main/kotlin/LiveLocationsBot.kt

@@ -1,67 +0,0 @@
-import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions
-import dev.inmo.tgbotapi.extensions.api.EditLiveLocationInfo
-import dev.inmo.tgbotapi.extensions.api.edit.location.live.stopLiveLocation
-import dev.inmo.tgbotapi.extensions.api.handleLiveLocation
-import dev.inmo.tgbotapi.extensions.behaviour_builder.expectations.waitMessageDataCallbackQuery
-import dev.inmo.tgbotapi.extensions.behaviour_builder.telegramBotWithBehaviourAndLongPolling
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onCommand
-import dev.inmo.tgbotapi.extensions.utils.extensions.sameMessage
-import dev.inmo.tgbotapi.extensions.utils.types.buttons.dataButton
-import dev.inmo.tgbotapi.extensions.utils.types.buttons.flatInlineKeyboard
-import dev.inmo.tgbotapi.types.message.abstracts.ContentMessage
-import dev.inmo.tgbotapi.types.message.content.LocationContent
-import kotlinx.coroutines.*
-import kotlinx.coroutines.flow.FlowCollector
-import kotlinx.coroutines.flow.MutableStateFlow
-import kotlinx.coroutines.flow.filter
-import kotlinx.coroutines.flow.first
-import kotlinx.coroutines.flow.flow
-
-/**
- * This bot will send you live location and update it from time to time
- */
-suspend fun main(vararg args: String) {
-    val botToken = args.first()
-
-    telegramBotWithBehaviourAndLongPolling(botToken, CoroutineScope(Dispatchers.IO)) {
-        val locationsFlow = flow {
-            var i = 0
-            while (isActive) {
-                val newInfo = EditLiveLocationInfo(
-                    latitude = i.toDouble(),
-                    longitude = i.toDouble(),
-                    replyMarkup = flatInlineKeyboard {
-                        dataButton("Cancel", "cancel")
-                    }
-                )
-                emit(newInfo)
-                i++
-                delay(3000L) // 3 seconds
-            }
-        }
-        onCommand("start") {
-            // in this flow will be actual message with live location
-            val currentMessageState = MutableStateFlow<ContentMessage<LocationContent>?>(null)
-            val sendingJob = launch {
-                handleLiveLocation(
-                    it.chat.id,
-                    locationsFlow,
-                    sentMessageFlow = { currentMessageState.emit(it) },
-                )
-            }
-
-            waitMessageDataCallbackQuery().filter {
-                it.message.sameMessage(
-                    currentMessageState.value ?: return@filter false
-                ) && it.data == "cancel"
-            }.first()
-
-            sendingJob.cancel() // ends live location
-            currentMessageState.value ?.let {
-                stopLiveLocation(it, replyMarkup = null)
-            }
-        }
-        allUpdatesFlow.subscribeSafelyWithoutExceptions(this) { println(it) }
-    }.second.join()
-}
-

MemberUpdatedWatcherBot/README.md

@@ -1,10 +0,0 @@
-# MemberUpdatedWatcherBot
-
-This bot will watch for some ChatMemberUpdated events using new extensions from 18.0.0
-
-
-## Launch
-
-```bash
-../gradlew run --args="BOT_TOKEN"
-```

MemberUpdatedWatcherBot/build.gradle

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

MemberUpdatedWatcherBot/src/main/kotlin/MemberUpdatedWatcher.kt

@@ -1,98 +0,0 @@
-import dev.inmo.kslog.common.*
-import dev.inmo.tgbotapi.extensions.api.*
-import dev.inmo.tgbotapi.extensions.api.bot.*
-import dev.inmo.tgbotapi.extensions.api.send.*
-import dev.inmo.tgbotapi.extensions.behaviour_builder.*
-import dev.inmo.tgbotapi.extensions.behaviour_builder.filters.chatMemberGotRestrictedFilter
-import dev.inmo.tgbotapi.extensions.behaviour_builder.filters.chatMemberGotRestrictionsChangedFilter
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.*
-import dev.inmo.tgbotapi.extensions.behaviour_builder.utils.*
-import dev.inmo.tgbotapi.extensions.utils.*
-import dev.inmo.tgbotapi.types.chat.member.*
-import dev.inmo.tgbotapi.utils.*
-
-
-@OptIn(PreviewFeature::class)
-suspend fun main(args: Array<String>) {
-    val token = args.first()
-
-    val isDebug = args.any { it == "debug" }
-
-    if (isDebug) {
-        setDefaultKSLog(
-            KSLog { level: LogLevel, tag: String?, message: Any, throwable: Throwable? ->
-                println(defaultMessageFormatter(level, tag, message, throwable))
-            }
-        )
-    }
-
-    val internalLogger = KSLog { level: LogLevel, tag: String?, message: Any, throwable: Throwable? ->
-        println(defaultMessageFormatter(level, tag ?: "ChatMemberUpdates", message, throwable))
-    }
-
-    val bot = telegramBot(token)
-
-    bot.buildBehaviourWithLongPolling {
-        val me = getMe()
-        val filterSelfUpdates = SimpleFilter<ChatMemberUpdated> {
-            it.member.id == me.id
-        }
-
-        // This bot updates
-        onChatMemberJoined(initialFilter = filterSelfUpdates) {
-            internalLogger.i("Bot was added to chat")
-            send(it.chat.id, "I was added to chat. Please grant me admin permissions to make me able to watch other users' events")
-        }
-
-        onChatMemberGotPromoted(initialFilter = filterSelfUpdates) {
-            internalLogger.i("Bot was granted admin permissions")
-            send(it.chat.id, "I was promoted to admin. I now can watch other users' events")
-        }
-
-        onChatMemberGotDemoted(initialFilter = filterSelfUpdates) {
-            internalLogger.i("Admin permissions were revoked")
-            send(it.chat.id, "I'm no longer an admin. Admin permissions are required to watch other users' events")
-        }
-
-        // All users updates
-        onChatMemberJoined {
-            val member = it.member
-            internalLogger.i("${member.firstName} joined the chat: ${it.oldChatMemberState::class.simpleName} => ${it.newChatMemberState::class.simpleName}")
-            send(it.chat.id, "Welcome ${member.firstName}")
-        }
-
-        onChatMemberLeft {
-            val member = it.member
-            internalLogger.i("${member.firstName} left the chat: ${it.oldChatMemberState::class.simpleName} => ${it.newChatMemberState::class.simpleName}")
-            send(it.chat.id, "Goodbye ${member.firstName}")
-        }
-
-        onChatMemberGotPromoted {
-            val newState = it.newChatMemberState.administratorChatMemberOrThrow()
-            internalLogger.i("${newState.user.firstName} got promoted to ${newState.customTitle ?: "Admin"}: ${it.oldChatMemberState::class.simpleName} => ${it.newChatMemberState::class.simpleName}")
-            send(it.chat.id, "${newState.user.firstName} is now an ${newState.customTitle ?: "Admin"}")
-        }
-
-        onChatMemberGotDemoted {
-            val member = it.member
-            internalLogger.i("${member.firstName} got demoted: ${it.oldChatMemberState::class.simpleName} => ${it.newChatMemberState::class.simpleName}")
-            send(it.chat.id, "${member.firstName} is now got demoted back to member")
-        }
-
-        onChatMemberGotPromotionChanged {
-            val member = it.member
-            val message = "${member.firstName} has the permissions changed: ${it.oldChatMemberState::class.simpleName} => ${it.newChatMemberState::class.simpleName}"
-            internalLogger.i(message)
-            send(it.chat.id, message)
-        }
-
-        onChatMemberUpdated(
-            initialFilter = chatMemberGotRestrictedFilter + chatMemberGotRestrictionsChangedFilter,
-        ) {
-            val member = it.member
-            val message = "${member.firstName} has the permissions changed: ${it.oldChatMemberState::class.simpleName} => ${it.newChatMemberState::class.simpleName}"
-            internalLogger.i(message)
-            send(it.chat.id, message)
-        }
-    }.join()
-}

PollsBot/README.md

@@ -1,11 +0,0 @@
-# PollsBot
-
-This bot will send test poll in the chat where commands will be received. Commands:
-
-
-
-## Launch
-
-```bash
-../gradlew run --args="BOT_TOKEN"
-```

PollsBot/build.gradle

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

PollsBot/src/main/kotlin/PollsBot.kt

@@ -1,179 +0,0 @@
-import dev.inmo.kslog.common.KSLog
-import dev.inmo.kslog.common.LogLevel
-import dev.inmo.kslog.common.defaultMessageFormatter
-import dev.inmo.kslog.common.setDefaultKSLog
-import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions
-import dev.inmo.tgbotapi.extensions.api.bot.setMyCommands
-import dev.inmo.tgbotapi.extensions.api.send.polls.sendQuizPoll
-import dev.inmo.tgbotapi.extensions.api.send.polls.sendRegularPoll
-import dev.inmo.tgbotapi.extensions.api.send.send
-import dev.inmo.tgbotapi.extensions.behaviour_builder.telegramBotWithBehaviourAndLongPolling
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onCommand
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onPollAnswer
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onPollUpdates
-import dev.inmo.tgbotapi.extensions.utils.customEmojiTextSourceOrNull
-import dev.inmo.tgbotapi.extensions.utils.extensions.parseCommandsWithArgsSources
-import dev.inmo.tgbotapi.types.BotCommand
-import dev.inmo.tgbotapi.types.IdChatIdentifier
-import dev.inmo.tgbotapi.types.PollId
-import dev.inmo.tgbotapi.types.ReplyParameters
-import dev.inmo.tgbotapi.types.polls.InputPollOption
-import dev.inmo.tgbotapi.types.polls.PollAnswer
-import dev.inmo.tgbotapi.utils.buildEntities
-import dev.inmo.tgbotapi.utils.customEmoji
-import dev.inmo.tgbotapi.utils.regular
-import dev.inmo.tgbotapi.utils.underline
-import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.Dispatchers
-import kotlinx.coroutines.sync.Mutex
-import kotlinx.coroutines.sync.withLock
-import kotlin.random.Random
-
-/**
- * This bot will answer with anonymous or public poll and send message on
- * any update.
- * 
- * * Use `/anonymous` to take anonymous regular poll
- * * Use `/public` to take public regular poll
- */
-suspend fun main(vararg args: String) {
-    val botToken = args.first()
-    val isDebug = args.any { it == "debug" }
-
-    if (isDebug) {
-        setDefaultKSLog(
-            KSLog { level: LogLevel, tag: String?, message: Any, throwable: Throwable? ->
-                println(defaultMessageFormatter(level, tag, message, throwable))
-            }
-        )
-    }
-
-    telegramBotWithBehaviourAndLongPolling(botToken, CoroutineScope(Dispatchers.IO)) {
-        val pollToChat = mutableMapOf<PollId, IdChatIdentifier>()
-        val pollToChatMutex = Mutex()
-
-        onCommand("anonymous", requireOnlyCommandInMessage = false) {
-            val customEmoji = it.content.parseCommandsWithArgsSources()
-                .toList()
-                .firstOrNull { it.first.command == "anonymous" }
-                ?.second
-                ?.firstNotNullOfOrNull { it.customEmojiTextSourceOrNull() }
-            val sentPoll = sendRegularPoll(
-                it.chat.id,
-                buildEntities {
-                    regular("Test regular anonymous poll")
-                    if (customEmoji != null) {
-                        customEmoji(customEmoji.customEmojiId, customEmoji.subsources)
-                    }
-                },
-                (1 .. 10).map {
-                    InputPollOption {
-                        regular(it.toString()) + " "
-                        if (customEmoji != null) {
-                            customEmoji(customEmoji.customEmojiId, customEmoji.subsources)
-                        }
-                    }
-                },
-                isAnonymous = true,
-                replyParameters = ReplyParameters(it)
-            )
-            pollToChatMutex.withLock {
-                pollToChat[sentPoll.content.poll.id] = sentPoll.chat.id
-            }
-        }
-
-        onCommand("public", requireOnlyCommandInMessage = false) {
-            val customEmoji = it.content.parseCommandsWithArgsSources()
-                .toList()
-                .firstOrNull { it.first.command == "public" }
-                ?.second
-                ?.firstNotNullOfOrNull { it.customEmojiTextSourceOrNull() }
-            val sentPoll = sendRegularPoll(
-                it.chat.id,
-                buildEntities {
-                    regular("Test regular non anonymous poll")
-                    if (customEmoji != null) {
-                        customEmoji(customEmoji.customEmojiId, customEmoji.subsources)
-                    }
-                },
-                (1 .. 10).map {
-                    InputPollOption {
-                        regular(it.toString()) + " "
-                        if (customEmoji != null) {
-                            customEmoji(customEmoji.customEmojiId, customEmoji.subsources)
-                        }
-                    }
-                },
-                isAnonymous = false,
-                replyParameters = ReplyParameters(it)
-            )
-            pollToChatMutex.withLock {
-                pollToChat[sentPoll.content.poll.id] = sentPoll.chat.id
-            }
-        }
-
-        onCommand("quiz", requireOnlyCommandInMessage = false) {
-            val customEmoji = it.content.parseCommandsWithArgsSources()
-                .toList()
-                .firstOrNull { it.first.command == "quiz" }
-                ?.second
-                ?.firstNotNullOfOrNull { it.customEmojiTextSourceOrNull() }
-            val correctAnswer = Random.nextInt(10)
-            val sentPoll = sendQuizPoll(
-                it.chat.id,
-                questionEntities = buildEntities {
-                    regular("Test quiz poll")
-                    if (customEmoji != null) {
-                        customEmoji(customEmoji.customEmojiId, customEmoji.subsources)
-                    }
-                },
-                (1 .. 10).map {
-                    InputPollOption {
-                        regular(it.toString()) + " "
-                        if (customEmoji != null) {
-                            customEmoji(customEmoji.customEmojiId, customEmoji.subsources)
-                        }
-                    }
-                },
-                isAnonymous = false,
-                replyParameters = ReplyParameters(it),
-                correctOptionId = correctAnswer,
-                explanationTextSources = buildEntities {
-                    regular("Random solved it to be ") + underline((correctAnswer + 1).toString()) + " "
-                    if (customEmoji != null) {
-                        customEmoji(customEmoji.customEmojiId, customEmoji.subsources)
-                    }
-                }
-            )
-            pollToChatMutex.withLock {
-                pollToChat[sentPoll.content.poll.id] = sentPoll.chat.id
-            }
-        }
-
-        onPollAnswer {
-            val chatId = pollToChat[it.pollId] ?: return@onPollAnswer
-
-            when(it) {
-                is PollAnswer.Public -> send(chatId, "[onPollAnswer] User ${it.user} have answered")
-                is PollAnswer.Anonymous -> send(chatId, "[onPollAnswer] Chat ${it.voterChat} have answered")
-            }
-        }
-
-        onPollUpdates {
-            val chatId = pollToChat[it.id] ?: return@onPollUpdates
-
-            when(it.isAnonymous) {
-                false -> send(chatId, "[onPollUpdates] Public poll updated: ${it.options.joinToString()}")
-                true -> send(chatId, "[onPollUpdates] Anonymous poll updated: ${it.options.joinToString()}")
-            }
-        }
-
-        setMyCommands(
-            BotCommand("anonymous", "Create anonymous regular poll"),
-            BotCommand("public", "Create non anonymous regular poll"),
-            BotCommand("quiz", "Create quiz poll with random right answer"),
-        )
-
-        allUpdatesFlow.subscribeSafelyWithoutExceptions(this) { println(it) }
-    }.second.join()
-}

README.md

@@ -4,8 +4,6 @@ This repository contains several examples of simple bots which are using Telegra
 
 ## How to use this repository
 
-***TO RUN NATIVE TARGETS ON LINUX YOU SHOULD INSTALL CURL LIBRARY. FOR EXAMPLE: `sudo apt install libcurl4-gnutls-dev`***
-
 This repository contains several important things:
 
 * Example subprojects

RandomFileSenderBot/build.gradle

@@ -1,6 +1,6 @@
 buildscript {
     repositories {
-        mavenCentral()
+        jcenter()
     }
 
     dependencies {
@@ -8,29 +8,14 @@ buildscript {
     }
 }
 
-plugins {
-    id "org.jetbrains.kotlin.multiplatform"
+apply plugin: 'kotlin'
+apply plugin: 'application'
+
+mainClassName="RandomFileSenderBotKt"
+
+
+dependencies {
+    implementation "org.jetbrains.kotlin:kotlin-stdlib:$kotlin_version"
+
+    implementation "dev.inmo:tgbotapi:$telegram_bot_api_version"
 }
-
-kotlin {
-    jvm {
-        binaries {
-            executable {
-                mainClass.set("RandomFileSenderBotKt")
-            }
-        }
-    }
-
-    sourceSets {
-        commonMain {
-            dependencies {
-                implementation kotlin('stdlib')
-
-                api "dev.inmo:tgbotapi:$telegram_bot_api_version"
-            }
-        }
-    }
-}
-
-apply from: "$nativePartTemplate"
-

RandomFileSenderBot/src/jvmMain/kotlin/ActualPickFile.kt

@@ -1,10 +0,0 @@
-import dev.inmo.micro_utils.common.MPPFile
-import java.io.File
-
-actual fun pickFile(currentRoot: MPPFile): File? {
-    if (currentRoot.isFile) {
-        return currentRoot
-    } else {
-        return pickFile(currentRoot.listFiles() ?.takeIf { it.isNotEmpty() } ?.random() ?: return null)
-    }
-}

RandomFileSenderBot/src/jvmMain/kotlin/RandomFileSenderBot.kt

@@ -1,5 +0,0 @@
-import dev.inmo.micro_utils.common.MPPFile
-
-suspend fun main(args: Array<String>) {
-    doRandomFileSenderBot(args.first(), MPPFile(args.getOrNull(1) ?: ""))
-}

RandomFileSenderBot/src/main/kotlin/RandomFileSenderBot.kt

@@ -1,5 +1,4 @@
-import dev.inmo.micro_utils.common.MPPFile
-import dev.inmo.micro_utils.common.filesize
+import dev.inmo.tgbotapi.bot.Ktor.telegramBot
 import dev.inmo.tgbotapi.bot.TelegramBot
 import dev.inmo.tgbotapi.extensions.api.bot.getMe
 import dev.inmo.tgbotapi.extensions.api.bot.setMyCommands
@@ -7,19 +6,22 @@ import dev.inmo.tgbotapi.extensions.api.send.media.sendDocument
 import dev.inmo.tgbotapi.extensions.api.send.media.sendDocumentsGroup
 import dev.inmo.tgbotapi.extensions.api.send.reply
 import dev.inmo.tgbotapi.extensions.api.send.withUploadDocumentAction
-import dev.inmo.tgbotapi.extensions.api.telegramBot
+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.onCommand
 import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onCommandWithArgs
 import dev.inmo.tgbotapi.requests.abstracts.asMultipartFile
+import dev.inmo.tgbotapi.requests.abstracts.toInputFile
 import dev.inmo.tgbotapi.types.BotCommand
-import dev.inmo.tgbotapi.types.chat.Chat
-import dev.inmo.tgbotapi.types.media.TelegramMediaDocument
+import dev.inmo.tgbotapi.types.InputMedia.DocumentMediaGroupMemberInputMedia
+import dev.inmo.tgbotapi.types.InputMedia.InputMediaDocument
+import dev.inmo.tgbotapi.types.chat.abstracts.Chat
 import dev.inmo.tgbotapi.types.mediaCountInMediaGroup
+import kotlinx.coroutines.*
+import java.io.File
 
 private const val command = "send_file"
 
-expect fun pickFile(currentRoot: MPPFile): MPPFile?
-
 /**
  * This bot will send files inside of working directory OR from directory in the second argument.
  * You may send /send_file command to this bot to get random file from the directory OR
@@ -27,10 +29,19 @@ expect fun pickFile(currentRoot: MPPFile): MPPFile?
  * /send_file and `/send_file 1` will have the same effect - bot will send one random file.
  * But if you will send `/send_file 5` it will choose 5 random files and send them as group
  */
-suspend fun doRandomFileSenderBot(token: String, folder: MPPFile) {
-    val bot = telegramBot(token)
+suspend fun main(args: Array<String>) {
+    val botToken = args.first()
+    val directoryOrFile = args.getOrNull(1) ?.let { File(it) } ?: File("")
 
-    suspend fun TelegramBot.sendFiles(chat: Chat, files: List<MPPFile>) {
+    fun pickFile(currentRoot: File = directoryOrFile): File? {
+        if (currentRoot.isFile) {
+            return currentRoot
+        } else {
+            return pickFile(currentRoot.listFiles() ?.takeIf { it.isNotEmpty() } ?.random() ?: return null)
+        }
+    }
+
+    suspend fun TelegramBot.sendFiles(chat: Chat, files: List<File>) {
         when (files.size) {
             1 -> sendDocument(
                 chat.id,
@@ -39,12 +50,14 @@ suspend fun doRandomFileSenderBot(token: String, folder: MPPFile) {
             )
             else -> sendDocumentsGroup(
                 chat,
-                files.map { TelegramMediaDocument(it.asMultipartFile()) },
+                files.map { InputMediaDocument(it.asMultipartFile()) },
                 protectContent = true
             )
         }
     }
 
+    val bot = telegramBot(botToken)
+
     bot.buildBehaviourWithLongPolling (defaultExceptionsHandler = { it.printStackTrace() }) {
         onCommandWithArgs(command) { message, args ->
 
@@ -53,12 +66,12 @@ suspend fun doRandomFileSenderBot(token: String, folder: MPPFile) {
                 var sent = false
 
                 var left = count
-                val chosen = mutableListOf<MPPFile>()
+                val chosen = mutableListOf<File>()
 
                 while (left > 0) {
-                    val picked = pickFile(folder) ?.takeIf { it.filesize > 0 } ?: continue
-                    chosen.add(picked)
                     left--
+                    val picked = pickFile() ?: continue
+                    chosen.add(picked)
                     if (chosen.size >= mediaCountInMediaGroup.last) {
                         sendFiles(message.chat, chosen)
                         chosen.clear()
@@ -72,7 +85,7 @@ suspend fun doRandomFileSenderBot(token: String, folder: MPPFile) {
                 }
 
                 if (!sent) {
-                    reply(message, "Nothing selected :(")
+                    bot.reply(message, "Nothing selected :(")
                 }
             }
         }

RandomFileSenderBot/src/nativeMain/kotlin/ActualPickFile.kt

@@ -1,10 +0,0 @@
-import dev.inmo.micro_utils.common.MPPFile
-import okio.FileSystem
-
-actual fun pickFile(currentRoot: MPPFile): MPPFile? {
-    if (FileSystem.SYSTEM.exists(currentRoot) && FileSystem.SYSTEM.listOrNull(currentRoot) == null) {
-        return currentRoot
-    } else {
-        return pickFile(FileSystem.SYSTEM.list(currentRoot).takeIf { it.isNotEmpty() } ?.random() ?: return null)
-    }
-}

RandomFileSenderBot/src/nativeMain/kotlin/RandomFileSenderBot.kt

@@ -1,8 +0,0 @@
-import kotlinx.coroutines.runBlocking
-import okio.Path.Companion.toPath
-
-fun main(args: Array<String>) {
-    runBlocking {
-        doRandomFileSenderBot(args.first(), args.getOrNull(1) ?.toPath() ?: "".toPath())
-    }
-}

ReactionsInfoBot/README.md

@@ -1,9 +0,0 @@
-# ReactionsInfoBot
-
-This bot will send info about user reactions in his PM with reply to message user reacted to
-
-## Launch
-
-```bash
-../gradlew run --args="BOT_TOKEN"
-```

ReactionsInfoBot/build.gradle

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

ReactionsInfoBot/src/main/kotlin/ReactionsInfoBot.kt

@@ -1,68 +0,0 @@
-import dev.inmo.kslog.common.KSLog
-import dev.inmo.kslog.common.LogLevel
-import dev.inmo.kslog.common.defaultMessageFormatter
-import dev.inmo.kslog.common.setDefaultKSLog
-import dev.inmo.tgbotapi.bot.ktor.telegramBot
-import dev.inmo.tgbotapi.extensions.api.chat.get.getChat
-import dev.inmo.tgbotapi.extensions.api.send.reply
-import dev.inmo.tgbotapi.extensions.api.send.setMessageReaction
-import dev.inmo.tgbotapi.extensions.behaviour_builder.buildBehaviourWithLongPolling
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onChatMessageReactionUpdatedByUser
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onChatMessageReactionsCountUpdated
-import dev.inmo.tgbotapi.types.chat.ExtendedChat
-import dev.inmo.tgbotapi.types.reactions.Reaction
-import dev.inmo.tgbotapi.utils.customEmoji
-import dev.inmo.tgbotapi.utils.regular
-
-/**
- * This bot will send info about user reactions in his PM with reply to message user reacted to
- */
-suspend fun main(vararg args: String) {
-    val botToken = args.first()
-    val isDebug = args.getOrNull(1) == "debug"
-
-    if (isDebug) {
-        setDefaultKSLog(
-            KSLog { level: LogLevel, tag: String?, message: Any, throwable: Throwable? ->
-                println(defaultMessageFormatter(level, tag, message, throwable))
-            }
-        )
-    }
-
-    val bot = telegramBot(botToken)
-
-    bot.buildBehaviourWithLongPolling {
-        onChatMessageReactionUpdatedByUser {
-            setMessageReaction(
-                it.chat.id,
-                it.messageId,
-                "✍"
-            )
-            val replyResult = reply(
-                it.chat.id,
-                it.messageId,
-                replyInChatId = it.reactedUser.id
-            ) {
-                regular("Current reactions for message in reply:\n")
-                it.new.forEach {
-                    when (it) {
-                        is Reaction.CustomEmoji -> regular("• ") + customEmoji(it.customEmojiId) + regular("(customEmojiId: ${it.customEmojiId})")
-                        is Reaction.Emoji -> regular("• ${it.emoji}")
-                        is Reaction.Paid -> regular("• Some paid reaction")
-                        is Reaction.Unknown -> regular("• Unknown emoji ($it)")
-                    }
-                    regular("\n")
-                }
-            }
-            setMessageReaction(
-                it.chat.id,
-                it.messageId,
-            )
-        }
-        onChatMessageReactionsCountUpdated {
-            val extendedChat: ExtendedChat = getChat(it.chat)
-            println(extendedChat)
-            println(it)
-        }
-    }.join()
-}

ResenderBot/ResenderBotLib/build.gradle

@@ -1,6 +1,6 @@
 buildscript {
     repositories {
-        mavenCentral()
+        jcenter()
     }
 
     dependencies {
@@ -9,7 +9,7 @@ buildscript {
 }
 
 plugins {
-    id "org.jetbrains.kotlin.multiplatform"
+    id "org.jetbrains.kotlin.multiplatform" version "$kotlin_version"
 }
 
 
@@ -20,9 +20,6 @@ kotlin {
         browser()
         binaries.executable()
     }
-    linuxX64()
-    mingwX64()
-    linuxArm64()
 
     sourceSets {
         commonMain {

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

@@ -1,65 +1,55 @@
-import dev.inmo.kslog.common.KSLog
-import dev.inmo.kslog.common.defaultMessageFormatter
-import dev.inmo.kslog.common.filter.filtered
-import dev.inmo.micro_utils.coroutines.subscribeLoggingDropExceptions
+import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions
 import dev.inmo.tgbotapi.extensions.api.bot.getMe
-import dev.inmo.tgbotapi.extensions.api.send.withTypingAction
+import dev.inmo.tgbotapi.bot.Ktor.telegramBot
+import dev.inmo.tgbotapi.extensions.api.send.*
+import dev.inmo.tgbotapi.extensions.api.send.media.*
+import dev.inmo.tgbotapi.extensions.behaviour_builder.*
+import dev.inmo.tgbotapi.extensions.behaviour_builder.filters.CommonMessageFilterExcludeMediaGroups
 import dev.inmo.tgbotapi.extensions.behaviour_builder.filters.MessageFilterByChat
-import dev.inmo.tgbotapi.extensions.behaviour_builder.telegramBotWithBehaviourAndLongPolling
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onContentMessage
-import dev.inmo.tgbotapi.extensions.utils.possiblyWithEffectMessageOrNull
-import dev.inmo.tgbotapi.extensions.utils.shortcuts.executeUnsafe
-import dev.inmo.tgbotapi.extensions.utils.withContentOrNull
-import dev.inmo.tgbotapi.types.ReplyParameters
-import dev.inmo.tgbotapi.types.message.abstracts.BusinessContentMessage
-import dev.inmo.tgbotapi.types.message.content.TextContent
-import dev.inmo.tgbotapi.utils.DefaultKTgBotAPIKSLog
-import dev.inmo.tgbotapi.utils.extensions.threadIdOrNull
-import kotlinx.coroutines.CancellationException
-import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.SupervisorJob
-import kotlinx.coroutines.currentCoroutineContext
+import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.*
+import dev.inmo.tgbotapi.extensions.utils.shortcuts.*
+import dev.inmo.tgbotapi.types.message.abstracts.Message
+import kotlinx.coroutines.*
 
 suspend fun activateResenderBot(
     token: String,
     print: (Any) -> Unit
 ) {
-    telegramBotWithBehaviourAndLongPolling(
-        token,
-        scope = CoroutineScope(currentCoroutineContext() + SupervisorJob()),
-    ) {
+    val bot = telegramBot(token)
+
+    print(bot.getMe())
+
+    bot.buildBehaviourWithLongPolling(CoroutineScope(currentCoroutineContext() + SupervisorJob())) {
         onContentMessage(
-            subcontextUpdatesFilter = MessageFilterByChat,
-            initialFilter = { it !is BusinessContentMessage<*> || !it.sentByBusinessConnectionOwner }
+            initialFilter = CommonMessageFilterExcludeMediaGroups,
+            subcontextUpdatesFilter = MessageFilterByChat
         ) {
             val chat = it.chat
-
-            val answer = withTypingAction(chat) {
-                executeUnsafe(
-                    it.content.createResend(
-                        chat.id,
-                        messageThreadId = it.threadIdOrNull,
-                        replyParameters = it.replyInfo?.messageMeta?.let { meta ->
-                            val quote = it.withContentOrNull<TextContent>()?.content?.quote
-                            ReplyParameters(
-                                meta,
-                                entities = quote?.textSources ?: emptyList(),
-                                quotePosition = quote?.position
-                            )
-                        },
-                        effectId = it.possiblyWithEffectMessageOrNull()?.effectId
-                    )
-                ) {
-                    it.forEach(print)
-                }
+            withTypingAction(chat) {
+                executeUnsafe(it.content.createResend(chat.id, replyToMessageId = it.messageId))
+            }
+        }
+        onVisualGallery {
+            val chat = it.chat ?: return@onVisualGallery
+            withUploadPhotoAction(chat) {
+                sendVisualMediaGroup(chat, it.map { it.content.toMediaGroupMemberInputMedia() })
+            }
+        }
+        onPlaylist {
+            val chat = it.chat ?: return@onPlaylist
+            withUploadDocumentAction(chat) {
+                sendPlaylist(chat, it.map { it.content.toMediaGroupMemberInputMedia() })
+            }
+        }
+        onDocumentsGroup {
+            val chat = it.chat ?: return@onDocumentsGroup
+            withUploadDocumentAction(chat) {
+                sendDocumentsGroup(chat, it.map { it.content.toMediaGroupMemberInputMedia() })
             }
-
-            println("Answer info: $answer")
         }
 
-        allUpdatesFlow.subscribeLoggingDropExceptions(scope = this) {
+        allUpdatesFlow.subscribeSafelyWithoutExceptions(this) {
             println(it)
         }
-        print(bot.getMe())
-    }.second.join()
+    }.join()
 }

ResenderBot/jvm_launcher/build.gradle

@@ -1,6 +1,6 @@
 buildscript {
     repositories {
-        mavenCentral()
+        jcenter()
     }
 
     dependencies {

ResenderBot/jvm_launcher/src/main/kotlin/ResenderBotJvm.kt

@@ -1,19 +1,4 @@
-import dev.inmo.kslog.common.KSLog
-import dev.inmo.kslog.common.LogLevel
-import dev.inmo.kslog.common.defaultMessageFormatter
-import dev.inmo.kslog.common.setDefaultKSLog
-
 suspend fun main(args: Array<String>) {
-    val isDebug = args.getOrNull(1) == "debug"
-
-    if (isDebug) {
-        setDefaultKSLog(
-            KSLog { level: LogLevel, tag: String?, message: Any, throwable: Throwable? ->
-                println(defaultMessageFormatter(level, tag, message, throwable))
-            }
-        )
-    }
-
     activateResenderBot(args.first()) {
         println(it)
     }

ResenderBot/native_launcher/build.gradle

@@ -1,28 +0,0 @@
-buildscript {
-    repositories {
-        mavenCentral()
-    }
-
-    dependencies {
-        classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version"
-    }
-}
-
-plugins {
-    id "org.jetbrains.kotlin.multiplatform"
-}
-
-apply from: "$nativePartTemplate"
-
-kotlin {
-    sourceSets {
-        commonMain {
-            dependencies {
-                implementation kotlin('stdlib')
-
-                api project(":ResenderBot:ResenderBotLib")
-            }
-        }
-    }
-}
-

ResenderBot/native_launcher/src/nativeMain/kotlin/ResenderBot.kt

@@ -1,9 +0,0 @@
-import kotlinx.coroutines.runBlocking
-
-fun main(vararg args: String) {
-    runBlocking {
-        activateResenderBot(args.first()) {
-            println(it)
-        }
-    }
-}

RightsChangerBot/README.md

@@ -1,12 +0,0 @@
-# RightsChanger
-
-All the commands should be called with reply to some common user.
-
-* Use `/simple` with bot to get request buttons for non-independent permissions change
-* Use `/granular` with bot to get request buttons for independent permissions change
-
-## Launch
-
-```bash
-../gradlew run --args="BOT_TOKEN allowed_user_id_long"
-```

RightsChangerBot/build.gradle

@@ -1,22 +0,0 @@
-buildscript {
-    repositories {
-        mavenCentral()
-    }
-
-    dependencies {
-        classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version"
-    }
-}
-
-apply plugin: 'kotlin'
-apply plugin: 'application'
-
-mainClassName="RightsChangerKt"
-
-
-dependencies {
-    implementation "org.jetbrains.kotlin:kotlin-stdlib:$kotlin_version"
-
-    implementation "dev.inmo:tgbotapi:$telegram_bot_api_version"
-    implementation 'io.ktor:ktor-client-logging-jvm:3.2.3'
-}

RightsChangerBot/src/main/kotlin/RightsChanger.kt

@@ -1,540 +0,0 @@
-import dev.inmo.kslog.common.KSLog
-import dev.inmo.kslog.common.LogLevel
-import dev.inmo.kslog.common.defaultMessageFormatter
-import dev.inmo.kslog.common.setDefaultKSLog
-import dev.inmo.micro_utils.coroutines.firstOf
-import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions
-import dev.inmo.micro_utils.fsm.common.State
-import dev.inmo.tgbotapi.bot.ktor.telegramBot
-import dev.inmo.tgbotapi.extensions.api.bot.setMyCommands
-import dev.inmo.tgbotapi.extensions.api.chat.get.getChat
-import dev.inmo.tgbotapi.extensions.api.chat.members.getChatMember
-import dev.inmo.tgbotapi.extensions.api.chat.members.promoteChannelAdministrator
-import dev.inmo.tgbotapi.extensions.api.chat.members.restrictChatMember
-import dev.inmo.tgbotapi.extensions.api.edit.edit
-import dev.inmo.tgbotapi.extensions.api.send.reply
-import dev.inmo.tgbotapi.extensions.api.send.send
-import dev.inmo.tgbotapi.extensions.behaviour_builder.BehaviourContext
-import dev.inmo.tgbotapi.extensions.behaviour_builder.buildBehaviourWithFSMAndStartLongPolling
-import dev.inmo.tgbotapi.extensions.behaviour_builder.expectations.waitChatSharedEventsMessages
-import dev.inmo.tgbotapi.extensions.behaviour_builder.expectations.waitCommandMessage
-import dev.inmo.tgbotapi.extensions.behaviour_builder.expectations.waitUserSharedEventsMessages
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onCommand
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onMessageDataCallbackQuery
-import dev.inmo.tgbotapi.extensions.utils.*
-import dev.inmo.tgbotapi.extensions.utils.extensions.sameChat
-import dev.inmo.tgbotapi.extensions.utils.types.buttons.*
-import dev.inmo.tgbotapi.types.*
-import dev.inmo.tgbotapi.types.buttons.InlineKeyboardMarkup
-import dev.inmo.tgbotapi.types.chat.ChannelChat
-import dev.inmo.tgbotapi.types.chat.ChatPermissions
-import dev.inmo.tgbotapi.types.chat.PublicChat
-import dev.inmo.tgbotapi.types.chat.member.AdministratorChatMember
-import dev.inmo.tgbotapi.types.chat.member.ChatCommonAdministratorRights
-import dev.inmo.tgbotapi.types.commands.BotCommandScope
-import dev.inmo.tgbotapi.types.message.abstracts.AccessibleMessage
-import dev.inmo.tgbotapi.types.request.RequestId
-import dev.inmo.tgbotapi.utils.*
-import kotlinx.coroutines.flow.filter
-import kotlinx.coroutines.flow.first
-import kotlinx.coroutines.flow.mapNotNull
-
-sealed interface UserRetrievingStep : State {
-    data class RetrievingChannelChatState(
-        override val context: ChatId
-    ) : UserRetrievingStep
-    data class RetrievingUserIdChatState(
-        override val context: ChatId,
-        val channelId: ChatId
-    ) : UserRetrievingStep
-    data class RetrievingChatInfoDoneState(
-        override val context: ChatId,
-        val channelId: ChatId,
-        val userId: UserId
-    ) : UserRetrievingStep
-}
-
-@OptIn(PreviewFeature::class)
-suspend fun main(args: Array<String>) {
-    val botToken = args.first()
-
-    val isDebug = args.getOrNull(2) == "debug"
-
-    if (isDebug) {
-        setDefaultKSLog(
-            KSLog { level: LogLevel, tag: String?, message: Any, throwable: Throwable? ->
-                println(defaultMessageFormatter(level, tag, message, throwable))
-            }
-        )
-    }
-
-    val bot = telegramBot(botToken)
-
-    val allowedAdmin = ChatId(RawChatId(args[1].toLong()))
-
-    fun Boolean?.allowedSymbol() = when (this) {
-        true -> "✅"
-        false -> "❌"
-        null -> ""
-    }
-
-    val granularDataPrefix = "granular"
-    val messagesToggleGranularData = "$granularDataPrefix messages"
-    val otherMessagesToggleGranularData = "$granularDataPrefix other messages"
-    val audiosToggleGranularData = "$granularDataPrefix audios"
-    val voicesToggleGranularData = "$granularDataPrefix voices"
-    val videosToggleGranularData = "$granularDataPrefix videos"
-    val videoNotesToggleGranularData = "$granularDataPrefix video notes"
-    val photosToggleGranularData = "$granularDataPrefix photos"
-    val webPagePreviewToggleGranularData = "$granularDataPrefix web page preview"
-    val pollsToggleGranularData = "$granularDataPrefix polls"
-    val documentsToggleGranularData = "$granularDataPrefix documents"
-
-    val commonDataPrefix = "common"
-    val pollsToggleCommonData = "$commonDataPrefix polls"
-    val otherMessagesToggleCommonData = "$commonDataPrefix other messages"
-    val webPagePreviewToggleCommonData = "$commonDataPrefix web page preview"
-
-    val adminRightsDataPrefix = "admin"
-    val refreshAdminRightsData = "${adminRightsDataPrefix}_refresh"
-    val postMessagesToggleAdminRightsData = "${adminRightsDataPrefix}_post_messages"
-    val editMessagesToggleAdminRightsData = "${adminRightsDataPrefix}_edit_messages"
-    val deleteMessagesToggleAdminRightsData = "${adminRightsDataPrefix}_delete_messages"
-    val editStoriesToggleAdminRightsData = "${adminRightsDataPrefix}_edit_stories"
-    val deleteStoriesToggleAdminRightsData = "${adminRightsDataPrefix}_delete_stories"
-    val postStoriesToggleAdminRightsData = "${adminRightsDataPrefix}_post_stories"
-
-    suspend fun BehaviourContext.getUserChatPermissions(chatId: ChatId, userId: UserId): ChatPermissions? {
-        val chatMember = getChatMember(chatId, userId)
-        return chatMember.restrictedMemberChatMemberOrNull() ?: chatMember.whenMemberChatMember {
-            getChat(chatId).extendedGroupChatOrNull() ?.permissions
-        }
-    }
-    fun buildGranularKeyboard(
-        permissions: ChatPermissions
-    ): InlineKeyboardMarkup {
-        return inlineKeyboard {
-            row {
-                dataButton("Send messages${permissions.canSendMessages.allowedSymbol()}", messagesToggleGranularData)
-                dataButton(
-                    "Send other messages${permissions.canSendOtherMessages.allowedSymbol()}",
-                    otherMessagesToggleGranularData
-                )
-            }
-            row {
-                dataButton("Send audios${permissions.canSendAudios.allowedSymbol()}", audiosToggleGranularData)
-                dataButton("Send voices${permissions.canSendVoiceNotes.allowedSymbol()}", voicesToggleGranularData)
-            }
-            row {
-                dataButton("Send videos${permissions.canSendVideos.allowedSymbol()}", videosToggleGranularData)
-                dataButton(
-                    "Send video notes${permissions.canSendVideoNotes.allowedSymbol()}",
-                    videoNotesToggleGranularData
-                )
-            }
-            row {
-                dataButton("Send photos${permissions.canSendPhotos.allowedSymbol()}", photosToggleGranularData)
-                dataButton(
-                    "Add web preview${permissions.canAddWebPagePreviews.allowedSymbol()}",
-                    webPagePreviewToggleGranularData
-                )
-            }
-            row {
-                dataButton("Send polls${permissions.canSendPolls.allowedSymbol()}", pollsToggleGranularData)
-                dataButton("Send documents${permissions.canSendDocuments.allowedSymbol()}", documentsToggleGranularData)
-            }
-        }
-    }
-    fun buildAdminRightsKeyboard(
-        permissions: AdministratorChatMember?,
-        channelId: ChatId,
-        userId: UserId
-    ): InlineKeyboardMarkup {
-        return inlineKeyboard {
-            permissions ?.also {
-                row {
-                    dataButton("Refresh", "$refreshAdminRightsData ${channelId.chatId} ${userId.chatId}")
-                }
-                row {
-                    dataButton("Edit messages${permissions.canEditMessages.allowedSymbol()}", "$editMessagesToggleAdminRightsData ${channelId.chatId} ${userId.chatId}")
-                    dataButton("Delete messages${permissions.canRemoveMessages.allowedSymbol()}", "$deleteMessagesToggleAdminRightsData ${channelId.chatId} ${userId.chatId}")
-                }
-                row {
-                    dataButton("Post messages${permissions.canPostMessages.allowedSymbol()}", "$postMessagesToggleAdminRightsData ${channelId.chatId} ${userId.chatId}")
-                }
-                row {
-                    dataButton("Edit stories${permissions.canEditStories.allowedSymbol()}", "$editStoriesToggleAdminRightsData ${channelId.chatId} ${userId.chatId}")
-                    dataButton("Delete stories${permissions.canDeleteStories.allowedSymbol()}", "$deleteStoriesToggleAdminRightsData ${channelId.chatId} ${userId.chatId}")
-                }
-                row {
-                    dataButton("Post stories${permissions.canPostStories.allowedSymbol()}", "$postStoriesToggleAdminRightsData ${channelId.chatId} ${userId.chatId}")
-                }
-            } ?: row {
-                dataButton("Promote to admin", "$postMessagesToggleAdminRightsData ${channelId.chatId} ${userId.chatId}")
-            }
-        }
-    }
-
-    suspend fun BehaviourContext.buildGranularKeyboard(chatId: ChatId, userId: UserId): InlineKeyboardMarkup? {
-        return buildGranularKeyboard(
-            getUserChatPermissions(chatId, userId) ?: return null
-        )
-    }
-
-    suspend fun BehaviourContext.buildCommonKeyboard(chatId: ChatId, userId: UserId): InlineKeyboardMarkup? {
-        val permissions = getUserChatPermissions(chatId, userId) ?: return null
-
-        return inlineKeyboard {
-            row {
-                dataButton("Send polls${permissions.canSendPolls.allowedSymbol()}", pollsToggleCommonData)
-            }
-            row {
-                dataButton("Send other messages${permissions.canSendOtherMessages.allowedSymbol()}", otherMessagesToggleCommonData)
-            }
-            row {
-                dataButton("Add web preview${permissions.canAddWebPagePreviews.allowedSymbol()}", webPagePreviewToggleCommonData)
-            }
-        }
-    }
-
-    bot.buildBehaviourWithFSMAndStartLongPolling<UserRetrievingStep>(
-        defaultExceptionsHandler = {
-            it.printStackTrace()
-        },
-    ) {
-        onCommand(
-            "simple",
-            initialFilter = { it.chat is PublicChat && it.fromUserMessageOrNull()?.user?.id == allowedAdmin }
-        ) {
-            val replyMessage = it.replyTo
-            val userInReply = replyMessage?.fromUserMessageOrNull()?.user?.id ?: return@onCommand
-            if (replyMessage is AccessibleMessage) {
-                reply(
-                    replyMessage,
-                    "Manage keyboard:",
-                    replyMarkup = buildCommonKeyboard(it.chat.id.toChatId(), userInReply) ?: return@onCommand
-                )
-            } else {
-                reply(it) {
-                    regular("Reply to somebody's message to get hist/her rights keyboard")
-                }
-            }
-        }
-        onCommand(
-            "granular",
-            initialFilter = {
-                it.chat is ChannelChat || (it.chat is PublicChat && it.fromUserMessageOrNull()?.user?.id == allowedAdmin)
-            }
-        ) {
-            val replyMessage = it.replyTo
-            val userInReply = replyMessage?.fromUserMessageOrNull()?.user?.id ?: return@onCommand
-
-            if (replyMessage is AccessibleMessage) {
-                reply(
-                    replyMessage,
-                    "Manage keyboard:",
-                    replyMarkup = buildGranularKeyboard(it.chat.id.toChatId(), userInReply) ?: return@onCommand
-                )
-            } else {
-                reply(it) {
-                    regular("Reply to somebody's message to get hist/her rights keyboard")
-                }
-            }
-        }
-
-        onMessageDataCallbackQuery(
-            Regex("^${granularDataPrefix}.*"),
-            initialFilter = { it.user.id == allowedAdmin }
-        ) {
-            val messageReply =
-                it.message.commonMessageOrNull()?.replyTo?.fromUserMessageOrNull() ?: return@onMessageDataCallbackQuery
-            val userId = messageReply.user.id
-            val permissions =
-                getUserChatPermissions(it.message.chat.id.toChatId(), userId) ?: return@onMessageDataCallbackQuery
-            val newPermission = when (it.data) {
-                messagesToggleGranularData -> {
-                    permissions.copyGranular(
-                        canSendMessages = permissions.canSendMessages?.let { !it } ?: false
-                    )
-                }
-
-                otherMessagesToggleGranularData -> {
-                    permissions.copyGranular(
-                        canSendOtherMessages = permissions.canSendOtherMessages?.let { !it } ?: false
-                    )
-                }
-
-                audiosToggleGranularData -> {
-                    permissions.copyGranular(
-                        canSendAudios = permissions.canSendAudios?.let { !it } ?: false
-                    )
-                }
-
-                voicesToggleGranularData -> {
-                    permissions.copyGranular(
-                        canSendVoiceNotes = permissions.canSendVoiceNotes?.let { !it } ?: false
-                    )
-                }
-
-                videosToggleGranularData -> {
-                    permissions.copyGranular(
-                        canSendVideos = permissions.canSendVideos?.let { !it } ?: false
-                    )
-                }
-
-                videoNotesToggleGranularData -> {
-                    permissions.copyGranular(
-                        canSendVideoNotes = permissions.canSendVideoNotes?.let { !it } ?: false
-                    )
-                }
-
-                photosToggleGranularData -> {
-                    permissions.copyGranular(
-                        canSendPhotos = permissions.canSendPhotos?.let { !it } ?: false
-                    )
-                }
-
-                webPagePreviewToggleGranularData -> {
-                    permissions.copyGranular(
-                        canAddWebPagePreviews = permissions.canAddWebPagePreviews?.let { !it } ?: false
-                    )
-                }
-
-                pollsToggleGranularData -> {
-                    permissions.copyGranular(
-                        canSendPolls = permissions.canSendPolls?.let { !it } ?: false
-                    )
-                }
-
-                documentsToggleGranularData -> {
-                    permissions.copyGranular(
-                        canSendDocuments = permissions.canSendDocuments?.let { !it } ?: false
-                    )
-                }
-
-                else -> permissions.copyGranular()
-            }
-
-            restrictChatMember(
-                it.message.chat.id,
-                userId,
-                permissions = newPermission,
-                useIndependentChatPermissions = true
-            )
-
-            edit(
-                it.message,
-                replyMarkup = buildGranularKeyboard(it.message.chat.id.toChatId(), userId)
-                    ?: return@onMessageDataCallbackQuery
-            )
-        }
-
-        onMessageDataCallbackQuery(
-            Regex("^${commonDataPrefix}.*"),
-            initialFilter = { it.user.id == allowedAdmin }
-        ) {
-            val messageReply =
-                it.message.commonMessageOrNull()?.replyTo?.fromUserMessageOrNull() ?: return@onMessageDataCallbackQuery
-            val userId = messageReply.user.id
-            val permissions =
-                getUserChatPermissions(it.message.chat.id.toChatId(), userId) ?: return@onMessageDataCallbackQuery
-            val newPermission = when (it.data) {
-                pollsToggleCommonData -> {
-                    permissions.copyCommon(
-                        canSendPolls = permissions.canSendPolls?.let { !it } ?: false
-                    )
-                }
-
-                otherMessagesToggleCommonData -> {
-                    permissions.copyCommon(
-                        canSendOtherMessages = permissions.canSendOtherMessages?.let { !it } ?: false
-                    )
-                }
-
-                webPagePreviewToggleCommonData -> {
-                    permissions.copyCommon(
-                        canAddWebPagePreviews = permissions.canAddWebPagePreviews?.let { !it } ?: false
-                    )
-                }
-
-                else -> permissions.copyCommon()
-            }
-
-            restrictChatMember(
-                it.message.chat.id,
-                userId,
-                permissions = newPermission,
-                useIndependentChatPermissions = false
-            )
-
-            edit(
-                it.message,
-                replyMarkup = buildCommonKeyboard(it.message.chat.id.toChatId(), userId)
-                    ?: return@onMessageDataCallbackQuery
-            )
-        }
-
-        onMessageDataCallbackQuery(
-            Regex("^${adminRightsDataPrefix}.*"),
-            initialFilter = { it.user.id == allowedAdmin }
-        ) {
-            val (channelIdString, userIdString) = it.data.split(" ").drop(1)
-            val channelId = ChatId(RawChatId(channelIdString.toLong()))
-            val userId = ChatId(RawChatId(userIdString.toLong()))
-            val chatMember = getChatMember(channelId, userId)
-            val asAdmin = chatMember.administratorChatMemberOrNull()
-
-            val realData = it.data.takeWhile { it != ' ' }
-
-            fun Boolean?.toggleIfData(data: String) = if (realData == data) {
-                !(this ?: false)
-            } else {
-                null
-            }
-
-            if (realData != refreshAdminRightsData) {
-                promoteChannelAdministrator(
-                    channelId,
-                    userId,
-                    canPostMessages = asAdmin ?.canPostMessages.toggleIfData(postMessagesToggleAdminRightsData),
-                    canEditMessages = asAdmin ?.canEditMessages.toggleIfData(editMessagesToggleAdminRightsData),
-                    canDeleteMessages = asAdmin ?.canRemoveMessages.toggleIfData(deleteMessagesToggleAdminRightsData),
-                    canEditStories = asAdmin ?.canEditStories.toggleIfData(editStoriesToggleAdminRightsData),
-                    canDeleteStories = asAdmin ?.canDeleteStories.toggleIfData(deleteStoriesToggleAdminRightsData),
-                    canPostStories = asAdmin ?.canPostStories.toggleIfData(postStoriesToggleAdminRightsData),
-                )
-            }
-
-            edit(
-                it.message,
-                replyMarkup = buildAdminRightsKeyboard(
-                    getChatMember(
-                        channelId,
-                        userId
-                    ).administratorChatMemberOrNull(),
-                    channelId,
-                    userId
-                )
-            )
-        }
-
-        strictlyOn<UserRetrievingStep.RetrievingChannelChatState> { state ->
-            val requestId = RequestId.random()
-            send(
-                state.context,
-                replyMarkup = replyKeyboard(
-                    oneTimeKeyboard = true,
-                    resizeKeyboard = true
-                ) {
-                    row {
-                        requestChatButton(
-                            "Choose channel",
-                            requestId = requestId,
-                            isChannel = true,
-                            botIsMember = true,
-                            botRightsInChat = ChatCommonAdministratorRights(
-                                canPromoteMembers = true,
-                                canRestrictMembers = true
-                            ),
-                            userRightsInChat = ChatCommonAdministratorRights(
-                                canPromoteMembers = true,
-                                canRestrictMembers = true
-                            )
-                        )
-                    }
-                }
-            ) {
-                regular("Ok, send me the channel in which you wish to manage user, or use ")
-                botCommand("cancel")
-                regular(" to cancel the request")
-            }
-            firstOf {
-                include {
-                    val chatId = waitChatSharedEventsMessages().mapNotNull {
-                        it.chatEvent.chatId.takeIf { _ ->
-                            it.chatEvent.requestId == requestId && it.sameChat(state.context)
-                        }
-                    }.first()
-                    UserRetrievingStep.RetrievingUserIdChatState(state.context, chatId)
-                }
-                include {
-                    waitCommandMessage("cancel").filter { it.sameChat(state.context) }.first()
-                    null
-                }
-            }
-        }
-        strictlyOn<UserRetrievingStep.RetrievingUserIdChatState> { state ->
-            val requestId = RequestId.random()
-            send(
-                state.context,
-                replyMarkup = replyKeyboard(
-                    oneTimeKeyboard = true,
-                    resizeKeyboard = true
-                ) {
-                    row {
-                        requestUserButton(
-                            "Choose user",
-                            requestId = requestId
-                        )
-                    }
-                }
-            ) {
-                regular("Ok, send me the user for which you wish to change rights, or use ")
-                botCommand("cancel")
-                regular(" to cancel the request")
-            }
-
-            firstOf {
-                include {
-                    val userContactChatId = waitUserSharedEventsMessages().filter {
-                        it.sameChat(state.context)
-                    }.first().chatEvent.chatId
-                    UserRetrievingStep.RetrievingChatInfoDoneState(
-                        state.context,
-                        state.channelId,
-                        userContactChatId
-                    )
-                }
-                include {
-                    waitCommandMessage("cancel").filter { it.sameChat(state.context) }.first()
-                    null
-                }
-            }
-        }
-
-        strictlyOn<UserRetrievingStep.RetrievingChatInfoDoneState> { state ->
-            val chatMember = getChatMember(state.channelId, state.userId).administratorChatMemberOrNull()
-            if (chatMember == null) {
-                return@strictlyOn null
-            }
-            send(
-                state.context,
-                replyMarkup = buildAdminRightsKeyboard(
-                    chatMember,
-                    state.channelId,
-                    state.userId
-                )
-            ) {
-                regular("Rights of ")
-                mentionln(chatMember.user)
-                regular("Please, remember, that to be able to change user rights bot must promote user by itself to admin")
-            }
-            null
-        }
-
-        onCommand("rights_in_channel") {
-            startChain(UserRetrievingStep.RetrievingChannelChatState(it.chat.id.toChatId()))
-        }
-
-        setMyCommands(
-            BotCommand("simple", "Trigger simple keyboard. Use with reply to user"),
-            BotCommand("granular", "Trigger granular keyboard. Use with reply to user"),
-            BotCommand("rights_in_channel", "Trigger granular keyboard. Use with reply to user"),
-            scope = BotCommandScope.AllGroupChats
-        )
-
-        allUpdatesFlow.subscribeSafelyWithoutExceptions(this) {
-            println(it)
-        }
-    }.join()
-}

SlotMachineDetectorBot/build.gradle

@@ -1,6 +1,6 @@
 buildscript {
     repositories {
-        mavenCentral()
+        jcenter()
     }
 
     dependencies {

SlotMachineDetectorBot/src/main/kotlin/SlotMachineDetectorBot.kt

@@ -1,26 +1,35 @@
-import dev.inmo.tgbotapi.bot.ktor.telegramBot
+import dev.inmo.micro_utils.coroutines.safely
+import dev.inmo.tgbotapi.bot.Ktor.telegramBot
 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.onDice
 import dev.inmo.tgbotapi.extensions.utils.*
+import dev.inmo.tgbotapi.extensions.utils.shortcuts.filterContentMessages
+import dev.inmo.tgbotapi.extensions.utils.updates.retrieving.longPolling
 import dev.inmo.tgbotapi.types.dice.SlotMachineDiceAnimationType
+import dev.inmo.tgbotapi.types.message.content.DiceContent
 import kotlinx.coroutines.*
+import kotlinx.coroutines.flow.launchIn
+import kotlinx.coroutines.flow.onEach
 
 suspend fun main(args: Array<String>) {
     val bot = telegramBot(args.first())
 
-    bot.buildBehaviourWithLongPolling(scope = CoroutineScope(Dispatchers.IO)) {
-        onDice {
+    val scope = CoroutineScope(Dispatchers.Default)
+    bot.longPolling(scope = scope) {
+        filterContentMessages<DiceContent>(scope).onEach {
             val content = it.content
             val dice = content.dice
             val diceType = dice.animationType
 
-            if (diceType == SlotMachineDiceAnimationType) {
-                val result = dice.calculateSlotMachineResult() ?: return@onDice
-                reply(it, "${result.leftReel}|${result.centerReel}|${result.rightReel}")
-            } else {
-                reply(it, "There is no slot machine dice in message")
+            safely ({ it.printStackTrace() }) {
+                if (diceType == SlotMachineDiceAnimationType) {
+                    val result = dice.calculateSlotMachineResult() ?: return@safely
+                    bot.reply(it, "${result.leftReel}|${result.centerReel}|${result.rightReel}")
+                } else {
+                    bot.reply(it, "There is no slot machine dice in message")
+                }
             }
-        }
-    }.join()
-}
+        }.launchIn(scope)
+    }
+
+    scope.coroutineContext[Job]!!.join()
+}

StarTransactionsBot/README.md

@@ -1,9 +0,0 @@
-# StarTransactionsBot
-
-This bot basically have no any useful behaviour, but you may customize it as a playground
-
-## Launch
-
-```bash
-../gradlew run --args="BOT_TOKEN"
-```

StarTransactionsBot/build.gradle

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

StarTransactionsBot/src/main/kotlin/StarTransactionsBot.kt

@@ -1,184 +0,0 @@
-import dev.inmo.kslog.common.KSLog
-import dev.inmo.kslog.common.LogLevel
-import dev.inmo.kslog.common.defaultMessageFormatter
-import dev.inmo.kslog.common.setDefaultKSLog
-import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions
-import dev.inmo.tgbotapi.extensions.api.answers.payments.answerPreCheckoutQueryOk
-import dev.inmo.tgbotapi.extensions.api.edit.edit
-import dev.inmo.tgbotapi.extensions.api.files.downloadFileToTemp
-import dev.inmo.tgbotapi.extensions.api.get.getStarTransactions
-import dev.inmo.tgbotapi.extensions.api.send.reply
-import dev.inmo.tgbotapi.extensions.api.send.send
-import dev.inmo.tgbotapi.extensions.behaviour_builder.telegramBotWithBehaviourAndLongPolling
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.*
-import dev.inmo.tgbotapi.extensions.utils.extensions.sameChat
-import dev.inmo.tgbotapi.extensions.utils.types.buttons.*
-import dev.inmo.tgbotapi.extensions.utils.withContentOrNull
-import dev.inmo.tgbotapi.requests.abstracts.asMultipartFile
-import dev.inmo.tgbotapi.types.RawChatId
-import dev.inmo.tgbotapi.types.UserId
-import dev.inmo.tgbotapi.types.buttons.InlineKeyboardMarkup
-import dev.inmo.tgbotapi.types.files.*
-import dev.inmo.tgbotapi.types.media.TelegramPaidMediaPhoto
-import dev.inmo.tgbotapi.types.media.TelegramPaidMediaVideo
-import dev.inmo.tgbotapi.types.media.toTelegramPaidMediaPhoto
-import dev.inmo.tgbotapi.types.media.toTelegramPaidMediaVideo
-import dev.inmo.tgbotapi.types.message.content.TextContent
-import dev.inmo.tgbotapi.types.message.textsources.TextSourcesList
-import dev.inmo.tgbotapi.types.payments.LabeledPrice
-import dev.inmo.tgbotapi.types.payments.stars.StarTransaction
-import dev.inmo.tgbotapi.types.request.RequestId
-import dev.inmo.tgbotapi.utils.bold
-import dev.inmo.tgbotapi.utils.buildEntities
-import dev.inmo.tgbotapi.utils.regular
-import dev.inmo.tgbotapi.utils.row
-import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.Dispatchers
-
-/**
- * An example bot that interacts with Telegram Stars API (used for payments)
- */
-suspend fun main(vararg args: String) {
-    val botToken = args.first()
-    val adminUserId = args.getOrNull(1) ?.toLongOrNull() ?.let(::RawChatId) ?.let(::UserId) ?: error("Pass user-admin for full access to the bot")
-
-    val isDebug = args.any { it == "debug" }
-    val isTestServer = args.any { it == "testServer" }
-
-    if (isDebug) {
-        setDefaultKSLog(
-            KSLog { level: LogLevel, tag: String?, message: Any, throwable: Throwable? ->
-                println(defaultMessageFormatter(level, tag, message, throwable))
-            }
-        )
-    }
-
-    telegramBotWithBehaviourAndLongPolling(botToken, CoroutineScope(Dispatchers.IO), testServer = isTestServer) {
-        val payload = "sample payload"
-        command("start") {
-            reply(
-                it,
-                price = LabeledPrice("1", 1L),
-                title = "Sample",
-                description = "Sample description",
-                payload = payload,
-                replyMarkup = flatInlineKeyboard {
-                    payButton("Pay")
-                },
-            )
-        }
-
-        onPreCheckoutQuery(initialFilter = { it.invoicePayload == payload }) {
-            answerPreCheckoutQueryOk(it)
-        }
-
-        val transactionsDataPrefix = "getStarTransactions"
-        fun buildTransactionsData(offset: Int, limit: Int = 10) = "$transactionsDataPrefix $offset $limit"
-        fun parseTransactionsData(data: String): Pair<Int, Int> = data.split(" ").drop(1).let {
-            it.first().toInt() to it.last().toInt()
-        }
-        suspend fun buildStarTransactionsPage(offset: Int, limit: Int = 10): Pair<TextSourcesList, InlineKeyboardMarkup> {
-            val transactions = getStarTransactions(offset, limit)
-            return buildEntities {
-                transactions.transactions.forEach {
-                    regular("Transaction Id: ") + bold(it.id.string) + "\n"
-                    regular("Date: ") + bold(it.date.asDate.toStringDefault()) + "\n"
-                    regular("Amount: ") + bold(it.amount.toString()) + "\n"
-                    when (it) {
-                        is StarTransaction.Incoming -> {
-                            regular("Type: ") + bold("incoming") + "\n"
-                            regular("Partner: ") + bold(it.partner.type) + "\n"
-                        }
-                        is StarTransaction.Outgoing -> {
-                            regular("Type: ") + bold("outgoing") + "\n"
-                            regular("Partner: ") + bold(it.partner.type) + "\n"
-                        }
-                        is StarTransaction.Unknown -> {
-                            regular("Type: ") + bold("unknown") + "\n"
-                            regular("Partner: ") + bold(it.partner.type) + "\n"
-                        }
-                    }
-                }
-            } to inlineKeyboard {
-                row {
-                    val prevOffset = (offset - limit).coerceAtLeast(0)
-                    if (prevOffset < offset) {
-                        dataButton("<", buildTransactionsData(prevOffset, limit))
-                    }
-                    val nextOffset = (offset + limit)
-                    dataButton(">", buildTransactionsData(nextOffset, limit))
-                }
-            }
-        }
-
-        onCommand("transactions", initialFilter = { it.sameChat(adminUserId) }) {
-            val (text, keyboard) = buildStarTransactionsPage(0)
-
-            reply(it, text, replyMarkup = keyboard)
-        }
-
-        onMessageDataCallbackQuery(Regex("$transactionsDataPrefix \\d+ \\d+")) {
-            val (offset, limit) = parseTransactionsData(it.data)
-            val (text, keyboard) = buildStarTransactionsPage(offset, limit)
-            edit(
-                it.message.withContentOrNull<TextContent>() ?: return@onMessageDataCallbackQuery,
-                text,
-                replyMarkup = keyboard,
-            )
-        }
-
-        onVisualGalleryMessages {
-            send(
-                it.chat,
-                1,
-                it.content.group.mapNotNull {
-                    val file = downloadFileToTemp(it.content.media)
-                    when (it.content.media) {
-                        is VideoFile -> {
-                            TelegramPaidMediaVideo(
-                                file.asMultipartFile()
-                            )
-                        }
-                        is PhotoSize -> {
-                            TelegramPaidMediaPhoto(
-                                file.asMultipartFile()
-                            )
-                        }
-                        else -> null
-                    }
-                },
-                it.content.textSources,
-                showCaptionAboveMedia = true
-            )
-        }
-
-        onPhoto {
-            send(
-                it.chat,
-                1,
-                listOf(it.content.media.toTelegramPaidMediaPhoto())
-            )
-        }
-
-        onVideo {
-            send(
-                it.chat,
-                1,
-                listOf(it.content.media.toTelegramPaidMediaVideo())
-            )
-        }
-
-        onPaidMediaInfoContent {
-            println(it)
-        }
-
-        onRefundedPayment {
-            reply(
-                it,
-                "Received your refund: ${it.chatEvent.payment}"
-            )
-        }
-
-        allUpdatesFlow.subscribeSafelyWithoutExceptions(this) { println(it) }
-    }.second.join()
-}

StickerInfoBot/StickerInfoBotLib/build.gradle

@@ -1,33 +0,0 @@
-buildscript {
-    repositories {
-        mavenCentral()
-    }
-
-    dependencies {
-        classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version"
-    }
-}
-
-plugins {
-    id "org.jetbrains.kotlin.multiplatform"
-}
-
-
-kotlin {
-    jvm()
-//    js(LEGACY) {
-    js(IR) {
-        browser()
-        binaries.executable()
-    }
-
-    sourceSets {
-        commonMain {
-            dependencies {
-                implementation kotlin('stdlib')
-
-                api "dev.inmo:tgbotapi:$telegram_bot_api_version"
-            }
-        }
-    }
-}

StickerInfoBot/StickerInfoBotLib/src/commonMain/kotlin/StickerInfoBot.kt

@@ -1,83 +0,0 @@
-import dev.inmo.micro_utils.coroutines.defaultSafelyWithoutExceptionHandler
-import dev.inmo.micro_utils.coroutines.subscribeLoggingDropExceptions
-import dev.inmo.tgbotapi.bot.ktor.telegramBot
-import dev.inmo.tgbotapi.extensions.api.bot.getMe
-import dev.inmo.tgbotapi.extensions.api.get.getCustomEmojiStickerOrNull
-import dev.inmo.tgbotapi.extensions.api.get.getStickerSet
-import dev.inmo.tgbotapi.extensions.api.get.getStickerSetOrNull
-import dev.inmo.tgbotapi.extensions.api.send.reply
-import dev.inmo.tgbotapi.extensions.api.send.withTypingAction
-import dev.inmo.tgbotapi.extensions.behaviour_builder.buildBehaviourWithLongPolling
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onSticker
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onText
-import dev.inmo.tgbotapi.types.StickerType
-import dev.inmo.tgbotapi.types.message.textsources.CustomEmojiTextSource
-import dev.inmo.tgbotapi.types.message.textsources.regularTextSource
-import dev.inmo.tgbotapi.types.message.textsources.separateForText
-import dev.inmo.tgbotapi.types.stickers.StickerSet
-import dev.inmo.tgbotapi.utils.bold
-import dev.inmo.tgbotapi.utils.buildEntities
-import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.SupervisorJob
-import kotlinx.coroutines.currentCoroutineContext
-
-fun StickerSet?.buildInfo() = buildEntities {
-    if (this@buildInfo == null) {
-        bold("Looks like this stickerset has been removed")
-    } else {
-        bold("StickerSet name: ") + "${name}\n"
-        bold("StickerSet title: ") + "${title}\n"
-        bold(
-            when (stickerType) {
-                StickerType.CustomEmoji -> "Custom emoji"
-                StickerType.Mask -> "Mask"
-                StickerType.Regular -> "Regular"
-                is StickerType.Unknown -> "Unknown type \"${stickerType.type}\""
-            }
-        ) + " sticker set with title " + bold(title) + " and name " + bold(name.string)
-    }
-}
-
-suspend fun activateStickerInfoBot(
-    token: String,
-    print: (Any) -> Unit
-) {
-    val bot = telegramBot(token)
-
-    print(bot.getMe())
-
-    defaultSafelyWithoutExceptionHandler = {
-        it.printStackTrace()
-    }
-
-    bot.buildBehaviourWithLongPolling(CoroutineScope(currentCoroutineContext() + SupervisorJob())) {
-        onText {
-            withTypingAction(it.chat) {
-                it.content.textSources.mapNotNull {
-                    if (it is CustomEmojiTextSource) {
-                        getCustomEmojiStickerOrNull(it.customEmojiId)?.stickerSetName
-                    } else {
-                        null
-                    }
-                }.distinct().map {
-                    getStickerSet(it)
-                }.distinct().flatMap {
-                    it.buildInfo() + regularTextSource("\n")
-                }.separateForText().map { entities ->
-                    reply(it, entities)
-                }
-            }
-        }
-        onSticker {
-            val stickerSetInfo = getStickerSetOrNull(it.content.media)
-            reply(
-                it,
-                stickerSetInfo.buildInfo()
-            )
-        }
-
-        allUpdatesFlow.subscribeLoggingDropExceptions(scope = this) {
-            println(it)
-        }
-    }.join()
-}

StickerInfoBot/StickerInfoBotLib/src/jsMain/kotlin/StickerInfoBot.kt

@@ -1,32 +0,0 @@
-import kotlinx.browser.document
-import kotlinx.coroutines.*
-import org.w3c.dom.*
-
-private val scope = CoroutineScope(Dispatchers.Default)
-
-fun main() {
-    document.addEventListener(
-        "DOMContentLoaded",
-        {
-            val botsContainer = document.getElementById("bots_container") ?: return@addEventListener
-
-            (document.getElementById("bot_token_form") as? HTMLFormElement) ?.onsubmit = {
-                (document.getElementById("bot_token") as? HTMLInputElement) ?.value ?.let { token ->
-                    val botContainer = document.createElement("div") as HTMLDivElement
-                    botsContainer.append(botContainer)
-
-                    val infoDiv = document.createElement("div") as HTMLDivElement
-                    botContainer.append(infoDiv)
-
-                    scope.launch {
-                        activateStickerInfoBot(token) {
-                            infoDiv.innerHTML = it.toString()
-                        }
-                    }
-                }
-
-                false
-            }
-        }
-    )
-}

StickerInfoBot/StickerInfoBotLib/src/jsMain/resources/index.html

@@ -1,16 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <title>Resender bot</title>
-</head>
-<body>
-    <form id="bot_token_form">
-        <input type="text" id="bot_token">
-        <input type="submit" value="Start bot">
-    </form>
-    <div id="start_offer">Type your bot token to the input above to start its work</div>
-    <script type="text/javascript" src="StickerInfoBotLib.js"></script>
-    <div id="bots_container"></div>
-</body>
-</html>

StickerInfoBot/jvm_launcher/build.gradle

@@ -1,21 +0,0 @@
-buildscript {
-    repositories {
-        mavenCentral()
-    }
-
-    dependencies {
-        classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version"
-    }
-}
-
-apply plugin: 'kotlin'
-apply plugin: 'application'
-
-mainClassName="StickerInfoBotJvmKt"
-
-
-dependencies {
-    implementation "org.jetbrains.kotlin:kotlin-stdlib:$kotlin_version"
-
-    implementation project(":StickerInfoBot:StickerInfoBotLib")
-}

StickerInfoBot/jvm_launcher/src/main/kotlin/StickerInfoBotBotJvm.kt

@@ -1,5 +0,0 @@
-suspend fun main(args: Array<String>) {
-    activateStickerInfoBot(args.first()) {
-        println(it)
-    }
-}

StickerSetHandler/README.md

@@ -1,9 +0,0 @@
-# StickerSetHandler
-
-Send sticker to this bot to form your own stickers set. Send /delete to delete this sticker set
-
-## How to run
-
-```bash
-./gradlew run --args="TOKEN"
-```

StickerSetHandler/build.gradle

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

StickerSetHandler/src/main/kotlin/StickerSetHandlerBot.kt

@@ -1,118 +0,0 @@
-import dev.inmo.micro_utils.coroutines.runCatchingSafely
-import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions
-import dev.inmo.tgbotapi.extensions.api.bot.getMe
-import dev.inmo.tgbotapi.extensions.api.files.downloadFileToTemp
-import dev.inmo.tgbotapi.extensions.api.get.getStickerSet
-import dev.inmo.tgbotapi.extensions.api.send.reply
-import dev.inmo.tgbotapi.extensions.api.stickers.addStickerToSet
-import dev.inmo.tgbotapi.extensions.api.stickers.createNewStickerSet
-import dev.inmo.tgbotapi.extensions.api.stickers.deleteStickerSet
-import dev.inmo.tgbotapi.extensions.behaviour_builder.telegramBotWithBehaviourAndLongPolling
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onCommand
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onSticker
-import dev.inmo.tgbotapi.requests.abstracts.asMultipartFile
-import dev.inmo.tgbotapi.requests.stickers.InputSticker
-import dev.inmo.tgbotapi.types.StickerSetName
-import dev.inmo.tgbotapi.types.chat.Chat
-import dev.inmo.tgbotapi.types.files.CustomEmojiSticker
-import dev.inmo.tgbotapi.types.files.MaskSticker
-import dev.inmo.tgbotapi.types.files.RegularSticker
-import dev.inmo.tgbotapi.types.files.UnknownSticker
-import dev.inmo.tgbotapi.types.toChatId
-import dev.inmo.tgbotapi.utils.botCommand
-import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.Dispatchers
-
-/**
- * Send sticker to this bot to form your own stickers set. Send /delete to delete this sticker set
- */
-suspend fun main(args: Array<String>) {
-    telegramBotWithBehaviourAndLongPolling(
-        args.first(),
-        scope = CoroutineScope(Dispatchers.IO),
-        defaultExceptionsHandler = {
-            it.printStackTrace()
-        }
-    ) {
-        val me = getMe()
-        fun Chat.stickerSetName() = StickerSetName("s${id.chatId}_by_${me.username ?.withoutAt}")
-        onCommand("start") {
-            reply(it) {
-                botCommand("delete") + " - to clear stickers"
-            }
-        }
-        onCommand("delete") {
-            val deleted = runCatchingSafely {
-                deleteStickerSet(it.chat.stickerSetName())
-            }.getOrElse { false }
-
-            if (deleted) {
-                reply(it, "Deleted")
-            } else {
-                reply(it, "Can't delete for some of reason")
-            }
-        }
-        onSticker {
-            val stickerSetName = it.chat.stickerSetName()
-            val sticker = it.content.media
-            val newSticker = when (sticker) {
-                is CustomEmojiSticker -> InputSticker.WithKeywords.CustomEmoji(
-                    downloadFileToTemp(sticker.fileId).asMultipartFile(),
-                    sticker.stickerFormat,
-                    listOf(sticker.emoji ?: "\uD83D\uDE0A"),
-                    emptyList()
-                )
-                is MaskSticker -> InputSticker.Mask(
-                    downloadFileToTemp(sticker.fileId).asMultipartFile(),
-                    sticker.stickerFormat,
-                    listOf(sticker.emoji ?: "\uD83D\uDE0A"),
-                    sticker.maskPosition
-                )
-                is RegularSticker -> InputSticker.WithKeywords.Regular(
-                    downloadFileToTemp(sticker.fileId).asMultipartFile(),
-                    sticker.stickerFormat,
-                    listOf(sticker.emoji ?: "\uD83D\uDE0A"),
-                    emptyList()
-                )
-                is UnknownSticker -> return@onSticker
-            }
-            runCatchingSafely {
-                getStickerSet(stickerSetName)
-            }.onSuccess { stickerSet ->
-                runCatching {
-                    addStickerToSet(it.chat.id.toChatId(), stickerSet.name, newSticker).also { _ ->
-                        reply(
-                            it,
-                            getStickerSet(stickerSetName).stickers.last()
-                        )
-                    }
-                }.onFailure { exception ->
-                    exception.printStackTrace()
-                    reply(
-                        it,
-                        "Unable to add sticker in stickerset"
-                    )
-                }
-            }.onFailure { exception ->
-                createNewStickerSet(
-                    it.chat.id.toChatId(),
-                    stickerSetName.string,
-                    "Sticker set by ${me.firstName}",
-                    listOf(
-                        newSticker
-                    ),
-                    (sticker as? CustomEmojiSticker) ?.needsRepainting ?: false
-                ).also { _ ->
-                    reply(
-                        it,
-                        getStickerSet(stickerSetName).stickers.first()
-                    )
-                }
-            }
-        }
-
-        allUpdatesFlow.subscribeSafelyWithoutExceptions(this) {
-            println(it)
-        }
-    }.second.join()
-}

SuggestedPosts/README.md

@@ -1,9 +0,0 @@
-# StickerSetHandler
-
-Send sticker to this bot to form your own stickers set. Send /delete to delete this sticker set
-
-## How to run
-
-```bash
-./gradlew run --args="TOKEN"
-```

SuggestedPosts/build.gradle

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

SuggestedPosts/src/main/kotlin/SuggestedPostsBot.kt

@@ -1,140 +0,0 @@
-import dev.inmo.kslog.common.KSLog
-import dev.inmo.kslog.common.LogLevel
-import dev.inmo.kslog.common.defaultMessageFormatter
-import dev.inmo.kslog.common.setDefaultKSLog
-import dev.inmo.micro_utils.coroutines.runCatchingLogging
-import dev.inmo.micro_utils.coroutines.subscribeLoggingDropExceptions
-import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions
-import dev.inmo.tgbotapi.extensions.api.bot.getMe
-import dev.inmo.tgbotapi.extensions.api.bot.getMyStarBalance
-import dev.inmo.tgbotapi.extensions.api.chat.get.getChat
-import dev.inmo.tgbotapi.extensions.api.send.reply
-import dev.inmo.tgbotapi.extensions.api.send.resend
-import dev.inmo.tgbotapi.extensions.api.send.send
-import dev.inmo.tgbotapi.extensions.api.suggested.approveSuggestedPost
-import dev.inmo.tgbotapi.extensions.api.suggested.declineSuggestedPost
-import dev.inmo.tgbotapi.extensions.behaviour_builder.BehaviourContextData
-import dev.inmo.tgbotapi.extensions.behaviour_builder.buildSubcontextInitialAction
-import dev.inmo.tgbotapi.extensions.behaviour_builder.expectations.waitSuggestedPostApproved
-import dev.inmo.tgbotapi.extensions.behaviour_builder.expectations.waitSuggestedPostDeclined
-import dev.inmo.tgbotapi.extensions.behaviour_builder.telegramBotWithBehaviourAndLongPolling
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onChannelDirectMessagesConfigurationChanged
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onCommand
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onContentMessage
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onSuggestedPostApprovalFailed
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onSuggestedPostApproved
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onSuggestedPostDeclined
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onSuggestedPostPaid
-import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onSuggestedPostRefunded
-import dev.inmo.tgbotapi.extensions.utils.channelDirectMessagesContentMessageOrNull
-import dev.inmo.tgbotapi.extensions.utils.previewChannelDirectMessagesChatOrNull
-import dev.inmo.tgbotapi.extensions.utils.suggestedChannelDirectMessagesContentMessageOrNull
-import dev.inmo.tgbotapi.types.message.SuggestedPostParameters
-import dev.inmo.tgbotapi.types.message.abstracts.ChannelPaidPost
-import dev.inmo.tgbotapi.types.message.abstracts.CommonMessage
-import dev.inmo.tgbotapi.types.update.abstracts.Update
-import dev.inmo.tgbotapi.utils.firstOf
-import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.Dispatchers
-import kotlinx.coroutines.delay
-import kotlinx.coroutines.flow.filter
-import kotlinx.coroutines.flow.first
-
-/**
- * This place can be the playground for your code.
- */
-suspend fun main(vararg args: String) {
-    val botToken = args.first()
-
-    val isDebug = args.any { it == "debug" }
-    val isTestServer = args.any { it == "testServer" }
-
-    if (isDebug) {
-        setDefaultKSLog(
-            KSLog { level: LogLevel, tag: String?, message: Any, throwable: Throwable? ->
-                println(defaultMessageFormatter(level, tag, message, throwable))
-            }
-        )
-    }
-
-    telegramBotWithBehaviourAndLongPolling(
-        botToken,
-        CoroutineScope(Dispatchers.Default),
-        testServer = isTestServer,
-    ) {
-        // start here!!
-        val me = getMe()
-        println(me)
-
-        onCommand("start") {
-            println(getChat(it.chat))
-        }
-
-        onContentMessage {
-            val message = it.channelDirectMessagesContentMessageOrNull() ?: return@onContentMessage
-            val chat = getChat(it.chat)
-            println(chat)
-
-            resend(
-                message.chat.id,
-                message.content,
-                suggestedPostParameters = SuggestedPostParameters()
-            )
-        }
-
-        onContentMessage(
-            subcontextUpdatesFilter = { _, _ -> true } // important to not miss updates in channel for waitSuggestedPost events
-        ) { message ->
-            val suggestedPost = message.suggestedChannelDirectMessagesContentMessageOrNull() ?: return@onContentMessage
-
-            firstOf(
-                {
-                    waitSuggestedPostApproved().filter {
-                        it.suggestedPostMessage ?.chat ?.id == message.chat.id
-                    }.first()
-                },
-                {
-                    waitSuggestedPostDeclined().filter {
-                        it.suggestedPostMessage ?.chat ?.id == message.chat.id
-                    }.first()
-                },
-                {
-                    for (i in 0 until 3) {
-                        delay(1000L)
-                        send(suggestedPost.chat, "${3 - i}")
-                    }
-                    declineSuggestedPost(suggestedPost)
-                },
-            )
-        }
-
-        onContentMessage(initialFilter = { it is ChannelPaidPost<*> }) {
-            println(it)
-        }
-
-        onSuggestedPostPaid {
-            println(it)
-            reply(it, "Paid")
-        }
-        onSuggestedPostApproved {
-            println(it)
-            reply(it, "Approved")
-        }
-        onSuggestedPostDeclined {
-            println(it)
-            reply(it, "Declined")
-        }
-        onSuggestedPostRefunded {
-            println(it)
-            reply(it, "Refunded")
-        }
-        onSuggestedPostApprovalFailed {
-            println(it)
-            reply(it, "Approval failed")
-        }
-
-        allUpdatesFlow.subscribeLoggingDropExceptions(this) {
-            println(it)
-        }
-    }.second.join()
-}

TopicsHandling/README.md

@@ -1,9 +0,0 @@
-# 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

@@ -1,21 +0,0 @@
-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

@@ -1,135 +0,0 @@
-import com.benasher44.uuid.uuid4
-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.*
-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()
-}

UserChatShared/README.md

@@ -1,9 +0,0 @@
-# UserChatShared
-
-Use `/start` with bot to get request buttons. Bot will ask you to choose user/chat from your list and send it to him.
-
-## Launch
-
-```bash
-../gradlew run --args="BOT_TOKEN"
-```

UserChatShared/build.gradle

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