From 9b4a68051f668d6e1587cb0d508cf6032c889a31 Mon Sep 17 00:00:00 2001
From: you <you@example.com>
Date: Sat, 21 Mar 2026 21:38:32 +0000
Subject: [PATCH] fix: dedup live channel messages by packet hash, not
 sender+timestamp
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Multiple observers seeing the same packet triggered separate message
entries. Now deduplicates by packet hash — additional observations
increment repeats count and add to observers list. Channel messageCount
also only bumps once per unique packet.
---
 public/channels.js | 15 +++++++++------
 public/index.html  |  2 +-
 2 files changed, 10 insertions(+), 7 deletions(-)

diff --git a/public/channels.js b/public/channels.js
index 24aac1e2..707f9913 100644
--- a/public/channels.js
+++ b/public/channels.js
@@ -380,6 +380,7 @@
 
       var channelListDirty = false;
       var messagesDirty = false;
+      var seenHashes = new Set();
 
       for (var i = 0; i < dominated.length; i++) {
         var m = dominated[i];
@@ -412,15 +413,18 @@
         var snr = m.data?.snr ?? m.data?.packet?.snr ?? payload.SNR ?? null;
         var observer = m.data?.packet?.observer_name || m.data?.observer || null;
 
-        // Update channel list entry
+        // Update channel list entry — only once per unique packet hash
+        var isFirstObservation = pktHash && !seenHashes.has(pktHash + ':' + channelName);
+        if (pktHash) seenHashes.add(pktHash + ':' + channelName);
+
         var ch = channels.find(function (c) { return c.hash === channelName; });
         if (ch) {
-          ch.messageCount = (ch.messageCount || 0) + 1;
+          if (isFirstObservation) ch.messageCount = (ch.messageCount || 0) + 1;
           ch.lastActivity = ts;
           ch.lastSender = sender;
           ch.lastMessage = truncate(displayText, 100);
           channelListDirty = true;
-        } else {
+        } else if (isFirstObservation) {
           // New channel we haven't seen
           channels.push({
             hash: channelName,
@@ -435,9 +439,8 @@
 
         // If this message is for the selected channel, append to messages
         if (selectedHash && channelName === selectedHash) {
-          // Deduplicate: check if we already have this exact message
-          var dedupeKey = sender + ':' + ts;
-          var existing = messages.find(function (msg) { return msg.sender === sender && msg.timestamp === ts; });
+          // Deduplicate by packet hash — same message seen by multiple observers
+          var existing = pktHash ? messages.find(function (msg) { return msg.packetHash === pktHash; }) : null;
           if (existing) {
             existing.repeats = (existing.repeats || 1) + 1;
             if (observer && existing.observers && existing.observers.indexOf(observer) === -1) {
diff --git a/public/index.html b/public/index.html
index 62d55a8a..7e59d770 100644
--- a/public/index.html
+++ b/public/index.html
@@ -86,7 +86,7 @@
   <script src="home.js?v=1774042199"></script>
   <script src="packets.js?v=1774127844"></script>
   <script src="map.js?v=1774126708" onerror="console.error('Failed to load:', this.src)"></script>
-  <script src="channels.js?v=1774127388" onerror="console.error('Failed to load:', this.src)"></script>
+  <script src="channels.js?v=1774129112" onerror="console.error('Failed to load:', this.src)"></script>
   <script src="nodes.js?v=1774126708" onerror="console.error('Failed to load:', this.src)"></script>
   <script src="traces.js?v=1774350000" onerror="console.error('Failed to load:', this.src)"></script>
   <script src="analytics.js?v=1774126708" onerror="console.error('Failed to load:', this.src)"></script>