mirror of
				https://github.com/InsanusMokrassar/TelegramBotApiLibraries.git
				synced 2025-10-31 12:10:15 +00:00 
			
		
		
		
	Compare commits
	
		
			97 Commits
		
	
	
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| 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 | |||
| bd4e3d2380 | |||
| d77e08631c | |||
| 90e063a47a | |||
| a988117037 | |||
| 50d8511db5 | |||
| cf5b02057d | |||
| 64305c9393 | |||
| b4107cff26 | |||
| 23d68c9aa5 | |||
| 735e23cadb | |||
| 59b32f9b9a | |||
| b8601d4c90 | |||
| 240ee3de6f | |||
| 300ff6514b | |||
| ce85622876 | |||
| bd9e6045a3 | |||
| e8a41d97e8 | |||
| e2e329a757 | |||
| c69dd61eb9 | |||
| cf13bfadde | |||
| 6e33649e6c | |||
| 40dd4b166f | |||
| 95adaef36f | |||
| 8386690090 | |||
| 0f02910766 | |||
| 46b694c72b | |||
| 1bf9a1570f | |||
| f24825bcbc | |||
| 5b560118c0 | |||
| c27b5647d7 | |||
| 6a5cd2f469 | |||
| 69c819162d | |||
| 7a603c21b8 | |||
| bfebd1de50 | |||
| cbbe283305 | |||
| a2dab361cf | |||
| ac89551ac4 | |||
| 0b0d1e4ea5 | |||
| 9b056656e3 | |||
| 9023cc5acc | |||
| 617b8091db | |||
| 88a89ff1e7 | |||
| c211002ac1 | |||
| 50f592f52c | |||
| efeb15b971 | |||
| d33ca67c7c | |||
| f59ff6dd3c | |||
| 8f643a7d5b | |||
| 980badd275 | |||
| a2e65f7b24 | |||
| f86cef7118 | |||
| 2278572cb2 | |||
| 3ce3b03f02 | |||
| 48b5f88359 | |||
| 0bb7257ec3 | |||
| 2b503786ca | |||
| 4622359592 | |||
| 0fa045f6a9 | |||
| 7759d5faa5 | |||
| d6896c63b5 | |||
| 262c496d45 | 
							
								
								
									
										5
									
								
								.github/workflows/commit-publish.yml
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										5
									
								
								.github/workflows/commit-publish.yml
									
									
									
									
										vendored
									
									
								
							| @@ -7,10 +7,7 @@ jobs: | |||||||
