mirror of
				https://github.com/InsanusMokrassar/TelegramBotApiLibraries.git
				synced 2025-10-31 12:10:15 +00:00 
			
		
		
		
	Compare commits
	
		
			55 Commits
		
	
	
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| 5524fc9fa0 | |||
| d0eebc0ace | |||
| 891dab1f4b | |||
| 9f6895a530 | |||
| 49084169d2 | |||
| 1457cfc748 | |||
| 6784a3c49a | |||
| 8ef89a32c7 | |||
| d16de6428a | |||
| 49475a457d | |||
| b8312873b0 | |||
| 3ede07c2a6 | |||
| a0e17a664c | |||
| fc3bf19453 | |||
| 8d1c57700e | |||
| 00c0f0fd6f | |||
| 551eb293ab | |||
| f1b58a889f | |||
| 36a0f9b65b | |||
| 86abe49bc1 | |||
| 5b62bfa7d3 | |||
| d94d847715 | |||
| 91013b914d | |||
| cec4c610f3 | |||
| b9003388b1 | |||
| 6d161c2d78 | |||
| dc63639fee | |||
| 66934c823d | |||
| 90870c225c | |||
| 106d01775c | |||
| cea2f7dc6e | |||
| 7d461edc9b | |||
| c52c6cb633 | |||
| 6db1755ee7 | |||
| ccf60c95ca | |||
| 4057d5167f | |||
| f19664da58 | |||
| 646a551b15 | |||
| a08974e76d | |||
| 30e62041c0 | |||
| be8fe43e76 | |||
| 42f3a064ad | |||
| 34f9d8c0ab | |||
| 6e4fc54a23 | |||
| 674ee28991 | |||
| 4950fd4ed0 | |||
| e3f5ae0b24 | |||
| 3bf2d858eb | |||
| b51bc97551 | |||
| c0680932ab | |||
| 849edadab0 | |||
| f02933a9d0 | |||
| f018b723cb | |||
| 65d8fd6be1 | |||
| d44c13bea5 | 
							
								
								
									
										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
									
								
								.gitignore
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										1
									
								
								.gitignore
									
									
									
									
										vendored
									
									
								
							| @@ -1,4 +1,5 @@ | |||||||
