core-data/org.meshtastic.core.data.repository/PacketRepositoryImpl

PacketRepositoryImpl

class PacketRepositoryImpl(dbManager: DatabaseProvider, dispatchers: CoroutineDispatchers) : PacketRepository(source)

Constructors

Link copied to clipboard
constructor(dbManager: DatabaseProvider, dispatchers: CoroutineDispatchers)

Types

Link copied to clipboard
object Companion

Functions

Link copied to clipboard
open suspend override fun applyOutgoingQueueStatus(packet: MeshPacket, status: MessageStatus): PersistedPacket?
Link copied to clipboard
open suspend override fun applyOutgoingReactionQueueStatus(packetId: Int, status: MessageStatus): PersistedReaction?
Link copied to clipboard
open suspend override fun claimQueuedPacket(id: PersistedPacketId): PersistedPacket?
Link copied to clipboard
open suspend override fun claimQueuedPacketByPacketIdIfUnique(packetId: Int): PersistedPacket?
Link copied to clipboard
open suspend override fun clearAllUnreadCounts()
Link copied to clipboard
open suspend override fun clearPacketDB()
Link copied to clipboard
open suspend override fun clearUnreadCount(contact: String, timestamp: Long)
Link copied to clipboard
suspend fun delete(packet: Packet)
Link copied to clipboard
open suspend override fun deleteContacts(contactList: List<String>)
Link copied to clipboard
open suspend override fun deleteMessages(uuidList: List<Long>)
Link copied to clipboard
open suspend override fun deleteWaypoint(id: Int)
Link copied to clipboard
open suspend override fun findPacketsWithId(packetId: Int): List<DataPacket>
Link copied to clipboard
open suspend override fun findReactionsWithId(packetId: Int): List<Reaction>
Link copied to clipboard
open override fun getContacts(): Flow<Map<String, DataPacket>>
Link copied to clipboard
open override fun getContactSettings(): Flow<Map<String, ContactSettings>>
open suspend override fun getContactSettings(contact: String): ContactSettings
Link copied to clipboard
open override fun getContactsPaged(): Flow<PagingData<Pair<String, DataPacket>>>
Link copied to clipboard
open suspend override fun getEnroutePackets(): List<PersistedPacket>
Link copied to clipboard
open suspend override fun getEnrouteReactions(): List<PersistedReaction>
Link copied to clipboard
open suspend override fun getFilteredCount(contactKey: String): Int
Link copied to clipboard
open override fun getFilteredCountFlow(contactKey: String): Flow<Int>
Link copied to clipboard
open override fun getFirstUnreadMessageUuid(contact: String): Flow<Long?>
Link copied to clipboard
open suspend override fun getMessageCount(contact: String): Int
Link copied to clipboard
open suspend override fun getMessagesFrom(contact: String, limit: Int?, includeFiltered: Boolean, getNode: suspend (String?) -> Node): Flow<List<Message>>
Link copied to clipboard
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>>
Link copied to clipboard
open suspend override fun getPacketById(id: Int): DataPacket?
Link copied to clipboard
open suspend override fun getPacketByPacketId(packetId: Int): DataPacket?
Link copied to clipboard
open suspend override fun getPacketByPacketIdIfUnique(packetId: Int): DataPacket?
Link copied to clipboard
open suspend override fun getPacketByPersistedId(id: PersistedPacketId): DataPacket?
Link copied to clipboard
open suspend override fun getQueuedPackets(): List<PersistedPacket>
Link copied to clipboard
open suspend override fun getReactionByPacketId(packetId: Int): Reaction?
Link copied to clipboard
open suspend override fun getUnreadCount(contact: String): Int
Link copied to clipboard
open override fun getUnreadCountFlow(contact: String): Flow<Int>
Link copied to clipboard
open override fun getUnreadCountTotal(): Flow<Int>
Link copied to clipboard
open override fun getWaypoints(): Flow<List<DataPacket>>
Link copied to clipboard
open override fun hasUnreadMessages(contact: String): Flow<Boolean>
Link copied to clipboard
open suspend override fun insert(packet: DataPacket, myNodeNum: Int, contactKey: String, receivedTime: Long, read: Boolean, filtered: Boolean)
Link copied to clipboard
suspend fun insertReaction(reaction: ReactionEntity)
open suspend override fun insertReaction(reaction: Reaction, myNodeNum: Int)
Link copied to clipboard
suspend fun insertRoomPacket(packet: Packet): Long
Link copied to clipboard
open suspend override fun migrateChannelsByPSK(oldSettings: List<ChannelSettings>, newSettings: List<ChannelSettings>)
Link copied to clipboard
open suspend override fun resolveOutgoingPacket(packet: MeshPacket): PersistedPacket?
Link copied to clipboard
open suspend override fun rollbackEnroutePacket(id: PersistedPacketId): Boolean
Link copied to clipboard
open suspend override fun savePacket(myNodeNum: Int, contactKey: String, packet: DataPacket, receivedTime: Long, read: Boolean, filtered: Boolean): PersistedPacketId
Link copied to clipboard
open override fun searchMessages(query: String, contactKey: String?, getNode: (String?) -> Node): Flow<List<Message>>
Link copied to clipboard
open suspend override fun setContactFilteringDisabled(contactKey: String, disabled: Boolean)
Link copied to clipboard
open suspend override fun setMessageTranslation(uuid: Long, translatedText: String)
Link copied to clipboard
open suspend override fun setMuteUntil(contacts: List<String>, until: Long)
Link copied to clipboard
open suspend override fun setShowTranslated(uuid: Long, showTranslated: Boolean)
Link copied to clipboard
open suspend override fun timeOutEnroutePacket(id: PersistedPacketId, routingError: Int): Boolean
Link copied to clipboard
open suspend override fun timeOutEnrouteReaction(id: PersistedReactionId, routingError: Int): Boolean
Link copied to clipboard
suspend fun update(packet: Packet)
open suspend override fun update(packet: DataPacket, routingError: Int)
Link copied to clipboard
open suspend override fun updateFilteredBySender(senderId: String, filtered: Boolean)
Link copied to clipboard
open suspend override fun updateLastReadMessage(contact: String, messageUuid: Long, lastReadTimestamp: Long)
Link copied to clipboard
open suspend override fun updateMessageId(d: DataPacket, id: Int)
Link copied to clipboard
open suspend override fun updateMessageStatus(d: DataPacket, m: MessageStatus)
open suspend override fun updateMessageStatus(id: PersistedPacketId, status: MessageStatus)
Link copied to clipboard
open suspend override fun updateOutgoingMessageStatus(packet: MeshPacket, status: MessageStatus): PersistedPacketId?
Link copied to clipboard
suspend fun updateReaction(reaction: ReactionEntity)
open suspend override fun updateReaction(reaction: Reaction)
Link copied to clipboard
open suspend override fun updateSFPPStatus(packetId: Int, from: Int, to: Int, hash: ByteArray, status: MessageStatus, rxTime: Long, myNodeNum: Int?)
Link copied to clipboard
open suspend override fun updateSFPPStatusByHash(hash: ByteArray, status: MessageStatus, rxTime: Long)
Generated by Dokka
© 2026 Copyright