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

NodeRepositoryImpl

class NodeRepositoryImpl(processLifecycle: Lifecycle, nodeInfoReadDataSource: NodeInfoReadDataSource, nodeInfoWriteDataSource: NodeInfoWriteDataSource, dispatchers: CoroutineDispatchers, localStatsDataSource: LocalStatsDataSource) : NodeRepository(source)

Repository for managing node-related data, including hardware info, node database, and identity.

Constructors

NodeRepositoryImpl

constructor(processLifecycle: Lifecycle, nodeInfoReadDataSource: NodeInfoReadDataSource, nodeInfoWriteDataSource: NodeInfoWriteDataSource, dispatchers: CoroutineDispatchers, localStatsDataSource: LocalStatsDataSource)

Properties

localStats

open override val localStats: StateFlow<LocalStats>

The latest local stats telemetry received from the locally connected node.

myId

open override val myId: StateFlow<String?>

The unique userId (hex string) of our local node.

myNodeInfo

open override val myNodeInfo: StateFlow<MyNodeInfo?>

Hardware info about our local device (can be null if not connected).

nodeDBbyNum

open override val nodeDBbyNum: StateFlow<Map<Int, Node>>

A reactive map from nodeNum to Node objects, representing the entire mesh.

onlineNodeCount

open override val onlineNodeCount: Flow<Int>

Flow emitting the count of nodes currently considered "online".

ourNodeInfo

open override val ourNodeInfo: StateFlow<Node?>

Information about the locally connected node, as seen from the mesh.

totalNodeCount

open override val totalNodeCount: Flow<Int>

Flow emitting the total number of nodes in the database.

Functions

clearMyNodeInfo

open suspend override fun clearMyNodeInfo()

Clears the local node's connection info.

clearNodeDB

open suspend override fun clearNodeDB(preserveFavorites: Boolean)

Deletes all nodes from the database, optionally preserving favorites.

deleteNode

open suspend override fun deleteNode(num: Int)

Deletes a node and its metadata by num.

deleteNodes

open suspend override fun deleteNodes(nodeNums: List<Int>)

Deletes multiple nodes and their metadata.

effectiveLogNodeId

open override fun effectiveLogNodeId(nodeNum: Int): Flow<Int>

Returns the node number used for log queries. Maps nodeNum to MeshLog.NODE_NUM_LOCAL (0) if it is the locally connected node.

getNode

open override fun getNode(userId: String): Node

Returns the Node associated with a given userId. Falls back to a generic node if not found.

getNodeEntityDBbyNumFlow

fun getNodeEntityDBbyNumFlow(): Flow<Map<Int, NodeEntity>>

getNodes

open override fun getNodes(sort: NodeSortOption, filter: String, includeUnknown: Boolean, onlyOnline: Boolean, onlyDirect: Boolean): Flow<List<Node>>

Returns a flow of nodes filtered and sorted according to the parameters.

getNodesOlderThan

open suspend override fun getNodesOlderThan(lastHeard: Int): List<Node>

getUnknownNodes

open suspend override fun getUnknownNodes(): List<Node>

getUser

open override fun getUser(nodeNum: Int): User

Returns the User info for a given nodeNum.

open override fun getUser(userId: String): User

Returns the User info for a given userId. Falls back to a generic user if not found.

insertMetadata

open suspend override fun insertMetadata(nodeNum: Int, metadata: DeviceMetadata)

Persists hardware metadata for a node.

installConfig

open suspend override fun installConfig(mi: MyNodeInfo, nodes: List<Node>)

Installs initial configuration data (local info and remote nodes) into the database.

setNodeNotes

open suspend override fun setNodeNotes(num: Int, notes: String)

updateLocalStats

open override fun updateLocalStats(stats: LocalStats)

Update the cached local stats telemetry.

upsert

open suspend override fun upsert(node: Node)

Upserts a Node to the database.