| .idea | .idea | ||||||
|  | .kotlin | ||||||
| out/* | out/* | ||||||
| *.iml | *.iml | ||||||
| target | target | ||||||
|   | |||||||
| @@ -18,7 +18,7 @@ allprojects { | |||||||
|         mavenLocal() |         mavenLocal() | ||||||
|         mavenCentral() |         mavenCentral() | ||||||
|         google() |         google() | ||||||
|         maven { url "https://git.inmo.dev/api/packages/InsanusMokrassar/maven" } |         maven { url "https://nexus.inmo.dev/repository/maven-releases/" } | ||||||
|     } |     } | ||||||
| } | } | ||||||
|  |  | ||||||
|   | |||||||
| @@ -3,6 +3,7 @@ package dev.inmo.tgbotapi.libraries.cache.admins | |||||||
| import korlibs.time.minutes | import 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 | ||||||
|  |  | ||||||
|   | |||||||
| @@ -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 { | ||||||
|   | |||||||
| @@ -38,8 +38,8 @@ fun TelegramBot.createAdminsCacheAPI( | |||||||
|             { long("chatId") }, |             { long("chatId") }, | ||||||
|             { text("member") }, |             { text("member") }, | ||||||
|             "AdminsTable" |             "AdminsTable" | ||||||
|         ).withMapper<IdChatIdentifier, AdministratorChatMember, Identifier, String>( |         ).withMapper<IdChatIdentifier, AdministratorChatMember, Long, String>( | ||||||
|             keyFromToTo = { chatId }, |             keyFromToTo = { chatId.long }, | ||||||
|             valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(AdministratorChatMember.serializer(), this) }, |             valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(AdministratorChatMember.serializer(), this) }, | ||||||
|             keyToToFrom = { toChatId() }, |             keyToToFrom = { toChatId() }, | ||||||
|             valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(AdministratorChatMember.serializer(), this) } |             valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(AdministratorChatMember.serializer(), this) } | ||||||
| @@ -49,8 +49,8 @@ fun TelegramBot.createAdminsCacheAPI( | |||||||
|             { long("chatId") }, |             { long("chatId") }, | ||||||
|             { long("datetime") }, |             { long("datetime") }, | ||||||
|             "AdminsUpdatesTimesTable" |             "AdminsUpdatesTimesTable" | ||||||
|         ).withMapper<IdChatIdentifier, Long, Identifier, Long>( |         ).withMapper<IdChatIdentifier, Long, Long, Long>( | ||||||
|             keyFromToTo = { chatId }, |             keyFromToTo = { chatId.long }, | ||||||
|             valueFromToTo = { this }, |             valueFromToTo = { this }, | ||||||
|             keyToToFrom = { toChatId() }, |             keyToToFrom = { toChatId() }, | ||||||
|             valueToToFrom = { this } |             valueToToFrom = { this } | ||||||
| @@ -63,8 +63,8 @@ fun TelegramBot.createAdminsCacheAPI( | |||||||
|             { long("chatId") }, |             { long("chatId") }, | ||||||
|             { text("settings") }, |             { text("settings") }, | ||||||
|             "DynamicAdminsCacheSettingsAPI" |             "DynamicAdminsCacheSettingsAPI" | ||||||
|         ).withMapper<IdChatIdentifier, AdminsCacheSettings, Identifier, String>( |         ).withMapper<IdChatIdentifier, AdminsCacheSettings, Long, String>( | ||||||
|             keyFromToTo = { chatId }, |             keyFromToTo = { chatId.long }, | ||||||
|             valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(AdminsCacheSettings.serializer() , this) }, |             valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(AdminsCacheSettings.serializer() , this) }, | ||||||
|             keyToToFrom = { toChatId() }, |             keyToToFrom = { toChatId() }, | ||||||
|             valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(AdminsCacheSettings.serializer() , this) } |             valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(AdminsCacheSettings.serializer() , this) } | ||||||
|   | |||||||
| @@ -4,6 +4,7 @@ import dev.inmo.micro_utils.repos.exposed.keyvalue.ExposedKeyValueRepo | |||||||
| import dev.inmo.micro_utils.repos.exposed.onetomany.ExposedKeyValuesRepo | import dev.inmo.micro_utils.repos.exposed.onetomany.ExposedKeyValuesRepo | ||||||
| import dev.inmo.micro_utils.repos.mappers.withMapper | import dev.inmo.micro_utils.repos.mappers.withMapper | ||||||
| import dev.inmo.plagubot.Plugin | import dev.inmo.plagubot.Plugin | ||||||
|  | import dev.inmo.plagubot.database | ||||||
| import dev.inmo.tgbotapi.extensions.behaviour_builder.BehaviourContext | import dev.inmo.tgbotapi.extensions.behaviour_builder.BehaviourContext | ||||||
| import dev.inmo.tgbotapi.libraries.cache.admins.micro_utils.DefaultAdminsCacheAPIRepoImpl | import dev.inmo.tgbotapi.libraries.cache.admins.micro_utils.DefaultAdminsCacheAPIRepoImpl | ||||||
| import dev.inmo.tgbotapi.libraries.cache.admins.micro_utils.DynamicAdminsCacheSettingsAPI | import dev.inmo.tgbotapi.libraries.cache.admins.micro_utils.DynamicAdminsCacheSettingsAPI | ||||||
| @@ -44,7 +45,7 @@ class AdminsPlugin : Plugin { | |||||||
|         return flow.filterNotNull().first() |         return flow.filterNotNull().first() | ||||||
|     } |     } | ||||||
|  |  | ||||||
|     override fun Module.setupDI(database: Database, params: JsonObject) { |     override fun Module.setupDI(config: JsonObject) { | ||||||
|         single { this@AdminsPlugin } |         single { this@AdminsPlugin } | ||||||
|         val scopeQualifier = named("admins plugin scope") |         val scopeQualifier = named("admins plugin scope") | ||||||
|         single(scopeQualifier) { CoroutineScope(Dispatchers.IO + SupervisorJob()) } |         single(scopeQualifier) { CoroutineScope(Dispatchers.IO + SupervisorJob()) } | ||||||
| @@ -55,8 +56,8 @@ class AdminsPlugin : Plugin { | |||||||
|                     { long("chatId") }, |                     { long("chatId") }, | ||||||
|                     { text("member") }, |                     { text("member") }, | ||||||
|                     "AdminsTable" |                     "AdminsTable" | ||||||
|                 ).withMapper<IdChatIdentifier, AdministratorChatMember, Identifier, String>( |                 ).withMapper<IdChatIdentifier, AdministratorChatMember, Long, String>( | ||||||
|                     keyFromToTo = { chatId }, |                     keyFromToTo = { chatId.long }, | ||||||
|                     valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(this) }, |                     valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(this) }, | ||||||
|                     keyToToFrom = { toChatId() }, |                     keyToToFrom = { toChatId() }, | ||||||
|                     valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(this) } |                     valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(this) } | ||||||
| @@ -66,8 +67,8 @@ class AdminsPlugin : Plugin { | |||||||
|                     { long("chatId") }, |                     { long("chatId") }, | ||||||
|                     { long("datetime") }, |                     { long("datetime") }, | ||||||
|                     "AdminsUpdatesTimesTable" |                     "AdminsUpdatesTimesTable" | ||||||
|                 ).withMapper<IdChatIdentifier, Long, Identifier, Long>( |                 ).withMapper<IdChatIdentifier, Long, Long, Long>( | ||||||
|                     keyFromToTo = { chatId }, |                     keyFromToTo = { chatId.long }, | ||||||
|                     valueFromToTo = { this }, |                     valueFromToTo = { this }, | ||||||
|                     keyToToFrom = { toChatId() }, |                     keyToToFrom = { toChatId() }, | ||||||
|                     valueToToFrom = { this } |                     valueToToFrom = { this } | ||||||
| @@ -82,8 +83,8 @@ class AdminsPlugin : Plugin { | |||||||
|                     { long("chatId") }, |                     { long("chatId") }, | ||||||
|                     { text("settings") }, |                     { text("settings") }, | ||||||
|                     "DynamicAdminsCacheSettingsAPI" |                     "DynamicAdminsCacheSettingsAPI" | ||||||
|                 ).withMapper<IdChatIdentifier, AdminsCacheSettings, Identifier, String>( |                 ).withMapper<IdChatIdentifier, AdminsCacheSettings, Long, String>( | ||||||
|                     keyFromToTo = { chatId }, |                     keyFromToTo = { chatId.long }, | ||||||
|                     valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(this) }, |                     valueFromToTo = { telegramAdminsSerializationFormat.encodeToString(this) }, | ||||||
|                     keyToToFrom = { toChatId() }, |                     keyToToFrom = { toChatId() }, | ||||||
|                     valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(this) } |                     valueToToFrom = { telegramAdminsSerializationFormat.decodeFromString(this) } | ||||||
|   | |||||||
| @@ -3,8 +3,7 @@ package dev.inmo.tgbotapi.libraries.cache.media.common | |||||||
| import dev.inmo.tgbotapi.requests.abstracts.MultipartFile | import dev.inmo.tgbotapi.requests.abstracts.MultipartFile | ||||||
| import io.ktor.utils.io.core.Input | import io.ktor.utils.io.core.Input | ||||||
| import io.ktor.utils.io.core.copyTo | import io.ktor.utils.io.core.copyTo | ||||||
| import io.ktor.utils.io.streams.asInput | import io.ktor.utils.io.streams.* | ||||||
| import io.ktor.utils.io.streams.asOutput |  | ||||||
| import java.io.File | import java.io.File | ||||||
|  |  | ||||||
| class InFilesMessagesFilesCache<K>( | class InFilesMessagesFilesCache<K>( | ||||||
| @@ -39,8 +38,8 @@ class InFilesMessagesFilesCache<K>( | |||||||
|         val file = File(folderFile, fullFileName).apply { |         val file = File(folderFile, fullFileName).apply { | ||||||
|             delete() |             delete() | ||||||
|         } |         } | ||||||
|         inputAllocator().use { input -> |         inputAllocator().inputStream().use { input -> | ||||||
|             file.outputStream().asOutput().use { output -> |             file.outputStream().use { output -> | ||||||
|                 input.copyTo(output) |                 input.copyTo(output) | ||||||
|             } |             } | ||||||
|         } |         } | ||||||
|   | |||||||
| @@ -4,7 +4,7 @@ import dev.inmo.micro_utils.repos.* | |||||||
| import dev.inmo.micro_utils.repos.mappers.withMapper | import dev.inmo.micro_utils.repos.mappers.withMapper | ||||||
| import dev.inmo.tgbotapi.libraries.cache.media.common.MessagesSimpleCache | import dev.inmo.tgbotapi.libraries.cache.media.common.MessagesSimpleCache | ||||||
| import dev.inmo.tgbotapi.types.ChatId | import dev.inmo.tgbotapi.types.ChatId | ||||||
| import dev.inmo.tgbotapi.types.MessageIdentifier | import dev.inmo.tgbotapi.types.MessageId | ||||||
| import dev.inmo.tgbotapi.types.message.content.MessageContent | import dev.inmo.tgbotapi.types.message.content.MessageContent | ||||||
| import kotlinx.serialization.* | import kotlinx.serialization.* | ||||||
| import kotlinx.serialization.builtins.PairSerializer | import kotlinx.serialization.builtins.PairSerializer | ||||||
| @@ -47,7 +47,7 @@ class SimpleKeyValueMessageContentCache<K>( | |||||||
|  |  | ||||||
| val chatIdToMessageIdentifierSerializer = PairSerializer( | val chatIdToMessageIdentifierSerializer = PairSerializer( | ||||||
|     ChatId.serializer(), |     ChatId.serializer(), | ||||||
|     MessageIdentifier.serializer() |     MessageId.serializer() | ||||||
| ) | ) | ||||||
|  |  | ||||||
| val messageContentSerializer = PolymorphicSerializer<MessageContent>(MessageContent::class) | val messageContentSerializer = PolymorphicSerializer<MessageContent>(MessageContent::class) | ||||||
| @@ -56,9 +56,9 @@ inline fun <K> KeyValueRepo<K, MessageContent>.asMessageContentCache() = SimpleK | |||||||
|  |  | ||||||
| inline fun KeyValueRepo<String, String>.asMessageContentCache( | inline fun KeyValueRepo<String, String>.asMessageContentCache( | ||||||
|     serialFormatCreator: (SerializersModule) -> StringFormat = { Json { serializersModule = it } } |     serialFormatCreator: (SerializersModule) -> StringFormat = { Json { serializersModule = it } } | ||||||
| ): StandardKeyValueRepo<Pair<ChatId, MessageIdentifier>, MessageContent> { | ): StandardKeyValueRepo<Pair<ChatId, MessageId>, MessageContent> { | ||||||
|     val serialFormat = serialFormatCreator(MessageContent.serializationModule()) |     val serialFormat = serialFormatCreator(MessageContent.serializationModule()) | ||||||
|     return withMapper<Pair<ChatId, MessageIdentifier>, MessageContent, String, String>( |     return withMapper<Pair<ChatId, MessageId>, MessageContent, String, String>( | ||||||
|         { serialFormat.encodeToString(chatIdToMessageIdentifierSerializer, this) }, |         { serialFormat.encodeToString(chatIdToMessageIdentifierSerializer, this) }, | ||||||
|         { serialFormat.encodeToString(messageContentSerializer, this) }, |         { serialFormat.encodeToString(messageContentSerializer, this) }, | ||||||
|         { serialFormat.decodeFromString(chatIdToMessageIdentifierSerializer, this) }, |         { serialFormat.decodeFromString(chatIdToMessageIdentifierSerializer, this) }, | ||||||
| @@ -70,9 +70,9 @@ inline fun KeyValueRepo<String, String>.asMessageContentCache( | |||||||
| @JsName("stringsKeyValueAsHexMessageContentCache") | @JsName("stringsKeyValueAsHexMessageContentCache") | ||||||
| inline fun KeyValueRepo<String, String>.asMessageContentCache( | inline fun KeyValueRepo<String, String>.asMessageContentCache( | ||||||
|     serialFormatCreator: (SerializersModule) -> BinaryFormat |     serialFormatCreator: (SerializersModule) -> BinaryFormat | ||||||
| ): StandardKeyValueRepo<Pair<ChatId, MessageIdentifier>, MessageContent> { | ): StandardKeyValueRepo<Pair<ChatId, MessageId>, MessageContent> { | ||||||
|     val serialFormat = serialFormatCreator(MessageContent.serializationModule()) |     val serialFormat = serialFormatCreator(MessageContent.serializationModule()) | ||||||
|     return withMapper<Pair<ChatId, MessageIdentifier>, MessageContent, String, String>( |     return withMapper<Pair<ChatId, MessageId>, MessageContent, String, String>( | ||||||
|         { serialFormat.encodeToHexString(chatIdToMessageIdentifierSerializer, this) }, |         { serialFormat.encodeToHexString(chatIdToMessageIdentifierSerializer, this) }, | ||||||
|         { serialFormat.encodeToHexString(messageContentSerializer, this) }, |         { serialFormat.encodeToHexString(messageContentSerializer, this) }, | ||||||
|         { serialFormat.decodeFromHexString(chatIdToMessageIdentifierSerializer, this) }, |         { serialFormat.decodeFromHexString(chatIdToMessageIdentifierSerializer, this) }, | ||||||
| @@ -84,9 +84,9 @@ inline fun KeyValueRepo<String, String>.asMessageContentCache( | |||||||
| @JsName("bytesKeyValueAsMessageContentCache") | @JsName("bytesKeyValueAsMessageContentCache") | ||||||
| inline fun KeyValueRepo<ByteArray, ByteArray>.asMessageContentCache( | inline fun KeyValueRepo<ByteArray, ByteArray>.asMessageContentCache( | ||||||
|     serialFormatCreator: (SerializersModule) -> BinaryFormat |     serialFormatCreator: (SerializersModule) -> BinaryFormat | ||||||
| ): StandardKeyValueRepo<Pair<ChatId, MessageIdentifier>, MessageContent> { | ): StandardKeyValueRepo<Pair<ChatId, MessageId>, MessageContent> { | ||||||
|     val serialFormat = serialFormatCreator(MessageContent.serializationModule()) |     val serialFormat = serialFormatCreator(MessageContent.serializationModule()) | ||||||
|     return withMapper<Pair<ChatId, MessageIdentifier>, MessageContent, ByteArray, ByteArray>( |     return withMapper<Pair<ChatId, MessageId>, MessageContent, ByteArray, ByteArray>( | ||||||
|         { serialFormat.encodeToByteArray(chatIdToMessageIdentifierSerializer, this) }, |         { serialFormat.encodeToByteArray(chatIdToMessageIdentifierSerializer, this) }, | ||||||
|         { serialFormat.encodeToByteArray(messageContentSerializer, this) }, |         { serialFormat.encodeToByteArray(messageContentSerializer, this) }, | ||||||
|         { serialFormat.decodeFromByteArray(chatIdToMessageIdentifierSerializer, this) }, |         { serialFormat.decodeFromByteArray(chatIdToMessageIdentifierSerializer, this) }, | ||||||
|   | |||||||
| @@ -6,21 +6,21 @@ kotlin.incremental=true | |||||||
| kotlin.incremental.js=true | kotlin.incremental.js=true | ||||||
|  |  | ||||||
|  |  | ||||||
| kotlin_version=1.8.22 | kotlin_version=2.0.21 | ||||||
| kotlin_serialisation_core_version=1.5.1 | kotlin_serialisation_core_version=1.7.3 | ||||||
|  |  | ||||||
| github_release_plugin_version=2.4.1 | github_release_plugin_version=2.5.2 | ||||||
|  |  | ||||||
| tgbotapi_version=9.2.1 | tgbotapi_version=20.0.1 | ||||||
| micro_utils_version=0.19.9 | micro_utils_version=0.23.0 | ||||||
| exposed_version=0.41.1 | exposed_version=0.55.0 | ||||||
| plagubot_version=7.2.1 | plagubot_version=10.1.1 | ||||||
|  |  | ||||||
| # Dokka | # Dokka | ||||||
|  |  | ||||||
| dokka_version=1.8.20 | dokka_version=1.9.20 | ||||||
|  |  | ||||||
| # Project data | # Project data | ||||||
|  |  | ||||||
| group=dev.inmo | group=dev.inmo | ||||||
| version=0.15.1 | version=0.26.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.6.1-bin.zip | distributionUrl=https\://services.gradle.org/distributions/gradle-8.9-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" | ||||||
|             } |             } | ||||||
|         } |         } | ||||||
|     } |     } | ||||||
| @@ -37,13 +37,12 @@ kotlin { | |||||||
|         jsTest { |         jsTest { | ||||||
|             dependencies { |             dependencies { | ||||||
|                 implementation kotlin('test-js') |                 implementation kotlin('test-js') | ||||||
|                 implementation kotlin('test-junit') |  | ||||||
|             } |             } | ||||||
|         } |         } | ||||||
|     } |     } | ||||||
| } | } | ||||||
|  |  | ||||||
| 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"}}} | ||||||
| @@ -2,9 +2,12 @@ package dev.inmo.tgbotapi.libraries.resender | |||||||
|  |  | ||||||
| import dev.inmo.tgbotapi.types.FullChatIdentifierSerializer | import dev.inmo.tgbotapi.types.FullChatIdentifierSerializer | ||||||
| import dev.inmo.tgbotapi.types.IdChatIdentifier | import dev.inmo.tgbotapi.types.IdChatIdentifier | ||||||
|  | import dev.inmo.tgbotapi.types.MediaGroupId | ||||||
| import dev.inmo.tgbotapi.types.MessageId | 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.Message | ||||||
| import dev.inmo.tgbotapi.types.message.abstracts.PossiblyMediaGroupMessage | import dev.inmo.tgbotapi.types.message.abstracts.PossiblyMediaGroupMessage | ||||||
|  | import dev.inmo.tgbotapi.types.message.content.MediaGroupContent | ||||||
| import kotlinx.serialization.Serializable | import kotlinx.serialization.Serializable | ||||||
|  |  | ||||||
| @Serializable | @Serializable | ||||||
| @@ -12,8 +15,21 @@ data class MessageMetaInfo( | |||||||
|     @Serializable(FullChatIdentifierSerializer::class) |     @Serializable(FullChatIdentifierSerializer::class) | ||||||
|     val chatId: IdChatIdentifier, |     val chatId: IdChatIdentifier, | ||||||
|     val messageId: MessageId, |     val messageId: MessageId, | ||||||
|     val group: String? = null |     val group: MediaGroupId? = null | ||||||
| ) | ) { | ||||||
|  |     val metaInfo: Message.MetaInfo | ||||||
|  |         get() = Message.MetaInfo(chatId, messageId) | ||||||
|  | } | ||||||
|  |  | ||||||
|  | fun Message.asMessageMetaInfos(): List<MessageMetaInfo> { | ||||||
|  |     return if (this is ContentMessage<*>) { | ||||||
|  |         (content as? MediaGroupContent<*>) ?.group ?.map { | ||||||
|  |             MessageMetaInfo(it.sourceMessage.chat.id, it.sourceMessage.messageId, it.sourceMessage.mediaGroupId) | ||||||
|  |         } | ||||||
|  |     } else { | ||||||
|  |         null | ||||||
|  |     } ?: listOf(MessageMetaInfo(chat.id, messageId, (this as? PossiblyMediaGroupMessage<*>) ?.mediaGroupId)) | ||||||
|  | } | ||||||
|  |  | ||||||
| operator fun MessageMetaInfo.Companion.invoke( | operator fun MessageMetaInfo.Companion.invoke( | ||||||
|     message: Message |     message: Message | ||||||
|   | |||||||
| @@ -1,8 +1,11 @@ | |||||||
| package dev.inmo.tgbotapi.libraries.resender | package dev.inmo.tgbotapi.libraries.resender | ||||||
|  |  | ||||||
|  | import dev.inmo.micro_utils.common.applyDiff | ||||||
| import dev.inmo.tgbotapi.bot.TelegramBot | import dev.inmo.tgbotapi.bot.TelegramBot | ||||||
| import dev.inmo.tgbotapi.requests.ForwardMessage | import dev.inmo.tgbotapi.requests.ForwardMessage | ||||||
|  | import dev.inmo.tgbotapi.requests.ForwardMessages | ||||||
| import dev.inmo.tgbotapi.requests.send.CopyMessage | import dev.inmo.tgbotapi.requests.send.CopyMessage | ||||||
|  | import dev.inmo.tgbotapi.requests.send.CopyMessages | ||||||
| import dev.inmo.tgbotapi.requests.send.media.SendMediaGroup | import dev.inmo.tgbotapi.requests.send.media.SendMediaGroup | ||||||
| import dev.inmo.tgbotapi.types.ChatIdentifier | import dev.inmo.tgbotapi.types.ChatIdentifier | ||||||
| import dev.inmo.tgbotapi.types.IdChatIdentifier | import dev.inmo.tgbotapi.types.IdChatIdentifier | ||||||
| @@ -46,9 +49,9 @@ class MessagesResender( | |||||||
|                             targetChatId, |                             targetChatId, | ||||||
|                             bot.execute( |                             bot.execute( | ||||||
|                                 CopyMessage( |                                 CopyMessage( | ||||||
|                                     targetChatId, |                                     toChatId = targetChatId, | ||||||
|                                     fromChatId = messageInfo.chatId, |                                     fromChatId = messageInfo.chatId, | ||||||
|                                     messageId = messageInfo.messageId |                                     messageId = messageInfo.messageId, | ||||||
|                                 ) |                                 ) | ||||||
|                             ) |                             ) | ||||||
|                         ) |                         ) | ||||||
| @@ -66,7 +69,7 @@ class MessagesResender( | |||||||
|                                 targetChatId, |                                 targetChatId, | ||||||
|                                 bot.execute( |                                 bot.execute( | ||||||
|                                     CopyMessage( |                                     CopyMessage( | ||||||
|                                         targetChatId, |                                         toChatId = targetChatId, | ||||||
|                                         fromChatId = it.chat.id, |                                         fromChatId = it.chat.id, | ||||||
|                                         messageId = it.messageId |                                         messageId = it.messageId | ||||||
|                                     ) |                                     ) | ||||||
| @@ -99,7 +102,7 @@ class MessagesResender( | |||||||
|                                     targetChatId, |                                     targetChatId, | ||||||
|                                     bot.execute( |                                     bot.execute( | ||||||
|                                         CopyMessage( |                                         CopyMessage( | ||||||
|                                             targetChatId, |                                             toChatId = targetChatId, | ||||||
|                                             fromChatId = forwardedMessage.chat.id, |                                             fromChatId = forwardedMessage.chat.id, | ||||||
|                                             messageId = forwardedMessage.messageId |                                             messageId = forwardedMessage.messageId | ||||||
|                                         ) |                                         ) | ||||||
| @@ -115,9 +118,9 @@ class MessagesResender( | |||||||
|                                 targetChatId, |                                 targetChatId, | ||||||
|                                 bot.execute( |                                 bot.execute( | ||||||
|                                     CopyMessage( |                                     CopyMessage( | ||||||
|                                         targetChatId, |                                         toChatId = targetChatId, | ||||||
|                                         it.chat.id, |                                         fromChatId = it.chat.id, | ||||||
|                                         it.messageId |                                         messageId = it.messageId | ||||||
|                                     ) |                                     ) | ||||||
|                                 ) |                                 ) | ||||||
|                             ) |                             ) | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user