open suspend override fun getMessagesFrom(contact: String, limit: Int?, includeFiltered: Boolean, getNode: suspend (String?) -> Node): Flow<List<Message>>

getMessagesFromPaged

open override fun getMessagesFromPaged(contact: String, getNode: suspend (String?) -> Node): Flow<PagingData<Message>>

open override fun getMessagesFromPaged(contactKey: String, includeFiltered: Boolean, getNode: suspend (String?) -> Node): Flow<PagingData<Message>>

getPacketById

open suspend override fun getPacketById(id: Int): DataPacket?

getPacketByPacketId

open suspend override fun getPacketByPacketId(packetId: Int): DataPacket?

getQueuedPackets

open suspend override fun getQueuedPackets(): List<DataPacket>

getReactionByPacketId

open suspend override fun getReactionByPacketId(packetId: Int): Reaction?

getUnreadCount

open suspend override fun getUnreadCount(contact: String): Int

getUnreadCountFlow

open override fun getUnreadCountFlow(contact: String): Flow<Int>

getUnreadCountTotal

open override fun getUnreadCountTotal(): Flow<Int>

getWaypoints

open override fun getWaypoints(): Flow<List<DataPacket>>

hasUnreadMessages

open override fun hasUnreadMessages(contact: String): Flow<Boolean>

insert

open suspend override fun insert(packet: DataPacket, myNodeNum: Int, contactKey: String, receivedTime: Long, read: Boolean, filtered: Boolean)

insertReaction

suspend fun insertReaction(reaction: ReactionEntity)

open suspend override fun insertReaction(reaction: Reaction, myNodeNum: Int)

insertRoomPacket

suspend fun insertRoomPacket(packet: Packet)

migrateChannelsByPSK

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

savePacket

open suspend override fun savePacket(myNodeNum: Int, contactKey: String, packet: DataPacket, receivedTime: Long, read: Boolean, filtered: Boolean)

setContactFilteringDisabled

open suspend override fun setContactFilteringDisabled(contactKey: String, disabled: Boolean)

setMuteUntil

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

update

suspend fun update(packet: Packet)

open suspend override fun update(packet: DataPacket, routingError: Int)

updateFilteredBySender

open suspend override fun updateFilteredBySender(senderId: String, filtered: Boolean)

updateLastReadMessage

open suspend override fun updateLastReadMessage(contact: String, messageUuid: Long, lastReadTimestamp: Long)

updateMessageId

open suspend override fun updateMessageId(d: DataPacket, id: Int)

updateMessageStatus

open suspend override fun updateMessageStatus(d: DataPacket, m: MessageStatus)

updateReaction

suspend fun updateReaction(reaction: ReactionEntity)

open suspend override fun updateReaction(reaction: Reaction)

updateSFPPStatus

open suspend override fun updateSFPPStatus(packetId: Int, from: Int, to: Int, hash: ByteArray, status: MessageStatus, rxTime: Long, myNodeNum: Int?)

updateSFPPStatusByHash

open suspend override fun updateSFPPStatusByHash(hash: ByteArray, status: MessageStatus, rxTime: Long)