mirror of
https://github.com/InsanusMokrassar/TelegramBotAPI-examples.git
synced 2024-11-17 22:03:54 +00:00
101 lines
3.9 KiB
Kotlin
101 lines
3.9 KiB
Kotlin
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.ReplyParameters
|
|
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,
|
|
replyParameters = ReplyParameters(it)
|
|
)
|
|
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,
|
|
replyParameters = ReplyParameters(it)
|
|
)
|
|
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()
|
|
}
|