mirror of
https://github.com/InsanusMokrassar/TelegramBotApiLibraries.git
synced 2026-03-27 20:52:27 +00:00
@@ -34,7 +34,7 @@ class DefaultAdminsCacheAPIRepoImpl(
|
|||||||
private val scope: CoroutineScope
|
private val scope: CoroutineScope
|
||||||
) : DefaultAdminsCacheAPIRepo {
|
) : DefaultAdminsCacheAPIRepo {
|
||||||
private val actor = scope.actorAsync<RepoActions<*>>(Channel.UNLIMITED) {
|
private val actor = scope.actorAsync<RepoActions<*>>(Channel.UNLIMITED) {
|
||||||
safelyWithoutExceptions(
|
runCatchingLogging (
|
||||||
{ e ->
|
{ e ->
|
||||||
it.deferred.completeExceptionally(e)
|
it.deferred.completeExceptionally(e)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ import kotlinx.serialization.*
|
|||||||
import kotlinx.serialization.json.Json
|
import kotlinx.serialization.json.Json
|
||||||
import kotlinx.serialization.modules.SerializersModule
|
import kotlinx.serialization.modules.SerializersModule
|
||||||
import kotlinx.serialization.modules.polymorphic
|
import kotlinx.serialization.modules.polymorphic
|
||||||
import org.jetbrains.exposed.sql.Database
|
import org.jetbrains.exposed.v1.jdbc.Database
|
||||||
|
|
||||||
val telegramAdminsSerializationFormat = Json {
|
val telegramAdminsSerializationFormat = Json {
|
||||||
ignoreUnknownKeys = true
|
ignoreUnknownKeys = true
|
||||||
|
|||||||
@@ -16,7 +16,7 @@ import kotlinx.coroutines.sync.Mutex
|
|||||||
import kotlinx.coroutines.sync.withLock
|
import kotlinx.coroutines.sync.withLock
|
||||||
import kotlinx.serialization.*
|
import kotlinx.serialization.*
|
||||||
import kotlinx.serialization.json.JsonObject
|
import kotlinx.serialization.json.JsonObject
|
||||||
import org.jetbrains.exposed.sql.Database
|
import org.jetbrains.exposed.v1.jdbc.Database
|
||||||
import org.koin.core.Koin
|
import org.koin.core.Koin
|
||||||
import org.koin.core.module.Module
|
import org.koin.core.module.Module
|
||||||
import org.koin.core.qualifier.named
|
import org.koin.core.qualifier.named
|
||||||
|
|||||||
@@ -1,3 +1,5 @@
|
|||||||
|
@file:Suppress("RemoveExplicitTypeArguments", "unused")
|
||||||
|
|
||||||
package dev.inmo.tgbotapi.libraries.cache.media.micro_utils
|
package dev.inmo.tgbotapi.libraries.cache.media.micro_utils
|
||||||
|
|
||||||
import dev.inmo.micro_utils.repos.*
|
import dev.inmo.micro_utils.repos.*
|
||||||
@@ -8,7 +10,6 @@ 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
|
||||||
import kotlinx.serialization.builtins.serializer
|
|
||||||
import kotlinx.serialization.json.Json
|
import kotlinx.serialization.json.Json
|
||||||
import kotlinx.serialization.modules.SerializersModule
|
import kotlinx.serialization.modules.SerializersModule
|
||||||
import kotlin.js.JsName
|
import kotlin.js.JsName
|
||||||
@@ -52,11 +53,12 @@ val chatIdToMessageIdentifierSerializer = PairSerializer(
|
|||||||
|
|
||||||
val messageContentSerializer = PolymorphicSerializer<MessageContent>(MessageContent::class)
|
val messageContentSerializer = PolymorphicSerializer<MessageContent>(MessageContent::class)
|
||||||
|
|
||||||
inline fun <K> KeyValueRepo<K, MessageContent>.asMessageContentCache() = SimpleKeyValueMessageContentCache(this)
|
fun <K> KeyValueRepo<K, MessageContent>.asMessageContentCache() = SimpleKeyValueMessageContentCache(this)
|
||||||
|
|
||||||
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, MessageId>, MessageContent> {
|
): StandardKeyValueRepo<Pair<ChatId, MessageId>, MessageContent> {
|
||||||
|
@Suppress("OPT_IN_USAGE")
|
||||||
val serialFormat = serialFormatCreator(MessageContent.serializationModule())
|
val serialFormat = serialFormatCreator(MessageContent.serializationModule())
|
||||||
return withMapper<Pair<ChatId, MessageId>, MessageContent, String, String>(
|
return withMapper<Pair<ChatId, MessageId>, MessageContent, String, String>(
|
||||||
{ serialFormat.encodeToString(chatIdToMessageIdentifierSerializer, this) },
|
{ serialFormat.encodeToString(chatIdToMessageIdentifierSerializer, this) },
|
||||||
@@ -71,6 +73,7 @@ inline fun KeyValueRepo<String, String>.asMessageContentCache(
|
|||||||
inline fun KeyValueRepo<String, String>.asMessageContentCache(
|
inline fun KeyValueRepo<String, String>.asMessageContentCache(
|
||||||
serialFormatCreator: (SerializersModule) -> BinaryFormat
|
serialFormatCreator: (SerializersModule) -> BinaryFormat
|
||||||
): StandardKeyValueRepo<Pair<ChatId, MessageId>, MessageContent> {
|
): StandardKeyValueRepo<Pair<ChatId, MessageId>, MessageContent> {
|
||||||
|
@Suppress("OPT_IN_USAGE")
|
||||||
val serialFormat = serialFormatCreator(MessageContent.serializationModule())
|
val serialFormat = serialFormatCreator(MessageContent.serializationModule())
|
||||||
return withMapper<Pair<ChatId, MessageId>, MessageContent, String, String>(
|
return withMapper<Pair<ChatId, MessageId>, MessageContent, String, String>(
|
||||||
{ serialFormat.encodeToHexString(chatIdToMessageIdentifierSerializer, this) },
|
{ serialFormat.encodeToHexString(chatIdToMessageIdentifierSerializer, this) },
|
||||||
@@ -85,6 +88,7 @@ inline fun KeyValueRepo<String, String>.asMessageContentCache(
|
|||||||
inline fun KeyValueRepo<ByteArray, ByteArray>.asMessageContentCache(
|
inline fun KeyValueRepo<ByteArray, ByteArray>.asMessageContentCache(
|
||||||
serialFormatCreator: (SerializersModule) -> BinaryFormat
|
serialFormatCreator: (SerializersModule) -> BinaryFormat
|
||||||
): StandardKeyValueRepo<Pair<ChatId, MessageId>, MessageContent> {
|
): StandardKeyValueRepo<Pair<ChatId, MessageId>, MessageContent> {
|
||||||
|
@Suppress("OPT_IN_USAGE")
|
||||||
val serialFormat = serialFormatCreator(MessageContent.serializationModule())
|
val serialFormat = serialFormatCreator(MessageContent.serializationModule())
|
||||||
return withMapper<Pair<ChatId, MessageId>, MessageContent, ByteArray, ByteArray>(
|
return withMapper<Pair<ChatId, MessageId>, MessageContent, ByteArray, ByteArray>(
|
||||||
{ serialFormat.encodeToByteArray(chatIdToMessageIdentifierSerializer, this) },
|
{ serialFormat.encodeToByteArray(chatIdToMessageIdentifierSerializer, this) },
|
||||||
|
|||||||
@@ -6,17 +6,17 @@ kotlin.incremental=true
|
|||||||
kotlin.incremental.js=true
|
kotlin.incremental.js=true
|
||||||
|
|
||||||
|
|
||||||
kotlin_version=2.2.21
|
kotlin_version=2.3.10
|
||||||
kotlin_serialisation_core_version=1.9.0
|
kotlin_serialisation_core_version=1.10.0
|
||||||
|
|
||||||
github_release_plugin_version=2.5.2
|
github_release_plugin_version=2.5.2
|
||||||
|
|
||||||
tgbotapi_version=30.0.2
|
tgbotapi_version=32.0.0
|
||||||
micro_utils_version=0.26.8
|
micro_utils_version=0.29.1
|
||||||
exposed_version=0.61.0
|
exposed_version=1.1.1
|
||||||
plagubot_version=10.10.0
|
plagubot_version=11.0.0
|
||||||
|
|
||||||
nmcp_version=1.3.0
|
nmcp_version=1.4.4
|
||||||
|
|
||||||
# Dokka
|
# Dokka
|
||||||
|
|
||||||
@@ -25,4 +25,4 @@ dokka_version=2.1.0
|
|||||||
# Project data
|
# Project data
|
||||||
|
|
||||||
group=dev.inmo
|
group=dev.inmo
|
||||||
version=0.28.0
|
version=0.29.0
|
||||||
|
|||||||
Reference in New Issue
Block a user