Merge pull request #3 from InsanusMokrassar/0.0.3

0.0.3
This commit is contained in:
InsanusMokrassar 2022-09-16 21:12:52 +06:00 committed by GitHub
commit 39d49f5d58
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 39 additions and 13 deletions

View File

@ -10,5 +10,5 @@ android.enableJetifier=true
# Project data
group=dev.inmo
version=0.0.2
android_code_version=2
version=0.0.3
android_code_version=3

View File

@ -3,14 +3,14 @@
kotlin = "1.7.10"
kotlin-serialization = "1.4.0"
plagubot = "2.3.1"
tgbotapi = "3.2.1"
plagubot = "2.3.2"
tgbotapi = "3.2.3"
microutils = "0.12.13"
kslog = "0.5.2"
krontab = "0.8.1"
tgbotapi-libraries = "0.5.3"
psql = "42.3.6"
psql = "42.5.0"
dexcount = "3.1.0"
junit_version = "4.12"

View File

@ -10,8 +10,10 @@ import dev.inmo.plaguposter.common.ChatConfig
import dev.inmo.plaguposter.posts.models.PostId
import dev.inmo.plaguposter.posts.panel.repos.PostsMessages
import dev.inmo.plaguposter.posts.repo.PostsRepo
import dev.inmo.tgbotapi.extensions.api.answers.answer
import dev.inmo.tgbotapi.extensions.api.delete
import dev.inmo.tgbotapi.extensions.api.edit.edit
import dev.inmo.tgbotapi.extensions.api.edit.text.editMessageText
import dev.inmo.tgbotapi.extensions.api.send.send
import dev.inmo.tgbotapi.extensions.behaviour_builder.BehaviourContext
import dev.inmo.tgbotapi.extensions.behaviour_builder.expectations.waitMessageDataCallbackQuery
@ -19,14 +21,11 @@ import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onMessag
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.extensions.utils.withContentOrNull
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.ParseMode
import dev.inmo.tgbotapi.types.message.abstracts.Message
import dev.inmo.tgbotapi.types.message.content.TextContent
import kotlinx.coroutines.flow.first
import kotlinx.serialization.Serializable
import kotlinx.serialization.json.*
@ -41,7 +40,8 @@ object Plugin : Plugin {
val parseMode: ParseMode? = null,
val buttonsPerRow: Int = 4,
val deleteButtonText: String? = null,
val rootButtonText: String = "Return to panel"
val rootButtonText: String = "\uD83D\uDD19",
val refreshButtonText: String? = "\uD83D\uDD04"
)
override fun Module.setupDI(database: Database, params: JsonObject) {
params["panel"] ?.let { element ->
@ -57,6 +57,14 @@ object Plugin : Plugin {
"delete ${it.id.string}"
)
}
},
config.refreshButtonText ?.let { text ->
PanelButtonBuilder {
CallbackDataInlineKeyboardButton(
text,
"refresh ${it.id.string}"
)
}
}
)
PanelButtonsAPI(
@ -97,7 +105,7 @@ object Plugin : Plugin {
delete(chatId, messageId)
}
suspend fun updatePost(
suspend fun refreshPostMessage(
postId: PostId,
chatId: ChatId,
messageId: MessageIdentifier
@ -108,9 +116,10 @@ object Plugin : Plugin {
builder.buildButton(post)
}.takeIf { it.isNotEmpty() }
}
edit(
editMessageText(
chatId,
messageId,
text = config.text,
replyMarkup = InlineKeyboardMarkup(buttons)
)
}
@ -121,7 +130,7 @@ object Plugin : Plugin {
}
) {
val postId = it.data.removePrefix(PanelButtonsAPI.openGlobalMenuDataPrefix).let(::PostId)
updatePost(postId, it.message.chat.id, it.message.messageId)
refreshPostMessage(postId, it.message.chat.id, it.message.messageId)
}
onMessageDataCallbackQuery(
initialFilter = {
@ -140,6 +149,7 @@ object Plugin : Plugin {
api.RootPanelButtonBuilder.buildButton(post) ?.let(::add)
}
)
answer(query)
val pushedButton = waitMessageDataCallbackQuery().first {
it.message.sameMessage(query.message)
@ -149,10 +159,25 @@ object Plugin : Plugin {
postsRepo.deleteById(postId)
}
}
onMessageDataCallbackQuery(
initialFilter = {
it.data.startsWith("refresh ") && it.message.chat.id == chatsConfig.sourceChatId
}
) { query ->
val postId = query.data.removePrefix("refresh ").let(::PostId)
val (chatId, messageId) = postsMessages.get(postId) ?: return@onMessageDataCallbackQuery
refreshPostMessage(
postId,
chatId,
messageId
)
answer(query)
}
api.forceRefreshFlow.subscribeSafelyWithoutExceptions(this) {
val (chatId, messageId) = postsMessages.get(it) ?: return@subscribeSafelyWithoutExceptions
updatePost(it, chatId, messageId)
refreshPostMessage(it, chatId, messageId)
}
}
}

View File

@ -273,6 +273,7 @@ object Plugin : Plugin {
attachPoll(postId)
}
}
answer(it)
}
}
}