core-database/org.meshtastic.core.database.dao/PacketDao

PacketDao

Functions

open suspend fun backfillMessageTexts(): Int

Populates Packet.messageText for historical text packets that predate the FTS5 schema (v39) so they become searchable. The text is decoded in Kotlin from each packet's DataPacket.text; it cannot be read with a SQL json_extract(data, '$.text') because DataPacket.text is a computed property that is never serialized into the stored JSON (the payload is persisted as bytes). Returns the number of rows updated; the caller rebuilds the FTS index via rebuildFtsIndex when this is greater than zero.

clearAllUnreadCounts

abstract suspend fun clearAllUnreadCounts()

clearUnreadCount

abstract suspend fun clearUnreadCount(contact: String, timestamp: Long)

countPacketsNeedingBackfill

abstract suspend fun countPacketsNeedingBackfill(): Int

delete

abstract suspend fun delete(uuid: Long)

open suspend fun delete(packet: Packet)

deleteAll

open suspend fun deleteAll()

deleteAllContactSettings

abstract suspend fun deleteAllContactSettings()

deleteAllPackets

abstract suspend fun deleteAllPackets()

deleteAllReactions

abstract suspend fun deleteAllReactions()

deleteContacts

abstract suspend fun deleteContacts(contactList: List<String>)

deleteMessages

open suspend fun deleteMessages(uuidList: List<Long>)

deletePackets

abstract suspend fun deletePackets(uuidList: List<Long>)

deleteReactions

abstract suspend fun deleteReactions(packetIds: List<Int>)

deleteWaypoint

open suspend fun deleteWaypoint(id: Int)

findDataPacket

abstract suspend fun findDataPacket(data: DataPacket): Packet?

findPacketBySfppHash

abstract suspend fun findPacketBySfppHash(hash: ByteString): Packet?

findPacketsWithId

abstract suspend fun findPacketsWithId(packetId: Int): List<Packet>

findReactionBySfppHash

abstract suspend fun findReactionBySfppHash(hash: ByteString): ReactionEntity?

findReactionsWithId

abstract suspend fun findReactionsWithId(packetId: Int): List<ReactionEntity>

getAllContactSettingsSnapshot

abstract suspend fun getAllContactSettingsSnapshot(): List<ContactSettings>

getAllDataPackets

abstract suspend fun getAllDataPackets(): List<DataPacket>

getAllPackets

abstract fun getAllPackets(portNum: Int): Flow<List<Packet>>

getAllPacketsSnapshot

abstract suspend fun getAllPacketsSnapshot(): List<Packet>

getAllReactionsSnapshot

abstract suspend fun getAllReactionsSnapshot(): List<ReactionEntity>

getAllUserPacketsForMigration

abstract suspend fun getAllUserPacketsForMigration(): List<Packet>

getAllWaypoints

abstract suspend fun getAllWaypoints(): List<Packet>

getContactFilteringDisabled

abstract suspend fun getContactFilteringDisabled(contact: String): Boolean?

getContactKeys

abstract fun getContactKeys(): Flow<Map<String, Packet>>

getContactKeysPaged

abstract fun getContactKeysPaged(): PagingSource<Int, Packet>

getContactSettings

abstract fun getContactSettings(): Flow<Map<String, ContactSettings>>

abstract suspend fun getContactSettings(contact: String): ContactSettings?

getDataPackets

abstract suspend fun getDataPackets(): List<DataPacket>

getFilteredCount

abstract suspend fun getFilteredCount(contact: String): Int

getFilteredCountFlow

abstract fun getFilteredCountFlow(contact: String): Flow<Int>

getFirstUnreadMessageUuid

abstract fun getFirstUnreadMessageUuid(contact: String): Flow<Long?>

getMessageCount

abstract suspend fun getMessageCount(contact: String): Int

getMessagesFrom

abstract fun getMessagesFrom(contact: String): Flow<List<PacketEntity>>

