mirror of
				https://github.com/InsanusMokrassar/TelegramBotApiLibraries.git
				synced 2025-10-29 11:10:20 +00:00 
			
		
		
		
	Compare commits
	
		
			84 Commits
		
	
	
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| 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 | |||
| 17072092ae | |||
| 78c44a2c61 | |||
| 0263fe0862 | |||
| 3baccc6c12 | |||
| 87bd39544d | |||
| 4bb1f54ddb | |||
| a4662b084a | |||
| 53fd94f094 | |||
| 2b288c43c0 | |||
| 842dcbf4b6 | |||
| 653d17827a | |||
| e4a21fe293 | |||
| 7b75828b2e | |||
| e8cb9556db | |||
| d118a3d060 | |||
| 62fb8854b9 | |||
| 7163f7d64a | |||
| 8a6925e95c | |||
| fd275ddacf | 
							
								
								
									
										3
									
								
								.github/workflows/commit-publish.yml
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										3
									
								
								.github/workflows/commit-publish.yml
									
									
									
									
										vendored
									
									
								
							| @@ -8,9 +8,6 @@ jobs: | ||||
|       - uses: actions/setup-java@v1 | ||||
|         with: | ||||
|           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 | ||||
|         run: | | ||||
|           branch="`echo "${{ github.ref }}" | grep -o "[^/]*$"`" | ||||
|   | ||||
| @@ -7,10 +7,8 @@ buildscript { | ||||
|     } | ||||
|  | ||||
|     dependencies { | ||||
|         classpath 'com.android.tools.build:gradle:7.0.4' | ||||
|         classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version" | ||||
|         classpath "org.jetbrains.kotlin:kotlin-serialization:$kotlin_version" | ||||
|         classpath "com.getkeepsafe.dexcount:dexcount-gradle-plugin:$dexcount_version" | ||||
|         classpath "org.jetbrains.dokka:dokka-gradle-plugin:$dokka_version" | ||||
|     } | ||||
| } | ||||
| @@ -20,6 +18,7 @@ allprojects { | ||||
|         mavenLocal() | ||||
|         mavenCentral() | ||||
|         google() | ||||
|         maven { url "https://git.inmo.dev/api/packages/InsanusMokrassar/maven" } | ||||
|     } | ||||
| } | ||||
|  | ||||
|   | ||||
							
								
								
									
										3
									
								
								cache/admins/common/build.gradle
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										3
									
								
								cache/admins/common/build.gradle
									
									
									
									
										vendored
									
									
								
							| @@ -1,10 +1,9 @@ | ||||
