core-data/org.meshtastic.core.data.manager/NodeManagerImpl

NodeManagerImpl

class NodeManagerImpl(nodeRepository: NodeRepository, notificationManager: NotificationManager, radioInterfaceService: RadioInterfaceService, scope: ServiceScope) : NodeManager(source)

Implementation of NodeManager that maintains an in-memory database of the mesh.

Constructors

NodeManagerImpl

constructor(nodeRepository: NodeRepository, notificationManager: NotificationManager, radioInterfaceService: RadioInterfaceService, scope: ServiceScope)

Types

Companion

object Companion

Properties

allowNodeDbWrites

open override val allowNodeDbWrites: MutableStateFlow<Boolean>

connectionIdentity

open override val connectionIdentity: StateFlow<ConnectionIdentity?>

firmwareEdition

open override val firmwareEdition: MutableStateFlow<FirmwareEdition?>

isNodeDbReady

open override val isNodeDbReady: MutableStateFlow<Boolean>

myDeviceId

open override val myDeviceId: MutableStateFlow<String?>

myNodeNum

open override val myNodeNum: MutableStateFlow<Int?>

nodeDBbyNodeNum

open override val nodeDBbyNodeNum: Map<Int, Node>

Functions

applyTrustedIdentityMigrations

open override fun applyTrustedIdentityMigrations(removedNums: Collection<Int>)

clear

open override fun clear()

clearConnectionIdentity

open override fun clearConnectionIdentity()

clearStaleConnectionIdentity

open override fun clearStaleConnectionIdentity(activeSessionGeneration: Long)

getMyId

open override fun getMyId(): String

getMyNodeInfo

open override fun getMyNodeInfo(): MyNodeInfo?

getNodeById

open override fun getNodeById(id: String): Node?

handleReceivedNodeStatus

open override fun handleReceivedNodeStatus(fromNum: Int, s: StatusMessage, session: RadioSessionContext?)

handleReceivedPaxcounter

open override fun handleReceivedPaxcounter(fromNum: Int, p: Paxcount, session: RadioSessionContext?)

handleReceivedPosition

open override fun handleReceivedPosition(fromNum: Int, myNodeNum: Int, p: Position, defaultTime: Long, session: RadioSessionContext?)

handleReceivedTelemetry

open override fun handleReceivedTelemetry(fromNum: Int, telemetry: Telemetry)

handleReceivedUser

open override fun handleReceivedUser(fromNum: Int, p: User, channel: Int, manuallyVerified: Boolean, session: RadioSessionContext?)

insertMetadata

open override fun insertMetadata(nodeNum: Int, metadata: DeviceMetadata, session: RadioSessionContext?)

installNodeInfo

open override fun installNodeInfo(info: NodeInfo)

installNodeInfoAndPersist

open suspend override fun installNodeInfoAndPersist(info: NodeInfo)

loadCachedNodeDB

open override fun loadCachedNodeDB()

publishConnectionIdentity

open override fun publishConnectionIdentity(sessionGeneration: Long, address: String, nodeNum: Int, deviceId: String?)

removeByNodenum

open override fun removeByNodenum(nodeNum: Int)

setAllowNodeDbWrites

open override fun setAllowNodeDbWrites(allowed: Boolean)

setFirmwareEdition

open override fun setFirmwareEdition(edition: FirmwareEdition?)

setMyDeviceId

open override fun setMyDeviceId(id: String?)

setMyNodeNum

open override fun setMyNodeNum(num: Int?)

setNodeDbReady

open override fun setNodeDbReady(ready: Boolean)

toNodeID

open override fun toNodeID(nodeNum: Int): String

updateNode

open override fun updateNode(nodeNum: Int, channel: Int, transform: (Node) -> Node)

updateNodeAndPersist

open suspend override fun updateNodeAndPersist(nodeNum: Int, channel: Int, transform: (Node) -> Node)

updateNodeForSession

open override fun updateNodeForSession(nodeNum: Int, session: RadioSessionContext, channel: Int, transform: (Node) -> Node)

updateNodeStatus

open override fun updateNodeStatus(nodeNum: Int, status: String?)

updateNodeStatusAndPersist

open suspend override fun updateNodeStatusAndPersist(nodeNum: Int, status: String?)