import io.realm.kotlin.Realm
import io.realm.kotlin.RealmConfiguration
import io.realm.kotlin.types.RealmObject
import io.realm.kotlin.types.TypedRealmObject
import kotlinx.coroutines.flow.map
import kotlin.reflect.KClass

class Database {
    private val db: Realm

    init {
        val config = RealmConfiguration.create(schema = setOf(LocalUser::class))
        db = Realm.open(config)
    }



    suspend fun add(manga: RealmObject) {
        db.write {
            copyToRealm(manga)
        }
    }

    fun <T : TypedRealmObject> queryFirstLive(clazz: KClass<T>) =
        db.query(clazz).first().asFlow().map { it.obj }

    suspend fun deleteAll() {
        db.write {
            deleteAll()
        }
    }

    fun close() {
        if (!db.isClosed())
            db.close()
    }

}

 private fun setupStrictMode() {
        val policy = ThreadPolicy.Builder()
            .detectDiskReads()
            .detectDiskWrites()
            .penaltyDeath() // This will cause the app to crash on violation
            .build()
        StrictMode.setThreadPolicy(policy)
    }