[feat](trx-rs): make spectrum affordable over a slow link

Spectrum dominates the server↔client connection, and all three things that
govern its cost were working against a poor link.

**It was polled, one round trip per frame.** The client asked for a frame every
50 ms on a dedicated connection and waited for the reply, so the frame rate was
capped at 1/RTT — on a 200 ms link, five frames a second no matter what was
configured.  Add SubscribeSpectrum alongside the existing SubscribeMeter: the
server pushes frames from a per-rig broadcast that rig_task fills only while
somebody is subscribed.  A server too old to know the command answers with an
error and leaves the connection usable, so the client falls back to polling on
the same connection without reconnecting.

**Bins were JSON floats.** 1024 bins spelled out as decimal text is around
10 KB a frame, ~200 KB/s at full rate — while the very next hop, client to
browser, already sends the same information as base64 i8 in about 1.4 KB.  Bins
now travel base64-encoded whole dBFS, the resolution the display draws at
anyway.  Decoding still accepts the old array form.

**Nothing was tunable.** [sdr].spectrum_fft_size and [sdr].spectrum_interval_ms
replace the compile-time FFT size and cadence; [[remotes]].spectrum_interval_ms
lets the client ask for less.  512 bins at 5 frames/s is roughly 3.5 KB/s
against roughly 200 KB/s before.

Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_01SyX26FCpMQxiBoC7r5K1A7
Signed-off-by: Stan Grams <sjg@haxx.space>

docs/User-Manual.md

@@ -454,29 +454,6 @@ listener and every rig's audio listener.
 
 ---
 
-## Multiple Rigs in the Web UI
-
-A client connected to several rigs decodes all of them at once, whichever one
-is on screen. The rig picker in the header decides which rig the UI is about,
-and each page answers that differently:
-
-| Page | Shows |
-|------|-------|
-| Radio | The selected rig: its spectrum, its audio, and the mini decode views over the waterfall. |
-| Digital Modes | The selected rig: every decoder panel, its counts and its status line. |
-| Map | The whole station — every rig's positions, with the map's own rig filter to narrow it. |
-| Statistics | The whole station, including the per-rig comparison. |
-
-Switching rigs repaints the radio and digital modes pages for the rig now
-selected. Nothing is lost by switching: the traffic other rigs heard is still
-held, and switching back brings it up again. The one exception is the CW pane,
-which is a single running stream of copied text rather than a list of frames,
-so it starts empty on the rig you switch to.
-
-Each browser tab keeps its own selection, so two tabs can watch two rigs.
-
----
-
 ## Tune Links
 
 Every page of the web UI carries what the radio is doing in its address, so the

src/trx-client/trx-frontend/trx-frontend-http/assets/web/generated/ais.js

@@ -1,7 +1,3 @@
-import {
-  forActiveRig,
-  isActiveRigDecode
-} from "./chunk-S57W63QN.js";
 import {
   hostCore,
   hostState
@@ -144,22 +140,18 @@ function aisLatestByVessel(messages) {
   }
   return Array.from(byMmsi.values());
 }
