From fdbd6511fffaeca74a8ca5c00c3b1a713b6fc327 Mon Sep 17 00:00:00 2001
From: you <you@example.com>
Date: Thu, 19 Mar 2026 07:56:12 +0000
Subject: [PATCH] Scrub replay fetches ALL packets from scrub point to now

No more 5-minute window or 200-packet limit. Fetches up to 10K
packets from the scrub point forward and replays them all.
When replay finishes, resumes live.
---
 public/live.js | 28 ++++++++++------------------
 1 file changed, 10 insertions(+), 18 deletions(-)

diff --git a/public/live.js b/public/live.js
index 7da176e9..ec3a367c 100644
--- a/public/live.js
+++ b/public/live.js
@@ -109,8 +109,7 @@
   }
 
   function vcrReplayFromTs(targetTs) {
-    const fetchFrom = new Date(targetTs - 5000).toISOString();
-    const fetchTo = new Date(targetTs + 300000).toISOString(); // 5 min window
+    const fetchFrom = new Date(targetTs).toISOString();
     stopReplay();
     vcrSetMode('REPLAY');
 
@@ -118,11 +117,11 @@
     clearNodeMarkers();
     loadNodes(targetTs);
 
-    fetch(`/api/packets?limit=200&grouped=false&since=${encodeURIComponent(fetchFrom)}&until=${encodeURIComponent(fetchTo)}`)
+    // Fetch ALL packets from scrub point to now (no limit, no until)
+    fetch(`/api/packets?limit=10000&grouped=false&since=${encodeURIComponent(fetchFrom)}`)
       .then(r => r.json())
       .then(data => {
-        const pkts = (data.packets || []).reverse();
-        // Build a fresh replay buffer from ONLY the fetched packets
+        const pkts = (data.packets || []).reverse(); // chronological order
         const replayEntries = pkts.map(p => ({
           ts: new Date(p.timestamp || p.created_at).getTime(),
           pkt: dbPacketToLive(p)
@@ -131,13 +130,11 @@
           vcrSetMode('PAUSED');
           return;
         }
-        // Replace buffer with fetched packets for clean replay
-        // (keep existing buffer entries that are newer for when we resume live)
-        const oldNew = VCR.buffer.filter(b => b.ts > replayEntries[replayEntries.length - 1].ts);
-        VCR.buffer = [...replayEntries, ...oldNew];
-        VCR.playhead = 0; // start from first fetched packet
-        VCR.scrubEnd = replayEntries.length;
+        VCR.buffer = replayEntries;
+        VCR.playhead = 0;
+        VCR.scrubEnd = null;
         VCR.scrubTs = null;
+        VCR.dragPct = null;
         startReplay();
       })
       .catch(() => { vcrResumeLive(); });
@@ -200,13 +197,8 @@
     stopReplay();
     function tick() {
       if (VCR.mode !== 'REPLAY') return;
-      const endIdx = VCR.scrubEnd != null ? VCR.scrubEnd : VCR.buffer.length;
-      if (VCR.playhead >= endIdx) {
-        // Hold playhead at the last replayed packet's time
-        const lastEntry = VCR.buffer[Math.max(0, VCR.playhead - 1)];
-        if (lastEntry) VCR.scrubTs = lastEntry.ts;
-        VCR.scrubEnd = null;
-        vcrSetMode('PAUSED');
+      if (VCR.playhead >= VCR.buffer.length) {
+        vcrResumeLive();
         return;
       }
       const entry = VCR.buffer[VCR.playhead];