69 lines
2.6 KiB
Kotlin
69 lines
2.6 KiB
Kotlin
package dev.inmo.tgbotapi.libraries.cache.admins
|
|
|
|
import dev.inmo.micro_utils.repos.exposed.keyvalue.ExposedKeyValueRepo
|
|
import dev.inmo.micro_utils.repos.exposed.onetomany.ExposedOneToManyKeyValueRepo
|
|
import dev.inmo.micro_utils.repos.mappers.withMapper
|
|
import dev.inmo.tgbotapi.bot.TelegramBot
|
|
import dev.inmo.tgbotapi.extensions.behaviour_builder.BehaviourContext
|
|
import dev.inmo.tgbotapi.libraries.cache.admins.micro_utils.DefaultAdminsCacheAPIRepo
|
|
import dev.inmo.tgbotapi.libraries.cache.admins.micro_utils.DynamicAdminsCacheSettingsAPI
|
|
import dev.inmo.tgbotapi.types.*
|
|
import dev.inmo.tgbotapi.types.ChatMember.abstracts.AdministratorChatMember
|
|
import kotlinx.coroutines.CoroutineScope
|
|
import kotlinx.serialization.cbor.Cbor
|
|
import kotlinx.serialization.decodeFromByteArray
|
|
import kotlinx.serialization.encodeToByteArray
|
|
import org.jetbrains.exposed.sql.Database
|
|
import org.jetbrains.exposed.sql.statements.api.ExposedBlob
|
|
|
|
private val serializationFormat = Cbor
|
|
|
|
fun AdminsCacheAPI(
|
|
bot: TelegramBot,
|
|
database: Database,
|
|
scope: CoroutineScope
|
|
) : AdminsCacheAPI = DefaultAdminsCacheAPI(
|
|
bot,
|
|
DefaultAdminsCacheAPIRepo(
|
|
ExposedOneToManyKeyValueRepo(
|
|
database,
|
|
{ long("chatId") },
|
|
{ blob("member") },
|
|
"AdminsTable"
|
|
).withMapper<ChatId, AdministratorChatMember, Identifier, ExposedBlob>(
|
|
keyFromToTo = { chatId },
|
|
valueFromToTo = { ExposedBlob(serializationFormat.encodeToByteArray(this)) },
|
|
keyToToFrom = { toChatId() },
|
|
valueToToFrom = { serializationFormat.decodeFromByteArray(bytes) }
|
|
),
|
|
ExposedKeyValueRepo(
|
|
database,
|
|
{ long("chatId") },
|
|
{ long("datetime") },
|
|
"AdminsUpdatesTimesTable"
|
|
).withMapper<ChatId, Long, Identifier, Long>(
|
|
keyFromToTo = { chatId },
|
|
valueFromToTo = { this },
|
|
keyToToFrom = { toChatId() },
|
|
valueToToFrom = { this }
|
|
),
|
|
scope
|
|
),
|
|
DynamicAdminsCacheSettingsAPI(
|
|
ExposedKeyValueRepo(
|
|
database,
|
|
{ long("chatId") },
|
|
{ blob("settings") },
|
|
"DynamicAdminsCacheSettingsAPI"
|
|
).withMapper<ChatId, AdminsCacheSettings, Identifier, ExposedBlob>(
|
|
keyFromToTo = { chatId },
|
|
valueFromToTo = { ExposedBlob(serializationFormat.encodeToByteArray(this)) },
|
|
keyToToFrom = { toChatId() },
|
|
valueToToFrom = { serializationFormat.decodeFromByteArray(bytes) }
|
|
),
|
|
scope
|
|
)
|
|
)
|
|
|
|
fun BehaviourContext.AdminsCacheAPI(database: Database) = AdminsCacheAPI(this, database, this)
|