chore: release v0.20.4

The File menu's Exit item was hard-disabled and its action had no case in the
menu dispatcher, so it did nothing. Enable it and route file.exit to QuitApp,
which runs the same graceful beforeClose shutdown as the window close button.

app.go

@@ -812,6 +812,7 @@ func (a *App) startup(ctx context.Context) {
 	applog.Printf("startup: logbook backend = %s", backend)
 	a.logDb = logbookConn
 	a.qso = qso.NewRepo(logbookConn)
+	a.backfillAwardRefsOnce() // one-time: materialise award_refs for pre-existing QSOs
 	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
@@ -1873,6 +1874,7 @@ func (a *App) AddQSO(q qso.QSO) (id int64, err error) {
 		q.ID = id
 		a.noteWorked(q.Callsign, q.Band, q.Mode) // keep the alert worked-index fresh
 		a.noteLiveQSO()                           // multi-op: flip this operator back "online"
+		a.materializeAwardRefs(q)                 // stamp award_refs so the grid columns show at once
 		// Announce the log so UI widgets can react (e.g. the Flex panel zeroing RIT).
 		wruntime.EventsEmit(a.ctx, "qso:logged", id)
 		a.saveQSORecording(&q)
@@ -2515,6 +2517,7 @@ func (a *App) SaveAwardDefs(defs []award.Def) error {
 		return err
 	}
 	go a.mirrorAwardsToFolder(defs)
+	a.recomputeAwardRefsAsync() // definitions changed → refresh every row's award_refs
 	return nil
 }
 
@@ -3639,71 +3642,224 @@ func (a *App) ComputeQSOAwardRefs(q qso.QSO) ([]QSOAwardRef, error) {
 	return out, nil
 }
 
-// AwardRefsForQSOs returns, per QSO id, a map of award code → the reference(s)
-// that QSO contributes to (joined when several). Powers the per-award columns in
-// the Recent QSOs / Worked-before grids. The reference metadata is computed ONCE
-// for the whole batch so a page of QSOs stays cheap.
-func (a *App) AwardRefsForQSOs(ids []int64) (map[int64]map[string]string, error) {
-	out := map[int64]map[string]string{}
-	if a.qso == nil || len(ids) == 0 {
-		return out, nil
-	}
+// awardMatCtx bundles the precompiled award state needed to derive a QSO's
+// materialised references. Built ONCE (newAwardMatCtx) and reused across a batch
+// or a full recompute so award.Compute's per-pattern compilation isn't repeated.
+type awardMatCtx struct {
+	defs        []award.Def
+	metas       map[string][]award.RefMeta
+	fieldByCode map[string]string
+	dispByCode  map[string]string
+	nameOf      award.NameResolver
+}
+
+func (a *App) newAwardMatCtx() awardMatCtx {
 	defs := a.awardDefs()
-	metas := a.awardRefMetas(defs)
 	fieldByCode := map[string]string{}
 	dispByCode := map[string]string{}
 	for _, d := range defs {
 		fieldByCode[strings.ToUpper(d.Code)] = strings.ToLower(strings.TrimSpace(d.Field))
 		dispByCode[strings.ToUpper(d.Code)] = strings.ToLower(strings.TrimSpace(d.RefDisplay))
 	}
-	nameOf := func(field, ref string) string {
-		switch field {
-		case "dxcc":
-			if n, err := strconv.Atoi(ref); err == nil {
-				return dxcc.NameForDXCC(n)
+	return awardMatCtx{
+		defs:        defs,
+		metas:       a.awardRefMetas(defs),
+		fieldByCode: fieldByCode,
+		dispByCode:  dispByCode,
+		nameOf: func(field, ref string) string {
+			switch field {
+			case "dxcc":
+				if n, err := strconv.Atoi(ref); err == nil {
+					return dxcc.NameForDXCC(n)
+				}
+			case "cont":
+				return continentName(ref)
 			}
-		case "cont":
-			return continentName(ref)
+			return ""
+		},
+	}
+}
+
+// awardRefLabels derives, for one QSO, the map of award code → the reference(s)
+// that QSO contributes to (joined when several), formatted per the award's
+// RefDisplay choice (ref / name / both; DXCC shows the country name by default).
+func (a *App) awardRefLabels(ac awardMatCtx, q qso.QSO) map[string]string {
+	a.enrichQSOForAwards(&q)
+	results := award.Compute(ac.defs, []qso.QSO{q}, ac.metas, ac.nameOf)
+	m := map[string]string{}
+	for i := range results {
+		r := &results[i]
+		code := strings.ToUpper(r.Code)
+		dxccField := ac.fieldByCode[code] == "dxcc"
+		var refs []string
+		for _, rf := range r.Refs {
+			if !rf.Worked {
+				continue
+			}
+			label := rf.Ref
+			switch ac.dispByCode[code] {
+			case "name":
+				if rf.Name != "" {
+					label = rf.Name
+				}
+			case "both":
+				if rf.Name != "" {
+					label = rf.Ref + " — " + rf.Name
+				}
+			default: // "" or "ref"
+				if dxccField && rf.Name != "" {
+					label = rf.Name
+				}
+			}
+			refs = append(refs, label)
 		}
+		if len(refs) > 0 {
+			m[code] = strings.Join(refs, ", ")
+		}
+	}
+	return m
+}
+
+// awardRefsJSONFor returns awardRefLabels marshalled to a compact JSON object
+// keyed by award code, or "" when the QSO contributes to no award (blank column).
+func (a *App) awardRefsJSONFor(ac awardMatCtx, q qso.QSO) string {
+	m := a.awardRefLabels(ac, q)
+	if len(m) == 0 {
 		return ""
 	}
+	b, err := json.Marshal(m)
+	if err != nil {
+		return ""
+	}
+	return string(b)
+}
+
+// materializeAwardRefs computes ONE QSO's award references and stores them on the
+// row (the award_refs column) so the grid columns read them straight from the DB.
+// Cheap: an in-memory award.Compute plus one targeted UPDATE. Called on every
+// log / edit / UDP-import. Never fatal — a failure just leaves the column stale
+// until the next recompute.
+func (a *App) materializeAwardRefs(q qso.QSO) {
+	if a.qso == nil || q.ID == 0 {
+		return
+	}
+	ac := a.newAwardMatCtx()
+	if err := a.qso.SetAwardRefs(a.ctx, q.ID, a.awardRefsJSONFor(ac, q)); err != nil {
+		applog.Printf("award_refs: store for qso %d failed: %v", q.ID, err)
+	}
+}
+
+// materializeAwardRefsForIDs recomputes award_refs for a specific set of QSOs
+// (e.g. after a bulk cty/QRZ/Club Log update or a bulk edit changed fields that
+// feed awards). Writes only the changed rows, in one transaction.
+func (a *App) materializeAwardRefsForIDs(ids []int64) {
+	if a.qso == nil || len(ids) == 0 {
+		return
+	}
+	ac := a.newAwardMatCtx()
+	changes := map[int64]string{}
 	err := a.qso.IterateByIDs(a.ctx, ids, func(q qso.QSO) error {
-		a.enrichQSOForAwards(&q)
-		results := award.Compute(defs, []qso.QSO{q}, metas, nameOf)
-		m := map[string]string{}
-		for i := range results {
-			r := &results[i]
-			code := strings.ToUpper(r.Code)
-			dxccField := fieldByCode[code] == "dxcc"
-			var refs []string
-			for _, rf := range r.Refs {
-				if !rf.Worked {
-					continue
-				}
-				// Per-award display choice: ref (default), name (description), or
-				// both. DXCC keeps showing the country name under the default.
-				label := rf.Ref
-				switch dispByCode[code] {
-				case "name":
-					if rf.Name != "" {
-						label = rf.Name
-					}
-				case "both":
-					if rf.Name != "" {
-						label = rf.Ref + " — " + rf.Name
-					}
-				default: // "" or "ref"
-					if dxccField && rf.Name != "" {
-						label = rf.Name
-					}
-				}
-				refs = append(refs, label)
-			}
-			if len(refs) > 0 {
-				m[code] = strings.Join(refs, ", ")
-			}
+		if js := a.awardRefsJSONFor(ac, q); js != q.AwardRefs {
+			changes[q.ID] = js
 		}
-		if len(m) > 0 {
+		return nil
+	})
+	if err != nil {
+		applog.Printf("award_refs: recompute for ids failed: %v", err)
+		return
+	}
+	if err := a.qso.SetAwardRefsBatch(a.ctx, changes); err != nil {
+		applog.Printf("award_refs: batch write for ids failed: %v", err)
+	}
+}
+
+// RecomputeAllAwardRefs rebuilds every QSO's materialised award references. Run
+// when an award definition or reference list changes (stored labels would
+// otherwise go stale) and once after upgrade to backfill existing rows. Rows
+// whose result is unchanged are skipped; the changed ones are written in a single
+// transaction (SetAwardRefsBatch) so even a large logbook on a remote MySQL is
+// one round-trip's worth of work rather than N. Returns how many rows changed.
+func (a *App) RecomputeAllAwardRefs() (int, error) {
+	if a.qso == nil {
+		return 0, fmt.Errorf("db not initialized")
+	}
+	ac := a.newAwardMatCtx()
+	// Collect updates during the scan; DON'T write mid-iteration (a nested query on
+	// the same connection can deadlock SQLite / trip MySQL "commands out of sync").
+	changes := map[int64]string{}
+	err := a.qso.IterateAll(a.ctx, func(q qso.QSO) error {
+		if js := a.awardRefsJSONFor(ac, q); js != q.AwardRefs {
+			changes[q.ID] = js
+		}
+		return nil
+	})
+	if err != nil {
+		return 0, err
+	}
+	if err := a.qso.SetAwardRefsBatch(a.ctx, changes); err != nil {
+		return 0, err
+	}
+	return len(changes), nil
+}
+
+// recomputeAwardRefsAsync runs a full recompute off the UI goroutine and, when
+// done, tells the frontend to reload so the refreshed award columns show. Used
+// wherever the set of matches could shift for MANY rows at once: an award
+// definition / reference-list change, or a bulk ADIF import.
+func (a *App) recomputeAwardRefsAsync() {
+	go func() {
+		n, err := a.RecomputeAllAwardRefs()
+		if err != nil {
+			applog.Printf("award_refs: bulk recompute failed: %v", err)
+			return
+		}
+		if a.ctx != nil {
+			wruntime.EventsEmit(a.ctx, "awards:recomputed", n)
+		}
+	}()
+}
+
+// keyAwardsMaterialized marks (per profile / logbook) that the one-time award_refs
+// backfill has run, so it doesn't re-scan the whole logbook on every launch.
+const keyAwardsMaterialized = "awards.materialized.v1"
+
+// backfillAwardRefsOnce populates award_refs for QSOs that predate the feature
+// (or were logged by an older client that didn't materialise them). It runs at
+// most once per logbook — guarded by a per-profile flag — in the background so it
+// never delays startup, even on a large remote MySQL logbook.
+func (a *App) backfillAwardRefsOnce() {
+	if a.qso == nil || a.settings == nil {
+		return
+	}
+	if done, _ := a.settings.Get(a.ctx, keyAwardsMaterialized); done == "1" {
+		return
+	}
+	go func() {
+		n, err := a.RecomputeAllAwardRefs()
+		if err != nil {
+			applog.Printf("award_refs: initial backfill failed: %v", err)
+			return
+		}
+		_ = a.settings.Set(a.ctx, keyAwardsMaterialized, "1")
+		applog.Printf("award_refs: backfilled %d QSO(s)", n)
+		if a.ctx != nil && n > 0 {
+			wruntime.EventsEmit(a.ctx, "awards:recomputed", n)
+		}
+	}()
+}
+
+// AwardRefsForQSOs returns, per QSO id, the award code → reference(s) map. It is
+// the live (non-materialised) path, kept for callers that want fresh values
+// without touching the DB. The grid now reads the stored award_refs column
+// instead, but this stays available and is the single source of the label logic.
+func (a *App) AwardRefsForQSOs(ids []int64) (map[int64]map[string]string, error) {
+	out := map[int64]map[string]string{}
+	if a.qso == nil || len(ids) == 0 {
+		return out, nil
+	}
+	ac := a.newAwardMatCtx()
+	err := a.qso.IterateByIDs(a.ctx, ids, func(q qso.QSO) error {
+		if m := a.awardRefLabels(ac, q); len(m) > 0 {
 			out[q.ID] = m
 		}
 		return nil
@@ -3749,6 +3905,17 @@ func (a *App) GetAwardReferenceMeta() ([]AwardRefMeta, error) {
 // UpdateAwardReferenceList downloads the latest reference list for an award and
 // replaces the stored set. Returns the new reference count.
 func (a *App) UpdateAwardReferenceList(code string) (AwardRefMeta, error) {
+	meta, err := a.updateAwardReferenceList(code)
+	if err == nil {
+		a.recomputeAwardRefsAsync() // new reference list → labels change → refresh rows
+	}
+	return meta, err
+}
+
+// updateAwardReferenceList is the recompute-free core, so DownloadAllReferenceLists
+// can update several lists in a loop and trigger ONE bulk recompute at the end
+// rather than one per list.
+func (a *App) updateAwardReferenceList(code string) (AwardRefMeta, error) {
 	if a.awardRefs == nil {
 		return AwardRefMeta{}, fmt.Errorf("db not initialized")
 	}
@@ -3785,7 +3952,7 @@ func (a *App) DownloadAllReferenceLists() (string, error) {
 		if !awardref.CanUpdate(code) {
 			continue
 		}
-		meta, err := a.UpdateAwardReferenceList(code)
+		meta, err := a.updateAwardReferenceList(code)
 		if err != nil {
 			parts = append(parts, fmt.Sprintf("%s ✗", code))
 			if firstErr == nil {
@@ -3795,6 +3962,7 @@ func (a *App) DownloadAllReferenceLists() (string, error) {
 		}
 		parts = append(parts, fmt.Sprintf("%s %d", code, meta.Count))
 	}
+	a.recomputeAwardRefsAsync() // one bulk recompute after all lists updated
 	return strings.Join(parts, " · "), firstErr
 }
 
@@ -3838,6 +4006,7 @@ func (a *App) DeleteAwardReference(code, refCode string) error {
 	}
 	a.markAwardEdited(code)
 	a.mirrorAwards()
+	a.recomputeAwardRefsAsync()
 	return nil
 }
 
@@ -3881,6 +4050,7 @@ func (a *App) ReplaceAwardReferences(code string, refs []awardref.Ref) (int, err
 	}
 	a.markAwardEdited(code)
 	a.mirrorAwards()
+	a.recomputeAwardRefsAsync() // reference list replaced → refresh every row's award_refs
 	return n, nil
 }
 
@@ -4485,6 +4655,7 @@ func (a *App) UpdateQSO(q qso.QSO) error {
 	err := a.qso.Update(a.ctx, q)
 	if err == nil {
 		a.invalidateAwardStats()
+		a.materializeAwardRefs(q) // fields may have changed → refresh award_refs
 	}
 	return err
 }
@@ -4518,31 +4689,31 @@ func (a *App) GetOperators() ([]string, error) {
 // 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"`
+	Last10     int `json:"last10"`      // active operator, last 10 min
+	Last60     int `json:"last60"`      // active operator, last 60 min
+	TeamLast10 int `json:"team_last10"` // ALL operators (the whole station), last 10 min
+	TeamLast60 int `json:"team_last60"` // ALL operators, last 60 min
 }
 
-// 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.
+// GetQSORate returns the number of QSOs logged in the last 10 and 60 minutes, both
+// for the active operator (their own performance) AND for all operators combined
+// (the team/station rate). Cheap (one scan of 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{}
 	}
-	// Per-operator on a shared logbook: count only the ACTIVE profile's operator
-	// so each op sees their own performance, not the cumulative station rate. An
-	// empty operator (single-op / station owner) matches all their QSOs.
 	operator := ""
 	if a.profiles != nil {
 		if p, err := a.profiles.Active(a.ctx); err == nil {
 			operator = p.Operator
 		}
 	}
-	counts, err := a.qso.RecentRate(a.ctx, time.Now(), operator, 10*time.Minute, 60*time.Minute)
-	if err != nil || len(counts) < 2 {
+	op, all, err := a.qso.RecentRateBreakdown(a.ctx, time.Now(), operator, 10*time.Minute, 60*time.Minute)
+	if err != nil || len(op) < 2 || len(all) < 2 {
 		return QSORate{}
 	}
-	return QSORate{Last10: counts[0], Last60: counts[1]}
+	return QSORate{Last10: op[0], Last60: op[1], TeamLast10: all[0], TeamLast60: all[1]}
 }
 
 // GetContestRuns lists the (contest, year) pairs actually present in the log, so
@@ -4812,6 +4983,7 @@ func (a *App) BulkUpdateField(ids []int64, field, value string) (int64, error) {
 	}
 	if n > 0 {
 		a.invalidateAwardStats()
+		a.materializeAwardRefsForIDs(ids) // the edited field may feed an award → refresh
 	}
 	return n, nil
 }
@@ -4961,7 +5133,11 @@ func (a *App) ImportADIF(path string, dupMode string, applyCty bool, applyStatio
 	im.OnProgress = func(processed, total int) {
 		wruntime.EventsEmit(a.ctx, "import:progress", map[string]int{"processed": processed, "total": total})
 	}
-	return im.ImportFile(a.ctx, path)
+	res, err := im.ImportFile(a.ctx, path)
+	if err == nil && (res.Imported > 0 || res.Updated > 0) {
+		a.recomputeAwardRefsAsync() // materialise award_refs for the imported rows
+	}
+	return res, err
 }
 
 // SaveADIFFile shows a native Save-As dialog suggesting a timestamped
@@ -8760,6 +8936,7 @@ func (a *App) UpdateQSOsFromCty(ids []int64) (int, error) {
 	}
 	if changed > 0 {
 		a.invalidateAwardStats()
+		a.materializeAwardRefsForIDs(ids) // entity fields changed → refresh award_refs
 	}
 	return changed, nil
 }
@@ -8835,6 +9012,7 @@ func (a *App) UpdateQSOsFromQRZ(ids []int64) (int, error) {
 	}
 	if changed > 0 {
 		a.invalidateAwardStats()
+		a.materializeAwardRefsForIDs(ids) // entity/geo fields changed → refresh award_refs
 	}
 	return changed, nil
 }
@@ -9290,6 +9468,7 @@ func (a *App) LogUDPLoggedADIF(adifText string) (int64, error) {
 	}
 	q.ID = id
 	a.noteLiveQSO() // multi-op: flip this operator back "online"
+	a.materializeAwardRefs(q)
 	a.saveQSORecording(&q)
 	if a.extsvc != nil {
 		a.extsvc.OnQSOLogged(id)

frontend/src/App.tsx

@@ -1,7 +1,7 @@
 import { useCallback, useEffect, useMemo, useRef, useState } from 'react';
 import {
   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,
+  Maximize2, Minimize2, Mic, MessageSquare, Pencil, Radio, RadioTower, RefreshCw, Satellite, Send, Settings, SlidersHorizontal, Square, Terminal, Trash2, Unlock, X, Zap,
 } from 'lucide-react';
 
 import {
@@ -13,7 +13,7 @@ import {
   GetQSO, UpdateQSO, DeleteQSO, DeleteQSOs, DeleteAllQSO,
   UpdateQSOsFromCty, UpdateQSOsFromQRZ, UpdateQSOsFromClublog, UploadQSOsManual, SendQSORecordingEmail,
   LookupCallsign, GetStationSettings, GetListsSettings,
-  GetStartupStatus, CheckForUpdate, DownloadAndApplyUpdate,
+  GetStartupStatus, CheckForUpdate, DownloadAndApplyUpdate, GetLiveStations,
   WorkedBefore,
   SetCompactMode,
   GetCATState, SetCATFrequency, SetCATMode, SwitchCATRig, FlexApplyBandAntenna,
@@ -41,9 +41,8 @@ import {
   ChatAvailable, GetChatHistory, SendChatMessage, GetOnlineOperators,
   QSOAudioBegin, QSOAudioCancel, QSOAudioRestart, QSOAudioResetClock,
   GetAwardDefs,
-  GetUIPref,
+  GetUIPref, GetActiveProfile, QuitApp,
   ReportLiveActivity, GetLiveStatusEnabled, LiveLastQSOAgeSec,
-  AwardRefsForQSOs,
 } from '../wailsjs/go/main/App';
 import { Combobox } from '@/components/ui/combobox';
 import { applyAwardRefs } from '@/lib/awardRefs';
@@ -87,6 +86,7 @@ import { SendSpotModal, type RecentSpotQSO } from '@/components/SendSpotModal';
 import { WinkeyerPanel, type WKStatus, type WKMacro } from '@/components/WinkeyerPanel';
 import { RotorCompass } from '@/components/RotorCompass';
 import { writeUiPref } from '@/lib/uiPref';
+import { setGridPrefsProfile } from '@/lib/gridPrefs';
 import { DvkPanel, type DVKMsg, type DVKStat } from '@/components/DvkPanel';
 
 import { Button } from '@/components/ui/button';
@@ -135,6 +135,22 @@ const emptyDetails: DetailsState = {
   award_refs: '',
 };
 
+// parseAwardRefs turns the QSO row's materialised award_refs JSON string
+// ({"DDFM":"74","WAJA":"12"}) into the code→ref object the grid columns read.
+// Tolerant of empty / malformed values (returns {}), and passes an already-parsed
+// object straight through.
+function parseAwardRefs(s: any): Record<string, string> {
+  if (!s) return {};
+  if (typeof s === 'object') return s as Record<string, string>;
+  if (typeof s !== 'string') return {};
+  try {
+    const o = JSON.parse(s);
+    return o && typeof o === 'object' ? o : {};
+  } catch {
+    return {};
+  }
+}
+
 function fmtDateUTC(s: any): string {
   if (!s) return '';
   const d = new Date(s);
@@ -210,6 +226,16 @@ function bandForMHz(mhz: number): string {
   return '';
 }
 
+// modeAccent maps a mode to a theme-aware colour for the live-stations widget:
+// CW gold, phone green, digital blue, unknown muted.
+function modeAccent(mode?: string): string {
+  const m = (mode || '').toUpperCase();
+  if (/CW/.test(m)) return 'var(--chart-3)';
+  if (/SSB|USB|LSB|AM|FM|PHONE|DV/.test(m)) return 'var(--chart-2)';
+  if (/FT8|FT4|RTTY|PSK|JT|JS8|Q65|MSK|FST|MFSK|OLIVIA|DIG|DATA|WSPR/.test(m)) return 'var(--chart-1)';
+  return 'var(--muted-foreground)';
+}
+
 // rstCategory buckets a mode into the report family used for its RST list.
 type RSTLists = { phone: string[]; cw: string[]; digital: string[] };
 function rstCategory(mode: string): keyof RSTLists {
@@ -410,6 +436,18 @@ export default function App() {
   // click reverts the UI and the click looks like it did nothing.
   const agPending = useRef<{ a?: { v: number; t: number }; b?: { v: number; t: number } }>({});
   const [dbConn, setDbConn] = useState<{ backend: string; label: string } | null>(null);
+  // Multi-op "who's on air" widget: every operator's live status from the shared
+  // MySQL logbook (freq/mode/version). Only polled on a MySQL logbook.
+  type LiveStation = { operator: string; station: string; freq_hz: number; band: string; mode: string; online: boolean; version: string; age_sec: number };
+  const [liveStations, setLiveStations] = useState<LiveStation[]>([]);
+  const [showLiveStations, setShowLiveStations] = useState(() => localStorage.getItem('opslog.showLiveStations') === '1');
+  useEffect(() => {
+    if (dbConn?.backend !== 'mysql') { setLiveStations([]); return; }
+    const load = () => GetLiveStations().then((s) => setLiveStations((s ?? []) as LiveStation[])).catch(() => {});
+    load();
+    const id = window.setInterval(load, 15 * 1000);
+    return () => window.clearInterval(id);
+  }, [dbConn]);
   // Mode OpsLog shows when the rig reports generic DIG_U/DIG_L. OmniRig
   // can't tell us if it's FT8 vs FT4 vs RTTY, so the user picks the default
   // in Preferences > Hardware > CAT interface.
@@ -615,6 +653,7 @@ export default function App() {
   const [filterOpen, setFilterOpen] = useState(false);
   const [activeFilter, setActiveFilter] = useState<QueryFilter>({ conditions: [], match: 'AND' });
   const [matchCount, setMatchCount] = useState<number | null>(null);
+  const [gridFilteredCount, setGridFilteredCount] = useState<number | null>(null); // rows after AG-Grid column filters, or null if none
   // The selected tab is remembered across restarts. Only the always-present tabs
   // are restored: the conditional ones (flex/icom/contest/net/stats/qsl) depend on
   // a feature or CAT backend that isn't known this early, and restoring one that
@@ -1096,32 +1135,26 @@ export default function App() {
   // offline. Only shown when live-status publishing is enabled (Settings→General).
   const [liveStatusOn, setLiveStatusOn] = useState(false);
   const [onAir, setOnAir] = useState(false);
-  const lastQsoAtRef = useRef(0);
   useEffect(() => { if (!showSettings) GetLiveStatusEnabled().then((v) => setLiveStatusOn(!!v)).catch(() => {}); }, [showSettings]);
   useEffect(() => {
-    const LIVE_WINDOW = 5 * 60 * 1000; // 5 min, matches the backend
-    const evalOnAir = () => setOnAir(liveStatusOn && lastQsoAtRef.current > 0 && (Date.now() - lastQsoAtRef.current) < LIVE_WINDOW);
-    const off = EventsOn('qso:logged', () => { lastQsoAtRef.current = Date.now(); evalOnAir(); });
-    // Seed from the DB at launch so a QSO logged just before starting OpsLog still
-    // counts (otherwise the badge showed offline until the next contact).
-    LiveLastQSOAgeSec().then((sec: number) => {
-      if (typeof sec === 'number' && sec >= 0) {
-        const at = Date.now() - sec * 1000;
-        if (at > lastQsoAtRef.current) lastQsoAtRef.current = at;
-        evalOnAir();
-      }
-    }).catch(() => {});
-    evalOnAir();
-    const id = window.setInterval(evalOnAir, 10 * 1000); // flip to offline within ~10s of the window elapsing
+    // Read the ON-AIR state straight from the backend (single source of truth:
+    // liveLastQSOAt, stamped on every log and seeded from the DB at launch). Poll
+    // it + refresh on each logged QSO — no fragile frontend timestamp to drift.
+    const refresh = () => LiveLastQSOAgeSec()
+      .then((sec: number) => setOnAir(liveStatusOn && typeof sec === 'number' && sec >= 0 && sec < 300))
+      .catch(() => {});
+    refresh();
+    const off = EventsOn('qso:logged', refresh);
+    const id = window.setInterval(refresh, 5 * 1000); // responsive without hammering (cheap 400-row scan)
     return () => { off(); window.clearInterval(id); };
   }, [liveStatusOn]);
   // 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 });
+  const [qsoRate, setQsoRate] = useState<{ last10: number; last60: number; team10: number; team60: number }>({ last10: 0, last60: 0, team10: 0, team60: 0 });
   useEffect(() => {
     if (!showQsoRate) return;
-    const load = () => { GetQSORate().then((r) => setQsoRate({ last10: r?.last10 ?? 0, last60: r?.last60 ?? 0 })).catch(() => {}); };
+    const load = () => { GetQSORate().then((r: any) => setQsoRate({ last10: r?.last10 ?? 0, last60: r?.last60 ?? 0, team10: r?.team_last10 ?? 0, team60: r?.team_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.
@@ -1217,38 +1250,28 @@ export default function App() {
   // list once, then compute each shown QSO's reference per award and attach it
   // to the rows (the grids render one hideable column per award).
   const [awardCols, setAwardCols] = useState<{ code: string; name: string }[]>([]);
-  // Bumped whenever award definitions are saved so the grid columns AND the
-  // per-QSO refs re-fetch — the ref/name display choice is computed live, so
-  // changing it updates ALL contacts (old included) with no restart.
+  // Bumped when award definitions change (or the backend finishes a bulk
+  // award_refs recompute) so the set of award COLUMNS re-reads from GetAwardDefs.
+  // The per-QSO values themselves ride on the row (award_refs) and refresh with
+  // the grid reload triggered alongside this bump.
   const [awardsVersion, setAwardsVersion] = useState(0);
   useEffect(() => {
     GetAwardDefs().then((defs: any[]) =>
       setAwardCols(((defs ?? []) as any[]).map((d) => ({ code: d.code, name: d.name })).sort((a, b) => a.code.localeCompare(b.code))),
     ).catch(() => {});
   }, [awardsVersion]);
-  const [qsoAwardRefs, setQsoAwardRefs] = useState<Record<string, Record<string, string>>>({});
-  useEffect(() => {
-    const ids = (qsos as any[]).map((q) => q.id).filter(Boolean);
-    if (ids.length === 0 || awardCols.length === 0) { setQsoAwardRefs({}); return; }
-    let alive = true;
-    AwardRefsForQSOs(ids as any).then((m: any) => { if (alive) setQsoAwardRefs(m ?? {}); }).catch(() => {});
-    return () => { alive = false; };
-  }, [qsos, awardCols.length, awardsVersion]);
+  // Award references are now MATERIALISED on the QSO row (the award_refs JSON
+  // column, written by the backend on log/edit and bulk-recomputed when awards
+  // change). The grid reads them straight from the row — no per-page backend
+  // recompute — so here we just parse the stored JSON string into the code→ref
+  // object the award columns expect (keys are already upper-case).
   const qsosWithAwards = useMemo(
-    () => (qsos as any[]).map((q) => ({ ...q, award_refs: qsoAwardRefs[String(q.id)] })),
-    [qsos, qsoAwardRefs],
+    () => (qsos as any[]).map((q) => ({ ...q, award_refs: parseAwardRefs(q.award_refs) })),
+    [qsos],
   );
-  const [wbAwardRefs, setWbAwardRefs] = useState<Record<string, Record<string, string>>>({});
-  useEffect(() => {
-    const ids = ((wb?.entries ?? []) as any[]).map((e) => e.id).filter(Boolean);
-    if (ids.length === 0 || awardCols.length === 0) { setWbAwardRefs({}); return; }
-    let alive = true;
-    AwardRefsForQSOs(ids as any).then((m: any) => { if (alive) setWbAwardRefs(m ?? {}); }).catch(() => {});
-    return () => { alive = false; };
-  }, [wb, awardCols.length, awardsVersion]);
   const wbWithAwards = useMemo(
-    () => (wb ? { ...wb, entries: ((wb.entries ?? []) as any[]).map((e) => ({ ...e, award_refs: wbAwardRefs[String(e.id)] })) } : null),
-    [wb, wbAwardRefs],
+    () => (wb ? { ...wb, entries: ((wb.entries ?? []) as any[]).map((e) => ({ ...e, award_refs: parseAwardRefs(e.award_refs) })) } : null),
+    [wb],
   );
   // Always-current copy of the entry callsign, so the UDP event handlers
   // (which live in a []-deps effect with a stale `callsign` closure) can
@@ -1409,6 +1432,15 @@ export default function App() {
     return () => { offUploaded(); offDone(); offEqsl(); if (t) window.clearTimeout(t); };
   }, [refresh]);
 
+  // The backend bulk-recomputed the materialised award_refs (an award definition
+  // or reference list changed, or the one-time backfill ran). Reload the rows so
+  // the award columns show the new values, and bump awardsVersion so the set of
+  // award COLUMNS refreshes too (a new award may have appeared).
+  useEffect(() => {
+    const off = EventsOn('awards:recomputed', () => { refresh(); setAwardsVersion((v) => v + 1); });
+    return () => { off(); };
+  }, [refresh]);
+
   // Backend-emitted toast messages (e.g. recording auto-send result/skip).
   useEffect(() => {
     const off = EventsOn('toast', (msg: any) => { if (msg) showToast(String(msg)); });
@@ -2008,11 +2040,25 @@ export default function App() {
     } catch { /* keyer not configured */ }
   }, []);
 
+  // Active profile id — scopes the grids' column layout (visibility / width /
+  // order) so each profile keeps its own. Seeded once on mount and updated on
+  // every profile switch; the grids take it as their React key so they remount
+  // and re-read the now-correct per-profile layout.
+  const [activeProfileId, setActiveProfileId] = useState<number | null>(null);
+  useEffect(() => {
+    GetActiveProfile().then((p: any) => {
+      if (p && p.id != null) { setGridPrefsProfile(p.id); setActiveProfileId(p.id); }
+    }).catch(() => {});
+  }, []);
+
   // Every setting is per-profile, so when the active profile changes the whole
   // main UI re-reads its config (station identity, lists, CAT, keyer). The Go
   // side reloads its managers; this keeps the React state in sync.
   useEffect(() => {
-    const off = EventsOn('profile:changed', () => {
+    const off = EventsOn('profile:changed', (id: any) => {
+      // Re-scope the grid column layout BEFORE the grids remount (key change).
+      setGridPrefsProfile(id ?? null);
+      setActiveProfileId(typeof id === 'number' ? id : null);
       loadStation(); loadLists(); loadCATCfg(); reloadWk(); loadMainPanes();
       // The chat is per shared logbook — clear the previous profile's messages
       // and reload for the new logbook (or hide if it isn't a MySQL log).
@@ -2626,7 +2672,14 @@ export default function App() {
     // keeps the pre-roll from before this); clearing it discards the take.
     // Recording START happens on blur (leaving the callsign field), NOT here —
     // you may type a call and work it minutes later. Clearing it cancels.
-    if (v.trim() === '') { QSOAudioCancel(); setRecording(false); recordingCallRef.current = ""; }
+    if (v.trim() === '') {
+      QSOAudioCancel(); setRecording(false); recordingCallRef.current = "";
+      // Callsign wiped → drop this contact's award references. They are auto-added
+      // per call (live detection merges pickable refs into award_refs), so without
+      // this they'd carry over to the NEXT call — e.g. IT9AOT's ref lingering when
+      // you then type F4BPO, showing both in the F3 Awards tab.
+      updateDetails({ award_refs: '' });
+    }
     const isEmpty = v.trim() === '';
     if (!isEmpty && !locks.start) {
       // Restart the start time on every callsign change (each keystroke, a
@@ -2709,7 +2762,7 @@ export default function App() {
       { type: 'separator' },
       { type: 'item', label: t('file.deleteAll'), action: 'file.deleteall', disabled: total === 0 },
       { type: 'separator' },
-      { type: 'item', label: t('file.exit'), action: 'file.exit', shortcut: 'Ctrl+Q', disabled: true },
+      { type: 'item', label: t('file.exit'), action: 'file.exit', shortcut: 'Ctrl+Q' },
     ]},
     { name: 'edit', label: t('menu.edit'), items: [
       { type: 'item', label: t('edit.editSel'), action: 'edit.edit', shortcut: 'Enter', disabled: selectedId === null },
@@ -2754,6 +2807,7 @@ export default function App() {
       case 'file.export':       exportAdif(); break;
       case 'file.exportCabrillo': exportCabrillo(); break;
       case 'file.deleteall':    setShowDeleteAll(true); break;
+      case 'file.exit':         QuitApp(); break;
       case 'view.refresh':      refresh(); break;
       case 'view.clearfilters': setFilterCallsign(''); setActiveFilter({ conditions: [], match: 'AND' }); break;
       case 'edit.edit':         if (selectedId !== null) openEdit(selectedId); break;
@@ -3593,6 +3647,7 @@ export default function App() {
         return (
           <div className="h-full w-full min-h-0 flex flex-col bg-card border border-border rounded-lg overflow-hidden">
             <RecentQSOsGrid
+              key={`rqg-${activeProfileId ?? 'x'}`}
               rows={qsosWithAwards as any}
               total={total}
               awardCols={awardCols}
@@ -3846,6 +3901,24 @@ export default function App() {
                 )}
               </button>
             )}
+            {/* Multi-op "who's on air": a dockable widget (toggle), not a popover. */}
+            {dbConn?.backend === 'mysql' && (
+              <button
+                type="button"
+                onClick={() => { const v = !showLiveStations; setShowLiveStations(v); writeUiPref('opslog.showLiveStations', v ? '1' : '0'); }}
+                title={showLiveStations ? `${t('live.stationsTitle')} — shown · click to hide` : `${t('live.stationsTitle')} · click to show`}
+                className={cn('relative inline-flex items-center justify-center size-7 rounded-md border transition-colors',
+                  showLiveStations ? 'border-info-border bg-info-muted text-info-muted-foreground hover:bg-info-muted'
+                    : 'border-border text-muted-foreground hover:bg-muted')}
+              >
+                <Radio className="size-4" />
+                {liveStations.filter((s) => s.online).length > 0 && (
+                  <span className="absolute -top-1 -right-1 min-w-3.5 h-3.5 px-0.5 rounded-full bg-danger text-danger-foreground text-[9px] font-bold leading-[14px] text-center">
+                    {(() => { const n = liveStations.filter((s) => s.online).length; return n > 9 ? '9+' : n; })()}
+                  </span>
+                )}
+              </button>
+            )}
           </div>
 
           {/* QSO-rate meter (opt-in) + propagation share ONE grid cell: the header
@@ -3853,21 +3926,39 @@ export default function App() {
               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"
+            <div className="flex items-center gap-2 font-mono px-2.5 h-8 rounded-md border border-border/60 bg-muted/40 whitespace-nowrap"
               title={t('rate.title')}>
+              {/* Contest-style rate: QSOs/hour projected from each window (10-min
+                  count ×6; the 60-min count is already per hour). On a shared MySQL
+                  logbook it shows both OP (the active operator, accent) and TEAM (all
+                  operators, muted); single-op shows one line. */}
               <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>
+              {dbConn?.backend === 'mysql' ? (
+                <div className="flex flex-col gap-0.5 leading-none">
+                  <div className="flex items-center gap-1.5">
+                    <span className="text-muted-foreground uppercase tracking-wider text-[8px] w-9">OP</span>
+                    <span className="inline-flex items-baseline gap-0.5"><span className={cn('font-bold text-[11px]', qsoRate.last10 > 0 ? 'text-primary' : 'text-muted-foreground')}>{qsoRate.last10 * 6}</span><span className="text-muted-foreground text-[7px]">10′</span></span>
+                    <span className="inline-flex items-baseline gap-0.5"><span className={cn('font-bold text-[11px]', qsoRate.last60 > 0 ? 'text-primary' : 'text-muted-foreground')}>{qsoRate.last60}</span><span className="text-muted-foreground text-[7px]">60′</span></span>
+                  </div>
+                  <div className="flex items-center gap-1.5">
+                    <span className="text-muted-foreground uppercase tracking-wider text-[8px] w-9">Team</span>
+                    <span className="inline-flex items-baseline gap-0.5"><span className={cn('font-bold text-[11px]', qsoRate.team10 > 0 ? 'text-foreground' : 'text-muted-foreground')}>{qsoRate.team10 * 6}</span><span className="text-muted-foreground text-[7px]">10′</span></span>
+                    <span className="inline-flex items-baseline gap-0.5"><span className={cn('font-bold text-[11px]', qsoRate.team60 > 0 ? 'text-foreground' : 'text-muted-foreground')}>{qsoRate.team60}</span><span className="text-muted-foreground text-[7px]">60′</span></span>
+                  </div>
+                </div>
+              ) : (
+                <>
+                  <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 self-center">Q/h</span>
             </div>
           )}
 
@@ -4214,8 +4305,55 @@ export default function App() {
       {/* Reserved free space to the right. The WinKeyer CW keyer and/or the
           Digital Voice Keyer take this slot when enabled (Log4OM-style);
           otherwise it shows the QRZ profile photo. */}
-      {!compact && (chatShown || wkEnabled || dvkEnabled || lookupResult?.image_url || (showRotor && (rotatorHeading.enabled || dxPath)) || (showAntGenius && agEnabled)) && (
+      {!compact && (chatShown || wkEnabled || dvkEnabled || lookupResult?.image_url || (showRotor && (rotatorHeading.enabled || dxPath)) || (showAntGenius && agEnabled) || (showLiveStations && dbConn?.backend === 'mysql')) && (
         <div className="flex-1 min-w-0 min-h-0 flex gap-2.5 items-stretch">
+          {/* Multi-op "who's on air" widget: every operator on the shared logbook,
+              their freq/mode (colour-coded) and OpsLog version. */}
+          {showLiveStations && dbConn?.backend === 'mysql' && (
+            <div className="w-[248px] shrink-0 min-h-0 relative">
+              <div className="absolute inset-0 flex flex-col min-h-0 rounded-xl border border-border bg-card shadow-sm overflow-hidden">
+                <div className="flex items-center gap-1.5 px-3 h-8 border-b border-border shrink-0">
+                  <Radio className="size-3.5 text-primary" />
+                  <span className="text-[11px] font-semibold uppercase tracking-wider truncate">{t('live.stationsTitle')}</span>
+                  <div className="flex-1" />
+                  <span className="text-[10px] text-muted-foreground tabular-nums">{liveStations.filter((s) => s.online).length}</span>
+                  <button type="button" className="text-muted-foreground hover:text-foreground shrink-0"
+                    onClick={() => { setShowLiveStations(false); writeUiPref('opslog.showLiveStations', '0'); }} title={t('live.stationsHide')}>
+                    <X className="size-3.5" />
+                  </button>
+                </div>
+                <div className="flex-1 min-h-0 overflow-auto p-1.5 flex flex-col gap-1">
+                  {liveStations.filter((s) => s.online).length === 0 ? (
+                    <p className="text-xs text-muted-foreground italic px-1 py-2">{t('live.stationsEmpty')}</p>
+                  ) : liveStations.filter((s) => s.online).map((s, i) => {
+                    const mc = modeAccent(s.mode);
+                    return (
+                      <div key={i} className={cn('flex items-center gap-2 rounded-md px-2 py-1.5 border', s.online ? 'bg-muted/40 border-border' : 'border-transparent opacity-60')}>
+                        <span className={cn('size-2 rounded-full shrink-0', s.online ? 'bg-danger animate-pulse' : 'bg-muted-foreground/40')}
+                          title={s.online ? t('live.onAir') : t('live.offline')} />
+                        <div className="min-w-0 flex-1">
+                          <div className="flex items-baseline gap-1.5 min-w-0">
+                            <span className="text-xs font-bold font-mono truncate">{s.operator}</span>
+                            {s.version && <span className="text-[9px] text-muted-foreground shrink-0 tabular-nums ml-auto">v{s.version}</span>}
+                          </div>
+                          <div className="flex items-center gap-1.5 mt-0.5 min-w-0">
+                            <span className="font-mono text-[11px] font-semibold tabular-nums" style={{ color: mc }}>
+                              {s.freq_hz ? (s.freq_hz / 1e6).toFixed(3) : '—'}
+                            </span>
+                            {s.mode && (
+                              <span className="text-[9px] font-bold uppercase px-1.5 rounded-full leading-[15px] shrink-0"
+                                style={{ background: `${mc}22`, color: mc }}>{s.mode}</span>
+                            )}
+                            {s.band && <span className="text-[10px] text-muted-foreground shrink-0">{s.band}</span>}
+                          </div>
+                        </div>
+                      </div>
+                    );
+                  })}
+                </div>
+              </div>
+            </div>
+          )}
           {chatShown && (
             // relative + absolute inner: the chat takes the row height (set by the
             // entry strip) WITHOUT its message list growing the row, like the
@@ -4536,9 +4674,11 @@ export default function App() {
               )}
 
               <RecentQSOsGrid
+                key={`rqg2-${activeProfileId ?? 'x'}`}
                 rows={qsosWithAwards as any}
                 total={total}
                 awardCols={awardCols}
+                onFilteredCountChange={setGridFilteredCount}
                 onRowDoubleClicked={(q) => openEdit(q.id as number)}
                 onUpdateFromCty={bulkUpdateFromCty}
                 onUpdateFromQRZ={bulkUpdateFromQRZ}
@@ -4574,11 +4714,18 @@ export default function App() {
                       onClick={() => { setActiveFilter({ conditions: [], match: 'AND' }); setFilterCallsign(''); }}
                     >clear</button>
                   ) : null}
-                  <span>
-                    Showing <span className="font-semibold text-foreground">{qsos.length}</span> of{' '}
-                    <span className="font-semibold text-foreground">{(activeFilter.conditions?.length || filterCallsign) && matchCount != null ? matchCount : total}</span>
-                    {(activeFilter.conditions?.length || filterCallsign) ? ` matches · ${total} total` : ''}
-                  </span>
+                  {gridFilteredCount != null ? (
+                    <span>
+                      Showing <span className="font-semibold text-foreground">{gridFilteredCount}</span> of{' '}
+                      <span className="font-semibold text-foreground">{qsos.length}</span> (column filter)
+                    </span>
+                  ) : (
+                    <span>
+                      Showing <span className="font-semibold text-foreground">{qsos.length}</span> of{' '}
+                      <span className="font-semibold text-foreground">{(activeFilter.conditions?.length || filterCallsign) && matchCount != null ? matchCount : total}</span>
+                      {(activeFilter.conditions?.length || filterCallsign) ? ` matches · ${total} total` : ''}
+                    </span>
+                  )}
                 </div>
                 <div className="flex items-center gap-2">
                   {qsos.length >= qsoLimit && qsos.length < total && (

frontend/src/components/RecentQSOsGrid.tsx

@@ -49,6 +49,10 @@ type Props = {
   onExportCabrilloSelected?: (ids: number[]) => void;
   onExportCabrilloFiltered?: () => void;
   onDelete?: (ids: number[]) => void;
+  // Reports how many rows the grid shows after its COLUMN filters (the funnel
+  // icons), or null when no column filter is active — so the parent's "Showing X
+  // of Y" can reflect them. Fired on filter change and when the data updates.
+  onFilteredCountChange?: (count: number | null) => void;
   // One column per defined award; the cell shows the reference this QSO counts
   // for (from row.award_refs[CODE], attached by the parent). Hidden by default.
   awardCols?: { code: string; name: string }[];
@@ -245,7 +249,7 @@ export const groupLabel = (t: TFn, g: string): string => t(GRP_KEYS[g] ?? g);
 const stripAwardCols = (st: any[] | null | undefined): any[] =>
   (st ?? []).filter((s) => !String(s?.colId ?? '').startsWith('award_'));
 
-export function RecentQSOsGrid({ rows, selectAllSignal, storageKey, onRowDoubleClicked, onRowClicked, onRowSelected, onUpdateFromCty, onUpdateFromQRZ, onUpdateFromClublog, onSendTo, onSendRecording, onSendEQSL, onBulkEdit, onExportSelected, onExportFiltered, onExportCabrilloSelected, onExportCabrilloFiltered, onDelete, awardCols }: Props) {
+export function RecentQSOsGrid({ rows, selectAllSignal, storageKey, onRowDoubleClicked, onRowClicked, onRowSelected, onUpdateFromCty, onUpdateFromQRZ, onUpdateFromClublog, onSendTo, onSendRecording, onSendEQSL, onBulkEdit, onExportSelected, onExportFiltered, onExportCabrilloSelected, onExportCabrilloFiltered, onDelete, onFilteredCountChange, awardCols }: Props) {
   const { t } = useI18n();
   const gridRef = useRef<any>(null);
   const [pickerOpen, setPickerOpen] = useState(false);
@@ -360,17 +364,26 @@ export function RecentQSOsGrid({ rows, selectAllSignal, storageKey, onRowDoubleC
       }
     });
   }
+  // Report the post-column-filter row count (funnel filters) to the parent, or
+  // null when no column filter is active, so "Showing X of Y" reflects them.
+  const reportFilteredCount = useCallback((e: { api?: any }) => {
+    const api = e?.api ?? gridRef.current?.api;
+    if (!api || !onFilteredCountChange) return;
+    onFilteredCountChange(api.isAnyFilterPresent?.() ? api.getDisplayedRowCount() : null);
+  }, [onFilteredCountChange]);
   const saveColumnState = useCallback(() => {
     if (restoringRef.current) return; // ignore the events fired by a column rebuild
     const state = gridRef.current?.api?.getColumnState();
     if (state) saveState(colStateKey, stripAwardCols(state));
   }, []);
 
-  // The award columns load asynchronously; when they arrive (or change) the
-  // columnDefs memo is rebuilt and AG Grid re-applies each colDef's `hide`
-  // default — wiping the user's saved visibility (award columns reappear,
-  // manually-shown ones like LoTW sent vanish). Re-apply the saved state after
-  // every rebuild so the user's choices win. No-op before the grid is ready.
+  // columnDefs is rebuilt whenever the award columns load OR the user toggles an
+  // award column (both change the memo → restoringRef flips true at line 316). Each
+  // rebuild makes AG Grid re-apply every colDef's `hide` default, wiping the user's
+  // saved visibility of the NON-award columns (QTH/Grid reappear, a manually-shown
+  // LoTW-sent vanishes). Re-apply the saved (award-stripped) state after EVERY such
+  // rebuild — hence awardShown in the deps, not just awardCols; without it, toggling
+  // an award reset the other columns AND left restoringRef stuck true (saving off).
   useEffect(() => {
     const api = gridRef.current?.api;
     const local = loadLocal(colStateKey);
@@ -378,7 +391,7 @@ export function RecentQSOsGrid({ rows, selectAllSignal, storageKey, onRowDoubleC
     // Re-enable saving once AG Grid has settled the column events from the rebuild.
     const t = window.setTimeout(() => { restoringRef.current = false; }, 0);
     return () => window.clearTimeout(t);
-  }, [awardCols]);
+  }, [awardCols, awardShown]);
 
   function handleRowDoubleClicked(e: RowDoubleClickedEvent<QSOForm>) {
     if (e.data && onRowDoubleClicked) onRowDoubleClicked(e.data);
@@ -467,6 +480,8 @@ export function RecentQSOsGrid({ rows, selectAllSignal, storageKey, onRowDoubleC
             defaultColDef={defaultColDef}
             rowSelection={{ mode: 'multiRow', checkboxes: false, headerCheckbox: false, enableClickSelection: true }}
             onGridReady={onGridReady}
+            onFilterChanged={reportFilteredCount}
+            onModelUpdated={reportFilteredCount}
             onColumnResized={saveColumnState}
             onColumnMoved={saveColumnState}
             onColumnPinned={saveColumnState}

frontend/src/lib/gridPrefs.ts

@@ -6,11 +6,32 @@
 // back to the DB copy and re-seed the cache.
 import { GetUIPref, SetUIPref } from '../../wailsjs/go/main/App';
 
+// The DB copy is ALREADY per-profile (the backend prefixes every ui.* key with
+// the active profile id). The localStorage cache, however, is one namespace for
+// the whole WebView, so without scoping it too a profile switch would keep
+// serving the previous profile's cached layout and the correct per-profile DB
+// value would never win. lsScope makes the cache per-profile as well; it's set
+// once the active profile is known and updated on every profile switch.
+let lsScope = '';
+
+// setGridPrefsProfile scopes the localStorage cache to a profile. Call it before
+// the grids read their state (at startup) and again whenever the active profile
+// changes so each profile keeps its own column layout / widths.
+export function setGridPrefsProfile(id: number | string | null | undefined): void {
+  lsScope = id == null || id === '' ? '' : `p${id}.`;
+}
+
+// lsKey scopes ONLY the localStorage cache key. The DB key passed to
+// GetUIPref/SetUIPref is left untouched — the backend already scopes it.
+function lsKey(key: string): string {
+  return lsScope + key;
+}
+
 // loadLocal reads the cached column state synchronously (used in onGridReady
 // to apply instantly, before the async DB round-trip).
 export function loadLocal(key: string): any[] | null {
   try {
-    const raw = localStorage.getItem(key);
+    const raw = localStorage.getItem(lsKey(key));
     const v = raw ? JSON.parse(raw) : null;
     return Array.isArray(v) ? v : null;
   } catch {
@@ -29,15 +50,16 @@ export async function loadRemote(key: string): Promise<any[] | null> {
   }
 }
 
-// saveState write-throughs to both the cache and the DB (fire-and-forget).
+// saveState write-throughs to both the cache and the DB (fire-and-forget). Only
+// the cache key is profile-scoped; the DB key is scoped by the backend.
 export function saveState(key: string, state: any[]) {
   const json = JSON.stringify(state);
-  try { localStorage.setItem(key, json); } catch { /* quota / private mode */ }
+  try { localStorage.setItem(lsKey(key), json); } catch { /* quota / private mode */ }
   SetUIPref(key, json).catch(() => { /* DB unavailable — cache still holds it */ });
 }
 
 // seedLocal writes a value into the cache without touching the DB (used after
 // hydrating the cache from the DB on a fresh machine).
 export function seedLocal(key: string, state: any[]) {
-  try { localStorage.setItem(key, JSON.stringify(state)); } catch { /* ignore */ }
+  try { localStorage.setItem(lsKey(key), JSON.stringify(state)); } catch { /* ignore */ }
 }

frontend/src/lib/i18n.tsx

@@ -17,6 +17,7 @@ const en: Dict = {
   'live.onAir': 'On air', 'live.offline': 'Offline',
   'live.onAirTip': 'On air — a QSO was logged in the last 5 minutes (published to the live status)',
   'live.offlineTip': 'Offline — no QSO logged in the last 5 minutes',
+  'live.stationsTitle': 'Stations on air', 'live.stationsEmpty': 'No station reporting yet.', 'live.stationsHide': 'Hide',
   'upd.available': 'OpsLog v{v} available', 'upd.current': "You're on v{v}.",
   'upd.install': 'Update now', 'upd.download': 'Download', 'upd.later': 'Later',
   'upd.downloading': 'Downloading…', 'upd.installing': 'Installing…',
@@ -335,6 +336,7 @@ const fr: Dict = {
   'live.onAir': 'On air', 'live.offline': 'Hors ligne',
   'live.onAirTip': "On air — un QSO a été loggé dans les 5 dernières minutes (publié dans le statut live)",
   'live.offlineTip': 'Hors ligne — aucun QSO loggé depuis 5 minutes',
+  'live.stationsTitle': 'Stations on air', 'live.stationsEmpty': 'Aucune station ne reporte pour le moment.', 'live.stationsHide': 'Masquer',
   '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',

frontend/src/lib/uiPref.ts

@@ -32,7 +32,10 @@ const PORTABLE_KEYS = [
   'opslog.clusterLockBand', 'opslog.clusterLockMode', 'opslog.clusterStatusFilter',
   'opslog.clusterModeFilter', 'opslog.clusterSearch', 'opslog.clusterHideWorked',
   'opslog.activeTab',     // last selected tab
-  'hamlog.awardColsShown', // which award columns are shown in the QSO grid
+  // NOTE: 'hamlog.awardColsShown' and the grid column layouts are NOT listed here.
+  // They are handled by lib/gridPrefs, which scopes the localStorage cache PER
+  // PROFILE and mirrors to the DB (already per-profile) itself — mirroring them
+  // through this global path would fight that per-profile scoping.
 ];
 
 // syncPortablePrefs reconciles the DB with the local cache at startup:

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.20.1';
+export const APP_VERSION = '0.20.4';
 
 // Author / credits, shown in Help -> About.
 export const APP_AUTHOR = 'F4BPO';

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

@@ -354,6 +354,8 @@ export function GetIcomState():Promise<cat.IcomTXState>;
 
 export function GetListsSettings():Promise<main.ListsSettings>;
 
+export function GetLiveStations():Promise<Array<main.LiveStation>>;
+
 export function GetLiveStatusEnabled():Promise<boolean>;
 
 export function GetLoTWUsersStatus():Promise<main.LoTWUsersStatus>;
@@ -664,6 +666,8 @@ export function QSOAudioRestart():Promise<boolean>;
 
 export function QuitApp():Promise<void>;
 
+export function RecomputeAllAwardRefs():Promise<number>;
+
 export function RefreshCtyDat():Promise<main.CtyDatInfo>;
 
 export function RefreshSolar():Promise<void>;

frontend/wailsjs/go/main/App.js

@@ -666,6 +666,10 @@ export function GetListsSettings() {
   return window['go']['main']['App']['GetListsSettings']();
 }
 
+export function GetLiveStations() {
+  return window['go']['main']['App']['GetLiveStations']();
+}
+
 export function GetLiveStatusEnabled() {
   return window['go']['main']['App']['GetLiveStatusEnabled']();
 }
@@ -1286,6 +1290,10 @@ export function QuitApp() {
   return window['go']['main']['App']['QuitApp']();
 }
 
+export function RecomputeAllAwardRefs() {
+  return window['go']['main']['App']['RecomputeAllAwardRefs']();
+}
+
 export function RefreshCtyDat() {
   return window['go']['main']['App']['RefreshCtyDat']();
 }

frontend/wailsjs/go/models.ts

@@ -2054,6 +2054,32 @@ export namespace main {
 		    return a;
 		}
 	}
+	export class LiveStation {
+	    operator: string;
+	    station: string;
+	    freq_hz: number;
+	    band: string;
+	    mode: string;
+	    online: boolean;
+	    version: string;
+	    age_sec: number;
+	
+	    static createFrom(source: any = {}) {
+	        return new LiveStation(source);
+	    }
+	
+	    constructor(source: any = {}) {
+	        if ('string' === typeof source) source = JSON.parse(source);
+	        this.operator = source["operator"];
+	        this.station = source["station"];
+	        this.freq_hz = source["freq_hz"];
+	        this.band = source["band"];
+	        this.mode = source["mode"];
+	        this.online = source["online"];
+	        this.version = source["version"];
+	        this.age_sec = source["age_sec"];
+	    }
+	}
 	export class LoTWUsersStatus {
 	    count: number;
 	    updated?: string;
@@ -2381,6 +2407,8 @@ export namespace main {
 	export class QSORate {
 	    last10: number;
 	    last60: number;
+	    team_last10: number;
+	    team_last60: number;
 	
 	    static createFrom(source: any = {}) {
 	        return new QSORate(source);
@@ -2390,6 +2418,8 @@ export namespace main {
 	        if ('string' === typeof source) source = JSON.parse(source);
 	        this.last10 = source["last10"];
 	        this.last60 = source["last60"];
+	        this.team_last10 = source["team_last10"];
+	        this.team_last60 = source["team_last60"];
 	    }
 	}
 	export class RelayAutoRule {
@@ -3618,6 +3648,7 @@ export namespace qso {
 	    my_arrl_sect?: string;
 	    my_vucc_grids?: string;
 	    extras?: Record<string, string>;
+	    award_refs?: string;
 	    // Go type: time
 	    created_at: any;
 	    // Go type: time
@@ -3755,6 +3786,7 @@ export namespace qso {
 	        this.my_arrl_sect = source["my_arrl_sect"];
 	        this.my_vucc_grids = source["my_vucc_grids"];
 	        this.extras = source["extras"];
+	        this.award_refs = source["award_refs"];
 	        this.created_at = this.convertValues(source["created_at"], null);
 	        this.updated_at = this.convertValues(source["updated_at"], null);
 	    }

internal/cat/omnirig.go

@@ -87,14 +87,6 @@ func (o *OmniRig) Connect() error {
 	return nil
 }
 
-// isIC7610 reports whether the connected rig is an IC-7610. OmniRig's generic
-// Freq property reads the wrong VFO on the 7610 (its Main/Sub model confuses the
-// stock ini), so we read VFO A explicitly for it instead — matching what Log4OM
-// shows.
-func (o *OmniRig) isIC7610() bool {
-	return strings.Contains(strings.ToUpper(o.rigType), "7610")
-}
-
 func (o *OmniRig) Disconnect() {
 	if o.rig != nil {
 		o.rig.Release()
@@ -204,23 +196,20 @@ func (o *OmniRig) ReadState() (RigState, error) {
 			s.FreqHz, s.RxFreqHz = freqB, freqA
 		}
 	} else {
-		// Simplex: the operating frequency is OmniRig's generic Freq (the active
-		// VFO), like Log4OM. Fall back to the per-VFO value only if Freq is 0.
+		// Simplex: read VFO A first, fall back to the generic Freq — exactly like
+		// DXHunter/WSJT-X. PM_FREQA rigs (Yaesu, Kenwood) populate FreqA; some
+		// Icoms (IC-9100 etc.) only populate the generic Freq. On the IC-7610
+		// OmniRig's generic Freq reports VFO B (its Main/Sub model confuses the
+		// stock ini), so keying off FreqA gives the operator the VFO they expect.
 		s.Split = false
 		s.RxFreqHz = 0
-		s.FreqHz = freqMain
-		// IC-7610 quirk: OmniRig's generic Freq reports VFO B (its Main/Sub model
-		// confuses the stock ini), so OpsLog showed the wrong VFO. Read VFO A
-		// explicitly for the 7610 — what the operator actually wants to see.
-		if o.isIC7610() && freqA != 0 {
+		switch {
+		case freqA != 0:
 			s.FreqHz = freqA
-		}
-		if s.FreqHz == 0 {
-			if s.Vfo == "B" || s.Vfo == "BB" {
-				s.FreqHz = freqB
-			} else {
-				s.FreqHz = freqA
-			}
+		case freqMain != 0:
+			s.FreqHz = freqMain
+		default:
+			s.FreqHz = freqB
 		}
 	}
 	return s, nil

internal/db/migrations/0023_award_refs.sql

@@ -0,0 +1,10 @@
+-- Materialised award references per QSO. As soon as a QSO matches an award
+-- (via the operator's award definitions) or a reference is set by hand, the
+-- resolved reference(s) are stored here as a compact JSON object keyed by award
+-- code, e.g. {"DDFM":"74","WAJA":"12"}. The grid's per-award columns then read
+-- straight from the row like any other column instead of recomputing the whole
+-- award engine on every page load — much faster, and easy to display anywhere
+-- (including the shared MySQL logbook). Kept in step by the app: written on log
+-- / edit / UDP-import and bulk-recomputed when an award definition or reference
+-- list changes. SQLite ADD COLUMN is metadata-only, fast even on large logbooks.
+ALTER TABLE qso ADD COLUMN award_refs TEXT;

internal/qso/qso.go

@@ -197,6 +197,14 @@ type QSO struct {
 	// ADIF field names (e.g. "MS_SHOWER"); values are the raw string content.
 	Extras map[string]string `json:"extras,omitempty"`
 
+	// AwardRefs is the materialised award-reference JSON for this QSO — a compact
+	// object keyed by award code, e.g. {"DDFM":"74","WAJA":"12"}. Derived (the app
+	// computes it on log/edit and bulk-recomputes it when awards change) and stored
+	// so the grid's award columns read straight from the row. Written ONLY via
+	// SetAwardRefs, never through the normal insert/update column list, so an edit
+	// that doesn't know about it can't clobber it.
+	AwardRefs string `json:"award_refs,omitempty"`
+
 	CreatedAt time.Time `json:"created_at"`
 	UpdatedAt time.Time `json:"updated_at"`
 }
@@ -250,7 +258,10 @@ const columnList = `callsign, qso_date, qso_date_off, band, band_rx, mode, submo
     credit_granted, credit_submitted, my_arrl_sect, my_vucc_grids,
     extras_json`
 
-const selectCols = `id, ` + columnList + `, created_at, updated_at`
+// award_refs is read here but is NOT part of columnList (the insert/update
+// write path) — it is a derived cache written only via SetAwardRefs, so a
+// normal QSO write can never clobber it.
+const selectCols = `id, ` + columnList + `, award_refs, created_at, updated_at`
 
 // columnCount is derived from columnList at init so they can never drift.
 var columnCount = countColumns(columnList)
@@ -793,7 +804,7 @@ func (r *Repo) SetExtra(ctx context.Context, id int64, key, value string) error
 		return fmt.Errorf("missing id or key")
 	}
 	var extrasJSON sql.NullString
-	if err := r.db.QueryRowContext(ctx, `SELECT extras FROM qso WHERE id = ?`, id).Scan(&extrasJSON); err != nil {
+	if err := r.db.QueryRowContext(ctx, `SELECT extras_json FROM qso WHERE id = ?`, id).Scan(&extrasJSON); err != nil {
 		return fmt.Errorf("load extras: %w", err)
 	}
 	m := decodeExtras(extrasJSON.String)
@@ -806,13 +817,56 @@ func (r *Repo) SetExtra(ctx context.Context, id int64, key, value string) error
 		m[key] = value
 	}
 	if _, err := r.db.ExecContext(ctx,
-		`UPDATE qso SET extras = ?, updated_at = ? WHERE id = ?`,
+		`UPDATE qso SET extras_json = ?, updated_at = ? WHERE id = ?`,
 		encodeExtras(m), db.NowISO(), id); err != nil {
 		return fmt.Errorf("set extra %s: %w", key, err)
 	}
 	return nil
 }
 
+// SetAwardRefs stores the materialised award-reference JSON for one QSO. Like
+// SetExtra it is a targeted single-column UPDATE — never a full-row write — so it
+// cannot clobber a field another action changed meanwhile. updated_at is left
+// UNTOUCHED on purpose: award_refs is a derived cache, and bumping updated_at
+// would masquerade as a real edit (re-triggering uploads / sync that watch it).
+func (r *Repo) SetAwardRefs(ctx context.Context, id int64, jsonStr string) error {
+	if id == 0 {
+		return fmt.Errorf("missing id")
+	}
+	if _, err := r.db.ExecContext(ctx,
+		`UPDATE qso SET award_refs = ? WHERE id = ?`, jsonStr, id); err != nil {
+		return fmt.Errorf("set award_refs: %w", err)
+	}
+	return nil
+}
+
+// SetAwardRefsBatch stores materialised award refs for many QSOs in a single
+// transaction — used by the bulk recompute so a large logbook on a remote MySQL
+// is one round-trip's worth of work, not N. Like SetAwardRefs it touches only the
+// award_refs column and leaves updated_at alone (derived cache). A nil/empty map
+// is a no-op.
+func (r *Repo) SetAwardRefsBatch(ctx context.Context, byID map[int64]string) error {
+	if len(byID) == 0 {
+		return nil
+	}
+	tx, err := r.db.BeginTx(ctx, nil)
+	if err != nil {
+		return fmt.Errorf("begin tx: %w", err)
+	}
+	defer tx.Rollback()
+	stmt, err := tx.PrepareContext(ctx, `UPDATE qso SET award_refs = ? WHERE id = ?`)
+	if err != nil {
+		return fmt.Errorf("prepare: %w", err)
+	}
+	defer stmt.Close()
+	for id, js := range byID {
+		if _, err := stmt.ExecContext(ctx, js, id); err != nil {
+			return fmt.Errorf("set award_refs %d: %w", id, err)
+		}
+	}
+	return tx.Commit()
+}
+
 // Update overwrites all editable fields of an existing QSO. updated_at is bumped.
 func (r *Repo) Update(ctx context.Context, q QSO) error {
 	if q.ID == 0 {
@@ -1921,21 +1975,20 @@ func (r *Repo) LastQSOTime(ctx context.Context, operator string) (time.Time, boo
 	return time.Time{}, false
 }
 
-// RecentRate counts QSOs whose start time falls within each trailing window from
-// `now` — the live "QSO rate" meter shown in the header. When operator is non-empty
-// (multi-op on a shared logbook) only that operator's QSOs are counted, so each op
-// sees their OWN performance, not the cumulative rate; empty operator matches every
-// QSO. 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, operator string, windows ...time.Duration) ([]int, error) {
-	counts := make([]int, len(windows))
-	// 2000 rows covers a full hour for one operator even in a busy multi-op run
-	// (other operators' rows are discarded before counting).
+// RecentRateBreakdown counts, in ONE pass over the most recent rows, QSOs whose
+// start time falls within each trailing window from `now` — for a specific operator
+// (their own rate, `op`) AND for ALL operators combined (the team/station rate,
+// `all`). The header rate meter shows both. It scans only recently inserted rows
+// (ORDER BY id DESC LIMIT), since any QSO in the last hour was inserted recently, so
+// it stays cheap on a large log. qso_date is parsed with parseTimeLoose (backend-
+// format agnostic).
+func (r *Repo) RecentRateBreakdown(ctx context.Context, now time.Time, operator string, windows ...time.Duration) (op []int, all []int, err error) {
+	op = make([]int, len(windows))
+	all = make([]int, len(windows))
+	// 2000 rows covers a full hour even in a busy multi-op run.
 	rows, err := r.db.QueryContext(ctx, `SELECT operator, qso_date FROM qso ORDER BY id DESC LIMIT 2000`)
 	if err != nil {
-		return counts, err
+		return op, all, err
 	}
 	defer rows.Close()
 	now = now.UTC()
@@ -1943,23 +1996,24 @@ func (r *Repo) RecentRate(ctx context.Context, now time.Time, operator string, w
 	for rows.Next() {
 		var oper, dateStr sql.NullString
 		if err := rows.Scan(&oper, &dateStr); err != nil {
-			return counts, err
-		}
-		if strings.ToUpper(strings.TrimSpace(oper.String)) != opFilter {
-			continue // a different operator's QSO — not part of my rate
+			return op, all, err
 		}
 		t := parseTimeLoose(dateStr.String).UTC()
 		if t.IsZero() || t.After(now) {
 			continue
 		}
+		mine := strings.ToUpper(strings.TrimSpace(oper.String)) == opFilter
 		age := now.Sub(t)
 		for i, w := range windows {
 			if age <= w {
-				counts[i]++
+				all[i]++
+				if mine {
+					op[i]++
+				}
 			}
 		}
 	}
-	return counts, rows.Err()
+	return op, all, rows.Err()
 }
 
 // ExistingDedupeKeys returns a set of every QSO key currently in the DB,
@@ -2374,6 +2428,7 @@ func scanQSO(s scanner) (QSO, error) {
 		creditGranted, creditSubmitted         sql.NullString
 		myARRLSect, myVUCCGrids                 sql.NullString
 		extrasJSON                            sql.NullString
+		awardRefs                             sql.NullString
 		createdStr, updatedStr                string
 	)
 	if err := s.Scan(
@@ -2401,7 +2456,7 @@ func scanQSO(s scanner) (QSO, error) {
 		&skcc, &fists, &tenTen, &contactedOp, &eqCall, &pfx, &myName, &class,
 		&darcDOK, &myDarcDOK, &region, &silentKey, &swl, &qsoComplete, &qsoRandom,
 		&creditGranted, &creditSubmitted, &myARRLSect, &myVUCCGrids,
-		&extrasJSON, &createdStr, &updatedStr,
+		&extrasJSON, &awardRefs, &createdStr, &updatedStr,
 	); err != nil {
 		return QSO{}, fmt.Errorf("scan qso: %w", err)
 	}
@@ -2598,6 +2653,7 @@ func scanQSO(s scanner) (QSO, error) {
 	q.MyARRLSect = myARRLSect.String
 	q.MyVUCCGrids = myVUCCGrids.String
 	q.Extras = decodeExtras(extrasJSON.String)
+	q.AwardRefs = awardRefs.String
 	return q, nil
 }
 

livestatus.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"database/sql"
 	"fmt"
 	"strings"
 	"time"
@@ -87,12 +88,29 @@ func (a *App) seedLiveLastQSO() {
 	}
 }
 
-// LiveLastQSOAgeSec returns seconds since this operator's last logged QSO, or -1 if
-// none is known — the UI uses it to seed the "on air" badge at launch.
-func (a *App) LiveLastQSOAgeSec() int {
+// liveLastQSOTime is the authoritative "last contact" instant for this operator:
+// the most recent of the in-memory stamp (this session's local logs, updated
+// instantly) AND the DB (a contact that arrived via the SHARED logbook from another
+// station, or one logged before launch). Used by both the published status and the
+// UI badge so on-air/offline is right in every multi-op case.
+func (a *App) liveLastQSOTime() time.Time {
 	a.liveActMu.Lock()
 	last := a.liveLastQSOAt
 	a.liveActMu.Unlock()
+	if a.qso != nil {
+		if op, _ := a.liveStatusOperator(); op != "" {
+			if t, ok := a.qso.LastQSOTime(a.ctx, op); ok && t.After(last) {
+				last = t
+			}
+		}
+	}
+	return last
+}
+
+// LiveLastQSOAgeSec returns seconds since this operator's last logged QSO, or -1 if
+// none is known — the UI polls it for the "on air" badge.
+func (a *App) LiveLastQSOAgeSec() int {
+	last := a.liveLastQSOTime()
 	if last.IsZero() {
 		return -1
 	}
@@ -182,35 +200,93 @@ func (a *App) publishLiveStatus() {
 	if mode == "" {
 		mode = a.liveMode
 	}
-	lastQSO := a.liveLastQSOAt
 	a.liveActMu.Unlock()
-	// Online = a new contact was logged within the window. An operator who leaves
-	// the log open but stops working shows offline after `liveOnlineWindow`; the
-	// next QSO flips them back on. never-logged (zero time) → offline.
-	online := 0
-	var lastQSOArg any
-	if !lastQSO.IsZero() {
-		lastQSOArg = lastQSO.UTC()
-		if time.Since(lastQSO) < liveOnlineWindow {
-			online = 1
-		}
-	}
+	lastQSO := a.liveLastQSOTime() // authoritative (in-memory OR shared DB)
+	// On air = a new contact was logged within the window. An operator who leaves
+	// the log open but stops working goes offline after `liveOnlineWindow`; the next
+	// QSO puts them back on. never-logged (zero time) → offline.
+	online := !lastQSO.IsZero() && time.Since(lastQSO) < liveOnlineWindow
 	if err := a.ensureLiveStatusTable(); err != nil {
 		applog.Printf("livestatus: CREATE TABLE failed: %v", err)
 		return
 	}
+	// Offline → REMOVE the row entirely, not just flip a flag: a status page that
+	// lists the present rows (the common case, keyed on updated_at) then shows the
+	// operator as gone without having to read the online column. The row reappears
+	// on the next QSO. This is the whole point — no one shows on air when they're not.
+	if !online {
+		if _, err := a.logDb.ExecContext(a.ctx, "DELETE FROM live_status WHERE operator=?", op); err != nil {
+			applog.Printf("livestatus: offline DELETE failed: %v", err)
+		}
+		return
+	}
+	lastQSOArg := lastQSO.UTC()
 	_, err := a.logDb.ExecContext(a.ctx,
-		"INSERT INTO live_status (operator, station, freq_hz, band, mode, online, last_qso_at, updated_at) "+
-			"VALUES (?, ?, ?, ?, ?, ?, ?, UTC_TIMESTAMP()) "+
+		"INSERT INTO live_status (operator, station, freq_hz, band, mode, online, version, last_qso_at, updated_at) "+
+			"VALUES (?, ?, ?, ?, ?, ?, ?, ?, UTC_TIMESTAMP()) "+
 			"ON DUPLICATE KEY UPDATE station=VALUES(station), freq_hz=VALUES(freq_hz), "+
-			"band=VALUES(band), mode=VALUES(mode), online=VALUES(online), "+
+			"band=VALUES(band), mode=VALUES(mode), online=VALUES(online), version=VALUES(version), "+
 			"last_qso_at=VALUES(last_qso_at), updated_at=UTC_TIMESTAMP()",
-		op, station, freqHz, band, mode, online, lastQSOArg)
+		op, station, freqHz, band, mode, 1, appVersion, lastQSOArg)
 	if err != nil {
 		applog.Printf("livestatus: INSERT failed: %v", err)
 		return
 	}
-	applog.Printf("livestatus: published op=%s station=%s %dHz %s %s online=%d", op, station, freqHz, band, mode, online)
+	applog.Printf("livestatus: published op=%s station=%s %dHz %s %s ON AIR", op, station, freqHz, band, mode)
+}
+
+// LiveStation is one operator's live status for the multi-op "who's on air" widget.
+type LiveStation struct {
+	Operator string `json:"operator"`
+	Station  string `json:"station"`
+	FreqHz   int64  `json:"freq_hz"`
+	Band     string `json:"band"`
+	Mode     string `json:"mode"`
+	Online   bool   `json:"online"`  // logged a QSO in the last 5 min
+	Version  string `json:"version"` // that operator's OpsLog version
+	AgeSec   int    `json:"age_sec"` // seconds since their last heartbeat (stale = OpsLog closed)
+}
+
+// GetLiveStations returns every operator's live status from the shared MySQL
+// logbook (empty on a local SQLite logbook). Rows whose heartbeat is very stale
+// (OpsLog closed without clearing its row) are dropped. Online stations first.
+func (a *App) GetLiveStations() []LiveStation {
+	if a.logDb == nil || a.dbBackend != "mysql" {
+		return nil
+	}
+	if err := a.ensureLiveStatusTable(); err != nil {
+		return nil
+	}
+	rows, err := a.logDb.QueryContext(a.ctx,
+		"SELECT operator, COALESCE(station,''), COALESCE(freq_hz,0), COALESCE(band,''), "+
+			"COALESCE(mode,''), COALESCE(online,0), COALESCE(version,''), "+
+			"TIMESTAMPDIFF(SECOND, updated_at, UTC_TIMESTAMP()) "+
+			"FROM live_status ORDER BY online DESC, operator")
+	if err != nil {
+		applog.Printf("livestatus: list failed: %v", err)
+		return nil
+	}
+	defer rows.Close()
+	out := []LiveStation{}
+	for rows.Next() {
+		var s LiveStation
+		var online int
+		var age sql.NullInt64
+		if err := rows.Scan(&s.Operator, &s.Station, &s.FreqHz, &s.Band, &s.Mode, &online, &s.Version, &age); err != nil {
+			continue
+		}
+		// Drop rows from an OpsLog that hasn't heartbeated in a while (closed): the
+		// heartbeat is every 15 s, so > 3 min means it's gone.
+		if age.Valid && age.Int64 > 180 {
+			continue
+		}
+		s.Online = online == 1
+		if age.Valid {
+			s.AgeSec = int(age.Int64)
+		}
+		out = append(out, s)
+	}
+	return out
 }
 
 func (a *App) ensureLiveStatusTable() error {
@@ -222,15 +298,17 @@ func (a *App) ensureLiveStatusTable() error {
 			"band VARCHAR(16), "+
 			"mode VARCHAR(16), "+
 			"online TINYINT DEFAULT 0, "+
+			"version VARCHAR(32), "+
 			"last_qso_at DATETIME NULL, "+
 			"updated_at DATETIME)"); err != nil {
 		return err
 	}
-	// Add the online/last_qso_at columns to a table created by an older build.
-	// MySQL has no portable "ADD COLUMN IF NOT EXISTS", so just run the ALTERs and
-	// ignore the duplicate-column error when they already exist.
+	// Add newer columns to a table created by an older build. MySQL has no portable
+	// "ADD COLUMN IF NOT EXISTS", so just run the ALTERs and ignore the duplicate-
+	// column error when they already exist.
 	for _, ddl := range []string{
 		"ALTER TABLE live_status ADD COLUMN online TINYINT DEFAULT 0",
+		"ALTER TABLE live_status ADD COLUMN version VARCHAR(32)",
 		"ALTER TABLE live_status ADD COLUMN last_qso_at DATETIME NULL",
 	} {
 		if _, err := a.logDb.ExecContext(a.ctx, ddl); err != nil && !strings.Contains(strings.ToLower(err.Error()), "duplicate column") {

relayauto.go

@@ -96,8 +96,23 @@ func bandInList(bands []string, band string) bool {
 	return false
 }
 
+// relayAction is one relay's computed desired state for this evaluation.
+type relayAction struct {
+	dev   string
+	relay int
+	want  bool
+}
+
 // applyRelayAuto evaluates every rule against the current frequency/band and
-// switches only the relays whose desired state changed since the last apply.
+// switches only the relays that are NOT already in the wanted position. Two things
+// it deliberately does NOT do, which used to make the relay clunk on every
+// launch/close:
+//   - Never acts on an UNKNOWN frequency/band. When the CAT disconnects (app close)
+//     the frequency drops to 0; reading that as "out of range" and switching the
+//     relay off — then back on at the next launch — was the whole bug.
+//   - Never commands a relay already in the right position: on the first evaluation
+//     after launch/save it reads the boards' LIVE state, so a relay that's already
+//     correct is left untouched instead of being re-sent.
 func (a *App) applyRelayAuto(freqHz int64, band string) {
 	a.relayAutoMu.Lock()
 	defer a.relayAutoMu.Unlock()
@@ -110,8 +125,11 @@ func (a *App) applyRelayAuto(freqHz int64, band string) {
 		a.relayAutoLast = map[string]bool{}
 	}
 	khz := float64(freqHz) / 1000.0
+	band = strings.TrimSpace(band)
 
-	changed := false
+	// Compute desired states, skipping rules whose input is unknown right now.
+	var acts []relayAction
+	needLive := false
 	for _, r := range cfg.Rules {
 		if r.Relay < 1 {
 			continue
@@ -119,8 +137,11 @@ func (a *App) applyRelayAuto(freqHz int64, band string) {
 		var want bool
 		switch r.Mode {
 		case "freq":
+			if freqHz <= 0 {
+				continue // no known frequency (CAT off/closing) → leave the relay as-is
+			}
 			if r.FreqLoKHz <= 0 && r.FreqHiKHz <= 0 {
-				continue // unconfigured range → leave the relay alone
+				continue // unconfigured range
 			}
 			lo, hi := r.FreqLoKHz, r.FreqHiKHz
 			if hi < lo {
@@ -128,6 +149,9 @@ func (a *App) applyRelayAuto(freqHz int64, band string) {
 			}
 			want = khz >= lo && khz <= hi
 		case "band":
+			if band == "" {
+				continue // no known band → leave the relay as-is
+			}
 			if len(r.Bands) == 0 {
 				continue
 			}
@@ -135,16 +159,43 @@ func (a *App) applyRelayAuto(freqHz int64, band string) {
 		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
+		acts = append(acts, relayAction{r.DeviceID, r.Relay, want})
+		if _, ok := a.relayAutoLast[relayAutoKey(r.DeviceID, r.Relay)]; !ok {
+			needLive = true
 		}
-		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)
+	}
+	if len(acts) == 0 {
+		return
+	}
+
+	// First evaluation after launch/save: read the boards' LIVE relay states once
+	// so we don't re-command a relay that's already in the wanted position.
+	var live map[string]bool
+	if needLive {
+		live = map[string]bool{}
+		for _, ds := range a.GetStationStatus() {
+			for _, rl := range ds.Relays {
+				live[relayAutoKey(ds.ID, rl.Number)] = rl.On
+			}
+		}
+	}
+
+	changed := false
+	for _, ac := range acts {
+		key := relayAutoKey(ac.dev, ac.relay)
+		cur, known := a.relayAutoLast[key]
+		if !known && live != nil {
+			cur, known = live[key]
+		}
+		if known && cur == ac.want {
+			a.relayAutoLast[key] = ac.want // already in position — record it, don't switch
+			continue
+		}
+		if err := a.StationSetRelay(ac.dev, ac.relay, ac.want); err != nil {
+			applog.Printf("relay auto: set %s relay %d = %v failed: %v", ac.dev, ac.relay, ac.want, err)
 			continue // don't cache a failed write — retry next change
 		}
-		a.relayAutoLast[key] = want
+		a.relayAutoLast[key] = ac.want
 		changed = true
 	}
 

telemetry.go

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

update.go

@@ -11,6 +11,7 @@ import (
 	"path/filepath"
 	"strconv"
 	"strings"
+	"syscall"
 	"time"
 
 	wruntime "github.com/wailsapp/wails/v2/pkg/runtime"
@@ -159,14 +160,26 @@ func (a *App) DownloadAndApplyUpdate(url string) error {
 		_ = os.Rename(oldExe, exe) // roll back
 		return fmt.Errorf("install new exe: %w", err)
 	}
-	applog.Printf("update: installed new exe, relaunching")
+	// Clear the "downloaded from the internet" mark (NTFS Zone.Identifier stream).
+	// Otherwise Windows SmartScreen wants to prompt "are you sure you want to open
+	// this?" — but since we launch the exe programmatically that prompt never shows,
+	// and the launch is silently blocked. This is exactly why the relaunch failed.
+	_ = os.Remove(exe + ":Zone.Identifier")
+	applog.Printf("update: installed new exe, scheduling relaunch")
 
-	// Relaunch with a flag so the fresh instance waits for THIS one to exit and
-	// free the single-instance mutex instead of bailing out immediately.
-	cmd := exec.Command(exe, "--post-update")
-	cmd.Dir = dir
+	// Relaunch via a detached, hidden PowerShell that WAITS for this process to exit
+	// (so the single-instance mutex is free) and THEN starts the new exe. Launching
+	// the new exe directly while we're still alive raced the mutex and often left
+	// nothing running; waiting for our own exit first makes the restart reliable,
+	// and the launcher outlives us.
+	quoted := strings.ReplaceAll(exe, "'", "''")
+	ps := fmt.Sprintf(
+		"Wait-Process -Id %d -ErrorAction SilentlyContinue; Start-Sleep -Milliseconds 400; Start-Process -FilePath '%s' -ArgumentList '--post-update'",
+		os.Getpid(), quoted)
+	cmd := exec.Command("powershell", "-NoProfile", "-WindowStyle", "Hidden", "-Command", ps)
+	cmd.SysProcAttr = &syscall.SysProcAttr{HideWindow: true, CreationFlags: 0x08000000} // CREATE_NO_WINDOW
 	if err := cmd.Start(); err != nil {
-		return fmt.Errorf("relaunch: %w", err)
+		return fmt.Errorf("schedule relaunch: %w", err)
 	}
 	if a.ctx != nil {
 		wruntime.Quit(a.ctx)