fix(metrics): replace telemetry times with receive time

pull/1348/head
andrekir 2024-10-25 07:53:58 -03:00
rodzic 5cf9741b13
commit a3b4b70db9
1 zmienionych plików z 5 dodań i 2 usunięć

Wyświetl plik

@ -27,8 +27,10 @@ class MeshLogRepository @Inject constructor(private val meshLogDaoLazy: dagger.L
meshLogDao.getAllLogsInReceiveOrder(maxItems)
}
private fun parseTelemetryLog(log: MeshLog): Telemetry? =
runCatching { Telemetry.parseFrom(log.fromRadio.packet.decoded.payload) }.getOrNull()
private fun parseTelemetryLog(log: MeshLog): Telemetry? = runCatching {
Telemetry.parseFrom(log.fromRadio.packet.decoded.payload)
.toBuilder().setTime((log.received_date / MILLIS_TO_SECONDS).toInt()).build()
}.getOrNull()
@OptIn(ExperimentalCoroutinesApi::class)
fun getTelemetryFrom(nodeNum: Int): Flow<List<Telemetry>> =
@ -61,5 +63,6 @@ class MeshLogRepository @Inject constructor(private val meshLogDaoLazy: dagger.L
companion object {
private const val MAX_ITEMS = 500
private const val MAX_MESH_PACKETS = 10000
private const val MILLIS_TO_SECONDS = 1000
}
}