abstract fun getMessagesFrom(contact: String, includeFiltered: Boolean): Flow<List<PacketEntity>>

abstract fun getMessagesFrom(contact: String, limit: Int): Flow<List<PacketEntity>>

getMessagesFromPaged

abstract fun getMessagesFromPaged(contact: String): PagingSource<Int, PacketEntity>

abstract fun getMessagesFromPaged(contact: String, includeFiltered: Boolean): PagingSource<Int, PacketEntity>

getPacketById

abstract suspend fun getPacketById(requestId: Int): Packet?

getPacketByPacketId

abstract suspend fun getPacketByPacketId(packetId: Int): PacketEntity?

getPacketIdsFrom

abstract suspend fun getPacketIdsFrom(uuidList: List<Long>): List<Int>

getPacketsByPacketIds

abstract suspend fun getPacketsByPacketIds(packetIds: List<Int>): List<PacketEntity>

getPacketsNeedingBackfill

abstract suspend fun getPacketsNeedingBackfill(): List<Packet>

getReactionByPacketId

abstract suspend fun getReactionByPacketId(packetId: Int): ReactionEntity?

getUnreadCount

abstract suspend fun getUnreadCount(contact: String): Int

getUnreadCountFlow

abstract fun getUnreadCountFlow(contact: String): Flow<Int>

getUnreadCountTotal

abstract fun getUnreadCountTotal(): Flow<Int>

hasUnreadMessages

abstract fun hasUnreadMessages(contact: String): Flow<Boolean>

insert

abstract suspend fun insert(packet: Packet)

abstract suspend fun insert(reaction: ReactionEntity)

insertContactSettingsIgnore

abstract suspend fun insertContactSettingsIgnore(contacts: List<ContactSettings>)

insertPacketForMerge

abstract suspend fun insertPacketForMerge(packet: Packet)

Insert a packet copied from another DB. Pass uuid = 0 so a fresh auto-generated id is assigned.

insertReactionsIgnore

abstract suspend fun insertReactionsIgnore(reactions: List<ReactionEntity>)

migrateChannelsByPSK

open suspend fun migrateChannelsByPSK(oldSettings: List<ChannelSettings>, newSettings: List<ChannelSettings>)

One-time migration: Remap all message DataPacket.channel indices to new mapping using PSK after a channel reorder. For each Packet (with port_num = 1), finds the old PSK then sets the channel index to the matching newSettings index. Skips if PSKs do not match or are missing.

rebuildFtsIndex

abstract suspend fun rebuildFtsIndex()

searchMessages

abstract suspend fun searchMessages(query: String): List<Packet>

searchMessagesInConversation

abstract suspend fun searchMessagesInConversation(query: String, contactKey: String): List<Packet>

setContactFilteringDisabled

open suspend fun setContactFilteringDisabled(contact: String, disabled: Boolean)

setMuteUntil

open suspend fun setMuteUntil(contacts: List<String>, until: Long)

setShowTranslated

abstract suspend fun setShowTranslated(uuid: Long, show: Boolean)

setTranslation

abstract suspend fun setTranslation(uuid: Long, translatedText: String)

Persists an on-device translation and switches the message to display it in one write.

update

abstract suspend fun update(packet: Packet)

abstract suspend fun update(reaction: ReactionEntity)

updateFilteredBySender

abstract suspend fun updateFilteredBySender(senderIdPattern: String, filtered: Boolean)

updateMessageId

open suspend fun updateMessageId(data: DataPacket, id: Int)

updateMessageStatus

open suspend fun updateMessageStatus(data: DataPacket, m: MessageStatus)

updateMessageText

abstract suspend fun updateMessageText(uuid: Long, text: String)

updateMuteUntil

abstract suspend fun updateMuteUntil(contactKeys: List<String>, muteUntil: Long)

upsertContactSettings

abstract suspend fun upsertContactSettings(contacts: List<ContactSettings>)