mirror of
https://github.com/InsanusMokrassar/TelegramBotApiLibraries.git
synced 2025-10-27 02:03:47 +00:00
Compare commits
26 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| a0e17a664c | |||
| fc3bf19453 | |||
| 8d1c57700e | |||
| 00c0f0fd6f | |||
| 551eb293ab | |||
| f1b58a889f | |||
| 36a0f9b65b | |||
| 86abe49bc1 | |||
| 5b62bfa7d3 | |||
| d94d847715 | |||
| 91013b914d | |||
| cec4c610f3 | |||
| b9003388b1 | |||
| 6d161c2d78 | |||
| dc63639fee | |||
| 66934c823d | |||
| 90870c225c | |||
| 106d01775c | |||
| cea2f7dc6e | |||
| 7d461edc9b | |||
| c52c6cb633 | |||
| 6db1755ee7 | |||
| ccf60c95ca | |||
| 4057d5167f | |||
| f19664da58 | |||
| 646a551b15 |
@@ -3,6 +3,7 @@ package dev.inmo.tgbotapi.libraries.cache.admins
|
|||||||
import korlibs.time.minutes
|
import korlibs.time.minutes
|
||||||
import dev.inmo.tgbotapi.types.IdChatIdentifier
|
import dev.inmo.tgbotapi.types.IdChatIdentifier
|
||||||
import dev.inmo.tgbotapi.types.Seconds
|
import dev.inmo.tgbotapi.types.Seconds
|
||||||
|
import korlibs.time.seconds
|
||||||
import kotlinx.coroutines.flow.SharedFlow
|
import kotlinx.coroutines.flow.SharedFlow
|
||||||
import kotlinx.serialization.Serializable
|
import kotlinx.serialization.Serializable
|
||||||
|
|
||||||
|
|||||||
@@ -8,6 +8,7 @@ import dev.inmo.tgbotapi.types.*
|
|||||||
import dev.inmo.tgbotapi.types.chat.ExtendedBot
|
import dev.inmo.tgbotapi.types.chat.ExtendedBot
|
||||||
import dev.inmo.tgbotapi.types.chat.member.AdministratorChatMember
|
import dev.inmo.tgbotapi.types.chat.member.AdministratorChatMember
|
||||||
import dev.inmo.tgbotapi.types.message.abstracts.*
|
import dev.inmo.tgbotapi.types.message.abstracts.*
|
||||||
|
import korlibs.time.seconds
|
||||||
import kotlinx.serialization.Serializable
|
import kotlinx.serialization.Serializable
|
||||||
|
|
||||||
interface DefaultAdminsCacheAPIRepo {
|
interface DefaultAdminsCacheAPIRepo {
|
||||||
|
|||||||
@@ -38,8 +38,8 @@ fun TelegramBot.createAdminsCacheAPI(
|
|||||||
{ long("chatId") },
|
{ long("chatId") },
|
||||||
{ text("member") },
|
{ text("member") },
|
||||||
"AdminsTable"
|
"AdminsTable"
|
||||||
).withMapper<IdChatIdentifier, AdministratorChatMember, Identifier, String>(
|
).withMapper<IdChatIdentifier, AdministratorChatMember, Long, String>(
|
||||||
keyFromToTo = { chatId },
|
keyFromToTo = { chatId.long },
|
||||||
valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(AdministratorChatMember.serializer(), this) },
|
valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(AdministratorChatMember.serializer(), this) },
|
||||||
keyToToFrom = { toChatId() },
|
keyToToFrom = { toChatId() },
|
||||||
valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(AdministratorChatMember.serializer(), this) }
|
valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(AdministratorChatMember.serializer(), this) }
|
||||||
@@ -49,8 +49,8 @@ fun TelegramBot.createAdminsCacheAPI(
|
|||||||
{ long("chatId") },
|
{ long("chatId") },
|
||||||
{ long("datetime") },
|
{ long("datetime") },
|
||||||
"AdminsUpdatesTimesTable"
|
"AdminsUpdatesTimesTable"
|
||||||
).withMapper<IdChatIdentifier, Long, Identifier, Long>(
|
).withMapper<IdChatIdentifier, Long, Long, Long>(
|
||||||
keyFromToTo = { chatId },
|
keyFromToTo = { chatId.long },
|
||||||
valueFromToTo = { this },
|
valueFromToTo = { this },
|
||||||
keyToToFrom = { toChatId() },
|
keyToToFrom = { toChatId() },
|
||||||
valueToToFrom = { this }
|
valueToToFrom = { this }
|
||||||
@@ -63,8 +63,8 @@ fun TelegramBot.createAdminsCacheAPI(
|
|||||||
{ long("chatId") },
|
{ long("chatId") },
|
||||||
{ text("settings") },
|
{ text("settings") },
|
||||||
"DynamicAdminsCacheSettingsAPI"
|
"DynamicAdminsCacheSettingsAPI"
|
||||||
).withMapper<IdChatIdentifier, AdminsCacheSettings, Identifier, String>(
|
).withMapper<IdChatIdentifier, AdminsCacheSettings, Long, String>(
|
||||||
keyFromToTo = { chatId },
|
keyFromToTo = { chatId.long },
|
||||||
valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(AdminsCacheSettings.serializer() , this) },
|
valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(AdminsCacheSettings.serializer() , this) },
|
||||||
keyToToFrom = { toChatId() },
|
keyToToFrom = { toChatId() },
|
||||||
valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(AdminsCacheSettings.serializer() , this) }
|
valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(AdminsCacheSettings.serializer() , this) }
|
||||||
|
|||||||
@@ -55,8 +55,8 @@ class AdminsPlugin : Plugin {
|
|||||||
{ long("chatId") },
|
{ long("chatId") },
|
||||||
{ text("member") },
|
{ text("member") },
|
||||||
"AdminsTable"
|
"AdminsTable"
|
||||||
).withMapper<IdChatIdentifier, AdministratorChatMember, Identifier, String>(
|
).withMapper<IdChatIdentifier, AdministratorChatMember, Long, String>(
|
||||||
keyFromToTo = { chatId },
|
keyFromToTo = { chatId.long },
|
||||||
valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(this) },
|
valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(this) },
|
||||||
keyToToFrom = { toChatId() },
|
keyToToFrom = { toChatId() },
|
||||||
valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(this) }
|
valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(this) }
|
||||||
@@ -66,8 +66,8 @@ class AdminsPlugin : Plugin {
|
|||||||
{ long("chatId") },
|
{ long("chatId") },
|
||||||
{ long("datetime") },
|
{ long("datetime") },
|
||||||
"AdminsUpdatesTimesTable"
|
"AdminsUpdatesTimesTable"
|
||||||
).withMapper<IdChatIdentifier, Long, Identifier, Long>(
|
).withMapper<IdChatIdentifier, Long, Long, Long>(
|
||||||
keyFromToTo = { chatId },
|
keyFromToTo = { chatId.long },
|
||||||
valueFromToTo = { this },
|
valueFromToTo = { this },
|
||||||
keyToToFrom = { toChatId() },
|
keyToToFrom = { toChatId() },
|
||||||
valueToToFrom = { this }
|
valueToToFrom = { this }
|
||||||
@@ -82,8 +82,8 @@ class AdminsPlugin : Plugin {
|
|||||||
{ long("chatId") },
|
{ long("chatId") },
|
||||||
{ text("settings") },
|
{ text("settings") },
|
||||||
"DynamicAdminsCacheSettingsAPI"
|
"DynamicAdminsCacheSettingsAPI"
|
||||||
).withMapper<IdChatIdentifier, AdminsCacheSettings, Identifier, String>(
|
).withMapper<IdChatIdentifier, AdminsCacheSettings, Long, String>(
|
||||||
keyFromToTo = { chatId },
|
keyFromToTo = { chatId.long },
|
||||||
valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(this) },
|
valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(this) },
|
||||||
keyToToFrom = { toChatId() },
|
keyToToFrom = { toChatId() },
|
||||||
valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(this) }
|
valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(this) }
|
||||||
|
|||||||
@@ -4,7 +4,7 @@ import dev.inmo.micro_utils.repos.*
|
|||||||
import dev.inmo.micro_utils.repos.mappers.withMapper
|
import dev.inmo.micro_utils.repos.mappers.withMapper
|
||||||
import dev.inmo.tgbotapi.libraries.cache.media.common.MessagesSimpleCache
|
import dev.inmo.tgbotapi.libraries.cache.media.common.MessagesSimpleCache
|
||||||
import dev.inmo.tgbotapi.types.ChatId
|
import dev.inmo.tgbotapi.types.ChatId
|
||||||
import dev.inmo.tgbotapi.types.MessageIdentifier
|
import dev.inmo.tgbotapi.types.MessageId
|
||||||
import dev.inmo.tgbotapi.types.message.content.MessageContent
|
import dev.inmo.tgbotapi.types.message.content.MessageContent
|
||||||
import kotlinx.serialization.*
|
import kotlinx.serialization.*
|
||||||
import kotlinx.serialization.builtins.PairSerializer
|
import kotlinx.serialization.builtins.PairSerializer
|
||||||
@@ -47,7 +47,7 @@ class SimpleKeyValueMessageContentCache<K>(
|
|||||||
|
|
||||||
val chatIdToMessageIdentifierSerializer = PairSerializer(
|
val chatIdToMessageIdentifierSerializer = PairSerializer(
|
||||||
ChatId.serializer(),
|
ChatId.serializer(),
|
||||||
MessageIdentifier.serializer()
|
MessageId.serializer()
|
||||||
)
|
)
|
||||||
|
|
||||||
val messageContentSerializer = PolymorphicSerializer<MessageContent>(MessageContent::class)
|
val messageContentSerializer = PolymorphicSerializer<MessageContent>(MessageContent::class)
|
||||||
@@ -56,9 +56,9 @@ inline fun <K> KeyValueRepo<K, MessageContent>.asMessageContentCache() = SimpleK
|
|||||||
|
|
||||||
inline fun KeyValueRepo<String, String>.asMessageContentCache(
|
inline fun KeyValueRepo<String, String>.asMessageContentCache(
|
||||||
serialFormatCreator: (SerializersModule) -> StringFormat = { Json { serializersModule = it } }
|
serialFormatCreator: (SerializersModule) -> StringFormat = { Json { serializersModule = it } }
|
||||||
): StandardKeyValueRepo<Pair<ChatId, MessageIdentifier>, MessageContent> {
|
): StandardKeyValueRepo<Pair<ChatId, MessageId>, MessageContent> {
|
||||||
val serialFormat = serialFormatCreator(MessageContent.serializationModule())
|
val serialFormat = serialFormatCreator(MessageContent.serializationModule())
|
||||||
return withMapper<Pair<ChatId, MessageIdentifier>, MessageContent, String, String>(
|
return withMapper<Pair<ChatId, MessageId>, MessageContent, String, String>(
|
||||||
{ serialFormat.encodeToString(chatIdToMessageIdentifierSerializer, this) },
|
{ serialFormat.encodeToString(chatIdToMessageIdentifierSerializer, this) },
|
||||||
{ serialFormat.encodeToString(messageContentSerializer, this) },
|
{ serialFormat.encodeToString(messageContentSerializer, this) },
|
||||||
{ serialFormat.decodeFromString(chatIdToMessageIdentifierSerializer, this) },
|
{ serialFormat.decodeFromString(chatIdToMessageIdentifierSerializer, this) },
|
||||||
@@ -70,9 +70,9 @@ inline fun KeyValueRepo<String, String>.asMessageContentCache(
|
|||||||
@JsName("stringsKeyValueAsHexMessageContentCache")
|
@JsName("stringsKeyValueAsHexMessageContentCache")
|
||||||
inline fun KeyValueRepo<String, String>.asMessageContentCache(
|
inline fun KeyValueRepo<String, String>.asMessageContentCache(
|
||||||
serialFormatCreator: (SerializersModule) -> BinaryFormat
|
serialFormatCreator: (SerializersModule) -> BinaryFormat
|
||||||
): StandardKeyValueRepo<Pair<ChatId, MessageIdentifier>, MessageContent> {
|
): StandardKeyValueRepo<Pair<ChatId, MessageId>, MessageContent> {
|
||||||
val serialFormat = serialFormatCreator(MessageContent.serializationModule())
|
val serialFormat = serialFormatCreator(MessageContent.serializationModule())
|
||||||
return withMapper<Pair<ChatId, MessageIdentifier>, MessageContent, String, String>(
|
return withMapper<Pair<ChatId, MessageId>, MessageContent, String, String>(
|
||||||
{ serialFormat.encodeToHexString(chatIdToMessageIdentifierSerializer, this) },
|
{ serialFormat.encodeToHexString(chatIdToMessageIdentifierSerializer, this) },
|
||||||
{ serialFormat.encodeToHexString(messageContentSerializer, this) },
|
{ serialFormat.encodeToHexString(messageContentSerializer, this) },
|
||||||
{ serialFormat.decodeFromHexString(chatIdToMessageIdentifierSerializer, this) },
|
{ serialFormat.decodeFromHexString(chatIdToMessageIdentifierSerializer, this) },
|
||||||
@@ -84,9 +84,9 @@ inline fun KeyValueRepo<String, String>.asMessageContentCache(
|
|||||||
@JsName("bytesKeyValueAsMessageContentCache")
|
@JsName("bytesKeyValueAsMessageContentCache")
|
||||||
inline fun KeyValueRepo<ByteArray, ByteArray>.asMessageContentCache(
|
inline fun KeyValueRepo<ByteArray, ByteArray>.asMessageContentCache(
|
||||||
serialFormatCreator: (SerializersModule) -> BinaryFormat
|
serialFormatCreator: (SerializersModule) -> BinaryFormat
|
||||||
): StandardKeyValueRepo<Pair<ChatId, MessageIdentifier>, MessageContent> {
|
): StandardKeyValueRepo<Pair<ChatId, MessageId>, MessageContent> {
|
||||||
val serialFormat = serialFormatCreator(MessageContent.serializationModule())
|
val serialFormat = serialFormatCreator(MessageContent.serializationModule())
|
||||||
return withMapper<Pair<ChatId, MessageIdentifier>, MessageContent, ByteArray, ByteArray>(
|
return withMapper<Pair<ChatId, MessageId>, MessageContent, ByteArray, ByteArray>(
|
||||||
{ serialFormat.encodeToByteArray(chatIdToMessageIdentifierSerializer, this) },
|
{ serialFormat.encodeToByteArray(chatIdToMessageIdentifierSerializer, this) },
|
||||||
{ serialFormat.encodeToByteArray(messageContentSerializer, this) },
|
{ serialFormat.encodeToByteArray(messageContentSerializer, this) },
|
||||||
{ serialFormat.decodeFromByteArray(chatIdToMessageIdentifierSerializer, this) },
|
{ serialFormat.decodeFromByteArray(chatIdToMessageIdentifierSerializer, this) },
|
||||||
|
|||||||
@@ -6,21 +6,21 @@ kotlin.incremental=true
|
|||||||
kotlin.incremental.js=true
|
kotlin.incremental.js=true
|
||||||
|
|
||||||
|
|
||||||
kotlin_version=1.9.22
|
kotlin_version=2.0.10
|
||||||
kotlin_serialisation_core_version=1.6.2
|
kotlin_serialisation_core_version=1.7.1
|
||||||
|
|
||||||
github_release_plugin_version=2.4.1
|
github_release_plugin_version=2.5.2
|
||||||
|
|
||||||
tgbotapi_version=9.4.3
|
tgbotapi_version=16.0.0
|
||||||
micro_utils_version=0.20.23
|
micro_utils_version=0.22.0
|
||||||
exposed_version=0.45.0
|
exposed_version=0.53.0
|
||||||
plagubot_version=7.4.2
|
plagubot_version=9.0.0
|
||||||
|
|
||||||
# Dokka
|
# Dokka
|
||||||
|
|
||||||
dokka_version=1.9.10
|
dokka_version=1.9.20
|
||||||
|
|
||||||
# Project data
|
# Project data
|
||||||
|
|
||||||
group=dev.inmo
|
group=dev.inmo
|
||||||
version=0.17.2
|
version=0.22.0
|
||||||
|
|||||||
2
gradle/wrapper/gradle-wrapper.properties
vendored
2
gradle/wrapper/gradle-wrapper.properties
vendored
@@ -1,5 +1,5 @@
|
|||||||
distributionBase=GRADLE_USER_HOME
|
distributionBase=GRADLE_USER_HOME
|
||||||
distributionPath=wrapper/dists
|
distributionPath=wrapper/dists
|
||||||
distributionUrl=https\://services.gradle.org/distributions/gradle-8.5-bin.zip
|
distributionUrl=https\://services.gradle.org/distributions/gradle-8.7-bin.zip
|
||||||
zipStoreBase=GRADLE_USER_HOME
|
zipStoreBase=GRADLE_USER_HOME
|
||||||
zipStorePath=wrapper/dists
|
zipStorePath=wrapper/dists
|
||||||
|
|||||||
@@ -37,7 +37,6 @@ kotlin {
|
|||||||
jsTest {
|
jsTest {
|
||||||
dependencies {
|
dependencies {
|
||||||
implementation kotlin('test-js')
|
implementation kotlin('test-js')
|
||||||
implementation kotlin('test-junit')
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -2,9 +2,12 @@ package dev.inmo.tgbotapi.libraries.resender
|
|||||||
|
|
||||||
import dev.inmo.tgbotapi.types.FullChatIdentifierSerializer
|
import dev.inmo.tgbotapi.types.FullChatIdentifierSerializer
|
||||||
import dev.inmo.tgbotapi.types.IdChatIdentifier
|
import dev.inmo.tgbotapi.types.IdChatIdentifier
|
||||||
|
import dev.inmo.tgbotapi.types.MediaGroupId
|
||||||
import dev.inmo.tgbotapi.types.MessageId
|
import dev.inmo.tgbotapi.types.MessageId
|
||||||
|
import dev.inmo.tgbotapi.types.message.abstracts.ContentMessage
|
||||||
import dev.inmo.tgbotapi.types.message.abstracts.Message
|
import dev.inmo.tgbotapi.types.message.abstracts.Message
|
||||||
import dev.inmo.tgbotapi.types.message.abstracts.PossiblyMediaGroupMessage
|
import dev.inmo.tgbotapi.types.message.abstracts.PossiblyMediaGroupMessage
|
||||||
|
import dev.inmo.tgbotapi.types.message.content.MediaGroupContent
|
||||||
import kotlinx.serialization.Serializable
|
import kotlinx.serialization.Serializable
|
||||||
|
|
||||||
@Serializable
|
@Serializable
|
||||||
@@ -12,8 +15,21 @@ data class MessageMetaInfo(
|
|||||||
@Serializable(FullChatIdentifierSerializer::class)
|
@Serializable(FullChatIdentifierSerializer::class)
|
||||||
val chatId: IdChatIdentifier,
|
val chatId: IdChatIdentifier,
|
||||||
val messageId: MessageId,
|
val messageId: MessageId,
|
||||||
val group: String? = null
|
val group: MediaGroupId? = null
|
||||||
)
|
) {
|
||||||
|
val metaInfo: Message.MetaInfo
|
||||||
|
get() = Message.MetaInfo(chatId, messageId)
|
||||||
|
}
|
||||||
|
|
||||||
|
fun Message.asMessageMetaInfos(): List<MessageMetaInfo> {
|
||||||
|
return if (this is ContentMessage<*>) {
|
||||||
|
(content as? MediaGroupContent<*>) ?.group ?.map {
|
||||||
|
MessageMetaInfo(it.sourceMessage.chat.id, it.sourceMessage.messageId, it.sourceMessage.mediaGroupId)
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
null
|
||||||
|
} ?: listOf(MessageMetaInfo(chat.id, messageId, (this as? PossiblyMediaGroupMessage<*>) ?.mediaGroupId))
|
||||||
|
}
|
||||||
|
|
||||||
operator fun MessageMetaInfo.Companion.invoke(
|
operator fun MessageMetaInfo.Companion.invoke(
|
||||||
message: Message
|
message: Message
|
||||||
|
|||||||
@@ -1,8 +1,11 @@
|
|||||||
package dev.inmo.tgbotapi.libraries.resender
|
package dev.inmo.tgbotapi.libraries.resender
|
||||||
|
|
||||||
|
import dev.inmo.micro_utils.common.applyDiff
|
||||||
import dev.inmo.tgbotapi.bot.TelegramBot
|
import dev.inmo.tgbotapi.bot.TelegramBot
|
||||||
import dev.inmo.tgbotapi.requests.ForwardMessage
|
import dev.inmo.tgbotapi.requests.ForwardMessage
|
||||||
|
import dev.inmo.tgbotapi.requests.ForwardMessages
|
||||||
import dev.inmo.tgbotapi.requests.send.CopyMessage
|
import dev.inmo.tgbotapi.requests.send.CopyMessage
|
||||||
|
import dev.inmo.tgbotapi.requests.send.CopyMessages
|
||||||
import dev.inmo.tgbotapi.requests.send.media.SendMediaGroup
|
import dev.inmo.tgbotapi.requests.send.media.SendMediaGroup
|
||||||
import dev.inmo.tgbotapi.types.ChatIdentifier
|
import dev.inmo.tgbotapi.types.ChatIdentifier
|
||||||
import dev.inmo.tgbotapi.types.IdChatIdentifier
|
import dev.inmo.tgbotapi.types.IdChatIdentifier
|
||||||
@@ -80,13 +83,13 @@ class MessagesResender(
|
|||||||
else -> {
|
else -> {
|
||||||
val resultContents = contents.mapNotNull {
|
val resultContents = contents.mapNotNull {
|
||||||
it to (
|
it to (
|
||||||
bot.execute(
|
bot.execute(
|
||||||
ForwardMessage(
|
ForwardMessage(
|
||||||
toChatId = cacheChatId,
|
toChatId = cacheChatId,
|
||||||
fromChatId = it.chatId,
|
fromChatId = it.chatId,
|
||||||
messageId = it.messageId
|
messageId = it.messageId
|
||||||
)
|
)
|
||||||
) as? ContentMessage<*> ?: return@mapNotNull null)
|
) as? ContentMessage<*> ?: return@mapNotNull null)
|
||||||
}.mapNotNull { (src, forwardedMessage) ->
|
}.mapNotNull { (src, forwardedMessage) ->
|
||||||
val forwardedMessageAsMediaPartMessage = forwardedMessage.takeIf {
|
val forwardedMessageAsMediaPartMessage = forwardedMessage.takeIf {
|
||||||
it.content is MediaGroupPartContent
|
it.content is MediaGroupPartContent
|
||||||
|
|||||||
Reference in New Issue
Block a user