diff --git a/data-adapters/adapter-mongodb/src/main/kotlin/com/kotlindiscord/kord/extensions/adapters/mongodb/Constants.kt b/data-adapters/adapter-mongodb/src/main/kotlin/com/kotlindiscord/kord/extensions/adapters/mongodb/Constants.kt index 64095cbfd8..32094f4522 100644 --- a/data-adapters/adapter-mongodb/src/main/kotlin/com/kotlindiscord/kord/extensions/adapters/mongodb/Constants.kt +++ b/data-adapters/adapter-mongodb/src/main/kotlin/com/kotlindiscord/kord/extensions/adapters/mongodb/Constants.kt @@ -10,18 +10,13 @@ import com.kotlindiscord.kord.extensions.adapters.mongodb.codecs.InstantCodec import com.kotlindiscord.kord.extensions.adapters.mongodb.codecs.SnowflakeCodec import com.kotlindiscord.kord.extensions.adapters.mongodb.codecs.StorageTypeCodec import com.kotlindiscord.kord.extensions.utils.env -import com.mongodb.MongoClientSettings import org.bson.codecs.configuration.CodecRegistries import org.bson.codecs.configuration.CodecRegistry internal val MONGODB_URI: String = env("ADAPTER_MONGODB_URI") -public val kordExCodecRegistry: CodecRegistry = CodecRegistries.fromRegistries( - CodecRegistries.fromCodecs( - InstantCodec(), - SnowflakeCodec(), - StorageTypeCodec(), - ), - - MongoClientSettings.getDefaultCodecRegistry(), +public val kordExCodecRegistry: CodecRegistry = CodecRegistries.fromCodecs( + InstantCodec(), + SnowflakeCodec(), + StorageTypeCodec(), ) diff --git a/data-adapters/adapter-mongodb/src/main/kotlin/com/kotlindiscord/kord/extensions/adapters/mongodb/db/Database.kt b/data-adapters/adapter-mongodb/src/main/kotlin/com/kotlindiscord/kord/extensions/adapters/mongodb/db/Database.kt index a2d7a3db7b..9821f31b64 100644 --- a/data-adapters/adapter-mongodb/src/main/kotlin/com/kotlindiscord/kord/extensions/adapters/mongodb/db/Database.kt +++ b/data-adapters/adapter-mongodb/src/main/kotlin/com/kotlindiscord/kord/extensions/adapters/mongodb/db/Database.kt @@ -8,6 +8,7 @@ package com.kotlindiscord.kord.extensions.adapters.mongodb.db import com.kotlindiscord.kord.extensions.adapters.mongodb.MONGODB_URI import com.kotlindiscord.kord.extensions.adapters.mongodb.kordExCodecRegistry +import com.mongodb.MongoClientSettings import com.mongodb.MongoException import com.mongodb.kotlin.client.coroutine.MongoClient import com.mongodb.kotlin.client.coroutine.MongoCollection @@ -15,11 +16,17 @@ import com.mongodb.kotlin.client.coroutine.MongoDatabase import mu.KotlinLogging import org.bson.BsonInt64 import org.bson.Document +import org.bson.codecs.configuration.CodecRegistries internal object Database { private val logger = KotlinLogging.logger {} private val client = MongoClient.create(MONGODB_URI) + private val codecRegistry = CodecRegistries.fromRegistries( + kordExCodecRegistry, + MongoClientSettings.getDefaultCodecRegistry(), + ) + val db: MongoDatabase = client.getDatabase("kordex-data") @Throws(MongoException::class) @@ -36,5 +43,5 @@ internal object Database { inline fun getCollection(name: String): MongoCollection = db .getCollection(name) - .withCodecRegistry(kordExCodecRegistry) + .withCodecRegistry(codecRegistry) }