feat: header rate/propagation colours + CW macro word space

Header: colour the propagation indices semantically (SFI/SSN green when
strong; A/K green quiet → yellow unsettled → red storm) and glow the QSO-rate
numbers the brand accent when active, dim to muted when idle.

WinKeyer/Icom CW: append a trailing word space to each macro send so two
macros fired back-to-back don't run together in the keyer buffer ("CQ"+"TEST"
→ "CQTEST"). The keyer keys the space at the current speed, so it scales with
WPM. Only the macro path is affected — send-on-type stays per-character.

app.go

@@ -4501,6 +4501,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) {
@@ -7825,7 +7846,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,
@@ -1085,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);
@@ -1993,17 +2008,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,
@@ -3738,6 +3757,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
@@ -3749,6 +3791,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>
@@ -3756,15 +3806,16 @@ export default function App() {
                   </span>
                 );
                 return (<>
-                  {it('SFI', solar.sfi)}
-                  {it('SSN', solar.ssn)}
-                  {it('A', solar.a_index)}
-                  {it('K', solar.k_index)}
+                  {it('SFI', solar.sfi, sfiCls(solar.sfi))}
+                  {it('SSN', solar.ssn, ssnCls(solar.ssn))}
+                  {it('A', solar.a_index, aCls(solar.a_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/SettingsModal.tsx

@@ -909,6 +909,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 });
@@ -4194,6 +4195,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>

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…',
@@ -122,6 +123,7 @@ const en: Dict = {
   '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',
@@ -308,6 +310,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…',
@@ -410,6 +413,7 @@ const fr: Dict = {
   '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/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/wailsjs/go/main/App.d.ts

@@ -382,6 +382,8 @@ export function GetQSLDefaults():Promise<main.QSLDefaults>;
 
 export function GetQSO(arg1:number):Promise<qso.QSO>;
 
+export function GetQSORate():Promise<main.QSORate>;
+
 export function GetRotatorHeading():Promise<main.RotatorHeading>;
 
 export function GetRotatorSettings():Promise<main.RotatorSettings>;

frontend/wailsjs/go/main/App.js

@@ -722,6 +722,10 @@ export function GetQSO(arg1) {
   return window['go']['main']['App']['GetQSO'](arg1);
 }
 
+export function GetQSORate() {
+  return window['go']['main']['App']['GetQSORate']();
+}
+
 export function GetRotatorHeading() {
   return window['go']['main']['App']['GetRotatorHeading']();
 }

frontend/wailsjs/go/models.ts

@@ -2329,6 +2329,20 @@ 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 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()