mirror of
				https://github.com/InsanusMokrassar/TelegramBotApiLibraries.git
				synced 2025-10-31 04:02:50 +00:00 
			
		
		
		
	Compare commits
	
		
			31 Commits
		
	
	
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| 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 | 
							
								
								
									
										3
									
								
								.github/workflows/commit-publish.yml
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										3
									
								
								.github/workflows/commit-publish.yml
									
									
									
									
										vendored
									
									
								
							| @@ -8,9 +8,6 @@ jobs: | |||||||
|       - uses: actions/setup-java@v1 |       - uses: actions/setup-java@v1 | ||||||
|         with: |         with: | ||||||
|           java-version: 11 |           java-version: 11 | ||||||
|       - 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 "[^/]*$"`" | ||||||
|   | |||||||
| @@ -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.22 | kotlin_version=1.8.21 | ||||||
| kotlin_serialisation_core_version=1.4.1 | kotlin_serialisation_core_version=1.5.0 | ||||||
|  |  | ||||||
| github_release_plugin_version=2.4.1 | github_release_plugin_version=2.4.1 | ||||||
|  |  | ||||||
| tgbotapi_version=5.1.0 | tgbotapi_version=7.1.2 | ||||||
| micro_utils_version=0.16.8 | micro_utils_version=0.18.1 | ||||||
| exposed_version=0.41.1 | exposed_version=0.41.1 | ||||||
| plagubot_version=3.4.0 | plagubot_version=5.1.2 | ||||||
|  |  | ||||||
| # Dokka | # Dokka | ||||||
|  |  | ||||||
| dokka_version=1.7.20 | dokka_version=1.8.10 | ||||||
|  |  | ||||||
| # Project data | # Project data | ||||||
|  |  | ||||||
| group=dev.inmo | group=dev.inmo | ||||||
| version=0.8.0 | version=0.11.2 | ||||||
|   | |||||||
							
								
								
									
										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-7.6.1-bin.zip | ||||||
| zipStoreBase=GRADLE_USER_HOME | zipStoreBase=GRADLE_USER_HOME | ||||||
| zipStorePath=wrapper/dists | zipStorePath=wrapper/dists | ||||||
|   | |||||||
| @@ -1,5 +1,6 @@ | |||||||
| package dev.inmo.tgbotapi.libraries.resender | package dev.inmo.tgbotapi.libraries.resender | ||||||
|  |  | ||||||
|  | import dev.inmo.tgbotapi.types.FullChatIdentifierSerializer | ||||||
| import dev.inmo.tgbotapi.types.IdChatIdentifier | import dev.inmo.tgbotapi.types.IdChatIdentifier | ||||||
| import dev.inmo.tgbotapi.types.MessageId | import dev.inmo.tgbotapi.types.MessageId | ||||||
| import dev.inmo.tgbotapi.types.message.abstracts.Message | import dev.inmo.tgbotapi.types.message.abstracts.Message | ||||||
| @@ -8,6 +9,7 @@ import kotlinx.serialization.Serializable | |||||||
|  |  | ||||||
| @Serializable | @Serializable | ||||||
| data class MessageMetaInfo( | data class MessageMetaInfo( | ||||||
|  |     @Serializable(FullChatIdentifierSerializer::class) | ||||||
|     val chatId: IdChatIdentifier, |     val chatId: IdChatIdentifier, | ||||||
|     val messageId: MessageId, |     val messageId: MessageId, | ||||||
|     val group: String? = null |     val group: String? = null | ||||||
|   | |||||||
| @@ -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() | ||||||
| @@ -68,7 +74,7 @@ class MessagesResender( | |||||||
|                             ) |                             ) | ||||||
|                         } |                         } | ||||||
|                     }.getOrNull() ?.let { |                     }.getOrNull() ?.let { | ||||||
|                         messageInfo to it |                         sourceMessagesToSentMessages.add(messageInfo to it) | ||||||
|                     } |                     } | ||||||
|                 } |                 } | ||||||
|                 else -> { |                 else -> { | ||||||
| @@ -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