mirror of
				https://github.com/InsanusMokrassar/TelegramBotApiLibraries.git
				synced 2025-10-31 12:10:15 +00:00 
			
		
		
		
	Compare commits
	
		
			38 Commits
		
	
	
		
			0.0.10
			...
			ec69456bcc
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| ec69456bcc | |||
| 6327366720 | |||
| 0f05779e0d | |||
| be1b13debb | |||
| 043948401d | |||
| cde0a11c1b | |||
| 7e37a43904 | |||
| 5305438686 | |||
| f423d31423 | |||
| 6591c8ffa8 | |||
| 5d6d4a0ade | |||
| 5a31a5566c | |||
| fecbfc4130 | |||
| bf3c4bc11f | |||
| 2ef2d60213 | |||
| a1c2e48622 | |||
| ffdf808a89 | |||
| ef8bc50bd9 | |||
| df5dea4915 | |||
| 989f3af9db | |||
| 4c0cdc8d1e | |||
| ce132cb4e7 | |||
| c519881800 | |||
| 17d7fe6659 | |||
| 63af9ba8e0 | |||
| b5d0eda79d | |||
| 5d32bf567c | |||
| 0444d5fe8d | |||
| ea18b23a2c | |||
| 271d094f10 | |||
| 4335e6e1cd | |||
| d2d7578be4 | |||
| 2105fa5718 | |||
| 165a3a9856 | |||
| f811968b05 | |||
| c2e3b49786 | |||
| 6d813ef142 | |||
| 9083b888c6 | 
							
								
								
									
										5
									
								
								.github/workflows/commit-publish.yml
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										5
									
								
								.github/workflows/commit-publish.yml
									
									
									
									
										vendored
									
									
								
							| @@ -7,7 +7,10 @@ jobs: | |||||||
