dandri/meshcore-analyzer
1
0
Fork 0
mirror of https://github.com/Kpa-clawbot/meshcore-analyzer.git synced 2026-08-28 12:44:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: dedup live channel messages by packet hash, not sender+timestamp

Browse Source 
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.
This commit is contained in:
you
2026-03-21 21:38:32 +00:00
parent cfcb441aa1
commit 9b4a68051f
2 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
public/channels.js
+9 -6
View File
@@ -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) {
public/index.html
+1 -1
View File
@@ -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>