From 6094609a863e8db7f3e8a31711cf5b5270219b65 Mon Sep 17 00:00:00 2001
From: l5y <220195275+l5yth@users.noreply.github.com>
Date: Sun, 14 Sep 2025 17:53:37 +0200
Subject: [PATCH] Ensure last_heard never precedes position time (#31)

---
 data/mesh.py | 10 +++++++++-
 web/app.rb   |  7 ++++++-
 2 files changed, 15 insertions(+), 2 deletions(-)

diff --git a/data/mesh.py b/data/mesh.py
index b013ab5..ca3463f 100644
--- a/data/mesh.py
+++ b/data/mesh.py
@@ -37,6 +37,14 @@ def upsert_node(node_id, n):
     met = _get(n, "deviceMetrics") or {}
     pos = _get(n, "position") or {}
     lh = _get(n, "lastHeard")
+    pt = _get(pos, "time")
+    now = int(time.time())
+    if lh is not None and lh > now:
+        lh = now
+    if pt is not None and pt > now:
+        pt = now
+    if pt is not None and (lh is None or lh < pt):
+        lh = pt
     row = (
         node_id,
         _get(n, "num"),
@@ -57,7 +65,7 @@ def upsert_node(node_id, n):
         _get(met, "channelUtilization"),
         _get(met, "airUtilTx"),
         _get(met, "uptimeSeconds"),
-        _get(pos, "time"),
+        pt,
         _get(pos, "locationSource"),
         _get(pos, "latitude"),
         _get(pos, "longitude"),
diff --git a/web/app.rb b/web/app.rb
index f4b5679..65c7dfd 100644
--- a/web/app.rb
+++ b/web/app.rb
@@ -45,6 +45,11 @@ def upsert_node(db, node_id, n)
   pos = n["position"] || {}
   role = user["role"] || "CLIENT"
   lh = n["lastHeard"]
+  pt = pos["time"]
+  now = Time.now.to_i
+  lh = now if lh && lh > now
+  pt = now if pt && pt > now
+  lh = pt if pt && (!lh || lh < pt)
   row = [
     node_id,
     n["num"],
@@ -65,7 +70,7 @@ def upsert_node(db, node_id, n)
     met["channelUtilization"],
     met["airUtilTx"],
     met["uptimeSeconds"],
-    pos["time"],
+    pt,
     pos["locationSource"],
     pos["latitude"],
     pos["longitude"],