chore: release v0.20.0

Automatically switches the Station Control relay boards from the rig's
current frequency / band. Each relay carries one rule: off (manual), a
frequency window (ON inside [lo,hi] kHz, OFF outside), or a set of bands
(ON on those bands, OFF elsewhere). Evaluated on every CAT frequency/band
change; a relay is only switched when its desired state actually changed,
so tuning within a range doesn't hammer the board.

A cached atomic flag keeps the CAT hot path a no-op when the feature is off
(important during FT8 slice churn). Saving re-applies from the live
frequency so a changed rule takes effect immediately.

New Settings → Hardware → Relay auto-control section: master enable plus a
per-relay mode (Off / Frequency / Band) with kHz range inputs or band
chips, per configured relay board. i18n EN + FR. Azimuth/Time modes (the
other two PstRotator tabs) are left for later.

adifwatch.go

@@ -0,0 +1,251 @@
+package main
+
+// ADIF monitor: watches a configurable list of external ADIF files (fldigi's
+// RTTY logbook, N1MM, VarAC…) and imports newly appended QSOs into OpsLog as if
+// they had been logged here — same enrichment, dedup and automatic upload to
+// external services (QRZ, Club Log…). Deliberately simpler than Log4OM's monitor:
+// no per-file "upload" / "delete after load" toggles — importing + auto-upload is
+// just what happens.
+//
+// Design notes:
+//   - A newly added file starts at its CURRENT size (Offset = -1 sentinel → set to
+//     size on first scan) so the QSOs already in it are NOT bulk-imported; only
+//     contacts appended AFTER you add the file come in.
+//   - Reads only up to the last complete <eor>, so a half-written record waits for
+//     the next poll instead of importing a truncated QSO.
+//   - Each record is fed through LogUDPLoggedADIF, which already does the full
+//     enrichment + ±2-minute dedup (shared udpLogMu, so it can't race the UDP
+//     auto-log) + automatic external-service upload.
+
+import (
+	"bytes"
+	"encoding/json"
+	"fmt"
+	"io"
+	"os"
+	"strings"
+	"time"
+
+	wruntime "github.com/wailsapp/wails/v2/pkg/runtime"
+
+	"hamlog/internal/applog"
+)
+
+const keyADIFMonitor = "adifmon.config"
+
+// ADIFWatchFile is one monitored ADIF file.
+type ADIFWatchFile struct {
+	Path    string `json:"path"`
+	Enabled bool   `json:"enabled"`
+	// Offset is the number of bytes already consumed. -1 means "not yet
+	// initialised": the first scan sets it to the file's current size so existing
+	// history is skipped.
+	Offset int64 `json:"offset"`
+}
+
+// ADIFMonitorConfig is the whole monitor setup: a master switch + the file list.
+type ADIFMonitorConfig struct {
+	Enabled bool            `json:"enabled"`
+	Files   []ADIFWatchFile `json:"files"`
+}
+
+const eorTag = "<eor>"
+
+func (a *App) loadADIFMonitorLocked() ADIFMonitorConfig {
+	var cfg ADIFMonitorConfig
+	if a.settings == nil {
+		return cfg
+	}
+	s, _ := a.settings.GetGlobal(a.ctx, keyADIFMonitor)
+	if strings.TrimSpace(s) != "" {
+		_ = json.Unmarshal([]byte(s), &cfg)
+	}
+	return cfg
+}
+
+func (a *App) saveADIFMonitorLocked(cfg ADIFMonitorConfig) {
+	b, _ := json.Marshal(cfg)
+	a.setSettingGlobal(keyADIFMonitor, string(b))
+}
+
+// GetADIFMonitor returns the monitor configuration for the settings UI.
+func (a *App) GetADIFMonitor() ADIFMonitorConfig {
+	a.adifMonMu.Lock()
+	defer a.adifMonMu.Unlock()
+	return a.loadADIFMonitorLocked()
+}
+
+// SaveADIFMonitor persists the monitor configuration. A file the user just added
+// gets Offset = -1 so its existing content is skipped (only QSOs logged AFTER it
+// was added import); a file already present keeps its current read position.
+func (a *App) SaveADIFMonitor(cfg ADIFMonitorConfig) error {
+	a.adifMonMu.Lock()
+	defer a.adifMonMu.Unlock()
+	old := a.loadADIFMonitorLocked()
+	oldOff := make(map[string]int64, len(old.Files))
+	for _, f := range old.Files {
+		oldOff[strings.TrimSpace(f.Path)] = f.Offset
+	}
+	for i := range cfg.Files {
+		cfg.Files[i].Path = strings.TrimSpace(cfg.Files[i].Path)
+		if off, ok := oldOff[cfg.Files[i].Path]; ok {
+			cfg.Files[i].Offset = off // keep the read position of an existing file
+		} else {
+			cfg.Files[i].Offset = -1 // new file → skip its existing history
+		}
+	}
+	a.saveADIFMonitorLocked(cfg)
+	return nil
+}
+
+// PickADIFMonitorFile opens a file dialog to choose an ADIF file to monitor.
+func (a *App) PickADIFMonitorFile() (string, error) {
+	if a.ctx == nil {
+		return "", fmt.Errorf("no app context")
+	}
+	return wruntime.OpenFileDialog(a.ctx, wruntime.OpenDialogOptions{
+		Title: "Choose an ADIF file to monitor",
+		Filters: []wruntime.FileFilter{
+			{DisplayName: "ADIF (*.adi;*.adif)", Pattern: "*.adi;*.adif"},
+			{DisplayName: "All files (*.*)", Pattern: "*.*"},
+		},
+	})
+}
+
+// adifMonitorLoop polls the enabled ADIF files every few seconds and imports any
+// newly appended QSOs. Runs for the app's lifetime on its own goroutine.
+func (a *App) adifMonitorLoop() {
+	tick := time.NewTicker(5 * time.Second)
+	defer tick.Stop()
+	for range tick.C {
+		if a.ctx == nil || a.qso == nil {
+			continue
+		}
+		a.scanADIFMonitors()
+	}
+}
+
+// scanADIFMonitors walks the enabled files once, importing new records and
+// persisting advanced offsets.
+func (a *App) scanADIFMonitors() {
+	a.adifMonMu.Lock()
+	cfg := a.loadADIFMonitorLocked()
+	a.adifMonMu.Unlock()
+	if !cfg.Enabled || len(cfg.Files) == 0 {
+		return
+	}
+
+	// path → new offset, for the files we advanced this pass.
+	advanced := map[string]int64{}
+	for i := range cfg.Files {
+		f := &cfg.Files[i]
+		if !f.Enabled || strings.TrimSpace(f.Path) == "" {
+			continue
+		}
+		fi, err := os.Stat(f.Path)
+		if err != nil {
+			continue // not present (yet) — try again next tick
+		}
+		size := fi.Size()
+		if f.Offset < 0 {
+			// First sight of this file → skip whatever history it already holds.
+			advanced[f.Path] = size
+			continue
+		}
+		if size < f.Offset {
+			f.Offset = 0 // truncated / rotated → re-read from the start (dedup protects us)
+		}
+		if size == f.Offset {
+			continue // nothing new
+		}
+		newOff, n := a.importADIFAppend(f.Path, f.Offset, size)
+		if newOff != f.Offset {
+			advanced[f.Path] = newOff
+		}
+		if n > 0 {
+			applog.Printf("adif monitor: imported %d QSO(s) from %s", n, f.Path)
+			if a.ctx != nil {
+				wruntime.EventsEmit(a.ctx, "adifmon:imported", map[string]any{"file": f.Path, "count": n})
+			}
+		}
+	}
+
+	if len(advanced) == 0 {
+		return
+	}
+	// Persist the advanced offsets WITHOUT clobbering a concurrent UI save of the
+	// file list: re-read the stored config and only patch offsets for paths that
+	// still exist there.
+	a.adifMonMu.Lock()
+	cur := a.loadADIFMonitorLocked()
+	for i := range cur.Files {
+		if off, ok := advanced[strings.TrimSpace(cur.Files[i].Path)]; ok {
+			cur.Files[i].Offset = off
+		}
+	}
+	a.saveADIFMonitorLocked(cur)
+	a.adifMonMu.Unlock()
+}
+
+// importADIFAppend reads bytes [from,to) of an ADIF file, imports every COMPLETE
+// record found (up to the last <eor>) and returns the new offset (just past that
+// last <eor>) plus how many QSOs were actually imported (duplicates excluded).
+func (a *App) importADIFAppend(path string, from, to int64) (int64, int) {
+	fh, err := os.Open(path)
+	if err != nil {
+		return from, 0
+	}
+	defer fh.Close()
+	if _, err := fh.Seek(from, io.SeekStart); err != nil {
+		return from, 0
+	}
+	buf := make([]byte, to-from)
+	nRead, err := io.ReadFull(fh, buf)
+	if err != nil && err != io.ErrUnexpectedEOF && err != io.EOF {
+		return from, 0
+	}
+	buf = buf[:nRead]
+
+	// Only consume up to the last complete <eor>; a half-written trailing record
+	// waits for the next poll.
+	lower := bytes.ToLower(buf)
+	last := bytes.LastIndex(lower, []byte(eorTag))
+	if last < 0 {
+		return from, 0 // no complete record yet
+	}
+	end := last + len(eorTag)
+	chunk := buf[:end]
+
+	count := 0
+	for _, rec := range splitADIFRecords(chunk) {
+		if strings.TrimSpace(rec) == "" {
+			continue
+		}
+		if _, err := a.LogUDPLoggedADIF(rec); err == nil {
+			count++
+		}
+		// A duplicate (already in the log within ±2 min) returns an error and is
+		// simply not counted — expected when the same QSO is also logged in OpsLog.
+	}
+	return from + int64(end), count
+}
+
+// splitADIFRecords cuts an ADIF byte slice into individual record texts, each
+// ending at its <eor> (case-insensitive). Any leading file header (up to the
+// first record's <eor>) rides along with the first record — LogUDPLoggedADIF
+// parses past an <EOH> header fine, and prepends one when there is none.
+func splitADIFRecords(b []byte) []string {
+	lower := bytes.ToLower(b)
+	var out []string
+	start := 0
+	for {
+		rel := bytes.Index(lower[start:], []byte(eorTag))
+		if rel < 0 {
+			break
+		}
+		end := start + rel + len(eorTag)
+		out = append(out, string(b[start:end]))
+		start = end
+	}
+	return out
+}

app.go