-function aisRigMessages() {
-  return forActiveRig(aisMessageHistory);
-}
 function updateAisSummary() {
   const plan = currentAisChannelPlan();
   if (aisChannelSummaryEl) {
     aisChannelSummaryEl.textContent = `A ${formatAisMhz(plan.aHz)} · B ${formatAisMhz(plan.bHz)}`;
   }
-  const rigMessages = aisRigMessages();
-  const vessels = aisLatestByVessel(rigMessages);
+  const vessels = aisLatestByVessel(aisMessageHistory);
   if (aisVesselCountEl) {
     const count = vessels.length;
     aisVesselCountEl.textContent = `${count} vessel${count === 1 ? "" : "s"}`;
   }
   if (aisLatestSeenEl) {
-    const latest = rigMessages[0];
+    const latest = aisMessageHistory[0];
     if (!latest) {
       aisLatestSeenEl.textContent = "No traffic yet";
     } else {
@@ -230,9 +222,7 @@ function updateAisBar() {
   updateAisSummary();
   const isAis = (document.getElementById("mode")?.value || "").toUpperCase() === "AIS";
   const cutoffMs = Date.now() - AIS_BAR_WINDOW_MS;
-  const recent = aisMessageHistory.filter(
-    (msg) => (msg._tsMs ?? 0) >= cutoffMs && isActiveRigDecode(msg.rig_id)
-  );
+  const recent = aisMessageHistory.filter((msg) => (msg._tsMs ?? 0) >= cutoffMs);
   const messages = aisLatestByVessel(recent).slice(0, 8);
   if (!isAis || messages.length === 0) {
     aisBarOverlay.style.display = "none";
@@ -277,7 +267,7 @@ function renderAisHistory() {
     return;
   }
   const fragment = document.createDocumentFragment();
-  for (const message of aisRigMessages()) {
+  for (const message of aisMessageHistory) {
     fragment.appendChild(renderAisRow(message));
   }
   aisMessagesEl.replaceChildren(fragment);
@@ -309,10 +299,10 @@ function normalizeServerAisMessage(msg) {
 }
 function onServerAisBatch(messages) {
   if (!Array.isArray(messages) || messages.length === 0) return;
+  if (aisStatus) aisStatus.textContent = "Receiving";
   const normalized = [];
   for (const msg of messages) {
     const next = normalizeServerAisMessage(msg);
-    if (aisStatus && isActiveRigDecode(next.rig_id)) aisStatus.textContent = "Receiving";
     const tsMs = Number.isFinite(next.ts_ms) ? Number(next.ts_ms) : Date.now();
     next._tsMs = tsMs;
     next._ts = new Date(tsMs).toLocaleTimeString([], {
@@ -352,9 +342,8 @@ if (aisFilterInput) {
   });
 }
 function onServerAis(msg) {
-  const message = normalizeServerAisMessage(msg);
-  if (aisStatus && isActiveRigDecode(message.rig_id)) aisStatus.textContent = "Receiving";
-  addAisMessage(message);
+  if (aisStatus) aisStatus.textContent = "Receiving";
+  addAisMessage(normalizeServerAisMessage(msg));
 }
 updateAisSummary();
 window.trxPluginRuntime.registerDecoder({
@@ -364,10 +353,6 @@ window.trxPluginRuntime.registerDecoder({
   restore: onServerAisBatch,
   reset: resetAisHistoryView,
   prune: pruneAisHistoryView,
-  rerender: () => {
-    updateAisBar();
-    renderAisHistory();
-  },
   // Oldest first, so vessel tracks are rebuilt in the order they happened.
   syncMap: () => {
     for (const entry of [...aisMessageHistory].reverse()) plotAisMessage(entry);

src/trx-client/trx-frontend/trx-frontend-http/assets/web/generated/app.js

@@ -885,7 +885,7 @@ function elementById(id) {
       if (restoreFocus) more.focus();
     };
     api.closeMobileOverlays = closeMore;
-    ["satellites", "statistics", "recorder", "settings", "about"].forEach((tabName) => {
+    ["statistics", "recorder", "settings", "about"].forEach((tabName) => {
       const source = nav.querySelector(`[data-tab="${tabName}"]`);
       if (!source) return;
       const item = document.createElement("button");
@@ -1065,9 +1065,6 @@ var runtime = {
     plugin.prune();
     return true;
   },
-  rerenderAll() {
-    for (const plugin of decoders.values()) plugin.rerender?.();
-  },
   syncMapAll() {
     for (const plugin of decoders.values()) plugin.syncMap?.();
   },
@@ -1532,7 +1529,6 @@ var TAB_ORDER = [
   "bookmarks",
   "digital-modes",
   "map",
-  "satellites",
   "statistics",
   "recorder",
   "settings",
@@ -1543,7 +1539,6 @@ var TAB_PATHS = {
   bookmarks: "/bookmarks",
   "digital-modes": "/digital-modes",
   map: "/map",
-  satellites: "/satellites",
   statistics: "/statistics",
   recorder: "/recorder",
   settings: "/settings",
@@ -1761,7 +1756,6 @@ var pluginGroups = {
   ],
   "map-data": ["/map-core.js", "/ais.js", "/vdes.js", "/aprs.js", "/hf-aprs.js"],
   map: ["/map-core.js", "/ais.js", "/vdes.js", "/aprs.js", "/hf-aprs.js", "/sat.js", "/sat-scheduler.js"],
-  satellites: ["/satellite-predictions.js"],
   statistics: ["/map-core.js"],
   bookmarks: ["/bookmarks.js"],
   recorder: [],
@@ -3558,13 +3552,6 @@ function positionRdsPsOverlay() {
 function resetRdsDisplay() {
   updateRdsPsOverlay(primaryRds);
 }
-function refreshDecodeBars() {
-  window.updateAisBar?.();
-  window.updateVdesBar?.();
-  window.updateAprsBar?.();
-  window.updateFt8Bar?.();
-  window.updateCwBar?.();
-}
 function resetDecoderStateOnRigSwitch() {
   primaryRds = null;
   vchanRdsById = /* @__PURE__ */ new Map();
@@ -3579,8 +3566,6 @@ function resetDecoderStateOnRigSwitch() {
     const el = document.getElementById(id);
     if (el) el.textContent = "--";
   });
-  refreshDecodeBars();
-  window.trxPluginRuntime.rerenderAll();
 }
 function resetWfmStereoIndicator() {
   if (!wfmStFlagEl) return;
@@ -4800,7 +4785,10 @@ function render(update) {
     const connText = _decodeConnectedText[d.id] || "Connected, listening for packets";
     setModeBoundDecodeStatus(el, d.active_modes, "Select " + d.active_modes[0] + " mode to decode", connText);
   }
-  refreshDecodeBars();
+  if (window.updateAisBar) window.updateAisBar();
+  if (window.updateVdesBar) window.updateVdesBar();
+  if (window.updateAprsBar) window.updateAprsBar();
+  if (window.updateFt8Bar) window.updateFt8Bar();
   for (const d of decoderRegistry) {
     if (d.activation !== "toggle") continue;
     const key = d.id.replace(/-/g, "_") + "_decode_enabled";
@@ -5856,7 +5844,6 @@ function _initMapWhenReady() {
 }
 function navigateToTab(name, options = {}) {
   window.trxUi?.closeMobileOverlays?.();
-  const leavingSatellites = _activeTab === "satellites" && name !== "satellites";
   const { updateHistory = true, replaceHistory = false } = options;
   if (authEnabled && !authRole && name !== "main") {
     showAuthGate(false);
@@ -5886,10 +5873,7 @@ function navigateToTab(name, options = {}) {
     updateTabHistory(name, replaceHistory);
   }
   scheduleSpectrumLayout();
-  if (leavingSatellites) window.clearSatPredictionDom?.();
-  void loadPluginsForTab(name).then(() => {
-    if (name === "satellites") window.refreshSatPredictions?.();
-  }).catch((error) => {
+  void loadPluginsForTab(name).catch((error) => {
     console.error(error);
   });
   if (name === "map") {
@@ -6336,6 +6320,9 @@ function _wireSubTabBar(bar) {
         if (window.refreshCwTonePicker) window.refreshCwTonePicker();
       });
     }
+    if (btn.dataset.subtab !== "sat" && typeof window.clearSatPredictionDom === "function") {
+      window.clearSatPredictionDom();
+    }
   });
 }
 document.querySelectorAll(".sub-tab-bar").forEach(_wireSubTabBar);

src/trx-client/trx-frontend/trx-frontend-http/assets/web/generated/aprs.js

@@ -5,10 +5,6 @@ import {
   normalizeAprsPacket,
   renderAprsPacketRow
 } from "./chunk-OPEIVJGD.js";
-import {
-  forActiveRig,
-  isActiveRigDecode
-} from "./chunk-S57W63QN.js";
 import {
   hostCore,
   hostState
@@ -86,25 +82,20 @@ function aprsFilterMatch(pkt) {
   ].filter(Boolean).join(" ").toUpperCase();
   return haystack.includes(aprsFilterText);
 }
-function aprsRigPackets() {
-  return forActiveRig(aprsPacketHistory);
-}
 function aprsVisiblePackets() {
-  const rigPackets = aprsRigPackets();
-  const packets = aprsCollapseDup ? collapseAprsDuplicates(rigPackets) : rigPackets;
+  const packets = aprsCollapseDup ? collapseAprsDuplicates(aprsPacketHistory) : aprsPacketHistory;
   return packets.filter(aprsFilterMatch);
 }
 function updateAprsSummary() {
-  const rigPackets = aprsRigPackets();
   const visible = aprsVisiblePackets();
   if (aprsTotalCountEl) {
-    aprsTotalCountEl.textContent = `${rigPackets.length} total`;
+    aprsTotalCountEl.textContent = `${aprsPacketHistory.length} total`;
   }
   if (aprsVisibleCountEl) {
     aprsVisibleCountEl.textContent = `${visible.length} shown`;
   }
   if (aprsLatestSeenEl) {
-    const latest = rigPackets[0];
+    const latest = aprsPacketHistory[0];
     if (!latest) {
       aprsLatestSeenEl.textContent = "No packets yet";
     } else {
@@ -162,9 +153,7 @@ function updateAprsBar() {
   if (!aprsBarOverlay) return;
   const isPkt = (document.getElementById("mode")?.value || "").toUpperCase() === "PKT";
   const cutoffMs = Date.now() - APRS_BAR_WINDOW_MS;
-  const okFrames = aprsPacketHistory.filter(
-    (p) => p.crcOk && (p._tsMs ?? 0) >= cutoffMs && isActiveRigDecode(p.rig_id)
-  );
+  const okFrames = aprsPacketHistory.filter((p) => p.crcOk && (p._tsMs ?? 0) >= cutoffMs);
   const frames = collapseAprsDuplicates(okFrames).slice(0, 8);
   const newestTsMs = frames.reduce((latest, pkt) => Math.max(latest, Number(pkt._tsMs) || 0), 0);
   if (!isPkt || frames.length === 0 || newestTsMs <= aprsBarDismissedAtMs) {
@@ -226,11 +215,11 @@ function normalizeServerAprsPacket(pkt) {
 }
 function onServerAprsBatch(packets) {
   if (!Array.isArray(packets) || packets.length === 0) return;
+  if (aprsStatus) aprsStatus.textContent = "Receiving";
   const normalized = [];
   let hasCrcOk = false;
   for (const pkt of packets) {
     const next = normalizeServerAprsPacket(pkt);
-    if (aprsStatus && isActiveRigDecode(next.rig_id)) aprsStatus.textContent = "Receiving";
     const tsMs = Number.isFinite(next.ts_ms) ? Number(next.ts_ms) : Date.now();
     next._tsMs = tsMs;
     next._ts = new Date(tsMs).toLocaleTimeString([], { hour: "2-digit", minute: "2-digit", second: "2-digit" });
@@ -288,9 +277,8 @@ if (aprsFilterInput) {
   });
 }
 function onServerAprs(pkt) {
-  const packet = normalizeServerAprsPacket(pkt);
-  if (aprsStatus && isActiveRigDecode(packet.rig_id)) aprsStatus.textContent = "Receiving";
-  addAprsPacket(packet);
+  if (aprsStatus) aprsStatus.textContent = "Receiving";
+  addAprsPacket(normalizeServerAprsPacket(pkt));
 }
 renderAprsHistory();
 window.trxPluginRuntime.registerDecoder({
@@ -300,10 +288,6 @@ window.trxPluginRuntime.registerDecoder({
   restore: onServerAprsBatch,
   reset: resetAprsHistoryView,
   prune: pruneAprsHistoryView,
-  rerender: () => {
-    updateAprsBar();
-    renderAprsHistory();
-  },
   // Oldest first, so station tracks are rebuilt in the order they happened.
   syncMap: () => {
     for (const entry of [...aprsPacketHistory].reverse()) plotAprsPacket(entry);

src/trx-client/trx-frontend/trx-frontend-http/assets/web/generated/chunk-O2Y7YEVQ.js

@@ -1,7 +1,3 @@
-import {
-  forActiveRig,
-  isActiveRigDecode
-} from "./chunk-S57W63QN.js";
 import {
   hostCore
 } from "./chunk-KL66PICH.js";
@@ -157,10 +153,9 @@ function initializeFtxDecoder(config) {
   const render = () => {
     prune();
     if (!messagesElement) return;
-    const rigMessages = forActiveRig(history);
     const fragment = document.createDocumentFragment();
     let count = 0;
-    for (const message of rigMessages) {
+    for (const message of history) {
       if (count >= 200) break;
       if (filterText && !(message.message ?? "").toUpperCase().includes(filterText)) continue;
       fragment.appendChild(renderRow(message));
@@ -182,9 +177,6 @@ function initializeFtxDecoder(config) {
       });
     }
     return {
-      // The rig that heard it, kept so the mini view can tell a decode of the
-      // rig on screen from one a background rig made on another band.
-      rig_id: message.rig_id ?? null,
       receiver: bridge.getDecodeRigMeta?.() ?? null,
       ts_ms: message.ts_ms,
       snr_db: message.snr_db,
@@ -196,9 +188,7 @@ function initializeFtxDecoder(config) {
   };
   const receiveBatch = (messages) => {
     if (messages.length === 0) return;
-    if (status && messages.some((message) => isActiveRigDecode(message.rig_id))) {
-      status.textContent = "Receiving";
-    }
+    if (status) status.textContent = "Receiving";
     history = messages.map(normalize).reverse().concat(history);
     prune();
     bridge.setFt8FamilyBarDecoder?.(id);
@@ -212,7 +202,7 @@ function initializeFtxDecoder(config) {
     bridge.clearMapMarkersByType?.(id);
   };
   const barFrames = () => {
-    const recent = history.filter((message) => (finiteNumber(message._tsMs ?? message.ts_ms) ?? 0) >= Date.now() - 9e5 && isActiveRigDecode(message.rig_id)).slice(0, 8);
+    const recent = history.filter((message) => (finiteNumber(message._tsMs ?? message.ts_ms) ?? 0) >= Date.now() - 9e5).slice(0, 8);
     let html = "";
     for (const message of recent) {
       const timestamp = finiteNumber(message._tsMs ?? message.ts_ms);
@@ -236,11 +226,7 @@ function initializeFtxDecoder(config) {
       prune();
       render();
     },
-    reset,
-    rerender: () => {
-      bridge.updateFt8Bar?.();
-      render();
-    }
+    reset
   });
   bridge.registerFt8FamilyBarRenderer?.(id, barFrames);
   const updatePeriod = () => {

src/trx-client/trx-frontend/trx-frontend-http/assets/web/generated/chunk-S57W63QN.js

@@ -1,18 +0,0 @@
-import {
-  hostState
-} from "./chunk-KL66PICH.js";
-
-// src/plugins/active-rig.ts
-function isActiveRigDecode(rigId) {
-  const activeRigId = hostState.lastActiveRigId;
-  if (!activeRigId || !rigId) return true;
-  return rigId === activeRigId;
-}
-function forActiveRig(items) {
-  return items.filter((item) => isActiveRigDecode(item.rig_id));
-}
-
-export {
-  isActiveRigDecode,
-  forActiveRig
-};

src/trx-client/trx-frontend/trx-frontend-http/assets/web/generated/cw.js

@@ -1,6 +1,3 @@
-import {
-  isActiveRigDecode
-} from "./chunk-S57W63QN.js";
 import {
   hostCore
 } from "./chunk-KL66PICH.js";
@@ -28,7 +25,7 @@ var CW_BAR_LINE_GAP_MS = 5e3;
 var cwLastAppendTime = 0;
 var cwTonePickerRaf = null;
 var cwBarHistory = [];
-var cwBarCurrentLines = /* @__PURE__ */ new Map();
+var cwBarCurrentLine = null;
 var cwBarDismissedAtMs = 0;
 var cwAutoLocalOverride = null;
 function escapeCwHtml(input) {
@@ -53,22 +50,20 @@ cwWindow.applyCwAutoUiFromServer = function(enabled) {
   if (cwAutoLocalOverride !== null) return;
   applyCwAutoUi(enabled);
 };
-function cwBarFlushCurrentLine(key) {
-  const line = cwBarCurrentLines.get(key);
-  cwBarCurrentLines.delete(key);
-  if (line?.text.trim()) {
-    cwBarHistory.unshift(line);
+function cwBarFlushCurrentLine() {
+  if (cwBarCurrentLine && cwBarCurrentLine.text.trim()) {
+    cwBarHistory.unshift(cwBarCurrentLine);
     if (cwBarHistory.length > 50) cwBarHistory.length = 50;
   }
+  cwBarCurrentLine = null;
 }
 function updateCwBar() {
   if (!cwBarOverlay) return;
   const mode = (document.getElementById("mode")?.value || "").toUpperCase();
   const isCw = mode === "CW" || mode === "CWR";
   const cutoffMs = Date.now() - CW_BAR_WINDOW_MS;
-  const recent = cwBarHistory.filter((l) => l.tsMs >= cutoffMs && isActiveRigDecode(l.rigId));
-  const inProgress = [...cwBarCurrentLines.values()].filter((l) => l.text && isActiveRigDecode(l.rigId)).sort((a, b) => b.tsMs - a.tsMs);
-  const liveLines = [...inProgress, ...recent];
+  const recent = cwBarHistory.filter((l) => l.tsMs >= cutoffMs);
+  const liveLines = cwBarCurrentLine && cwBarCurrentLine.text ? [cwBarCurrentLine, ...recent] : recent;
   const newestTsMs = liveLines.reduce((latest, line) => Math.max(latest, line.tsMs || 0), 0);
   if (!isCw || liveLines.length === 0 || newestTsMs <= cwBarDismissedAtMs) {
     cwBarOverlay.style.display = "none";
@@ -313,7 +308,7 @@ function resetCwHistoryView() {
   if (cwOutputEl) cwOutputEl.innerHTML = "";
   cwLastAppendTime = 0;
   cwBarHistory = [];
-  cwBarCurrentLines.clear();
+  cwBarCurrentLine = null;
   updateCwBar();
   drawCwTonePicker();
 }
@@ -329,9 +324,8 @@ document.getElementById("settings-clear-cw-history")?.addEventListener("click",
   })();
 });
 function onServerCw(evt) {
-  const forSelectedRig = isActiveRigDecode(evt.rig_id ?? null);
-  if (cwStatusEl && forSelectedRig) cwStatusEl.textContent = "Receiving";
-  if (evt.text && cwOutputEl && forSelectedRig) {
+  if (cwStatusEl) cwStatusEl.textContent = "Receiving";
+  if (evt.text && cwOutputEl) {
     const now = Date.now();
     if (!cwOutputEl.lastElementChild || now - cwLastAppendTime > 1e4 || evt.text === "\n") {
       const line = document.createElement("div");
@@ -352,29 +346,25 @@ function onServerCw(evt) {
   }
   if (evt.text) {
     const now = Date.now();
-    const rigId = evt.rig_id ?? null;
-    const key = rigId ?? "";
     if (evt.text === "\n") {
-      cwBarFlushCurrentLine(key);
+      cwBarFlushCurrentLine();
     } else {
-      let line = cwBarCurrentLines.get(key);
-      if (!line || now - line.lastMs > CW_BAR_LINE_GAP_MS) {
-        cwBarFlushCurrentLine(key);
+      if (!cwBarCurrentLine || now - cwBarCurrentLine.lastMs > CW_BAR_LINE_GAP_MS) {
+        cwBarFlushCurrentLine();
         const ts = new Date(now).toLocaleTimeString([], { hour: "2-digit", minute: "2-digit", second: "2-digit" });
-        line = { rigId, tsMs: now, ts, text: "", wpm: null, tone_hz: null, lastMs: now };
-        cwBarCurrentLines.set(key, line);
+        cwBarCurrentLine = { tsMs: now, ts, text: "", wpm: null, tone_hz: null, lastMs: now };
       }
-      line.text += evt.text;
-      line.lastMs = now;
-      if (Number.isFinite(Number(evt.wpm))) line.wpm = clampCwWpm(evt.wpm);
-      if (Number.isFinite(Number(evt.tone_hz))) line.tone_hz = Math.round(Number(evt.tone_hz));
+      cwBarCurrentLine.text += evt.text;
+      cwBarCurrentLine.lastMs = now;
+      if (Number.isFinite(Number(evt.wpm))) cwBarCurrentLine.wpm = clampCwWpm(evt.wpm);
+      if (Number.isFinite(Number(evt.tone_hz))) cwBarCurrentLine.tone_hz = Math.round(Number(evt.tone_hz));
     }
     updateCwBar();
   }
-  if (cwSignalIndicator && forSelectedRig) {
+  if (cwSignalIndicator) {
     cwSignalIndicator.className = evt.signal_on ? "cw-signal-on" : "cw-signal-off";
   }
-  if (forSelectedRig && (!cwAutoInput || cwAutoInput.checked)) {
+  if (!cwAutoInput || cwAutoInput.checked) {
     if (cwWpmInput && Number.isFinite(Number(evt.wpm))) {
       cwWpmInput.value = String(clampCwWpm(evt.wpm));
     }
@@ -399,14 +389,7 @@ cwWindow.trxPluginRuntime.registerDecoder({
   id: "cw",
   onMessage: onServerCw,
   restore: restoreCwHistory,
-  reset: resetCwHistoryView,
-  // The copied text of a rig that is no longer on screen cannot be unpicked
-  // from the pane, so the switch starts the new rig's stream from empty.
-  rerender: () => {
-    if (cwOutputEl) cwOutputEl.innerHTML = "";
-    cwLastAppendTime = 0;
-    updateCwBar();
-  }
+  reset: resetCwHistoryView
 });
 cwWindow.refreshCwTonePicker = function refreshCwTonePicker() {
   ensureCwToneCanvasResolution();

src/trx-client/trx-frontend/trx-frontend-http/assets/web/generated/ft2.js

@@ -1,7 +1,6 @@
 import {
   initializeFtxDecoder
-} from "./chunk-PAKFJPA2.js";
-import "./chunk-S57W63QN.js";
+} from "./chunk-O2Y7YEVQ.js";
 import "./chunk-KL66PICH.js";
 
 // src/plugins/ft2.ts

src/trx-client/trx-frontend/trx-frontend-http/assets/web/generated/ft4.js

@@ -1,7 +1,6 @@
 import {
   initializeFtxDecoder
-} from "./chunk-PAKFJPA2.js";
-import "./chunk-S57W63QN.js";
+} from "./chunk-O2Y7YEVQ.js";
 import "./chunk-KL66PICH.js";
 
 // src/plugins/ft4.ts

src/trx-client/trx-frontend/trx-frontend-http/assets/web/generated/ft8.js

@@ -2,8 +2,7 @@ import {
   initializeFt8FamilyBar,
   initializeFtxDecoder,
   installFtxCompatibilityHelpers
-} from "./chunk-PAKFJPA2.js";
-import "./chunk-S57W63QN.js";
+} from "./chunk-O2Y7YEVQ.js";
 import "./chunk-KL66PICH.js";
 
 // src/plugins/ft8.ts

src/trx-client/trx-frontend/trx-frontend-http/assets/web/generated/hf-aprs.js

@@ -5,10 +5,6 @@ import {
   normalizeAprsPacket,
   renderAprsPacketRow
 } from "./chunk-OPEIVJGD.js";
-import {
-  forActiveRig,
-  isActiveRigDecode
-} from "./chunk-S57W63QN.js";
 import {
   hostCore,
   hostState
@@ -71,26 +67,21 @@ function hfAprsFilterMatch(pkt) {
   ].filter(Boolean).join(" ").toUpperCase();
   return haystack.includes(hfAprsFilterText);
 }
-function hfAprsRigPackets() {
-  return forActiveRig(hfAprsPacketHistory);
-}
 function hfAprsVisiblePackets() {
-  const rigPackets = hfAprsRigPackets();
-  const packets = hfAprsCollapseDup ? collapseHfAprsDuplicates(rigPackets) : rigPackets;
+  const packets = hfAprsCollapseDup ? collapseHfAprsDuplicates(hfAprsPacketHistory) : hfAprsPacketHistory;
   return packets.filter(hfAprsFilterMatch);
 }
 var collapseHfAprsDuplicates = collapseAprsDuplicates;
 function updateHfAprsSummary() {
-  const rigPackets = hfAprsRigPackets();
   const visible = hfAprsVisiblePackets();
   if (hfAprsTotalCountEl) {
-    hfAprsTotalCountEl.textContent = `${rigPackets.length} total`;
+    hfAprsTotalCountEl.textContent = `${hfAprsPacketHistory.length} total`;
   }
   if (hfAprsVisibleCountEl) {
     hfAprsVisibleCountEl.textContent = `${visible.length} shown`;
   }
   if (hfAprsLatestSeenEl) {
-    const latest = rigPackets[0];
+    const latest = hfAprsPacketHistory[0];
     if (!latest) {
       hfAprsLatestSeenEl.textContent = "No packets yet";
     } else {
@@ -167,10 +158,10 @@ function normalizeServerHfAprsPacket(pkt) {
 }
 function onServerHfAprsBatch(packets) {
   if (!Array.isArray(packets) || packets.length === 0) return;
+  if (hfAprsStatus) hfAprsStatus.textContent = "Receiving";
   const normalized = [];
   for (const pkt of packets) {
     const next = normalizeServerHfAprsPacket(pkt);
-    if (hfAprsStatus && isActiveRigDecode(next.rig_id)) hfAprsStatus.textContent = "Receiving";
     const tsMs = Number.isFinite(next.ts_ms) ? Number(next.ts_ms) : Date.now();
     next._tsMs = tsMs;
     next._ts = new Date(tsMs).toLocaleTimeString([], { hour: "2-digit", minute: "2-digit", second: "2-digit" });
@@ -236,9 +227,8 @@ if (hfAprsFilterInput) {
   });
 }
 function onServerHfAprs(pkt) {
-  const packet = normalizeServerHfAprsPacket(pkt);
-  if (hfAprsStatus && isActiveRigDecode(packet.rig_id)) hfAprsStatus.textContent = "Receiving";
-  addHfAprsPacket(packet);
+  if (hfAprsStatus) hfAprsStatus.textContent = "Receiving";
+  addHfAprsPacket(normalizeServerHfAprsPacket(pkt));
 }
 renderHfAprsHistory();
 window.trxPluginRuntime.registerDecoder({
@@ -247,6 +237,5 @@ window.trxPluginRuntime.registerDecoder({
   onBatch: onServerHfAprsBatch,
   restore: onServerHfAprsBatch,
   reset: resetHfAprsHistoryView,
-  prune: pruneHfAprsHistoryView,
-  rerender: renderHfAprsHistory
+  prune: pruneHfAprsHistoryView
 });

src/trx-client/trx-frontend/trx-frontend-http/assets/web/generated/sat.js

@@ -8,6 +8,7 @@ var satDom = {
   status: document.getElementById("sat-status"),
   liveView: document.getElementById("sat-live-view"),
   historyView: document.getElementById("sat-history-view"),
+  predictionsView: document.getElementById("sat-predictions-view"),
   liveLatest: document.getElementById("sat-live-latest"),
   historyList: document.getElementById("sat-history-list"),
   historyCount: document.getElementById("sat-history-count"),
@@ -16,12 +17,29 @@ var satDom = {
   typeFilter: document.getElementById("sat-type-filter"),
   lrptState: document.getElementById("sat-lrpt-state"),
   viewLiveBtn: document.getElementById("sat-view-live"),
-  viewHistoryBtn: document.getElementById("sat-view-history")
+  viewHistoryBtn: document.getElementById("sat-view-history"),
+  viewPredBtn: document.getElementById("sat-view-predictions"),
+  predFilter: document.getElementById("sat-pred-filter"),
+  predMinEl: document.getElementById("sat-pred-min-el"),
+  predCategory: document.getElementById("sat-pred-category"),
+  predCurrentList: document.getElementById("sat-pred-current-list"),
+  predUpcomingList: document.getElementById("sat-pred-list"),
+  predCurrentSec: document.getElementById("sat-pred-current-section"),
+  predUpcomingSec: document.getElementById("sat-pred-upcoming-section"),
+  predStatus: document.getElementById("sat-pred-status")
 };
 var satImageHistory = [];
 var SAT_MAX_IMAGES = 100;
+var SAT_PRED_PAGE_SIZE = 50;
+var satPredShowAll = false;
 var satFilterText = "";
 var satActiveView = "live";
+var satPredData = [];
+var satPredFilterText = "";
+var satPredMinEl = 0;
+var satPredCategory = "all";
+var satPredSatCount = 0;
+var satPredCountdownTimer = null;
 function scheduleSatUi(key, job) {
   if (typeof satWindow.trxScheduleUiFrameJob === "function") {
     satWindow.trxScheduleUiFrameJob(key, job);
@@ -30,19 +48,37 @@ function scheduleSatUi(key, job) {
   job();
 }
 function switchSatView(view) {
+  const leavingPredictions = satActiveView === "predictions" && view !== "predictions";
   satActiveView = view;
   if (satDom.liveView) satDom.liveView.style.display = view === "live" ? "" : "none";
   if (satDom.historyView) satDom.historyView.style.display = view === "history" ? "" : "none";
+  if (satDom.predictionsView) satDom.predictionsView.style.display = view === "predictions" ? "" : "none";
   if (satDom.viewLiveBtn) satDom.viewLiveBtn.classList.toggle("sat-view-active", view === "live");
   if (satDom.viewHistoryBtn) satDom.viewHistoryBtn.classList.toggle("sat-view-active", view === "history");
-  if (view === "history") renderSatHistoryTable();
+  if (satDom.viewPredBtn) satDom.viewPredBtn.classList.toggle("sat-view-active", view === "predictions");
+  if (leavingPredictions) clearPredictionDom();
+  if (view === "history") {
+    renderSatHistoryTable();
+  } else if (view === "predictions") {
+    satPredShowAll = false;
+    void loadSatPredictions();
+  }
 }
+function clearPredictionDom() {
+  stopCountdownTimer();
+  if (satDom.predCurrentList) satDom.predCurrentList.innerHTML = "";
+  if (satDom.predUpcomingList) satDom.predUpcomingList.innerHTML = "";
+}
+satWindow.clearSatPredictionDom = clearPredictionDom;
 satDom.viewLiveBtn?.addEventListener("click", () => {
   switchSatView("live");
 });
 satDom.viewHistoryBtn?.addEventListener("click", () => {
   switchSatView("history");
 });
+satDom.viewPredBtn?.addEventListener("click", () => {
+  switchSatView("predictions");
+});
 var lastSatLrptOn = null;
 satWindow.updateSatLiveState = function(update) {
   if (!satDom.lrptState) return;
@@ -239,6 +275,200 @@ document.getElementById("settings-clear-sat-history")?.addEventListener("click",
     }
   })();
 });
+function azToCardinal(deg) {
+  const dirs = ["N", "NE", "E", "SE", "S", "SW", "W", "NW"];
+  return dirs[Math.round(deg / 45) % 8] ?? "N";
+}
+function formatPredTime(ms) {
+  const d = new Date(ms);
+  const now = /* @__PURE__ */ new Date();
+  const dayNames = ["Sun", "Mon", "Tue", "Wed", "Thu", "Fri", "Sat"];
+  const day = d.getUTCDay() !== now.getUTCDay() ? `${dayNames[d.getUTCDay()] ?? ""} ` : "";
+  const hh = String(d.getUTCHours()).padStart(2, "0");
+  const mm = String(d.getUTCMinutes()).padStart(2, "0");
+  return `${day}${hh}:${mm}`;
+}
+function formatPredDuration(s) {
+  if (s >= 60) return `${Math.round(s / 60)} min`;
+  return `${s}s`;
+}
+function formatCountdown(ms) {
+  const totalSec = Math.max(0, Math.floor(ms / 1e3));
+  const m = Math.floor(totalSec / 60);
+  const s = totalSec % 60;
+  return `${m}:${String(s).padStart(2, "0")}`;
+}
+function elevationClass(deg) {
+  if (deg >= 45) return "sat-pred-el-high";
+  if (deg >= 10) return "sat-pred-el-mid";
+  return "sat-pred-el-low";
+}
+function stopCountdownTimer() {
+  if (satPredCountdownTimer) {
+    clearInterval(satPredCountdownTimer);
+    satPredCountdownTimer = null;
+  }
+}
+function startCountdownTimer(container) {
+  const countdownEls = container?.querySelectorAll(".sat-pred-col-countdown") ?? [];
+  if (countdownEls.length === 0) return;
+  satPredCountdownTimer = setInterval(() => {
+    if (satActiveView !== "predictions") {
+      stopCountdownTimer();
+      return;
+    }
+    const n = Date.now();
+    let anyActive = false;
+    for (const el of countdownEls) {
+      const los = Number.parseInt(el.dataset.los ?? "0", 10);
+      const rem = los - n;
+      if (rem > 0) {
+        el.textContent = formatCountdown(rem);
+        anyActive = true;
+      } else {
+        el.textContent = "0:00";
+      }
+    }
+    if (!anyActive) {
+      stopCountdownTimer();
+      renderSatPredictions(getFilteredPredictions());
+    }
+  }, 1e3);
+}
+function buildCurrentPassRow(pass, now) {
+  const row = document.createElement("div");
+  row.className = "sat-pred-row-current";
+  const dir = `${azToCardinal(pass.azimuth_aos_deg)} → ${azToCardinal(pass.azimuth_los_deg)}`;
+  const remaining = Math.max(0, pass.los_ms - now);
+  row.innerHTML = [
+    `<span class="sat-pred-col-sat">${pass.satellite}</span>`,
+    `<span class="sat-pred-col-el ${elevationClass(pass.max_elevation_deg)}">${pass.max_elevation_deg.toFixed(1)}°</span>`,
+    `<span class="sat-pred-col-time">${formatPredTime(pass.aos_ms)}</span>`,
+    `<span class="sat-pred-col-time">${formatPredTime(pass.los_ms)}</span>`,
+    `<span class="sat-pred-col-countdown" data-los="${pass.los_ms}">${formatCountdown(remaining)}</span>`,
+    `<span class="sat-pred-col-dir">${dir}</span>`
+  ].join("");
+  return row;
+}
+function buildUpcomingPassRow(pass) {
+  const row = document.createElement("div");
+  row.className = "sat-pred-row";
+  const dir = `${azToCardinal(pass.azimuth_aos_deg)} → ${azToCardinal(pass.azimuth_los_deg)}`;
+  row.innerHTML = [
+    `<span class="sat-pred-col-time">${formatPredTime(pass.aos_ms)}</span>`,
+    `<span class="sat-pred-col-sat">${pass.satellite}</span>`,
+    `<span class="sat-pred-col-el ${elevationClass(pass.max_elevation_deg)}">${pass.max_elevation_deg.toFixed(1)}°</span>`,
+    `<span class="sat-pred-col-dur">${formatPredDuration(pass.duration_s)}</span>`,
+    `<span class="sat-pred-col-dir">${dir}</span>`
+  ].join("");
+  return row;
+}
+function getFilteredPredictions() {
+  let items = satPredData;
+  if (satPredCategory !== "all") items = items.filter((p) => p.category === satPredCategory);
+  if (satPredMinEl > 0) items = items.filter((p) => p.max_elevation_deg >= satPredMinEl);
+  if (satPredFilterText) items = items.filter((p) => p.satellite.toUpperCase().includes(satPredFilterText));
+  return items;
+}
+function applyPredFilters() {
+  renderSatPredictions(getFilteredPredictions());
+}
+var satPredictionFilter = satDom.predFilter;
+satPredictionFilter?.addEventListener("input", () => {
+  satPredFilterText = satPredictionFilter.value.trim().toUpperCase();
+  applyPredFilters();
+});
+var satPredictionMinElevation = satDom.predMinEl;
+satPredictionMinElevation?.addEventListener("change", () => {
+  satPredMinEl = Number.parseInt(satPredictionMinElevation.value, 10) || 0;
+  applyPredFilters();
+});
+var satPredictionCategory = satDom.predCategory;
+satPredictionCategory?.addEventListener("change", () => {
+  satPredCategory = satPredictionCategory.value;
+  applyPredFilters();
+});
+function renderSatPredictions(passes, error) {
+  stopCountdownTimer();
+  if (error) {
+    if (satDom.predCurrentList) satDom.predCurrentList.innerHTML = "";
+    if (satDom.predUpcomingList) satDom.predUpcomingList.innerHTML = "";
+    if (satDom.predCurrentSec) satDom.predCurrentSec.style.display = "none";
+    if (satDom.predUpcomingSec) satDom.predUpcomingSec.style.display = "none";
+    if (satDom.predStatus) satDom.predStatus.textContent = error;
+    return;
+  }
+  if (!Array.isArray(passes) || passes.length === 0) {
+    if (satDom.predCurrentList) satDom.predCurrentList.innerHTML = "";
+    if (satDom.predUpcomingList) satDom.predUpcomingList.innerHTML = "";
+    if (satDom.predCurrentSec) satDom.predCurrentSec.style.display = "none";
+    if (satDom.predUpcomingSec) satDom.predUpcomingSec.style.display = "none";
+    if (satDom.predStatus) satDom.predStatus.textContent = "No passes found in the next 24 hours.";
+    return;
+  }
+  const now = Date.now();
+  const current = passes.filter((p) => p.aos_ms <= now && p.los_ms > now);
+  const upcoming = passes.filter((p) => p.aos_ms > now);
+  if (satDom.predCurrentSec) satDom.predCurrentSec.style.display = current.length > 0 ? "" : "none";
+  if (satDom.predCurrentList) {
+    if (current.length === 0) {
+      satDom.predCurrentList.innerHTML = "";
+    } else {
+      const frag = document.createDocumentFragment();
+      for (const pass of current) frag.appendChild(buildCurrentPassRow(pass, now));
+      satDom.predCurrentList.replaceChildren(frag);
+    }
+  }
+  const upcomingLimit = satPredShowAll ? upcoming.length : SAT_PRED_PAGE_SIZE;
+  const visibleUpcoming = upcoming.slice(0, upcomingLimit);
+  const hiddenCount = upcoming.length - visibleUpcoming.length;
+  if (satDom.predUpcomingSec) satDom.predUpcomingSec.style.display = upcoming.length > 0 ? "" : "none";
+  if (satDom.predUpcomingList) {
+    const frag = document.createDocumentFragment();
+    for (const pass of visibleUpcoming) frag.appendChild(buildUpcomingPassRow(pass));
+    if (hiddenCount > 0) {
+      const moreRow = document.createElement("div");
+      moreRow.className = "sat-pred-row";
+      moreRow.style.cursor = "pointer";
+      moreRow.style.textAlign = "center";
+      moreRow.innerHTML = `<span style="grid-column:1/-1;color:var(--accent);font-size:0.82rem;">Show ${hiddenCount} more passes…</span>`;
+      moreRow.addEventListener("click", () => {
+        satPredShowAll = true;
+        renderSatPredictions(getFilteredPredictions());
+      });
+      frag.appendChild(moreRow);
+    }
+    satDom.predUpcomingList.replaceChildren(frag);
+  }
+  if (satDom.predStatus) {
+    let text = `${current.length} active · ${upcoming.length} upcoming · times in UTC`;
+    if (satPredSatCount > 0) text += ` · ${satPredSatCount} satellites tracked`;
+    satDom.predStatus.textContent = text;
+  }
+  if (current.length > 0 && satActiveView === "predictions") {
+    startCountdownTimer(satDom.predCurrentList);
+  }
+}
+async function loadSatPredictions() {
+  if (satDom.predStatus) satDom.predStatus.textContent = "Loading predictions…";
+  if (satDom.predCurrentList) satDom.predCurrentList.innerHTML = "";
+  if (satDom.predUpcomingList) satDom.predUpcomingList.innerHTML = "";
+  try {
+    const resp = await fetch("/sat_passes");
+    if (!resp.ok) throw new Error(`HTTP ${resp.status}`);
+    const data = await resp.json();
+    satPredSatCount = data.satellite_count || 0;
+    if (data.error) {
+      satPredData = [];
+      renderSatPredictions([], data.error);
+    } else {
+      satPredData = data.passes || [];
+      renderSatPredictions(getFilteredPredictions());
+    }
+  } catch (error) {
+    renderSatPredictions([], `Failed to load predictions: ${error instanceof Error ? error.message : String(error)}`);
+  }
+}
 satWindow.satShowOnMap = function(south, west, north, east) {
   if (typeof satWindow.enableMapSourceFilter === "function") {
     satWindow.enableMapSourceFilter("sat");

src/trx-client/trx-frontend/trx-frontend-http/assets/web/generated/satellite-predictions.js

@@ -1,228 +0,0 @@
-// src/plugins/satellite-predictions.ts
-var predWindow = window;
-var dom = {
-  page: document.getElementById("tab-satellites"),
-  filter: document.getElementById("sat-pred-filter"),
-  minElevation: document.getElementById("sat-pred-min-el"),
-  category: document.getElementById("sat-pred-category"),
-  currentList: document.getElementById("sat-pred-current-list"),
-  upcomingList: document.getElementById("sat-pred-list"),
-  currentSection: document.getElementById("sat-pred-current-section"),
-  upcomingSection: document.getElementById("sat-pred-upcoming-section"),
-  status: document.getElementById("sat-pred-status")
-};
-var PAGE_SIZE = 50;
-var predShowAll = false;
-var predData = [];
-var predFilterText = "";
-var predMinEl = 0;
-var predCategory = "all";
-var predSatCount = 0;
-var predCountdownTimer = null;
-function isPageVisible() {
-  return !!dom.page && dom.page.style.display !== "none";
-}
-function azToCardinal(deg) {
-  const dirs = ["N", "NE", "E", "SE", "S", "SW", "W", "NW"];
-  return dirs[Math.round(deg / 45) % 8] ?? "N";
-}
-function formatPredTime(ms) {
-  const d = new Date(ms);
-  const now = /* @__PURE__ */ new Date();
-  const dayNames = ["Sun", "Mon", "Tue", "Wed", "Thu", "Fri", "Sat"];
-  const day = d.getUTCDay() !== now.getUTCDay() ? `${dayNames[d.getUTCDay()] ?? ""} ` : "";
-  const hh = String(d.getUTCHours()).padStart(2, "0");
-  const mm = String(d.getUTCMinutes()).padStart(2, "0");
-  return `${day}${hh}:${mm}`;
-}
-function formatPredDuration(s) {
-  if (s >= 60) return `${Math.round(s / 60)} min`;
-  return `${s}s`;
-}
-function formatCountdown(ms) {
-  const totalSec = Math.max(0, Math.floor(ms / 1e3));
-  const m = Math.floor(totalSec / 60);
-  const s = totalSec % 60;
-  return `${m}:${String(s).padStart(2, "0")}`;
-}
-function elevationClass(deg) {
-  if (deg >= 45) return "sat-pred-el-high";
-  if (deg >= 10) return "sat-pred-el-mid";
-  return "sat-pred-el-low";
-}
-function stopCountdownTimer() {
-  if (predCountdownTimer) {
-    clearInterval(predCountdownTimer);
-    predCountdownTimer = null;
-  }
-}
-function startCountdownTimer(container) {
-  const countdownEls = container?.querySelectorAll(".sat-pred-col-countdown") ?? [];
-  if (countdownEls.length === 0) return;
-  predCountdownTimer = setInterval(() => {
-    if (!isPageVisible()) {
-      stopCountdownTimer();
-      return;
-    }
-    const n = Date.now();
-    let anyActive = false;
-    for (const el of countdownEls) {
-      const los = Number.parseInt(el.dataset.los ?? "0", 10);
-      const rem = los - n;
-      if (rem > 0) {
-        el.textContent = formatCountdown(rem);
-        anyActive = true;
-      } else {
-        el.textContent = "0:00";
-      }
-    }
-    if (!anyActive) {
-      stopCountdownTimer();
-      render(filtered());
-    }
-  }, 1e3);
-}
-function buildCurrentPassRow(pass, now) {
-  const row = document.createElement("div");
-  row.className = "sat-pred-row-current";
-  const dir = `${azToCardinal(pass.azimuth_aos_deg)} → ${azToCardinal(pass.azimuth_los_deg)}`;
-  const remaining = Math.max(0, pass.los_ms - now);
-  row.innerHTML = [
-    `<span class="sat-pred-col-sat">${pass.satellite}</span>`,
-    `<span class="sat-pred-col-el ${elevationClass(pass.max_elevation_deg)}">${pass.max_elevation_deg.toFixed(1)}°</span>`,
-    `<span class="sat-pred-col-time">${formatPredTime(pass.aos_ms)}</span>`,
-    `<span class="sat-pred-col-time">${formatPredTime(pass.los_ms)}</span>`,
-    `<span class="sat-pred-col-countdown" data-los="${pass.los_ms}">${formatCountdown(remaining)}</span>`,
-    `<span class="sat-pred-col-dir">${dir}</span>`
-  ].join("");
-  return row;
-}
-function buildUpcomingPassRow(pass) {
-  const row = document.createElement("div");
-  row.className = "sat-pred-row";
-  const dir = `${azToCardinal(pass.azimuth_aos_deg)} → ${azToCardinal(pass.azimuth_los_deg)}`;
-  row.innerHTML = [
-    `<span class="sat-pred-col-time">${formatPredTime(pass.aos_ms)}</span>`,
-    `<span class="sat-pred-col-sat">${pass.satellite}</span>`,
-    `<span class="sat-pred-col-el ${elevationClass(pass.max_elevation_deg)}">${pass.max_elevation_deg.toFixed(1)}°</span>`,
-    `<span class="sat-pred-col-dur">${formatPredDuration(pass.duration_s)}</span>`,
-    `<span class="sat-pred-col-dir">${dir}</span>`
-  ].join("");
-  return row;
-}
-function filtered() {
-  let items = predData;
-  if (predCategory !== "all") items = items.filter((p) => p.category === predCategory);
-  if (predMinEl > 0) items = items.filter((p) => p.max_elevation_deg >= predMinEl);
-  if (predFilterText) items = items.filter((p) => p.satellite.toUpperCase().includes(predFilterText));
-  return items;
-}
-function applyFilters() {
-  render(filtered());
-}
-var filterInput = dom.filter;
-filterInput?.addEventListener("input", () => {
-  predFilterText = filterInput.value.trim().toUpperCase();
-  applyFilters();
-});
-var minElevationSelect = dom.minElevation;
-minElevationSelect?.addEventListener("change", () => {
-  predMinEl = Number.parseInt(minElevationSelect.value, 10) || 0;
-  applyFilters();
-});
-var categorySelect = dom.category;
-categorySelect?.addEventListener("change", () => {
-  predCategory = categorySelect.value;
-  applyFilters();
-});
-function render(passes, error) {
-  stopCountdownTimer();
-  if (error) {
-    if (dom.currentList) dom.currentList.innerHTML = "";
-    if (dom.upcomingList) dom.upcomingList.innerHTML = "";
-    if (dom.currentSection) dom.currentSection.style.display = "none";
-    if (dom.upcomingSection) dom.upcomingSection.style.display = "none";
-    if (dom.status) dom.status.textContent = error;
-    return;
-  }
-  if (!Array.isArray(passes) || passes.length === 0) {
-    if (dom.currentList) dom.currentList.innerHTML = "";
-    if (dom.upcomingList) dom.upcomingList.innerHTML = "";
-    if (dom.currentSection) dom.currentSection.style.display = "none";
-    if (dom.upcomingSection) dom.upcomingSection.style.display = "none";
-    if (dom.status) dom.status.textContent = "No passes found in the next 24 hours.";
-    return;
-  }
-  const now = Date.now();
-  const current = passes.filter((p) => p.aos_ms <= now && p.los_ms > now);
-  const upcoming = passes.filter((p) => p.aos_ms > now);
-  if (dom.currentSection) dom.currentSection.style.display = current.length > 0 ? "" : "none";
-  if (dom.currentList) {
-    if (current.length === 0) {
-      dom.currentList.innerHTML = "";
-    } else {
-      const frag = document.createDocumentFragment();
-      for (const pass of current) frag.appendChild(buildCurrentPassRow(pass, now));
-      dom.currentList.replaceChildren(frag);
-    }
-  }
-  const upcomingLimit = predShowAll ? upcoming.length : PAGE_SIZE;
-  const visibleUpcoming = upcoming.slice(0, upcomingLimit);
-  const hiddenCount = upcoming.length - visibleUpcoming.length;
-  if (dom.upcomingSection) dom.upcomingSection.style.display = upcoming.length > 0 ? "" : "none";
-  if (dom.upcomingList) {
-    const frag = document.createDocumentFragment();
-    for (const pass of visibleUpcoming) frag.appendChild(buildUpcomingPassRow(pass));
-    if (hiddenCount > 0) {
-      const moreRow = document.createElement("div");
-      moreRow.className = "sat-pred-row";
-      moreRow.style.cursor = "pointer";
-      moreRow.style.textAlign = "center";
-      moreRow.innerHTML = `<span style="grid-column:1/-1;color:var(--accent);font-size:0.82rem;">Show ${hiddenCount} more passes…</span>`;
-      moreRow.addEventListener("click", () => {
-        predShowAll = true;
-        render(filtered());
-      });
-      frag.appendChild(moreRow);
-    }
-    dom.upcomingList.replaceChildren(frag);
-  }
-  if (dom.status) {
-    let text = `${current.length} active · ${upcoming.length} upcoming · times in UTC`;
-    if (predSatCount > 0) text += ` · ${predSatCount} satellites tracked`;
-    dom.status.textContent = text;
-  }
-  if (current.length > 0 && isPageVisible()) {
-    startCountdownTimer(dom.currentList);
-  }
-}
-async function load() {
-  if (dom.status) dom.status.textContent = "Loading predictions…";
-  if (dom.currentList) dom.currentList.innerHTML = "";
-  if (dom.upcomingList) dom.upcomingList.innerHTML = "";
-  try {
-    const resp = await fetch("/sat_passes");
-    if (!resp.ok) throw new Error(`HTTP ${resp.status}`);
-    const data = await resp.json();
-    predSatCount = data.satellite_count || 0;
-    if (data.error) {
-      predData = [];
-      render([], data.error);
-    } else {
-      predData = data.passes || [];
-      render(filtered());
-    }
-  } catch (error) {
-    render([], `Failed to load predictions: ${error instanceof Error ? error.message : String(error)}`);
-  }
-}
-function clearPredictionDom() {
-  stopCountdownTimer();
-  if (dom.currentList) dom.currentList.innerHTML = "";
-  if (dom.upcomingList) dom.upcomingList.innerHTML = "";
-}
-predWindow.clearSatPredictionDom = clearPredictionDom;
-predWindow.refreshSatPredictions = function() {
-  predShowAll = false;
-  void load();
-};

src/trx-client/trx-frontend/trx-frontend-http/assets/web/generated/sstv.js

@@ -1,7 +1,3 @@
-import {
-  forActiveRig,
-  isActiveRigDecode
-} from "./chunk-S57W63QN.js";
 import {
   hostCore
 } from "./chunk-KL66PICH.js";
@@ -115,7 +111,6 @@ function paintRow(line, rgb) {
   liveRows = Math.max(liveRows, line + 1);
 }
 function onProgress(msg) {
-  if (!isActiveRigDecode(msg.rig_id)) return;
   if (msg.state) {
     if (sstvDom.status) sstvDom.status.textContent = msg.state;
     beginPicture(msg.mode || "", msg.width || 0, msg.height || 0);
@@ -136,20 +131,15 @@ function onImage(msg) {
   sstvHistory.push(image);
   if (sstvHistory.length > SSTV_MAX_IMAGES) sstvHistory.shift();
   pruneHistory();
-  if (!isActiveRigDecode(image.rig_id)) return;
   if (sstvDom.status) {
     sstvDom.status.textContent = image.complete ? `Received ${image.mode ?? "picture"}` : `Partial ${image.mode ?? "picture"} — ${image.lines ?? 0} lines`;
   }
   scheduleUi("sstv-latest", renderLatestCard);
   if (activeView === "history") scheduleUi("sstv-history", renderHistoryTable);
 }
-function sstvRigImages() {
-  return forActiveRig(sstvHistory);
-}
 function renderLatestCard() {
   if (!sstvDom.liveLatest) return;
-  const rigImages = sstvRigImages();
-  const latest = rigImages[rigImages.length - 1];
+  const latest = sstvHistory[sstvHistory.length - 1];
   if (!latest) {
     sstvDom.liveLatest.innerHTML = "";
     return;
@@ -170,9 +160,8 @@ function renderLatestCard() {
     </div>`;
 }
 function filteredHistory() {
-  const rigImages = sstvRigImages();
   const text = filterText.trim().toLowerCase();
-  const matching = text ? rigImages.filter((image) => (image.mode ?? "").toLowerCase().includes(text)) : rigImages;
+  const matching = text ? sstvHistory.filter((image) => (image.mode ?? "").toLowerCase().includes(text)) : sstvHistory.slice();
   const newestFirst = (sstvDom.sortSelect?.value ?? "newest") === "newest";
   matching.sort((a, b) => (newestFirst ? 1 : -1) * ((b._tsMs ?? 0) - (a._tsMs ?? 0)));
   return matching;
@@ -252,11 +241,7 @@ sstvWindow.trxPluginRuntime.registerDecoder({
   onMessage: onImage,
   restore: restoreHistory,
   prune: renderHistoryTable,
-  reset: resetHistoryView,
-  rerender: () => {
-    renderLatestCard();
-    renderHistoryTable();
-  }
+  reset: resetHistoryView
 });
 sstvWindow.trxPluginRuntime.registerDecoder({
   id: "sstv_progress",

src/trx-client/trx-frontend/trx-frontend-http/assets/web/generated/vdes.js

@@ -1,7 +1,3 @@
-import {
-  forActiveRig,
-  isActiveRigDecode
-} from "./chunk-S57W63QN.js";
 import {
   hostCore
 } from "./chunk-KL66PICH.js";
@@ -64,21 +60,17 @@ function vdesHexPreview(rawBytes) {
   if (!Array.isArray(rawBytes) || rawBytes.length === 0) return "--";
   return rawBytes.slice(0, 20).map((value) => value.toString(16).padStart(2, "0")).join(" ").toUpperCase();
 }
-function vdesRigMessages() {
-  return forActiveRig(vdesMessageHistory);
-}
 function updateVdesSummary() {
   pruneVdesMessageHistory();
   if (vdesChannelSummaryEl) {
     vdesChannelSummaryEl.textContent = currentVdesCenterText();
   }
-  const rigMessages = vdesRigMessages();
   if (vdesFrameCountEl) {
-    const count = rigMessages.length;
+    const count = vdesMessageHistory.length;
     vdesFrameCountEl.textContent = `${count} burst${count === 1 ? "" : "s"}`;
   }
   if (vdesLatestSeenEl) {
-    const latest = rigMessages[0];
+    const latest = vdesMessageHistory[0];
     vdesLatestSeenEl.textContent = latest ? vdesAgeText(latest._tsMs) : "No traffic yet";
   }
 }
@@ -145,7 +137,7 @@ function updateVdesBar() {
   updateVdesSummary();
   const isVdes = (document.getElementById("mode")?.value || "").toUpperCase() === "VDES";
   const cutoffMs = Date.now() - VDES_BAR_WINDOW_MS;
-  const messages = vdesMessageHistory.filter((msg) => (msg._tsMs ?? 0) >= cutoffMs && isActiveRigDecode(msg.rig_id)).slice(0, 6);
+  const messages = vdesMessageHistory.filter((msg) => (msg._tsMs ?? 0) >= cutoffMs).slice(0, 6);
   if (!isVdes || messages.length === 0) {
     vdesBarOverlay.style.display = "none";
     vdesBarOverlay.innerHTML = "";
@@ -190,7 +182,7 @@ function renderVdesHistory() {
     return;
   }
   const fragment = document.createDocumentFragment();
-  for (const message of vdesRigMessages()) {
+  for (const message of vdesMessageHistory) {
     fragment.appendChild(renderVdesRow(message));
   }
   vdesMessagesEl.replaceChildren(fragment);
@@ -217,10 +209,10 @@ function normalizeServerVdesMessage(msg) {
 }
 function onServerVdesBatch(messages) {
   if (!Array.isArray(messages) || messages.length === 0) return;
+  if (vdesStatus) vdesStatus.textContent = "Receiving";
   const normalized = [];
   for (const msg of messages) {
     const next = normalizeServerVdesMessage(msg);
-    if (vdesStatus && isActiveRigDecode(next.rig_id)) vdesStatus.textContent = "Receiving";
     const tsMs = Number.isFinite(next.ts_ms) ? Number(next.ts_ms) : Date.now();
     next._tsMs = tsMs;
     next._ts = new Date(tsMs).toLocaleTimeString([], {
@@ -259,8 +251,8 @@ function plotVdesMessage(msg) {
   vdesWindow.vdesMapAddPoint(msg);
 }
 function onServerVdes(msg) {
+  if (vdesStatus) vdesStatus.textContent = "Receiving";
   const next = normalizeServerVdesMessage(msg);
-  if (vdesStatus && isActiveRigDecode(next.rig_id)) vdesStatus.textContent = "Receiving";
   addVdesMessage(next);
   plotVdesMessage(next);
 }
@@ -277,10 +269,6 @@ window.trxPluginRuntime.registerDecoder({
   restore: onServerVdesBatch,
   reset: resetVdesHistoryView,
   prune: pruneVdesHistoryView,
-  rerender: () => {
-    updateVdesBar();
-    renderVdesHistory();
-  },
   // Oldest first, so tracks are rebuilt in the order they happened.
   syncMap: () => {
     for (const entry of [...vdesMessageHistory].reverse()) plotVdesMessage(entry);

src/trx-client/trx-frontend/trx-frontend-http/assets/web/generated/wefax.js

@@ -1,7 +1,3 @@
-import {
-  forActiveRig,
-  isActiveRigDecode
-} from "./chunk-S57W63QN.js";
 import {
   hostCore
 } from "./chunk-KL66PICH.js";
@@ -106,17 +102,13 @@ function paintLine(lineBytes) {
   wefaxLiveCtx.putImageData(imgData, 0, y);
   wefaxLiveLineCount++;
 }
-function wefaxRigImages() {
-  return forActiveRig(wefaxImageHistory);
-}
 function renderWefaxLatestCard() {
   if (!wefaxDom.liveLatest) return;
-  const rigImages = wefaxRigImages();
-  if (rigImages.length === 0) {
+  if (wefaxImageHistory.length === 0) {
     wefaxDom.liveLatest.innerHTML = '<div style="color:var(--text-muted);font-size:0.82rem;">No images decoded yet. Enable the decoder and tune to a WEFAX station.</div>';
     return;
   }
-  const img = rigImages[0];
+  const img = wefaxImageHistory[0];
   if (!img) return;
   const ts = img._ts || "--";
   const date = img._tsMs ? new Date(img._tsMs).toLocaleDateString() : "";
@@ -137,7 +129,7 @@ function renderWefaxLatestCard() {
   wefaxDom.liveLatest.innerHTML = html;
 }
 function getWefaxFilteredHistory() {
-  let items = wefaxRigImages();
+  let items = wefaxImageHistory;
   if (wefaxFilterText) {
     items = items.filter(function(i) {
       const haystack = [
@@ -181,7 +173,7 @@ function renderWefaxHistoryTable() {
   }
   wefaxDom.historyList.replaceChildren(fragment);
   if (wefaxDom.historyCount) {
-    const total = wefaxRigImages().length;
+    const total = wefaxImageHistory.length;
     const shown = items.length;
     wefaxDom.historyCount.textContent = total === 0 ? "No images yet" : shown === total ? `${String(total)} image${total === 1 ? "" : "s"}` : `${String(shown)} of ${String(total)} images`;
   }
@@ -216,7 +208,6 @@ function addWefaxImage(msg) {
   }
 }
 function onServerWefaxProgress(msg) {
-  if (!isActiveRigDecode(msg.rig_id)) return;
   if (msg.state && !msg.line_data) {
     if (wefaxDom.status) {
       wefaxDom.status.textContent = msg.state;
@@ -243,7 +234,6 @@ function onServerWefaxProgress(msg) {
 }
 function onServerWefax(msg) {
   addWefaxImage(msg);
-  if (!isActiveRigDecode(msg.rig_id)) return;
   if (wefaxDom.liveContainer) wefaxDom.liveContainer.style.display = "none";
   if (wefaxDom.status) {
     wefaxDom.status.textContent = `Complete — ${String(msg.line_count ?? 0)} lines`;
@@ -338,11 +328,7 @@ wefaxWindow.trxPluginRuntime.registerDecoder({
   onMessage: onServerWefax,
   restore: restoreWefaxHistory,
   prune: pruneWefaxHistoryView,
-  reset: resetWefaxHistoryView,
-  rerender: () => {
-    renderWefaxLatestCard();
-    renderWefaxHistoryTable();
-  }
+  reset: resetWefaxHistoryView
 });
 wefaxWindow.trxPluginRuntime.registerDecoder({
   id: "wefax_progress",

src/trx-client/trx-frontend/trx-frontend-http/assets/web/generated/wspr.js

@@ -1,7 +1,3 @@
-import {
-  forActiveRig,
-  isActiveRigDecode
-} from "./chunk-S57W63QN.js";
 import {
   hostCore
 } from "./chunk-KL66PICH.js";
@@ -68,10 +64,10 @@ function renderWsprRow(msg) {
 function renderWsprHistory() {
   pruneWsprMessageHistory();
   if (!wsprMessagesEl) return;
-  const rigMessages = forActiveRig(wsprMessageHistory);
   const fragment = document.createDocumentFragment();
-  for (const message of rigMessages) {
-    fragment.appendChild(renderWsprRow(message));
+  for (let i = 0; i < wsprMessageHistory.length; i += 1) {
+    const message = wsprMessageHistory[i];
+    if (message) fragment.appendChild(renderWsprRow(message));
   }
   wsprMessagesEl.replaceChildren(fragment);
 }
@@ -94,7 +90,6 @@ function normalizeServerWsprMessage(msg) {
     station,
     rfHz,
     history: {
-      rig_id: msg.rig_id ?? null,
       receiver: wsprWindow.getDecodeRigMeta ? wsprWindow.getDecodeRigMeta() : null,
       ts_ms: msg.ts_ms,
       snr_db: msg.snr_db,
@@ -106,10 +101,10 @@ function normalizeServerWsprMessage(msg) {
 }
 function onServerWsprBatch(messages) {
   if (!Array.isArray(messages) || messages.length === 0) return;
+  if (wsprStatus) wsprStatus.textContent = "Receiving";
   const normalized = [];
   for (const msg of messages) {
     const next = normalizeServerWsprMessage(msg);
-    if (wsprStatus && isActiveRigDecode(msg.rig_id)) wsprStatus.textContent = "Receiving";
     if (next.grids.length > 0 && wsprWindow.mapAddLocator) {
       wsprWindow.mapAddLocator(next.raw, next.grids, "wspr", next.station, {
         ...msg,
@@ -256,7 +251,7 @@ document.getElementById("settings-clear-wspr-history")?.addEventListener("click"
   })();
 });
 function onServerWspr(msg) {
-  if (wsprStatus && isActiveRigDecode(msg.rig_id)) wsprStatus.textContent = "Receiving";
+  if (wsprStatus) wsprStatus.textContent = "Receiving";
   const next = normalizeServerWsprMessage(msg);
   if (next.grids.length > 0 && wsprWindow.mapAddLocator) {
     wsprWindow.mapAddLocator(next.raw, next.grids, "wspr", next.station, {
@@ -272,6 +267,5 @@ wsprWindow.trxPluginRuntime.registerDecoder({
   onBatch: onServerWsprBatch,
   restore: onServerWsprBatch,
   prune: pruneWsprHistoryView,
-  reset: resetWsprHistoryView,
-  rerender: renderWsprHistory
+  reset: resetWsprHistoryView
 });

src/trx-client/trx-frontend/trx-frontend-http/assets/web/index.html

@@ -24,7 +24,6 @@ SPDX-License-Identifier: GPL-2.0-or-later
     <symbol id="icon-bookmark" viewBox="0 0 16 16" fill="none" stroke="currentColor" stroke-width="1.5" stroke-linecap="round" stroke-linejoin="round"><path d="M4 2h8v12l-4-2.5L4 14V2z"/></symbol>
     <symbol id="icon-digital" viewBox="0 0 16 16" fill="none" stroke="currentColor" stroke-width="1.5" stroke-linecap="round" stroke-linejoin="round"><path d="M1 11.5h2.6V4.5h3.2v7h3.2v-7h3.2v7H15"/></symbol>
     <symbol id="icon-map" viewBox="0 0 16 16" fill="none" stroke="currentColor" stroke-width="1.5" stroke-linecap="round" stroke-linejoin="round"><path d="M8 2a4 4 0 0 1 4 4c0 3-4 8-4 8S4 9 4 6a4 4 0 0 1 4-4z"/><circle cx="8" cy="6" r="1.2" fill="currentColor" stroke="none"/></symbol>
-    <symbol id="icon-satellite" viewBox="0 0 16 16" fill="none" stroke="currentColor" stroke-width="1.4" stroke-linecap="round" stroke-linejoin="round"><path d="M2 13.2 5.6 9.6"/><path d="M4.2 8.2a3.4 3.4 0 0 1 4.8 4.8z"/><path d="M9.2 6.6a3.2 3.2 0 0 1 2.6 2.6"/><path d="M9.8 3.6a6.2 6.2 0 0 1 5.2 5.2"/></symbol>
     <symbol id="icon-stats" viewBox="0 0 16 16" fill="none" stroke="currentColor" stroke-width="1.4" stroke-linecap="round" stroke-linejoin="round"><path d="M2 14h12"/><rect x="3" y="8" width="2" height="6" rx="0.4" fill="currentColor" stroke="none" opacity="0.6"/><rect x="7" y="5" width="2" height="9" rx="0.4" fill="currentColor" stroke="none" opacity="0.75"/><rect x="11" y="2" width="2" height="12" rx="0.4" fill="currentColor" stroke="none" opacity="0.9"/></symbol>
     <symbol id="icon-record" viewBox="0 0 16 16" fill="none" stroke="currentColor" stroke-width="1.5" stroke-linecap="round" stroke-linejoin="round"><circle cx="8" cy="8" r="6"/><circle cx="8" cy="8" r="2.5" fill="currentColor" stroke="none"/></symbol>
     <symbol id="icon-settings" viewBox="0 0 16 16" fill="none" stroke="currentColor" stroke-width="1.4" stroke-linecap="round" stroke-linejoin="round"><path d="M9.8 3.1a2.6 2.6 0 0 0-2.2 3.9L3.4 11.2a1.2 1.2 0 1 0 1.7 1.7l4.2-4.2a2.6 2.6 0 0 0 3.9-2.2l-1.8.6-1.2-1.2z"/><path d="M10.2 5.8 12 4"/></symbol>
@@ -64,10 +63,6 @@ SPDX-License-Identifier: GPL-2.0-or-later
             <svg class="tab-icon" aria-hidden="true"><use href="#icon-map"/></svg>
             <span class="tab-label">Map</span>
           </button>
-          <button class="tab" data-tab="satellites">
-            <svg class="tab-icon" aria-hidden="true"><use href="#icon-satellite"/></svg>
-            <span class="tab-label">Satellites</span>
-          </button>
           <button class="tab" data-tab="statistics">
             <svg class="tab-icon" aria-hidden="true"><use href="#icon-stats"/></svg>
             <span class="tab-label">Statistics</span>
@@ -923,6 +918,7 @@ SPDX-License-Identifier: GPL-2.0-or-later
         <div class="sat-view-bar">
           <button id="sat-view-live" class="sat-view-btn sat-view-active" type="button">Live</button>
           <button id="sat-view-history" class="sat-view-btn" type="button">History</button>
+          <button id="sat-view-predictions" class="sat-view-btn" type="button">Predictions</button>
         </div>
         <!-- Live view -->
         <div id="sat-live-view">
@@ -964,6 +960,50 @@ SPDX-License-Identifier: GPL-2.0-or-later
           <div id="sat-history-list"></div>
           <small id="sat-history-count" style="color:var(--text-muted);font-size:0.75rem;">No images yet</small>
         </div>
+        <!-- Predictions view -->
+        <div id="sat-predictions-view" style="display:none;">
+          <div class="ft8-controls">
+            <input id="sat-pred-filter" class="ft8-filter" type="text" placeholder="Filter (e.g. ISS, NOAA, Meteor)" />
+            <select id="sat-pred-category" class="sat-sort-select">
+              <option value="all">All</option>
+              <option value="weather">Weather</option>
+              <option value="amateur">Ham Radio</option>
+              <option value="other">Other</option>
+            </select>
+            <select id="sat-pred-min-el" class="sat-sort-select">
+              <option value="0">All passes</option>
+              <option value="10">Min 10°</option>
+              <option value="20">Min 20°</option>
+              <option value="45">Min 45°</option>
+            </select>
+          </div>
+          <!-- Current passes -->
+          <div id="sat-pred-current-section">
+            <div class="sat-pred-section-title">Currently receivable</div>
+            <div class="sat-pred-header sat-pred-header-current">
+              <span class="sat-pred-col-sat">Satellite</span>
+              <span class="sat-pred-col-el">Max El</span>
+              <span class="sat-pred-col-time">AOS Start</span>
+              <span class="sat-pred-col-time">AOS End</span>
+              <span class="sat-pred-col-countdown">Time left</span>
+              <span class="sat-pred-col-dir">Direction</span>
+            </div>
+            <div id="sat-pred-current-list"></div>
+          </div>
+          <!-- Upcoming passes -->
+          <div id="sat-pred-upcoming-section">
+            <div class="sat-pred-section-title">Upcoming passes</div>
+            <div class="sat-pred-header">
+              <span class="sat-pred-col-time">AOS (UTC)</span>
+              <span class="sat-pred-col-sat">Satellite</span>
+              <span class="sat-pred-col-el">Max El</span>
+              <span class="sat-pred-col-dur">Duration</span>
+              <span class="sat-pred-col-dir">Direction</span>
+            </div>
+            <div id="sat-pred-list"></div>
+          </div>
+          <small id="sat-pred-status" style="color:var(--text-muted);font-size:0.75rem;">Loading predictions&hellip;</small>
+        </div>
       </div>
       <div id="subtab-wefax" class="sub-tab-panel" style="display:none;">
         <div class="ft8-controls">
@@ -1077,51 +1117,6 @@ SPDX-License-Identifier: GPL-2.0-or-later
       </div>
       </template>
     </div>
-    <div id="tab-satellites" class="tab-panel" style="display:none;">
-      <h2 class="section-heading">Satellites</h2>
-      <div class="ft8-controls">
-        <input id="sat-pred-filter" class="ft8-filter" type="text" placeholder="Filter (e.g. ISS, NOAA, Meteor)" />
-        <select id="sat-pred-category" class="sat-sort-select">
-          <option value="all">All</option>
-          <option value="weather">Weather</option>
-          <option value="amateur">Ham Radio</option>
-          <option value="other">Other</option>
-        </select>
-        <select id="sat-pred-min-el" class="sat-sort-select">
-          <option value="0">All passes</option>
-          <option value="10">Min 10°</option>
-          <option value="20">Min 20°</option>
-          <option value="45">Min 45°</option>
-        </select>
-      </div>
-      <!-- Current passes -->
-      <div id="sat-pred-current-section">
-        <div class="sat-pred-section-title">Currently receivable</div>
-        <div class="sat-pred-header sat-pred-header-current">
-          <span class="sat-pred-col-sat">Satellite</span>
-          <span class="sat-pred-col-el">Max El</span>
-          <span class="sat-pred-col-time">AOS Start</span>
-          <span class="sat-pred-col-time">AOS End</span>
-          <span class="sat-pred-col-countdown">Time left</span>
-          <span class="sat-pred-col-dir">Direction</span>
-        </div>
-        <div id="sat-pred-current-list"></div>
-      </div>
-      <!-- Upcoming passes -->
-      <div id="sat-pred-upcoming-section">
-        <div class="sat-pred-section-title">Upcoming passes</div>
-        <div class="sat-pred-header">
-          <span class="sat-pred-col-time">AOS (UTC)</span>
-          <span class="sat-pred-col-sat">Satellite</span>
-          <span class="sat-pred-col-el">Max El</span>
-          <span class="sat-pred-col-dur">Duration</span>
-          <span class="sat-pred-col-dir">Direction</span>
-        </div>
-        <div id="sat-pred-list"></div>
-      </div>
-      <small id="sat-pred-status" style="color:var(--text-muted);font-size:0.75rem;">Loading predictions&hellip;</small>
-    </div>
-
     <div id="tab-statistics" class="tab-panel" style="display:none;">
       <h2 class="section-heading">Statistics</h2>
       <template id="tmpl-statistics">

src/trx-client/trx-frontend/trx-frontend-http/assets/web/style.css

@@ -3816,12 +3816,11 @@ body[data-operator-layout="broadcast"] #cw-bar-overlay {
 @media (max-width: 760px) {
   body[data-operator-layout="broadcast"] #wfm-controls-col { flex-basis: 100%; }
 }
-/* One navigation model at every width.  Satellites, Statistics, Recorder,
- * Settings and About are occasional destinations: they live behind More rather
- * than competing with the operating tabs for the row and then scrolling out of
+/* One navigation model at every width.  Statistics, Recorder, Settings and
+ * About are occasional destinations: they live behind More rather than
+ * competing with the operating tabs for the row and then scrolling out of
  * reach.  The mobile layout already grouped them this way; the desktop strip
  * now matches it, which is why the tab strip no longer needs to scroll. */
-.tab-bar-nav .tab[data-tab="satellites"],
 .tab-bar-nav .tab[data-tab="statistics"],
 .tab-bar-nav .tab[data-tab="recorder"],
 .tab-bar-nav .tab[data-tab="settings"],
@@ -4031,9 +4030,8 @@ body[data-operator-layout="broadcast"] #cw-bar-overlay {
     box-shadow: inset 0 1px 0 color-mix(in srgb, #ffffff 8%, transparent);
   }
   .tab-icon, .tab-more-icon { display: block; }
-  .tab[data-tab="satellites"], .tab[data-tab="statistics"],
-  .tab[data-tab="recorder"], .tab[data-tab="settings"],
-  .tab[data-tab="about"] { display: none; }
+  .tab[data-tab="statistics"], .tab[data-tab="recorder"],
+  .tab[data-tab="settings"], .tab[data-tab="about"] { display: none; }
   .mobile-more-btn { display: flex; }
   .mobile-more-menu {
     position: fixed;

src/trx-client/trx-frontend/trx-frontend-http/frontend/build.mjs

@@ -30,7 +30,6 @@ await build({
     "hf-aprs": path.join(sourceDir, "plugins", "hf-aprs.ts"),
     sat: path.join(sourceDir, "plugins", "sat.ts"),
     "sat-scheduler": path.join(sourceDir, "plugins", "sat-scheduler.ts"),
-    "satellite-predictions": path.join(sourceDir, "plugins", "satellite-predictions.ts"),
     vchan: path.join(sourceDir, "plugins", "vchan.ts"),
     bookmarks: path.join(sourceDir, "plugins", "bookmarks.ts"),
     scheduler: path.join(sourceDir, "plugins", "scheduler.ts"),

src/trx-client/trx-frontend/trx-frontend-http/frontend/package.json

@@ -12,7 +12,7 @@
     "typecheck": "tsc --project tsconfig.json && tsc --project tsconfig.worker.json",
     "lint": "eslint \"src/**/*.ts\" \"tests/**/*.mjs\" build.mjs --no-error-on-unmatched-pattern",
     "test": "node --test tests/*.test.mjs",
-    "test:browser": "node tests/browser-smoke.mjs && node tests/spectrum-layout.mjs && node tests/decode-flow.mjs && node tests/tune-links.mjs && node tests/mobile-layout.mjs && node tests/satellite-predictions.mjs",
+    "test:browser": "node tests/browser-smoke.mjs && node tests/spectrum-layout.mjs && node tests/decode-flow.mjs && node tests/tune-links.mjs && node tests/mobile-layout.mjs",
     "verify-generated": "npm run generate-types && npm run build && git diff --exit-code -- ../assets/web/generated src/api/generated.ts"
   },
   "devDependencies": {

src/trx-client/trx-frontend/trx-frontend-http/frontend/src/app.ts

@@ -385,14 +385,12 @@ declare global {
     refreshCwTonePicker?(): void;
     updateFt8RfDisplay?(): void;
     clearSatPredictionDom?(): void;
-    refreshSatPredictions?(): void;
     syncWefaxToggle?(enabled: boolean): void;
     syncSstvToggle?(enabled: boolean): void;
     updateAisBar?(value?: number): void;
     updateVdesBar?(value?: number): void;
     updateAprsBar?(value?: number): void;
     updateFt8Bar?(value?: number): void;
-    updateCwBar?(value?: number): void;
     updateSatLiveState?(value: unknown): void;
     applyCwAutoUi?(enabled: boolean): void;
     applyCwAutoUiFromServer?(enabled: boolean): void;
@@ -2208,17 +2206,6 @@ function resetRdsDisplay() {
   updateRdsPsOverlay(primaryRds);
 }
 
-// The mini views over the waterfall show only what the rig on screen heard, so
-// they have to be repainted whenever that rig — or its mode — changes, not just
-// when the next decode happens to arrive.
-function refreshDecodeBars() {
-  window.updateAisBar?.();
-  window.updateVdesBar?.();
-  window.updateAprsBar?.();
-  window.updateFt8Bar?.();
-  window.updateCwBar?.();
-}
-
 function resetDecoderStateOnRigSwitch() {
   // RDS
   primaryRds = null;
@@ -2238,12 +2225,6 @@ function resetDecoderStateOnRigSwitch() {
     const el = document.getElementById(id);
     if (el) el.textContent = "--";
   });
-
-  // The decode stream is not rig-scoped, so the histories behind the mini views
-  // and the decoder panels survive the switch: repaint both for the rig now
-  // selected instead of leaving the outgoing rig's traffic on screen.
-  refreshDecodeBars();
-  window.trxPluginRuntime.rerenderAll();
 }
 
 function resetWfmStereoIndicator() {
@@ -3694,7 +3675,10 @@ function render(update: AppUpdate) {
     const connText = _decodeConnectedText[d.id] || "Connected, listening for packets";
     setModeBoundDecodeStatus(el, d.active_modes, "Select " + d.active_modes[0] + " mode to decode", connText);
   }
-  refreshDecodeBars();
+  if (window.updateAisBar) window.updateAisBar();
+  if (window.updateVdesBar) window.updateVdesBar();
+  if (window.updateAprsBar) window.updateAprsBar();
+  if (window.updateFt8Bar) window.updateFt8Bar();
   // Toggle-gated decoder status: clear "Receiving" when decoder disabled or mode wrong.
   for (const d of decoderRegistry) {
     if (d.activation !== "toggle") continue;
@@ -4865,7 +4849,6 @@ function _initMapWhenReady() {
 
 function navigateToTab(name: TabName, options: { updateHistory?: boolean; replaceHistory?: boolean } = {}) {
   window.trxUi?.closeMobileOverlays?.();
-  const leavingSatellites = _activeTab === "satellites" && name !== "satellites";
   const { updateHistory = true, replaceHistory = false } = options;
   if (authEnabled && !authRole && name !== "main") {
     showAuthGate(false);
@@ -4906,13 +4889,7 @@ function navigateToTab(name: TabName, options: { updateHistory?: boolean; replac
     updateTabHistory(name, replaceHistory);
   }
   scheduleSpectrumLayout();
-  // Its countdowns tick every second, so the page stops when it is not on screen.
-  if (leavingSatellites) window.clearSatPredictionDom?.();
-  void loadPluginsForTab(name).then(() => {
-    // Passes go stale while the page is closed, so each visit reloads them.
-    // The first visit is what imports the module, which renders on its own.
-    if (name === "satellites") window.refreshSatPredictions?.();
-  }).catch((error: unknown) => { console.error(error); });
+  void loadPluginsForTab(name).catch((error: unknown) => { console.error(error); });
   if (name === "map") {
     _initMapWhenReady();
   }
@@ -5264,6 +5241,10 @@ function _wireSubTabBar(bar: WiredElement) {
         if (window.refreshCwTonePicker) window.refreshCwTonePicker();
       });
     }
+    // Clear SAT prediction DOM when leaving the SAT tab to reduce node count.
+    if (btn.dataset.subtab !== "sat" && typeof window.clearSatPredictionDom === "function") {
+      window.clearSatPredictionDom();
+    }
   });
 }
 document.querySelectorAll<WiredElement>(".sub-tab-bar").forEach(_wireSubTabBar);

src/trx-client/trx-frontend/trx-frontend-http/frontend/src/features/navigation/routes.ts

@@ -3,7 +3,7 @@
 // SPDX-License-Identifier: GPL-2.0-or-later
 
 export const TAB_ORDER = [
-  "main", "bookmarks", "digital-modes", "map", "satellites", "statistics", "recorder", "settings", "about",
+  "main", "bookmarks", "digital-modes", "map", "statistics", "recorder", "settings", "about",
 ] as const;
 
 export type TabName = typeof TAB_ORDER[number];
@@ -13,7 +13,6 @@ export const TAB_PATHS: Readonly<Record<TabName, string>> = {
   bookmarks: "/bookmarks",
   "digital-modes": "/digital-modes",
   map: "/map",
-  satellites: "/satellites",
   statistics: "/statistics",
   recorder: "/recorder",
   settings: "/settings",

src/trx-client/trx-frontend/trx-frontend-http/frontend/src/plugin-loader.ts

@@ -2,9 +2,7 @@
 //
 // SPDX-License-Identifier: GPL-2.0-or-later
 
-type PluginGroup =
-  | "digital-modes" | "map-data" | "map" | "satellites" | "statistics"
-  | "bookmarks" | "recorder" | "settings";
+type PluginGroup = "digital-modes" | "map-data" | "map" | "statistics" | "bookmarks" | "recorder" | "settings";
 
 const pluginGroups: Readonly<Record<PluginGroup, readonly string[]>> = {
   // AIS, VDES and the two APRS decoders have panels on this tab, so they load
@@ -17,7 +15,6 @@ const pluginGroups: Readonly<Record<PluginGroup, readonly string[]>> = {
   ],
   "map-data": ["/map-core.js", "/ais.js", "/vdes.js", "/aprs.js", "/hf-aprs.js"],
   map: ["/map-core.js", "/ais.js", "/vdes.js", "/aprs.js", "/hf-aprs.js", "/sat.js", "/sat-scheduler.js"],
-  satellites: ["/satellite-predictions.js"],
   statistics: ["/map-core.js"],
   bookmarks: ["/bookmarks.js"],
   recorder: [],

src/trx-client/trx-frontend/trx-frontend-http/frontend/src/plugin-runtime.ts

@@ -81,7 +81,6 @@ const runtime: TrxPluginRuntime = {
     plugin.prune();
     return true;
   },
-  rerenderAll() { for (const plugin of decoders.values()) plugin.rerender?.(); },
   syncMapAll() { for (const plugin of decoders.values()) plugin.syncMap?.(); },
   clearQueued() { queued.clear(); },
   hasDecoder: (id) => decoders.has(id),

src/trx-client/trx-frontend/trx-frontend-http/frontend/src/plugins/active-rig.ts

@@ -1,26 +0,0 @@
-// SPDX-FileCopyrightText: 2026 Stan Grams <sjg@haxx.space>
-//
-// SPDX-License-Identifier: GPL-2.0-or-later
-
-import { hostState } from "./host.js";
-
-// The decode stream is not rig-scoped: every rig a client is connected to sends
-// its decodes to every browser, each frame naming the rig that heard it (the
-// client stamps `rig_id` as it leaves the audio connection).  The map wants all
-// of them — it has its own filter, and plotting only one rig would empty it —
-// but the radio page and the decoder panels describe one rig at a time: the one
-// the operator selected, whose spectrum is on screen and whose audio is
-// playing.  A frame a background rig copied on another band belongs to neither
-// picture, so both filter on this.
-export function isActiveRigDecode(rigId: string | null | undefined): boolean {
-  const activeRigId = hostState.lastActiveRigId;
-  // Before the rig list has arrived, and for a decode that reached the browser
-  // without a rig of its own, there is nothing to disagree with.
-  if (!activeRigId || !rigId) return true;
-  return rigId === activeRigId;
-}
-
-/** The decodes of `items` that the selected rig heard, in their original order. */
-export function forActiveRig<T extends { rig_id?: string | null | undefined }>(items: T[]): T[] {
-  return items.filter((item) => isActiveRigDecode(item.rig_id));
-}

src/trx-client/trx-frontend/trx-frontend-http/frontend/src/plugins/ais.ts

@@ -6,7 +6,6 @@ import { hostCore, hostState } from "./host.js";
 
 export {};
 
-import { forActiveRig, isActiveRigDecode } from "./active-rig.js";
 import type { PluginRuntimeWindow } from "./runtime-contract";
 
 interface AisMessage {
@@ -191,27 +190,20 @@ function aisLatestByVessel(messages: AisMessage[]): AisMessage[] {
   return Array.from(byMmsi.values());
 }
 
-/** What the selected rig heard.  The history holds every rig's traffic, for
- *  the map; the panel is about the rig the operator is working. */
-function aisRigMessages(): AisMessage[] {
-  return forActiveRig(aisMessageHistory);
-}
-
 function updateAisSummary() {
   const plan = currentAisChannelPlan();
   if (aisChannelSummaryEl) {
     aisChannelSummaryEl.textContent = `A ${formatAisMhz(plan.aHz)} · B ${formatAisMhz(plan.bHz)}`;
   }
 
-  const rigMessages = aisRigMessages();
-  const vessels = aisLatestByVessel(rigMessages);
+  const vessels = aisLatestByVessel(aisMessageHistory);
   if (aisVesselCountEl) {
     const count = vessels.length;
     aisVesselCountEl.textContent = `${count} vessel${count === 1 ? "" : "s"}`;
   }
 
   if (aisLatestSeenEl) {
-    const latest = rigMessages[0];
+    const latest = aisMessageHistory[0];
     if (!latest) {
       aisLatestSeenEl.textContent = "No traffic yet";
     } else {
@@ -322,9 +314,7 @@ function updateAisBar() {
 
   const isAis = ((document.getElementById("mode") as HTMLSelectElement | null)?.value || "").toUpperCase() === "AIS";
   const cutoffMs = Date.now() - AIS_BAR_WINDOW_MS;
-  const recent = aisMessageHistory.filter(
-    (msg) => (msg._tsMs ?? 0) >= cutoffMs && isActiveRigDecode(msg.rig_id),
-  );
+  const recent = aisMessageHistory.filter((msg) => (msg._tsMs ?? 0) >= cutoffMs);
   const messages = aisLatestByVessel(recent).slice(0, 8);
   if (!isAis || messages.length === 0) {
     aisBarOverlay.style.display = "none";
@@ -378,7 +368,7 @@ function renderAisHistory() {
     return;
   }
   const fragment = document.createDocumentFragment();
-  for (const message of aisRigMessages()) {
+  for (const message of aisMessageHistory) {
     fragment.appendChild(renderAisRow(message));
   }
   aisMessagesEl.replaceChildren(fragment);
@@ -417,11 +407,10 @@ function normalizeServerAisMessage(msg: AisMessage): AisMessage {
 
 function onServerAisBatch(messages: AisMessage[]): void {
   if (!Array.isArray(messages) || messages.length === 0) return;
+  if (aisStatus) aisStatus.textContent = "Receiving";
   const normalized: AisMessage[] = [];
   for (const msg of messages) {
     const next = normalizeServerAisMessage(msg);
-    // "Receiving" is the panel's own status, and the panel is the rig's.
-    if (aisStatus && isActiveRigDecode(next.rig_id)) aisStatus.textContent = "Receiving";
     const tsMs = Number.isFinite(next.ts_ms) ? Number(next.ts_ms) : Date.now();
     next._tsMs = tsMs;
     next._ts = new Date(tsMs).toLocaleTimeString([], {
@@ -463,9 +452,8 @@ if (aisFilterInput) {
 }
 
 function onServerAis(msg: AisMessage): void {
-  const message = normalizeServerAisMessage(msg);
-  if (aisStatus && isActiveRigDecode(message.rig_id)) aisStatus.textContent = "Receiving";
-  addAisMessage(message);
+  if (aisStatus) aisStatus.textContent = "Receiving";
+  addAisMessage(normalizeServerAisMessage(msg));
 }
 
 updateAisSummary();
@@ -476,7 +464,6 @@ updateAisSummary();
   restore: onServerAisBatch,
   reset: resetAisHistoryView,
   prune: pruneAisHistoryView,
-  rerender: () => { updateAisBar(); renderAisHistory(); },
   // Oldest first, so vessel tracks are rebuilt in the order they happened.
   syncMap: () => { for (const entry of [...aisMessageHistory].reverse()) plotAisMessage(entry); },
 });

src/trx-client/trx-frontend/trx-frontend-http/frontend/src/plugins/aprs.ts

@@ -4,7 +4,6 @@
 
 import { hostCore, hostState } from "./host.js";
 
-import { forActiveRig, isActiveRigDecode } from "./active-rig.js";
 import {
   aprsAgeText,
   aprsPacketCategory,
@@ -107,29 +106,21 @@ function aprsFilterMatch(pkt: AprsPacket): boolean {
   return haystack.includes(aprsFilterText);
 }
 
-/** What the selected rig heard.  The history holds every rig's traffic, for
- *  the map; the panel is about the rig the operator is working. */
-function aprsRigPackets(): AprsPacket[] {
-  return forActiveRig(aprsPacketHistory);
-}
-
 function aprsVisiblePackets(): AprsPacket[] {
-  const rigPackets = aprsRigPackets();
-  const packets = aprsCollapseDup ? collapseAprsDuplicates(rigPackets) : rigPackets;
+  const packets = aprsCollapseDup ? collapseAprsDuplicates(aprsPacketHistory) : aprsPacketHistory;
   return packets.filter(aprsFilterMatch);
 }
 
 function updateAprsSummary() {
-  const rigPackets = aprsRigPackets();
   const visible = aprsVisiblePackets();
   if (aprsTotalCountEl) {
-    aprsTotalCountEl.textContent = `${rigPackets.length} total`;
+    aprsTotalCountEl.textContent = `${aprsPacketHistory.length} total`;
   }
   if (aprsVisibleCountEl) {
     aprsVisibleCountEl.textContent = `${visible.length} shown`;
   }
   if (aprsLatestSeenEl) {
-    const latest = rigPackets[0];
+    const latest = aprsPacketHistory[0];
     if (!latest) {
       aprsLatestSeenEl.textContent = "No packets yet";
     } else {
@@ -188,9 +179,7 @@ function updateAprsBar() {
   if (!aprsBarOverlay) return;
   const isPkt = ((document.getElementById("mode") as HTMLSelectElement | null)?.value || "").toUpperCase() === "PKT";
   const cutoffMs = Date.now() - APRS_BAR_WINDOW_MS;
-  const okFrames = aprsPacketHistory.filter(
-    (p) => p.crcOk && (p._tsMs ?? 0) >= cutoffMs && isActiveRigDecode(p.rig_id),
-  );
+  const okFrames = aprsPacketHistory.filter((p) => p.crcOk && (p._tsMs ?? 0) >= cutoffMs);
   const frames = collapseAprsDuplicates(okFrames).slice(0, 8);
   const newestTsMs = frames.reduce((latest, pkt) => Math.max(latest, Number(pkt._tsMs) || 0), 0);
   if (!isPkt || frames.length === 0 || newestTsMs <= aprsBarDismissedAtMs) {
@@ -267,12 +256,11 @@ function normalizeServerAprsPacket(pkt: AprsPacket): AprsPacket {
 
 function onServerAprsBatch(packets: AprsPacket[]): void {
   if (!Array.isArray(packets) || packets.length === 0) return;
+  if (aprsStatus) aprsStatus.textContent = "Receiving";
   const normalized: AprsPacket[] = [];
   let hasCrcOk = false;
   for (const pkt of packets) {
     const next = normalizeServerAprsPacket(pkt);
-    // "Receiving" is the panel's own status, and the panel is the rig's.
-    if (aprsStatus && isActiveRigDecode(next.rig_id)) aprsStatus.textContent = "Receiving";
     const tsMs = Number.isFinite(next.ts_ms) ? Number(next.ts_ms) : Date.now();
     next._tsMs = tsMs;
     next._ts = new Date(tsMs).toLocaleTimeString([], { hour: "2-digit", minute: "2-digit", second: "2-digit" });
@@ -336,9 +324,8 @@ if (aprsFilterInput) {
 
 // --- Server-side APRS decode handler ---
 function onServerAprs(pkt: AprsPacket): void {
-  const packet = normalizeServerAprsPacket(pkt);
-  if (aprsStatus && isActiveRigDecode(packet.rig_id)) aprsStatus.textContent = "Receiving";
-  addAprsPacket(packet);
+  if (aprsStatus) aprsStatus.textContent = "Receiving";
+  addAprsPacket(normalizeServerAprsPacket(pkt));
 }
 
 renderAprsHistory();
@@ -349,7 +336,6 @@ renderAprsHistory();
   restore: onServerAprsBatch,
   reset: resetAprsHistoryView,
   prune: pruneAprsHistoryView,
-  rerender: () => { updateAprsBar(); renderAprsHistory(); },
   // Oldest first, so station tracks are rebuilt in the order they happened.
   syncMap: () => { for (const entry of [...aprsPacketHistory].reverse()) plotAprsPacket(entry); },
 });

src/trx-client/trx-frontend/trx-frontend-http/frontend/src/plugins/cw.ts

@@ -4,7 +4,6 @@
 
 import { hostCore } from "./host.js";
 
-import { isActiveRigDecode } from "./active-rig.js";
 import type { PluginRuntimeWindow } from "./runtime-contract.js";
 
 export {};
@@ -21,11 +20,8 @@ interface CwRenderer {
   drawPoints(points: number[], size: number, color: Rgba): void;
 }
 interface CwSpectrum { bins: number[]; sample_rate: number; center_hz: number }
-interface CwEvent { rig_id?: string | null; text?: string; wpm?: number; tone_hz?: number; signal_on?: boolean }
-interface CwLine {
-  rigId: string | null; tsMs: number; ts: string; text: string;
-  wpm: number | null; tone_hz: number | null; lastMs: number;
-}
+interface CwEvent { text?: string; wpm?: number; tone_hz?: number; signal_on?: boolean }
+interface CwLine { tsMs: number; ts: string; text: string; wpm: number | null; tone_hz: number | null; lastMs: number }
 interface CwToneRange {
   tunedHz: number; bandwidthHz: number; toneMinHz: number; toneMaxHz: number;
   toneSpanHz: number; lowerSideband: boolean; mode: string;
@@ -70,10 +66,7 @@ const CW_BAR_LINE_GAP_MS = 5000;
 let cwLastAppendTime = 0;
 let cwTonePickerRaf: number | null = null;
 let cwBarHistory: CwLine[] = [];
-// One line in progress per rig, keyed by rig id ("" for a decode that names no
-// rig).  Two rigs copying at the same time each fill their own line instead of
-// braiding their characters into one.
-const cwBarCurrentLines = new Map<string, CwLine>();
+let cwBarCurrentLine: CwLine | null = null;
 let cwBarDismissedAtMs = 0;
 // Tracks a user-initiated auto toggle that is in-flight (POST not yet
 // acknowledged).  While set, server-state updates must not override the
@@ -108,13 +101,12 @@ cwWindow.applyCwAutoUiFromServer = function(enabled: boolean) {
   applyCwAutoUi(enabled);
 };
 
-function cwBarFlushCurrentLine(key: string): void {
-  const line = cwBarCurrentLines.get(key);
-  cwBarCurrentLines.delete(key);
-  if (line?.text.trim()) {
-    cwBarHistory.unshift(line);
+function cwBarFlushCurrentLine(): void {
+  if (cwBarCurrentLine && cwBarCurrentLine.text.trim()) {
+    cwBarHistory.unshift(cwBarCurrentLine);
     if (cwBarHistory.length > 50) cwBarHistory.length = 50;
   }
+  cwBarCurrentLine = null;
 }
 
 function updateCwBar(): void {
@@ -122,12 +114,9 @@ function updateCwBar(): void {
   const mode = ((document.getElementById("mode") as HTMLSelectElement | null)?.value || "").toUpperCase();
   const isCw = mode === "CW" || mode === "CWR";
   const cutoffMs = Date.now() - CW_BAR_WINDOW_MS;
-  const recent = cwBarHistory.filter((l) => l.tsMs >= cutoffMs && isActiveRigDecode(l.rigId));
-  // Prepend the in-progress lines so characters appear immediately
-  const inProgress = [...cwBarCurrentLines.values()]
-    .filter((l) => l.text && isActiveRigDecode(l.rigId))
-    .sort((a, b) => b.tsMs - a.tsMs);
-  const liveLines = [...inProgress, ...recent];
+  const recent = cwBarHistory.filter((l) => l.tsMs >= cutoffMs);
+  // Prepend the in-progress line so characters appear immediately
+  const liveLines = cwBarCurrentLine && cwBarCurrentLine.text ? [cwBarCurrentLine, ...recent] : recent;
   const newestTsMs = liveLines.reduce((latest, line) => Math.max(latest, line.tsMs || 0), 0);
   if (!isCw || liveLines.length === 0 || newestTsMs <= cwBarDismissedAtMs) {
     cwBarOverlay.style.display = "none";
@@ -413,7 +402,7 @@ function resetCwHistoryView(): void {
   if (cwOutputEl) cwOutputEl.innerHTML = "";
   cwLastAppendTime = 0;
   cwBarHistory = [];
-  cwBarCurrentLines.clear();
+  cwBarCurrentLine = null;
   updateCwBar();
   drawCwTonePicker();
 }
@@ -432,13 +421,8 @@ document.getElementById("settings-clear-cw-history")?.addEventListener("click",
 
 // --- Server-side CW decode handler ---
 function onServerCw(evt: CwEvent): void {
-  // The panel is a single stream of copied text: characters from a background
-  // rig do not belong in it at all, and interleaving them would make both
-  // rigs unreadable.  The bar histories below keep every rig, each on its own
-  // line, and pick out the selected rig when they paint.
-  const forSelectedRig = isActiveRigDecode(evt.rig_id ?? null);
-  if (cwStatusEl && forSelectedRig) cwStatusEl.textContent = "Receiving";
-  if (evt.text && cwOutputEl && forSelectedRig) {
+  if (cwStatusEl) cwStatusEl.textContent = "Receiving";
+  if (evt.text && cwOutputEl) {
     // Append decoded text to output
     const now = Date.now();
     if (!cwOutputEl.lastElementChild || now - cwLastAppendTime > 10000 || evt.text === "\n") {
@@ -461,29 +445,25 @@ function onServerCw(evt: CwEvent): void {
   // Bar history accumulation (regardless of pause state)
   if (evt.text) {
     const now = Date.now();
-    const rigId = evt.rig_id ?? null;
-    const key = rigId ?? "";
     if (evt.text === "\n") {
-      cwBarFlushCurrentLine(key);
+      cwBarFlushCurrentLine();
     } else {
-      let line = cwBarCurrentLines.get(key);
-      if (!line || now - line.lastMs > CW_BAR_LINE_GAP_MS) {
-        cwBarFlushCurrentLine(key);
+      if (!cwBarCurrentLine || now - cwBarCurrentLine.lastMs > CW_BAR_LINE_GAP_MS) {
+        cwBarFlushCurrentLine();
         const ts = new Date(now).toLocaleTimeString([], { hour: "2-digit", minute: "2-digit", second: "2-digit" });
-        line = { rigId, tsMs: now, ts, text: "", wpm: null, tone_hz: null, lastMs: now };
-        cwBarCurrentLines.set(key, line);
+        cwBarCurrentLine = { tsMs: now, ts, text: "", wpm: null, tone_hz: null, lastMs: now };
       }
-      line.text += evt.text;
-      line.lastMs = now;
-      if (Number.isFinite(Number(evt.wpm))) line.wpm = clampCwWpm(evt.wpm);
-      if (Number.isFinite(Number(evt.tone_hz))) line.tone_hz = Math.round(Number(evt.tone_hz));
+      cwBarCurrentLine.text += evt.text;
+      cwBarCurrentLine.lastMs = now;
+      if (Number.isFinite(Number(evt.wpm))) cwBarCurrentLine.wpm = clampCwWpm(evt.wpm);
+      if (Number.isFinite(Number(evt.tone_hz))) cwBarCurrentLine.tone_hz = Math.round(Number(evt.tone_hz));
     }
     updateCwBar();
   }
-  if (cwSignalIndicator && forSelectedRig) {
+  if (cwSignalIndicator) {
     cwSignalIndicator.className = evt.signal_on ? "cw-signal-on" : "cw-signal-off";
   }
-  if (forSelectedRig && (!cwAutoInput || cwAutoInput.checked)) {
+  if (!cwAutoInput || cwAutoInput.checked) {
     if (cwWpmInput && Number.isFinite(Number(evt.wpm))) {
       cwWpmInput.value = String(clampCwWpm(evt.wpm));
     }
@@ -511,13 +491,6 @@ cwWindow.trxPluginRuntime.registerDecoder({
   onMessage: onServerCw,
   restore: restoreCwHistory,
   reset: resetCwHistoryView,
-  // The copied text of a rig that is no longer on screen cannot be unpicked
-  // from the pane, so the switch starts the new rig's stream from empty.
-  rerender: () => {
-    if (cwOutputEl) cwOutputEl.innerHTML = "";
-    cwLastAppendTime = 0;
-    updateCwBar();
-  },
 });
 
 cwWindow.refreshCwTonePicker = function refreshCwTonePicker() {

src/trx-client/trx-frontend/trx-frontend-http/frontend/src/plugins/ftx-family.ts

@@ -4,7 +4,6 @@
 
 import { hostCore } from "./host.js";
 
-import { forActiveRig, isActiveRigDecode } from "./active-rig.js";
 import type { PluginRuntimeWindow } from "./runtime-contract.js";
 
 export type FtxDecoderId = "ft2" | "ft4" | "ft8";
@@ -16,7 +15,6 @@ export interface FtxMessage {
   snr_db?: number | undefined;
   dt_s?: number | undefined;
   freq_hz?: number | undefined;
-  rig_id?: string | null | undefined;
   receiver?: unknown;
   [key: string]: unknown;
 }
@@ -229,12 +227,9 @@ export function initializeFtxDecoder(config: FtxConfig): void {
   const render = (): void => {
     prune();
     if (!messagesElement) return;
-    // The history holds every rig's decodes, for the map; the panel is about
-    // the rig the operator is working.
-    const rigMessages = forActiveRig(history);
     const fragment = document.createDocumentFragment();
     let count = 0;
-    for (const message of rigMessages) {
+    for (const message of history) {
       if (count >= 200) break;
       if (filterText && !(message.message ?? "").toUpperCase().includes(filterText)) continue;
       fragment.appendChild(renderRow(message));
@@ -256,9 +251,6 @@ export function initializeFtxDecoder(config: FtxConfig): void {
       });
     }
     return {
-      // The rig that heard it, kept so the mini view can tell a decode of the
-      // rig on screen from one a background rig made on another band.
-      rig_id: message.rig_id ?? null,
       receiver: bridge.getDecodeRigMeta?.() ?? null,
       ts_ms: message.ts_ms,
       snr_db: message.snr_db,
@@ -270,10 +262,7 @@ export function initializeFtxDecoder(config: FtxConfig): void {
   };
   const receiveBatch = (messages: FtxMessage[]): void => {
     if (messages.length === 0) return;
-    // "Receiving" is the panel's own status, and the panel is the rig's.
-    if (status && messages.some((message) => isActiveRigDecode(message.rig_id))) {
-      status.textContent = "Receiving";
-    }
+    if (status) status.textContent = "Receiving";
     history = messages.map(normalize).reverse().concat(history);
     prune();
     bridge.setFt8FamilyBarDecoder?.(id);
@@ -288,8 +277,7 @@ export function initializeFtxDecoder(config: FtxConfig): void {
   };
   const barFrames = (): BarFrames => {
     const recent = history
-      .filter((message) => (finiteNumber(message._tsMs ?? message.ts_ms) ?? 0) >= Date.now() - 900_000
-        && isActiveRigDecode(message.rig_id))
+      .filter((message) => (finiteNumber(message._tsMs ?? message.ts_ms) ?? 0) >= Date.now() - 900_000)
       .slice(0, 8);
     let html = "";
     for (const message of recent) {
@@ -311,7 +299,6 @@ export function initializeFtxDecoder(config: FtxConfig): void {
     restore: receiveBatch,
     prune: () => { prune(); render(); },
     reset,
-    rerender: () => { bridge.updateFt8Bar?.(); render(); },
   });
   bridge.registerFt8FamilyBarRenderer?.(id, barFrames);
 

src/trx-client/trx-frontend/trx-frontend-http/frontend/src/plugins/hf-aprs.ts

@@ -4,7 +4,6 @@
 
 import { hostCore, hostState } from "./host.js";
 
-import { forActiveRig, isActiveRigDecode } from "./active-rig.js";
 import {
   aprsAgeText,
   aprsPacketCategory,
@@ -91,31 +90,23 @@ function hfAprsFilterMatch(pkt: AprsPacket): boolean {
   return haystack.includes(hfAprsFilterText);
 }
 
-/** What the selected rig heard.  The history holds every rig's traffic, for
- *  the map; the panel is about the rig the operator is working. */
-function hfAprsRigPackets(): AprsPacket[] {
-  return forActiveRig(hfAprsPacketHistory);
-}
-
 function hfAprsVisiblePackets(): AprsPacket[] {
-  const rigPackets = hfAprsRigPackets();
-  const packets = hfAprsCollapseDup ? collapseHfAprsDuplicates(rigPackets) : rigPackets;
+  const packets = hfAprsCollapseDup ? collapseHfAprsDuplicates(hfAprsPacketHistory) : hfAprsPacketHistory;
   return packets.filter(hfAprsFilterMatch);
 }
 
 const collapseHfAprsDuplicates = collapseAprsDuplicates;
 
 function updateHfAprsSummary() {
-  const rigPackets = hfAprsRigPackets();
   const visible = hfAprsVisiblePackets();
   if (hfAprsTotalCountEl) {
-    hfAprsTotalCountEl.textContent = `${rigPackets.length} total`;
+    hfAprsTotalCountEl.textContent = `${hfAprsPacketHistory.length} total`;
   }
   if (hfAprsVisibleCountEl) {
     hfAprsVisibleCountEl.textContent = `${visible.length} shown`;
   }
   if (hfAprsLatestSeenEl) {
-    const latest = rigPackets[0];
+    const latest = hfAprsPacketHistory[0];
     if (!latest) {
       hfAprsLatestSeenEl.textContent = "No packets yet";
     } else {
@@ -201,11 +192,10 @@ function normalizeServerHfAprsPacket(pkt: AprsPacket): AprsPacket {
 
 function onServerHfAprsBatch(packets: AprsPacket[]): void {
   if (!Array.isArray(packets) || packets.length === 0) return;
+  if (hfAprsStatus) hfAprsStatus.textContent = "Receiving";
   const normalized: AprsPacket[] = [];
   for (const pkt of packets) {
     const next = normalizeServerHfAprsPacket(pkt);
-    // "Receiving" is the panel's own status, and the panel is the rig's.
-    if (hfAprsStatus && isActiveRigDecode(next.rig_id)) hfAprsStatus.textContent = "Receiving";
     const tsMs = Number.isFinite(next.ts_ms) ? Number(next.ts_ms) : Date.now();
     next._tsMs = tsMs;
     next._ts = new Date(tsMs).toLocaleTimeString([], { hour: "2-digit", minute: "2-digit", second: "2-digit" });
@@ -276,9 +266,8 @@ if (hfAprsFilterInput) {
 
 // --- Server-side HF APRS decode handler ---
 function onServerHfAprs(pkt: AprsPacket): void {
-  const packet = normalizeServerHfAprsPacket(pkt);
-  if (hfAprsStatus && isActiveRigDecode(packet.rig_id)) hfAprsStatus.textContent = "Receiving";
-  addHfAprsPacket(packet);
+  if (hfAprsStatus) hfAprsStatus.textContent = "Receiving";
+  addHfAprsPacket(normalizeServerHfAprsPacket(pkt));
 }
 
 renderHfAprsHistory();
@@ -289,5 +278,4 @@ renderHfAprsHistory();
   restore: onServerHfAprsBatch,
   reset: resetHfAprsHistoryView,
   prune: pruneHfAprsHistoryView,
-  rerender: renderHfAprsHistory,
 });

src/trx-client/trx-frontend/trx-frontend-http/frontend/src/plugins/runtime-contract.ts

@@ -9,10 +9,6 @@ export interface DecoderPlugin<TMessage = unknown> {
   restore?(messages: TMessage[]): void;
   reset?(): void;
   prune?(): void;
-  /** Repaint the plugin's panel from what it already holds. Called when the
-   *  selected rig changes: the panels show one rig's traffic, and the decodes
-   *  behind them arrived long before the switch. */
-  rerender?(): void;
   /** Replay everything the plugin is holding onto the map. Called when the map
    *  module attaches, which can happen long after the decodes arrived. */
   syncMap?(): void;
@@ -26,7 +22,6 @@ export interface TrxPluginRuntime {
   reset(id: string): boolean;
   resetAll(): void;
   prune(id: string): boolean;
-  rerenderAll(): void;
   syncMapAll(): void;
   clearQueued(): void;
   hasDecoder(id: string): boolean;

src/trx-client/trx-frontend/trx-frontend-http/frontend/src/plugins/sat.ts

@@ -4,12 +4,13 @@
 
 import { hostCore } from "./host.js";
 
-import type { LrptProgress, SatelliteImage, SatelliteLiveUpdate } from "./satellite-types";
+import type { LrptProgress, SatelliteImage, SatelliteLiveUpdate, SatellitePass, SatellitePassResponse } from "./satellite-types";
 import type { PluginRuntimeWindow } from "./runtime-contract.js";
 
-type SatelliteView = "live" | "history";
+type SatelliteView = "live" | "history" | "predictions";
 interface SatelliteBridge {
   trxScheduleUiFrameJob?: (key: string, job: () => void) => void;
+  clearSatPredictionDom?: () => void;
   updateSatLiveState?: (update: SatelliteLiveUpdate) => void;
   addSatMapOverlay?: (image: SatelliteImage) => void;
   clearSatMapOverlays?: () => void;
@@ -24,14 +25,14 @@ const satWindow = window as unknown as SatelliteBridge & PluginRuntimeWindow;
 // --- SAT Plugin ---
 // Live view: decoder state, latest image card
 // History view: filterable table of all decoded images
-//
-// Pass predictions live on their own page; see satellite-predictions.ts.
+// Predictions view: next 24 h passes for ham satellites
 
 // ── DOM references (cached once) ───────────────────────────────────
 const satDom = {
   status:           document.getElementById("sat-status"),
   liveView:         document.getElementById("sat-live-view"),
   historyView:      document.getElementById("sat-history-view"),
+  predictionsView:  document.getElementById("sat-predictions-view"),
   liveLatest:       document.getElementById("sat-live-latest"),
   historyList:      document.getElementById("sat-history-list"),
   historyCount:     document.getElementById("sat-history-count"),
@@ -41,13 +42,30 @@ const satDom = {
   lrptState:        document.getElementById("sat-lrpt-state"),
   viewLiveBtn:      document.getElementById("sat-view-live"),
   viewHistoryBtn:   document.getElementById("sat-view-history"),
+  viewPredBtn:      document.getElementById("sat-view-predictions"),
+  predFilter:       document.getElementById("sat-pred-filter") as HTMLInputElement | null,
+  predMinEl:        document.getElementById("sat-pred-min-el") as HTMLSelectElement | null,
+  predCategory:     document.getElementById("sat-pred-category") as HTMLSelectElement | null,
+  predCurrentList:  document.getElementById("sat-pred-current-list"),
+  predUpcomingList: document.getElementById("sat-pred-list"),
+  predCurrentSec:   document.getElementById("sat-pred-current-section"),
+  predUpcomingSec:  document.getElementById("sat-pred-upcoming-section"),
+  predStatus:       document.getElementById("sat-pred-status"),
 };
 
 // ── State ───────────────────────────────────────────────────────────
 let satImageHistory: SatelliteImage[] = [];
 const SAT_MAX_IMAGES = 100;
+const SAT_PRED_PAGE_SIZE = 50;
+let satPredShowAll = false;
 let satFilterText = "";
 let satActiveView: SatelliteView = "live";
+let satPredData: SatellitePass[] = [];
+let satPredFilterText = "";
+let satPredMinEl = 0;
+let satPredCategory = "all";
+let satPredSatCount = 0;
+let satPredCountdownTimer: ReturnType<typeof setInterval> | null = null;
 
 // ── UI scheduler helper ─────────────────────────────────────────────
 function scheduleSatUi(key: string, job: () => void): void {
@@ -60,16 +78,33 @@ function scheduleSatUi(key: string, job: () => void): void {
 
 // ── View switching ──────────────────────────────────────────────────
 function switchSatView(view: SatelliteView): void {
+  const leavingPredictions = satActiveView === "predictions" && view !== "predictions";
   satActiveView = view;
-  if (satDom.liveView)       satDom.liveView.style.display = view === "live" ? "" : "none";
-  if (satDom.historyView)    satDom.historyView.style.display = view === "history" ? "" : "none";
-  if (satDom.viewLiveBtn)    satDom.viewLiveBtn.classList.toggle("sat-view-active", view === "live");
-  if (satDom.viewHistoryBtn) satDom.viewHistoryBtn.classList.toggle("sat-view-active", view === "history");
-  if (view === "history") renderSatHistoryTable();
+  if (satDom.liveView)        satDom.liveView.style.display = view === "live" ? "" : "none";
+  if (satDom.historyView)     satDom.historyView.style.display = view === "history" ? "" : "none";
+  if (satDom.predictionsView) satDom.predictionsView.style.display = view === "predictions" ? "" : "none";
+  if (satDom.viewLiveBtn)     satDom.viewLiveBtn.classList.toggle("sat-view-active", view === "live");
+  if (satDom.viewHistoryBtn)  satDom.viewHistoryBtn.classList.toggle("sat-view-active", view === "history");
+  if (satDom.viewPredBtn)     satDom.viewPredBtn.classList.toggle("sat-view-active", view === "predictions");
+  if (leavingPredictions) clearPredictionDom();
+  if (view === "history") {
+    renderSatHistoryTable();
+  } else if (view === "predictions") {
+    satPredShowAll = false;
+    void loadSatPredictions();
+  }
 }
 
+function clearPredictionDom() {
+  stopCountdownTimer();
+  if (satDom.predCurrentList)  satDom.predCurrentList.innerHTML = "";
+  if (satDom.predUpcomingList) satDom.predUpcomingList.innerHTML = "";
+}
+satWindow.clearSatPredictionDom = clearPredictionDom;
+
 satDom.viewLiveBtn?.addEventListener("click", () => { switchSatView("live"); });
 satDom.viewHistoryBtn?.addEventListener("click", () => { switchSatView("history"); });
+satDom.viewPredBtn?.addEventListener("click", () => { switchSatView("predictions"); });
 
 // ── Live view: decoder state ────────────────────────────────────────
 let lastSatLrptOn: boolean | null = null;
@@ -300,6 +335,234 @@ document
     }
   })(); });
 
+// ── Predictions: helpers ────────────────────────────────────────────
+function azToCardinal(deg: number): string {
+  const dirs = ["N", "NE", "E", "SE", "S", "SW", "W", "NW"];
+  return dirs[Math.round(deg / 45) % 8] ?? "N";
+}
+
+function formatPredTime(ms: number): string {
+  const d = new Date(ms);
+  const now = new Date();
+  const dayNames = ["Sun", "Mon", "Tue", "Wed", "Thu", "Fri", "Sat"];
+  const day = d.getUTCDay() !== now.getUTCDay() ? `${dayNames[d.getUTCDay()] ?? ""} ` : "";
+  const hh = String(d.getUTCHours()).padStart(2, "0");
+  const mm = String(d.getUTCMinutes()).padStart(2, "0");
+  return `${day}${hh}:${mm}`;
+}
+
+function formatPredDuration(s: number): string {
+  if (s >= 60) return `${Math.round(s / 60)} min`;
+  return `${s}s`;
+}
+
+function formatCountdown(ms: number): string {
+  const totalSec = Math.max(0, Math.floor(ms / 1000));
+  const m = Math.floor(totalSec / 60);
+  const s = totalSec % 60;
+  return `${m}:${String(s).padStart(2, "0")}`;
+}
+
+function elevationClass(deg: number): string {
+  if (deg >= 45) return "sat-pred-el-high";
+  if (deg >= 10) return "sat-pred-el-mid";
+  return "sat-pred-el-low";
+}
+
+// ── Predictions: countdown timer management ─────────────────────────
+function stopCountdownTimer() {
+  if (satPredCountdownTimer) {
+    clearInterval(satPredCountdownTimer);
+    satPredCountdownTimer = null;
+  }
+}
+
+function startCountdownTimer(container: HTMLElement | null): void {
+  const countdownEls = container?.querySelectorAll<HTMLElement>(".sat-pred-col-countdown") ?? [];
+  if (countdownEls.length === 0) return;
+
+  satPredCountdownTimer = setInterval(() => {
+    if (satActiveView !== "predictions") {
+      stopCountdownTimer();
+      return;
+    }
+    const n = Date.now();
+    let anyActive = false;
+    for (const el of countdownEls) {
+      const los = Number.parseInt(el.dataset.los ?? "0", 10);
+      const rem = los - n;
+      if (rem > 0) {
+        el.textContent = formatCountdown(rem);
+        anyActive = true;
+      } else {
+        el.textContent = "0:00";
+      }
+    }
+    if (!anyActive) {
+      stopCountdownTimer();
+      renderSatPredictions(getFilteredPredictions());
+    }
+  }, 1000);
+}
+
+// ── Predictions: row builders ───────────────────────────────────────
+function buildCurrentPassRow(pass: SatellitePass, now: number): HTMLElement {
+  const row = document.createElement("div");
+  row.className = "sat-pred-row-current";
+  const dir = `${azToCardinal(pass.azimuth_aos_deg)} \u2192 ${azToCardinal(pass.azimuth_los_deg)}`;
+  const remaining = Math.max(0, pass.los_ms - now);
+  row.innerHTML = [
+    `<span class="sat-pred-col-sat">${pass.satellite}</span>`,
+    `<span class="sat-pred-col-el ${elevationClass(pass.max_elevation_deg)}">${pass.max_elevation_deg.toFixed(1)}\u00B0</span>`,
+    `<span class="sat-pred-col-time">${formatPredTime(pass.aos_ms)}</span>`,
+    `<span class="sat-pred-col-time">${formatPredTime(pass.los_ms)}</span>`,
+    `<span class="sat-pred-col-countdown" data-los="${pass.los_ms}">${formatCountdown(remaining)}</span>`,
+    `<span class="sat-pred-col-dir">${dir}</span>`,
+  ].join("");
+  return row;
+}
+
+function buildUpcomingPassRow(pass: SatellitePass): HTMLElement {
+  const row = document.createElement("div");
+  row.className = "sat-pred-row";
+  const dir = `${azToCardinal(pass.azimuth_aos_deg)} \u2192 ${azToCardinal(pass.azimuth_los_deg)}`;
+  row.innerHTML = [
+    `<span class="sat-pred-col-time">${formatPredTime(pass.aos_ms)}</span>`,
+    `<span class="sat-pred-col-sat">${pass.satellite}</span>`,
+    `<span class="sat-pred-col-el ${elevationClass(pass.max_elevation_deg)}">${pass.max_elevation_deg.toFixed(1)}\u00B0</span>`,
+    `<span class="sat-pred-col-dur">${formatPredDuration(pass.duration_s)}</span>`,
+    `<span class="sat-pred-col-dir">${dir}</span>`,
+  ].join("");
+  return row;
+}
+
+// ── Predictions: filter state ───────────────────────────────────────
+function getFilteredPredictions(): SatellitePass[] {
+  let items = satPredData;
+  if (satPredCategory !== "all") items = items.filter((p) => p.category === satPredCategory);
+  if (satPredMinEl > 0) items = items.filter((p) => p.max_elevation_deg >= satPredMinEl);
+  if (satPredFilterText) items = items.filter((p) => p.satellite.toUpperCase().includes(satPredFilterText));
+  return items;
+}
+
+function applyPredFilters() {
+  renderSatPredictions(getFilteredPredictions());
+}
+
+const satPredictionFilter = satDom.predFilter;
+satPredictionFilter?.addEventListener("input", () => {
+  satPredFilterText = satPredictionFilter.value.trim().toUpperCase();
+  applyPredFilters();
+});
+
+const satPredictionMinElevation = satDom.predMinEl;
+satPredictionMinElevation?.addEventListener("change", () => {
+  satPredMinEl = Number.parseInt(satPredictionMinElevation.value, 10) || 0;
+  applyPredFilters();
+});
+
+const satPredictionCategory = satDom.predCategory;
+satPredictionCategory?.addEventListener("change", () => {
+  satPredCategory = satPredictionCategory.value;
+  applyPredFilters();
+});
+
+// ── Predictions: main render ────────────────────────────────────────
+function renderSatPredictions(passes: SatellitePass[], error?: string): void {
+  stopCountdownTimer();
+
+  if (error) {
+    if (satDom.predCurrentList)  satDom.predCurrentList.innerHTML = "";
+    if (satDom.predUpcomingList) satDom.predUpcomingList.innerHTML = "";
+    if (satDom.predCurrentSec)   satDom.predCurrentSec.style.display = "none";
+    if (satDom.predUpcomingSec)  satDom.predUpcomingSec.style.display = "none";
+    if (satDom.predStatus)       satDom.predStatus.textContent = error;
+    return;
+  }
+
+  if (!Array.isArray(passes) || passes.length === 0) {
+    if (satDom.predCurrentList)  satDom.predCurrentList.innerHTML = "";
+    if (satDom.predUpcomingList) satDom.predUpcomingList.innerHTML = "";
+    if (satDom.predCurrentSec)   satDom.predCurrentSec.style.display = "none";
+    if (satDom.predUpcomingSec)  satDom.predUpcomingSec.style.display = "none";
+    if (satDom.predStatus)       satDom.predStatus.textContent = "No passes found in the next 24 hours.";
+    return;
+  }
+
+  const now = Date.now();
+  const current = passes.filter((p) => p.aos_ms <= now && p.los_ms > now);
+  const upcoming = passes.filter((p) => p.aos_ms > now);
+
+  // ── Current passes ──
+  if (satDom.predCurrentSec) satDom.predCurrentSec.style.display = current.length > 0 ? "" : "none";
+  if (satDom.predCurrentList) {
+    if (current.length === 0) {
+      satDom.predCurrentList.innerHTML = "";
+    } else {
+      const frag = document.createDocumentFragment();
+      for (const pass of current) frag.appendChild(buildCurrentPassRow(pass, now));
+      satDom.predCurrentList.replaceChildren(frag);
+    }
+  }
+
+  // ── Upcoming passes ──
+  const upcomingLimit = satPredShowAll ? upcoming.length : SAT_PRED_PAGE_SIZE;
+  const visibleUpcoming = upcoming.slice(0, upcomingLimit);
+  const hiddenCount = upcoming.length - visibleUpcoming.length;
+  if (satDom.predUpcomingSec) satDom.predUpcomingSec.style.display = upcoming.length > 0 ? "" : "none";
+  if (satDom.predUpcomingList) {
+    const frag = document.createDocumentFragment();
+    for (const pass of visibleUpcoming) frag.appendChild(buildUpcomingPassRow(pass));
+    if (hiddenCount > 0) {
+      const moreRow = document.createElement("div");
+      moreRow.className = "sat-pred-row";
+      moreRow.style.cursor = "pointer";
+      moreRow.style.textAlign = "center";
+      moreRow.innerHTML = `<span style="grid-column:1/-1;color:var(--accent);font-size:0.82rem;">Show ${hiddenCount} more passes\u2026</span>`;
+      moreRow.addEventListener("click", () => {
+        satPredShowAll = true;
+        renderSatPredictions(getFilteredPredictions());
+      });
+      frag.appendChild(moreRow);
+    }
+    satDom.predUpcomingList.replaceChildren(frag);
+  }
+
+  // ── Status ──
+  if (satDom.predStatus) {
+    let text = `${current.length} active \u00B7 ${upcoming.length} upcoming \u00B7 times in UTC`;
+    if (satPredSatCount > 0) text += ` \u00B7 ${satPredSatCount} satellites tracked`;
+    satDom.predStatus.textContent = text;
+  }
+
+  // ── Countdown timer ──
+  if (current.length > 0 && satActiveView === "predictions") {
+    startCountdownTimer(satDom.predCurrentList);
+  }
+}
+
+// ── Predictions: data loading ───────────────────────────────────────
+async function loadSatPredictions(): Promise<void> {
+  if (satDom.predStatus)       satDom.predStatus.textContent = "Loading predictions\u2026";
+  if (satDom.predCurrentList)  satDom.predCurrentList.innerHTML = "";
+  if (satDom.predUpcomingList) satDom.predUpcomingList.innerHTML = "";
+  try {
+    const resp = await fetch("/sat_passes");
+    if (!resp.ok) throw new Error(`HTTP ${resp.status}`);
+    const data = await resp.json() as SatellitePassResponse;
+    satPredSatCount = data.satellite_count || 0;
+    if (data.error) {
+      satPredData = [];
+      renderSatPredictions([], data.error);
+    } else {
+      satPredData = data.passes || [];
+      renderSatPredictions(getFilteredPredictions());
+    }
+  } catch (error: unknown) {
+    renderSatPredictions([], `Failed to load predictions: ${error instanceof Error ? error.message : String(error)}`);
+  }
+}
+
 // ── Navigate to map centered on satellite image bounds ──────────────
 satWindow.satShowOnMap = function (south: number, west: number, north: number, east: number) {
   if (typeof satWindow.enableMapSourceFilter === "function") {

src/trx-client/trx-frontend/trx-frontend-http/frontend/src/plugins/satellite-predictions.ts

@@ -1,290 +0,0 @@
-// SPDX-FileCopyrightText: 2026 Stan Grams <sjg@haxx.space>
-//
-// SPDX-License-Identifier: GPL-2.0-or-later
-
-import type { SatellitePass, SatellitePassResponse } from "./satellite-types";
-
-// --- Satellite pass predictions ---
-//
-// Its own page rather than a third view inside the weather-satellite decoder:
-// when a bird comes over is a planning question, and it was buried under
-// Digital modes beside decoders it has nothing to do with.
-
-interface PredictionsBridge {
-  clearSatPredictionDom?: () => void;
-  refreshSatPredictions?: () => void;
-}
-const predWindow = window as unknown as PredictionsBridge;
-
-// ── DOM references (cached once) ───────────────────────────────────
-const dom = {
-  page:            document.getElementById("tab-satellites"),
-  filter:          document.getElementById("sat-pred-filter") as HTMLInputElement | null,
-  minElevation:    document.getElementById("sat-pred-min-el") as HTMLSelectElement | null,
-  category:        document.getElementById("sat-pred-category") as HTMLSelectElement | null,
-  currentList:     document.getElementById("sat-pred-current-list"),
-  upcomingList:    document.getElementById("sat-pred-list"),
-  currentSection:  document.getElementById("sat-pred-current-section"),
-  upcomingSection: document.getElementById("sat-pred-upcoming-section"),
-  status:          document.getElementById("sat-pred-status"),
-};
-
-// ── State ───────────────────────────────────────────────────────────
-const PAGE_SIZE = 50;
-let predShowAll = false;
-let predData: SatellitePass[] = [];
-let predFilterText = "";
-let predMinEl = 0;
-let predCategory = "all";
-let predSatCount = 0;
-let predCountdownTimer: ReturnType<typeof setInterval> | null = null;
-
-/** The countdowns tick once a second, so they stop when nobody is looking. */
-function isPageVisible(): boolean {
-  return !!dom.page && dom.page.style.display !== "none";
-}
-
-// ── Predictions: helpers ────────────────────────────────────────────
-function azToCardinal(deg: number): string {
-  const dirs = ["N", "NE", "E", "SE", "S", "SW", "W", "NW"];
-  return dirs[Math.round(deg / 45) % 8] ?? "N";
-}
-
-function formatPredTime(ms: number): string {
-  const d = new Date(ms);
-  const now = new Date();
-  const dayNames = ["Sun", "Mon", "Tue", "Wed", "Thu", "Fri", "Sat"];
-  const day = d.getUTCDay() !== now.getUTCDay() ? `${dayNames[d.getUTCDay()] ?? ""} ` : "";
-  const hh = String(d.getUTCHours()).padStart(2, "0");
-  const mm = String(d.getUTCMinutes()).padStart(2, "0");
-  return `${day}${hh}:${mm}`;
-}
-
-function formatPredDuration(s: number): string {
-  if (s >= 60) return `${Math.round(s / 60)} min`;
-  return `${s}s`;
-}
-
-function formatCountdown(ms: number): string {
-  const totalSec = Math.max(0, Math.floor(ms / 1000));
-  const m = Math.floor(totalSec / 60);
-  const s = totalSec % 60;
-  return `${m}:${String(s).padStart(2, "0")}`;
-}
-
-function elevationClass(deg: number): string {
-  if (deg >= 45) return "sat-pred-el-high";
-  if (deg >= 10) return "sat-pred-el-mid";
-  return "sat-pred-el-low";
-}
-
-// ── Predictions: countdown timer management ─────────────────────────
-function stopCountdownTimer() {
-  if (predCountdownTimer) {
-    clearInterval(predCountdownTimer);
-    predCountdownTimer = null;
-  }
-}
-
-function startCountdownTimer(container: HTMLElement | null): void {
-  const countdownEls = container?.querySelectorAll<HTMLElement>(".sat-pred-col-countdown") ?? [];
-  if (countdownEls.length === 0) return;
-
-  predCountdownTimer = setInterval(() => {
-    if (!isPageVisible()) {
-      stopCountdownTimer();
-      return;
-    }
-    const n = Date.now();
-    let anyActive = false;
-    for (const el of countdownEls) {
-      const los = Number.parseInt(el.dataset.los ?? "0", 10);
-      const rem = los - n;
-      if (rem > 0) {
-        el.textContent = formatCountdown(rem);
-        anyActive = true;
-      } else {
-        el.textContent = "0:00";
-      }
-    }
-    if (!anyActive) {
-      stopCountdownTimer();
-      render(filtered());
-    }
-  }, 1000);
-}
-
-// ── Predictions: row builders ───────────────────────────────────────
-function buildCurrentPassRow(pass: SatellitePass, now: number): HTMLElement {
-  const row = document.createElement("div");
-  row.className = "sat-pred-row-current";
-  const dir = `${azToCardinal(pass.azimuth_aos_deg)} \u2192 ${azToCardinal(pass.azimuth_los_deg)}`;
-  const remaining = Math.max(0, pass.los_ms - now);
-  row.innerHTML = [
-    `<span class="sat-pred-col-sat">${pass.satellite}</span>`,
-    `<span class="sat-pred-col-el ${elevationClass(pass.max_elevation_deg)}">${pass.max_elevation_deg.toFixed(1)}\u00B0</span>`,
-    `<span class="sat-pred-col-time">${formatPredTime(pass.aos_ms)}</span>`,
-    `<span class="sat-pred-col-time">${formatPredTime(pass.los_ms)}</span>`,
-    `<span class="sat-pred-col-countdown" data-los="${pass.los_ms}">${formatCountdown(remaining)}</span>`,
-    `<span class="sat-pred-col-dir">${dir}</span>`,
-  ].join("");
-  return row;
-}
-
-function buildUpcomingPassRow(pass: SatellitePass): HTMLElement {
-  const row = document.createElement("div");
-  row.className = "sat-pred-row";
-  const dir = `${azToCardinal(pass.azimuth_aos_deg)} \u2192 ${azToCardinal(pass.azimuth_los_deg)}`;
-  row.innerHTML = [
-    `<span class="sat-pred-col-time">${formatPredTime(pass.aos_ms)}</span>`,
-    `<span class="sat-pred-col-sat">${pass.satellite}</span>`,
-    `<span class="sat-pred-col-el ${elevationClass(pass.max_elevation_deg)}">${pass.max_elevation_deg.toFixed(1)}\u00B0</span>`,
-    `<span class="sat-pred-col-dur">${formatPredDuration(pass.duration_s)}</span>`,
-    `<span class="sat-pred-col-dir">${dir}</span>`,
-  ].join("");
-  return row;
-}
-
-// ── Predictions: filter state ───────────────────────────────────────
-function filtered(): SatellitePass[] {
-  let items = predData;
-  if (predCategory !== "all") items = items.filter((p) => p.category === predCategory);
-  if (predMinEl > 0) items = items.filter((p) => p.max_elevation_deg >= predMinEl);
-  if (predFilterText) items = items.filter((p) => p.satellite.toUpperCase().includes(predFilterText));
-  return items;
-}
-
-function applyFilters() {
-  render(filtered());
-}
-
-const filterInput = dom.filter;
-filterInput?.addEventListener("input", () => {
-  predFilterText = filterInput.value.trim().toUpperCase();
-  applyFilters();
-});
-
-const minElevationSelect = dom.minElevation;
-minElevationSelect?.addEventListener("change", () => {
-  predMinEl = Number.parseInt(minElevationSelect.value, 10) || 0;
-  applyFilters();
-});
-
-const categorySelect = dom.category;
-categorySelect?.addEventListener("change", () => {
-  predCategory = categorySelect.value;
-  applyFilters();
-});
-
-// ── Predictions: main render ────────────────────────────────────────
-function render(passes: SatellitePass[], error?: string): void {
-  stopCountdownTimer();
-
-  if (error) {
-    if (dom.currentList)  dom.currentList.innerHTML = "";
-    if (dom.upcomingList) dom.upcomingList.innerHTML = "";
-    if (dom.currentSection)   dom.currentSection.style.display = "none";
-    if (dom.upcomingSection)  dom.upcomingSection.style.display = "none";
-    if (dom.status)       dom.status.textContent = error;
-    return;
-  }
-
-  if (!Array.isArray(passes) || passes.length === 0) {
-    if (dom.currentList)  dom.currentList.innerHTML = "";
-    if (dom.upcomingList) dom.upcomingList.innerHTML = "";
-    if (dom.currentSection)   dom.currentSection.style.display = "none";
-    if (dom.upcomingSection)  dom.upcomingSection.style.display = "none";
-    if (dom.status)       dom.status.textContent = "No passes found in the next 24 hours.";
-    return;
-  }
-
-  const now = Date.now();
-  const current = passes.filter((p) => p.aos_ms <= now && p.los_ms > now);
-  const upcoming = passes.filter((p) => p.aos_ms > now);
-
-  // ── Current passes ──
-  if (dom.currentSection) dom.currentSection.style.display = current.length > 0 ? "" : "none";
-  if (dom.currentList) {
-    if (current.length === 0) {
-      dom.currentList.innerHTML = "";
-    } else {
-      const frag = document.createDocumentFragment();
-      for (const pass of current) frag.appendChild(buildCurrentPassRow(pass, now));
-      dom.currentList.replaceChildren(frag);
-    }
-  }
-
-  // ── Upcoming passes ──
-  const upcomingLimit = predShowAll ? upcoming.length : PAGE_SIZE;
-  const visibleUpcoming = upcoming.slice(0, upcomingLimit);
-  const hiddenCount = upcoming.length - visibleUpcoming.length;
-  if (dom.upcomingSection) dom.upcomingSection.style.display = upcoming.length > 0 ? "" : "none";
-  if (dom.upcomingList) {
-    const frag = document.createDocumentFragment();
-    for (const pass of visibleUpcoming) frag.appendChild(buildUpcomingPassRow(pass));
-    if (hiddenCount > 0) {
-      const moreRow = document.createElement("div");
-      moreRow.className = "sat-pred-row";
-      moreRow.style.cursor = "pointer";
-      moreRow.style.textAlign = "center";
-      moreRow.innerHTML = `<span style="grid-column:1/-1;color:var(--accent);font-size:0.82rem;">Show ${hiddenCount} more passes\u2026</span>`;
-      moreRow.addEventListener("click", () => {
-        predShowAll = true;
-        render(filtered());
-      });
-      frag.appendChild(moreRow);
-    }
-    dom.upcomingList.replaceChildren(frag);
-  }
-
-  // ── Status ──
-  if (dom.status) {
-    let text = `${current.length} active \u00B7 ${upcoming.length} upcoming \u00B7 times in UTC`;
-    if (predSatCount > 0) text += ` \u00B7 ${predSatCount} satellites tracked`;
-    dom.status.textContent = text;
-  }
-
-  // ── Countdown timer ──
-  if (current.length > 0 && isPageVisible()) {
-    startCountdownTimer(dom.currentList);
-  }
-}
-
-// ── Predictions: data loading ───────────────────────────────────────
-async function load(): Promise<void> {
-  if (dom.status)       dom.status.textContent = "Loading predictions\u2026";
-  if (dom.currentList)  dom.currentList.innerHTML = "";
-  if (dom.upcomingList) dom.upcomingList.innerHTML = "";
-  try {
-    const resp = await fetch("/sat_passes");
-    if (!resp.ok) throw new Error(`HTTP ${resp.status}`);
-    const data = await resp.json() as SatellitePassResponse;
-    predSatCount = data.satellite_count || 0;
-    if (data.error) {
-      predData = [];
-      render([], data.error);
-    } else {
-      predData = data.passes || [];
-      render(filtered());
-    }
-  } catch (error: unknown) {
-    render([], `Failed to load predictions: ${error instanceof Error ? error.message : String(error)}`);
-  }
-}
-
-// ── Page lifecycle ──────────────────────────────────────────────────
-function clearPredictionDom(): void {
-  stopCountdownTimer();
-  if (dom.currentList)  dom.currentList.innerHTML = "";
-  if (dom.upcomingList) dom.upcomingList.innerHTML = "";
-}
-predWindow.clearSatPredictionDom = clearPredictionDom;
-
-/**
- * Called by the router each time the Satellites page is opened, including the
- * visit that imports this module — so loading is driven from one place only.
- */
-predWindow.refreshSatPredictions = function () {
-  predShowAll = false;
-  void load();
-};

src/trx-client/trx-frontend/trx-frontend-http/frontend/src/plugins/sstv.ts

@@ -14,13 +14,11 @@
 
 import { hostCore } from "./host.js";
 
-import { forActiveRig, isActiveRigDecode } from "./active-rig.js";
 import type { PluginRuntimeWindow } from "./runtime-contract.js";
 
 export {};
 
 interface SstvImage {
-  rig_id?: string | null;
   ts_ms?: number;
   vis?: number;
   mode?: string;
@@ -34,7 +32,6 @@ interface SstvImage {
 }
 
 interface SstvProgress {
-  rig_id?: string | null;
   state?: string;
   mode?: string;
   width?: number;
@@ -188,9 +185,6 @@ function paintRow(line: number, rgb: Uint8Array): void {
 // ── Server messages ─────────────────────────────────────────────────
 
 function onProgress(msg: SstvProgress): void {
-  // The live canvas draws one picture at a time: a background rig's rows would
-  // paint straight over the one being watched.
-  if (!isActiveRigDecode(msg.rig_id)) return;
   if (msg.state) {
     if (sstvDom.status) sstvDom.status.textContent = msg.state;
     // A state update carries the geometry; a row update carries only the row.
@@ -214,9 +208,6 @@ function onImage(msg: SstvImage): void {
   if (sstvHistory.length > SSTV_MAX_IMAGES) sstvHistory.shift();
   pruneHistory();
 
-  // Kept in the history either way, so switching to that rig finds it there.
-  if (!isActiveRigDecode(image.rig_id)) return;
-
   if (sstvDom.status) {
     sstvDom.status.textContent = image.complete
       ? `Received ${image.mode ?? "picture"}`
@@ -228,15 +219,9 @@ function onImage(msg: SstvImage): void {
 
 // ── Rendering ───────────────────────────────────────────────────────
 
-/** The pictures the selected rig decoded, oldest first, as the history is kept. */
-function sstvRigImages(): SstvImage[] {
-  return forActiveRig(sstvHistory);
-}
-
 function renderLatestCard(): void {
   if (!sstvDom.liveLatest) return;
-  const rigImages = sstvRigImages();
-  const latest = rigImages[rigImages.length - 1];
+  const latest = sstvHistory[sstvHistory.length - 1];
   if (!latest) {
     sstvDom.liveLatest.innerHTML = "";
     return;
@@ -260,12 +245,10 @@ function renderLatestCard(): void {
 }
 
 function filteredHistory(): SstvImage[] {
-  // Every rig's pictures are kept; the panel shows the selected rig's.
-  const rigImages = sstvRigImages();
   const text = filterText.trim().toLowerCase();
   const matching = text
-    ? rigImages.filter((image) => (image.mode ?? "").toLowerCase().includes(text))
-    : rigImages;
+    ? sstvHistory.filter((image) => (image.mode ?? "").toLowerCase().includes(text))
+    : sstvHistory.slice();
   const newestFirst = (sstvDom.sortSelect?.value ?? "newest") === "newest";
   matching.sort((a, b) => (newestFirst ? 1 : -1) * ((b._tsMs ?? 0) - (a._tsMs ?? 0)));
   return matching;
@@ -365,7 +348,6 @@ sstvWindow.trxPluginRuntime.registerDecoder({
   restore: restoreHistory,
   prune: renderHistoryTable,
   reset: resetHistoryView,
-  rerender: () => { renderLatestCard(); renderHistoryTable(); },
 });
 sstvWindow.trxPluginRuntime.registerDecoder({
   id: "sstv_progress",

src/trx-client/trx-frontend/trx-frontend-http/frontend/src/plugins/vdes.ts

@@ -6,7 +6,6 @@ import { hostCore } from "./host.js";
 
 export {};
 
-import { forActiveRig, isActiveRigDecode } from "./active-rig.js";
 import type { PluginRuntimeWindow } from "./runtime-contract";
 
 interface VdesMessage {
@@ -117,24 +116,17 @@ function vdesHexPreview(rawBytes: number[] | undefined): string {
     .toUpperCase();
 }
 
-/** What the selected rig heard.  The history holds every rig's traffic, for
- *  the map; the panel is about the rig the operator is working. */
-function vdesRigMessages(): VdesMessage[] {
-  return forActiveRig(vdesMessageHistory);
-}
-
 function updateVdesSummary() {
   pruneVdesMessageHistory();
   if (vdesChannelSummaryEl) {
     vdesChannelSummaryEl.textContent = currentVdesCenterText();
   }
-  const rigMessages = vdesRigMessages();
   if (vdesFrameCountEl) {
-    const count = rigMessages.length;
+    const count = vdesMessageHistory.length;
     vdesFrameCountEl.textContent = `${count} burst${count === 1 ? "" : "s"}`;
   }
   if (vdesLatestSeenEl) {
-    const latest = rigMessages[0];
+    const latest = vdesMessageHistory[0];
     vdesLatestSeenEl.textContent = latest ? vdesAgeText(latest._tsMs) : "No traffic yet";
   }
 }
@@ -236,9 +228,7 @@ function updateVdesBar() {
   updateVdesSummary();
   const isVdes = ((document.getElementById("mode") as HTMLSelectElement | null)?.value || "").toUpperCase() === "VDES";
   const cutoffMs = Date.now() - VDES_BAR_WINDOW_MS;
-  const messages = vdesMessageHistory
-    .filter((msg) => (msg._tsMs ?? 0) >= cutoffMs && isActiveRigDecode(msg.rig_id))
-    .slice(0, 6);
+  const messages = vdesMessageHistory.filter((msg) => (msg._tsMs ?? 0) >= cutoffMs).slice(0, 6);
   if (!isVdes || messages.length === 0) {
     vdesBarOverlay.style.display = "none";
     vdesBarOverlay.innerHTML = "";
@@ -288,7 +278,7 @@ function renderVdesHistory() {
     return;
   }
   const fragment = document.createDocumentFragment();
-  for (const message of vdesRigMessages()) {
+  for (const message of vdesMessageHistory) {
     fragment.appendChild(renderVdesRow(message));
   }
   vdesMessagesEl.replaceChildren(fragment);
@@ -319,11 +309,10 @@ function normalizeServerVdesMessage(msg: VdesMessage): VdesMessage {
 
 function onServerVdesBatch(messages: VdesMessage[]): void {
   if (!Array.isArray(messages) || messages.length === 0) return;
+  if (vdesStatus) vdesStatus.textContent = "Receiving";
   const normalized: VdesMessage[] = [];
   for (const msg of messages) {
     const next = normalizeServerVdesMessage(msg);
-    // "Receiving" is the panel's own status, and the panel is the rig's.
-    if (vdesStatus && isActiveRigDecode(next.rig_id)) vdesStatus.textContent = "Receiving";
     const tsMs = Number.isFinite(next.ts_ms) ? Number(next.ts_ms) : Date.now();
     next._tsMs = tsMs;
     next._ts = new Date(tsMs).toLocaleTimeString([], {
@@ -365,8 +354,8 @@ function plotVdesMessage(msg: VdesMessage): void {
 }
 
 function onServerVdes(msg: VdesMessage): void {
+  if (vdesStatus) vdesStatus.textContent = "Receiving";
   const next = normalizeServerVdesMessage(msg);
-  if (vdesStatus && isActiveRigDecode(next.rig_id)) vdesStatus.textContent = "Receiving";
   addVdesMessage(next);
   plotVdesMessage(next);
 }
@@ -385,7 +374,6 @@ updateVdesSummary();
   restore: onServerVdesBatch,
   reset: resetVdesHistoryView,
   prune: pruneVdesHistoryView,
-  rerender: () => { updateVdesBar(); renderVdesHistory(); },
   // Oldest first, so tracks are rebuilt in the order they happened.
   syncMap: () => { for (const entry of [...vdesMessageHistory].reverse()) plotVdesMessage(entry); },
 });

src/trx-client/trx-frontend/trx-frontend-http/frontend/src/plugins/wefax.ts

@@ -4,13 +4,11 @@
 
 import { hostCore } from "./host.js";
 
-import { forActiveRig, isActiveRigDecode } from "./active-rig.js";
 import type { PluginRuntimeWindow } from "./runtime-contract.js";
 
 export {};
 
 interface WefaxImage {
-  rig_id?: string | null;
   ts_ms?: number;
   ioc?: number;
   lpm?: number;
@@ -22,7 +20,6 @@ interface WefaxImage {
 }
 
 interface WefaxProgress {
-  rig_id?: string | null;
   state?: string;
   line_data?: string;
   line_count?: number;
@@ -159,21 +156,15 @@ function paintLine(lineBytes: Uint8Array): void {
 }
 
 // ── Live view: latest image card ────────────────────────────────────
-/** The pictures the selected rig decoded, newest first. */
-function wefaxRigImages(): WefaxImage[] {
-  return forActiveRig(wefaxImageHistory);
-}
-
 function renderWefaxLatestCard() {
   if (!wefaxDom.liveLatest) return;
-  const rigImages = wefaxRigImages();
-  if (rigImages.length === 0) {
+  if (wefaxImageHistory.length === 0) {
     wefaxDom.liveLatest.innerHTML =
       '<div style="color:var(--text-muted);font-size:0.82rem;">No images decoded yet. Enable the decoder and tune to a WEFAX station.</div>';
     return;
   }
 
-  const img = rigImages[0];
+  const img = wefaxImageHistory[0];
   if (!img) return;
   const ts = img._ts || '--';
   const date = img._tsMs ? new Date(img._tsMs).toLocaleDateString() : '';
@@ -202,8 +193,7 @@ function renderWefaxLatestCard() {
 
 // ── History view: table ─────────────────────────────────────────────
 function getWefaxFilteredHistory() {
-  // Every rig's pictures are kept; the panel shows the selected rig's.
-  let items = wefaxRigImages();
+  let items = wefaxImageHistory;
 
   if (wefaxFilterText) {
     items = items.filter(function (i) {
@@ -263,7 +253,7 @@ function renderWefaxHistoryTable() {
   wefaxDom.historyList.replaceChildren(fragment);
 
   if (wefaxDom.historyCount) {
-    const total = wefaxRigImages().length;
+    const total = wefaxImageHistory.length;
     const shown = items.length;
     wefaxDom.historyCount.textContent =
       total === 0
@@ -308,9 +298,6 @@ function addWefaxImage(msg: WefaxImage): void {
 
 // ── SSE event handlers (public API) ─────────────────────────────────
 function onServerWefaxProgress(msg: WefaxProgress): void {
-  // The live canvas draws one picture at a time: a background rig's lines
-  // would paint straight over the one being watched.
-  if (!isActiveRigDecode(msg.rig_id)) return;
   // State-only update (no image data): show decoder state in status.
   if (msg.state && !msg.line_data) {
     if (wefaxDom.status) {
@@ -344,8 +331,6 @@ function onServerWefaxProgress(msg: WefaxProgress): void {
 
 function onServerWefax(msg: WefaxImage): void {
   addWefaxImage(msg);
-  // Kept in the history either way, so switching to that rig finds it there.
-  if (!isActiveRigDecode(msg.rig_id)) return;
 
   if (wefaxDom.liveContainer) wefaxDom.liveContainer.style.display = 'none';
   if (wefaxDom.status) {
@@ -453,7 +438,6 @@ wefaxWindow.trxPluginRuntime.registerDecoder({
   restore: restoreWefaxHistory,
   prune: pruneWefaxHistoryView,
   reset: resetWefaxHistoryView,
-  rerender: () => { renderWefaxLatestCard(); renderWefaxHistoryTable(); },
 });
 wefaxWindow.trxPluginRuntime.registerDecoder({
   id: "wefax_progress",

src/trx-client/trx-frontend/trx-frontend-http/frontend/src/plugins/wspr.ts

@@ -4,7 +4,6 @@
 
 import { hostCore } from "./host.js";
 
-import { forActiveRig, isActiveRigDecode } from "./active-rig.js";
 import type { PluginRuntimeWindow } from "./runtime-contract.js";
 
 export {};
@@ -16,7 +15,6 @@ interface WsprMessage {
   snr_db?: number | undefined;
   dt_s?: number | undefined;
   freq_hz?: number | undefined;
-  rig_id?: string | null | undefined;
   receiver?: unknown;
   [key: string]: unknown;
 }
@@ -104,12 +102,10 @@ function renderWsprRow(msg: WsprMessage): HTMLDivElement {
 function renderWsprHistory(): void {
   pruneWsprMessageHistory();
   if (!wsprMessagesEl) return;
-  // The history holds every rig's decodes, for the map; the panel is about the
-  // rig the operator is working.
-  const rigMessages = forActiveRig(wsprMessageHistory);
   const fragment = document.createDocumentFragment();
-  for (const message of rigMessages) {
-    fragment.appendChild(renderWsprRow(message));
+  for (let i = 0; i < wsprMessageHistory.length; i += 1) {
+    const message = wsprMessageHistory[i];
+    if (message) fragment.appendChild(renderWsprRow(message));
   }
   wsprMessagesEl.replaceChildren(fragment);
 }
@@ -134,7 +130,6 @@ function normalizeServerWsprMessage(msg: WsprMessage): { raw: string; grids: str
     station,
     rfHz,
     history: {
-      rig_id: msg.rig_id ?? null,
       receiver: wsprWindow.getDecodeRigMeta ? wsprWindow.getDecodeRigMeta() : null,
       ts_ms: msg.ts_ms,
       snr_db: msg.snr_db,
@@ -147,11 +142,10 @@ function normalizeServerWsprMessage(msg: WsprMessage): { raw: string; grids: str
 
 function onServerWsprBatch(messages: WsprMessage[]): void {
   if (!Array.isArray(messages) || messages.length === 0) return;
+  if (wsprStatus) wsprStatus.textContent = "Receiving";
   const normalized: WsprMessage[] = [];
   for (const msg of messages) {
     const next = normalizeServerWsprMessage(msg);
-    // "Receiving" is the panel's own status, and the panel is the rig's.
-    if (wsprStatus && isActiveRigDecode(msg.rig_id)) wsprStatus.textContent = "Receiving";
     if (next.grids.length > 0 && wsprWindow.mapAddLocator) {
       wsprWindow.mapAddLocator(next.raw, next.grids, "wspr", next.station, {
         ...msg,
@@ -318,7 +312,7 @@ document.getElementById("settings-clear-wspr-history")?.addEventListener("click"
 });
 
 function onServerWspr(msg: WsprMessage): void {
-  if (wsprStatus && isActiveRigDecode(msg.rig_id)) wsprStatus.textContent = "Receiving";
+  if (wsprStatus) wsprStatus.textContent = "Receiving";
   const next = normalizeServerWsprMessage(msg);
   if (next.grids.length > 0 && wsprWindow.mapAddLocator) {
     wsprWindow.mapAddLocator(next.raw, next.grids, "wspr", next.station, {
@@ -336,5 +330,4 @@ wsprWindow.trxPluginRuntime.registerDecoder({
   restore: onServerWsprBatch,
   prune: pruneWsprHistoryView,
   reset: resetWsprHistoryView,
-  rerender: renderWsprHistory,
 });

src/trx-client/trx-frontend/trx-frontend-http/frontend/src/ui-core.ts

@@ -499,7 +499,7 @@ function elementById<T extends HTMLElement>(id: string): T {
       if (restoreFocus) more.focus();
     };
     api.closeMobileOverlays = closeMore;
-    ["satellites", "statistics", "recorder", "settings", "about"].forEach((tabName) => {
+    ["statistics", "recorder", "settings", "about"].forEach((tabName) => {
       const source = nav.querySelector(`[data-tab="${tabName}"]`);
       if (!source) return;
       const item = document.createElement("button");

src/trx-client/trx-frontend/trx-frontend-http/frontend/tests/active-rig.test.mjs

@@ -1,348 +0,0 @@
-// SPDX-FileCopyrightText: 2026 Stan Grams <sjg@haxx.space>
-//
-// SPDX-License-Identifier: GPL-2.0-or-later
-
-// The radio page and the digital modes page both describe one rig: the one the
-// operator selected.  Every rig a client is connected to feeds the same decode
-// stream, so both the mini views over the waterfall and the panels behind them
-// filter on the rig that heard each decode.  The map is the exception and keeps
-// all of them — it has its own rig filter — which is why the histories these
-// views read from are never pruned by rig.
-
-import assert from "node:assert/strict";
-import test from "node:test";
-import vm from "node:vm";
-import { bundleEntry } from "./bundle-entry.mjs";
-import { createHost } from "./host-fixture.mjs";
-
-class ElementFixture {
-  constructor(value = "") {
-    this.children = [];
-    this.innerHTML = "";
-    this.textContent = "";
-    this.value = value;
-    this.style = {};
-    this.dataset = {};
-    this.classList = { add() {}, remove() {}, toggle() {} };
-  }
-  appendChild(child) { this.children.push(child); return child; }
-  removeChild(child) { this.children.splice(this.children.indexOf(child), 1); }
-  replaceChildren(...nodes) { this.children = nodes.flatMap((node) => node.children ?? [node]); }
-  addEventListener() {}
-  setAttribute() {}
-  querySelector() { return null; }
-  querySelectorAll() { return []; }
-  get firstChild() { return this.children[0] ?? null; }
-  get lastElementChild() { return this.children.at(-1) ?? null; }
-  get scrollHeight() { return this.children.length; }
-}
-
-/** A document whose named elements exist and whose unknown ones do not. */
-function createDocument(elements) {
-  return {
-    documentElement: {},
-    getElementById: (id) => elements.get(id) ?? null,
-    querySelector: () => null,
-    querySelectorAll: () => [],
-    createElement: () => new ElementFixture(),
-    createDocumentFragment: () => new ElementFixture(),
-  };
-}
-
-async function runPlugin(entry, { window, document: doc, extras = {} }) {
-  const context = vm.createContext({
-    window,
-    document: doc,
-    navigator: {},
-    requestAnimationFrame(callback) { callback(); return 1; },
-    getComputedStyle: () => ({ getPropertyValue: () => "" }),
-    Date, Number, String, Math, Array, Map, Set, Reflect, console,
-    ...extras,
-  });
-  const runtime = await bundleEntry(new URL("../src/plugin-runtime.ts", import.meta.url));
-  const source = await bundleEntry(new URL(`../src/plugins/${entry}.ts`, import.meta.url));
-  new vm.Script(runtime).runInContext(context);
-  new vm.Script(source).runInContext(context);
-  return context;
-}
-
-test("the APRS mini view and panel both keep to the active rig", async () => {
-  const overlay = new ElementFixture();
-  const packets = new ElementFixture();
-  const totals = new ElementFixture();
-  const elements = new Map([
-    ["aprs-bar-overlay", overlay],
-    ["aprs-packets", packets],
-    ["aprs-total-count", totals],
-    ["mode", new ElementFixture("PKT")],
-  ]);
-  const window = {
-    ...createHost({ state: { lastActiveRigId: "rig-a" } }),
-    trxUi: { confirm: async () => true },
-    aprsMapAddStation: () => {},
-  };
-  await runPlugin("aprs", { window, document: createDocument(elements) });
-
-  const frame = { dest_call: "APRS", packet_type: "position", crc_ok: true, info: "beacon" };
-  window.trxPluginRuntime.dispatch("aprs", { ...frame, src_call: "SP1AAA", rig_id: "rig-a" });
-  window.trxPluginRuntime.dispatch("aprs", { ...frame, src_call: "SP2BBB", rig_id: "rig-b" });
-
-  assert.match(overlay.innerHTML, /SP1AAA/, "the active rig's frame is missing from the mini view");
-  assert.doesNotMatch(overlay.innerHTML, /SP2BBB/, "a background rig's frame reached the mini view");
-  assert.equal(packets.children.length, 1, "the APRS panel listed a background rig's frame");
-  assert.equal(totals.textContent, "1 total", `the APRS panel counted "${totals.textContent}"`);
-});
-
-test("the APRS mini view shows every frame until a rig is known", async () => {
-  const overlay = new ElementFixture();
-  const elements = new Map([
-    ["aprs-bar-overlay", overlay],
-    ["mode", new ElementFixture("PKT")],
-  ]);
-  const window = {
-    ...createHost(),
-    trxUi: { confirm: async () => true },
-    aprsMapAddStation: () => {},
-  };
-  await runPlugin("aprs", { window, document: createDocument(elements) });
-
-  const frame = { dest_call: "APRS", packet_type: "position", crc_ok: true, info: "beacon" };
-  window.trxPluginRuntime.dispatch("aprs", { ...frame, src_call: "SP1AAA", rig_id: "rig-a" });
-  window.trxPluginRuntime.dispatch("aprs", { ...frame, src_call: "SP2BBB" });
-
-  assert.match(overlay.innerHTML, /SP1AAA/);
-  assert.match(overlay.innerHTML, /SP2BBB/);
-});
-
-test("the AIS mini view keeps to the active rig", async () => {
-  const overlay = new ElementFixture();
-  const elements = new Map([
-    ["ais-bar-overlay", overlay],
-    ["mode", new ElementFixture("AIS")],
-  ]);
-  const window = {
-    ...createHost({ state: { lastActiveRigId: "rig-a" } }),
-    trxUi: { confirm: async () => true },
-    aisMapAddVessel: () => {},
-  };
-  await runPlugin("ais", { window, document: createDocument(elements) });
-
-  const now = Date.now();
-  window.trxPluginRuntime.dispatch("ais", { mmsi: 261000001, vessel_name: "NEARBY", channel: "A", ts_ms: now, rig_id: "rig-a" });
-  window.trxPluginRuntime.dispatch("ais", { mmsi: 261000002, vessel_name: "ELSEWHERE", channel: "A", ts_ms: now, rig_id: "rig-b" });
-
-  assert.match(overlay.innerHTML, /NEARBY/);
-  assert.doesNotMatch(overlay.innerHTML, /ELSEWHERE/, "a background rig's vessel reached the mini view");
-});
-
-test("the VDES mini view keeps to the active rig", async () => {
-  const overlay = new ElementFixture();
-  const elements = new Map([
-    ["vdes-bar-overlay", overlay],
-    ["mode", new ElementFixture("VDES")],
-  ]);
-  const window = {
-    ...createHost({ state: { lastActiveRigId: "rig-a" } }),
-    trxUi: { confirm: async () => true },
-    vdesMapAddPoint: () => {},
-  };
-  await runPlugin("vdes", { window, document: createDocument(elements) });
-
-  const now = Date.now();
-  window.trxPluginRuntime.dispatch("vdes", { callsign: "SP1AAA", bit_len: 120, ts_ms: now, rig_id: "rig-a" });
-  window.trxPluginRuntime.dispatch("vdes", { callsign: "SP2BBB", bit_len: 120, ts_ms: now, rig_id: "rig-b" });
-
-  assert.match(overlay.innerHTML, /SP1AAA/);
-  assert.doesNotMatch(overlay.innerHTML, /SP2BBB/, "a background rig's burst reached the mini view");
-});
-
-test("the CW mini view keeps to the active rig and does not braid two rigs into a line", async () => {
-  const overlay = new ElementFixture();
-  const elements = new Map([
-    ["cw-bar-overlay", overlay],
-    ["cw-output", new ElementFixture()],
-    ["mode", new ElementFixture("CW")],
-  ]);
-  const window = {
-    ...createHost({ state: { lastActiveRigId: "rig-a" } }),
-    trxUi: { confirm: async () => true },
-    addEventListener() {},
-  };
-  await runPlugin("cw", { window, document: createDocument(elements) });
-
-  window.trxPluginRuntime.dispatch("cw", { text: "CQ ", wpm: 18, tone_hz: 700, rig_id: "rig-a" });
-  window.trxPluginRuntime.dispatch("cw", { text: "DX ", wpm: 22, tone_hz: 600, rig_id: "rig-b" });
-  window.trxPluginRuntime.dispatch("cw", { text: "SP1AAA", wpm: 18, tone_hz: 700, rig_id: "rig-a" });
-
-  assert.match(overlay.innerHTML, /CQ SP1AAA/, "the active rig's line was broken up or lost");
-  assert.doesNotMatch(overlay.innerHTML, /DX/, "a background rig's characters reached the mini view");
-});
-
-test("the FT8 mini view keeps to the active rig", async () => {
-  const overlay = new ElementFixture();
-  const elements = new Map([
-    ["ft8-bar-overlay", overlay],
-    ["mode", new ElementFixture("DIG")],
-  ]);
-  const window = {
-    ...createHost({ state: { lastActiveRigId: "rig-a" } }),
-    ft8BaseHz: 7_074_000,
-    trxUi: { confirm: async () => true },
-    mapAddLocator: () => {},
-    setInterval() { return 1; },
-  };
-  await runPlugin("ft8", { window, document: createDocument(elements) });
-
-  const now = Date.now();
-  window.trxPluginRuntime.dispatch("ft8", { message: "CQ SP1AAA JO91", freq_hz: 500, ts_ms: now, rig_id: "rig-a" });
-  window.trxPluginRuntime.dispatch("ft8", { message: "CQ SP2BBB JO94", freq_hz: 800, ts_ms: now, rig_id: "rig-b" });
-
-  assert.match(overlay.innerHTML, /SP1AAA/);
-  assert.doesNotMatch(overlay.innerHTML, /SP2BBB/, "a background rig's decode reached the mini view");
-});
-
-// ── The digital modes panels ───────────────────────────────────────────────
-// The same rule one page over: a panel lists the selected rig's decodes only.
-
-test("the AIS panel lists the active rig's vessels only", async () => {
-  const messages = new ElementFixture();
-  const count = new ElementFixture();
-  const elements = new Map([
-    ["ais-messages", messages],
-    ["ais-vessel-count", count],
-    ["mode", new ElementFixture("AIS")],
-  ]);
-  const window = {
-    ...createHost({ state: { lastActiveRigId: "rig-a" } }),
-    trxUi: { confirm: async () => true },
-    aisMapAddVessel: () => {},
-  };
-  await runPlugin("ais", { window, document: createDocument(elements) });
-
-  const now = Date.now();
-  window.trxPluginRuntime.dispatch("ais", { mmsi: 261000001, vessel_name: "NEARBY", channel: "A", ts_ms: now, rig_id: "rig-a" });
-  window.trxPluginRuntime.dispatch("ais", { mmsi: 261000002, vessel_name: "ELSEWHERE", channel: "A", ts_ms: now, rig_id: "rig-b" });
-
-  assert.equal(messages.children.length, 1, "the AIS panel listed a background rig's vessel");
-  assert.equal(count.textContent, "1 vessel", `the panel counted "${count.textContent}"`);
-});
-
-test("the VDES panel lists the active rig's bursts only", async () => {
-  const messages = new ElementFixture();
-  const count = new ElementFixture();
-  const elements = new Map([
-    ["vdes-messages", messages],
-    ["vdes-frame-count", count],
-    ["mode", new ElementFixture("VDES")],
-  ]);
-  const window = {
-    ...createHost({ state: { lastActiveRigId: "rig-a" } }),
-    trxUi: { confirm: async () => true },
-    vdesMapAddPoint: () => {},
-  };
-  await runPlugin("vdes", { window, document: createDocument(elements) });
-
-  const now = Date.now();
-  window.trxPluginRuntime.dispatch("vdes", { callsign: "SP1AAA", bit_len: 120, ts_ms: now, rig_id: "rig-a" });
-  window.trxPluginRuntime.dispatch("vdes", { callsign: "SP2BBB", bit_len: 120, ts_ms: now, rig_id: "rig-b" });
-
-  assert.equal(messages.children.length, 1, "the VDES panel listed a background rig's burst");
-  assert.equal(count.textContent, "1 burst", `the panel counted "${count.textContent}"`);
-});
-
-test("the FT8 panel lists the active rig's decodes only", async () => {
-  const messages = new ElementFixture();
-  const elements = new Map([
-    ["ft8-messages", messages],
-    ["mode", new ElementFixture("DIG")],
-  ]);
-  const window = {
-    ...createHost({ state: { lastActiveRigId: "rig-a" } }),
-    ft8BaseHz: 7_074_000,
-    trxUi: { confirm: async () => true },
-    mapAddLocator: () => {},
-    setInterval() { return 1; },
-  };
-  await runPlugin("ft8", { window, document: createDocument(elements) });
-
-  const now = Date.now();
-  window.trxPluginRuntime.dispatch("ft8", { message: "CQ SP1AAA JO91", freq_hz: 500, ts_ms: now, rig_id: "rig-a" });
-  window.trxPluginRuntime.dispatch("ft8", { message: "CQ SP2BBB JO94", freq_hz: 800, ts_ms: now, rig_id: "rig-b" });
-
-  assert.equal(messages.children.length, 1, "the FT8 panel listed a background rig's decode");
-});
-
-test("the WSPR panel lists the active rig's spots only", async () => {
-  const messages = new ElementFixture();
-  const elements = new Map([
-    ["wspr-messages", messages],
-    ["mode", new ElementFixture("DIG")],
-  ]);
-  const window = {
-    ...createHost({ state: { lastActiveRigId: "rig-a" } }),
-    ft8BaseHz: 14_095_600,
-    trxUi: { confirm: async () => true },
-    mapAddLocator: () => {},
-  };
-  await runPlugin("wspr", {
-    window,
-    document: createDocument(elements),
-    extras: { setInterval: () => 1 },
-  });
-
-  const now = Date.now();
-  window.trxPluginRuntime.dispatch("wspr", { message: "SP1AAA JO91 30", freq_hz: 1_500, ts_ms: now, rig_id: "rig-a" });
-  window.trxPluginRuntime.dispatch("wspr", { message: "SP2BBB JO94 27", freq_hz: 1_520, ts_ms: now, rig_id: "rig-b" });
-
-  assert.equal(messages.children.length, 1, "the WSPR panel listed a background rig's spot");
-});
-
-test("the CW pane copies the active rig only", async () => {
-  const output = new ElementFixture();
-  const elements = new Map([
-    ["cw-output", output],
-    ["cw-bar-overlay", new ElementFixture()],
-    ["mode", new ElementFixture("CW")],
-  ]);
-  const window = {
-    ...createHost({ state: { lastActiveRigId: "rig-a" } }),
-    trxUi: { confirm: async () => true },
-    addEventListener() {},
-  };
-  await runPlugin("cw", { window, document: createDocument(elements) });
-
-  window.trxPluginRuntime.dispatch("cw", { text: "CQ ", wpm: 18, tone_hz: 700, rig_id: "rig-a" });
-  window.trxPluginRuntime.dispatch("cw", { text: "XX ", wpm: 22, tone_hz: 600, rig_id: "rig-b" });
-  window.trxPluginRuntime.dispatch("cw", { text: "SP1AAA", wpm: 18, tone_hz: 700, rig_id: "rig-a" });
-
-  const copied = output.children.map((line) => line.textContent).join("");
-  assert.equal(copied, "CQ SP1AAA", `the pane copied "${copied}"`);
-});
-
-test("switching rigs repaints the panels through the runtime", async () => {
-  const packets = new ElementFixture();
-  const elements = new Map([
-    ["aprs-packets", packets],
-    ["aprs-bar-overlay", new ElementFixture()],
-    ["mode", new ElementFixture("PKT")],
-  ]);
-  // A mutable host: the rig picker writes lastActiveRigId, and the panels read
-  // it as they paint.
-  const host = createHost({ state: { lastActiveRigId: "rig-a" } });
-  let activeRigId = "rig-a";
-  Object.defineProperty(host.trx.state, "lastActiveRigId", { get: () => activeRigId });
-  const window = { ...host, trxUi: { confirm: async () => true }, aprsMapAddStation: () => {} };
-  await runPlugin("aprs", { window, document: createDocument(elements) });
-
-  const frame = { dest_call: "APRS", packet_type: "position", crc_ok: true, info: "beacon" };
-  window.trxPluginRuntime.dispatch("aprs", { ...frame, src_call: "SP1AAA", rig_id: "rig-a" });
-  window.trxPluginRuntime.dispatch("aprs", { ...frame, src_call: "SP2BBB", rig_id: "rig-b" });
-  assert.equal(packets.children.length, 1);
-
-  activeRigId = "rig-b";
-  window.trxPluginRuntime.rerenderAll();
-  assert.equal(packets.children.length, 1, "the panel did not follow the switch");
-  const shown = packets.children.map((row) => row.innerHTML).join("");
-  assert.match(shown, /SP2BBB/, "the panel still shows the rig that was switched away from");
-  assert.doesNotMatch(shown, /SP1AAA/);
-});

src/trx-client/trx-frontend/trx-frontend-http/frontend/tests/decode-flow.mjs

@@ -22,18 +22,9 @@ const BEACON = {
   packet_type: "position", crc_ok: true, lat: 54.35, lon: 18.65,
   symbol_table: "/", symbol_code: ">", rig_id: "rig-a",
 };
-// A second rig listening in the background, on its own band. Both pages
-// describe the rig on screen, so its traffic belongs in neither the panel nor
-// the mini view — only on the map, which shows the whole station.
-const OTHER_RIG_VESSEL = {
-  ...VESSEL, mmsi: 244660001, vessel_name: "ELDERBERRY", callsign: "PBTY",
-  lat: 51.92, lon: 4.48, rig_id: "rig-b",
-};
 
 // AIS is what the mini view for vessels is gated on; the rig has to be on it.
-const fixture = await startWebFixture({
-  spectrum: true, decodes: [VESSEL, BEACON, OTHER_RIG_VESSEL], mode: "AIS",
-});
+const fixture = await startWebFixture({ spectrum: true, decodes: [VESSEL, BEACON], mode: "AIS" });
 const { browser, page, runtimeErrors } = await startBrowser(chromium);
 
 try {
@@ -50,14 +41,11 @@ try {
     aprs: document.getElementById("aprs-packets")?.children.length ?? 0,
     aisStatus: document.getElementById("ais-status")?.textContent ?? "",
     aprsStatus: document.getElementById("aprs-status")?.textContent ?? "",
-    otherRig: document.getElementById("ais-messages")?.textContent.includes("ELDERBERRY") ?? false,
-    aisRows: document.getElementById("ais-messages")?.children.length ?? 0,
     mapLoaded: !!window.trx.modules.map,
   }));
   assert.equal(panels.mapLoaded, false, "the map module was loaded, so this proves nothing");
   assert.ok(panels.ais > 0, `the AIS panel is empty (status: ${panels.aisStatus})`);
   assert.ok(panels.aprs > 0, `the APRS panel is empty (status: ${panels.aprsStatus})`);
-  assert.equal(panels.otherRig, false, "the AIS panel listed a background rig's vessel");
 
   // The mini view rides over the waterfall on the radio page.
   await page.locator('.tab[data-tab="main"]').click();
@@ -68,13 +56,11 @@ try {
       shown: getComputedStyle(bar).display !== "none",
       pins: bar.querySelectorAll(".aprs-bar-pin").length,
       names: bar.textContent.includes("NEDERLAND"),
-      otherRig: bar.textContent.includes("ELDERBERRY"),
     };
   });
   assert.equal(miniView.shown, true, "the AIS mini view did not appear");
   assert.ok(miniView.pins > 0, "the mini view has no pin to follow");
   assert.equal(miniView.names, true, "the mini view does not name the vessel");
-  assert.equal(miniView.otherRig, false, "the mini view shows a background rig's vessel");
 
   // Following the pin: the map opens, on the vessel. This is the path that was
   // broken for every decoder — the module that owned the navigation had not
@@ -103,11 +89,8 @@ try {
       : Object.keys(collection ?? {}).length);
     return { ais: size(map?.aisMarkers), stations: size(map?.stationMarkers) };
   });
+  assert.ok(markers.ais > 0, "the vessel never reached the map");
   assert.ok(markers.stations > 0, "the APRS station never reached the map");
-  // The map is the whole station's view — the one place a background rig's
-  // traffic belongs — so both vessels are on it even though the panel and the
-  // mini view show only the selected rig's.
-  assert.equal(markers.ais, 2, `${markers.ais} of 2 vessels reached the map`);
 
   assert.deepEqual(runtimeErrors, []);
 } finally {

src/trx-client/trx-frontend/trx-frontend-http/frontend/tests/satellite-predictions.mjs

@@ -1,122 +0,0 @@
-// SPDX-FileCopyrightText: 2026 Stan Grams <sjg@haxx.space>
-//
-// SPDX-License-Identifier: GPL-2.0-or-later
-
-// Pass predictions used to be a third view inside the weather-satellite
-// decoder, under Digital modes — a planning tool filed with the decoders it has
-// nothing to do with. It is its own page now, so what this guards is that the
-// page exists at its own address, renders passes, and that the decoder card no
-// longer offers the view it gave up.
-
-import assert from "node:assert/strict";
-import { chromium } from "playwright-core";
-import { startBrowser, startWebFixture } from "./web-fixture.mjs";
-
-/* global document, window, getComputedStyle */
-
-const HOUR = 3_600_000;
-const now = Date.now();
-const satPasses = {
-  satellite_count: 2,
-  passes: [
-    // In progress right now, so the page has a countdown to run.
-    {
-      satellite: "NOAA 19", category: "weather",
-      aos_ms: now - 4 * 60_000, los_ms: now + 6 * 60_000,
-      max_elevation_deg: 62.4, duration_s: 600,
-      azimuth_aos_deg: 10, azimuth_los_deg: 190,
-    },
-    {
-      satellite: "ISS", category: "amateur",
-      aos_ms: now + 2 * HOUR, los_ms: now + 2 * HOUR + 480_000,
-      max_elevation_deg: 18.2, duration_s: 480,
-      azimuth_aos_deg: 200, azimuth_los_deg: 20,
-    },
-  ],
-};
-
-const fixture = await startWebFixture({ satPasses });
-const { browser, page, runtimeErrors } = await startBrowser(chromium);
-
-try {
-  await page.setViewportSize({ width: 1500, height: 950 });
-
-  // The page is reachable at its own address, not through a decoder sub-view.
-  // #content is the radio panel on the main tab, so the readiness signal for a
-  // deep link is the destination panel itself.
-  await page.goto(`${fixture.origin}/satellites`, { waitUntil: "domcontentloaded" });
-  await page.locator("#tab-satellites").waitFor({ state: "visible" });
-
-  await page.waitForFunction(
-    () => (document.getElementById("sat-pred-list")?.childElementCount ?? 0) > 0,
-    null,
-    { timeout: 5000 },
-  );
-
-  const rendered = await page.evaluate(() => ({
-    current: document.getElementById("sat-pred-current-list").textContent,
-    upcoming: document.getElementById("sat-pred-list").textContent,
-    status: document.getElementById("sat-pred-status").textContent,
-    activeTab: document.querySelector(".tab-bar .tab.active")?.dataset.tab,
-  }));
-  assert.match(rendered.current, /NOAA 19/, `current passes read "${rendered.current}"`);
-  assert.match(rendered.upcoming, /ISS/, `upcoming passes read "${rendered.upcoming}"`);
-  assert.match(rendered.status, /1 active/, `status reads "${rendered.status}"`);
-  assert.equal(rendered.activeTab, "satellites", "the Satellites tab is the active one");
-
-  // A pass in progress counts down, so the seconds have to move on their own.
-  const firstTick = await page.evaluate(
-    () => document.querySelector(".sat-pred-col-countdown[data-los]")?.textContent);
-  await page.waitForTimeout(1600);
-  const secondTick = await page.evaluate(
-    () => document.querySelector(".sat-pred-col-countdown[data-los]")?.textContent);
-  assert.notEqual(firstTick, secondTick, `the countdown sat at ${firstTick}`);
-
-  // Leaving stops the countdown rather than leaving a timer running behind a
-  // hidden page.
-  await page.evaluate(() => { window.navigateToTab("main"); });
-  await page.waitForTimeout(300);
-  const afterLeaving = await page.evaluate(() => ({
-    visible: document.getElementById("tab-satellites").style.display,
-    rows: document.getElementById("sat-pred-current-list").childElementCount,
-  }));
-  assert.equal(afterLeaving.visible, "none", "the page stayed on screen after navigating away");
-  assert.equal(afterLeaving.rows, 0, "the countdown rows outlived the page");
-
-  // Coming back reloads rather than showing whatever was there before.
-  await page.evaluate(() => { window.navigateToTab("satellites"); });
-  await page.waitForFunction(
-    () => (document.getElementById("sat-pred-list")?.childElementCount ?? 0) > 0,
-    null,
-    { timeout: 5000 },
-  );
-
-  // The page is an occasional destination, so it lives behind Tools rather than
-  // taking a slot in the operating strip — the same treatment Statistics,
-  // Recorder, Settings and About get.
-  const nav = await page.evaluate(() => ({
-    inStrip: getComputedStyle(document.querySelector('.tab-bar-nav .tab[data-tab="satellites"]')).display,
-    inTools: !!document.querySelector('#mobile-more-menu [data-navigate-tab="satellites"]'),
-  }));
-  assert.equal(nav.inStrip, "none", "Satellites took a slot in the operating strip");
-  assert.ok(nav.inTools, "Satellites is not reachable from Tools");
-
-  // The decoder card keeps Live and History, and no longer offers Predictions.
-  await page.goto(`${fixture.origin}/digital-modes`, { waitUntil: "domcontentloaded" });
-  await page.locator("#tab-digital-modes").waitFor({ state: "visible" });
-  const satCard = await page.evaluate(() => ({
-    predictionsButton: !!document.getElementById("sat-view-predictions"),
-    predictionsView: !!document.getElementById("sat-predictions-view"),
-    live: !!document.getElementById("sat-view-live"),
-    history: !!document.getElementById("sat-view-history"),
-  }));
-  assert.equal(satCard.predictionsButton, false, "the decoder card still offers Predictions");
-  assert.equal(satCard.predictionsView, false, "the old predictions view is still in the page");
-  assert.ok(satCard.live && satCard.history, "the decoder card lost Live/History");
-
-  assert.deepEqual(runtimeErrors, [], "the page threw while showing predictions");
-  console.log("satellite predictions page tests passed");
-} finally {
-  await browser.close();
-  await fixture.close();
-}

src/trx-client/trx-frontend/trx-frontend-http/frontend/tests/tune-links.mjs

@@ -27,21 +27,6 @@ const dial = () => page.evaluate(() => ({
   path: window.location.pathname,
 }));
 
-// Typed, not filled. The app holds back its own refreshes of the frequency
-// field from the first keystroke until Enter, so that a state update arriving
-// mid-edit does not rewrite what is being typed. `fill()` sets the value
-// without a keystroke, leaving the field unguarded: on a slow machine a state
-// update could land between the fill and the Enter and put the old frequency
-// back, and the Enter would then re-apply the frequency the radio was already
-// on. Selecting first arms the guard before a single character changes.
-async function tuneByHand(text) {
-  const field = page.locator("#freq");
-  await field.click();
-  await field.press("ControlOrMeta+a");
-  await field.pressSequentially(text);
-  await field.press("Enter");
-}
-
 try {
   await page.setViewportSize({ width: 1500, height: 950 });
 
@@ -64,7 +49,8 @@ try {
 
   // Tuning by hand rewrites the link. This is the part that makes the address
   // bar shareable at any moment rather than only at load.
-  await tuneByHand("7.040M");
+  await page.locator("#freq").fill("7.040M");
+  await page.locator("#freq").press("Enter");
   await page.waitForTimeout(1500);
   const tuned = await dial();
   assert.equal(tuned.freqHz, TUNED_HZ, `tuning landed on ${tuned.freqHz} Hz`);
@@ -73,7 +59,8 @@ try {
 
   // Tuning is not navigation: a swept dial must not bury the back button.
   const historyLength = await page.evaluate(() => window.history.length);
-  await tuneByHand("7.100M");
+  await page.locator("#freq").fill("7.100M");
+  await page.locator("#freq").press("Enter");
   await page.waitForTimeout(1200);
   assert.equal(await page.evaluate(() => window.history.length), historyLength,
     "tuning pushed a history entry instead of replacing one");

src/trx-client/trx-frontend/trx-frontend-http/frontend/tests/web-fixture.mjs

@@ -135,7 +135,6 @@ export async function startWebFixture({
   bandplan = {},
   bandplanEnabled = false,
   bandplanUnauthorizedFirst = false,
-  satPasses = null,
 } = {}) {
   const rigItems = ["rig-a", "rig-b"].map((remote) => ({
     remote,
@@ -231,7 +230,6 @@ export async function startWebFixture({
     ["/bandplan.json", bandplan],
     ["/api/recorder/status", []],
     ["/api/recorder/files", []],
-    ["/sat_passes", satPasses ?? { satellite_count: 0, passes: [] }],
   ]);
 
   // Flat i8 bins: the shape does not matter, only that frames arrive so the

src/trx-client/trx-frontend/trx-frontend-http/src/api/assets.rs

@@ -101,12 +101,6 @@ pub(crate) async fn statistics_index(req: HttpRequest) -> impl Responder {
     static_asset_response(&req, "text/html; charset=utf-8", c)
 }
 
-#[get("/satellites")]
-pub(crate) async fn satellites_index(req: HttpRequest) -> impl Responder {
-    let c = gz_index_html();
-    static_asset_response(&req, "text/html; charset=utf-8", c)
-}
-
 #[get("/bookmarks")]
 pub(crate) async fn bookmarks_index(req: HttpRequest) -> impl Responder {
     let c = gz_index_html();

src/trx-client/trx-frontend/trx-frontend-http/src/api/mod.rs

@@ -639,7 +639,6 @@ pub fn configure(cfg: &mut web::ServiceConfig) {
         .service(assets::recorder_index)
         .service(assets::settings_index)
         .service(assets::about_index)
-        .service(assets::satellites_index)
         .service(assets::statistics_index)
         .service(assets::bookmarks_index)
         .service(assets::favicon)