mirror of
				https://github.com/InsanusMokrassar/TelegramBotApiLibraries.git
				synced 2025-10-29 03:00:12 +00:00 
			
		
		
		
	Compare commits
	
		
			60 Commits
		
	
	
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| d16de6428a | |||
| 49475a457d | |||
| b8312873b0 | |||
| 3ede07c2a6 | |||
| 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 | |||
| a08974e76d | |||
| 30e62041c0 | |||
| be8fe43e76 | |||
| 42f3a064ad | |||
| 34f9d8c0ab | |||
| 6e4fc54a23 | |||
| 674ee28991 | |||
| 4950fd4ed0 | |||
| e3f5ae0b24 | |||
| 3bf2d858eb | |||
| b51bc97551 | |||
| c0680932ab | |||
| 849edadab0 | |||
| f02933a9d0 | |||
| f018b723cb | |||
| 65d8fd6be1 | |||
| d44c13bea5 | |||
| 50c1e33b52 | |||
| 41b9001e1f | |||
| 2c44a4e580 | |||
| ffa9525c70 | |||
| 4f2df31e5e | |||
| 18f9318b63 | |||
| c97a48dcd4 | |||
| caaba32f9a | |||
| 2734fc0adc | |||
| 9c2e271d57 | |||
| 3edb5b1b11 | |||
| 82d859272f | |||
| 64952fb054 | 
							
								
								
									
										2
									
								
								.github/workflows/commit-publish.yml
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										2
									
								
								.github/workflows/commit-publish.yml
									
									
									
									
										vendored
									
									
								
							| @@ -7,7 +7,7 @@ jobs: | ||||
|       - uses: actions/checkout@v2 | ||||
|       - uses: actions/setup-java@v1 | ||||
|         with: | ||||
|           java-version: 11 | ||||
|           java-version: 17 | ||||
|       - name: Update version | ||||
|         run: | | ||||
|           branch="`echo "${{ github.ref }}" | grep -o "[^/]*$"`" | ||||
|   | ||||
							
								
								
									
										1
									
								
								.gitignore
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										1
									
								
								.gitignore
									
									
									
									
										vendored
									
									
								
							| @@ -1,4 +1,5 @@ | ||||
