update PollsBot

9.0.0

.gitignore

@@ -10,3 +10,6 @@ build/
 out/
 
 kotlin-js-store/
+
+local.*
+local.*/

DeepLinksBot/src/main/kotlin/DeepLinksBot.kt

@@ -17,12 +17,17 @@ suspend fun main(vararg args: String) {
 
     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(me.username, it.content.text))
+            reply(it, makeTelegramDeepLink(username, it.content.text))
         }
 
         onCommand("start", requireOnlyCommandInMessage = true) { // handling of `start` without args

HelloBot/src/main/kotlin/HelloBot.kt

@@ -28,7 +28,7 @@ suspend fun main(vararg args: String) {
 
     telegramBotWithBehaviourAndLongPolling(botToken, CoroutineScope(Dispatchers.IO)) {
         val me = getMe()
-        onMentionWithAnyContent(me.username) { message ->
+        onMentionWithAnyContent(me) { message ->
             val chat = message.chat
 
             val answerText = when (val chat = message.chat) {

PollsBot/README.md

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

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

@@ -0,0 +1,99 @@
+import com.benasher44.uuid.uuid4
+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.*
+import dev.inmo.tgbotapi.extensions.api.send.polls.sendRegularPoll
+import dev.inmo.tgbotapi.extensions.behaviour_builder.telegramBotWithBehaviourAndLongPolling
+import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.*
+import dev.inmo.tgbotapi.extensions.utils.extensions.raw.sender_chat
+import dev.inmo.tgbotapi.extensions.utils.formatting.linkMarkdownV2
+import dev.inmo.tgbotapi.extensions.utils.formatting.textMentionMarkdownV2
+import dev.inmo.tgbotapi.extensions.utils.ifChannelChat
+import dev.inmo.tgbotapi.extensions.utils.ifFromChannelGroupContentMessage
+import dev.inmo.tgbotapi.types.ChatId
+import dev.inmo.tgbotapi.types.IdChatIdentifier
+import dev.inmo.tgbotapi.types.PollIdentifier
+import dev.inmo.tgbotapi.types.chat.*
+import dev.inmo.tgbotapi.types.chat.GroupChat
+import dev.inmo.tgbotapi.types.chat.PrivateChat
+import dev.inmo.tgbotapi.types.chat.SupergroupChat
+import dev.inmo.tgbotapi.types.message.MarkdownV2
+import dev.inmo.tgbotapi.types.polls.Poll
+import dev.inmo.tgbotapi.types.polls.PollAnswer
+import dev.inmo.tgbotapi.types.polls.PollOption
+import dev.inmo.tgbotapi.types.polls.RegularPoll
+import dev.inmo.tgbotapi.utils.PreviewFeature
+import dev.inmo.tgbotapi.utils.extensions.escapeMarkdownV2Common
+import kotlinx.coroutines.*
+import kotlinx.coroutines.sync.Mutex
+import kotlinx.coroutines.sync.withLock
+
+/**
+ * This bot will answer with anonymous or public poll and send message on
+ * updates of any of it.
+ * 
+ * * Use `/anonymous` to take anonymous regular poll
+ * * Use `/public` to take public regular poll
+ */
+@OptIn(PreviewFeature::class)
+suspend fun main(vararg args: String) {
+    val botToken = args.first()
+
+    telegramBotWithBehaviourAndLongPolling(botToken, CoroutineScope(Dispatchers.IO)) {
+        val me = getMe()
+
+        val pollToChat = mutableMapOf<PollIdentifier, IdChatIdentifier>()
+        val pollToChatMutex = Mutex()
+
+        onCommand("anonymous") {
+            val sentPoll = sendRegularPoll(
+                it.chat,
+                "Test regular anonymous poll",
+                (1 .. 10).map {
+                    it.toString()
+                },
+                isAnonymous = true,
+                replyToMessageId = it.messageId
+            )
+            pollToChatMutex.withLock {
+                pollToChat[sentPoll.content.poll.id] = sentPoll.chat.id
+            }
+        }
+
+        onCommand("public") {
+            val sentPoll = sendRegularPoll(
+                it.chat,
+                "Test regular anonymous poll",
+                (1 .. 10).map {
+                    it.toString()
+                },
+                isAnonymous = false,
+                replyToMessageId = it.messageId
+            )
+            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()}")
+            }
+        }
+
+        allUpdatesFlow.subscribeSafelyWithoutExceptions(this) { println(it) }
+    }.second.join()
+}

RightsChangerBot/src/main/kotlin/RightsChanger.kt

@@ -1,3 +1,4 @@
+import dev.inmo.micro_utils.coroutines.runCatchingSafely
 import dev.inmo.tgbotapi.bot.ktor.telegramBot
 import dev.inmo.tgbotapi.extensions.api.bot.setMyCommands
 import dev.inmo.tgbotapi.extensions.api.chat.get.getChat
@@ -111,7 +112,7 @@ suspend fun main(args: Array<String>) {
 
     bot.buildBehaviourWithLongPolling(
         defaultExceptionsHandler = {
-            println(it)
+            it.printStackTrace()
         }
     ) {
         onCommand("simple", initialFilter = { it.chat is PublicChat && it.fromUserMessageOrNull() ?.user ?.id == allowedAdmin }) {

StickerSetHandler/src/main/kotlin/StickerSetHandlerBot.kt

@@ -32,7 +32,7 @@ suspend fun main(args: Array<String>) {
         }
     ) {
         val me = getMe()
-        fun Chat.stickerSetName() = "s${id.chatId}_by_${me.username.usernameWithoutAt}"
+        fun Chat.stickerSetName() = "s${id.chatId}_by_${me.username ?.usernameWithoutAt}"
         onCommand("start") {
             reply(it) {
                 botCommand("delete") + " - to clear stickers"

gradle.properties

@@ -4,8 +4,8 @@ org.gradle.parallel=true
 org.gradle.jvmargs=-Xmx2g
 
 
-kotlin_version=1.8.21
-telegram_bot_api_version=8.0.1
-micro_utils_version=0.19.2
+kotlin_version=1.8.22
+telegram_bot_api_version=9.1.0
+micro_utils_version=0.19.9
 serialization_version=1.5.1
-ktor_version=2.3.1
+ktor_version=2.3.3

gradle/wrapper/gradle-wrapper.properties

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

settings.gradle

@@ -4,6 +4,8 @@ include ":RandomFileSenderBot"
 
 include ":HelloBot"
 
+include ":PollsBot"
+
 include ":GetMeBot"
 
 include ":DeepLinksBot"