[feat](trx-rs): remap decoder modes — remove DIG/PKT from SDR, wire decoders to standard modes

For SDR backends, DIG and PKT are removed from supported_modes and
replaced by USB and FM respectively. CAT backends (FT-817, FT-450D)
retain DIG/PKT as before.

Decoder mode allowances updated:
- APRS: FM | PKT (was PKT only)
- HF-APRS: USB | DIG (was DIG only)
- AIS: AIS | FM | PKT (was AIS only)
- VDES: VDES | FM (was VDES only)
- FT8/FT4/FT2/WSPR: USB | DIG (unchanged)
- CW: CW | CWR (unchanged)
- LRPT: FM (unchanged, mode-independent)

Frontend status text, bookmark decoder toggles, background-decode
fallbacks, and scheduler wiring updated to match.

https://claude.ai/code/session_01DCAaMH8RF5FNB2gRtVu4pY
Signed-off-by: Claude <noreply@anthropic.com>
This commit is contained in:
Claude
2026-03-30 16:32:23 +00:00
committed by Stan Grams
parent f944cc0790
commit 5c43bac42b
11 changed files with 41 additions and 41 deletions
@@ -3241,22 +3241,22 @@ function render(update) {
const wsprStatus = document.getElementById("wspr-status"); const wsprStatus = document.getElementById("wspr-status");
setModeBoundDecodeStatus( setModeBoundDecodeStatus(
aisStatus, aisStatus,
["AIS"], ["AIS", "FM", "PKT"],
"Select AIS mode to decode", "Select AIS or FM mode to decode",
"Connected, listening for packets", "Connected, listening for packets",
); );
if (window.updateAisBar) window.updateAisBar(); if (window.updateAisBar) window.updateAisBar();
setModeBoundDecodeStatus( setModeBoundDecodeStatus(
vdesStatus, vdesStatus,
["VDES"], ["VDES", "FM"],
"Select VDES mode to decode", "Select VDES or FM mode to decode",
"Connected, listening for bursts", "Connected, listening for bursts",
); );
if (window.updateVdesBar) window.updateVdesBar(); if (window.updateVdesBar) window.updateVdesBar();
setModeBoundDecodeStatus( setModeBoundDecodeStatus(
aprsStatus, aprsStatus,
["PKT"], ["PKT", "FM"],
"Select PKT mode to decode", "Select FM mode to decode",
"Connected, listening for packets", "Connected, listening for packets",
); );
if (window.updateAprsBar) window.updateAprsBar(); if (window.updateAprsBar) window.updateAprsBar();
@@ -8903,10 +8903,10 @@ function updateDecodeStatus(text) {
const ft8 = document.getElementById("ft8-status"); const ft8 = document.getElementById("ft8-status");
const ft4 = document.getElementById("ft4-status"); const ft4 = document.getElementById("ft4-status");
const ft2 = document.getElementById("ft2-status"); const ft2 = document.getElementById("ft2-status");
setModeBoundDecodeStatus(ais, ["AIS"], "Select AIS mode to decode", text); setModeBoundDecodeStatus(ais, ["AIS", "FM", "PKT"], "Select AIS or FM mode to decode", text);
const vdesText = text === "Connected, listening for packets" ? "Connected, listening for bursts" : text; const vdesText = text === "Connected, listening for packets" ? "Connected, listening for bursts" : text;
setModeBoundDecodeStatus(vdes, ["VDES"], "Select VDES mode to decode", vdesText); setModeBoundDecodeStatus(vdes, ["VDES", "FM"], "Select VDES or FM mode to decode", vdesText);
setModeBoundDecodeStatus(aprs, ["PKT"], "Select PKT mode to decode", text); setModeBoundDecodeStatus(aprs, ["PKT", "FM"], "Select FM mode to decode", text);
const cwText = text === "Connected, listening for packets" ? "Connected, listening for CW" : text; const cwText = text === "Connected, listening for packets" ? "Connected, listening for CW" : text;
setModeBoundDecodeStatus(cw, ["CW", "CWR"], "Select CW mode to decode", cwText); setModeBoundDecodeStatus(cw, ["CW", "CWR"], "Select CW mode to decode", cwText);
if (ft8 && ft8.textContent !== "Receiving") ft8.textContent = text; if (ft8 && ft8.textContent !== "Receiving") ft8.textContent = text;
@@ -449,14 +449,13 @@
<input type="number" id="bm-freq" class="status-input" required min="0" placeholder="e.g. 7074000" /> <input type="number" id="bm-freq" class="status-input" required min="0" placeholder="e.g. 7074000" />
</label> </label>
<label class="bm-label">Mode <label class="bm-label">Mode
<input type="text" id="bm-mode" class="status-input" list="bm-mode-list" required placeholder="e.g. DIG" /> <input type="text" id="bm-mode" class="status-input" list="bm-mode-list" required placeholder="e.g. USB" />
<datalist id="bm-mode-list"> <datalist id="bm-mode-list">
<option value="LSB"> <option value="LSB">
<option value="USB"> <option value="USB">
<option value="AM"> <option value="AM">
<option value="SAM"> <option value="SAM">
<option value="FM"> <option value="FM">
<option value="DIG">
<option value="CW"> <option value="CW">
<option value="WFM"> <option value="WFM">
</datalist> </datalist>
@@ -561,25 +560,25 @@
<div class="plugin-item"> <div class="plugin-item">
<strong>FT8 Decoder</strong> <strong>FT8 Decoder</strong>
<div style="color:var(--text-muted); font-size:0.85rem; margin-top:0.2rem;"> <div style="color:var(--text-muted); font-size:0.85rem; margin-top:0.2rem;">
Decodes FT8 messages from RX audio (DIG/USB only, toggle required). Decodes FT8 messages from RX audio (USB only, toggle required).
</div> </div>
</div> </div>
<div class="plugin-item"> <div class="plugin-item">
<strong>FT4 Decoder</strong> <strong>FT4 Decoder</strong>
<div style="color:var(--text-muted); font-size:0.85rem; margin-top:0.2rem;"> <div style="color:var(--text-muted); font-size:0.85rem; margin-top:0.2rem;">
Decodes FT4 messages from RX audio (DIG/USB only, toggle required). 7.5-second slots. Decodes FT4 messages from RX audio (USB only, toggle required). 7.5-second slots.
</div> </div>
</div> </div>
<div class="plugin-item"> <div class="plugin-item">
<strong>FT2 Decoder</strong> <strong>FT2 Decoder</strong>
<div style="color:var(--text-muted); font-size:0.85rem; margin-top:0.2rem;"> <div style="color:var(--text-muted); font-size:0.85rem; margin-top:0.2rem;">
Decodes FT2 messages from RX audio (DIG/USB only, toggle required). 3.75-second slots. Decodes FT2 messages from RX audio (USB only, toggle required). 3.75-second slots.
</div> </div>
</div> </div>
<div class="plugin-item"> <div class="plugin-item">
<strong>WSPR Decoder</strong> <strong>WSPR Decoder</strong>
<div style="color:var(--text-muted); font-size:0.85rem; margin-top:0.2rem;"> <div style="color:var(--text-muted); font-size:0.85rem; margin-top:0.2rem;">
Decodes WSPR messages from RX audio (DIG/USB only, toggle required). Decodes WSPR messages from RX audio (USB only, toggle required).
</div> </div>
</div> </div>
<div class="plugin-item"> <div class="plugin-item">
@@ -322,7 +322,8 @@ function renderAprsHistory() {
function updateAprsBar() { function updateAprsBar() {
if (!aprsBarOverlay) return; if (!aprsBarOverlay) return;
const isPkt = (document.getElementById("mode")?.value || "").toUpperCase() === "PKT"; const modeVal = (document.getElementById("mode")?.value || "").toUpperCase();
const isPkt = modeVal === "PKT" || modeVal === "FM";
const cutoffMs = Date.now() - APRS_BAR_WINDOW_MS; const cutoffMs = Date.now() - APRS_BAR_WINDOW_MS;
const okFrames = aprsPacketHistory.filter((p) => p.crcOk && p._tsMs >= cutoffMs); const okFrames = aprsPacketHistory.filter((p) => p.crcOk && p._tsMs >= cutoffMs);
const frames = collapseAprsDuplicates(okFrames).slice(0, 8); const frames = collapseAprsDuplicates(okFrames).slice(0, 8);
@@ -102,7 +102,7 @@
if (supported.length > 0) return supported; if (supported.length > 0) return supported;
const mode = String(bookmark && bookmark.mode || "").trim().toUpperCase(); const mode = String(bookmark && bookmark.mode || "").trim().toUpperCase();
if (mode === "AIS") return ["ais"]; if (mode === "AIS") return ["ais"];
if (mode === "PKT") return ["aprs"]; if (mode === "PKT" || mode === "FM") return ["aprs"];
return supported; return supported;
} }
@@ -428,9 +428,9 @@ async function bmApply(bm) {
await postPath("/set_freq?hz=" + bm.freq_hz); await postPath("/set_freq?hz=" + bm.freq_hz);
} }
})(); })();
// Decoder toggles (DIG / FM modes) — also fire-and-forget. // Decoder toggles (USB / DIG / FM / PKT modes) — also fire-and-forget.
const hasDecoders = Array.isArray(bm.decoders) && bm.decoders.length > 0; const hasDecoders = Array.isArray(bm.decoders) && bm.decoders.length > 0;
const decoderMode = bm.mode === "DIG" || bm.mode === "FM"; const decoderMode = bm.mode === "USB" || bm.mode === "DIG" || bm.mode === "FM" || bm.mode === "PKT";
const decoderPromise = (hasDecoders && decoderMode) ? (async () => { const decoderPromise = (hasDecoders && decoderMode) ? (async () => {
const statusResp = await fetch("/status"); const statusResp = await fetch("/status");
if (statusResp.ok) { if (statusResp.ok) {
@@ -630,7 +630,7 @@ fn bookmark_supported_decoder_kinds(bookmark: &Bookmark) -> Vec<String> {
match bookmark.mode.trim().to_ascii_uppercase().as_str() { match bookmark.mode.trim().to_ascii_uppercase().as_str() {
"AIS" => vec!["ais".to_string()], "AIS" => vec!["ais".to_string()],
"PKT" => vec!["aprs".to_string()], "PKT" | "FM" => vec!["aprs".to_string()],
_ => Vec::new(), _ => Vec::new(),
} }
} }
@@ -966,7 +966,8 @@ async fn apply_scheduler_decoders(
bookmark: &crate::server::bookmarks::Bookmark, bookmark: &crate::server::bookmarks::Bookmark,
extra_bookmarks: &[crate::server::bookmarks::Bookmark], extra_bookmarks: &[crate::server::bookmarks::Bookmark],
) { ) {
let mut want_aprs = bookmark.mode.trim().eq_ignore_ascii_case("PKT"); let mut want_aprs = bookmark.mode.trim().eq_ignore_ascii_case("PKT")
|| bookmark.mode.trim().eq_ignore_ascii_case("FM");
let mut want_hf_aprs = false; let mut want_hf_aprs = false;
let mut want_ft8 = false; let mut want_ft8 = false;
let mut want_ft4 = false; let mut want_ft4 = false;
@@ -723,7 +723,7 @@ mod tests {
mgr.init_rig(rig_id, 14_074_000, "USB"); mgr.init_rig(rig_id, 14_074_000, "USB");
let channel = mgr let channel = mgr
.allocate(session_id, rig_id, 14_075_000, "DIG") .allocate(session_id, rig_id, 14_075_000, "USB")
.expect("allocate vchan"); .expect("allocate vchan");
assert_eq!(mgr.channels(rig_id).len(), 2); assert_eq!(mgr.channels(rig_id).len(), 2);
@@ -747,7 +747,7 @@ mod tests {
&[( &[(
"bm-ft8".to_string(), "bm-ft8".to_string(),
14_074_000, 14_074_000,
"DIG".to_string(), "USB".to_string(),
3_000, 3_000,
vec!["ft8".to_string()], vec!["ft8".to_string()],
)], )],
@@ -756,7 +756,7 @@ mod tests {
let channels = mgr.channels(rig_id); let channels = mgr.channels(rig_id);
assert_eq!(channels.len(), 2); assert_eq!(channels.len(), 2);
assert_eq!(channels[1].freq_hz, 14_074_000); assert_eq!(channels[1].freq_hz, 14_074_000);
assert_eq!(channels[1].mode, "DIG"); assert_eq!(channels[1].mode, "USB");
assert_eq!(channels[1].bandwidth_hz, 3_000); assert_eq!(channels[1].bandwidth_hz, 3_000);
assert_eq!(channels[1].subscribers, 0); assert_eq!(channels[1].subscribers, 0);
assert!(channels[1].permanent); assert!(channels[1].permanent);
@@ -770,14 +770,14 @@ mod tests {
mgr.init_rig(rig_id, 14_074_000, "USB"); mgr.init_rig(rig_id, 14_074_000, "USB");
let _channel = mgr let _channel = mgr
.allocate(session_id, rig_id, 14_075_000, "DIG") .allocate(session_id, rig_id, 14_075_000, "USB")
.expect("allocate vchan"); .expect("allocate vchan");
mgr.sync_scheduler_channels( mgr.sync_scheduler_channels(
rig_id, rig_id,
&[( &[(
"bm-ft8".to_string(), "bm-ft8".to_string(),
14_074_000, 14_074_000,
"DIG".to_string(), "USB".to_string(),
3_000, 3_000,
vec!["ft8".to_string()], vec!["ft8".to_string()],
)], )],
@@ -787,7 +787,7 @@ mod tests {
let channels = mgr.channels(rig_id); let channels = mgr.channels(rig_id);
assert_eq!(channels.len(), 2); assert_eq!(channels.len(), 2);
assert_eq!(channels[1].mode, "DIG"); assert_eq!(channels[1].mode, "USB");
assert_eq!(channels[1].subscribers, 0); assert_eq!(channels[1].subscribers, 0);
} }
@@ -803,7 +803,7 @@ mod tests {
&[( &[(
"bm-aprs".to_string(), "bm-aprs".to_string(),
144_800_000, 144_800_000,
"PKT".to_string(), "FM".to_string(),
12_500, 12_500,
vec!["aprs".to_string()], vec!["aprs".to_string()],
)], )],
+9 -9
View File
@@ -1183,7 +1183,7 @@ fn run_playback(
} }
} }
/// Run the APRS decoder task. Only processes PCM when rig mode is PKT. /// Run the APRS decoder task. Only processes PCM when rig mode is FM or PKT.
pub async fn run_aprs_decoder( pub async fn run_aprs_decoder(
sample_rate: u32, sample_rate: u32,
channels: u16, channels: u16,
@@ -1257,9 +1257,9 @@ async fn run_aprs_decoder_inner(
let mode_match = |state: &RigState| -> bool { let mode_match = |state: &RigState| -> bool {
if is_hf { if is_hf {
matches!(state.status.mode, RigMode::DIG) matches!(state.status.mode, RigMode::USB | RigMode::DIG)
} else { } else {
matches!(state.status.mode, RigMode::PKT) matches!(state.status.mode, RigMode::FM | RigMode::PKT)
} }
}; };
let get_reset_seq = |state: &RigState| -> u64 { let get_reset_seq = |state: &RigState| -> u64 {
@@ -1405,14 +1405,14 @@ pub async fn run_ais_decoder(
let mut decoder_a = AisDecoder::new(sample_rate); let mut decoder_a = AisDecoder::new(sample_rate);
let mut decoder_b = AisDecoder::new(sample_rate); let mut decoder_b = AisDecoder::new(sample_rate);
let mut was_active = false; let mut was_active = false;
let mut active = matches!(state_rx.borrow().status.mode, RigMode::AIS); let mut active = matches!(state_rx.borrow().status.mode, RigMode::AIS | RigMode::FM | RigMode::PKT);
loop { loop {
if !active { if !active {
match state_rx.changed().await { match state_rx.changed().await {
Ok(()) => { Ok(()) => {
let state = state_rx.borrow(); let state = state_rx.borrow();
active = matches!(state.status.mode, RigMode::AIS); active = matches!(state.status.mode, RigMode::AIS | RigMode::FM | RigMode::PKT);
if active { if active {
pcm_a_rx = pcm_a_rx.resubscribe(); pcm_a_rx = pcm_a_rx.resubscribe();
pcm_b_rx = pcm_b_rx.resubscribe(); pcm_b_rx = pcm_b_rx.resubscribe();
@@ -1476,7 +1476,7 @@ pub async fn run_ais_decoder(
match changed { match changed {
Ok(()) => { Ok(()) => {
let state = state_rx.borrow(); let state = state_rx.borrow();
active = matches!(state.status.mode, RigMode::AIS); active = matches!(state.status.mode, RigMode::AIS | RigMode::FM | RigMode::PKT);
if !active && was_active { if !active && was_active {
decoder_a.reset(); decoder_a.reset();
decoder_b.reset(); decoder_b.reset();
@@ -1505,14 +1505,14 @@ pub async fn run_vdes_decoder(
info!("VDES decoder started ({}Hz complex baseband)", sample_rate); info!("VDES decoder started ({}Hz complex baseband)", sample_rate);
let mut decoder = VdesDecoder::new(sample_rate); let mut decoder = VdesDecoder::new(sample_rate);
let mut was_active = false; let mut was_active = false;
let mut active = matches!(state_rx.borrow().status.mode, RigMode::VDES); let mut active = matches!(state_rx.borrow().status.mode, RigMode::VDES | RigMode::FM);
loop { loop {
if !active { if !active {
match state_rx.changed().await { match state_rx.changed().await {
Ok(()) => { Ok(()) => {
let state = state_rx.borrow(); let state = state_rx.borrow();
active = matches!(state.status.mode, RigMode::VDES); active = matches!(state.status.mode, RigMode::VDES | RigMode::FM);
if active { if active {
iq_rx = iq_rx.resubscribe(); iq_rx = iq_rx.resubscribe();
} }
@@ -1550,7 +1550,7 @@ pub async fn run_vdes_decoder(
match changed { match changed {
Ok(()) => { Ok(()) => {
let state = state_rx.borrow(); let state = state_rx.borrow();
active = matches!(state.status.mode, RigMode::VDES); active = matches!(state.status.mode, RigMode::VDES | RigMode::FM);
if !active && was_active { if !active && was_active {
decoder.reset(); decoder.reset();
was_active = false; was_active = false;
@@ -158,7 +158,8 @@ impl SoapySdrRig {
fn default_bandwidth_for_mode(mode: &RigMode) -> u32 { fn default_bandwidth_for_mode(mode: &RigMode) -> u32 {
match mode { match mode {
RigMode::LSB | RigMode::USB | RigMode::DIG => 3_000, RigMode::LSB | RigMode::USB | RigMode::DIG => 3_000,
RigMode::PKT | RigMode::AIS => 25_000, RigMode::AIS => 25_000,
RigMode::PKT => 25_000,
RigMode::VDES => 100_000, RigMode::VDES => 100_000,
RigMode::CW | RigMode::CWR => 500, RigMode::CW | RigMode::CWR => 500,
RigMode::AM | RigMode::SAM => 9_000, RigMode::AM | RigMode::SAM => 9_000,
@@ -317,8 +318,6 @@ impl SoapySdrRig {
RigMode::FM, RigMode::FM,
RigMode::AIS, RigMode::AIS,
RigMode::VDES, RigMode::VDES,
RigMode::DIG,
RigMode::PKT,
], ],
num_vfos: 1, num_vfos: 1,
lock: false, lock: false,
@@ -504,7 +504,7 @@ mod tests {
mgr.add_channel(14_074_000, &RigMode::USB).unwrap(); mgr.add_channel(14_074_000, &RigMode::USB).unwrap();
let hidden_id = Uuid::new_v4(); let hidden_id = Uuid::new_v4();
mgr.ensure_background_channel_pcm(hidden_id, 14_075_000, &RigMode::DIG) mgr.ensure_background_channel_pcm(hidden_id, 14_075_000, &RigMode::USB)
.unwrap(); .unwrap();
let visible = mgr.channels(); let visible = mgr.channels();