mirror of
				https://github.com/InsanusMokrassar/TelegramBotApiLibraries.git
				synced 2025-10-31 12:10:15 +00:00 
			
		
		
		
	Compare commits
	
		
			26 Commits
		
	
	
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| 00c0f0fd6f | |||
| 551eb293ab | |||
| f1b58a889f | |||
| 36a0f9b65b | |||
| 86abe49bc1 | |||
| 5b62bfa7d3 | |||
| d94d847715 | |||
| 91013b914d | |||
| cec4c610f3 | |||
| b9003388b1 | |||
| 6d161c2d78 | |||
| dc63639fee | |||
| 66934c823d | |||
| 90870c225c | |||
| 106d01775c | |||
| cea2f7dc6e | |||
| 7d461edc9b | |||
| c52c6cb633 | |||
| 6db1755ee7 | |||
| ccf60c95ca | |||
| 4057d5167f | |||
| f19664da58 | |||
| 646a551b15 | |||
| a08974e76d | |||
| 30e62041c0 | |||
| be8fe43e76 | 
| @@ -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.21 | kotlin_version=1.9.23 | ||||||
| kotlin_serialisation_core_version=1.6.2 | kotlin_serialisation_core_version=1.6.3 | ||||||
|  |  | ||||||
| github_release_plugin_version=2.4.1 | github_release_plugin_version=2.5.2 | ||||||
|  |  | ||||||
| tgbotapi_version=9.4.2 | tgbotapi_version=15.2.0 | ||||||
| micro_utils_version=0.20.19 | micro_utils_version=0.21.4 | ||||||
| exposed_version=0.45.0 | exposed_version=0.50.1 | ||||||
| plagubot_version=7.4.1 | plagubot_version=8.5.1 | ||||||
|  |  | ||||||
| # 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.1 | version=0.21.1 | ||||||
|   | |||||||
							
								
								
									
										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.4-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 | ||||||
|   | |||||||
| @@ -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