diff --git a/ChecklistsBot/build.gradle b/ChecklistsBot/build.gradle new file mode 100644 index 0000000..a5fc55b --- /dev/null +++ b/ChecklistsBot/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="ChecklistsBotKt" + + +dependencies { + implementation "org.jetbrains.kotlin:kotlin-stdlib:$kotlin_version" + + implementation "dev.inmo:tgbotapi:$telegram_bot_api_version" +} diff --git a/ChecklistsBot/src/main/kotlin/ChecklistsBot.kt b/ChecklistsBot/src/main/kotlin/ChecklistsBot.kt new file mode 100644 index 0000000..bc69334 --- /dev/null +++ b/ChecklistsBot/src/main/kotlin/ChecklistsBot.kt @@ -0,0 +1,120 @@ +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() +} diff --git a/ResenderBot/jvm_launcher/src/main/kotlin/ResenderBotJvm.kt b/ResenderBot/jvm_launcher/src/main/kotlin/ResenderBotJvm.kt index 0aa1a92..9b9c812 100644 --- a/ResenderBot/jvm_launcher/src/main/kotlin/ResenderBotJvm.kt +++ b/ResenderBot/jvm_launcher/src/main/kotlin/ResenderBotJvm.kt @@ -1,4 +1,19 @@ +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) { + 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) } diff --git a/StarTransactionsBot/README.md b/StarTransactionsBot/README.md index 13b72ef..8790a9d 100644 --- a/StarTransactionsBot/README.md +++ b/StarTransactionsBot/README.md @@ -1,4 +1,4 @@ -# CustomBot +# StarTransactionsBot This bot basically have no any useful behaviour, but you may customize it as a playground diff --git a/SuggestedPosts/README.md b/SuggestedPosts/README.md new file mode 100644 index 0000000..6849019 --- /dev/null +++ b/SuggestedPosts/README.md @@ -0,0 +1,9 @@ +# 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" +``` diff --git a/SuggestedPosts/build.gradle b/SuggestedPosts/build.gradle new file mode 100644 index 0000000..a53fad2 --- /dev/null +++ b/SuggestedPosts/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="SuggestedPostsBotKt" + + +dependencies { + implementation "org.jetbrains.kotlin:kotlin-stdlib:$kotlin_version" + + implementation "dev.inmo:tgbotapi:$telegram_bot_api_version" +} diff --git a/SuggestedPosts/src/main/kotlin/SuggestedPostsBot.kt b/SuggestedPosts/src/main/kotlin/SuggestedPostsBot.kt new file mode 100644 index 0000000..6553b2b --- /dev/null +++ b/SuggestedPosts/src/main/kotlin/SuggestedPostsBot.kt @@ -0,0 +1,140 @@ +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() +} diff --git a/gradle.properties b/gradle.properties index 77a536c..9982181 100644 --- a/gradle.properties +++ b/gradle.properties @@ -6,7 +6,7 @@ kotlin.daemon.jvmargs=-Xmx3g -Xms500m kotlin_version=2.2.10 -telegram_bot_api_version=28.0.3 +telegram_bot_api_version=29.0.0 micro_utils_version=0.26.3 serialization_version=1.9.0 ktor_version=3.2.3 diff --git a/settings.gradle b/settings.gradle index bfdabe8..63cf651 100644 --- a/settings.gradle +++ b/settings.gradle @@ -59,3 +59,7 @@ include ":CustomBot" include ":MemberUpdatedWatcherBot" include ":WebHooks" + +include ":SuggestedPosts" + +include ":ChecklistsBot"