Fix packet deduplication and node status handling

- Add unique index on origin_key to prevent duplicate packets from multiple observers
- Update insertPacket() to use ON CONFLICT DO NOTHING for deduplication
- Change updateObserverLastSeen() to only update gateway nodes, not room_server
- Room servers now follow normal 15-minute inactive timeout

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: cj-vana

services/mqtt-collector/src/db.ts

@@ -49,6 +49,7 @@ function getTodayDateString(): string {
 
 /**
  * Insert a new packet into the database with all fields
+ * Uses ON CONFLICT to skip duplicate packets (same origin_key from multiple observers)
  */
 export async function insertPacket(packet: ParsedPacket): Promise<void> {
   const client = getDb();
@@ -60,6 +61,7 @@ export async function insertPacket(packet: ParsedPacket): Promise<void> {
         score, duration, route, len, payload_len, direction
       )
       VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
+      ON CONFLICT(origin_key) DO NOTHING
     `,
     args: [
       packet.nodeId,

src/app/api/health/route.ts

@@ -258,12 +258,12 @@ function calculateNetworkScore(
 }
 
 /**
- * Update observer node's last_seen timestamp when bot is active
+ * Update observer/gateway node's last_seen timestamp when bot is active
  */
 async function updateObserverLastSeen(): Promise<void> {
   try {
     await db.execute({
-      sql: `UPDATE nodes SET last_seen = datetime('now') WHERE name LIKE '%Observer%' OR node_type = 'room_server'`,
+      sql: `UPDATE nodes SET last_seen = datetime('now') WHERE node_type = 'gateway'`,
       args: [],
     });
   } catch {

src/lib/db/migrations/003_add_origin_key_unique.sql

@@ -0,0 +1,15 @@
+-- Migration: Add unique constraint on origin_key to prevent duplicate packets
+-- Created: 2026-01-02
+--
+-- Problem: When multiple observers see the same packet, it gets inserted multiple times,
+-- inflating packet counts. The origin_key field contains the packet hash which should be unique.
+--
+-- Solution: Add unique index on origin_key and use ON CONFLICT DO NOTHING in insertPacket()
+
+-- First, remove any existing duplicates (keep the first occurrence by id)
+DELETE FROM packets WHERE id NOT IN (
+  SELECT MIN(id) FROM packets WHERE origin_key IS NOT NULL GROUP BY origin_key
+) AND origin_key IS NOT NULL;
+
+-- Add unique constraint on origin_key
+CREATE UNIQUE INDEX IF NOT EXISTS idx_packets_origin_key_unique ON packets(origin_key);

src/lib/db/schema.sql

@@ -44,3 +44,6 @@ CREATE INDEX IF NOT EXISTS idx_packets_timestamp ON packets(timestamp);
 CREATE INDEX IF NOT EXISTS idx_packets_node_id ON packets(node_id);
 CREATE INDEX IF NOT EXISTS idx_nodes_last_seen ON nodes(last_seen);
 CREATE INDEX IF NOT EXISTS idx_stats_node_date ON node_stats_daily(node_id, date);
+
+-- Unique constraint on origin_key to prevent duplicate packets from multiple observers
+CREATE UNIQUE INDEX IF NOT EXISTS idx_packets_origin_key_unique ON packets(origin_key);