core-database/org.meshtastic.core.database/DatabaseManager

DatabaseManager

open class DatabaseManager(datastore: DataStore<Preferences>, dispatchers: CoroutineDispatchers) : DatabaseProvider, DatabaseManager(source)

Manages per-device Room database instances for node data, with LRU eviction.

Constructors

DatabaseManager

constructor(datastore: DataStore<Preferences>, dispatchers: CoroutineDispatchers)

Properties

cacheLimit

open override val cacheLimit: StateFlow<Int>

currentAddress

val currentAddress: StateFlow<String?>

currentDb

open override val currentDb: StateFlow<MeshtasticDatabase>

The currently active database, built lazily on first access. Room's onOpen callback is itself lazy (not invoked until the first query), so construction only allocates the builder and connection pool — actual I/O is deferred.

Functions

fun close()

Closes all open databases and cancels background work.

getCurrentCacheLimit

open override fun getCurrentCacheLimit(): Int

hasDatabaseFor

open override fun hasDatabaseFor(address: String?): Boolean

Returns true if a database exists for the given device address. Android Room stores DB files without an extension; JVM/iOS append .db. We check both to stay platform-agnostic.

init

suspend fun init(address: String?)

Initialize the active database for address.

setCacheLimit

open override fun setCacheLimit(limit: Int)

switchActiveDatabase

open suspend override fun switchActiveDatabase(address: String?)

Switch active database to the one associated with address. Serialized via mutex.

withDb

open suspend override fun <T> withDb(block: suspend (MeshtasticDatabase) -> T): T?

Execute block with the current DB instance.