| plugins { | ||||
|     id "org.jetbrains.kotlin.multiplatform" | ||||
|     id "org.jetbrains.kotlin.plugin.serialization" | ||||
|     id "com.android.library" | ||||
| } | ||||
|  | ||||
| apply from: "$mppProjectWithSerializationPresetPath" | ||||
| apply from: "$mppJavaWithJsProjectPath" | ||||
|  | ||||
| kotlin { | ||||
|     sourceSets { | ||||
|   | ||||
| @@ -7,8 +7,8 @@ import dev.inmo.tgbotapi.types.message.abstracts.GroupContentMessage | ||||
| import dev.inmo.tgbotapi.types.message.abstracts.Message | ||||
|  | ||||
| interface AdminsCacheAPI { | ||||
|     suspend fun getChatAdmins(chatId: ChatId): List<AdministratorChatMember>? | ||||
|     suspend fun isAdmin(chatId: ChatId, userId: UserId): Boolean = getChatAdmins(chatId) ?.any { | ||||
|     suspend fun getChatAdmins(chatId: IdChatIdentifier): List<AdministratorChatMember>? | ||||
|     suspend fun isAdmin(chatId: IdChatIdentifier, userId: UserId): Boolean = getChatAdmins(chatId) ?.any { | ||||
|         it.user.id == userId | ||||
|     } == true | ||||
|     suspend fun sentByAdmin(groupContentMessage: GroupContentMessage<*>): Boolean | ||||
|   | ||||
| @@ -1,7 +1,7 @@ | ||||
| package dev.inmo.tgbotapi.libraries.cache.admins | ||||
|  | ||||
| import com.soywiz.klock.minutes | ||||
| import dev.inmo.tgbotapi.types.ChatId | ||||
| import korlibs.time.minutes | ||||
| import dev.inmo.tgbotapi.types.IdChatIdentifier | ||||
| import dev.inmo.tgbotapi.types.Seconds | ||||
| import kotlinx.coroutines.flow.SharedFlow | ||||
| import kotlinx.serialization.Serializable | ||||
| @@ -23,22 +23,22 @@ data class AdminsCacheSettings( | ||||
| } | ||||
|  | ||||
| interface AdminsCacheSettingsAPI { | ||||
|     suspend fun getChatSettings(chatId: ChatId): AdminsCacheSettings? | ||||
|     suspend fun getChatSettings(chatId: IdChatIdentifier): AdminsCacheSettings? | ||||
| } | ||||
|  | ||||
| interface MutableAdminsCacheSettingsAPI : AdminsCacheSettingsAPI { | ||||
|     val chatSettingsUpdatedFlow: SharedFlow<Pair<ChatId, AdminsCacheSettings>> | ||||
|     val chatSettingsUpdatedFlow: SharedFlow<Pair<IdChatIdentifier, AdminsCacheSettings>> | ||||
|  | ||||
|     suspend fun setChatSettings(chatId: ChatId, settings: AdminsCacheSettings) | ||||
|     suspend fun setChatSettings(chatId: IdChatIdentifier, settings: AdminsCacheSettings) | ||||
| } | ||||
|  | ||||
| fun AdminsCacheSettingsAPI.asMutable(): MutableAdminsCacheSettingsAPI? = this as? MutableAdminsCacheSettingsAPI | ||||
|  | ||||
| @Serializable | ||||
| class StaticAdminsCacheSettingsAPI( | ||||
|     private val settings: Map<ChatId, AdminsCacheSettings> | ||||
|     private val settings: Map<IdChatIdentifier, AdminsCacheSettings> | ||||
| ) : AdminsCacheSettingsAPI { | ||||
|     override suspend fun getChatSettings(chatId: ChatId): AdminsCacheSettings? = settings[chatId] | ||||
|     override suspend fun getChatSettings(chatId: IdChatIdentifier): AdminsCacheSettings? = settings[chatId] | ||||
| } | ||||
|  | ||||
|  | ||||
|   | ||||
| @@ -7,7 +7,7 @@ import dev.inmo.tgbotapi.extensions.behaviour_builder.triggers_handling.onChatMe | ||||
| import dev.inmo.tgbotapi.extensions.behaviour_builder.utils.SimpleFilter | ||||
| import dev.inmo.tgbotapi.extensions.behaviour_builder.utils.marker_factories.ByChatChatMemberUpdatedMarkerFactory | ||||
| import dev.inmo.tgbotapi.extensions.behaviour_builder.utils.marker_factories.MarkerFactory | ||||
| import dev.inmo.tgbotapi.types.ChatId | ||||
| import dev.inmo.tgbotapi.types.IdChatIdentifier | ||||
| import dev.inmo.tgbotapi.types.chat.member.AdministratorChatMember | ||||
| import dev.inmo.tgbotapi.types.chat.member.ChatMemberUpdated | ||||
| import dev.inmo.tgbotapi.types.update.abstracts.Update | ||||
| @@ -35,7 +35,7 @@ suspend fun BehaviourContext.activateAdminsChangesListening( | ||||
|  | ||||
| suspend fun BehaviourContext.activateAdminsChangesListening( | ||||
|     repo: DefaultAdminsCacheAPIRepo, | ||||
|     allowedChats: List<ChatId> | ||||
|     allowedChats: List<IdChatIdentifier> | ||||
| ) = activateAdminsChangesListening( | ||||
|     repo, | ||||
|     { | ||||
|   | ||||
| @@ -2,19 +2,19 @@ package dev.inmo.tgbotapi.libraries.cache.admins | ||||
|  | ||||
| import dev.inmo.tgbotapi.abstracts.FromUser | ||||
| import dev.inmo.tgbotapi.extensions.behaviour_builder.utils.SimpleFilter | ||||
| import dev.inmo.tgbotapi.types.ChatId | ||||
| import dev.inmo.tgbotapi.types.IdChatIdentifier | ||||
| import dev.inmo.tgbotapi.types.UserId | ||||
| import dev.inmo.tgbotapi.types.message.abstracts.Message | ||||
|  | ||||
| fun AdminsChecker( | ||||
|     adminsCacheAPI: AdminsCacheAPI | ||||
| ): SimpleFilter<Pair<ChatId, UserId>> = SimpleFilter { | ||||
| ): SimpleFilter<Pair<IdChatIdentifier, UserId>> = SimpleFilter { | ||||
|     adminsCacheAPI.isAdmin(it.first, it.second) | ||||
| } | ||||
|  | ||||
| fun <T> AdminsChecker( | ||||
|     adminsCacheAPI: AdminsCacheAPI, | ||||
|     mapper: (T) -> Pair<ChatId, UserId> | ||||
|     mapper: (T) -> Pair<IdChatIdentifier, UserId> | ||||
| ): SimpleFilter<T> { | ||||
|     val baseChecker = AdminsChecker(adminsCacheAPI) | ||||
|  | ||||
| @@ -31,7 +31,7 @@ fun MessageAdminsChecker( | ||||
|  | ||||
| fun AdminsChecker( | ||||
|     adminsCacheAPI: AdminsCacheAPI, | ||||
|     chatId: ChatId | ||||
|     chatId: IdChatIdentifier | ||||
| ) = SimpleFilter<FromUser> { | ||||
|     adminsCacheAPI.isAdmin(chatId, it.from.id) | ||||
| } | ||||
|   | ||||
| @@ -1,6 +1,6 @@ | ||||
| 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.extensions.api.bot.getMe | ||||
| import dev.inmo.tgbotapi.extensions.api.chat.members.getChatMember | ||||
| @@ -11,9 +11,9 @@ import dev.inmo.tgbotapi.types.message.abstracts.* | ||||
| import kotlinx.serialization.Serializable | ||||
|  | ||||
| interface DefaultAdminsCacheAPIRepo { | ||||
|     suspend fun getChatAdmins(chatId: ChatId): List<AdministratorChatMember>? | ||||
|     suspend fun setChatAdmins(chatId: ChatId, chatMembers: List<AdministratorChatMember>) | ||||
|     suspend fun lastUpdate(chatId: ChatId): DateTime? | ||||
|     suspend fun getChatAdmins(chatId: IdChatIdentifier): List<AdministratorChatMember>? | ||||
|     suspend fun setChatAdmins(chatId: IdChatIdentifier, chatMembers: List<AdministratorChatMember>) | ||||
|     suspend fun lastUpdate(chatId: IdChatIdentifier): DateTime? | ||||
| } | ||||
|  | ||||
| @Serializable | ||||
| @@ -29,7 +29,7 @@ class DefaultAdminsCacheAPI( | ||||
|         bot.getMe().also { botInfo = it } | ||||
|     } | ||||
|  | ||||
|     override suspend fun getChatAdmins(chatId: ChatId): List<AdministratorChatMember>? { | ||||
|     override suspend fun getChatAdmins(chatId: IdChatIdentifier): List<AdministratorChatMember>? { | ||||
|         val settings = settingsAPI.getChatSettings(chatId) | ||||
|         val lastUpdate = repo.lastUpdate(chatId) | ||||
|         return when { | ||||
| @@ -42,7 +42,7 @@ class DefaultAdminsCacheAPI( | ||||
|         } | ||||
|     } | ||||
|  | ||||
|     override suspend fun isAdmin(chatId: ChatId, userId: UserId): Boolean { | ||||
|     override suspend fun isAdmin(chatId: IdChatIdentifier, userId: UserId): Boolean { | ||||
|         val settings = settingsAPI.getChatSettings(chatId) | ||||
|         val lastUpdate = repo.lastUpdate(chatId) | ||||
|         return when { | ||||
|   | ||||
| @@ -1,6 +1,6 @@ | ||||
| package dev.inmo.tgbotapi.libraries.cache.admins | ||||
|  | ||||
| import dev.inmo.tgbotapi.types.ChatId | ||||
| import dev.inmo.tgbotapi.types.IdChatIdentifier | ||||
| import dev.inmo.tgbotapi.types.UserId | ||||
| import dev.inmo.tgbotapi.types.message.abstracts.* | ||||
|  | ||||
| @@ -13,7 +13,7 @@ suspend inline fun AdminsCacheAPI.isAdmin(message: Message) = when (message) { | ||||
| suspend inline fun AdminsCacheAPI.verifyMessageFromAdmin(message: Message) = isAdmin(message) | ||||
|  | ||||
| suspend inline fun <R : Any> AdminsCacheAPI.doIfAdmin( | ||||
|     chatId: ChatId, | ||||
|     chatId: IdChatIdentifier, | ||||
|     userId: UserId, | ||||
|     block: () -> R | ||||
| ) = if(isAdmin(chatId, userId)) { | ||||
|   | ||||
| @@ -3,12 +3,12 @@ package dev.inmo.tgbotapi.libraries.cache.admins | ||||
| import dev.inmo.tgbotapi.bot.TelegramBot | ||||
| import dev.inmo.tgbotapi.extensions.api.bot.getMe | ||||
| import dev.inmo.tgbotapi.extensions.api.chat.get.getChatAdministrators | ||||
| import dev.inmo.tgbotapi.types.ChatId | ||||
| import dev.inmo.tgbotapi.types.IdChatIdentifier | ||||
| import dev.inmo.tgbotapi.types.chat.ExtendedBot | ||||
| import dev.inmo.tgbotapi.types.chat.member.AdministratorChatMember | ||||
|  | ||||
| internal suspend fun TelegramBot.updateAdmins( | ||||
|     chatId: ChatId, | ||||
|     chatId: IdChatIdentifier, | ||||
|     repo: DefaultAdminsCacheAPIRepo, | ||||
|     botInfo: ExtendedBot? = null | ||||
| ): List<AdministratorChatMember> { | ||||
|   | ||||
| @@ -1 +0,0 @@ | ||||
| <manifest package="dev.inmo.tgbotapi.libraries.cache.admins"/> | ||||
							
								
								
									
										3
									
								
								cache/admins/micro_utils/build.gradle
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										3
									
								
								cache/admins/micro_utils/build.gradle
									
									
									
									
										vendored
									
									
								
							| @@ -1,10 +1,9 @@ | ||||
| plugins { | ||||
|     id "org.jetbrains.kotlin.multiplatform" | ||||
|     id "org.jetbrains.kotlin.plugin.serialization" | ||||
|     id "com.android.library" | ||||
| } | ||||
|  | ||||
| apply from: "$mppProjectWithSerializationPresetPath" | ||||
| apply from: "$mppJavaWithJsProjectPath" | ||||
|  | ||||
| kotlin { | ||||
|     sourceSets { | ||||
|   | ||||
| @@ -1,6 +1,6 @@ | ||||
| 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.repos.* | ||||
| import dev.inmo.tgbotapi.libraries.cache.admins.DefaultAdminsCacheAPIRepo | ||||
| @@ -15,22 +15,22 @@ private sealed class RepoActions<T> { | ||||
|     abstract val deferred: CompletableDeferred<T> | ||||
| } | ||||
| private class GetUpdateDateTimeRepoAction( | ||||
|     val chatId: ChatId, | ||||
|     val chatId: IdChatIdentifier, | ||||
|     override val deferred: CompletableDeferred<DateTime?> | ||||
| ) : RepoActions<DateTime?>() | ||||
| private class GetChatAdminsRepoAction( | ||||
|     val chatId: ChatId, | ||||
|     val chatId: IdChatIdentifier, | ||||
|     override val deferred: CompletableDeferred<List<AdministratorChatMember>?> | ||||
| ) : RepoActions<List<AdministratorChatMember>?>() | ||||
| private class SetChatAdminsRepoAction( | ||||
|     val chatId: ChatId, | ||||
|     val chatId: IdChatIdentifier, | ||||
|     val newValue: List<AdministratorChatMember>, | ||||
|     override val deferred: CompletableDeferred<Unit> | ||||
| ) : RepoActions<Unit>() | ||||
|  | ||||
| class DefaultAdminsCacheAPIRepoImpl( | ||||
|     private val adminsRepo: KeyValuesRepo<ChatId, AdministratorChatMember>, | ||||
|     private val updatesRepo: KeyValueRepo<ChatId, MilliSeconds>, | ||||
|     private val adminsRepo: KeyValuesRepo<IdChatIdentifier, AdministratorChatMember>, | ||||
|     private val updatesRepo: KeyValueRepo<IdChatIdentifier, MilliSeconds>, | ||||
|     private val scope: CoroutineScope | ||||
| ) : DefaultAdminsCacheAPIRepo { | ||||
|     private val actor = scope.actorAsync<RepoActions<*>>(Channel.UNLIMITED) { | ||||
| @@ -54,7 +54,7 @@ class DefaultAdminsCacheAPIRepoImpl( | ||||
|         } | ||||
|     } | ||||
|  | ||||
|     override suspend fun getChatAdmins(chatId: ChatId): List<AdministratorChatMember>? { | ||||
|     override suspend fun getChatAdmins(chatId: IdChatIdentifier): List<AdministratorChatMember>? { | ||||
|         val deferred = CompletableDeferred<List<AdministratorChatMember>?>() | ||||
|         actor.trySend( | ||||
|             GetChatAdminsRepoAction(chatId, deferred) | ||||
| @@ -64,7 +64,7 @@ class DefaultAdminsCacheAPIRepoImpl( | ||||
|         return deferred.await() | ||||
|     } | ||||
|  | ||||
|     override suspend fun setChatAdmins(chatId: ChatId, chatMembers: List<AdministratorChatMember>) { | ||||
|     override suspend fun setChatAdmins(chatId: IdChatIdentifier, chatMembers: List<AdministratorChatMember>) { | ||||
|         val deferred = CompletableDeferred<Unit>() | ||||
|         actor.trySend( | ||||
|             SetChatAdminsRepoAction(chatId, chatMembers, deferred) | ||||
| @@ -73,7 +73,7 @@ class DefaultAdminsCacheAPIRepoImpl( | ||||
|         } | ||||
|         return deferred.await() | ||||
|     } | ||||
|     override suspend fun lastUpdate(chatId: ChatId): DateTime? { | ||||
|     override suspend fun lastUpdate(chatId: IdChatIdentifier): DateTime? { | ||||
|         val deferred = CompletableDeferred<DateTime?>() | ||||
|         actor.trySend( | ||||
|             GetUpdateDateTimeRepoAction(chatId, deferred) | ||||
| @@ -85,7 +85,7 @@ class DefaultAdminsCacheAPIRepoImpl( | ||||
| } | ||||
|  | ||||
| fun DefaultAdminsCacheAPIRepo( | ||||
|     adminsRepo: KeyValuesRepo<ChatId, AdministratorChatMember>, | ||||
|     updatesRepo: KeyValueRepo<ChatId, MilliSeconds>, | ||||
|     adminsRepo: KeyValuesRepo<IdChatIdentifier, AdministratorChatMember>, | ||||
|     updatesRepo: KeyValueRepo<IdChatIdentifier, MilliSeconds>, | ||||
|     scope: CoroutineScope | ||||
| ) = DefaultAdminsCacheAPIRepoImpl(adminsRepo, updatesRepo, scope) | ||||
|   | ||||
| @@ -3,22 +3,22 @@ package dev.inmo.tgbotapi.libraries.cache.admins.micro_utils | ||||
| import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions | ||||
| import dev.inmo.micro_utils.repos.* | ||||
| import dev.inmo.tgbotapi.libraries.cache.admins.* | ||||
| import dev.inmo.tgbotapi.types.ChatId | ||||
| import dev.inmo.tgbotapi.types.IdChatIdentifier | ||||
| import kotlinx.coroutines.CoroutineScope | ||||
| import kotlinx.coroutines.flow.* | ||||
|  | ||||
| class DynamicAdminsCacheSettingsAPI( | ||||
|     private val repo: KeyValueRepo<ChatId, AdminsCacheSettings>, | ||||
|     private val repo: KeyValueRepo<IdChatIdentifier, AdminsCacheSettings>, | ||||
|     private val scope: CoroutineScope | ||||
| ) : AdminsCacheSettingsAPI, MutableAdminsCacheSettingsAPI { | ||||
|     override val chatSettingsUpdatedFlow: SharedFlow<Pair<ChatId, AdminsCacheSettings>> | ||||
|     override val chatSettingsUpdatedFlow: SharedFlow<Pair<IdChatIdentifier, AdminsCacheSettings>> | ||||
|         get() = repo.onNewValue.shareIn(scope, SharingStarted.Eagerly) | ||||
|  | ||||
|     override suspend fun setChatSettings(chatId: ChatId, settings: AdminsCacheSettings) { | ||||
|     override suspend fun setChatSettings(chatId: IdChatIdentifier, settings: AdminsCacheSettings) { | ||||
|         repo.set(chatId, settings) | ||||
|     } | ||||
|  | ||||
|     override suspend fun getChatSettings(chatId: ChatId): AdminsCacheSettings { | ||||
|     override suspend fun getChatSettings(chatId: IdChatIdentifier): AdminsCacheSettings { | ||||
|         val settings = repo.get(chatId) | ||||
|         return if (settings == null) { | ||||
|             val newSettings = AdminsCacheSettings() | ||||
| @@ -28,4 +28,4 @@ class DynamicAdminsCacheSettingsAPI( | ||||
|             settings | ||||
|         } | ||||
|     } | ||||
| } | ||||
| } | ||||
|   | ||||
| @@ -38,7 +38,7 @@ fun TelegramBot.createAdminsCacheAPI( | ||||
|             { long("chatId") }, | ||||
|             { text("member") }, | ||||
|             "AdminsTable" | ||||
|         ).withMapper<ChatId, AdministratorChatMember, Identifier, String>( | ||||
|         ).withMapper<IdChatIdentifier, AdministratorChatMember, Identifier, String>( | ||||
|             keyFromToTo = { chatId }, | ||||
|             valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(AdministratorChatMember.serializer(), this) }, | ||||
|             keyToToFrom = { toChatId() }, | ||||
| @@ -49,7 +49,7 @@ fun TelegramBot.createAdminsCacheAPI( | ||||
|             { long("chatId") }, | ||||
|             { long("datetime") }, | ||||
|             "AdminsUpdatesTimesTable" | ||||
|         ).withMapper<ChatId, Long, Identifier, Long>( | ||||
|         ).withMapper<IdChatIdentifier, Long, Identifier, Long>( | ||||
|             keyFromToTo = { chatId }, | ||||
|             valueFromToTo = { this }, | ||||
|             keyToToFrom = { toChatId() }, | ||||
| @@ -63,7 +63,7 @@ fun TelegramBot.createAdminsCacheAPI( | ||||
|             { long("chatId") }, | ||||
|             { text("settings") }, | ||||
|             "DynamicAdminsCacheSettingsAPI" | ||||
|         ).withMapper<ChatId, AdminsCacheSettings, Identifier, String>( | ||||
|         ).withMapper<IdChatIdentifier, AdminsCacheSettings, Identifier, String>( | ||||
|             keyFromToTo = { chatId }, | ||||
|             valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(AdminsCacheSettings.serializer() , this) }, | ||||
|             keyToToFrom = { toChatId() }, | ||||
|   | ||||
| @@ -1 +0,0 @@ | ||||
| <manifest package="dev.inmo.tgbotapi.libraries.cache.admins.micro_utils"/> | ||||
							
								
								
									
										3
									
								
								cache/admins/plagubot/build.gradle
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										3
									
								
								cache/admins/plagubot/build.gradle
									
									
									
									
										vendored
									
									
								
							| @@ -1,10 +1,9 @@ | ||||
| plugins { | ||||
|     id "org.jetbrains.kotlin.multiplatform" | ||||
|     id "org.jetbrains.kotlin.plugin.serialization" | ||||
|     id "com.android.library" | ||||
| } | ||||
|  | ||||
| apply from: "$mppProjectWithSerializationPresetPath" | ||||
| apply from: "$mppJavaWithJsProjectPath" | ||||
|  | ||||
| kotlin { | ||||
|     sourceSets { | ||||
|   | ||||
| @@ -55,7 +55,7 @@ class AdminsPlugin : Plugin { | ||||
|                     { long("chatId") }, | ||||
|                     { text("member") }, | ||||
|                     "AdminsTable" | ||||
|                 ).withMapper<ChatId, AdministratorChatMember, Identifier, String>( | ||||
|                 ).withMapper<IdChatIdentifier, AdministratorChatMember, Identifier, String>( | ||||
|                     keyFromToTo = { chatId }, | ||||
|                     valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(this) }, | ||||
|                     keyToToFrom = { toChatId() }, | ||||
| @@ -66,7 +66,7 @@ class AdminsPlugin : Plugin { | ||||
|                     { long("chatId") }, | ||||
|                     { long("datetime") }, | ||||
|                     "AdminsUpdatesTimesTable" | ||||
|                 ).withMapper<ChatId, Long, Identifier, Long>( | ||||
|                 ).withMapper<IdChatIdentifier, Long, Identifier, Long>( | ||||
|                     keyFromToTo = { chatId }, | ||||
|                     valueFromToTo = { this }, | ||||
|                     keyToToFrom = { toChatId() }, | ||||
| @@ -82,7 +82,7 @@ class AdminsPlugin : Plugin { | ||||
|                     { long("chatId") }, | ||||
|                     { text("settings") }, | ||||
|                     "DynamicAdminsCacheSettingsAPI" | ||||
|                 ).withMapper<ChatId, AdminsCacheSettings, Identifier, String>( | ||||
|                 ).withMapper<IdChatIdentifier, AdminsCacheSettings, Identifier, String>( | ||||
|                     keyFromToTo = { chatId }, | ||||
|                     valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(this) }, | ||||
|                     keyToToFrom = { toChatId() }, | ||||
|   | ||||
| @@ -1 +0,0 @@ | ||||
| <manifest package="dev.inmo.tgbotapi.libraries.cache.admins.plagubot"/> | ||||
							
								
								
									
										3
									
								
								cache/content/common/build.gradle
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										3
									
								
								cache/content/common/build.gradle
									
									
									
									
										vendored
									
									
								
							| @@ -1,10 +1,9 @@ | ||||
| plugins { | ||||
|     id "org.jetbrains.kotlin.multiplatform" | ||||
|     id "org.jetbrains.kotlin.plugin.serialization" | ||||
|     id "com.android.library" | ||||
| } | ||||
|  | ||||
| apply from: "$mppProjectWithSerializationPresetPath" | ||||
| apply from: "$mppJavaWithJsProjectPath" | ||||
|  | ||||
| kotlin { | ||||
|     sourceSets { | ||||
|   | ||||
| @@ -4,7 +4,7 @@ import dev.inmo.tgbotapi.bot.TelegramBot | ||||
| import dev.inmo.tgbotapi.requests.DownloadFileStream | ||||
| import dev.inmo.tgbotapi.requests.get.GetFile | ||||
| import dev.inmo.tgbotapi.requests.send.media.* | ||||
| import dev.inmo.tgbotapi.types.ChatId | ||||
| import dev.inmo.tgbotapi.types.IdChatIdentifier | ||||
| import dev.inmo.tgbotapi.types.media.* | ||||
| import dev.inmo.tgbotapi.types.message.content.MediaContent | ||||
| import dev.inmo.tgbotapi.types.message.content.MessageContent | ||||
| @@ -13,7 +13,7 @@ import io.ktor.utils.io.core.Input | ||||
|  | ||||
| class DefaultMessageContentCache<K>( | ||||
|     private val bot: TelegramBot, | ||||
|     private val filesRefreshingChatId: ChatId, | ||||
|     private val filesRefreshingChatId: IdChatIdentifier, | ||||
|     private val simpleMessageContentCache: MessagesSimpleCache<K>, | ||||
|     private val mediaFileActualityChecker: MediaFileActualityChecker = MediaFileActualityChecker.WithDelay( | ||||
|         MediaFileActualityChecker.Default(filesRefreshingChatId) | ||||
| @@ -111,7 +111,7 @@ class DefaultMessageContentCache<K>( | ||||
|     companion object { | ||||
|         operator fun invoke( | ||||
|             bot: TelegramBot, | ||||
|             filesRefreshingChatId: ChatId, | ||||
|             filesRefreshingChatId: IdChatIdentifier, | ||||
|             simpleMessageContentCache: MessagesSimpleCache<String> = InMemoryMessagesSimpleCache(), | ||||
|             mediaFileActualityChecker: MediaFileActualityChecker = MediaFileActualityChecker.WithDelay( | ||||
|                 MediaFileActualityChecker.Default(filesRefreshingChatId) | ||||
|   | ||||
| @@ -1,11 +1,12 @@ | ||||
| package dev.inmo.tgbotapi.libraries.cache.media.common | ||||
|  | ||||
| import com.soywiz.klock.DateTime | ||||
| import com.soywiz.klock.milliseconds | ||||
| import korlibs.time.DateTime | ||||
| import korlibs.time.milliseconds | ||||
| import dev.inmo.tgbotapi.bot.TelegramBot | ||||
| import dev.inmo.tgbotapi.requests.DeleteMessage | ||||
| import dev.inmo.tgbotapi.requests.abstracts.FileId | ||||
| import dev.inmo.tgbotapi.types.ChatId | ||||
| import dev.inmo.tgbotapi.types.IdChatIdentifier | ||||
| import dev.inmo.tgbotapi.types.MilliSeconds | ||||
| import dev.inmo.tgbotapi.types.message.content.MediaContent | ||||
|  | ||||
| @@ -14,7 +15,7 @@ fun interface MediaFileActualityChecker { | ||||
|     suspend fun TelegramBot.saved(mediaContent: MediaContent) {} | ||||
|  | ||||
|     class Default( | ||||
|         private val checkingChatId: ChatId | ||||
|         private val checkingChatId: IdChatIdentifier | ||||
|     ) : MediaFileActualityChecker { | ||||
|         override suspend fun TelegramBot.isActual(mediaContent: MediaContent): Boolean { | ||||
|             return runCatching { | ||||
|   | ||||
| @@ -1 +0,0 @@ | ||||
| <manifest package="dev.inmo.tgbotapi.libraries.cache.content.common"/> | ||||
							
								
								
									
										3
									
								
								cache/content/micro_utils/build.gradle
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										3
									
								
								cache/content/micro_utils/build.gradle
									
									
									
									
										vendored
									
									
								
							| @@ -1,10 +1,9 @@ | ||||
| plugins { | ||||
|     id "org.jetbrains.kotlin.multiplatform" | ||||
|     id "org.jetbrains.kotlin.plugin.serialization" | ||||
|     id "com.android.library" | ||||
| } | ||||
|  | ||||
| apply from: "$mppProjectWithSerializationPresetPath" | ||||
| apply from: "$mppJavaWithJsProjectPath" | ||||
|  | ||||
| kotlin { | ||||
|     sourceSets { | ||||
|   | ||||
| @@ -1 +0,0 @@ | ||||
| <manifest package="dev.inmo.tgbotapi.libraries.cache.content.micro_utils"/> | ||||
| @@ -1,40 +0,0 @@ | ||||
| apply plugin: 'com.getkeepsafe.dexcount' | ||||
|  | ||||
| android { | ||||
|     compileSdkVersion "$android_compileSdkVersion".toInteger() | ||||
|     buildToolsVersion "$android_buildToolsVersion" | ||||
|  | ||||
|     defaultConfig { | ||||
|         minSdkVersion "$android_minSdkVersion".toInteger() | ||||
|         targetSdkVersion "$android_compileSdkVersion".toInteger() | ||||
|         versionCode "${android_code_version}".toInteger() | ||||
|         versionName "$version" | ||||
|     } | ||||
|     buildTypes { | ||||
|         release { | ||||
|             minifyEnabled false | ||||
|         } | ||||
|         debug { | ||||
|             debuggable true | ||||
|         } | ||||
|     } | ||||
|  | ||||
|     packagingOptions { | ||||
|         exclude 'META-INF/kotlinx-serialization-runtime.kotlin_module' | ||||
|         exclude 'META-INF/kotlinx-serialization-cbor.kotlin_module' | ||||
|         exclude 'META-INF/kotlinx-serialization-properties.kotlin_module' | ||||
|     } | ||||
|  | ||||
|     compileOptions { | ||||
|         sourceCompatibility JavaVersion.VERSION_1_8 | ||||
|         targetCompatibility JavaVersion.VERSION_1_8 | ||||
|     } | ||||
|  | ||||
|     kotlinOptions { | ||||
|         jvmTarget = JavaVersion.VERSION_1_8.toString() | ||||
|     } | ||||
|  | ||||
|     sourceSets { | ||||
|         main.java.srcDirs += 'src/main/kotlin' | ||||
|     } | ||||
| } | ||||
| @@ -13,11 +13,7 @@ allprojects { | ||||
|             projectByName(name) | ||||
|         } | ||||
|  | ||||
|         mppProjectWithSerializationPresetPath = "${rootProject.projectDir.absolutePath}/mppProjectWithSerialization.gradle" | ||||
|         mppJavaProjectPresetPath = "${rootProject.projectDir.absolutePath}/mppJavaProject.gradle" | ||||
|         mppAndroidProjectPresetPath = "${rootProject.projectDir.absolutePath}/mppAndroidProject.gradle" | ||||
|  | ||||
|         defaultAndroidSettingsPresetPath = "${rootProject.projectDir.absolutePath}/defaultAndroidSettings.gradle" | ||||
|         mppJavaWithJsProjectPath = "${rootProject.projectDir.absolutePath}/mppJavaWithJsProject.gradle" | ||||
|  | ||||
|         publishGradlePath = "${rootProject.projectDir.absolutePath}/publish.gradle" | ||||
|     } | ||||
|   | ||||
| @@ -1,37 +1,26 @@ | ||||
| org.gradle.jvmargs=-Xmx512m | ||||
| kotlin.code.style=official | ||||
| org.gradle.parallel=true | ||||
| kotlin.js.generate.externals=true | ||||
| kotlin.incremental=true | ||||
| kotlin.incremental.js=true | ||||
| android.useAndroidX=true | ||||
| android.enableJetifier=true | ||||
|  | ||||
| kotlin_version=1.7.10 | ||||
| kotlin_serialisation_core_version=1.4.0 | ||||
|  | ||||
| kotlin_version=1.8.22 | ||||
| kotlin_serialisation_core_version=1.5.1 | ||||
|  | ||||
| github_release_plugin_version=2.4.1 | ||||
|  | ||||
| tgbotapi_version=3.2.7 | ||||
| micro_utils_version=0.12.17 | ||||
| exposed_version=0.39.2 | ||||
| plagubot_version=2.3.4 | ||||
|  | ||||
| # ANDROID | ||||
|  | ||||
| android_minSdkVersion=21 | ||||
| android_compileSdkVersion=33 | ||||
| android_buildToolsVersion=33.0.0 | ||||
| dexcount_version=3.1.0 | ||||
| junit_version=4.12 | ||||
| test_ext_junit_version=1.1.3 | ||||
| espresso_core=3.4.0 | ||||
| tgbotapi_version=8.1.0 | ||||
| micro_utils_version=0.19.4 | ||||
| exposed_version=0.41.1 | ||||
| plagubot_version=6.1.0 | ||||
|  | ||||
| # Dokka | ||||
|  | ||||
| dokka_version=1.7.10 | ||||
| dokka_version=1.8.20 | ||||
|  | ||||
| # Project data | ||||
|  | ||||
| group=dev.inmo | ||||
| version=0.5.5 | ||||
| android_code_version=32 | ||||
| version=0.12.2 | ||||
|   | ||||
							
								
								
									
										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.5.1-bin.zip | ||||
| distributionUrl=https\://services.gradle.org/distributions/gradle-7.6.1-bin.zip | ||||
| zipStoreBase=GRADLE_USER_HOME | ||||
| zipStorePath=wrapper/dists | ||||
|   | ||||
| @@ -1,26 +0,0 @@ | ||||
| project.version = "$version" | ||||
| project.group = "$group" | ||||
|  | ||||
| apply from: "$publishGradlePath" | ||||
|  | ||||
| kotlin { | ||||
|     android { | ||||
|         publishAllLibraryVariants() | ||||
|     } | ||||
|  | ||||
|     sourceSets { | ||||
|         commonMain { | ||||
|             dependencies { | ||||
|                 implementation kotlin('stdlib') | ||||
|             } | ||||
|         } | ||||
|         commonTest { | ||||
|             dependencies { | ||||
|                 implementation kotlin('test-common') | ||||
|                 implementation kotlin('test-annotations-common') | ||||
|             } | ||||
|         } | ||||
|     } | ||||
| } | ||||
|  | ||||
| apply from: "$defaultAndroidSettingsPresetPath" | ||||
| @@ -1,39 +0,0 @@ | ||||
| project.version = "$version" | ||||
| project.group = "$group" | ||||
|  | ||||
| apply from: "$publishGradlePath" | ||||
|  | ||||
| kotlin { | ||||
|     jvm { | ||||
|         compilations.main { | ||||
|             kotlinOptions { | ||||
|                 jvmTarget = "1.8" | ||||
|             } | ||||
|         } | ||||
|     } | ||||
|  | ||||
|     sourceSets { | ||||
|         commonMain { | ||||
|             dependencies { | ||||
|                 implementation kotlin('stdlib') | ||||
|             } | ||||
|         } | ||||
|         commonTest { | ||||
|             dependencies { | ||||
|                 implementation kotlin('test-common') | ||||
|                 implementation kotlin('test-annotations-common') | ||||
|             } | ||||
|         } | ||||
|  | ||||
|         jvmTest { | ||||
|             dependencies { | ||||
|                 implementation kotlin('test-junit') | ||||
|             } | ||||
|         } | ||||
|     } | ||||
| } | ||||
|  | ||||
| java { | ||||
|     sourceCompatibility = JavaVersion.VERSION_1_8 | ||||
|     targetCompatibility = JavaVersion.VERSION_1_8 | ||||
| } | ||||
| @@ -15,9 +15,6 @@ kotlin { | ||||
|         browser() | ||||
|         nodejs() | ||||
|     } | ||||
|     android { | ||||
|         publishAllLibraryVariants() | ||||
|     } | ||||
| 
 | ||||
|     sourceSets { | ||||
|         commonMain { | ||||
| @@ -43,13 +40,6 @@ kotlin { | ||||
|                 implementation kotlin('test-junit') | ||||
|             } | ||||
|         } | ||||
|         androidTest { | ||||
|             dependencies { | ||||
|                 implementation kotlin('test-junit') | ||||
|                 implementation "androidx.test.ext:junit:$test_ext_junit_version" | ||||
|                 implementation "androidx.test.espresso:espresso-core:$espresso_core" | ||||
|             } | ||||
|         } | ||||
|     } | ||||
| } | ||||
| 
 | ||||
| @@ -57,5 +47,3 @@ java { | ||||
|     sourceCompatibility = JavaVersion.VERSION_1_8 | ||||
|     targetCompatibility = JavaVersion.VERSION_1_8 | ||||
| } | ||||
| 
 | ||||
| apply from: "$defaultAndroidSettingsPresetPath" | ||||
| @@ -42,20 +42,40 @@ publishing { | ||||
|                 maven { | ||||
|                     name = "GithubPackages" | ||||
|                     url = uri("https://maven.pkg.github.com/InsanusMokrassar/TelegramBotApiLibraries") | ||||
|              | ||||
|                     credentials { | ||||
|                         username = project.hasProperty('GITHUBPACKAGES_USER') ? project.property('GITHUBPACKAGES_USER') : System.getenv('GITHUBPACKAGES_USER') | ||||
|                         password = project.hasProperty('GITHUBPACKAGES_PASSWORD') ? project.property('GITHUBPACKAGES_PASSWORD') : System.getenv('GITHUBPACKAGES_PASSWORD') | ||||
|                     } | ||||
|              | ||||
|                 } | ||||
|             } | ||||
|             if (project.hasProperty('GITEA_TOKEN') || System.getenv('GITEA_TOKEN') != null) { | ||||
|                 maven { | ||||
|                     name = "Gitea" | ||||
|                     url = uri("https://git.inmo.dev/api/packages/InsanusMokrassar/maven") | ||||
|              | ||||
|                     credentials(HttpHeaderCredentials) { | ||||
|                         name = "Authorization" | ||||
|                         value = project.hasProperty('GITEA_TOKEN') ? project.property('GITEA_TOKEN') : System.getenv('GITEA_TOKEN') | ||||
|                     } | ||||
|              | ||||
|                     authentication { | ||||
|                         header(HttpHeaderAuthentication) | ||||
|                     } | ||||
|              | ||||
|                 } | ||||
|             } | ||||
|             if ((project.hasProperty('SONATYPE_USER') || System.getenv('SONATYPE_USER') != null) && (project.hasProperty('SONATYPE_PASSWORD') || System.getenv('SONATYPE_PASSWORD') != null)) { | ||||
|                 maven { | ||||
|                     name = "sonatype" | ||||
|                     url = uri("https://oss.sonatype.org/service/local/staging/deploy/maven2/") | ||||
|              | ||||
|                     credentials { | ||||
|                         username = project.hasProperty('SONATYPE_USER') ? project.property('SONATYPE_USER') : System.getenv('SONATYPE_USER') | ||||
|                         password = project.hasProperty('SONATYPE_PASSWORD') ? project.property('SONATYPE_PASSWORD') : System.getenv('SONATYPE_PASSWORD') | ||||
|                     } | ||||
|              | ||||
|                 } | ||||
|             } | ||||
|         } | ||||
|   | ||||
| @@ -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":"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":"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"}}} | ||||
							
								
								
									
										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" | ||||
|             } | ||||
|         } | ||||
|     } | ||||
| } | ||||
|  | ||||
							
								
								
									
										20
									
								
								resender/src/commonMain/kotlin/MessageMetaInfo.kt
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										20
									
								
								resender/src/commonMain/kotlin/MessageMetaInfo.kt
									
									
									
									
									
										Normal file
									
								
							| @@ -0,0 +1,20 @@ | ||||
| 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.Message | ||||
| import dev.inmo.tgbotapi.types.message.abstracts.PossiblyMediaGroupMessage | ||||
| import kotlinx.serialization.Serializable | ||||
|  | ||||
| @Serializable | ||||
| data class MessageMetaInfo( | ||||
|     @Serializable(FullChatIdentifierSerializer::class) | ||||
|     val chatId: IdChatIdentifier, | ||||
|     val messageId: MessageId, | ||||
|     val group: String? = null | ||||
| ) | ||||
|  | ||||
| operator fun MessageMetaInfo.Companion.invoke( | ||||
|     message: Message | ||||
| ) = MessageMetaInfo(message.chat.id, message.messageId, (message as? PossiblyMediaGroupMessage<*>) ?.mediaGroupId) | ||||
							
								
								
									
										157
									
								
								resender/src/commonMain/kotlin/MessagesResender.kt
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										157
									
								
								resender/src/commonMain/kotlin/MessagesResender.kt
									
									
									
									
									
										Normal file
									
								
							| @@ -0,0 +1,157 @@ | ||||
| package dev.inmo.tgbotapi.libraries.resender | ||||
|  | ||||
| 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.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 messagesWithOrders = messagesInfo.mapIndexed { i, messageInfo -> messageInfo to i }.toMap() | ||||
|         val ordersWithMessagesGroups = messagesInfo.groupBy { it.group }.flatMap { (group, list) -> | ||||
|             if (group == null) { | ||||
|                 list.map { | ||||
|                     messagesWithOrders.getValue(it) to listOf(it) | ||||
|                 } | ||||
|             } else { | ||||
|                 listOf(messagesWithOrders.getValue(list.first()) to list) | ||||
|             } | ||||
|         }.sortedBy { it.first } | ||||
|  | ||||
|         val sent = mutableListOf<MessageMetaInfo>() | ||||
|         val leftToSend = ordersWithMessagesGroups.map { it.second }.toMutableList() | ||||
|  | ||||
|         return ordersWithMessagesGroups.flatMap { (_, contents) -> | ||||
|             val sourceMessagesToSentMessages = mutableListOf<Pair<MessageMetaInfo, MessageMetaInfo>>() | ||||
|  | ||||
|             onBetweenMessages(sent.toList(), leftToSend.flatten()) | ||||
|  | ||||
|             when { | ||||
|                 contents.size == 1 -> { | ||||
|                     val messageInfo = contents.first() | ||||
|                     runCatching { | ||||
|                         MessageMetaInfo( | ||||
|                             targetChatId, | ||||
|                             bot.execute( | ||||
|                                 CopyMessage( | ||||
|                                     targetChatId, | ||||
|                                     fromChatId = messageInfo.chatId, | ||||
|                                     messageId = messageInfo.messageId | ||||
|                                 ) | ||||
|                             ) | ||||
|                         ) | ||||
|                     }.onFailure { _ -> | ||||
|                         runCatching { | ||||
|                             bot.execute( | ||||
|                                 ForwardMessage( | ||||
|                                     toChatId = targetChatId, | ||||
|                                     fromChatId = messageInfo.chatId, | ||||
|                                     messageId = messageInfo.messageId | ||||
|                                 ) | ||||
|                             ) | ||||
|                         }.onSuccess { | ||||
|                             MessageMetaInfo( | ||||
|                                 targetChatId, | ||||
|                                 bot.execute( | ||||
|                                     CopyMessage( | ||||
|                                         targetChatId, | ||||
|                                         fromChatId = it.chat.id, | ||||
|                                         messageId = it.messageId | ||||
|                                     ) | ||||
|                                 ) | ||||
|                             ) | ||||
|                         } | ||||
|                     }.getOrNull() ?.let { | ||||
|                         sourceMessagesToSentMessages.add(messageInfo to it) | ||||
|                     } | ||||
|                 } | ||||
|                 else -> { | ||||
|                     val resultContents = contents.mapNotNull { | ||||
|                         it to ( | ||||
|                             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 | ||||
|                         } ?.let { | ||||
|                             it as ContentMessage<MediaGroupPartContent> | ||||
|                         } | ||||
|                         src to (forwardedMessageAsMediaPartMessage ?: null.also { _ -> | ||||
|                             sourceMessagesToSentMessages.add( | ||||
|                                 src to MessageMetaInfo( | ||||
|                                     targetChatId, | ||||
|                                     bot.execute( | ||||
|                                         CopyMessage( | ||||
|                                             targetChatId, | ||||
|                                             fromChatId = forwardedMessage.chat.id, | ||||
|                                             messageId = forwardedMessage.messageId | ||||
|                                         ) | ||||
|                                     ) | ||||
|                                 ) | ||||
|                             ) | ||||
|                         } ?: return@mapNotNull null) | ||||
|                     } | ||||
|  | ||||
|                     resultContents.singleOrNull() ?.also { (src, it) -> | ||||
|                         sourceMessagesToSentMessages.add( | ||||
|                             src to MessageMetaInfo( | ||||
|                                 targetChatId, | ||||
|                                 bot.execute( | ||||
|                                     CopyMessage( | ||||
|                                         targetChatId, | ||||
|                                         it.chat.id, | ||||
|                                         it.messageId | ||||
|                                     ) | ||||
|                                 ) | ||||
|                             ) | ||||
|                         ) | ||||
|                     } ?: resultContents.chunked(mediaCountInMediaGroup.last).forEach { | ||||
|                         bot.execute( | ||||
|                             SendMediaGroup<MediaGroupPartContent>( | ||||
|                                 targetChatId, | ||||
|                                 it.map { it.second.content.toMediaGroupMemberTelegramMedia() } | ||||
|                             ) | ||||
|                         ).content.group.mapIndexed { i, partWrapper -> | ||||
|                             it.getOrNull(i) ?.let { | ||||
|                                 sourceMessagesToSentMessages.add( | ||||
|                                     it.first to MessageMetaInfo( | ||||
|                                         partWrapper.sourceMessage.chat.id, | ||||
|                                         partWrapper.sourceMessage.messageId, | ||||
|                                         partWrapper.sourceMessage.mediaGroupId | ||||
|                                     ) | ||||
|                                 ) | ||||
|                             } | ||||
|                         } | ||||
|                     } | ||||
|                 } | ||||
|             } | ||||
|  | ||||
|             leftToSend.takeIf { it.isNotEmpty() } ?.removeAt(0) ?.also { | ||||
|                 sent.addAll(it) | ||||
|             } | ||||
|             sourceMessagesToSentMessages.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:micro_utils", | ||||
|  | ||||
|     ":resender", | ||||
| ] | ||||
|  | ||||
|  | ||||
|   | ||||
		Reference in New Issue
	
	Block a user