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

DiscoveryDao

interface DiscoveryDao(source)

Inheritors

SwitchingDiscoveryDao

Functions

countSessionsForDevice

abstract suspend fun countSessionsForDevice(sessionId: Long, deviceAddress: String): Int

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>)

insertDwellIfSessionExists

open suspend fun insertDwellIfSessionExists(result: DiscoveryPresetResultEntity, nodes: List<DiscoveredNodeEntity>, deviceAddress: String): Long?

Writes one dwell's preset result and its discovered nodes, but only if the parent session row exists in this database and belongs to deviceAddress, returning null when it does not.

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