mirror of
https://github.com/InsanusMokrassar/TelegramBotAPI-examples.git
synced 2026-04-09 03:22:23 +00:00
Compare commits
1 Commits
9.1.0
...
31793eeb8e
| Author | SHA1 | Date | |
|---|---|---|---|
| 31793eeb8e |
@@ -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"
|
|
||||||
```
|
|
||||||
@@ -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"
|
|
||||||
}
|
|
||||||
@@ -1,99 +0,0 @@
|
|||||||
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()
|
|
||||||
}
|
|
||||||
@@ -4,8 +4,6 @@ include ":RandomFileSenderBot"
|
|||||||
|
|
||||||
include ":HelloBot"
|
include ":HelloBot"
|
||||||
|
|
||||||
include ":PollsBot"
|
|
||||||
|
|
||||||
include ":GetMeBot"
|
include ":GetMeBot"
|
||||||
|
|
||||||
include ":DeepLinksBot"
|
include ":DeepLinksBot"
|
||||||
|
|||||||
Reference in New Issue
Block a user