mirror of
				https://github.com/InsanusMokrassar/TelegramBotApiLibraries.git
				synced 2025-10-31 12:10:15 +00:00 
			
		
		
		
	Compare commits
	
		
			44 Commits
		
	
	
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| 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 | 
							
								
								
									
										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/checkout@v2 | ||||||
|       - uses: actions/setup-java@v1 |       - uses: actions/setup-java@v1 | ||||||
|         with: |         with: | ||||||
|           java-version: 11 |           java-version: 17 | ||||||
|       - name: Update version |       - name: Update version | ||||||
|         run: | |         run: | | ||||||
|           branch="`echo "${{ github.ref }}" | grep -o "[^/]*$"`" |           branch="`echo "${{ github.ref }}" | grep -o "[^/]*$"`" | ||||||
|   | |||||||
| @@ -1,6 +1,6 @@ | |||||||
| 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 kotlinx.coroutines.flow.SharedFlow | import kotlinx.coroutines.flow.SharedFlow | ||||||
|   | |||||||
| @@ -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 | ||||||
|   | |||||||
| @@ -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 | ||||||
|   | |||||||
| @@ -6,21 +6,21 @@ kotlin.incremental=true | |||||||
| kotlin.incremental.js=true | kotlin.incremental.js=true | ||||||
|  |  | ||||||
|  |  | ||||||
| kotlin_version=1.8.10 | kotlin_version=1.9.21 | ||||||
| kotlin_serialisation_core_version=1.5.0 | kotlin_serialisation_core_version=1.6.1 | ||||||
|  |  | ||||||
| github_release_plugin_version=2.4.1 | github_release_plugin_version=2.4.1 | ||||||
|  |  | ||||||
| tgbotapi_version=6.1.0 | tgbotapi_version=9.4.1 | ||||||
| micro_utils_version=0.17.3 | micro_utils_version=0.20.15 | ||||||
| exposed_version=0.41.1 | exposed_version=0.44.1 | ||||||
| plagubot_version=4.1.0 | plagubot_version=7.4.0 | ||||||
|  |  | ||||||
| # Dokka | # Dokka | ||||||
|  |  | ||||||
| dokka_version=1.8.10 | dokka_version=1.9.10 | ||||||
|  |  | ||||||
| # Project data | # Project data | ||||||
|  |  | ||||||
| group=dev.inmo | group=dev.inmo | ||||||
| version=0.9.4 | version=0.17.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-7.6-bin.zip | distributionUrl=https\://services.gradle.org/distributions/gradle-8.4-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 { | ||||||
| @@ -96,4 +96,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) | ||||||
|  |         } | ||||||
|  |     } | ||||||
| } | } | ||||||
|   | |||||||
| @@ -16,7 +16,8 @@ class MessagesResender( | |||||||
| ) { | ) { | ||||||
|     suspend fun resend( |     suspend fun resend( | ||||||
|         targetChatId: IdChatIdentifier, |         targetChatId: IdChatIdentifier, | ||||||
|         messagesInfo: List<MessageMetaInfo> |         messagesInfo: List<MessageMetaInfo>, | ||||||
|  |         onBetweenMessages: suspend (sent: List<MessageMetaInfo>, toBeSent: List<MessageMetaInfo>) -> Unit | ||||||
|     ): List<Pair<MessageMetaInfo, MessageMetaInfo>> { |     ): List<Pair<MessageMetaInfo, MessageMetaInfo>> { | ||||||
|         val messagesWithOrders = messagesInfo.mapIndexed { i, messageInfo -> messageInfo to i }.toMap() |         val messagesWithOrders = messagesInfo.mapIndexed { i, messageInfo -> messageInfo to i }.toMap() | ||||||
|         val ordersWithMessagesGroups = messagesInfo.groupBy { it.group }.flatMap { (group, list) -> |         val ordersWithMessagesGroups = messagesInfo.groupBy { it.group }.flatMap { (group, list) -> | ||||||
| @@ -29,9 +30,14 @@ class MessagesResender( | |||||||
|             } |             } | ||||||
|         }.sortedBy { it.first } |         }.sortedBy { it.first } | ||||||
|  |  | ||||||
|  |         val sent = mutableListOf<MessageMetaInfo>() | ||||||
|  |         val leftToSend = ordersWithMessagesGroups.map { it.second }.toMutableList() | ||||||
|  |  | ||||||
|         return ordersWithMessagesGroups.flatMap { (_, contents) -> |         return ordersWithMessagesGroups.flatMap { (_, contents) -> | ||||||
|             val sourceMessagesToSentMessages = mutableListOf<Pair<MessageMetaInfo, MessageMetaInfo>>() |             val sourceMessagesToSentMessages = mutableListOf<Pair<MessageMetaInfo, MessageMetaInfo>>() | ||||||
|  |  | ||||||
|  |             onBetweenMessages(sent.toList(), leftToSend.flatten()) | ||||||
|  |  | ||||||
|             when { |             when { | ||||||
|                 contents.size == 1 -> { |                 contents.size == 1 -> { | ||||||
|                     val messageInfo = contents.first() |                     val messageInfo = contents.first() | ||||||
| @@ -137,8 +143,15 @@ class MessagesResender( | |||||||
|                 } |                 } | ||||||
|             } |             } | ||||||
|  |  | ||||||
|  |             leftToSend.takeIf { it.isNotEmpty() } ?.removeAt(0) ?.also { | ||||||
|  |                 sent.addAll(it) | ||||||
|  |             } | ||||||
|             sourceMessagesToSentMessages.toList() |             sourceMessagesToSentMessages.toList() | ||||||
|         } |         } | ||||||
|  |  | ||||||
|     } |     } | ||||||
|  |  | ||||||
|  |     suspend fun resend( | ||||||
|  |         targetChatId: IdChatIdentifier, | ||||||
|  |         messagesInfo: List<MessageMetaInfo> | ||||||
|  |     ): List<Pair<MessageMetaInfo, MessageMetaInfo>> = resend(targetChatId, messagesInfo) { _, _ -> } | ||||||
| } | } | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user