complete adding of panel plugin

triggers/command/src/jvmMain/kotlin/Plugin.kt

@@ -1,28 +1,42 @@
 package dev.inmo.plaguposter.triggers.command
 
+import com.benasher44.uuid.uuid4
 import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions
 import dev.inmo.micro_utils.fsm.common.State
+import dev.inmo.micro_utils.pagination.firstPageWithOneElementPagination
 import dev.inmo.plagubot.Plugin
 import dev.inmo.plaguposter.common.SuccessfulSymbol
+import dev.inmo.plaguposter.common.UnsuccessfulSymbol
 import dev.inmo.plaguposter.inlines.models.Format
 import dev.inmo.plaguposter.inlines.models.OfferTemplate
 import dev.inmo.plaguposter.inlines.repos.InlineTemplatesRepo
+import dev.inmo.plaguposter.posts.models.PostId
+import dev.inmo.plaguposter.posts.panel.PanelButtonBuilder
+import dev.inmo.plaguposter.posts.panel.PanelButtonsAPI
 import dev.inmo.plaguposter.posts.repo.PostsRepo
 import dev.inmo.plaguposter.posts.sending.PostPublisher
 import dev.inmo.plaguposter.ratings.selector.Selector
+import dev.inmo.tgbotapi.extensions.api.answers.answer
 import dev.inmo.tgbotapi.extensions.api.edit.edit
 import dev.inmo.tgbotapi.extensions.api.send.reply
 import dev.inmo.tgbotapi.extensions.api.send.send
 import dev.inmo.tgbotapi.extensions.behaviour_builder.BehaviourContextWithFSM
+import dev.inmo.tgbotapi.extensions.behaviour_builder.expectations.waitMessageDataCallbackQuery
 import dev.inmo.tgbotapi.extensions.behaviour_builder.expectations.waitTextMessage
 import dev.inmo.tgbotapi.extensions.behaviour_builder.strictlyOn
 import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onCommand
-import dev.inmo.tgbotapi.extensions.utils.botCommandTextSourceOrNull
-import dev.inmo.tgbotapi.extensions.utils.contentMessageOrNull
+import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onMessageDataCallbackQuery
+import dev.inmo.tgbotapi.extensions.utils.*
+import dev.inmo.tgbotapi.extensions.utils.extensions.sameMessage
+import dev.inmo.tgbotapi.extensions.utils.types.buttons.dataButton
+import dev.inmo.tgbotapi.extensions.utils.types.buttons.flatInlineKeyboard
 import dev.inmo.tgbotapi.types.ChatId
 import dev.inmo.tgbotapi.types.MessageIdentifier
+import dev.inmo.tgbotapi.types.buttons.InlineKeyboardButtons.CallbackDataInlineKeyboardButton
+import dev.inmo.tgbotapi.types.buttons.InlineKeyboardMarkup
 import dev.inmo.tgbotapi.types.message.textsources.regular
 import kotlinx.coroutines.flow.filter
+import kotlinx.coroutines.flow.first
 import kotlinx.serialization.Serializable
 import kotlinx.serialization.json.*
 import org.jetbrains.exposed.sql.Database
@@ -36,13 +50,22 @@ object Plugin : Plugin {
         val sourceMessageId: MessageIdentifier,
         val messageInReply: MessageIdentifier
     ) : State
+    @Serializable
+    internal data class Config(
+        val panelButtonText: String? = "Publish"
+    )
     override fun Module.setupDI(database: Database, params: JsonObject) {
+        params["publish_command"] ?.let { configJson ->
+            single { get<Json>().decodeFromJsonElement(Config.serializer(), configJson) }
+        }
     }
 
     override suspend fun BehaviourContextWithFSM<State>.setupBotPlugin(koin: Koin) {
         val postsRepo = koin.get<PostsRepo>()
         val publisher = koin.get<PostPublisher>()
         val selector = koin.getOrNull<Selector>()
+        val config = koin.getOrNull<Config>()
+        val panelApi = koin.getOrNull<PanelButtonsAPI>()
 
         onCommand("publish_post") {
             val messageInReply = it.replyTo ?.contentMessageOrNull() ?: run {
@@ -87,5 +110,44 @@ object Plugin : Plugin {
                 )
             )
         }
+
+        panelApi ?.apply {
+            config ?.panelButtonText ?.let { text ->
+                add(
+                    PanelButtonBuilder {
+                        CallbackDataInlineKeyboardButton(
+                            text,
+                            "publish ${it.id.string}"
+                        )
+                    }
+                )
+                onMessageDataCallbackQuery(
+                    initialFilter = {
+                        it.data.startsWith("publish ")
+                    }
+                ) {
+                    val postId = it.data.removePrefix("publish ").let(::PostId)
+                    val post = postsRepo.getById(postId) ?: return@onMessageDataCallbackQuery
+
+                    val publishData = uuid4().toString()
+
+                    val edited = edit(
+                        it.message,
+                        replyMarkup = flatInlineKeyboard {
+                            dataButton(SuccessfulSymbol, publishData)
+                            RootPanelButtonBuilder.buildButton(post) ?.let(::add)
+                        }
+                    )
+
+                    val pushedButton = waitMessageDataCallbackQuery().first {
+                        it.message.sameMessage(edited)
+                    }
+
+                    if (pushedButton.data == publishData) {
+                        publisher.publish(postId)
+                    }
+                }
+            }
+        }
     }
 }