persistence/com.wire.kalium.persistence.db/UserDatabaseBuilder

UserDatabaseBuilder

class UserDatabaseBuilder(userId: UserIDEntity, val sqlDriver: SqlDriver, dispatcher: CoroutineDispatcher, platformDatabaseData: PlatformDatabaseData, isEncrypted: Boolean, val dbInvalidationController: DbInvalidationController, initializeSelfUser: Boolean = true)

Constructors

UserDatabaseBuilder

internal constructor(userId: UserIDEntity, sqlDriver: SqlDriver, dispatcher: CoroutineDispatcher, platformDatabaseData: PlatformDatabaseData, isEncrypted: Boolean, dbInvalidationController: DbInvalidationController, initializeSelfUser: Boolean = true)

Properties

appDAO

val appDAO: AppDAO

assetDAO

val assetDAO: AssetDAO

callDAO

val callDAO: CallDAO

cellFileDao

val cellFileDao: CellFileDao

clientDAO

val clientDAO: ClientDAO

compositeMessageDAO

val compositeMessageDAO: CompositeMessageDAO

connectionDAO

val connectionDAO: ConnectionDAO

conversationDAO

val conversationDAO: ConversationDAO

conversationFolderDAO

val conversationFolderDAO: ConversationFolderDAO

conversationMetaDataDAO

val conversationMetaDataDAO: ConversationMetaDataDAO

database

internal val database: UserDatabase

databaseExporter

val databaseExporter: DatabaseExporter

databaseImporter

val databaseImporter: DatabaseImporter

databaseOptimizer

val databaseOptimizer: DatabaseOptimizer

dbInvalidationController

val dbInvalidationController: DbInvalidationController

debugExtension

val debugExtension: DebugExtension

eventDAO

val eventDAO: EventDAO

historyClientQueries

val historyClientQueries: HistoryClientQueries

meetingDao

val meetingDao: MeetingDao

memberDAO

val memberDAO: MemberDAO

mentionsFeeder

val mentionsFeeder: MentionsFeeder

messageAttachmentDraftDao

val messageAttachmentDraftDao: MessageAttachmentDraftDao

messageAttachments

val messageAttachments: MessageAttachmentsDao

messageDAO

val messageDAO: MessageDAO

messageDraftDAO

val messageDraftDAO: MessageDraftDAOImpl

messageMetaDataDAO

val messageMetaDataDAO: MessageMetadataDAO

messagesFeeder

val messagesFeeder: MessagesFeeder

messageTimelineDAO

val messageTimelineDAO: MessageTimelineDAO

metadataDAO

val metadataDAO: MetadataDAO

newClientDAO

val newClientDAO: NewClientDAO

notificationEventStore

val notificationEventStore: NotificationEventStore

obfuscatedCopyExporter

val obfuscatedCopyExporter: ObfuscatedCopyExporter

pendingActionDAO

val pendingActionDAO: PendingActionDAO

pendingDeliveryConfirmationDAO

val pendingDeliveryConfirmationDAO: PendingDeliveryConfirmationDAO

pendingSubconversationProposalDAO

val pendingSubconversationProposalDAO: PendingSubconversationProposalDAO

pollMessageDAO

val pollMessageDAO: PollMessageDAO

prekeyDAO

val prekeyDAO: PrekeyDAO

publicLinks

val publicLinks: PublicLinkDao

reactionDAO

val reactionDAO: ReactionDAO

reactionFeeder

val reactionFeeder: ReactionsFeeder

readDispatcher

val readDispatcher: ReadDispatcher

receiptDAO

val receiptDAO: ReceiptDAO

searchDAO

val searchDAO: SearchDAO

serviceDAO

val serviceDAO: ServiceDAO

sqlDriver

internal val sqlDriver: SqlDriver

subconversationDAO

val subconversationDAO: SubconversationDAO

teamDAO

val teamDAO: TeamDAO

unreadEventsFeeder

val unreadEventsFeeder: UnreadEventsFeeder

userConfigDAO

val userConfigDAO: UserConfigDAO

userDAO

val userDAO: UserDAO

userPrefsDAO

val userPrefsDAO: UserConfigStorage

writeDispatcher

val writeDispatcher: WriteDispatcher

Functions

fun close()

Stop and await all database users before closing. Failed native cleanup must never appear successful on retry.

dbFileLocation

fun dbFileLocation(): String?

nuke

fun nuke(): Boolean

drops DB connection and delete the DB file

refreshAfterExternalWrites

fun UserDatabaseBuilder.refreshAfterExternalWrites()

Requery retained observers after the NSE may have committed changes through its own driver.

writeMessageEffects

suspend fun <T> writeMessageEffects(block: suspend MessageEffectDAOs.() -> T): T

Apply ordered receiving effects on the writer connection. The supplied DAOs use the same dispatcher for reads and writes, so native transactions never hop to a reader thread. Local file cleanup may run before its SQL references are removed. Callers awaiting network work here must supply a fixed thread dispatcher for the native SQLite driver (as the NSE does).