|       - uses: actions/checkout@v2 |       - uses: actions/checkout@v2 | ||||||
|       - uses: actions/setup-java@v1 |       - uses: actions/setup-java@v1 | ||||||
|         with: |         with: | ||||||
|           java-version: 1.8 |           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 "[^/]*$"`" | ||||||
|   | |||||||
							
								
								
									
										1
									
								
								.gitignore
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										1
									
								
								.gitignore
									
									
									
									
										vendored
									
									
								
							| @@ -11,5 +11,6 @@ out/ | |||||||
|  |  | ||||||
| secret.gradle | secret.gradle | ||||||
| local.properties | local.properties | ||||||
|  | kotlin-js-store/ | ||||||
|  |  | ||||||
| publishing.sh | publishing.sh | ||||||
|   | |||||||
| @@ -1,6 +1,5 @@ | |||||||
| buildscript { | buildscript { | ||||||
|     repositories { |     repositories { | ||||||
|         jcenter() |  | ||||||
|         google() |         google() | ||||||
|         mavenCentral() |         mavenCentral() | ||||||
|         mavenLocal() |         mavenLocal() | ||||||
| @@ -8,7 +7,7 @@ buildscript { | |||||||
|     } |     } | ||||||
|  |  | ||||||
|     dependencies { |     dependencies { | ||||||
|         classpath 'com.android.tools.build:gradle:4.1.3' |         classpath 'com.android.tools.build:gradle:7.0.4' | ||||||
|         classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version" |         classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version" | ||||||
|         classpath "org.jetbrains.kotlin:kotlin-serialization:$kotlin_version" |         classpath "org.jetbrains.kotlin:kotlin-serialization:$kotlin_version" | ||||||
|         classpath "com.getkeepsafe.dexcount:dexcount-gradle-plugin:$dexcount_version" |         classpath "com.getkeepsafe.dexcount:dexcount-gradle-plugin:$dexcount_version" | ||||||
| @@ -19,10 +18,8 @@ buildscript { | |||||||
| allprojects { | allprojects { | ||||||
|     repositories { |     repositories { | ||||||
|         mavenLocal() |         mavenLocal() | ||||||
|         jcenter() |  | ||||||
|         mavenCentral() |         mavenCentral() | ||||||
|         google() |         google() | ||||||
|         maven { url "https://kotlin.bintray.com/kotlinx" } |  | ||||||
|     } |     } | ||||||
| } | } | ||||||
|  |  | ||||||
|   | |||||||
| @@ -51,12 +51,12 @@ class DefaultAdminsCacheAPIRepo( | |||||||
|     } |     } | ||||||
|  |  | ||||||
|     override suspend fun getChatAdmins(chatId: ChatId): List<AdministratorChatMember>? = suspendCoroutine { |     override suspend fun getChatAdmins(chatId: ChatId): List<AdministratorChatMember>? = suspendCoroutine { | ||||||
|         actor.offer(GetChatAdminsRepoAction(chatId, it)) |         actor.trySend(GetChatAdminsRepoAction(chatId, it)) | ||||||
|     } |     } | ||||||
|     override suspend fun setChatAdmins(chatId: ChatId, chatMembers: List<AdministratorChatMember>) = suspendCoroutine<Unit> { |     override suspend fun setChatAdmins(chatId: ChatId, chatMembers: List<AdministratorChatMember>) = suspendCoroutine<Unit> { | ||||||
|         actor.offer(SetChatAdminsRepoAction(chatId, chatMembers, it)) |         actor.trySend(SetChatAdminsRepoAction(chatId, chatMembers, it)) | ||||||
|     } |     } | ||||||
|     override suspend fun lastUpdate(chatId: ChatId): DateTime? = suspendCoroutine { |     override suspend fun lastUpdate(chatId: ChatId): DateTime? = suspendCoroutine { | ||||||
|         actor.offer(GetUpdateDateTimeRepoAction(chatId, it)) |         actor.trySend(GetUpdateDateTimeRepoAction(chatId, it)) | ||||||
|     } |     } | ||||||
| } | } | ||||||
|   | |||||||
| @@ -6,3 +6,13 @@ plugins { | |||||||
| 
 | 
 | ||||||
| apply from: "$mppProjectWithSerializationPresetPath" | apply from: "$mppProjectWithSerializationPresetPath" | ||||||
| 
 | 
 | ||||||
|  | kotlin { | ||||||
|  |     sourceSets { | ||||||
|  |         commonMain { | ||||||
|  |             dependencies { | ||||||
|  |                 api "dev.inmo:tgbotapi.core:$tgbotapi_version" | ||||||
|  |             } | ||||||
|  |         } | ||||||
|  |     } | ||||||
|  | } | ||||||
|  | 
 | ||||||
| @@ -0,0 +1,128 @@ | |||||||
|  | package dev.inmo.tgbotapi.libraries.cache.media.common | ||||||
|  |  | ||||||
|  | import dev.inmo.tgbotapi.bot.TelegramBot | ||||||
|  | import dev.inmo.tgbotapi.requests.DownloadFileStream | ||||||
|  | import dev.inmo.tgbotapi.requests.abstracts.MultipartFile | ||||||
|  | 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.InputMedia.* | ||||||
|  | import dev.inmo.tgbotapi.types.message.content.abstracts.MediaContent | ||||||
|  | import dev.inmo.tgbotapi.types.message.content.abstracts.MessageContent | ||||||
|  | import dev.inmo.tgbotapi.utils.asInput | ||||||
|  | import io.ktor.utils.io.core.Input | ||||||
|  |  | ||||||
|  | class DefaultMessageContentCache<K>( | ||||||
|  |     private val bot: TelegramBot, | ||||||
|  |     private val filesRefreshingChatId: ChatId, | ||||||
|  |     private val simpleMessageContentCache: MessagesSimpleCache<K>, | ||||||
|  |     private val messagesFilesCache: MessagesFilesCache<K> = InMemoryMessagesFilesCache() | ||||||
|  | ) : MessageContentCache<K> { | ||||||
|  |     override suspend fun save(content: MessageContent): K { | ||||||
|  |         return when (content) { | ||||||
|  |             is MediaContent -> { | ||||||
|  |                 val extendedInfo = bot.execute( | ||||||
|  |                     GetFile(content.media.fileId) | ||||||
|  |                 ) | ||||||
|  |                 val allocator = bot.execute( | ||||||
|  |                     DownloadFileStream( | ||||||
|  |                         extendedInfo.filePath | ||||||
|  |                     ) | ||||||
|  |                 ) | ||||||
|  |  | ||||||
|  |                 save(content, extendedInfo.fileName) { | ||||||
|  |                     allocator.invoke().asInput() | ||||||
|  |                 } | ||||||
|  |             } | ||||||
|  |             else -> simpleMessageContentCache.add(content) | ||||||
|  |         } | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     override suspend fun save( | ||||||
|  |         content: MediaContent, | ||||||
|  |         filename: String, | ||||||
|  |         inputAllocator: suspend () -> Input | ||||||
|  |     ): K { | ||||||
|  |         val key = simpleMessageContentCache.add(content) | ||||||
|  |         runCatching { | ||||||
|  |             messagesFilesCache.set(key, filename, inputAllocator) | ||||||
|  |         }.onFailure { | ||||||
|  |             simpleMessageContentCache.remove(key) | ||||||
|  |         } | ||||||
|  |  | ||||||
|  |         return key | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     override suspend fun get(k: K): MessageContent? { | ||||||
|  |         val savedSimpleContent = simpleMessageContentCache.get(k) ?: return null | ||||||
|  |  | ||||||
|  |         if (savedSimpleContent is MediaContent) { | ||||||
|  |             runCatching { | ||||||
|  |                 bot.execute(GetFile(savedSimpleContent.media.fileId)) | ||||||
|  |             }.onFailure { | ||||||
|  |                 val savedFileContentAllocator = messagesFilesCache.get(k) ?: error("Unexpected absence of $k file for content ($simpleMessageContentCache)") | ||||||
|  |                 val newContent = bot.execute( | ||||||
|  |                     when (savedSimpleContent.asInputMedia()) { | ||||||
|  |                         is InputMediaAnimation -> SendAnimation( | ||||||
|  |                             filesRefreshingChatId, | ||||||
|  |                             MultipartFile( | ||||||
|  |                                 savedFileContentAllocator | ||||||
|  |                             ), | ||||||
|  |                             disableNotification = true | ||||||
|  |                         ) | ||||||
|  |                         is InputMediaAudio -> SendAudio( | ||||||
|  |                             filesRefreshingChatId, | ||||||
|  |                             MultipartFile( | ||||||
|  |                                 savedFileContentAllocator | ||||||
|  |                             ), | ||||||
|  |                             disableNotification = true | ||||||
|  |                         ) | ||||||
|  |                         is InputMediaVideo -> SendVideo( | ||||||
|  |                             filesRefreshingChatId, | ||||||
|  |                             MultipartFile( | ||||||
|  |                                 savedFileContentAllocator | ||||||
|  |                             ), | ||||||
|  |                             disableNotification = true | ||||||
|  |                         ) | ||||||
|  |                         is InputMediaDocument -> SendDocument( | ||||||
|  |                             filesRefreshingChatId, | ||||||
|  |                             MultipartFile( | ||||||
|  |                                 savedFileContentAllocator | ||||||
|  |                             ), | ||||||
|  |                             disableNotification = true | ||||||
|  |                         ) | ||||||
|  |                         is InputMediaPhoto -> SendPhoto( | ||||||
|  |                             filesRefreshingChatId, | ||||||
|  |                             MultipartFile( | ||||||
|  |                                 savedFileContentAllocator | ||||||
|  |                             ), | ||||||
|  |                             disableNotification = true | ||||||
|  |                         ) | ||||||
|  |                     } | ||||||
|  |                 ) | ||||||
|  |  | ||||||
|  |                 simpleMessageContentCache.update(k, newContent.content) | ||||||
|  |                 return newContent.content | ||||||
|  |             } | ||||||
|  |         } | ||||||
|  |         return savedSimpleContent | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     override suspend fun contains(k: K): Boolean { | ||||||
|  |         return simpleMessageContentCache.contains(k) | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     override suspend fun remove(k: K) { | ||||||
|  |         simpleMessageContentCache.remove(k) | ||||||
|  |         messagesFilesCache.remove(k) | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     companion object { | ||||||
|  |         operator fun invoke( | ||||||
|  |             bot: TelegramBot, | ||||||
|  |             filesRefreshingChatId: ChatId, | ||||||
|  |             simpleMessageContentCache: MessagesSimpleCache<String> = InMemoryMessagesSimpleCache(), | ||||||
|  |             messagesFilesCache: MessagesFilesCache<String> = InMemoryMessagesFilesCache() | ||||||
|  |         ) = DefaultMessageContentCache(bot, filesRefreshingChatId, simpleMessageContentCache, messagesFilesCache) | ||||||
|  |     } | ||||||
|  | } | ||||||
| @@ -0,0 +1,17 @@ | |||||||
|  | package dev.inmo.tgbotapi.libraries.cache.media.common | ||||||
|  |  | ||||||
|  | import dev.inmo.tgbotapi.types.message.content.abstracts.MediaContent | ||||||
|  | import dev.inmo.tgbotapi.types.message.content.abstracts.MessageContent | ||||||
|  | import io.ktor.utils.io.core.Input | ||||||
|  |  | ||||||
|  | interface MessageContentCache<K> { | ||||||
|  |     suspend fun save(content: MessageContent): K | ||||||
|  |     suspend fun save( | ||||||
|  |         content: MediaContent, | ||||||
|  |         filename: String, | ||||||
|  |         inputAllocator: suspend () -> Input | ||||||
|  |     ): K | ||||||
|  |     suspend fun get(k: K): MessageContent? | ||||||
|  |     suspend fun contains(k: K): Boolean | ||||||
|  |     suspend fun remove(k: K) | ||||||
|  | } | ||||||
| @@ -0,0 +1,41 @@ | |||||||
|  | package dev.inmo.tgbotapi.libraries.cache.media.common | ||||||
|  |  | ||||||
|  | import dev.inmo.tgbotapi.types.ChatId | ||||||
|  | import dev.inmo.tgbotapi.types.MessageIdentifier | ||||||
|  | import dev.inmo.tgbotapi.utils.StorageFile | ||||||
|  | import io.ktor.utils.io.core.* | ||||||
|  |  | ||||||
|  | interface MessagesFilesCache<K> { | ||||||
|  |     suspend fun set(k: K, filename: String, inputAllocator: suspend () -> Input) | ||||||
|  |     suspend fun get(k: K): StorageFile? | ||||||
|  |     suspend fun remove(k: K) | ||||||
|  |     suspend fun contains(k: K): Boolean | ||||||
|  | } | ||||||
|  |  | ||||||
|  | /** | ||||||
|  |  * It is not recommended to use in production realization of [MessagesFilesCache] which has been created for fast | ||||||
|  |  * start of application creation with usage of [MessageContentCache] with aim to replace this realization by some | ||||||
|  |  * disks-oriented one | ||||||
|  |  */ | ||||||
|  | class InMemoryMessagesFilesCache<K> : MessagesFilesCache<K> { | ||||||
|  |     private val map = mutableMapOf<K, StorageFile>() | ||||||
|  |  | ||||||
|  |     override suspend fun set(k: K, filename: String, inputAllocator: suspend () -> Input) { | ||||||
|  |         map[k] = StorageFile( | ||||||
|  |             filename, | ||||||
|  |             inputAllocator().readBytes() | ||||||
|  |         ) | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     override suspend fun get(k: K): StorageFile? { | ||||||
|  |         return map[k] | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     override suspend fun remove(k: K) { | ||||||
|  |         map.remove(k) | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     override suspend fun contains(k: K): Boolean { | ||||||
|  |         return map.contains(k) | ||||||
|  |     } | ||||||
|  | } | ||||||
| @@ -0,0 +1,63 @@ | |||||||
|  | package dev.inmo.tgbotapi.libraries.cache.media.common | ||||||
|  |  | ||||||
|  | import com.benasher44.uuid.uuid4 | ||||||
|  | import dev.inmo.tgbotapi.types.message.content.abstracts.MessageContent | ||||||
|  |  | ||||||
|  | interface MessagesSimpleCache<K> { | ||||||
|  |     suspend fun add(content: MessageContent): K | ||||||
|  |     suspend fun update(k: K, content: MessageContent): Boolean | ||||||
|  |     suspend fun get(k: K): MessageContent? | ||||||
|  |     suspend fun remove(k: K) | ||||||
|  |     suspend fun contains(k: K): Boolean | ||||||
|  | } | ||||||
|  |  | ||||||
|  | /** | ||||||
|  |  * It is not recommended to use in production realization of [MessagesFilesCache] which has been created for fast | ||||||
|  |  * start of application creation with usage of [MessageContentCache] with aim to replace this realization by some | ||||||
|  |  * disks-oriented one | ||||||
|  |  */ | ||||||
|  | class InMemoryMessagesSimpleCache<K>( | ||||||
|  |     private val keyGenerator: () -> K | ||||||
|  | ) : MessagesSimpleCache<K> { | ||||||
|  |     private val map = mutableMapOf<K, MessageContent>() | ||||||
|  |  | ||||||
|  |     override suspend fun add( | ||||||
|  |         content: MessageContent | ||||||
|  |     ): K { | ||||||
|  |         val key = keyGenerator() | ||||||
|  |         map[key] = content | ||||||
|  |         return key | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     override suspend fun update( | ||||||
|  |         k: K, | ||||||
|  |         content: MessageContent | ||||||
|  |     ): Boolean { | ||||||
|  |         return map.runCatching { | ||||||
|  |             if (contains(k)) { | ||||||
|  |                 put(k, content) | ||||||
|  |                 true | ||||||
|  |             } else { | ||||||
|  |                 false | ||||||
|  |             } | ||||||
|  |         }.getOrDefault(false) | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     override suspend fun get(k: K): MessageContent? { | ||||||
|  |         return map[k] | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     override suspend fun remove(k: K) { | ||||||
|  |         map.remove(k) | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     override suspend fun contains(k: K): Boolean { | ||||||
|  |         return map.contains(k) | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     companion object { | ||||||
|  |         operator fun invoke() = InMemoryMessagesSimpleCache { | ||||||
|  |             uuid4().toString() | ||||||
|  |         } | ||||||
|  |     } | ||||||
|  | } | ||||||
| @@ -0,0 +1,74 @@ | |||||||
|  | package dev.inmo.tgbotapi.libraries.cache.media.common | ||||||
|  |  | ||||||
|  | import dev.inmo.tgbotapi.utils.* | ||||||
|  | import io.ktor.utils.io.core.Input | ||||||
|  | import io.ktor.utils.io.core.copyTo | ||||||
|  | import io.ktor.utils.io.streams.asInput | ||||||
|  | import io.ktor.utils.io.streams.asOutput | ||||||
|  | import java.io.File | ||||||
|  |  | ||||||
|  | class InFilesMessagesFilesCache<K>( | ||||||
|  |     private val folderFile: File, | ||||||
|  |     private val filePrefixBuilder: (K) -> String | ||||||
|  | ) : MessagesFilesCache<K> { | ||||||
|  |     private val K.storageFile: StorageFile? | ||||||
|  |         get() { | ||||||
|  |             val prefix = filePrefix(this) | ||||||
|  |             val filename = folderFile.list() ?.firstOrNull { it.startsWith(prefix) } ?: return null | ||||||
|  |             val file = File(folderFile, filename) | ||||||
|  |             val storageFileFilename = file.name.removePrefix("$prefix ") | ||||||
|  |  | ||||||
|  |             return StorageFile( | ||||||
|  |                 StorageFileInfo(storageFileFilename) | ||||||
|  |             ) { | ||||||
|  |                 file.inputStream().asInput() | ||||||
|  |             } | ||||||
|  |         } | ||||||
|  |  | ||||||
|  |     init { | ||||||
|  |         require(!folderFile.isFile) { "Folder of messages files cache can't be file, but was $folderFile" } | ||||||
|  |         folderFile.mkdirs() | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     private fun filePrefix(k: K): String = filePrefixBuilder(k) | ||||||
|  |  | ||||||
|  |     private fun fileName(k: K, filename: String): String { | ||||||
|  |         return "${filePrefix(k)} $filename" | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     override suspend fun set(k: K, filename: String, inputAllocator: suspend () -> Input) { | ||||||
|  |         val fullFileName = fileName(k, filename) | ||||||
|  |         val file = File(folderFile, fullFileName).apply { | ||||||
|  |             delete() | ||||||
|  |         } | ||||||
|  |         inputAllocator().use { input -> | ||||||
|  |             file.outputStream().asOutput().use { output -> | ||||||
|  |                 input.copyTo(output) | ||||||
|  |             } | ||||||
|  |         } | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     override suspend fun get(k: K): StorageFile? { | ||||||
|  |         return k.storageFile | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     override suspend fun remove(k: K) { | ||||||
|  |         val prefix = filePrefix(k) | ||||||
|  |         folderFile.listFiles() ?.forEach { | ||||||
|  |             if (it.name.startsWith(prefix)) { | ||||||
|  |                 it.delete() | ||||||
|  |             } | ||||||
|  |         } | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     override suspend fun contains(k: K): Boolean { | ||||||
|  |         val prefix = filePrefix(k) | ||||||
|  |         return folderFile.list() ?.any { it.startsWith(prefix) } == true | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     companion object { | ||||||
|  |         operator fun invoke(folderFile: File) = InFilesMessagesFilesCache<String>( | ||||||
|  |             folderFile | ||||||
|  |         ) { it } | ||||||
|  |     } | ||||||
|  | } | ||||||
							
								
								
									
										1
									
								
								cache/content/common/src/main/AndroidManifest.xml
									
									
									
									
										vendored
									
									
										Normal file
									
								
							
							
						
						
									
										1
									
								
								cache/content/common/src/main/AndroidManifest.xml
									
									
									
									
										vendored
									
									
										Normal file
									
								
							| @@ -0,0 +1 @@ | |||||||
|  | <manifest package="dev.inmo.tgbotapi.libraries.cache.content.common"/> | ||||||
							
								
								
									
										19
									
								
								cache/content/micro_utils/build.gradle
									
									
									
									
										vendored
									
									
										Normal file
									
								
							
							
						
						
									
										19
									
								
								cache/content/micro_utils/build.gradle
									
									
									
									
										vendored
									
									
										Normal file
									
								
							| @@ -0,0 +1,19 @@ | |||||||
|  | plugins { | ||||||
|  |     id "org.jetbrains.kotlin.multiplatform" | ||||||
|  |     id "org.jetbrains.kotlin.plugin.serialization" | ||||||
|  |     id "com.android.library" | ||||||
|  | } | ||||||
|  |  | ||||||
|  | apply from: "$mppProjectWithSerializationPresetPath" | ||||||
|  |  | ||||||
|  | kotlin { | ||||||
|  |     sourceSets { | ||||||
|  |         commonMain { | ||||||
|  |             dependencies { | ||||||
|  |                 api "dev.inmo:micro_utils.repos.common:$micro_utils_version" | ||||||
|  |                 api project(":tgbotapi.libraries.cache.content.common") | ||||||
|  |             } | ||||||
|  |         } | ||||||
|  |     } | ||||||
|  | } | ||||||
|  |  | ||||||
| @@ -0,0 +1,104 @@ | |||||||
|  | package dev.inmo.tgbotapi.libraries.cache.media.micro_utils | ||||||
|  |  | ||||||
|  | import com.benasher44.uuid.uuid4 | ||||||
|  | import dev.inmo.micro_utils.repos.* | ||||||
|  | import dev.inmo.micro_utils.repos.mappers.withMapper | ||||||
|  | import dev.inmo.tgbotapi.libraries.cache.media.common.MessagesSimpleCache | ||||||
|  | import dev.inmo.tgbotapi.types.ChatId | ||||||
|  | import dev.inmo.tgbotapi.types.MessageIdentifier | ||||||
|  | import dev.inmo.tgbotapi.types.message.content.abstracts.MessageContent | ||||||
|  | import kotlinx.serialization.* | ||||||
|  | import kotlinx.serialization.builtins.PairSerializer | ||||||
|  | import kotlinx.serialization.builtins.serializer | ||||||
|  | import kotlinx.serialization.json.Json | ||||||
|  | import kotlinx.serialization.modules.SerializersModule | ||||||
|  | import kotlin.js.JsName | ||||||
|  | import kotlin.jvm.JvmName | ||||||
|  |  | ||||||
|  | class SimpleKeyValueMessageContentCache<K>( | ||||||
|  |     private val keyValueRepo: KeyValueRepo<K, MessageContent>, | ||||||
|  |     private val keyGenerator: () -> K | ||||||
|  | ) : MessagesSimpleCache<K> { | ||||||
|  |     override suspend fun add(content: MessageContent): K { | ||||||
|  |         val key = keyGenerator() | ||||||
|  |         keyValueRepo.set(key, content) | ||||||
|  |  | ||||||
|  |         return key | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     override suspend fun update(k: K, content: MessageContent): Boolean { | ||||||
|  |         return keyValueRepo.runCatching { | ||||||
|  |             if (contains(k)) { | ||||||
|  |                 keyValueRepo.set(k, content) | ||||||
|  |                 true | ||||||
|  |             } else { | ||||||
|  |                 false | ||||||
|  |             } | ||||||
|  |         }.getOrDefault(false) | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     override suspend fun get(k: K): MessageContent? { | ||||||
|  |         return keyValueRepo.get(k) | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     override suspend fun contains(k: K): Boolean { | ||||||
|  |         return keyValueRepo.contains(k) | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     override suspend fun remove(k: K) { | ||||||
|  |         keyValueRepo.unset(k) | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     companion object { | ||||||
|  |         operator fun invoke( | ||||||
|  |             keyValueRepo: KeyValueRepo<String, MessageContent> | ||||||
|  |         ) = SimpleKeyValueMessageContentCache(keyValueRepo) { uuid4().toString() } | ||||||
|  |     } | ||||||
|  | } | ||||||
|  |  | ||||||
|  | val chatIdToMessageIdentifierSerializer = PairSerializer( | ||||||
|  |     ChatId.serializer(), | ||||||
|  |     MessageIdentifier.serializer() | ||||||
|  | ) | ||||||
|  |  | ||||||
|  | val messageContentSerializer = PolymorphicSerializer<MessageContent>(MessageContent::class) | ||||||
|  |  | ||||||
|  | inline fun KeyValueRepo<String, String>.asMessageContentCache( | ||||||
|  |     serialFormatCreator: (SerializersModule) -> StringFormat = { Json { serializersModule = it } } | ||||||
|  | ): StandardKeyValueRepo<Pair<ChatId, MessageIdentifier>, MessageContent> { | ||||||
|  |     val serialFormat = serialFormatCreator(MessageContent.serializationModule()) | ||||||
|  |     return withMapper<Pair<ChatId, MessageIdentifier>, MessageContent, String, String>( | ||||||
|  |         { serialFormat.encodeToString(chatIdToMessageIdentifierSerializer, this) }, | ||||||
|  |         { serialFormat.encodeToString(messageContentSerializer, this) }, | ||||||
|  |         { serialFormat.decodeFromString(chatIdToMessageIdentifierSerializer, this) }, | ||||||
|  |         { serialFormat.decodeFromString(messageContentSerializer, this) }, | ||||||
|  |     ) | ||||||
|  | } | ||||||
|  |  | ||||||
|  | @JvmName("stringsKeyValueAsHexMessageContentCache") | ||||||
|  | @JsName("stringsKeyValueAsHexMessageContentCache") | ||||||
|  | inline fun KeyValueRepo<String, String>.asMessageContentCache( | ||||||
|  |     serialFormatCreator: (SerializersModule) -> BinaryFormat | ||||||
|  | ): StandardKeyValueRepo<Pair<ChatId, MessageIdentifier>, MessageContent> { | ||||||
|  |     val serialFormat = serialFormatCreator(MessageContent.serializationModule()) | ||||||
|  |     return withMapper<Pair<ChatId, MessageIdentifier>, MessageContent, String, String>( | ||||||
|  |         { serialFormat.encodeToHexString(chatIdToMessageIdentifierSerializer, this) }, | ||||||
|  |         { serialFormat.encodeToHexString(messageContentSerializer, this) }, | ||||||
|  |         { serialFormat.decodeFromHexString(chatIdToMessageIdentifierSerializer, this) }, | ||||||
|  |         { serialFormat.decodeFromHexString(messageContentSerializer, this) }, | ||||||
|  |     ) | ||||||
|  | } | ||||||
|  |  | ||||||
|  | @JvmName("bytesKeyValueAsMessageContentCache") | ||||||
|  | @JsName("bytesKeyValueAsMessageContentCache") | ||||||
|  | inline fun KeyValueRepo<ByteArray, ByteArray>.asMessageContentCache( | ||||||
|  |     serialFormatCreator: (SerializersModule) -> BinaryFormat | ||||||
|  | ): StandardKeyValueRepo<Pair<ChatId, MessageIdentifier>, MessageContent> { | ||||||
|  |     val serialFormat = serialFormatCreator(MessageContent.serializationModule()) | ||||||
|  |     return withMapper<Pair<ChatId, MessageIdentifier>, MessageContent, ByteArray, ByteArray>( | ||||||
|  |         { serialFormat.encodeToByteArray(chatIdToMessageIdentifierSerializer, this) }, | ||||||
|  |         { serialFormat.encodeToByteArray(messageContentSerializer, this) }, | ||||||
|  |         { serialFormat.decodeFromByteArray(chatIdToMessageIdentifierSerializer, this) }, | ||||||
|  |         { serialFormat.decodeFromByteArray(messageContentSerializer, this) }, | ||||||
|  |     ) | ||||||
|  | } | ||||||
							
								
								
									
										1
									
								
								cache/content/micro_utils/src/main/AndroidManifest.xml
									
									
									
									
										vendored
									
									
										Normal file
									
								
							
							
						
						
									
										1
									
								
								cache/content/micro_utils/src/main/AndroidManifest.xml
									
									
									
									
										vendored
									
									
										Normal file
									
								
							| @@ -0,0 +1 @@ | |||||||
|  | <manifest package="dev.inmo.tgbotapi.libraries.cache.content.micro_utils"/> | ||||||
							
								
								
									
										1
									
								
								cache/media/src/main/AndroidManifest.xml
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										1
									
								
								cache/media/src/main/AndroidManifest.xml
									
									
									
									
										vendored
									
									
								
							| @@ -1 +0,0 @@ | |||||||
| <manifest package="dev.inmo.tgbotapi.libraries.cache.media"/> |  | ||||||
| @@ -6,32 +6,32 @@ kotlin.incremental.js=true | |||||||
| android.useAndroidX=true | android.useAndroidX=true | ||||||
| android.enableJetifier=true | android.enableJetifier=true | ||||||
|  |  | ||||||
| kotlin_version=1.5.10 | kotlin_version=1.6.10 | ||||||
| kotlin_serialisation_core_version=1.2.1 | kotlin_serialisation_core_version=1.3.2 | ||||||
|  |  | ||||||
| github_release_plugin_version=2.2.12 | github_release_plugin_version=2.2.12 | ||||||
|  |  | ||||||
| tgbotapi_version=0.35.0 | tgbotapi_version=0.38.12 | ||||||
| micro_utils_version=0.5.12 | micro_utils_version=0.9.20 | ||||||
| exposed_version=0.32.1 | exposed_version=0.37.3 | ||||||
| plagubot_version=0.3.0 | plagubot_version=0.5.1 | ||||||
|  |  | ||||||
| # ANDROID | # ANDROID | ||||||
|  |  | ||||||
| android_minSdkVersion=21 | android_minSdkVersion=21 | ||||||
| android_compileSdkVersion=30 | android_compileSdkVersion=32 | ||||||
| android_buildToolsVersion=30.0.3 | android_buildToolsVersion=32.0.0 | ||||||
| dexcount_version=2.0.0 | dexcount_version=3.0.1 | ||||||
| junit_version=4.12 | junit_version=4.12 | ||||||
| test_ext_junit_version=1.1.2 | test_ext_junit_version=1.1.2 | ||||||
| espresso_core=3.3.0 | espresso_core=3.3.0 | ||||||
|  |  | ||||||
| # Dokka | # Dokka | ||||||
|  |  | ||||||
| dokka_version=1.4.32 | dokka_version=1.6.10 | ||||||
|  |  | ||||||
| # Project data | # Project data | ||||||
|  |  | ||||||
| group=dev.inmo | group=dev.inmo | ||||||
| version=0.0.10 | version=0.0.17 | ||||||
| android_code_version=9 | android_code_version=17 | ||||||
|   | |||||||
							
								
								
									
										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-6.8.2-bin.zip | distributionUrl=https\://services.gradle.org/distributions/gradle-7.4.1-bin.zip | ||||||
| zipStoreBase=GRADLE_USER_HOME | zipStoreBase=GRADLE_USER_HOME | ||||||
| zipStorePath=wrapper/dists | zipStorePath=wrapper/dists | ||||||
|   | |||||||
| @@ -28,3 +28,8 @@ kotlin { | |||||||
|         } |         } | ||||||
|     } |     } | ||||||
| } | } | ||||||
|  |  | ||||||
|  | java { | ||||||
|  |     sourceCompatibility = JavaVersion.VERSION_1_8 | ||||||
|  |     targetCompatibility = JavaVersion.VERSION_1_8 | ||||||
|  | } | ||||||
|   | |||||||
| @@ -47,4 +47,9 @@ kotlin { | |||||||
|     } |     } | ||||||
| } | } | ||||||
|  |  | ||||||
|  | java { | ||||||
|  |     sourceCompatibility = JavaVersion.VERSION_1_8 | ||||||
|  |     targetCompatibility = JavaVersion.VERSION_1_8 | ||||||
|  | } | ||||||
|  |  | ||||||
| apply from: "$defaultAndroidSettingsPresetPath" | apply from: "$defaultAndroidSettingsPresetPath" | ||||||
|   | |||||||
| @@ -38,14 +38,42 @@ publishing { | |||||||
|             } |             } | ||||||
|         } |         } | ||||||
|         repositories { |         repositories { | ||||||
|             maven { |             if ((project.hasProperty('GITHUBPACKAGES_USER') || System.getenv('GITHUBPACKAGES_USER') != null) && (project.hasProperty('GITHUBPACKAGES_PASSWORD') || System.getenv('GITHUBPACKAGES_PASSWORD') != null)) { | ||||||
|                 name = "GithubPackages" |                 maven { | ||||||
|                 url = uri("https://maven.pkg.github.com/InsanusMokrassar/TelegramBotApiLibraries") |                     name = "GithubPackages" | ||||||
|                 credentials { |                     url = uri("https://maven.pkg.github.com/InsanusMokrassar/TelegramBotApiLibraries") | ||||||
|                     username = project.hasProperty('GITHUBPACKAGES_USER') ? project.property('GITHUBPACKAGES_USER') : System.getenv('GITHUBPACKAGES_USER') |                     credentials { | ||||||
|                     password = project.hasProperty('GITHUBPACKAGES_PASSWORD') ? project.property('GITHUBPACKAGES_PASSWORD') : System.getenv('GITHUBPACKAGES_PASSWORD') |                         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('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') | ||||||
|  |                     } | ||||||
|                 } |                 } | ||||||
|             } |             } | ||||||
|         } |         } | ||||||
|     } |     } | ||||||
| } | } | ||||||
|  |      | ||||||
|  | if (project.hasProperty("signing.gnupg.keyName")) { | ||||||
|  |     apply plugin: 'signing' | ||||||
|  |      | ||||||
|  |     signing { | ||||||
|  |         useGpgCmd() | ||||||
|  |      | ||||||
|  |         sign publishing.publications | ||||||
|  |     } | ||||||
|  |      | ||||||
|  |     task signAll { | ||||||
|  |         tasks.withType(Sign).forEach { | ||||||
|  |             dependsOn(it) | ||||||
|  |         } | ||||||
|  |     } | ||||||
|  | } | ||||||
|   | |||||||
							
								
								
									
										1
									
								
								publish.kpsb
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										1
									
								
								publish.kpsb
									
									
									
									
									
										Normal file
									
								
							| @@ -0,0 +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"}}} | ||||||
| @@ -1 +0,0 @@ | |||||||
| {"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","includeGpgSigning":false,"developers":[{"id":"InsanusMokrassar","name":"Ovsiannikov Aleksei","eMail":"ovsyannikov.alexey95@gmail.com"}],"repositories":[{"name":"GithubPackages","url":"https://maven.pkg.github.com/InsanusMokrassar/TelegramBotApiLibraries"}]}} |  | ||||||
| @@ -4,13 +4,15 @@ String[] includes = [ | |||||||
|     ":cache:admins:common", |     ":cache:admins:common", | ||||||
|     ":cache:admins:micro_utils", |     ":cache:admins:micro_utils", | ||||||
|     ":cache:admins:plagubot", |     ":cache:admins:plagubot", | ||||||
|     ":cache:media" |  | ||||||
|  |     ":cache:content:common", | ||||||
|  |     ":cache:content:micro_utils", | ||||||
| ] | ] | ||||||
|  |  | ||||||
|  |  | ||||||
| includes.each { originalName -> | includes.each { originalName -> | ||||||
|     String projectDirectory = "${rootProject.projectDir.getAbsolutePath()}${originalName.replaceAll(":", File.separator)}" |     String projectDirectory = "${rootProject.projectDir.getAbsolutePath()}${originalName.replace(":", File.separator)}" | ||||||
|     String projectName = "${rootProject.name}${originalName.replaceAll(":", ".")}" |     String projectName = "${rootProject.name}${originalName.replace(":", ".")}" | ||||||
|     String projectIdentifier = ":${projectName}" |     String projectIdentifier = ":${projectName}" | ||||||
|     include projectIdentifier |     include projectIdentifier | ||||||
|     ProjectDescriptor project = project(projectIdentifier) |     ProjectDescriptor project = project(projectIdentifier) | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user