feat: live feed shows last 10 mins only, history excludes last 10 mins and auto-refreshes as events age out

Author: naveedious

src/db.js

@@ -128,14 +128,15 @@ export function getRecentActivity(limit = 100) {
   ).all(limit);
 }
 
-export function getActivityFiltered({ show, type, from, to } = {}, limit = 50, offset = 0) {
+export function getActivityFiltered({ show, type, from, to, before } = {}, limit = 50, offset = 0) {
   const conditions = [];
   const params = [];
 
-  if (show) { conditions.push('show_title LIKE ?'); params.push('%' + show + '%'); }
-  if (type) { conditions.push('event_type = ?');   params.push(type); }
-  if (from) { conditions.push('timestamp >= ?');   params.push(from); }
-  if (to)   { conditions.push('timestamp <= ?');   params.push(to); }
+  if (show)   { conditions.push('show_title LIKE ?'); params.push('%' + show + '%'); }
+  if (type)   { conditions.push('event_type = ?');    params.push(type); }
+  if (from)   { conditions.push('timestamp >= ?');    params.push(from); }
+  if (to)     { conditions.push('timestamp <= ?');    params.push(to); }
+  if (before) { conditions.push('timestamp < ?');     params.push(before); }
 
   const where = conditions.length ? 'WHERE ' + conditions.join(' AND ') : '';
 

src/public/index.html

@@ -580,6 +580,7 @@ <h1>Episode<span>Guard</span><span class="version-badge" id="version-badge"></sp
     if (d.message && !d.reason) detail += (detail?' - ':'')+String(d.message).slice(0,60);
     const el = document.createElement('div');
     el.className = 'live-row'+(animate?' new':'');
+    el.dataset.ts = String(new Date(row.timestamp).getTime());
     el.innerHTML = '<span class="live-time">'+relativeTime(row.timestamp)+'</span>'+
       '<span class="live-type">'+badgeHtml(row.event_type)+'</span>'+
       '<span class="live-show">'+esc(row.show_title??'-')+'<span class="live-ep">'+epLabel(row.season,row.episode)+'</span></span>'+
@@ -601,6 +602,9 @@ <h1>Episode<span>Guard</span><span class="version-badge" id="version-badge"></sp
 
   let histPage=1;
   const HIST_LIMIT=50;
+  const LIVE_WINDOW_MS = 10 * 60 * 1000; // 10 minutes
+
+  function liveCutoff() { return new Date(Date.now() - LIVE_WINDOW_MS).toISOString(); }
 
   function applyFilters(){histPage=1;loadHistLog();}
   function clearFilters(){
@@ -618,6 +622,9 @@ <h1>Episode<span>Guard</span><span class="version-badge" id="version-badge"></sp
     if (type) params.set('type',type);
     if (from) params.set('from',from+'T00:00:00Z');
     if (to)   params.set('to',to+'T23:59:59Z');
+    // Default: exclude last 10 mins (those are in the live feed)
+    // Only apply if user hasn't set an explicit date range
+    if (!from && !to) params.set('before', liveCutoff());
     try {
       const res = await fetch('/api/logs?'+params);
       const data = await res.json();
@@ -639,7 +646,26 @@ <h1>Episode<span>Guard</span><span class="version-badge" id="version-badge"></sp
   }
 
   function goPage(p){histPage=p;loadHistLog();}
-  function initLogsView(){initLiveFeed();loadHistLog();}
+
+  // Prune live feed rows older than 10 mins and refresh history to pick them up
+  function pruneLiveFeed() {
+    const cutoff = Date.now() - LIVE_WINDOW_MS;
+    const feed = document.getElementById('live-feed');
+    if (!feed) return;
+    let pruned = 0;
+    feed.querySelectorAll('.live-row').forEach(el => {
+      const ts = el.dataset.ts ? parseInt(el.dataset.ts, 10) : 0;
+      if (ts && ts < cutoff) { el.remove(); pruned++; }
+    });
+    if (pruned > 0) loadHistLog();
+  }
+
+  let logsViewTimer = null;
+  function initLogsView() {
+    initLiveFeed();
+    loadHistLog();
+    if (!logsViewTimer) logsViewTimer = setInterval(pruneLiveFeed, 60000);
+  }
 
   function showSettingsTab(name, btn) {
     document.querySelectorAll('.settings-pane').forEach(p => p.classList.remove('active'));

src/routes/api.js

@@ -53,12 +53,12 @@ router.get('/dashboard', async (req, res) => {
 });
 
 router.get('/logs', (req, res) => {
-  const { show, type, from, to } = req.query;
+  const { show, type, from, to, before } = req.query;
   const limit  = Math.min(parseInt(req.query.limit ?? '50', 10), 200);
   const page   = Math.max(parseInt(req.query.page  ?? '1',  10), 1);
   const offset = (page - 1) * limit;
   try {
-    const result = getActivityFiltered({ show, type, from, to }, limit, offset);
+    const result = getActivityFiltered({ show, type, from, to, before }, limit, offset);
     res.json({ rows: result.rows, total: result.total, page, limit, totalPages: Math.ceil(result.total / limit) });
   } catch (err) { res.status(500).json({ error: err.message }); }
 });
@@ -69,7 +69,9 @@ router.get('/logs/stream', (req, res) => {
   res.setHeader('Connection',    'keep-alive');
   res.flushHeaders();
 
-  const recent = getRecentActivity(20).reverse();
+  // Seed with events from the last 10 minutes only
+  const tenMinsAgo = new Date(Date.now() - 10 * 60 * 1000).toISOString();
+  const recent = getActivityFiltered({ from: tenMinsAgo }, 200, 0).rows.reverse();
   for (const row of recent) res.write('data: ' + JSON.stringify(row) + '\n\n');
 
   addSseClient(res);