@@ -435,8 +435,8 @@ type App struct {
 	// to run inline in the read loop, so a single slow step stopped draining the
 	// TCP socket and the whole feed fell behind the node (visible as the grid
 	// lagging telnet). The read loop now just enqueues here; one worker does the work.
-	clusterEventCh chan clusterEvent
+	// Unbounded FIFO: a burst grows the backlog instead of dropping spots.
-	clusterDropped int64 // spots/lines dropped when the queue was full (atomic)
+	clusterEvents *clusterQueue
 	// wcbm is an in-memory "CALL|BAND|MODE" worked-index so the alert engine never
 	// queries the DB per cluster spot (an FT8 firehose would swamp a remote MySQL).
 	// Loaded once, appended to on each log, rebuilt after bulk changes.
@@ -483,6 +483,10 @@ type App struct {
 	dvkPttKeyed    bool              // we keyed PTT for a voice message; unkey when it ends
 	pttMu          sync.Mutex
 	udpLogMu       sync.Mutex      // serialises UDP auto-log so concurrent packets can't both pass the dedup check
+	adifMonMu      sync.Mutex      // guards the ADIF-monitor config (file list + per-file read offsets)
+	relayAutoMu    sync.Mutex        // serialises relay auto-control evaluation
+	relayAutoLast  map[string]bool   // deviceID|relay → last applied on/off, so we only switch on a real change
+	relayAutoOn    atomic.Bool       // cached "auto-control enabled" so the CAT hot path skips work when off
 	pttPort        serial.Port     // open serial port while PTT (RTS/DTR) is asserted
 	pttKeyedMethod string          // "cat" | "rts" | "dtr" while keyed; "" when idle
 	pttGen         int64           // bumped on every key; a delayed unkey only fires if unchanged (guards against a stale release cutting a new transmission)
@@ -808,6 +812,8 @@ func (a *App) startup(ctx context.Context) {
 	a.logDb = logbookConn
 	a.qso = qso.NewRepo(logbookConn)
 	go a.rebuildWorkedIndex() // in-memory worked-index for per-spot alert checks
+	go a.adifMonitorLoop()    // watch external ADIF files (fldigi, N1MM…) for new QSOs
+	a.relayAutoOn.Store(a.GetRelayAuto().Enabled) // prime the relay auto-control hot-path flag
 
 	// cty.dat for offline DXCC / country resolution. Cached on disk; first
 	// run downloads it from country-files.com in the background so startup
@@ -893,6 +899,13 @@ func (a *App) startup(ctx context.Context) {
 			wruntime.EventsEmit(a.ctx, "cat:state", s)
 		}
 		a.emitRadioUDP(s)
+		// Drive station relays by the current frequency/band (PstRotator-style
+		// automatic control). Cheap cached-flag check keeps this a no-op when the
+		// feature is off; when on, run off this callback so a slow relay board never
+		// stalls rig-state processing.
+		if a.relayAutoOn.Load() {
+			go a.applyRelayAuto(s.FreqHz, s.Band)
+		}
 	})
 	a.reloadCAT()
 
@@ -906,10 +919,11 @@ func (a *App) startup(ctx context.Context) {
 	// renders the row with all metadata already filled (no flicker of
 	// empty Country / Cont columns while the batch status fetch runs).
 	// Cluster events are processed OFF the socket-read goroutine (see clusterEvent /
-	// clusterEventWorker). Sized large so ordinary traffic and even an SH/DX/100
+	// clusterEventWorker). The queue is UNBOUNDED so no spot is ever dropped: an
-	// burst never fill it; a full queue drops-and-counts rather than block the read
+	// SH/DX or RBN burst grows the backlog and drains once enrichment catches up,
-	// loop, which was the actual cause of the feed falling behind telnet.
+	// while the read loop still never blocks (that was the cause of the feed falling
-	a.clusterEventCh = make(chan clusterEvent, 8192)
+	// behind telnet).
+	a.clusterEvents = newClusterQueue()
 	go a.clusterEventWorker()
 
 	a.cluster = cluster.NewManager(
@@ -4500,6 +4514,27 @@ func (a *App) GetOperators() ([]string, error) {
 	return a.qso.Operators(a.ctx)
 }
 
+// QSORate is the live QSO-rate meter shown in the header: how many QSOs were
+// logged in the trailing 10 and 60 minutes.
+type QSORate struct {
+	Last10 int `json:"last10"`
+	Last60 int `json:"last60"`
+}
+
+// GetQSORate returns the number of QSOs logged in the last 10 and 60 minutes.
+// Cheap (scans only the most recent rows); polled by the header and refreshed on
+// each qso:logged event.
+func (a *App) GetQSORate() QSORate {
+	if a.qso == nil {
+		return QSORate{}
+	}
+	counts, err := a.qso.RecentRate(a.ctx, time.Now(), 10*time.Minute, 60*time.Minute)
+	if err != nil || len(counts) < 2 {
+		return QSORate{}
+	}
+	return QSORate{Last10: counts[0], Last60: counts[1]}
+}
+
 // GetContestRuns lists the (contest, year) pairs actually present in the log, so
 // the Statistics picker only ever offers contests you really entered.
 func (a *App) GetContestRuns() ([]qso.ContestRun, error) {
@@ -5902,20 +5937,85 @@ type clusterEvent struct {
 	line *cluster.Line
 }
 
-// enqueueClusterEvent hands an event to the worker WITHOUT blocking. It runs on
+// clusterQueue is an unbounded FIFO between the socket-read goroutines (producers,
-// the cluster session's socket-read goroutine: blocking here would stop draining
+// which must never block or the TCP feed stalls) and the single clusterEventWorker
-// the TCP socket, the node's send buffer would fill, and the feed would fall
+// (consumer). Unlike a bounded channel it NEVER drops an event: a burst just grows
-// behind — the exact bug this indirection fixes. If the queue is full (processing
+// the backlog, which drains once enrichment catches up.
-// can't keep up), drop and count rather than stall the whole feed.
+type clusterQueue struct {
-func (a *App) enqueueClusterEvent(ev clusterEvent) {
+	mu     sync.Mutex
-	select {
+	cond   *sync.Cond
-	case a.clusterEventCh <- ev:
+	buf    []clusterEvent
-	default:
+	head   int  // index of the next event to pop (waste reclaimed by compaction)
-		n := atomic.AddInt64(&a.clusterDropped, 1)
+	closed bool
-		if n == 1 || n%100 == 0 {
+}
-			applog.Printf("cluster: processing backlog — dropped %d event(s); the feed is faster than enrichment/UI", n)
+
-		}
+func newClusterQueue() *clusterQueue {
+	q := &clusterQueue{}
+	q.cond = sync.NewCond(&q.mu)
+	return q
+}
+
+// push appends an event and wakes the worker. Amortised O(1); never blocks, never
+// drops.
+func (q *clusterQueue) push(ev clusterEvent) {
+	q.mu.Lock()
+	if q.closed {
+		q.mu.Unlock()
+		return
 	}
+	q.buf = append(q.buf, ev)
+	q.mu.Unlock()
+	q.cond.Signal()
+}
+
+// pop blocks until an event is available, returning ok=false only once the queue
+// is closed AND fully drained.
+func (q *clusterQueue) pop() (clusterEvent, bool) {
+	q.mu.Lock()
+	for q.head == len(q.buf) && !q.closed {
+		q.cond.Wait()
+	}
+	if q.head == len(q.buf) { // closed and drained
+		q.mu.Unlock()
+		return clusterEvent{}, false
+	}
+	ev := q.buf[q.head]
+	q.buf[q.head] = clusterEvent{} // release pointers held by the consumed slot
+	q.head++
+	switch {
+	case q.head == len(q.buf):
+		// Fully drained → reset to reuse the backing array from the front.
+		q.buf = q.buf[:0]
+		q.head = 0
+	case q.head > 1024 && q.head*2 >= len(q.buf):
+		// Head waste is large → compact so a long sustained burst doesn't grow
+		// the backing array without bound.
+		n := copy(q.buf, q.buf[q.head:])
+		for i := n; i < len(q.buf); i++ {
+			q.buf[i] = clusterEvent{}
+		}
+		q.buf = q.buf[:n]
+		q.head = 0
+	}
+	q.mu.Unlock()
+	return ev, true
+}
+
+// close wakes any waiting consumer so it can exit once the backlog is drained.
+func (q *clusterQueue) close() {
+	q.mu.Lock()
+	q.closed = true
+	q.mu.Unlock()
+	q.cond.Broadcast()
+}
+
+// enqueueClusterEvent hands an event to the worker WITHOUT blocking and WITHOUT
+// dropping. It runs on the cluster session's socket-read goroutine: blocking here
+// would stop draining the TCP socket, the node's send buffer would fill, and the
+// feed would fall behind — the exact bug this indirection fixes. The queue is
+// unbounded, so a burst grows the backlog rather than losing a spot.
+func (a *App) enqueueClusterEvent(ev clusterEvent) {
+	a.clusterEvents.push(ev)
 }
 
 // clusterEventWorker drains clusterEventCh and does everything that used to run
@@ -5923,7 +6023,11 @@ func (a *App) enqueueClusterEvent(ev clusterEvent) {
 // to the UI, run alert rules (which may query a remote MySQL) and mirror it to the
 // Flex panadapter — all serialised on this one goroutine, off the read path.
 func (a *App) clusterEventWorker() {
-	for ev := range a.clusterEventCh {
+	for {
+		ev, ok := a.clusterEvents.pop()
+		if !ok {
+			return
+		}
 		if ev.line != nil {
 			if a.ctx != nil {
 				wruntime.EventsEmit(a.ctx, "cluster:line", *ev.line)
@@ -7755,7 +7859,15 @@ func (a *App) runManualUpload(svc extsvc.Service, ids []int64, cfg extsvc.Extern
 					if err != nil {
 						msg = err.Error()
 					}
+					// Name the QSOs in the failing batch so a per-record rejection
+					// (e.g. a field value nginx's WAF blocks with a 403) can actually
+					// be located — otherwise "batch FAILED" hides which contact it is.
+					who := make([]string, 0, len(batch))
+					for _, it := range batch {
+						who = append(who, fmt.Sprintf("%s#%d", it.call, it.id))
+					}
 					emit(fmt.Sprintf("Club Log: batch of %d FAILED: %s", len(batch), msg))
+					applog.Printf("extsvc: Club Log batch FAILED (%s) — QSOs: %s", msg, strings.Join(who, ", "))
 				}
 			}
 		} else {

frontend/src/App.tsx

@@ -1,6 +1,6 @@
 import { useCallback, useEffect, useMemo, useRef, useState } from 'react';
 import {
-  AlertCircle, Antenna, Bell, CheckCircle2, Clock, CloudOff, Compass, Database, Ear, Eraser, Hash, Loader2, Lock,
+  Activity, AlertCircle, Antenna, Bell, CheckCircle2, Clock, CloudOff, Compass, Database, Ear, Eraser, Hash, Loader2, Lock,
   Maximize2, Minimize2, Mic, MessageSquare, Pencil, RadioTower, RefreshCw, Satellite, Send, Settings, SlidersHorizontal, Square, Terminal, Trash2, Unlock, X, Zap,
 } from 'lucide-react';
 
@@ -28,6 +28,7 @@ import {
   ListClusterServers, ClusterSpotStatuses, SendClusterSpot,
   GetCATSettings,
   GetSolarData,
+  GetQSORate,
   LoTWUserInfo,
   OperatingDefaultForBand,
   LogUDPLoggedADIF,
@@ -1064,6 +1065,15 @@ export default function App() {
   // Keyed by `${call}|${band}|${mode}` so two spots of the same call on
   // different slots don't share the same colour.
   const [spotStatus, setSpotStatus] = useState<Record<string, { status: string; country?: string; continent?: string; worked_call?: boolean; new_county?: boolean; new_pota?: boolean }>>({});
+  // Live mirror of spotStatus so the incoming-spot buffer can tell which slots
+  // still need resolving without re-subscribing the cluster:spot listener.
+  const spotStatusRef = useRef(spotStatus);
+  useEffect(() => { spotStatusRef.current = spotStatus; }, [spotStatus]);
+  // Incoming spots are staged here for a few ms, their status resolved, then
+  // committed to `spots` together — so a row paints with its NEW BAND/MODE badge
+  // already on, instead of flashing plain text then flipping to the pill.
+  const pendingSpotsRef = useRef<ClusterSpot[]>([]);
+  const pendingSpotTimer = useRef<number | undefined>(undefined);
 
   // === Modals ===
   const [editingQSO, setEditingQSO] = useState<QSO | null>(null);
@@ -1076,6 +1086,20 @@ export default function App() {
   const [showSettings, setShowSettings] = useState(false);
   // Re-read the "beam on map" toggle when Preferences closes (it's edited there).
   useEffect(() => { if (!showSettings) setShowBeamOnMap(localStorage.getItem('opslog.showBeamOnMap') !== '0'); }, [showSettings]);
+  // QSO-rate meter (10/60 min) in the header — opt-in via Settings→General.
+  const [showQsoRate, setShowQsoRate] = useState(() => localStorage.getItem('opslog.showQsoRate') === '1');
+  useEffect(() => { if (!showSettings) setShowQsoRate(localStorage.getItem('opslog.showQsoRate') === '1'); }, [showSettings]);
+  const [qsoRate, setQsoRate] = useState<{ last10: number; last60: number }>({ last10: 0, last60: 0 });
+  useEffect(() => {
+    if (!showQsoRate) return;
+    const load = () => { GetQSORate().then((r) => setQsoRate({ last10: r?.last10 ?? 0, last60: r?.last60 ?? 0 })).catch(() => {}); };
+    load();
+    // Refresh on each logged QSO (immediate feedback) and on a 30s tick so the
+    // trailing windows roll forward even when nothing new is logged.
+    const off = EventsOn('qso:logged', load);
+    const id = window.setInterval(load, 30 * 1000);
+    return () => { off(); window.clearInterval(id); };
+  }, [showQsoRate]);
   // Optional deep-link: which Preferences section to open. Cleared on
   // close so the next plain "Preferences" launch reverts to default.
   const [settingsSection, setSettingsSection] = useState<string | undefined>(undefined);
@@ -1290,20 +1314,28 @@ export default function App() {
   // surface the error — used by the startup retry, since the logbook DB (a remote
   // MySQL especially) can take a few seconds to connect while the UI is already
   // mounted, and we don't want to flash "db not available" during that window.
+  const refreshSeqRef = useRef(0); // guards against an older refresh clobbering a newer one's data
   const refresh = useCallback(async (silent = false): Promise<boolean> => {
+    // Monotonic guard: two refreshes can be in flight at once (e.g. the immediate
+    // one after a UDP auto-log, which reads the QSO at "R", and the debounced one
+    // after extsvc:uploaded, which reads it at "Y"). MySQL query latency can make
+    // the OLDER one resolve LAST and clobber the newer data — the Club Log status
+    // flicking R→Y→R. Only the most-recently-issued refresh is allowed to apply.
+    const seq = ++refreshSeqRef.current;
     try {
       const f = buildActiveFilter();
       const list = await ListQSOFiltered(f as any);
       const n = await CountQSO();
       const hasFilter = !!(f.quick_callsign || (f.conditions && f.conditions.length));
       const matched = hasFilter ? await CountQSOFiltered(f as any) : n;
+      if (seq !== refreshSeqRef.current) return true; // a newer refresh superseded us — drop this stale result
       setQsos(list);
       setTotal(n);
       setMatchCount(matched);
       setError('');
       return true;
     } catch (e: any) {
-      if (!silent) setError(String(e?.message ?? e));
+      if (!silent && seq === refreshSeqRef.current) setError(String(e?.message ?? e));
       return false;
     }
   }, [buildActiveFilter]);
@@ -1740,13 +1772,76 @@ export default function App() {
       const activeIds = new Set((sts ?? []).map((s) => s.server_id));
       setSpots((arr) => arr.filter((sp) => activeIds.has(sp.source_id)));
     });
-    const unsubSpot = EventsOn('cluster:spot', (sp: ClusterSpot) => {
+    // Commit the staged spots: resolve the status for any slot we don't know yet
+    // FIRST, then insert the rows — so they appear with the right badge already
+    // painted instead of flashing plain text then flipping to a pill.
+    const flushPendingSpots = async () => {
+      pendingSpotTimer.current = undefined;
+      const batch = pendingSpotsRef.current;
+      pendingSpotsRef.current = [];
+      if (batch.length === 0) return;
+      // Resolve unknown statuses before the rows go in.
+      try {
+        const known = spotStatusRef.current;
+        const unknown: { call: string; band: string; mode: string; pota_ref: string }[] = [];
+        const seen = new Set<string>();
+        for (const s of batch) {
+          const k = spotStatusKey(s.dx_call, s.band ?? '', s.comment ?? '', s.freq_hz);
+          if (seen.has(k) || known[k]) continue;
+          seen.add(k);
+          unknown.push({
+            call: s.dx_call, band: s.band ?? '',
+            mode: inferSpotMode(s.comment ?? '', s.freq_hz),
+            pota_ref: (s as any).pota_ref ?? '',
+          });
+        }
+        if (unknown.length > 0) {
+          const res = await ClusterSpotStatuses(unknown as any);
+          setSpotStatus((prev) => {
+            const next = { ...prev };
+            for (const r of res) {
+              const k = `${r.call}|${r.band ?? ''}|${(r.mode ?? '').toUpperCase()}`;
+              next[k] = {
+                status: r.status ?? '',
+                country: r.country,
+                continent: (r as any).continent,
+                worked_call: !!(r as any).worked_call,
+                new_county: !!(r as any).new_county,
+                new_pota: !!(r as any).new_pota,
+              };
+            }
+            return next;
+          });
+        }
+      } catch {}
+      // Now insert the staged rows. Same de-dupe as before: a station re-spotted
+      // (RBN skimmers on a CQ, several nodes relaying) shows as ONE live row that
+      // the freshest spot REPLACES and floats to the top. Historical (SH/DX
+      // replay) rows are left alone.
       setSpots((arr) => {
-        const next = [sp, ...arr];
+        const key = (x: ClusterSpot) => `${(x.dx_call ?? '').toUpperCase()}|${(x.band ?? '').toLowerCase()}`;
+        const hist = (x: ClusterSpot) => !!(x as any).historical;
+        let next = arr;
+        for (const sp of batch) {
+          const k = key(sp);
+          const filtered = hist(sp) ? next : next.filter((x) => hist(x) || key(x) !== k);
+          next = [sp, ...filtered];
+        }
         return next.length > SPOTS_CAP ? next.slice(0, SPOTS_CAP) : next;
       });
+    };
+    const unsubSpot = EventsOn('cluster:spot', (sp: ClusterSpot) => {
+      // Stage the spot; a short timer resolves its status then commits it.
+      pendingSpotsRef.current.push(sp);
+      // 50 ms is enough to coalesce an RBN burst into one status lookup (the
+      // worked-index is in memory, so resolving is near-instant) while staying
+      // imperceptible.
+      if (pendingSpotTimer.current === undefined) {
+        pendingSpotTimer.current = window.setTimeout(flushPendingSpots, 50);
+      }
       // Self-spot: someone spotted OUR callsign — show it in the shared header
       // toast (same place as the other notifications), not a separate banner.
+      // Fired immediately (not staged) so the notification never lags the spot.
       const mine = myCallRef.current;
       if (mine && (sp.dx_call ?? '').toUpperCase() === mine) {
         const by = cleanSpotter(sp.spotter ?? '') || '?';
@@ -1754,7 +1849,10 @@ export default function App() {
         showToast(`Spotted by ${by}${c ? ` with ${c}` : ''}`);
       }
     });
-    return () => { unsubState?.(); unsubSpot?.(); };
+    return () => {
+      unsubState?.(); unsubSpot?.();
+      if (pendingSpotTimer.current !== undefined) window.clearTimeout(pendingSpotTimer.current);
+    };
     // eslint-disable-next-line react-hooks/exhaustive-deps
   }, []);
 
@@ -1823,7 +1921,16 @@ export default function App() {
         else setError('UDP auto-log: ' + msg);
       }
     });
-    return () => { unsubDX?.(); unsubRC?.(); unsubClear?.(); unsubFlexSpot?.(); unsubProg?.(); unsubLog?.(); };
+    // ADIF monitor imported new QSOs (backend file watcher) → refresh the grid
+    // and show how many, from which file.
+    const unsubAdifMon = EventsOn('adifmon:imported', async (p: any) => {
+      const n = Number(p?.count ?? 0);
+      if (n <= 0) return;
+      await refresh();
+      const file = String(p?.file ?? '').replace(/^.*[\\/]/, '');
+      showToast(`ADIF: ${n} QSO imported${file ? ` from ${file}` : ''}`);
+    });
+    return () => { unsubDX?.(); unsubRC?.(); unsubClear?.(); unsubFlexSpot?.(); unsubProg?.(); unsubLog?.(); unsubAdifMon?.(); };
     // eslint-disable-next-line react-hooks/exhaustive-deps
   }, []);
 
@@ -1918,17 +2025,21 @@ export default function App() {
   async function wkSend(rawText: string) {
     setWkSent('');
     const resolved = resolveCW(rawText);
+    // Trailing word space so two macros fired back-to-back don't run together in
+    // the keyer buffer ("CQ" + "TEST" → "CQTEST"). The keyer keys a space as a
+    // word gap at the CURRENT speed, so it scales with WPM automatically.
+    const keyed = resolved ? resolved + ' ' : resolved;
     const doLog = /<LOGQSO>/i.test(rawText); // resolveCW strips the token (unknown var → "")
     const sleep = (ms: number) => new Promise((r) => window.setTimeout(r, ms));
     if (cwSourceRef.current === 'icom') {
       // The rig's keyer gives no busy echo back, so show the text we sent and,
       // for <LOGQSO>, wait the estimated send duration before logging.
       setWkSent(resolved);
-      await IcomSendCW(resolved).catch((e) => setError(String(e?.message ?? e)));
+      await IcomSendCW(keyed).catch((e) => setError(String(e?.message ?? e)));
       if (doLog) { await sleep(Math.round(estimateCwMs(resolved, wkWpm)) + 600); void save(); }
       return;
     }
-    await WinkeyerSend(resolved).catch((e) => setError(String(e?.message ?? e)));
+    await WinkeyerSend(keyed).catch((e) => setError(String(e?.message ?? e)));
     // <LOGQSO> (e.g. "BK 73 TU <LOGQSO>") logs the contact AFTER the keyer has
     // finished sending — so the QSO isn't logged (and the form cleared) while CW
     // is still going out. We'd like to wait for the busy flag to rise then fall,
@@ -3663,6 +3774,29 @@ export default function App() {
             )}
           </div>
 
+          {/* QSO-rate meter (opt-in) + propagation share ONE grid cell: the header
+              is a fixed 6-column grid, so adding the meter as its own child pushed
+              the last columns (profile / band map / compact) onto a 2nd row. */}
+          <div className="flex items-center gap-2">
+          {showQsoRate && (
+            <div className="flex items-center gap-2.5 font-mono px-2.5 h-8 rounded-md border border-border/60 bg-muted/40 whitespace-nowrap"
+              title={t('rate.title')}>
+              <Activity className={cn('size-3.5', (qsoRate.last10 + qsoRate.last60) > 0 ? 'text-primary' : 'text-muted-foreground')} />
+              {/* Contest-style rate: QSOs/hour projected from each window
+                  (10-min count ×6; the 60-min count is already per hour). Numbers
+                  glow the brand accent when active, dim to muted when idle. */}
+              <span className="inline-flex items-baseline gap-1">
+                <span className="text-muted-foreground uppercase tracking-wider text-[9px]">10′</span>
+                <span className={cn('font-bold text-[12px]', qsoRate.last10 > 0 ? 'text-primary' : 'text-muted-foreground')}>{qsoRate.last10 * 6}</span>
+              </span>
+              <span className="inline-flex items-baseline gap-1">
+                <span className="text-muted-foreground uppercase tracking-wider text-[9px]">60′</span>
+                <span className={cn('font-bold text-[12px]', qsoRate.last60 > 0 ? 'text-primary' : 'text-muted-foreground')}>{qsoRate.last60}</span>
+              </span>
+              <span className="text-muted-foreground text-[9px] uppercase tracking-wider">Q/h</span>
+            </div>
+          )}
+
           {/* Space-weather / propagation — compact, in the header. Live from N0NBH
               (hamqsl.com), auto-refreshed hourly; the same SFI / A / K are stamped
               onto each logged QSO. Always renders one element so the grid columns
@@ -3674,6 +3808,14 @@ export default function App() {
                 const geo = String(solar.geomag_field || '').toUpperCase();
                 const geoCls = /STORM|SEVERE/.test(geo) ? 'text-danger'
                   : /ACTIVE|UNSETTLED/.test(geo) ? 'text-warning' : 'text-success';
+                const num = (v: any) => { const n = Number(v); return Number.isFinite(n) ? n : null; };
+                // Semantic colour by band condition: higher flux/sunspots = better HF
+                // (green when strong); A and K measure geomagnetic disturbance, so LOW
+                // is good (green quiet → yellow unsettled → red storm).
+                const sfiCls = (v: any) => { const n = num(v); return n == null ? 'text-foreground' : n >= 120 ? 'text-success' : n >= 90 ? 'text-foreground' : 'text-warning'; };
+                const ssnCls = (v: any) => { const n = num(v); return n != null && n >= 80 ? 'text-success' : 'text-foreground'; };
+                const aCls = (v: any) => { const n = num(v); return n == null ? 'text-foreground' : n <= 7 ? 'text-success' : n <= 15 ? 'text-warning' : 'text-danger'; };
+                const kCls = (v: any) => { const n = num(v); return n == null ? 'text-foreground' : n <= 2 ? 'text-success' : n <= 3 ? 'text-warning' : 'text-danger'; };
                 const it = (label: string, val: any, cls = 'text-foreground') => (
                   <span className="inline-flex items-baseline gap-1">
                     <span className="text-muted-foreground uppercase tracking-wider text-[9px]">{label}</span>
@@ -3681,15 +3823,16 @@ export default function App() {
                   </span>
                 );
                 return (<>
-                  {it('SFI', solar.sfi)}
+                  {it('SFI', solar.sfi, sfiCls(solar.sfi))}
-                  {it('SSN', solar.ssn)}
+                  {it('SSN', solar.ssn, ssnCls(solar.ssn))}
-                  {it('A', solar.a_index)}
+                  {it('A', solar.a_index, aCls(solar.a_index))}
-                  {it('K', solar.k_index)}
+                  {it('K', solar.k_index, kCls(solar.k_index))}
                   {geo ? <span className={cn('font-bold text-[12px]', geoCls)}>{geo}</span> : null}
                 </>);
               })()}
             </div>
           ) : <span />}
+          </div>
 
           <div className="flex items-center gap-1.5 font-mono text-xs text-muted-foreground px-2.5 py-1 bg-muted rounded-md border border-border/60">
             <Clock className="size-3" />

frontend/src/components/ClusterGrid.tsx

@@ -113,6 +113,26 @@ function tok(name: string, text: string): Badge {
   return { text, fg: `var(--${name}-muted-foreground)`, bg: `var(--${name}-muted)`, bd: `var(--${name}-border)` };
 }
 
+// cellChip wraps a Band/Mode cell value in a small rounded pill (same look as the
+// Status badges) when the slot is notable, instead of flooding the whole cell with
+// a heavy muted fill that turned into an ugly olive block on dark themes. `name` is
+// null → plain text, no pill.
+function cellChip(value: any, name: string | null): any {
+  const txt = value === undefined || value === null || value === '' ? '' : String(value);
+  if (!name) return txt || <span style={{ color: 'var(--muted-foreground)', fontSize: 10 }}>—</span>;
+  // Inherit the column's font size (no fixed 9px / height) so a pill around a
+  // callsign stays the same size as the plain callsigns next to it — just tinted
+  // and rounded, not shrunk.
+  return (
+    <span style={{
+      display: 'inline-flex', alignItems: 'center', lineHeight: 1.1,
+      backgroundColor: `var(--${name}-muted)`, color: `var(--${name}-muted-foreground)`,
+      border: `1px solid var(--${name}-border)`, fontWeight: 700,
+      padding: '1px 6px', borderRadius: 999, whiteSpace: 'nowrap',
+    }}>{txt}</span>
+  );
+}
+
 function statusBadge(t: TFn, s: SpotStatusEntry | undefined): Badge | null {
   switch (s?.status) {
     case 'new':      return tok('danger',  t('clg2.newDxcc'));
@@ -129,22 +149,22 @@ const makeColCatalog = (t: TFn): ColEntry[] => [
     headerName: t('clg2.c.time'), field: 'time_utc' as any, width: 80, cellClass: 'font-mono',
     defaultVisible: true,
     sort: 'desc',
-    cellStyle: { color: '#7a6b50' },
+    cellStyle: { color: 'var(--muted-foreground)' },
   },
   {
     group: 'Spot', label: t('clg2.c.call'),  colId: 'call',
     headerName: t('clg2.c.call'), field: 'dx_call' as any, width: 120,
     defaultVisible: true,
     cellClass: 'font-mono',
-    // Only STATUS calls get a colour: new DXCC entity → filled cell (no padded
+    // NEW DXCC → a danger pill around the call, consistent with the NEW BAND /
-    // pill, so calls stay aligned), worked-call → blue. A plain spot inherits the
+    // NEW MODE pills (same look, same tokens). Worked-call stays blue bold text;
-    // theme's normal text colour (var(--foreground)) so callsigns blend in with
+    // a plain spot inherits the theme's normal text colour so callsigns blend in
-    // the rest of the row across every theme instead of always shouting orange.
+    // with the rest of the row instead of always shouting a colour.
-    cellStyle: (p: any): any => {
+    cellRenderer: (p: any) => {
       const s = statusFor(p);
-      if (s?.status === 'new') return { backgroundColor: 'var(--danger-muted)', color: 'var(--danger-muted-foreground)', fontWeight: 700 };
+      if (s?.status === 'new') return cellChip(p.value, 'danger');
-      if (s?.worked_call) return { color: 'var(--info)', fontWeight: 700 };
+      const color = s?.worked_call ? 'var(--info)' : undefined;
-      return { fontWeight: 700 };
+      return <span style={{ color, fontWeight: 700 }}>{p.value ?? ''}</span>;
     },
     tooltipValueGetter: (p: any) => {
       const s = statusFor(p);
@@ -204,7 +224,7 @@ const makeColCatalog = (t: TFn): ColEntry[] => [
     group: 'Spot', label: t('clg2.c.pota'), colId: 'pota',
     headerName: t('clg2.c.pota'), field: 'pota_ref' as any, width: 92, cellClass: 'font-mono',
     defaultVisible: true,
-    cellStyle: { color: '#166534' },
+    cellStyle: { color: 'var(--success)' },
     tooltipValueGetter: (p: any) => (p.data?.pota_name ? t('clg2.tipPota', { name: p.data.pota_name }) : undefined),
   },
   {
@@ -219,10 +239,8 @@ const makeColCatalog = (t: TFn): ColEntry[] => [
     headerName: t('clg2.c.band'), field: 'band' as any, width: 75,
     defaultVisible: true,
     cellClass: 'font-mono',
-    // NEW BAND for this entity → fill the cell (keeps the band text aligned).
+    // NEW BAND for this entity → small warning pill around the band text.
-    cellStyle: (p: any) => (statusFor(p)?.status === 'new-band'
+    cellRenderer: (p: any) => cellChip(p.value, statusFor(p)?.status === 'new-band' ? 'warning' : null),
-      ? { backgroundColor: '#fde68a', color: '#92400e', fontWeight: 700 }
-      : undefined),
     tooltipValueGetter: (p: any) => (statusFor(p)?.status === 'new-band' ? t('clg2.tipNewBand') : undefined),
   },
   {
@@ -231,16 +249,11 @@ const makeColCatalog = (t: TFn): ColEntry[] => [
     defaultVisible: true,
     cellClass: 'font-mono',
     valueGetter: (p: any) => p.data ? inferSpotMode(p.data.comment ?? '', p.data.freq_hz) : '',
-    // Fill the mode cell: teal = NEW MODE (mode never worked on this entity),
+    // Only NEW MODE pills the mode cell — there the mode itself is genuinely new
-    // yellow = NEW SLOT (this band+mode combo new, but the mode was worked elsewhere).
+    // for the entity. NEW SLOT means band AND mode were each worked before (just
-    cellStyle: (p: any) => {
+    // not together), so highlighting the mode cell would wrongly imply "CW is new";
-      const st = statusFor(p)?.status;
+    // that case is signalled by the Status badge alone.
-      // Both NEW MODE and NEW SLOT highlight the mode cell (same yellow); the
+    cellRenderer: (p: any) => cellChip(p.value, statusFor(p)?.status === 'new-mode' ? 'caution' : null),
-      // Status badge text tells them apart.
-      if (st === 'new-mode' || st === 'new-slot') return { backgroundColor: '#fef08a', color: '#854d0e', fontWeight: 700 };
-      return undefined;
-    },
-    cellRenderer: (p: any) => p.value ? p.value : <span style={{ color: '#a8a29e', fontSize: 10 }}>—</span>,
     tooltipValueGetter: (p: any) => {
       const st = statusFor(p)?.status;
       if (st === 'new-mode') return t('clg2.tipNewMode');
@@ -252,7 +265,7 @@ const makeColCatalog = (t: TFn): ColEntry[] => [
     group: 'Spot', label: t('clg2.c.pfx'), colId: 'pfx',
     headerName: t('clg2.c.pfx'), width: 60, cellClass: 'font-mono',
     valueGetter: (p: any) => fmtPfx(p.data?.dx_call ?? ''),
-    cellStyle: { color: '#7a6b50' },
+    cellStyle: { color: 'var(--muted-foreground)' },
   },
   {
     group: 'Geo', label: t('clg2.c.cqz'), colId: 'cqz',
@@ -289,7 +302,7 @@ const makeColCatalog = (t: TFn): ColEntry[] => [
     valueGetter: (p: any) => p.data?.country ?? p.context?.spotStatus?.[
       spotStatusKey(p.data?.dx_call, p.data?.band ?? '', p.data?.comment ?? '', p.data?.freq_hz)
     ]?.country ?? '',
-    cellStyle: { color: '#7a6b50' },
+    cellStyle: { color: 'var(--muted-foreground)' },
   },
   {
     group: 'Spot', label: t('clg2.c.continent'), colId: 'continent',
@@ -298,31 +311,31 @@ const makeColCatalog = (t: TFn): ColEntry[] => [
     valueGetter: (p: any) => p.data?.continent ?? p.context?.spotStatus?.[
       spotStatusKey(p.data?.dx_call, p.data?.band ?? '', p.data?.comment ?? '', p.data?.freq_hz)
     ]?.continent ?? '',
-    cellStyle: { color: '#7a6b50', fontSize: 10 },
+    cellStyle: { color: 'var(--muted-foreground)', fontSize: 10 },
   },
   {
     group: 'Spot', label: t('clg2.c.spotter'), colId: 'spotter',
     headerName: t('clg2.c.spotter'), field: 'spotter' as any, width: 100, cellClass: 'font-mono',
     defaultVisible: true,
     valueFormatter: (p) => cleanSpotter(p.value ?? ''),
-    cellStyle: { color: '#7a6b50' },
+    cellStyle: { color: 'var(--muted-foreground)' },
   },
   {
     group: 'Spot', label: t('clg2.c.source'), colId: 'source',
     headerName: t('clg2.c.source'), field: 'source_name' as any, width: 100,
     defaultVisible: true,
-    cellStyle: { color: '#9a8870', fontSize: 10 },
+    cellStyle: { color: 'var(--muted-foreground)', fontSize: 10 },
   },
   {
     group: 'Spot', label: t('clg2.c.locator'), colId: 'locator',
     headerName: t('clg2.h.locator'), field: 'locator' as any, width: 80, cellClass: 'font-mono',
-    cellStyle: { color: '#7a6b50' },
+    cellStyle: { color: 'var(--muted-foreground)' },
   },
   {
     group: 'Spot', label: t('clg2.c.comment'), colId: 'comment',
     headerName: t('clg2.c.comment'), field: 'comment' as any, flex: 1, minWidth: 160,
     defaultVisible: true,
-    cellStyle: { color: '#7a6b50' },
+    cellStyle: { color: 'var(--muted-foreground)' },
   },
   {
     group: 'Spot', label: t('clg2.c.received_at'), colId: 'received_at',

frontend/src/components/DvkPanel.tsx

@@ -25,8 +25,8 @@ export function DvkPanel({ messages, status, onPlay, onStop, onClose }: Props) {
       <div className="flex items-center gap-2 px-3 py-1.5 border-b border-border bg-muted/40 shrink-0">
         <Mic className="size-3.5 text-primary" />
         <span className="text-[11px] font-semibold uppercase tracking-wider">{t('dvkp.voiceKeyer')}</span>
-        <span className={cn('size-2 rounded-full', status.playing ? 'bg-warning animate-pulse' : 'bg-success')} />
+        <span className={cn('size-2 rounded-full', status.playing ? 'bg-danger animate-pulse' : 'bg-success')} />
-        {status.playing && <span className="text-[10px] text-warning font-medium">tx...</span>}
+        {status.playing && <span className="text-[10px] text-danger font-medium">TX</span>}
         <div className="flex-1" />
         <Button variant="ghost" size="sm" className="h-6 px-2 text-[11px]" onClick={onStop} disabled={!status.playing}>
           <Square className="size-3" /> {t('dvkp.stop')}

frontend/src/components/SettingsModal.tsx

@@ -42,6 +42,8 @@ import {
   ComputeStationInfo,
   GetUIPref, SetUIPref,
   GetFlexState, GetFlexBandAntennas, SaveFlexBandAntennas,
+  GetADIFMonitor, SaveADIFMonitor, PickADIFMonitorFile,
+  GetRelayAuto, SaveRelayAuto, GetStationDevices,
 } from '../../wailsjs/go/main/App';
 import type { profile as profileModels } from '../../wailsjs/go/models';
 import type { LookupSettingsForm, StationSettingsForm, ListsSettingsForm, ModePresetForm } from '@/types';
@@ -169,6 +171,7 @@ type SectionId =
   | 'confirmations'
   | 'external-services'
   | 'udp'
+  | 'adifmon'
   | 'lookup'
   | 'lists-bands'
   | 'lists-modes'
@@ -185,6 +188,7 @@ type SectionId =
   | 'antgenius'
   | 'pgxl'
   | 'flex'
+  | 'relayauto'
   | 'audio';
 
 type TreeNode =
@@ -202,6 +206,7 @@ function buildTree(flexAvailable: boolean, t: (k: string) => string): TreeNode[]
     { kind: 'item', label: t('sec.antgenius'),    id: 'antgenius' },
     { kind: 'item', label: t('sec.pgxl'),         id: 'pgxl' },
     ...(flexAvailable ? [{ kind: 'item', label: t('sec.flex'), id: 'flex' } as TreeNode] : []),
+    { kind: 'item', label: t('sec.relayauto'),    id: 'relayauto' },
     { kind: 'item', label: t('sec.audio'),        id: 'audio' },
   ];
   return [
@@ -225,6 +230,7 @@ function buildTree(flexAvailable: boolean, t: (k: string) => string): TreeNode[]
       ]},
       { kind: 'item', label: t('sec.cluster'),     id: 'cluster' },
       { kind: 'item', label: t('sec.udp'), id: 'udp' },
+      { kind: 'item', label: t('sec.adifmon'), id: 'adifmon' },
       { kind: 'item', label: t('sec.uscounties'), id: 'uscounties' },
       { kind: 'item', label: t('sec.database'), id: 'database' },
       { kind: 'item', label: t('sec.autostart'), id: 'autostart' },
@@ -241,9 +247,11 @@ const SECTION_KEY: Partial<Record<SectionId, string>> = {
   station: 'sec.station', profiles: 'sec.profiles', operating: 'sec.operating', confirmations: 'sec.confirmations',
   'external-services': 'sec.external', lookup: 'sec.lookup', 'lists-bands': 'sec.bands', 'lists-modes': 'sec.modes',
   cluster: 'sec.cluster', backup: 'sec.backup', database: 'sec.database', autostart: 'sec.autostart', udp: 'sec.udp',
+  adifmon: 'sec.adifmon',
   uscounties: 'sec.uscounties',
   awards: 'sec.awards', cat: 'sec.cat', rotator: 'sec.rotator', winkeyer: 'sec.winkeyer', antenna: 'sec.antenna',
   antgenius: 'sec.antgenius', pgxl: 'sec.pgxl', flex: 'sec.flex', audio: 'sec.audio', general: 'sec.general', email: 'sec.email',
+  relayauto: 'sec.relayauto',
 };
 
 // Map section id → friendly name (used in breadcrumb / placeholders).
@@ -261,6 +269,7 @@ const SECTION_LABELS: Partial<Record<SectionId, string>> = {
   database: 'Database',
   autostart: 'Autostart',
   udp: 'UDP integrations',
+  adifmon: 'ADIF monitor',
   awards: 'Awards',
   cat: 'CAT interface',
   rotator: 'Rotator',
@@ -269,6 +278,7 @@ const SECTION_LABELS: Partial<Record<SectionId, string>> = {
   antgenius: 'Antenna Genius',
   pgxl: 'Power Genius',
   flex: 'FlexRadio',
+  relayauto: 'Relay auto-control',
   audio: 'Audio devices',
 };
 
@@ -540,6 +550,7 @@ function AutostartPanelComponent() {
 // (a random install ID + version + OS, sent once a day). Real component so it
 // can own its state; embedded inside GeneralPanel.
 function TelemetryToggle() {
+  const { t } = useI18n();
   const [on, setOn] = useState(true);
   const [loaded, setLoaded] = useState(false);
   useEffect(() => {
@@ -549,8 +560,8 @@ function TelemetryToggle() {
     <label className="flex items-center gap-2 text-sm cursor-pointer">
       <Checkbox checked={on} disabled={!loaded}
         onCheckedChange={(c) => { const v = !!c; setOn(v); SetTelemetryEnabled(v).catch(() => {}); }} />
-      Send anonymous usage statistics
+      {t('settings.telemetry')}
-      <span className="text-xs text-muted-foreground">(install ID + version + OS, once a day — no callsign or QSO data)</span>
+      <span className="text-xs text-muted-foreground">({t('settings.telemetryHint')})</span>
     </label>
   );
 }
@@ -560,6 +571,7 @@ function TelemetryToggle() {
 // events — a small web script on your server renders it for the QRZ page. Only
 // useful on a MySQL logbook. Self-contained component (owns its async state).
 function LiveStatusToggle() {
+  const { t } = useI18n();
   const [on, setOn] = useState(false);
   const [loaded, setLoaded] = useState(false);
   useEffect(() => {
@@ -569,34 +581,195 @@ function LiveStatusToggle() {
     <label className="flex items-center gap-2 text-sm cursor-pointer">
       <Checkbox checked={on} disabled={!loaded}
         onCheckedChange={(c) => { const v = !!c; setOn(v); SetLiveStatusEnabled(v).catch(() => {}); }} />
-      Publish live operator status <span className="text-xs text-muted-foreground">(multi-op on shared MySQL — feeds a QRZ live page)</span>
+      {t('settings.liveStatus')} <span className="text-xs text-muted-foreground">({t('settings.liveStatusHint')})</span>
     </label>
   );
 }
 
+// ADIFMonitorPanel watches a list of external ADIF files (fldigi RTTY, N1MM,
+// VarAC…) and auto-imports newly appended QSOs — deliberately option-free: a
+// contact that arrives is imported and uploaded automatically like any log entry.
+type ADIFWatchFileUI = { path: string; enabled: boolean; offset: number };
+type ADIFMonitorCfgUI = { enabled: boolean; files: ADIFWatchFileUI[] };
+function ADIFMonitorPanel() {
+  const { t } = useI18n();
+  const [cfg, setCfg] = useState<ADIFMonitorCfgUI>({ enabled: false, files: [] });
+  const [loaded, setLoaded] = useState(false);
+  useEffect(() => {
+    GetADIFMonitor()
+      .then((c: any) => { if (c) setCfg({ enabled: !!c.enabled, files: (c.files ?? []) as ADIFWatchFileUI[] }); })
+      .catch(() => {})
+      .finally(() => setLoaded(true));
+  }, []);
+  // Offsets are managed backend-side; SaveADIFMonitor ignores the ones we send and
+  // keeps each existing file's read position (a new file starts at end-of-file).
+  const persist = (next: ADIFMonitorCfgUI) => { setCfg(next); SaveADIFMonitor(next as any).catch(() => {}); };
+  const addFile = async () => {
+    try {
+      const p = await PickADIFMonitorFile();
+      if (!p || cfg.files.some((f) => f.path === p)) return;
+      persist({ ...cfg, files: [...cfg.files, { path: p, enabled: true, offset: -1 }] });
+    } catch { /* dialog cancelled */ }
+  };
+  return (
+    <div className="space-y-4 max-w-2xl">
+      <p className="text-xs text-muted-foreground">{t('adifmon.hint')}</p>
+      <label className="flex items-center gap-2 text-sm cursor-pointer">
+        <Checkbox checked={cfg.enabled} disabled={!loaded} onCheckedChange={(c) => persist({ ...cfg, enabled: !!c })} />
+        {t('adifmon.enable')}
+      </label>
+      <div className="space-y-1.5">
+        {cfg.files.length === 0 && <p className="text-xs text-muted-foreground italic">{t('adifmon.empty')}</p>}
+        {cfg.files.map((f, i) => (
+          <div key={i} className="flex items-center gap-2 rounded-md border border-border bg-muted/20 px-2 py-1.5">
+            <Checkbox checked={f.enabled}
+              onCheckedChange={(c) => persist({ ...cfg, files: cfg.files.map((x, idx) => idx === i ? { ...x, enabled: !!c } : x) })} />
+            <span className="flex-1 font-mono text-xs truncate" title={f.path}>{f.path}</span>
+            <button type="button" title={t('adifmon.remove')}
+              className="text-muted-foreground hover:text-destructive shrink-0"
+              onClick={() => persist({ ...cfg, files: cfg.files.filter((_, idx) => idx !== i) })}>
+              <Trash2 className="size-3.5" />
+            </button>
+          </div>
+        ))}
+      </div>
+      <Button variant="outline" size="sm" onClick={addFile}>
+        <FolderOpen className="size-3.5 mr-1" /> {t('adifmon.add')}
+      </Button>
+      <p className="text-[11px] text-muted-foreground">{t('adifmon.note')}</p>
+    </div>
+  );
+}
+
+// RelayAutoPanel configures automatic control of the Station Control relay boards
+// from the rig's frequency / band (PstRotator-style). Each relay carries one rule:
+// off, a frequency window (kHz), or a set of bands.
+type RelayRuleUI = { device_id: string; relay: number; mode: string; freq_lo_khz: number; freq_hi_khz: number; bands: string[] };
+type StationDevUI = { id: string; type: string; name: string; labels: string[] };
+const RELAY_BANDS = ['160m', '80m', '60m', '40m', '30m', '20m', '17m', '15m', '12m', '10m', '6m', '4m', '2m', '70cm'];
+const relayCountUI = (type: string) => (type === 'kmtronic' ? 8 : 5);
+function RelayAutoPanel() {
+  const { t } = useI18n();
+  const [enabled, setEnabled] = useState(false);
+  const [rules, setRules] = useState<RelayRuleUI[]>([]);
+  const [devices, setDevices] = useState<StationDevUI[]>([]);
+  const [loaded, setLoaded] = useState(false);
+  useEffect(() => {
+    Promise.all([GetRelayAuto(), GetStationDevices()])
+      .then(([cfg, devs]: any[]) => {
+        setEnabled(!!cfg?.enabled);
+        setRules((cfg?.rules ?? []) as RelayRuleUI[]);
+        setDevices((devs ?? []) as StationDevUI[]);
+      })
+      .catch(() => {})
+      .finally(() => setLoaded(true));
+  }, []);
+  const save = (en: boolean, rs: RelayRuleUI[]) => { SaveRelayAuto({ enabled: en, rules: rs } as any).catch(() => {}); };
+  const ruleFor = (dev: string, relay: number): RelayRuleUI =>
+    rules.find((r) => r.device_id === dev && r.relay === relay) ?? { device_id: dev, relay, mode: 'off', freq_lo_khz: 0, freq_hi_khz: 0, bands: [] };
+  // Apply a patch and persist (commit=true) or keep local only (commit=false, for
+  // freq inputs that persist on blur so we don't switch relays on every keystroke).
+  const patchRule = (dev: string, relay: number, patch: Partial<RelayRuleUI>, commit = true) => {
+    const next = { ...ruleFor(dev, relay), ...patch };
+    const others = rules.filter((r) => !(r.device_id === dev && r.relay === relay));
+    const all = [...others, next];
+    setRules(all);
+    if (commit) save(enabled, all);
+  };
+  const toggleBand = (dev: string, relay: number, band: string) => {
+    const cur = ruleFor(dev, relay);
+    const has = cur.bands.includes(band);
+    patchRule(dev, relay, { bands: has ? cur.bands.filter((b) => b !== band) : [...cur.bands, band] });
+  };
+
+  return (
+    <div className="space-y-4 max-w-3xl">
+      <p className="text-xs text-muted-foreground">{t('relayauto.hint')}</p>
+      <label className="flex items-center gap-2 text-sm cursor-pointer">
+        <Checkbox checked={enabled} disabled={!loaded} onCheckedChange={(c) => { const v = !!c; setEnabled(v); save(v, rules); }} />
+        {t('relayauto.enable')}
+      </label>
+
+      {devices.length === 0 && loaded && (
+        <p className="text-xs text-muted-foreground italic">{t('relayauto.noDevices')}</p>
+      )}
+
+      {devices.map((dev) => (
+        <div key={dev.id} className="rounded-md border border-border">
+          <div className="px-3 py-1.5 border-b border-border bg-muted/40 text-xs font-semibold">{dev.name || dev.id}</div>
+          <div className="divide-y divide-border/60">
+            {Array.from({ length: relayCountUI(dev.type) }, (_, i) => i + 1).map((relay) => {
+              const r = ruleFor(dev.id, relay);
+              const label = (dev.labels?.[relay - 1] || '').trim() || `${t('relayauto.relay')} ${relay}`;
+              return (
+                <div key={relay} className="flex items-start gap-3 px-3 py-2">
+                  <span className="w-28 shrink-0 text-xs font-mono pt-1.5 truncate" title={label}>{label}</span>
+                  <Select value={r.mode || 'off'} onValueChange={(v) => patchRule(dev.id, relay, { mode: v })}>
+                    <SelectTrigger className="h-8 w-32 text-xs shrink-0"><SelectValue /></SelectTrigger>
+                    <SelectContent>
+                      <SelectItem value="off">{t('relayauto.modeOff')}</SelectItem>
+                      <SelectItem value="freq">{t('relayauto.modeFreq')}</SelectItem>
+                      <SelectItem value="band">{t('relayauto.modeBand')}</SelectItem>
+                    </SelectContent>
+                  </Select>
+                  <div className="flex-1 min-w-0 pt-0.5">
+                    {r.mode === 'freq' && (
+                      <div className="flex items-center gap-1.5 text-xs">
+                        <Input type="number" className="h-8 w-24 text-xs" placeholder={t('relayauto.from')}
+                          defaultValue={r.freq_lo_khz || ''}
+                          onChange={(e) => patchRule(dev.id, relay, { freq_lo_khz: parseFloat(e.target.value) || 0 }, false)}
+                          onBlur={() => save(enabled, rules)} />
+                        <span className="text-muted-foreground">–</span>
+                        <Input type="number" className="h-8 w-24 text-xs" placeholder={t('relayauto.to')}
+                          defaultValue={r.freq_hi_khz || ''}
+                          onChange={(e) => patchRule(dev.id, relay, { freq_hi_khz: parseFloat(e.target.value) || 0 }, false)}
+                          onBlur={() => save(enabled, rules)} />
+                        <span className="text-muted-foreground">kHz</span>
+                      </div>
+                    )}
+                    {r.mode === 'band' && (
+                      <div className="flex flex-wrap gap-1">
+                        {RELAY_BANDS.map((b) => {
+                          const on = r.bands.includes(b);
+                          return (
+                            <button key={b} type="button" onClick={() => toggleBand(dev.id, relay, b)}
+                              className={cn('px-1.5 py-0.5 rounded text-[11px] font-mono border transition-colors',
+                                on ? 'bg-primary text-primary-foreground border-primary' : 'border-border text-muted-foreground hover:bg-muted')}>
+                              {b}
+                            </button>
+                          );
+                        })}
+                      </div>
+                    )}
+                  </div>
+                </div>
+              );
+            })}
+          </div>
+        </div>
+      ))}
+    </div>
+  );
+}
+
 // MainViewPanes lets the operator choose what the Main tab's left and right
 // panes show, independently: the great-circle map, the locator street map, the
 // cluster grid or the worked-before grid. Per-profile (stored via SetUIPref,
 // which is profile-prefixed). Self-contained so it owns its async-loaded state.
-const MAIN_PANE_OPTIONS: { value: string; label: string }[] = [
+const MAIN_PANE_VALUES = ['map1', 'map2', 'cluster', 'worked', 'recent', 'netcontrol'];
-  { value: 'map1', label: 'Map — great-circle + beam' },
-  { value: 'map2', label: 'Map — locator (street)' },
-  { value: 'cluster', label: 'Cluster spots' },
-  { value: 'worked', label: 'Worked before' },
-  { value: 'recent', label: 'Recent QSOs' },
-  { value: 'netcontrol', label: 'Net control' },
-];
 function MainViewPanes({ onChanged, flexAvailable, icomAvailable }: { onChanged?: (side: 'left' | 'right', value: string) => void; flexAvailable?: boolean; icomAvailable?: boolean }) {
+  const { t } = useI18n();
   const [left, setLeft] = useState('map1');
   const [right, setRight] = useState('map2');
   // Radio-control panes are only offered when that CAT backend is active. Sorted A→Z.
   const options = [
-    ...MAIN_PANE_OPTIONS,
+    ...MAIN_PANE_VALUES,
-    ...(flexAvailable ? [{ value: 'flex', label: 'FlexRadio controls' }] : []),
+    ...(flexAvailable ? ['flex'] : []),
-    ...(icomAvailable ? [{ value: 'icom', label: 'Icom console' }] : []),
+    ...(icomAvailable ? ['icom'] : []),
-  ].sort((a, b) => a.label.localeCompare(b.label));
+  ].map((value) => ({ value, label: t(`settings.pane.${value}`) }))
+    .sort((a, b) => a.label.localeCompare(b.label));
   useEffect(() => {
-    const valid = (v: string) => v === 'flex' || v === 'icom' || MAIN_PANE_OPTIONS.some((o) => o.value === v);
+    const valid = (v: string) => v === 'flex' || v === 'icom' || MAIN_PANE_VALUES.includes(v);
     Promise.all([GetUIPref('mainPaneLeft').catch(() => ''), GetUIPref('mainPaneRight').catch(() => '')])
       .then(([l, r]) => { if (valid(l)) setLeft(l); if (valid(r)) setRight(r); });
   }, []);
@@ -609,11 +782,11 @@ function MainViewPanes({ onChanged, flexAvailable, icomAvailable }: { onChanged?
   };
   return (
     <div className="border-t border-border/60 pt-4 space-y-2">
-      <h4 className="text-sm font-semibold text-foreground">Main view</h4>
+      <h4 className="text-sm font-semibold text-foreground">{t('settings.mainView')}</h4>
-      <p className="text-xs text-muted-foreground">Choose what the Main tab shows on each side (per profile).</p>
+      <p className="text-xs text-muted-foreground">{t('settings.mainViewHint')}</p>
       <div className="grid grid-cols-2 gap-3 max-w-xl">
         <label className="flex flex-col gap-1 text-xs">
-          <span className="text-muted-foreground">Left pane</span>
+          <span className="text-muted-foreground">{t('settings.leftPane')}</span>
           <Select value={left} onValueChange={(v) => pick('left', v)}>
             <SelectTrigger className="h-8 text-xs"><SelectValue /></SelectTrigger>
             <SelectContent>
@@ -622,7 +795,7 @@ function MainViewPanes({ onChanged, flexAvailable, icomAvailable }: { onChanged?
           </Select>
         </label>
         <label className="flex flex-col gap-1 text-xs">
-          <span className="text-muted-foreground">Right pane</span>
+          <span className="text-muted-foreground">{t('settings.rightPane')}</span>
           <Select value={right} onValueChange={(v) => pick('right', v)}>
             <SelectTrigger className="h-8 text-xs"><SelectValue /></SelectTrigger>
             <SelectContent>
@@ -912,6 +1085,7 @@ export function SettingsModal({ onClose, onSaved, initialSection, onMainPaneChan
   const [showBeamMap, setShowBeamMap] = useState(() => localStorage.getItem('opslog.showBeamOnMap') !== '0');
   const [startEqEnd, setStartEqEnd] = useState(() => localStorage.getItem('opslog.startEqualsEnd') === '1');
   const [lookupOnBlur, setLookupOnBlur] = useState(() => localStorage.getItem('opslog.lookupOnBlur') === '1');
+  const [showQsoRate, setShowQsoRate] = useState(() => localStorage.getItem('opslog.showQsoRate') === '1');
   const [catModeBeforeFreq, setCatModeBeforeFreq] = useState(() => localStorage.getItem('opslog.catModeBeforeFreq') === '1');
   // Password-encryption (secret vault) state.
   const [secret, setSecret] = useState<{ has_passphrase: boolean; unlocked: boolean }>({ has_passphrase: false, unlocked: false });
@@ -4197,6 +4371,10 @@ export function SettingsModal({ onClose, onSaved, initialSection, onMainPaneChan
             <Checkbox checked={startEqEnd} onCheckedChange={(c) => { const v = !!c; setStartEqEnd(v); writeUiPref('opslog.startEqualsEnd', v ? '1' : '0'); }} />
             {t('gen.startEqEnd')} <span className="text-xs text-muted-foreground">{t('gen.startEqEndHint')}</span>
           </label>
+          <label className="flex items-center gap-2 text-sm cursor-pointer">
+            <Checkbox checked={showQsoRate} onCheckedChange={(c) => { const v = !!c; setShowQsoRate(v); writeUiPref('opslog.showQsoRate', v ? '1' : '0'); }} />
+            {t('gen.showQsoRate')} <span className="text-xs text-muted-foreground">{t('gen.showQsoRateHint')}</span>
+          </label>
           <label className="flex items-center gap-2 text-sm cursor-pointer">
             <Checkbox checked={lookupOnBlur} onCheckedChange={(c) => { const v = !!c; setLookupOnBlur(v); writeUiPref('opslog.lookupOnBlur', v ? '1' : '0'); }} />
             {t('gen.lookupOnBlur')} <span className="text-xs text-muted-foreground">{t('gen.lookupOnBlurHint')}</span>
@@ -4449,6 +4627,11 @@ export function SettingsModal({ onClose, onSaved, initialSection, onMainPaneChan
     'lists-modes':  ModesPanel,
     cluster:        ClusterPanel,
     udp:            UDPIntegrationsPanelWrapper,
+    // Rendered as a real element (not called as a bare function) so its own hooks
+    // — useState/useEffect/useI18n — get a proper component context; PANELS[x]()
+    // is a plain call and hook-holding panels must go through JSX like this.
+    adifmon:        () => <ADIFMonitorPanel />,
+    relayauto:      () => <RelayAutoPanel />,
     backup:         BackupPanel,
     database:       DatabasePanel,
     uscounties:     USCountiesPanel,

frontend/src/lib/i18n.tsx

@@ -14,6 +14,7 @@ type Dict = Record<string, string>;
 const en: Dict = {
   // Menu bar
   'prop.title': 'Propagation', 'prop.geomag': 'Geomag', 'prop.refresh': 'Refresh space weather',
+  'rate.title': 'QSO rate (QSOs/hour) — projected from the last 10 / 60 minutes',
   'lotw.userTip': 'LoTW user — last upload {date} ({days} days ago)',
   'menu.file': 'File', 'menu.edit': 'Edit', 'menu.view': 'View', 'menu.tools': 'Tools',
   'file.import': 'Import ADIF…', 'file.export': 'Export ADIF…', 'file.exporting': 'Exporting…',
@@ -80,6 +81,17 @@ const en: Dict = {
   'offline.synced': '{n} QSO(s) added to the logbook',
   'offline.stillDown': 'Database still unreachable — your QSOs are safe',
   'settings.theme': 'Theme', 'settings.themeHint': 'Interface colour theme.',
+  'settings.telemetry': 'Send anonymous usage statistics',
+  'settings.telemetryHint': 'install ID + version + OS, once a day — no callsign or QSO data',
+  'settings.liveStatus': 'Publish live operator status',
+  'settings.liveStatusHint': 'multi-op on shared MySQL — feeds a QRZ live page',
+  'settings.mainView': 'Main view',
+  'settings.mainViewHint': 'Choose what the Main tab shows on each side (per profile).',
+  'settings.leftPane': 'Left pane', 'settings.rightPane': 'Right pane',
+  'settings.pane.map1': 'Map — great-circle + beam', 'settings.pane.map2': 'Map — locator (street)',
+  'settings.pane.cluster': 'Cluster spots', 'settings.pane.worked': 'Worked before',
+  'settings.pane.recent': 'Recent QSOs', 'settings.pane.netcontrol': 'Net control',
+  'settings.pane.flex': 'FlexRadio controls', 'settings.pane.icom': 'Icom console',
   'theme.auto': 'Auto (system)', 'theme.light-warm': 'Warm light', 'theme.light-cool': 'Cool light',
   'theme.light-sage': 'Sage light', 'theme.dim-slate': 'Dim slate', 'theme.dark-warm': 'Warm dark',
   'theme.dark-graphite': 'Graphite dark', 'theme.high-contrast': 'High contrast',
@@ -90,6 +102,13 @@ const en: Dict = {
   'sec.general': 'General', 'sec.email': 'E-mail (SMTP)', 'sec.lookup': 'Callsign Lookup',
   'sec.bands': 'Bands', 'sec.modes': 'Modes & default RST', 'sec.cluster': 'DX Cluster',
   'sec.udp': 'UDP integrations', 'sec.database': 'Database', 'sec.autostart': 'Autostart', 'sec.backup': 'Database backup', 'sec.uscounties': 'US Counties',
+  'sec.adifmon': 'ADIF monitor',
+  'adifmon.hint': 'Watch external ADIF files and import new QSOs automatically — e.g. fldigi logging RTTY, or N1MM/VarAC. Imported QSOs are enriched, de-duplicated and uploaded to your external services just like a QSO logged here.',
+  'adifmon.enable': 'Enable ADIF monitor',
+  'adifmon.empty': 'No file watched yet. Add an ADIF file below.',
+  'adifmon.add': 'Add ADIF file…',
+  'adifmon.remove': 'Stop watching this file',
+  'adifmon.note': 'A newly added file starts from its current end — QSOs already in it are NOT imported, only contacts logged after you add it.',
   'uscty.title': 'US Counties (USA-CA)',
   'uscty.intro': 'Resolve a US callsign to its county and grid offline, from the FCC ULS licence database. This powers the US Counties award and county hunting — including on CW/SSB, where a spot carries only a callsign.',
   'uscty.needDownload': 'County resolution requires downloading the FCC database first (about 150 MB, stored locally). Nothing is resolved until you download it.',
@@ -106,11 +125,19 @@ const en: Dict = {
   'station.title': 'Station Control', 'station.rotator': 'Rotator', 'station.rotatorNoRead': 'No heading read', 'station.pattern': 'Pattern', 'station.bi': 'Bi', 'station.retract': 'Retract elements', 'station.moving': 'MOVING', 'station.elements': 'Elements (mm)', 'station.read': 'Read', 'station.readLengths': 'Read current element lengths from the controller', 'station.noLengths': 'Lengths unknown — click Read to fetch them from the controller.', 'station.element': 'Element', 'station.reflector': 'Reflector', 'station.driven': 'Driven', 'station.director': 'Dir', 'station.set': 'Set', 'station.elementsHint': 'Each press lengthens/shortens the element by 2 mm (like the physical console). Verify which element responds on your antenna.', 'station.setExactLen': 'Click to type the exact current length (fixes the baseline if the auto-read is off).', 'station.atMax': 'Controller refused — the element is likely at its maximum length for this band, so it can\'t extend further.', 'station.go': 'Go', 'station.stop': 'Stop', 'station.dragHint': 'Drag a widget by its card to reorder. Pick a column count to lay them out in a grid.', 'station.colsAuto': 'Auto', 'station.addDevice': 'Add device', 'station.editDevice': 'Edit device', 'station.empty': 'No relay boards yet. Add a WebSwitch 1216H or a KMTronic 8-relay board to control your station power and accessories.', 'station.online': 'Online', 'station.offline': 'Offline', 'station.edit': 'Edit', 'station.delete': 'Delete', 'station.relay': 'Relay', 'station.on': 'ON', 'station.off': 'OFF', 'station.type': 'Device type', 'station.name': 'Name', 'station.host': 'Host / IP', 'station.user': 'Username', 'station.pass': 'Password', 'station.optional': 'optional', 'station.labels': 'Relay labels', 'station.cancel': 'Cancel', 'station.save': 'Save',
   'sec.awards': 'Awards', 'sec.cat': 'CAT interface', 'sec.rotator': 'Rotator', 'sec.winkeyer': 'CW Keyer',
   'sec.antenna': 'Ultrabeam / Steppir', 'sec.antgenius': 'Antenna Genius', 'sec.pgxl': 'Power Genius', 'sec.flex': 'FlexRadio', 'sec.audio': 'Audio devices',
+  'sec.relayauto': 'Relay auto-control',
+  'relayauto.hint': 'Automatically switch Station Control relays from the rig frequency / band (like PstRotator). Each relay: a frequency window (ON inside, OFF outside) or a set of bands. Relays are set up in the Station Control panel.',
+  'relayauto.enable': 'Enable relay auto-control',
+  'relayauto.noDevices': 'No relay board configured. Add one in the Station Control panel first.',
+  'relayauto.relay': 'Relay',
+  'relayauto.modeOff': 'Off (manual)', 'relayauto.modeFreq': 'Frequency', 'relayauto.modeBand': 'Band',
+  'relayauto.from': 'from', 'relayauto.to': 'to',
   // General panel
   'gen.hint': 'App behaviour (saved instantly).',
   'gen.autofocusWB': 'Auto-focus "Worked before" for known stations',
   'gen.showBeam': 'Show the antenna beam heading on the Main map',
   'gen.startEqEnd': 'QSO start time = end time', 'gen.startEqEndHint': '(matches LoTW when you call a while)',
+  'gen.showQsoRate': 'Show QSO rate in the header', 'gen.showQsoRateHint': '(QSOs/hour, projected from the last 10 / 60 min)',
   'gen.lookupOnBlur': 'Look up the callsign only after leaving the field', 'gen.lookupOnBlurHint': '(not while typing)',
   'gen.checkUpdates': 'Check for updates at startup', 'gen.checkUpdatesHint': '(notifies when a newer OpsLog is published)',
   'email.title': 'E-mail',
@@ -297,6 +324,7 @@ const en: Dict = {
 
 const fr: Dict = {
   'prop.title': 'Propagation', 'prop.geomag': 'Géomag', 'prop.refresh': 'Actualiser la météo spatiale',
+  'rate.title': 'Rythme QSO (QSO/heure) — projeté sur les 10 / 60 dernières minutes',
   'lotw.userTip': 'Utilisateur LoTW — dernier upload {date} (il y a {days} j)',
   'menu.file': 'Fichier', 'menu.edit': 'Édition', 'menu.view': 'Affichage', 'menu.tools': 'Outils',
   'file.import': 'Importer ADIF…', 'file.export': 'Exporter ADIF…', 'file.exporting': 'Export…',
@@ -359,6 +387,17 @@ const fr: Dict = {
   'offline.synced': '{n} QSO ajoutés au journal',
   'offline.stillDown': 'Base toujours injoignable — tes QSO sont en sécurité',
   'settings.theme': 'Thème', 'settings.themeHint': "Thème de couleur de l'interface.",
+  'settings.telemetry': "Envoyer des statistiques d'usage anonymes",
+  'settings.telemetryHint': "ID d'installation + version + OS, une fois par jour — aucun indicatif ni donnée QSO",
+  'settings.liveStatus': 'Publier le statut opérateur en direct',
+  'settings.liveStatusHint': 'multi-op sur MySQL partagé — alimente une page live QRZ',
+  'settings.mainView': 'Vue principale',
+  'settings.mainViewHint': "Choisis ce que l'onglet Principal affiche de chaque côté (par profil).",
+  'settings.leftPane': 'Volet gauche', 'settings.rightPane': 'Volet droit',
+  'settings.pane.map1': 'Carte — orthodromie + faisceau', 'settings.pane.map2': 'Carte — locator (rue)',
+  'settings.pane.cluster': 'Spots cluster', 'settings.pane.worked': 'Déjà contactés',
+  'settings.pane.recent': 'QSO récents', 'settings.pane.netcontrol': 'Gestion de net',
+  'settings.pane.flex': 'Contrôles FlexRadio', 'settings.pane.icom': 'Console Icom',
   'theme.auto': 'Auto (système)', 'theme.light-warm': 'Clair chaud', 'theme.light-cool': 'Clair froid',
   'theme.light-sage': 'Clair sauge', 'theme.dim-slate': 'Ardoise tamisé', 'theme.dark-warm': 'Sombre chaud',
   'theme.dark-graphite': 'Sombre graphite', 'theme.high-contrast': 'Contraste élevé',
@@ -368,6 +407,13 @@ const fr: Dict = {
   'sec.general': 'Général', 'sec.email': 'E-mail (SMTP)', 'sec.lookup': "Recherche d'indicatif",
   'sec.bands': 'Bandes', 'sec.modes': 'Modes & RST par défaut', 'sec.cluster': 'DX Cluster',
   'sec.udp': 'Intégrations UDP', 'sec.database': 'Base de données', 'sec.autostart': 'Démarrage auto', 'sec.backup': 'Sauvegarde base', 'sec.uscounties': 'Comtés US',
+  'sec.adifmon': 'Moniteur ADIF',
+  'adifmon.hint': "Surveille des fichiers ADIF externes et importe les nouveaux QSO automatiquement — ex. fldigi en RTTY, ou N1MM/VarAC. Les QSO importés sont enrichis, dédoublonnés et envoyés à tes services externes comme un QSO loggé ici.",
+  'adifmon.enable': 'Activer le moniteur ADIF',
+  'adifmon.empty': 'Aucun fichier surveillé. Ajoute un fichier ADIF ci-dessous.',
+  'adifmon.add': 'Ajouter un fichier ADIF…',
+  'adifmon.remove': 'Ne plus surveiller ce fichier',
+  'adifmon.note': "Un fichier ajouté démarre à sa fin actuelle — les QSO déjà présents ne sont PAS importés, seulement les contacts loggés après l'ajout.",
   'uscty.title': 'Comtés US (USA-CA)',
   'uscty.intro': "Résout un indicatif US en comté et locator, hors-ligne, depuis la base de licences FCC ULS. Ça alimente le diplôme Comtés US et la chasse aux comtés — même en CW/SSB, où le spot ne porte qu'un indicatif.",
   'uscty.needDownload': "La résolution des comtés nécessite d'abord de télécharger la base FCC (environ 150 Mo, stockée en local). Rien n'est résolu tant que tu ne l'as pas téléchargée.",
@@ -384,10 +430,18 @@ const fr: Dict = {
   'station.title': 'Contrôle station', 'station.rotator': 'Rotator', 'station.rotatorNoRead': 'Azimut non lu', 'station.pattern': 'Diagramme', 'station.bi': 'Bi', 'station.retract': 'Rétracter les éléments', 'station.moving': 'EN MOUVEMENT', 'station.elements': 'Éléments (mm)', 'station.read': 'Lire', 'station.readLengths': 'Lire les longueurs actuelles depuis le contrôleur', 'station.noLengths': 'Longueurs inconnues — clique sur Lire pour les récupérer depuis le contrôleur.', 'station.element': 'Élément', 'station.reflector': 'Réflecteur', 'station.driven': 'Radiateur', 'station.director': 'Dir', 'station.set': 'Régler', 'station.elementsHint': "Chaque appui allonge/raccourcit l'élément de 2 mm (comme le pupitre). Vérifie quel élément répond sur ton antenne.", 'station.setExactLen': "Clique pour taper la longueur actuelle exacte (recale la base si la lecture auto est fausse).", 'station.atMax': "Refusé par le contrôleur — l'élément est probablement en butée (longueur max pour cette bande), il ne peut plus s'allonger.", 'station.go': 'Aller', 'station.stop': 'Stop', 'station.dragHint': 'Glisse une carte pour réordonner. Choisis un nombre de colonnes pour la disposition.', 'station.colsAuto': 'Auto', 'station.addDevice': 'Ajouter un appareil', 'station.editDevice': "Modifier l'appareil", 'station.empty': "Aucune carte relais. Ajoute un WebSwitch 1216H ou une carte KMTronic 8 relais pour piloter l'alimentation et les accessoires de ta station.", 'station.online': 'En ligne', 'station.offline': 'Hors ligne', 'station.edit': 'Modifier', 'station.delete': 'Supprimer', 'station.relay': 'Relais', 'station.on': 'ON', 'station.off': 'OFF', 'station.type': "Type d'appareil", 'station.name': 'Nom', 'station.host': 'Hôte / IP', 'station.user': "Nom d'utilisateur", 'station.pass': 'Mot de passe', 'station.optional': 'optionnel', 'station.labels': 'Libellés des relais', 'station.cancel': 'Annuler', 'station.save': 'Enregistrer',
   'sec.awards': 'Diplômes', 'sec.cat': 'Interface CAT', 'sec.rotator': 'Rotator', 'sec.winkeyer': 'Manipulateur CW',
   'sec.antenna': 'Antenne motorisée', 'sec.antgenius': 'Antenna Genius', 'sec.pgxl': 'Power Genius', 'sec.flex': 'FlexRadio', 'sec.audio': 'Périphériques audio',
+  'sec.relayauto': 'Relais automatiques',
+  'relayauto.hint': "Commute automatiquement les relais du Station Control selon la fréquence / bande du poste (comme PstRotator). Par relais : une plage de fréquence (ON dedans, OFF dehors) ou un ensemble de bandes. Les relais se configurent dans le panneau Station Control.",
+  'relayauto.enable': 'Activer les relais automatiques',
+  'relayauto.noDevices': "Aucune carte relais configurée. Ajoutes-en une dans le panneau Station Control d'abord.",
+  'relayauto.relay': 'Relais',
+  'relayauto.modeOff': 'Off (manuel)', 'relayauto.modeFreq': 'Fréquence', 'relayauto.modeBand': 'Bande',
+  'relayauto.from': 'de', 'relayauto.to': 'à',
   'gen.hint': 'Comportement de l\'application (enregistré immédiatement).',
   'gen.autofocusWB': 'Focus auto sur « Déjà contacté » pour les stations connues',
   'gen.showBeam': 'Afficher le cap de l\'antenne sur la carte principale',
   'gen.startEqEnd': 'Heure de début du QSO = heure de fin', 'gen.startEqEndHint': '(correspond à LoTW quand tu appelles un moment)',
+  'gen.showQsoRate': 'Afficher le rythme QSO dans la barre du haut', 'gen.showQsoRateHint': '(QSO/heure, projeté sur les 10 / 60 dernières min)',
   'gen.lookupOnBlur': 'Rechercher l\'indicatif seulement après avoir quitté le champ', 'gen.lookupOnBlurHint': '(pas pendant la saisie)',
   'gen.checkUpdates': 'Vérifier les mises à jour au démarrage', 'gen.checkUpdatesHint': '(prévient quand une version plus récente est publiée)',
   'email.title': 'E-mail',

frontend/src/lib/theme.tsx

@@ -1,5 +1,6 @@
-import { createContext, useContext, useState, useEffect, useCallback, type ReactNode } from 'react';
+import { createContext, useContext, useState, useEffect, useCallback, useRef, type ReactNode } from 'react';
 import { writeUiPref } from './uiPref';
+import { GetUIPref } from '../../wailsjs/go/main/App';
 
 // Theme system. Each choice maps to a `data-theme` value on <html> that the
 // CSS variables in style.css key off of. 'auto' follows the OS light/dark
@@ -49,13 +50,44 @@ export function useTheme(): Ctx { return useContext(ThemeCtx); }
 
 export function ThemeProvider({ children }: { children: ReactNode }) {
   const [theme, setThemeState] = useState<ThemeChoice>(() => readStored());
+  // Set once the operator changes the theme by hand, so the self-heal below
+  // never clobbers a fresh choice with a value it read a moment earlier.
+  const userPicked = useRef(false);
 
   const setTheme = useCallback((t: ThemeChoice) => {
+    userPicked.current = true;
     setThemeState(t);
     applyThemeToDom(t);
     writeUiPref(LS_KEY, t);
   }, []);
 
+  // Self-heal the persisted theme. The synchronous boot read (localStorage) can
+  // miss it when the WebView cleared its storage, OR when syncPortablePrefs ran
+  // while the backend was still starting (settings store not wired yet → GetUIPref
+  // returned "" with no error, so nothing was restored) — the "restart lands on
+  // the light theme sometimes" bug. Re-read the portable pref from the DB once the
+  // backend is up and apply it, retrying briefly to ride out a slow startup.
+  useEffect(() => {
+    let cancelled = false;
+    let tries = 0;
+    const load = () => {
+      tries += 1;
+      GetUIPref(LS_KEY).then((raw) => {
+        if (cancelled || userPicked.current) return;
+        const v = raw as ThemeChoice;
+        if (v && ALL.includes(v)) {
+          try { localStorage.setItem(LS_KEY, v); } catch { /* quota */ }
+          applyThemeToDom(v); // idempotent — safe to call unconditionally
+          setThemeState(v);
+          return; // restored
+        }
+        if (tries < 8) window.setTimeout(load, 300); // empty (unset or backend not ready yet) → retry
+      }).catch(() => { if (!cancelled && tries < 8) window.setTimeout(load, 300); });
+    };
+    load();
+    return () => { cancelled = true; };
+  }, []);
+
   // While in 'auto', re-resolve when the OS light/dark preference flips.
   useEffect(() => {
     if (theme !== 'auto') return;

frontend/src/lib/uiPref.ts

@@ -19,6 +19,7 @@ const PORTABLE_KEYS = [
   'opslog.showRotor',     // rotor compass shown next to the keyers
   'opslog.showBeamOnMap', // antenna beam lobe drawn on the Main map
   'opslog.startEqualsEnd',// log TIME_ON = TIME_OFF (QSO time = completion time)
+  'opslog.showQsoRate',   // QSO-rate meter (10/60 min) shown in the header
   'opslog.catModeBeforeFreq', // send CAT mode before frequency (older rigs)
   'opslog.bandMapBands',  // bands shown side-by-side in the Band Map tab
   'opslog.mapAutoZoomDX', // Main map: auto-zoom to the DX (vs free pan/zoom)

frontend/src/version.ts

@@ -1,6 +1,6 @@
 // Single source of truth for the app version shown in the UI (header + About).
 // Bump this on a release (the release script updates it alongside telemetry.go).
-export const APP_VERSION = '0.19.8';
+export const APP_VERSION = '0.20.0';
 
 // Author / credits, shown in Help -> About.
 export const APP_AUTHOR = 'F4BPO';

frontend/wailsjs/go/main/App.d.ts

@@ -278,6 +278,8 @@ export function FlexSetXITFreq(arg1:number):Promise<void>;
 
 export function FlexTune(arg1:boolean):Promise<void>;
 
+export function GetADIFMonitor():Promise<main.ADIFMonitorConfig>;
+
 export function GetActiveProfile():Promise<profile.Profile>;
 
 export function GetAlertEmailTo():Promise<string>;
@@ -382,6 +384,10 @@ export function GetQSLDefaults():Promise<main.QSLDefaults>;
 
 export function GetQSO(arg1:number):Promise<qso.QSO>;
 
+export function GetQSORate():Promise<main.QSORate>;
+
+export function GetRelayAuto():Promise<main.RelayAutoConfig>;
+
 export function GetRotatorHeading():Promise<main.RotatorHeading>;
 
 export function GetRotatorSettings():Promise<main.RotatorSettings>;
@@ -598,6 +604,8 @@ export function OperatingDefaultForBand(arg1:string):Promise<operating.BandDefau
 
 export function PGXLSetFanMode(arg1:string):Promise<void>;
 
+export function PickADIFMonitorFile():Promise<string>;
+
 export function PickAudioFolder():Promise<string>;
 
 export function PickBackupFolder():Promise<string>;
@@ -688,6 +696,8 @@ export function RunBackupNow():Promise<string>;
 
 export function SaveADIFFile():Promise<string>;
 
+export function SaveADIFMonitor(arg1:main.ADIFMonitorConfig):Promise<void>;
+
 export function SaveAlertRule(arg1:alerts.Rule):Promise<alerts.Rule>;
 
 export function SaveAntGeniusSettings(arg1:main.AntGeniusSettings):Promise<void>;
@@ -732,6 +742,8 @@ export function SaveProfile(arg1:profile.Profile):Promise<profile.Profile>;
 
 export function SaveQSLDefaults(arg1:main.QSLDefaults):Promise<void>;
 
+export function SaveRelayAuto(arg1:main.RelayAutoConfig):Promise<void>;
+
 export function SaveRotatorSettings(arg1:main.RotatorSettings):Promise<void>;
 
 export function SaveStationDevices(arg1:Array<main.StationDevice>):Promise<void>;

frontend/wailsjs/go/main/App.js

@@ -514,6 +514,10 @@ export function FlexTune(arg1) {
   return window['go']['main']['App']['FlexTune'](arg1);
 }
 
+export function GetADIFMonitor() {
+  return window['go']['main']['App']['GetADIFMonitor']();
+}
+
 export function GetActiveProfile() {
   return window['go']['main']['App']['GetActiveProfile']();
 }
@@ -722,6 +726,14 @@ export function GetQSO(arg1) {
   return window['go']['main']['App']['GetQSO'](arg1);
 }
 
+export function GetQSORate() {
+  return window['go']['main']['App']['GetQSORate']();
+}
+
+export function GetRelayAuto() {
+  return window['go']['main']['App']['GetRelayAuto']();
+}
+
 export function GetRotatorHeading() {
   return window['go']['main']['App']['GetRotatorHeading']();
 }
@@ -1154,6 +1166,10 @@ export function PGXLSetFanMode(arg1) {
   return window['go']['main']['App']['PGXLSetFanMode'](arg1);
 }
 
+export function PickADIFMonitorFile() {
+  return window['go']['main']['App']['PickADIFMonitorFile']();
+}
+
 export function PickAudioFolder() {
   return window['go']['main']['App']['PickAudioFolder']();
 }
@@ -1334,6 +1350,10 @@ export function SaveADIFFile() {
   return window['go']['main']['App']['SaveADIFFile']();
 }
 
+export function SaveADIFMonitor(arg1) {
+  return window['go']['main']['App']['SaveADIFMonitor'](arg1);
+}
+
 export function SaveAlertRule(arg1) {
   return window['go']['main']['App']['SaveAlertRule'](arg1);
 }
@@ -1422,6 +1442,10 @@ export function SaveQSLDefaults(arg1) {
   return window['go']['main']['App']['SaveQSLDefaults'](arg1);
 }
 
+export function SaveRelayAuto(arg1) {
+  return window['go']['main']['App']['SaveRelayAuto'](arg1);
+}
+
 export function SaveRotatorSettings(arg1) {
   return window['go']['main']['App']['SaveRotatorSettings'](arg1);
 }

frontend/wailsjs/go/models.ts

@@ -1296,6 +1296,55 @@ export namespace lotwusers {
 
 export namespace main {
 	
+	export class ADIFWatchFile {
+	    path: string;
+	    enabled: boolean;
+	    offset: number;
+	
+	    static createFrom(source: any = {}) {
+	        return new ADIFWatchFile(source);
+	    }
+	
+	    constructor(source: any = {}) {
+	        if ('string' === typeof source) source = JSON.parse(source);
+	        this.path = source["path"];
+	        this.enabled = source["enabled"];
+	        this.offset = source["offset"];
+	    }
+	}
+	export class ADIFMonitorConfig {
+	    enabled: boolean;
+	    files: ADIFWatchFile[];
+	
+	    static createFrom(source: any = {}) {
+	        return new ADIFMonitorConfig(source);
+	    }
+	
+	    constructor(source: any = {}) {
+	        if ('string' === typeof source) source = JSON.parse(source);
+	        this.enabled = source["enabled"];
+	        this.files = this.convertValues(source["files"], ADIFWatchFile);
+	    }
+	
+		convertValues(a: any, classs: any, asMap: boolean = false): any {
+		    if (!a) {
+		        return a;
+		    }
+		    if (a.slice && a.map) {
+		        return (a as any[]).map(elem => this.convertValues(elem, classs));
+		    } else if ("object" === typeof a) {
+		        if (asMap) {
+		            for (const key of Object.keys(a)) {
+		                a[key] = new classs(a[key]);
+		            }
+		            return a;
+		        }
+		        return new classs(a);
+		    }
+		    return a;
+		}
+	}
+	
 	export class AntGeniusSettings {
 	    enabled: boolean;
 	    host: string;
@@ -2329,6 +2378,75 @@ export namespace main {
 	        this.pickable = source["pickable"];
 	    }
 	}
+	export class QSORate {
+	    last10: number;
+	    last60: number;
+	
+	    static createFrom(source: any = {}) {
+	        return new QSORate(source);
+	    }
+	
+	    constructor(source: any = {}) {
+	        if ('string' === typeof source) source = JSON.parse(source);
+	        this.last10 = source["last10"];
+	        this.last60 = source["last60"];
+	    }
+	}
+	export class RelayAutoRule {
+	    device_id: string;
+	    relay: number;
+	    mode: string;
+	    freq_lo_khz: number;
+	    freq_hi_khz: number;
+	    bands: string[];
+	
+	    static createFrom(source: any = {}) {
+	        return new RelayAutoRule(source);
+	    }
+	
+	    constructor(source: any = {}) {
+	        if ('string' === typeof source) source = JSON.parse(source);
+	        this.device_id = source["device_id"];
+	        this.relay = source["relay"];
+	        this.mode = source["mode"];
+	        this.freq_lo_khz = source["freq_lo_khz"];
+	        this.freq_hi_khz = source["freq_hi_khz"];
+	        this.bands = source["bands"];
+	    }
+	}
+	export class RelayAutoConfig {
+	    enabled: boolean;
+	    rules: RelayAutoRule[];
+	
+	    static createFrom(source: any = {}) {
+	        return new RelayAutoConfig(source);
+	    }
+	
+	    constructor(source: any = {}) {
+	        if ('string' === typeof source) source = JSON.parse(source);
+	        this.enabled = source["enabled"];
+	        this.rules = this.convertValues(source["rules"], RelayAutoRule);
+	    }
+	
+		convertValues(a: any, classs: any, asMap: boolean = false): any {
+		    if (!a) {
+		        return a;
+		    }
+		    if (a.slice && a.map) {
+		        return (a as any[]).map(elem => this.convertValues(elem, classs));
+		    } else if ("object" === typeof a) {
+		        if (asMap) {
+		            for (const key of Object.keys(a)) {
+		                a[key] = new classs(a[key]);
+		            }
+		            return a;
+		        }
+		        return new classs(a);
+		    }
+		    return a;
+		}
+	}
+	
 	export class RotatorHeading {
 	    enabled: boolean;
 	    ok: boolean;

internal/qso/qso.go

@@ -1863,6 +1863,40 @@ func (r *Repo) Count(ctx context.Context) (int64, error) {
 	return n, err
 }
 
+// RecentRate counts QSOs whose start time falls within each trailing window from
+// `now` — the live "QSO rate" meter shown in the header. It scans only the most
+// recently inserted rows (ORDER BY id DESC LIMIT), since any QSO in the last hour
+// was inserted recently; that keeps it cheap even on a large log. qso_date is the
+// repo's text column, parsed with parseTimeLoose (backend-format agnostic).
+func (r *Repo) RecentRate(ctx context.Context, now time.Time, windows ...time.Duration) ([]int, error) {
+	counts := make([]int, len(windows))
+	// 400 rows covers a full hour even at a blistering contest rate (>300/h); any
+	// QSO inside the trailing windows is among the most recently inserted.
+	rows, err := r.db.QueryContext(ctx, `SELECT qso_date FROM qso ORDER BY id DESC LIMIT 400`)
+	if err != nil {
+		return counts, err
+	}
+	defer rows.Close()
+	now = now.UTC()
+	for rows.Next() {
+		var dateStr sql.NullString
+		if err := rows.Scan(&dateStr); err != nil {
+			return counts, err
+		}
+		t := parseTimeLoose(dateStr.String).UTC()
+		if t.IsZero() || t.After(now) {
+			continue
+		}
+		age := now.Sub(t)
+		for i, w := range windows {
+			if age <= w {
+				counts[i]++
+			}
+		}
+	}
+	return counts, rows.Err()
+}
+
 // ExistingDedupeKeys returns a set of every QSO key currently in the DB,
 // used by the ADIF importer to skip records that would re-create the
 // same contact. The key is callsign|YYYY-MM-DDTHH:MM|band|mode — minute

internal/uls/uls.go

@@ -24,6 +24,7 @@ import (
 	"bufio"
 	"context"
 	"database/sql"
+	"errors"
 	"fmt"
 	"io"
 	"math"
@@ -37,6 +38,10 @@ import (
 	_ "modernc.org/sqlite"
 )
 
+// errFCCMaintenance is raised when the FCC ULS download host bounces us to its
+// maintenance page instead of serving the file (a frequent, FCC-side event).
+var errFCCMaintenance = errors.New("fcc uls under maintenance")
+
 // Default download URLs (overridable in Import for tests).
 const (
 	fccAmateurURL = "https://data.fcc.gov/download/pub/uls/complete/l_amat.zip"
@@ -325,8 +330,26 @@ func download(ctx context.Context, url, dest string, prog func(pct int)) error {
 	if err != nil {
 		return err
 	}
-	resp, err := http.DefaultClient.Do(req)
+	// Catch the FCC maintenance bounce BEFORE following it: data.fcc.gov redirects
+	// to www.fcc.gov/system-maintenance during maintenance windows, and that page
+	// then HTTP/2-stream-errors — which surfaced as a cryptic "INTERNAL_ERROR"
+	// instead of a plain "try again later".
+	client := &http.Client{
+		CheckRedirect: func(r *http.Request, via []*http.Request) error {
+			if strings.Contains(r.URL.String(), "system-maintenance") {
+				return errFCCMaintenance
+			}
+			if len(via) >= 10 {
+				return errors.New("stopped after 10 redirects")
+			}
+			return nil
+		},
+	}
+	resp, err := client.Do(req)
 	if err != nil {
+		if errors.Is(err, errFCCMaintenance) || strings.Contains(err.Error(), "system-maintenance") {
+			return fmt.Errorf("the FCC ULS download service is under maintenance (fcc.gov redirected to its maintenance page) — please try again later")
+		}
 		return err
 	}
 	defer resp.Body.Close()

relayauto.go

@@ -0,0 +1,154 @@
+package main
+
+// Relay auto-control: drives the Station Control relay boards automatically from
+// the rig's current frequency / band — the equivalent of PstRotator's "Automatic
+// Control". Each relay carries at most one rule:
+//   - "freq": ON while the frequency is inside [lo,hi] kHz, OFF otherwise;
+//   - "band": ON while the current band is one of the listed bands, OFF otherwise;
+//   - "off"/empty: not managed (left to manual control).
+//
+// Evaluated on every CAT frequency/band change. A relay is only switched when its
+// desired state actually changed since the last apply, so a slow relay board isn't
+// hammered while you tune within the same range.
+
+import (
+	"encoding/json"
+	"fmt"
+	"strconv"
+	"strings"
+
+	wruntime "github.com/wailsapp/wails/v2/pkg/runtime"
+
+	"hamlog/internal/applog"
+)
+
+const keyRelayAuto = "relayauto.config"
+
+// RelayAutoRule is one relay's automatic-control rule.
+type RelayAutoRule struct {
+	DeviceID  string   `json:"device_id"`
+	Relay     int      `json:"relay"` // 1-based
+	Mode      string   `json:"mode"`  // "off" | "freq" | "band"
+	FreqLoKHz float64  `json:"freq_lo_khz"`
+	FreqHiKHz float64  `json:"freq_hi_khz"`
+	Bands     []string `json:"bands"`
+}
+
+// RelayAutoConfig is the whole auto-control setup: a master switch + the rules.
+type RelayAutoConfig struct {
+	Enabled bool            `json:"enabled"`
+	Rules   []RelayAutoRule `json:"rules"`
+}
+
+// GetRelayAuto returns the relay auto-control configuration for the settings UI.
+func (a *App) GetRelayAuto() RelayAutoConfig {
+	var cfg RelayAutoConfig
+	if a.settings == nil {
+		return cfg
+	}
+	s, _ := a.settings.GetGlobal(a.ctx, keyRelayAuto)
+	if strings.TrimSpace(s) != "" {
+		_ = json.Unmarshal([]byte(s), &cfg)
+	}
+	return cfg
+}
+
+// SaveRelayAuto persists the configuration and applies it immediately from the
+// current rig state, so toggling a rule takes effect without waiting for the next
+// frequency change.
+func (a *App) SaveRelayAuto(cfg RelayAutoConfig) error {
+	if a.settings == nil {
+		return fmt.Errorf("db not initialized")
+	}
+	b, err := json.Marshal(cfg)
+	if err != nil {
+		return err
+	}
+	if err := a.settings.SetGlobal(a.ctx, keyRelayAuto, string(b)); err != nil {
+		return err
+	}
+	a.relayAutoOn.Store(cfg.Enabled) // keep the CAT hot-path flag in sync
+	// Re-apply from the live frequency so a just-changed rule takes hold now. Also
+	// forget the last-applied cache so a rule the user just switched to "off" and
+	// back gets re-sent even if the value is unchanged.
+	a.relayAutoMu.Lock()
+	a.relayAutoLast = map[string]bool{}
+	a.relayAutoMu.Unlock()
+	if a.cat != nil {
+		st := a.cat.State()
+		go a.applyRelayAuto(st.FreqHz, st.Band)
+	}
+	return nil
+}
+
+func relayAutoKey(dev string, relay int) string { return dev + "|" + strconv.Itoa(relay) }
+
+func bandInList(bands []string, band string) bool {
+	band = strings.ToLower(strings.TrimSpace(band))
+	if band == "" {
+		return false
+	}
+	for _, b := range bands {
+		if strings.ToLower(strings.TrimSpace(b)) == band {
+			return true
+		}
+	}
+	return false
+}
+
+// applyRelayAuto evaluates every rule against the current frequency/band and
+// switches only the relays whose desired state changed since the last apply.
+func (a *App) applyRelayAuto(freqHz int64, band string) {
+	a.relayAutoMu.Lock()
+	defer a.relayAutoMu.Unlock()
+
+	cfg := a.GetRelayAuto()
+	if !cfg.Enabled || len(cfg.Rules) == 0 {
+		return
+	}
+	if a.relayAutoLast == nil {
+		a.relayAutoLast = map[string]bool{}
+	}
+	khz := float64(freqHz) / 1000.0
+
+	changed := false
+	for _, r := range cfg.Rules {
+		if r.Relay < 1 {
+			continue
+		}
+		var want bool
+		switch r.Mode {
+		case "freq":
+			if r.FreqLoKHz <= 0 && r.FreqHiKHz <= 0 {
+				continue // unconfigured range → leave the relay alone
+			}
+			lo, hi := r.FreqLoKHz, r.FreqHiKHz
+			if hi < lo {
+				lo, hi = hi, lo
+			}
+			want = khz >= lo && khz <= hi
+		case "band":
+			if len(r.Bands) == 0 {
+				continue
+			}
+			want = bandInList(r.Bands, band)
+		default:
+			continue // "off"/empty → not managed
+		}
+
+		key := relayAutoKey(r.DeviceID, r.Relay)
+		if last, ok := a.relayAutoLast[key]; ok && last == want {
+			continue // no change → don't hammer the board
+		}
+		if err := a.StationSetRelay(r.DeviceID, r.Relay, want); err != nil {
+			applog.Printf("relay auto: set %s relay %d = %v failed: %v", r.DeviceID, r.Relay, want, err)
+			continue // don't cache a failed write — retry next change
+		}
+		a.relayAutoLast[key] = want
+		changed = true
+	}
+
+	if changed && a.ctx != nil {
+		wruntime.EventsEmit(a.ctx, "station:relay_auto", nil) // nudge the Station Control UI to re-poll
+	}
+}

telemetry.go

@@ -21,7 +21,7 @@ import (
 
 const (
 	// appVersion is stamped on every heartbeat (and could feed the About box).
-	appVersion = "0.19.8"
+	appVersion = "0.20.0"
 
 	// posthogHost is the PostHog ingestion endpoint. EU cloud by default; change
 	// to https://us.i.posthog.com for a US project.