48 lines
1.6 KiB
Kotlin
48 lines
1.6 KiB
Kotlin
import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions
|
|
import dev.inmo.tgbotapi.extensions.api.bot.getMe
|
|
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.triggers_handling.*
|
|
import dev.inmo.tgbotapi.extensions.utils.shortcuts.*
|
|
import dev.inmo.tgbotapi.utils.extensions.threadIdOrNull
|
|
import kotlinx.coroutines.*
|
|
|
|
suspend fun activateResenderBot(
|
|
token: String,
|
|
print: (Any) -> Unit
|
|
) {
|
|
val bot = telegramBot(token)
|
|
|
|
print(bot.getMe())
|
|
|
|
bot.buildBehaviourWithLongPolling(CoroutineScope(currentCoroutineContext() + SupervisorJob())) {
|
|
onContentMessage(
|
|
subcontextUpdatesFilter = MessageFilterByChat,
|
|
) {
|
|
val chat = it.chat
|
|
|
|
val answer = withTypingAction(chat) {
|
|
executeUnsafe(
|
|
it.content.createResend(
|
|
chat.id,
|
|
messageThreadId = it.threadIdOrNull,
|
|
replyToMessageId = it.messageId
|
|
)
|
|
) {
|
|
it.forEach(print)
|
|
}
|
|
}
|
|
|
|
println("Answer info: $answer")
|
|
}
|
|
|
|
allUpdatesFlow.subscribeSafelyWithoutExceptions(this) {
|
|
println(it)
|
|
}
|
|
}.join()
|
|
}
|