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

PacketDao

interface PacketDao(source)

Functions

clearAllUnreadCounts

abstract suspend fun clearAllUnreadCounts()

clearUnreadCount

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

abstract suspend fun delete(uuid: Long)

open suspend fun delete(packet: Packet)

open suspend fun deleteAll()

deleteAllContactSettings

abstract suspend fun deleteAllContactSettings()

deleteAllPackets

abstract suspend fun deleteAllPackets()

deleteAllReactions

abstract suspend fun deleteAllReactions()

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

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

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

deleteReactions

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

open suspend fun deleteWaypoint(id: Int)

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>

getAllDataPackets

abstract suspend fun getAllDataPackets(): List<DataPacket>

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

getAllUserPacketsForMigration

abstract suspend fun getAllUserPacketsForMigration(): List<Packet>

getAllWaypoints

abstract suspend fun getAllWaypoints(): List<Packet>

getContactFilteringDisabled

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

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?

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>

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>

getReactionByPacketId

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

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>

abstract suspend fun insert(packet: Packet)

abstract suspend fun insert(reaction: ReactionEntity)

insertContactSettingsIgnore

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

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.

setContactFilteringDisabled

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

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

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)

updateMuteUntil

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

upsertContactSettings

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