|       - uses: actions/checkout@v2 |       - uses: actions/checkout@v2 | ||||||
|       - uses: actions/setup-java@v1 |       - uses: actions/setup-java@v1 | ||||||
|         with: |         with: | ||||||
|           java-version: 11 |           java-version: 17 | ||||||
|       - name: Fix android 32.0.0 dx |  | ||||||
|         continue-on-error: true |  | ||||||
|         run: cd /usr/local/lib/android/sdk/build-tools/32.0.0/ && mv d8 dx && cd lib  && mv d8.jar dx.jar |  | ||||||
|       - name: Update version |       - name: Update version | ||||||
|         run: | |         run: | | ||||||
|           branch="`echo "${{ github.ref }}" | grep -o "[^/]*$"`" |           branch="`echo "${{ github.ref }}" | grep -o "[^/]*$"`" | ||||||
|   | |||||||
| @@ -18,6 +18,7 @@ allprojects { | |||||||
|         mavenLocal() |         mavenLocal() | ||||||
|         mavenCentral() |         mavenCentral() | ||||||
|         google() |         google() | ||||||
|  |         maven { url "https://nexus.inmo.dev/repository/maven-releases/" } | ||||||
|     } |     } | ||||||
| } | } | ||||||
|  |  | ||||||
|   | |||||||
| @@ -1,8 +1,9 @@ | |||||||
| package dev.inmo.tgbotapi.libraries.cache.admins | package dev.inmo.tgbotapi.libraries.cache.admins | ||||||
|  |  | ||||||
| import com.soywiz.klock.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 | ||||||
|  |  | ||||||
|   | |||||||
| @@ -1,6 +1,6 @@ | |||||||
| package dev.inmo.tgbotapi.libraries.cache.admins | package dev.inmo.tgbotapi.libraries.cache.admins | ||||||
|  |  | ||||||
| import com.soywiz.klock.DateTime | import korlibs.time.DateTime | ||||||
| import dev.inmo.tgbotapi.bot.TelegramBot | import dev.inmo.tgbotapi.bot.TelegramBot | ||||||
| import dev.inmo.tgbotapi.extensions.api.bot.getMe | import dev.inmo.tgbotapi.extensions.api.bot.getMe | ||||||
| import dev.inmo.tgbotapi.extensions.api.chat.members.getChatMember | import dev.inmo.tgbotapi.extensions.api.chat.members.getChatMember | ||||||
| @@ -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 { | ||||||
|   | |||||||
| @@ -1,6 +1,6 @@ | |||||||
| package dev.inmo.tgbotapi.libraries.cache.admins.micro_utils | package dev.inmo.tgbotapi.libraries.cache.admins.micro_utils | ||||||
|  |  | ||||||
| import com.soywiz.klock.DateTime | import korlibs.time.DateTime | ||||||
| import dev.inmo.micro_utils.coroutines.* | import dev.inmo.micro_utils.coroutines.* | ||||||
| import dev.inmo.micro_utils.repos.* | import dev.inmo.micro_utils.repos.* | ||||||
| import dev.inmo.tgbotapi.libraries.cache.admins.DefaultAdminsCacheAPIRepo | import dev.inmo.tgbotapi.libraries.cache.admins.DefaultAdminsCacheAPIRepo | ||||||
|   | |||||||
| @@ -1,7 +1,7 @@ | |||||||
| package dev.inmo.tgbotapi.libraries.cache.media.common | package dev.inmo.tgbotapi.libraries.cache.media.common | ||||||
|  |  | ||||||
| import com.soywiz.klock.DateTime | import korlibs.time.DateTime | ||||||
| import com.soywiz.klock.milliseconds | import korlibs.time.milliseconds | ||||||
| import dev.inmo.tgbotapi.bot.TelegramBot | import dev.inmo.tgbotapi.bot.TelegramBot | ||||||
| import dev.inmo.tgbotapi.requests.DeleteMessage | import dev.inmo.tgbotapi.requests.DeleteMessage | ||||||
| import dev.inmo.tgbotapi.requests.abstracts.FileId | import dev.inmo.tgbotapi.requests.abstracts.FileId | ||||||
|   | |||||||
| @@ -4,25 +4,23 @@ org.gradle.parallel=true | |||||||
| kotlin.js.generate.externals=true | kotlin.js.generate.externals=true | ||||||
| kotlin.incremental=true | kotlin.incremental=true | ||||||
| kotlin.incremental.js=true | kotlin.incremental.js=true | ||||||
| android.useAndroidX=true |  | ||||||
| android.enableJetifier=true |  | ||||||
|  |  | ||||||
|  |  | ||||||
| kotlin_version=1.7.21 | kotlin_version=1.9.22 | ||||||
| kotlin_serialisation_core_version=1.4.1 | kotlin_serialisation_core_version=1.6.2 | ||||||
|  |  | ||||||
| github_release_plugin_version=2.4.1 | github_release_plugin_version=2.4.1 | ||||||
|  |  | ||||||
| tgbotapi_version=4.1.1 | tgbotapi_version=10.0.1 | ||||||
| micro_utils_version=0.14.2 | micro_utils_version=0.20.32 | ||||||
| exposed_version=0.41.1 | exposed_version=0.47.0 | ||||||
| plagubot_version=3.1.2 | plagubot_version=8.1.1 | ||||||
|  |  | ||||||
| # Dokka | # Dokka | ||||||
|  |  | ||||||
| dokka_version=1.7.20 | dokka_version=1.9.10 | ||||||
|  |  | ||||||
| # Project data | # Project data | ||||||
|  |  | ||||||
| group=dev.inmo | group=dev.inmo | ||||||
| version=0.6.2 | version=0.18.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-7.5.1-bin.zip | distributionUrl=https\://services.gradle.org/distributions/gradle-8.5-bin.zip | ||||||
| zipStoreBase=GRADLE_USER_HOME | zipStoreBase=GRADLE_USER_HOME | ||||||
| zipStorePath=wrapper/dists | zipStorePath=wrapper/dists | ||||||
|   | |||||||
| @@ -7,7 +7,7 @@ kotlin { | |||||||
|     jvm { |     jvm { | ||||||
|         compilations.main { |         compilations.main { | ||||||
|             kotlinOptions { |             kotlinOptions { | ||||||
|                 jvmTarget = "1.8" |                 jvmTarget = "17" | ||||||
|             } |             } | ||||||
|         } |         } | ||||||
|     } |     } | ||||||
| @@ -44,6 +44,6 @@ kotlin { | |||||||
| } | } | ||||||
|  |  | ||||||
| java { | java { | ||||||
|     sourceCompatibility = JavaVersion.VERSION_1_8 |     sourceCompatibility = JavaVersion.VERSION_17 | ||||||
|     targetCompatibility = JavaVersion.VERSION_1_8 |     targetCompatibility = JavaVersion.VERSION_17 | ||||||
| } | } | ||||||
|   | |||||||
| @@ -1,7 +1,7 @@ | |||||||
| apply plugin: 'maven-publish' | apply plugin: 'maven-publish' | ||||||
|  |  | ||||||
| task javadocsJar(type: Jar) { | task javadocsJar(type: Jar) { | ||||||
|     classifier = 'javadoc' |     archiveClassifier = 'javadoc' | ||||||
| } | } | ||||||
|  |  | ||||||
| publishing { | 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 { |                 maven { | ||||||
|                     name = "Gitea" |                     name = "InmoNexus" | ||||||
|                     url = uri("https://git.inmo.dev/api/packages/InsanusMokrassar/maven") |                     url = uri("https://nexus.inmo.dev/repository/maven-releases/") | ||||||
|              |              | ||||||
|                     credentials(HttpHeaderCredentials) { |                     credentials { | ||||||
|                         name = "Authorization" |                         username = project.hasProperty('INMONEXUS_USER') ? project.property('INMONEXUS_USER') : System.getenv('INMONEXUS_USER') | ||||||
|                         value = project.hasProperty('GITEA_TOKEN') ? project.property('GITEA_TOKEN') : System.getenv('GITEA_TOKEN') |                         password = project.hasProperty('INMONEXUS_PASSWORD') ? project.property('INMONEXUS_PASSWORD') : System.getenv('INMONEXUS_PASSWORD') | ||||||
|                     } |  | ||||||
|              |  | ||||||
|                     authentication { |  | ||||||
|                         header(HttpHeaderAuthentication) |  | ||||||
|                     } |                     } | ||||||
|              |              | ||||||
|                 } |                 } | ||||||
| @@ -96,4 +92,27 @@ if (project.hasProperty("signing.gnupg.keyName")) { | |||||||
|             dependsOn(it) |             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"}}} | ||||||
							
								
								
									
										17
									
								
								resender/build.gradle
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										17
									
								
								resender/build.gradle
									
									
									
									
									
										Normal file
									
								
							| @@ -0,0 +1,17 @@ | |||||||
|  | plugins { | ||||||
|  |     id "org.jetbrains.kotlin.multiplatform" | ||||||
|  |     id "org.jetbrains.kotlin.plugin.serialization" | ||||||
|  | } | ||||||
|  |  | ||||||
|  | apply from: "$mppJavaWithJsProjectPath" | ||||||
|  |  | ||||||
|  | kotlin { | ||||||
|  |     sourceSets { | ||||||
|  |         commonMain { | ||||||
|  |             dependencies { | ||||||
|  |                 api "dev.inmo:tgbotapi.core:$tgbotapi_version" | ||||||
|  |             } | ||||||
|  |         } | ||||||
|  |     } | ||||||
|  | } | ||||||
|  |  | ||||||
							
								
								
									
										35
									
								
								resender/src/commonMain/kotlin/MessageMetaInfo.kt
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										35
									
								
								resender/src/commonMain/kotlin/MessageMetaInfo.kt
									
									
									
									
									
										Normal file
									
								
							| @@ -0,0 +1,35 @@ | |||||||
|  | package dev.inmo.tgbotapi.libraries.resender | ||||||
|  |  | ||||||
|  | import dev.inmo.tgbotapi.types.FullChatIdentifierSerializer | ||||||
|  | import dev.inmo.tgbotapi.types.IdChatIdentifier | ||||||
|  | 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 | ||||||
|  | data class MessageMetaInfo( | ||||||
|  |     @Serializable(FullChatIdentifierSerializer::class) | ||||||
|  |     val chatId: IdChatIdentifier, | ||||||
|  |     val messageId: MessageId, | ||||||
|  |     val group: String? = 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 | ||||||
|  | ) = MessageMetaInfo(message.chat.id, message.messageId, (message as? PossiblyMediaGroupMessage<*>) ?.mediaGroupId) | ||||||
							
								
								
									
										82
									
								
								resender/src/commonMain/kotlin/MessagesResender.kt
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										82
									
								
								resender/src/commonMain/kotlin/MessagesResender.kt
									
									
									
									
									
										Normal file
									
								
							| @@ -0,0 +1,82 @@ | |||||||
|  | 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.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 | ||||||
|  | import dev.inmo.tgbotapi.types.mediaCountInMediaGroup | ||||||
|  | import dev.inmo.tgbotapi.types.message.abstracts.ContentMessage | ||||||
|  | import dev.inmo.tgbotapi.types.message.content.MediaGroupPartContent | ||||||
|  |  | ||||||
|  | class MessagesResender( | ||||||
|  |     private val bot: TelegramBot, | ||||||
|  |     private val cacheChatId: ChatIdentifier | ||||||
|  | ) { | ||||||
|  |     suspend fun resend( | ||||||
|  |         targetChatId: IdChatIdentifier, | ||||||
|  |         messagesInfo: List<MessageMetaInfo>, | ||||||
|  |         onBetweenMessages: suspend (sent: List<MessageMetaInfo>, toBeSent: List<MessageMetaInfo>) -> Unit | ||||||
|  |     ): List<Pair<MessageMetaInfo, MessageMetaInfo>> { | ||||||
|  |         val currentGroup = mutableListOf<MessageMetaInfo>() | ||||||
|  |         suspend fun makeCopy(): List<Pair<MessageMetaInfo, MessageMetaInfo>> { | ||||||
|  |             currentGroup.sortBy { it.messageId } | ||||||
|  |             while (currentGroup.isNotEmpty()) { | ||||||
|  |                 return runCatching { | ||||||
|  |                     bot.execute( | ||||||
|  |                         CopyMessages( | ||||||
|  |                             toChatId = targetChatId, | ||||||
|  |                             fromChatId = currentGroup.firstOrNull() ?.chatId ?: return emptyList(), | ||||||
|  |                             messageIds = currentGroup.map { it.messageId } | ||||||
|  |                         ) | ||||||
|  |                     ).mapIndexed { i, newMessageId -> | ||||||
|  |                         currentGroup[i] to MessageMetaInfo(targetChatId, newMessageId) | ||||||
|  |                     }.also { | ||||||
|  |                         currentGroup.clear() | ||||||
|  |                     } | ||||||
|  |                 }.getOrElse { | ||||||
|  |                     currentGroup.applyDiff( | ||||||
|  |                         currentGroup.filter { | ||||||
|  |                             runCatching { | ||||||
|  |                                 bot.execute( | ||||||
|  |                                     ForwardMessage( | ||||||
|  |                                         toChatId = cacheChatId, | ||||||
|  |                                         fromChatId = it.chatId, | ||||||
|  |                                         messageId = it.messageId | ||||||
|  |                                     ) | ||||||
|  |                                 ) | ||||||
|  |                             }.isSuccess | ||||||
|  |                         } | ||||||
|  |                     ) | ||||||
|  |                     null | ||||||
|  |                 } ?: continue | ||||||
|  |             } | ||||||
|  |             return emptyList() | ||||||
|  |         } | ||||||
|  |  | ||||||
|  |         val copied = mutableListOf<Pair<MessageMetaInfo, MessageMetaInfo>>() | ||||||
|  |         for (content in messagesInfo) { | ||||||
|  |             when { | ||||||
|  |                 currentGroup.isEmpty() || | ||||||
|  |                 currentGroup.first().chatId == content.chatId -> currentGroup.add(content) | ||||||
|  |                 else -> { | ||||||
|  |                     onBetweenMessages(copied.map { it.first }, currentGroup.toList()) | ||||||
|  |                     copied.addAll(makeCopy()) | ||||||
|  |                 } | ||||||
|  |             } | ||||||
|  |         } | ||||||
|  |         if (currentGroup.isNotEmpty()) { | ||||||
|  |             onBetweenMessages(copied.map { it.first }, currentGroup.toList()) | ||||||
|  |             copied.addAll(makeCopy()) | ||||||
|  |         } | ||||||
|  |         return copied.toList() | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     suspend fun resend( | ||||||
|  |         targetChatId: IdChatIdentifier, | ||||||
|  |         messagesInfo: List<MessageMetaInfo> | ||||||
|  |     ): List<Pair<MessageMetaInfo, MessageMetaInfo>> = resend(targetChatId, messagesInfo) { _, _ -> } | ||||||
|  | } | ||||||
| @@ -7,6 +7,8 @@ String[] includes = [ | |||||||
|  |  | ||||||
|     ":cache:content:common", |     ":cache:content:common", | ||||||
|     ":cache:content:micro_utils", |     ":cache:content:micro_utils", | ||||||
|  |  | ||||||
|  |     ":resender", | ||||||
| ] | ] | ||||||
|  |  | ||||||
|  |  | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user