From a3b4b70db9137bf46e858558fb676a86661b8bb6 Mon Sep 17 00:00:00 2001 From: andrekir Date: Fri, 25 Oct 2024 07:53:58 -0300 Subject: [PATCH] fix(metrics): replace telemetry times with receive time --- .../java/com/geeksville/mesh/database/MeshLogRepository.kt | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/app/src/main/java/com/geeksville/mesh/database/MeshLogRepository.kt b/app/src/main/java/com/geeksville/mesh/database/MeshLogRepository.kt index 6c5fa3c70..742401113 100644 --- a/app/src/main/java/com/geeksville/mesh/database/MeshLogRepository.kt +++ b/app/src/main/java/com/geeksville/mesh/database/MeshLogRepository.kt @@ -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> = @@ -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 } }