CI / lint (pull_request) Failing after 2s
CI / test (pull_request) Failing after 1s
CI / frontend (pull_request) Failing after 41s
CI / reuse (pull_request) Failing after 2s
CI / lint (push) Failing after 2s
CI / test (push) Failing after 2s
CI / frontend (push) Failing after 36s
CI / reuse (push) Failing after 1s
The bookmark fix addressed one instance of a defect the TypeScript migration left across the feature entries. app.js stopped being a classic script, so its top-level declarations are no longer shared globals, but the converted entries kept reading them as window properties that nothing publishes. Restore the broken behavior: - ais, aprs, hf-aprs read serverLat, serverLon and haversineKm as undefined, so every positioned packet rendered an empty distance. - ais, aprs, hf-aprs, cw, sat, vdes, wefax, wspr called an undefined postPath, so clear-history and decoder toggles threw. - scheduler read authRole as undefined, so the lazy-load path never self-initialized and the Settings tab opened an inert scheduler. - background-decode read authEnabled as undefined, so control gating fell back to role-only. - vchan read fifteen application values and services as undefined: mode and bandwidth sync, the out-of-band hint, RX audio restart, and the frequency field all silently no-opped on a virtual channel. - vchan wrapped window.refreshFreqDisplay, capturing an undefined original exactly as it did for setRigFrequency, so leaving a channel never restored the application's own frequency display. - _audioChannelOverride was a const that nothing could assign, so RX audio always subscribed to the primary channel. - ftx-family read fmtTime, a helper legacy ft8.js owned locally, so decode bar timestamps rendered empty. Declare the contract once in plugins/host.ts and import it from the feature entries, rather than restoring globals that docs/frontend-architecture.md excludes. trx.state gains jogUnit, rxActive and audioChannelOverride, and makes lastModeName writable; trx.core gains the tuning, RDS, WFM, jog and RX audio services the entries need. vchan interception moves to an interceptFreqDisplay service method that refreshFreqDisplay calls, matching the frequency, mode and bandwidth interception it already registers. Reading registry-built elements through a strict lookup is the same defect as in bookmarks: renderTimelineNeedle guards its result, but schedulerEl throws, so the now-initializing scheduler crashed on the timeline needle group that its own SVG creates. Feature tests move onto a shared host fixture, and entries that now import a common module are bundled through bundleEntry like the other shared-module entries. Covers scheduler self-initialization and the distance path that the bare window reads broke. Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01GdyUjuXejCEfiub675z6cz Signed-off-by: Stan Grams <sjg@haxx.space>
272 lines
9.5 KiB
JavaScript
272 lines
9.5 KiB
JavaScript
import {
|
|
hostCore
|
|
} from "./chunk-KL66PICH.js";
|
|
|
|
// src/plugins/wspr.ts
|
|
var wsprWindow = window;
|
|
var wsprStatus = document.getElementById("wspr-status");
|
|
var wsprPeriodEl = document.getElementById("wspr-period");
|
|
var wsprMessagesEl = document.getElementById("wspr-messages");
|
|
var wsprFilterInput = document.getElementById("wspr-filter");
|
|
var WSPR_PERIOD_SECONDS = 120;
|
|
var wsprFilterText = "";
|
|
var wsprMessageHistory = [];
|
|
function finiteNumber(value) {
|
|
const number = typeof value === "number" ? value : Number(value);
|
|
return Number.isFinite(number) ? number : null;
|
|
}
|
|
function currentWsprHistoryRetentionMs() {
|
|
return typeof wsprWindow.getDecodeHistoryRetentionMs === "function" ? wsprWindow.getDecodeHistoryRetentionMs() : 24 * 60 * 60 * 1e3;
|
|
}
|
|
function pruneWsprMessageHistory() {
|
|
const cutoffMs = Date.now() - currentWsprHistoryRetentionMs();
|
|
wsprMessageHistory = wsprMessageHistory.filter((msg) => Number(msg._tsMs ?? msg.ts_ms) >= cutoffMs);
|
|
}
|
|
function scheduleWsprHistoryRender() {
|
|
if (typeof wsprWindow.trxScheduleUiFrameJob === "function") {
|
|
wsprWindow.trxScheduleUiFrameJob("wspr-history", () => {
|
|
renderWsprHistory();
|
|
});
|
|
return;
|
|
}
|
|
renderWsprHistory();
|
|
}
|
|
function fmtWsprTime(tsMs) {
|
|
if (!tsMs) return "--:--:--";
|
|
return new Date(tsMs).toLocaleTimeString([], { hour: "2-digit", minute: "2-digit", second: "2-digit" });
|
|
}
|
|
function updateWsprPeriodTimer() {
|
|
if (!wsprPeriodEl) return;
|
|
const nowSec = Math.floor(Date.now() / 1e3);
|
|
const remaining = WSPR_PERIOD_SECONDS - nowSec % WSPR_PERIOD_SECONDS;
|
|
const mm = String(Math.floor(remaining / 60)).padStart(2, "0");
|
|
const ss = String(remaining % 60).padStart(2, "0");
|
|
wsprPeriodEl.textContent = `Next slot ${mm}:${ss}`;
|
|
}
|
|
updateWsprPeriodTimer();
|
|
setInterval(updateWsprPeriodTimer, 500);
|
|
function renderWsprRow(msg) {
|
|
const row = document.createElement("div");
|
|
row.className = "ft8-row";
|
|
row.dataset.decoder = "wspr";
|
|
const snr = finiteNumber(msg.snr_db);
|
|
const delta = finiteNumber(msg.dt_s);
|
|
const baseHz = finiteNumber(wsprWindow.ft8BaseHz);
|
|
const offsetHz = finiteNumber(msg.freq_hz);
|
|
const rfHz = offsetHz !== null && baseHz !== null ? baseHz + offsetHz : null;
|
|
const freq = rfHz?.toFixed(0) ?? "--";
|
|
const message = msg.message ?? "";
|
|
row.dataset.message = message.toUpperCase();
|
|
row.innerHTML = `<span class="ft8-time">${fmtWsprTime(msg.ts_ms)}</span><span class="ft8-snr">${snr?.toFixed(1) ?? "--"}</span><span class="ft8-dt">${delta?.toFixed(2) ?? "--"}</span><span class="ft8-freq">${freq}</span><span class="ft8-msg">${renderWsprMessage(message)}</span>`;
|
|
applyWsprFilterToRow(row);
|
|
return row;
|
|
}
|
|
function renderWsprHistory() {
|
|
pruneWsprMessageHistory();
|
|
if (!wsprMessagesEl) return;
|
|
const fragment = document.createDocumentFragment();
|
|
for (let i = 0; i < wsprMessageHistory.length; i += 1) {
|
|
const message = wsprMessageHistory[i];
|
|
if (message) fragment.appendChild(renderWsprRow(message));
|
|
}
|
|
wsprMessagesEl.replaceChildren(fragment);
|
|
}
|
|
function addWsprMessage(msg) {
|
|
msg._tsMs = Number.isFinite(msg.ts_ms) ? Number(msg.ts_ms) : Date.now();
|
|
wsprMessageHistory.unshift(msg);
|
|
pruneWsprMessageHistory();
|
|
scheduleWsprHistoryRender();
|
|
}
|
|
function normalizeServerWsprMessage(msg) {
|
|
const raw = msg.message ?? "";
|
|
const grids = extractAllGrids(raw);
|
|
const station = extractLikelyCallsign(raw);
|
|
const baseHz = finiteNumber(wsprWindow.ft8BaseHz);
|
|
const offsetHz = finiteNumber(msg.freq_hz);
|
|
const rfHz = offsetHz !== null && baseHz !== null ? baseHz + offsetHz : offsetHz;
|
|
return {
|
|
raw,
|
|
grids,
|
|
station,
|
|
rfHz,
|
|
history: {
|
|
receiver: wsprWindow.getDecodeRigMeta ? wsprWindow.getDecodeRigMeta() : null,
|
|
ts_ms: msg.ts_ms,
|
|
snr_db: msg.snr_db,
|
|
dt_s: msg.dt_s,
|
|
freq_hz: msg.freq_hz,
|
|
message: raw
|
|
}
|
|
};
|
|
}
|
|
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 (next.grids.length > 0 && wsprWindow.mapAddLocator) {
|
|
wsprWindow.mapAddLocator(next.raw, next.grids, "wspr", next.station, {
|
|
...msg,
|
|
...next.rfHz === null ? {} : { freq_hz: next.rfHz }
|
|
});
|
|
}
|
|
next.history._tsMs = Number.isFinite(next.history.ts_ms) ? Number(next.history.ts_ms) : Date.now();
|
|
normalized.push(next.history);
|
|
}
|
|
normalized.reverse();
|
|
wsprMessageHistory = normalized.concat(wsprMessageHistory);
|
|
pruneWsprMessageHistory();
|
|
scheduleWsprHistoryRender();
|
|
}
|
|
function pruneWsprHistoryView() {
|
|
pruneWsprMessageHistory();
|
|
renderWsprHistory();
|
|
}
|
|
function escapeWsprHtml(input) {
|
|
return input.replaceAll("&", "&").replaceAll("<", "<").replaceAll(">", ">").replaceAll('"', """);
|
|
}
|
|
function renderWsprMessage(message) {
|
|
let out = "";
|
|
let i = 0;
|
|
while (i < message.length) {
|
|
const ch = message[i];
|
|
if (isAlphaNum(ch)) {
|
|
let j = i + 1;
|
|
while (j < message.length && isAlphaNum(message[j])) j++;
|
|
const token = message.slice(i, j);
|
|
const grid = token.toUpperCase();
|
|
if (isMaidenheadGridToken(grid)) {
|
|
out += `<span class="ft8-locator" data-locator-grid="${grid}" role="button" tabindex="0" aria-label="Show locator ${grid} on map">${grid}</span>`;
|
|
} else {
|
|
out += escapeWsprHtml(token);
|
|
}
|
|
i = j;
|
|
} else {
|
|
out += escapeWsprHtml(ch ?? "");
|
|
i += 1;
|
|
}
|
|
}
|
|
return out;
|
|
}
|
|
function extractAllGrids(message) {
|
|
const out = [];
|
|
const seen = /* @__PURE__ */ new Set();
|
|
const parts = message.toUpperCase().split(/[^A-Z0-9]+/);
|
|
for (const token of parts) {
|
|
if (!token) continue;
|
|
if (isMaidenheadGridToken(token) && !seen.has(token)) {
|
|
seen.add(token);
|
|
out.push(token);
|
|
}
|
|
}
|
|
return out;
|
|
}
|
|
function extractLikelyCallsign(message) {
|
|
const parts = message.toUpperCase().split(/[^A-Z0-9/]+/);
|
|
for (const token of parts) {
|
|
if (!token) continue;
|
|
if (token.length < 3 || token.length > 12) continue;
|
|
if (token === "CQ" || token === "DE" || token === "QRZ" || token === "DX") continue;
|
|
if (isMaidenheadGridToken(token)) continue;
|
|
if (/^[A-Z0-9/]{1,5}\d[A-Z0-9/]{1,6}$/.test(token)) return token;
|
|
}
|
|
return null;
|
|
}
|
|
function isFtxFarewellToken(token) {
|
|
const normalized = token.trim().toUpperCase();
|
|
return normalized === "RR73" || normalized === "73" || normalized === "RR";
|
|
}
|
|
function isMaidenheadGridToken(token) {
|
|
const normalized = token.trim().toUpperCase();
|
|
return /^[A-R]{2}\d{2}(?:[A-X]{2})?$/.test(normalized) && !isFtxFarewellToken(normalized);
|
|
}
|
|
function isAlphaNum(ch) {
|
|
return ch !== void 0 && /[A-Za-z0-9]/.test(ch);
|
|
}
|
|
function activateWsprHistoryLocator(target) {
|
|
if (!(target instanceof Element)) return false;
|
|
const locatorEl = target.closest(".ft8-locator[data-locator-grid]");
|
|
if (!locatorEl) return false;
|
|
const grid = (locatorEl.dataset.locatorGrid || "").toUpperCase();
|
|
if (!grid) return false;
|
|
if (typeof wsprWindow.navigateToMapLocator === "function") {
|
|
wsprWindow.navigateToMapLocator(grid, "wspr");
|
|
}
|
|
return true;
|
|
}
|
|
function applyWsprFilterToRow(row) {
|
|
if (!wsprFilterText) {
|
|
row.style.display = "";
|
|
return;
|
|
}
|
|
const message = row.dataset.message || "";
|
|
row.style.display = message.includes(wsprFilterText) ? "" : "none";
|
|
}
|
|
function resetWsprHistoryView() {
|
|
if (wsprMessagesEl) wsprMessagesEl.innerHTML = "";
|
|
wsprMessageHistory = [];
|
|
renderWsprHistory();
|
|
if (wsprWindow.clearMapMarkersByType) wsprWindow.clearMapMarkersByType("wspr");
|
|
}
|
|
if (wsprFilterInput) {
|
|
wsprFilterInput.addEventListener("input", () => {
|
|
wsprFilterText = wsprFilterInput.value.trim().toUpperCase();
|
|
renderWsprHistory();
|
|
});
|
|
}
|
|
if (wsprMessagesEl) {
|
|
wsprMessagesEl.addEventListener("click", (event) => {
|
|
if (!activateWsprHistoryLocator(event.target)) return;
|
|
event.preventDefault();
|
|
event.stopPropagation();
|
|
});
|
|
wsprMessagesEl.addEventListener("keydown", (event) => {
|
|
if (event.key !== "Enter" && event.key !== " ") return;
|
|
if (!activateWsprHistoryLocator(event.target)) return;
|
|
event.preventDefault();
|
|
event.stopPropagation();
|
|
});
|
|
}
|
|
var wsprDecodeToggleBtn = document.getElementById("wspr-decode-toggle-btn");
|
|
wsprDecodeToggleBtn?.addEventListener("click", () => {
|
|
void (async () => {
|
|
try {
|
|
await wsprWindow.takeSchedulerControlForDecoderDisable?.(wsprDecodeToggleBtn);
|
|
await hostCore.postPath("/toggle_wspr_decode");
|
|
} catch (error) {
|
|
console.error("WSPR toggle failed", error);
|
|
}
|
|
})();
|
|
});
|
|
document.getElementById("settings-clear-wspr-history")?.addEventListener("click", () => {
|
|
void (async () => {
|
|
if (!await wsprWindow.trxUi.confirm({ title: "Clear WSPR history?", message: "All stored WSPR decodes will be permanently removed.", confirmLabel: "Clear history" })) return;
|
|
try {
|
|
await hostCore.postPath("/clear_wspr_decode");
|
|
resetWsprHistoryView();
|
|
} catch (error) {
|
|
console.error("WSPR history clear failed", error);
|
|
}
|
|
})();
|
|
});
|
|
function onServerWspr(msg) {
|
|
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, {
|
|
...msg,
|
|
...next.rfHz === null ? {} : { freq_hz: next.rfHz }
|
|
});
|
|
}
|
|
addWsprMessage(next.history);
|
|
}
|
|
wsprWindow.trxPluginRuntime.registerDecoder({
|
|
id: "wspr",
|
|
onMessage: onServerWspr,
|
|
onBatch: onServerWsprBatch,
|
|
restore: onServerWsprBatch,
|
|
prune: pruneWsprHistoryView,
|
|
reset: resetWsprHistoryView
|
|
});
|