mirror of
https://github.com/InsanusMokrassar/TelegramBotApiLibraries.git
synced 2025-10-26 17:50:20 +00:00
Compare commits
47 Commits
0.0.7
...
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 | |||
| 7ac8effb5f | |||
| 4dc009b222 | |||
| 0ace1c760d | |||
| c4e7e05ff2 | |||
| 681848a908 | |||
| 1e2cf00ffe | |||
| d940a266ac | |||
| cdbcf29409 | |||
| a88b6d17a2 |
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
|
||||||
|
|||||||
@@ -3,5 +3,5 @@
|
|||||||
This project was created due to neccessity of additional libraries over [tgbotapi](https://github.com/InsanusMokrassar/TelegramBotAPI).
|
This project was created due to neccessity of additional libraries over [tgbotapi](https://github.com/InsanusMokrassar/TelegramBotAPI).
|
||||||
Currently there are plans to create several libraries at the start of this project:
|
Currently there are plans to create several libraries at the start of this project:
|
||||||
|
|
||||||
* Cache library for media (saving and autorefreshing of `fileId`)
|
* Cache library for media (saving and autorefreshing of `fileId`) (**currently in TBD state**)
|
||||||
* Cache library for admins (saving chat admins, autoupdate and refreshing by command (maybe))
|
* Cache library for admins (saving chat admins, autoupdate and refreshing by command (maybe)) (you may retrieve it using github packages for now)
|
||||||
|
|||||||
@@ -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.0.2'
|
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.4.32
|
kotlin_version=1.6.10
|
||||||
kotlin_serialisation_core_version=1.1.0
|
kotlin_serialisation_core_version=1.3.2
|
||||||
|
|
||||||
github_release_plugin_version=2.2.12
|
github_release_plugin_version=2.2.12
|
||||||
|
|
||||||
tgbotapi_version=0.34.0
|
tgbotapi_version=0.38.12
|
||||||
micro_utils_version=0.4.36
|
micro_utils_version=0.9.20
|
||||||
exposed_version=0.31.1
|
exposed_version=0.37.3
|
||||||
plagubot_version=0.2.0
|
plagubot_version=0.5.1
|
||||||
|
|
||||||
# ANDROID
|
# ANDROID
|
||||||
|
|
||||||
android_minSdkVersion=21
|
android_minSdkVersion=21
|
||||||
android_compileSdkVersion=30
|
android_compileSdkVersion=32
|
||||||
android_buildToolsVersion=30.0.2
|
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.20
|
dokka_version=1.6.10
|
||||||
|
|
||||||
# Project data
|
# Project data
|
||||||
|
|
||||||
group=dev.inmo
|
group=dev.inmo
|
||||||
version=0.0.7
|
version=0.0.17
|
||||||
android_code_version=6
|
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
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
project.version = "$version" + System.getenv("additional_version")
|
project.version = "$version"
|
||||||
project.group = "$group"
|
project.group = "$group"
|
||||||
|
|
||||||
apply from: "$publishGradlePath"
|
apply from: "$publishGradlePath"
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
project.version = "$version" + System.getenv("additional_version")
|
project.version = "$version"
|
||||||
project.group = "$group"
|
project.group = "$group"
|
||||||
|
|
||||||
apply from: "$publishGradlePath"
|
apply from: "$publishGradlePath"
|
||||||
@@ -28,3 +28,8 @@ kotlin {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
java {
|
||||||
|
sourceCompatibility = JavaVersion.VERSION_1_8
|
||||||
|
targetCompatibility = JavaVersion.VERSION_1_8
|
||||||
|
}
|
||||||
|
|||||||
@@ -4,10 +4,8 @@ project.group = "$group"
|
|||||||
apply from: "$publishGradlePath"
|
apply from: "$publishGradlePath"
|
||||||
|
|
||||||
kotlin {
|
kotlin {
|
||||||
jvm {
|
jvm()
|
||||||
compilations.main.kotlinOptions.useIR = true
|
js (IR) {
|
||||||
}
|
|
||||||
js (BOTH) {
|
|
||||||
browser()
|
browser()
|
||||||
nodejs()
|
nodejs()
|
||||||
}
|
}
|
||||||
@@ -49,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