| .idea | ||||
| .kotlin | ||||
| out/* | ||||
| *.iml | ||||
| target | ||||
|   | ||||
| @@ -18,7 +18,7 @@ allprojects { | ||||
|         mavenLocal() | ||||
|         mavenCentral() | ||||
|         google() | ||||
|         maven { url "https://git.inmo.dev/api/packages/InsanusMokrassar/maven" } | ||||
|         maven { url "https://nexus.inmo.dev/repository/maven-releases/" } | ||||
|     } | ||||
| } | ||||
|  | ||||
|   | ||||
| @@ -3,6 +3,7 @@ package dev.inmo.tgbotapi.libraries.cache.admins | ||||
| import korlibs.time.minutes | ||||
| import dev.inmo.tgbotapi.types.IdChatIdentifier | ||||
| import dev.inmo.tgbotapi.types.Seconds | ||||
| import korlibs.time.seconds | ||||
| import kotlinx.coroutines.flow.SharedFlow | ||||
| 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.member.AdministratorChatMember | ||||
| import dev.inmo.tgbotapi.types.message.abstracts.* | ||||
| import korlibs.time.seconds | ||||
| import kotlinx.serialization.Serializable | ||||
|  | ||||
| interface DefaultAdminsCacheAPIRepo { | ||||
|   | ||||
| @@ -38,8 +38,8 @@ fun TelegramBot.createAdminsCacheAPI( | ||||
|             { long("chatId") }, | ||||
|             { text("member") }, | ||||
|             "AdminsTable" | ||||
|         ).withMapper<IdChatIdentifier, AdministratorChatMember, Identifier, String>( | ||||
|             keyFromToTo = { chatId }, | ||||
|         ).withMapper<IdChatIdentifier, AdministratorChatMember, Long, String>( | ||||
|             keyFromToTo = { chatId.long }, | ||||
|             valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(AdministratorChatMember.serializer(), this) }, | ||||
|             keyToToFrom = { toChatId() }, | ||||
|             valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(AdministratorChatMember.serializer(), this) } | ||||
| @@ -49,8 +49,8 @@ fun TelegramBot.createAdminsCacheAPI( | ||||
|             { long("chatId") }, | ||||
|             { long("datetime") }, | ||||
|             "AdminsUpdatesTimesTable" | ||||
|         ).withMapper<IdChatIdentifier, Long, Identifier, Long>( | ||||
|             keyFromToTo = { chatId }, | ||||
|         ).withMapper<IdChatIdentifier, Long, Long, Long>( | ||||
|             keyFromToTo = { chatId.long }, | ||||
|             valueFromToTo = { this }, | ||||
|             keyToToFrom = { toChatId() }, | ||||
|             valueToToFrom = { this } | ||||
| @@ -63,8 +63,8 @@ fun TelegramBot.createAdminsCacheAPI( | ||||
|             { long("chatId") }, | ||||
|             { text("settings") }, | ||||
|             "DynamicAdminsCacheSettingsAPI" | ||||
|         ).withMapper<IdChatIdentifier, AdminsCacheSettings, Identifier, String>( | ||||
|             keyFromToTo = { chatId }, | ||||
|         ).withMapper<IdChatIdentifier, AdminsCacheSettings, Long, String>( | ||||
|             keyFromToTo = { chatId.long }, | ||||
|             valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(AdminsCacheSettings.serializer() , this) }, | ||||
|             keyToToFrom = { toChatId() }, | ||||
|             valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(AdminsCacheSettings.serializer() , this) } | ||||
|   | ||||
| @@ -55,8 +55,8 @@ class AdminsPlugin : Plugin { | ||||
|                     { long("chatId") }, | ||||
|                     { text("member") }, | ||||
|                     "AdminsTable" | ||||
|                 ).withMapper<IdChatIdentifier, AdministratorChatMember, Identifier, String>( | ||||
|                     keyFromToTo = { chatId }, | ||||
|                 ).withMapper<IdChatIdentifier, AdministratorChatMember, Long, String>( | ||||
|                     keyFromToTo = { chatId.long }, | ||||
|                     valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(this) }, | ||||
|                     keyToToFrom = { toChatId() }, | ||||
|                     valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(this) } | ||||
| @@ -66,8 +66,8 @@ class AdminsPlugin : Plugin { | ||||
|                     { long("chatId") }, | ||||
|                     { long("datetime") }, | ||||
|                     "AdminsUpdatesTimesTable" | ||||
|                 ).withMapper<IdChatIdentifier, Long, Identifier, Long>( | ||||
|                     keyFromToTo = { chatId }, | ||||
|                 ).withMapper<IdChatIdentifier, Long, Long, Long>( | ||||
|                     keyFromToTo = { chatId.long }, | ||||
|                     valueFromToTo = { this }, | ||||
|                     keyToToFrom = { toChatId() }, | ||||
|                     valueToToFrom = { this } | ||||
| @@ -82,8 +82,8 @@ class AdminsPlugin : Plugin { | ||||
|                     { long("chatId") }, | ||||
|                     { text("settings") }, | ||||
|                     "DynamicAdminsCacheSettingsAPI" | ||||
|                 ).withMapper<IdChatIdentifier, AdminsCacheSettings, Identifier, String>( | ||||
|                     keyFromToTo = { chatId }, | ||||
|                 ).withMapper<IdChatIdentifier, AdminsCacheSettings, Long, String>( | ||||
|                     keyFromToTo = { chatId.long }, | ||||
|                     valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(this) }, | ||||
|                     keyToToFrom = { toChatId() }, | ||||
|                     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.tgbotapi.libraries.cache.media.common.MessagesSimpleCache | ||||
| 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 kotlinx.serialization.* | ||||
| import kotlinx.serialization.builtins.PairSerializer | ||||
| @@ -47,7 +47,7 @@ class SimpleKeyValueMessageContentCache<K>( | ||||
|  | ||||
| val chatIdToMessageIdentifierSerializer = PairSerializer( | ||||
|     ChatId.serializer(), | ||||
|     MessageIdentifier.serializer() | ||||
|     MessageId.serializer() | ||||
| ) | ||||
|  | ||||
| val messageContentSerializer = PolymorphicSerializer<MessageContent>(MessageContent::class) | ||||
| @@ -56,9 +56,9 @@ inline fun <K> KeyValueRepo<K, MessageContent>.asMessageContentCache() = SimpleK | ||||
|  | ||||
| inline fun KeyValueRepo<String, String>.asMessageContentCache( | ||||
|     serialFormatCreator: (SerializersModule) -> StringFormat = { Json { serializersModule = it } } | ||||
| ): StandardKeyValueRepo<Pair<ChatId, MessageIdentifier>, MessageContent> { | ||||
| ): StandardKeyValueRepo<Pair<ChatId, MessageId>, MessageContent> { | ||||
|     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(messageContentSerializer, this) }, | ||||
|         { serialFormat.decodeFromString(chatIdToMessageIdentifierSerializer, this) }, | ||||
| @@ -70,9 +70,9 @@ inline fun KeyValueRepo<String, String>.asMessageContentCache( | ||||
| @JsName("stringsKeyValueAsHexMessageContentCache") | ||||
| inline fun KeyValueRepo<String, String>.asMessageContentCache( | ||||
|     serialFormatCreator: (SerializersModule) -> BinaryFormat | ||||
| ): StandardKeyValueRepo<Pair<ChatId, MessageIdentifier>, MessageContent> { | ||||
| ): StandardKeyValueRepo<Pair<ChatId, MessageId>, MessageContent> { | ||||
|     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(messageContentSerializer, this) }, | ||||
|         { serialFormat.decodeFromHexString(chatIdToMessageIdentifierSerializer, this) }, | ||||
| @@ -84,9 +84,9 @@ inline fun KeyValueRepo<String, String>.asMessageContentCache( | ||||
| @JsName("bytesKeyValueAsMessageContentCache") | ||||
| inline fun KeyValueRepo<ByteArray, ByteArray>.asMessageContentCache( | ||||
|     serialFormatCreator: (SerializersModule) -> BinaryFormat | ||||
| ): StandardKeyValueRepo<Pair<ChatId, MessageIdentifier>, MessageContent> { | ||||
| ): StandardKeyValueRepo<Pair<ChatId, MessageId>, MessageContent> { | ||||
|     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(messageContentSerializer, this) }, | ||||
|         { serialFormat.decodeFromByteArray(chatIdToMessageIdentifierSerializer, this) }, | ||||
|   | ||||
| @@ -6,21 +6,21 @@ kotlin.incremental=true | ||||
| kotlin.incremental.js=true | ||||
|  | ||||
|  | ||||
| kotlin_version=1.8.21 | ||||
| kotlin_serialisation_core_version=1.5.1 | ||||
| kotlin_version=2.0.20 | ||||
| kotlin_serialisation_core_version=1.7.2 | ||||
|  | ||||
| github_release_plugin_version=2.4.1 | ||||
| github_release_plugin_version=2.5.2 | ||||
|  | ||||
| tgbotapi_version=8.0.0 | ||||
| micro_utils_version=0.19.1 | ||||
| exposed_version=0.41.1 | ||||
| plagubot_version=6.0.0 | ||||
| tgbotapi_version=18.2.0 | ||||
| micro_utils_version=0.22.2 | ||||
| exposed_version=0.54.0 | ||||
| plagubot_version=9.3.0 | ||||
|  | ||||
| # Dokka | ||||
|  | ||||
| dokka_version=1.8.10 | ||||
| dokka_version=1.9.20 | ||||
|  | ||||
| # Project data | ||||
|  | ||||
| group=dev.inmo | ||||
| version=0.12.0 | ||||
| version=0.24.0 | ||||
|   | ||||
							
								
								
									
										2
									
								
								gradle/wrapper/gradle-wrapper.properties
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										2
									
								
								gradle/wrapper/gradle-wrapper.properties
									
									
									
									
										vendored
									
									
								
							| @@ -1,5 +1,5 @@ | ||||
| distributionBase=GRADLE_USER_HOME | ||||
| distributionPath=wrapper/dists | ||||
| distributionUrl=https\://services.gradle.org/distributions/gradle-7.6.1-bin.zip | ||||
| distributionUrl=https\://services.gradle.org/distributions/gradle-8.9-bin.zip | ||||
| zipStoreBase=GRADLE_USER_HOME | ||||
| zipStorePath=wrapper/dists | ||||
|   | ||||
| @@ -7,7 +7,7 @@ kotlin { | ||||
|     jvm { | ||||
|         compilations.main { | ||||
|             kotlinOptions { | ||||
|                 jvmTarget = "1.8" | ||||
|                 jvmTarget = "17" | ||||
|             } | ||||
|         } | ||||
|     } | ||||
| @@ -37,13 +37,12 @@ kotlin { | ||||
|         jsTest { | ||||
|             dependencies { | ||||
|                 implementation kotlin('test-js') | ||||
|                 implementation kotlin('test-junit') | ||||
|             } | ||||
|         } | ||||
|     } | ||||
| } | ||||
|  | ||||
| java { | ||||
|     sourceCompatibility = JavaVersion.VERSION_1_8 | ||||
|     targetCompatibility = JavaVersion.VERSION_1_8 | ||||
|     sourceCompatibility = JavaVersion.VERSION_17 | ||||
|     targetCompatibility = JavaVersion.VERSION_17 | ||||
| } | ||||
|   | ||||
| @@ -1,7 +1,7 @@ | ||||
| apply plugin: 'maven-publish' | ||||
|  | ||||
| task javadocsJar(type: Jar) { | ||||
|     classifier = 'javadoc' | ||||
|     archiveClassifier = 'javadoc' | ||||
| } | ||||
|  | ||||
| publishing { | ||||
| @@ -50,18 +50,14 @@ publishing { | ||||
|              | ||||
|                 } | ||||
|             } | ||||
|             if (project.hasProperty('GITEA_TOKEN') || System.getenv('GITEA_TOKEN') != null) { | ||||
|             if ((project.hasProperty('INMONEXUS_USER') || System.getenv('INMONEXUS_USER') != null) && (project.hasProperty('INMONEXUS_PASSWORD') || System.getenv('INMONEXUS_PASSWORD') != null)) { | ||||
|                 maven { | ||||
|                     name = "Gitea" | ||||
|                     url = uri("https://git.inmo.dev/api/packages/InsanusMokrassar/maven") | ||||
|                     name = "InmoNexus" | ||||
|                     url = uri("https://nexus.inmo.dev/repository/maven-releases/") | ||||
|              | ||||
|                     credentials(HttpHeaderCredentials) { | ||||
|                         name = "Authorization" | ||||
|                         value = project.hasProperty('GITEA_TOKEN') ? project.property('GITEA_TOKEN') : System.getenv('GITEA_TOKEN') | ||||
|                     } | ||||
|              | ||||
|                     authentication { | ||||
|                         header(HttpHeaderAuthentication) | ||||
|                     credentials { | ||||
|                         username = project.hasProperty('INMONEXUS_USER') ? project.property('INMONEXUS_USER') : System.getenv('INMONEXUS_USER') | ||||
|                         password = project.hasProperty('INMONEXUS_PASSWORD') ? project.property('INMONEXUS_PASSWORD') : System.getenv('INMONEXUS_PASSWORD') | ||||
|                     } | ||||
|              | ||||
|                 } | ||||
| @@ -96,4 +92,27 @@ if (project.hasProperty("signing.gnupg.keyName")) { | ||||
|             dependsOn(it) | ||||
|         } | ||||
|     } | ||||
|  | ||||
|     // Workaround to make android sign operations depend on signing tasks | ||||
|     project.getTasks().withType(AbstractPublishToMaven.class).configureEach { | ||||
|         def signingTasks = project.getTasks().withType(Sign.class) | ||||
|         mustRunAfter(signingTasks) | ||||
|     } | ||||
|     // Workaround to make test tasks use sign | ||||
|     project.getTasks().withType(Sign.class).configureEach { signTask -> | ||||
|         def withoutSign = (signTask.name.startsWith("sign") ? signTask.name.minus("sign") : signTask.name) | ||||
|         def pubName = withoutSign.endsWith("Publication") ? withoutSign.substring(0, withoutSign.length() - "Publication".length()) : withoutSign | ||||
|         // These tasks only exist for native targets, hence findByName() to avoid trying to find them for other targets | ||||
|  | ||||
|         // Task ':linkDebugTest<platform>' uses this output of task ':sign<platform>Publication' without declaring an explicit or implicit dependency | ||||
|         def debugTestTask = tasks.findByName("linkDebugTest$pubName") | ||||
|         if (debugTestTask != null) { | ||||
|             signTask.mustRunAfter(debugTestTask) | ||||
|         } | ||||
|         // Task ':compileTestKotlin<platform>' uses this output of task ':sign<platform>Publication' without declaring an explicit or implicit dependency | ||||
|         def testTask = tasks.findByName("compileTestKotlin$pubName") | ||||
|         if (testTask != null) { | ||||
|             signTask.mustRunAfter(testTask) | ||||
|         } | ||||
|     } | ||||
| } | ||||
|   | ||||
| @@ -1 +1 @@ | ||||
| {"licenses":[{"id":"MIT","title":"MIT License","url":"https://opensource.org/licenses/MIT"}],"mavenConfig":{"name":"${project.name}","description":"${project.name}","url":"https://github.com/InsanusMokrassar/TelegramBotApiLibraries","vcsUrl":"https://github.com/InsanusMokrassar/TelegramBotApiLibraries.git","developers":[{"id":"InsanusMokrassar","name":"Ovsiannikov Aleksei","eMail":"ovsyannikov.alexey95@gmail.com"}],"repositories":[{"name":"GithubPackages","url":"https://maven.pkg.github.com/InsanusMokrassar/TelegramBotApiLibraries"},{"name":"Gitea","url":"https://git.inmo.dev/api/packages/InsanusMokrassar/maven","credsType":{"type":"dev.inmo.kmppscriptbuilder.core.models.MavenPublishingRepository.CredentialsType.HttpHeaderCredentials","headerName":"Authorization","headerValueProperty":"GITEA_TOKEN"}},{"name":"sonatype","url":"https://oss.sonatype.org/service/local/staging/deploy/maven2/"}],"gpgSigning":{"type":"dev.inmo.kmppscriptbuilder.core.models.GpgSigning.Optional"}}} | ||||
| {"licenses":[{"id":"MIT","title":"MIT License","url":"https://opensource.org/licenses/MIT"}],"mavenConfig":{"name":"${project.name}","description":"${project.name}","url":"https://github.com/InsanusMokrassar/TelegramBotApiLibraries","vcsUrl":"https://github.com/InsanusMokrassar/TelegramBotApiLibraries.git","developers":[{"id":"InsanusMokrassar","name":"Ovsiannikov Aleksei","eMail":"ovsyannikov.alexey95@gmail.com"}],"repositories":[{"name":"GithubPackages","url":"https://maven.pkg.github.com/InsanusMokrassar/TelegramBotApiLibraries"},{"name":"InmoNexus","url":"https://nexus.inmo.dev/repository/maven-releases/"},{"name":"sonatype","url":"https://oss.sonatype.org/service/local/staging/deploy/maven2/"}],"gpgSigning":{"type":"dev.inmo.kmppscriptbuilder.core.models.GpgSigning.Optional"}}} | ||||
| @@ -2,9 +2,12 @@ package dev.inmo.tgbotapi.libraries.resender | ||||
|  | ||||
| import dev.inmo.tgbotapi.types.FullChatIdentifierSerializer | ||||
| import dev.inmo.tgbotapi.types.IdChatIdentifier | ||||
| import dev.inmo.tgbotapi.types.MediaGroupId | ||||
| 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.PossiblyMediaGroupMessage | ||||
| import dev.inmo.tgbotapi.types.message.content.MediaGroupContent | ||||
| import kotlinx.serialization.Serializable | ||||
|  | ||||
| @Serializable | ||||
| @@ -12,8 +15,21 @@ data class MessageMetaInfo( | ||||
|     @Serializable(FullChatIdentifierSerializer::class) | ||||
|     val chatId: IdChatIdentifier, | ||||
|     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( | ||||
|     message: Message | ||||
|   | ||||
| @@ -1,8 +1,11 @@ | ||||
| package dev.inmo.tgbotapi.libraries.resender | ||||
|  | ||||
| import dev.inmo.micro_utils.common.applyDiff | ||||
| import dev.inmo.tgbotapi.bot.TelegramBot | ||||
| 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.CopyMessages | ||||
| import dev.inmo.tgbotapi.requests.send.media.SendMediaGroup | ||||
| import dev.inmo.tgbotapi.types.ChatIdentifier | ||||
| import dev.inmo.tgbotapi.types.IdChatIdentifier | ||||
| @@ -80,13 +83,13 @@ class MessagesResender( | ||||
|                 else -> { | ||||
|                     val resultContents = contents.mapNotNull { | ||||
|                         it to ( | ||||
|                             bot.execute( | ||||
|                                 ForwardMessage( | ||||
|                                     toChatId = cacheChatId, | ||||
|                                     fromChatId = it.chatId, | ||||
|                                     messageId = it.messageId | ||||
|                                 ) | ||||
|                             ) as? ContentMessage<*> ?: return@mapNotNull null) | ||||
|                                 bot.execute( | ||||
|                                     ForwardMessage( | ||||
|                                         toChatId = cacheChatId, | ||||
|                                         fromChatId = it.chatId, | ||||
|                                         messageId = it.messageId | ||||
|                                     ) | ||||
|                                 ) as? ContentMessage<*> ?: return@mapNotNull null) | ||||
|                     }.mapNotNull { (src, forwardedMessage) -> | ||||
|                         val forwardedMessageAsMediaPartMessage = forwardedMessage.takeIf { | ||||
|                             it.content is MediaGroupPartContent | ||||
|   | ||||
		Reference in New Issue
	
	Block a user