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

DiscoveryDao

interface DiscoveryDao(source)

Inheritors

SwitchingDiscoveryDao

Functions

deleteSession

abstract suspend fun deleteSession(sessionId: Long)

getAllSessions

abstract fun getAllSessions(): Flow<List<DiscoverySessionEntity>>

getAllSessionsSnapshot

abstract suspend fun getAllSessionsSnapshot(): List<DiscoverySessionEntity>

Snapshot used by DatabaseMerger to append a transport's discovery sessions to the unified DB.

getDiscoveredNodes

abstract suspend fun getDiscoveredNodes(presetResultId: Long): List<DiscoveredNodeEntity>

getDiscoveredNodesFlow

abstract fun getDiscoveredNodesFlow(presetResultId: Long): Flow<List<DiscoveredNodeEntity>>

getInterruptedSession

abstract suspend fun getInterruptedSession(deviceAddress: String): DiscoverySessionEntity?

The most recent recoverable session for deviceAddress. This includes active/interrupted scans and terminal scans whose home-radio restoration is still pending, so callers must inspect completionStatus rather than assuming an unfinished scan.

getMaxDistance

abstract suspend fun getMaxDistance(sessionId: Long): Double?

getPresetResults

abstract suspend fun getPresetResults(sessionId: Long): List<DiscoveryPresetResultEntity>

getPresetResultsFlow

abstract fun getPresetResultsFlow(sessionId: Long): Flow<List<DiscoveryPresetResultEntity>>

getSession

abstract suspend fun getSession(sessionId: Long): DiscoverySessionEntity?

getSessionFlow

abstract fun getSessionFlow(sessionId: Long): Flow<DiscoverySessionEntity?>

getSessionWithResults

abstract suspend fun getSessionWithResults(sessionId: Long): DiscoverySessionEntity?

getUniqueNodeCount

abstract suspend fun getUniqueNodeCount(sessionId: Long): Int

getUniqueNodeNums

abstract suspend fun getUniqueNodeNums(sessionId: Long): List<Long>

insertDiscoveredNode

abstract suspend fun insertDiscoveredNode(node: DiscoveredNodeEntity): Long

insertDiscoveredNodes

abstract suspend fun insertDiscoveredNodes(nodes: List<DiscoveredNodeEntity>)

insertPresetResult

abstract suspend fun insertPresetResult(result: DiscoveryPresetResultEntity): Long

insertSession

abstract suspend fun insertSession(session: DiscoverySessionEntity): Long

markInterruptedSessions

abstract suspend fun markInterruptedSessions()

updateDiscoveredNode

abstract suspend fun updateDiscoveredNode(node: DiscoveredNodeEntity)

updatePresetResult

abstract suspend fun updatePresetResult(result: DiscoveryPresetResultEntity)

updateRecoverableSessionCompletionStatus

abstract suspend fun updateRecoverableSessionCompletionStatus(sessionId: Long, status: String): Int

updateSession

abstract suspend fun updateSession(session: DiscoverySessionEntity)

updateSessionAggregates

abstract suspend fun updateSessionAggregates(sessionId: Long, totalUniqueNodes: Int, totalDwellSeconds: Long, totalMessages: Int, totalSensorPackets: Int, furthestNodeDistance: Double, avgChannelUtilization: Double)

updateSessionCompletionStatus

abstract suspend fun updateSessionCompletionStatus(sessionId: Long, status: String): Int