feat: clicking the status-bar amplifier chip toggles OPERATE <-> STANDBY (SPE/ACOM, optimistic flip reconciled by the poll; disabled offline) — PGXL still opens Settings, it has no standby command

README.fr.md

@@ -1,5 +1,9 @@
 # OpsLog
 
+<a href="https://discord.gg/FYM8yw5pT" target="_blank">
+  <img src="https://img.shields.io/badge/Discord-Rejoindre%20le%20serveur-5865F2?logo=discord&logoColor=white" alt="Rejoindre notre Discord" />
+</a>
+
 Un logiciel de log radioamateur moderne et rapide pour Windows — saisie façon
 Log4OM, CAT en temps réel pour **OmniRig**, **FlexRadio/SmartSDR** natif,
 **Icom CI-V** natif (USB **et** à distance par internet, en remplacement de

README.md

@@ -1,5 +1,9 @@
 # OpsLog
 
+<a href="https://discord.gg/FYM8yw5pT" target="_blank">
+  <img src="https://img.shields.io/badge/Discord-Join%20the%20server-5865F2?logo=discord&logoColor=white" alt="Join our Discord" />
+</a>
+
 A modern, fast ham-radio logger for Windows — Log4OM-style entry, real-time CAT
 for **OmniRig**, native **FlexRadio/SmartSDR**, native **Icom CI-V** (USB **and**
 remote-over-internet, replacing RS-BA1) and **TCI** (SunSDR / Expert Electronics),

app.go

@@ -19,6 +19,7 @@ import (
 	"sync/atomic"
 	"time"
 
+	"hamlog/internal/acom"
 	"hamlog/internal/adif"
 	"hamlog/internal/alerts"
 	"hamlog/internal/antgenius"
@@ -44,15 +45,15 @@ import (
 	"hamlog/internal/operating"
 	"hamlog/internal/pota"
 	"hamlog/internal/powergenius"
-	"hamlog/internal/spe"
 	"hamlog/internal/profile"
 	"hamlog/internal/qslcard"
 	"hamlog/internal/qso"
-	"hamlog/internal/rotator/pst"
 	"hamlog/internal/relaydev"
+	"hamlog/internal/rotator/pst"
 	"hamlog/internal/rotgenius"
 	"hamlog/internal/settings"
 	"hamlog/internal/solar"
+	"hamlog/internal/spe"
 	"hamlog/internal/steppir"
 	"hamlog/internal/uls"
 	"hamlog/internal/ultrabeam"
@@ -446,8 +447,8 @@ type App struct {
 	// wcbm is an in-memory "CALL|BAND|MODE" worked-index so the alert engine never
 	// queries the DB per cluster spot (an FT8 firehose would swamp a remote MySQL).
 	// Loaded once, appended to on each log, rebuilt after bulk changes.
-	wcbm   map[string]struct{}
-	wcbmMu sync.RWMutex
+	wcbm           map[string]struct{}
+	wcbmMu         sync.RWMutex
 	pota           *pota.Cache
 	uls            *uls.Store // US callsign→county/grid (offline FCC ULS), lazily opened
 	awardRefs      *awardref.Repo
@@ -466,6 +467,7 @@ type App struct {
 	antgenius      *antgenius.Client   // Antenna Genius (4O3A) switch (TCP); nil when disabled
 	pgxl           *powergenius.Client // PowerGenius XL (4O3A) amp fan control (TCP); nil when disabled
 	spe            *spe.Client         // SPE Expert amplifier (serial/TCP); nil when disabled or not SPE
+	acom           *acom.Client        // ACOM 500S/600S/700S/1200S/2020S amplifier (serial/TCP); nil when disabled or not ACOM
 	audioMgr       *audio.Manager
 	qsoRec         *audio.Recorder    // continuous QSO recorder (rolling pre-roll)
 	solar          *solar.Manager     // live space-weather (SFI/SSN/A/K) for the header + QSO stamping
@@ -481,27 +483,27 @@ type App struct {
 
 	alertStore *alerts.Store // DX-cluster spot alert rules (global JSON)
 
-	startupProfile string            // --profile <name> from the command line (activate at startup)
-	dvkRecSlot     int               // slot currently being recorded (DVKStartRecord → DVKStopRecord)
-	dvkPttKeyed    bool              // we keyed PTT for a voice message; unkey when it ends
+	startupProfile string // --profile <name> from the command line (activate at startup)
+	dvkRecSlot     int    // slot currently being recorded (DVKStartRecord → DVKStopRecord)
+	dvkPttKeyed    bool   // we keyed PTT for a voice message; unkey when it ends
 	pttMu          sync.Mutex
-	udpLogMu       sync.Mutex      // serialises UDP auto-log so concurrent packets can't both pass the dedup check
-	adifMonMu      sync.Mutex      // guards the ADIF-monitor config (file list + per-file read offsets)
-	relayAutoMu    sync.Mutex        // serialises relay auto-control evaluation
-	relayAutoLast  map[string]bool   // deviceID|relay → last applied on/off, so we only switch on a real change
-	relayAutoOn    atomic.Bool       // cached "auto-control enabled" so the CAT hot path skips work when off
-	relayDrvMu     sync.Mutex           // guards the cached relay drivers below
+	udpLogMu       sync.Mutex             // serialises UDP auto-log so concurrent packets can't both pass the dedup check
+	adifMonMu      sync.Mutex             // guards the ADIF-monitor config (file list + per-file read offsets)
+	relayAutoMu    sync.Mutex             // serialises relay auto-control evaluation
+	relayAutoLast  map[string]bool        // deviceID|relay → last applied on/off, so we only switch on a real change
+	relayAutoOn    atomic.Bool            // cached "auto-control enabled" so the CAT hot path skips work when off
+	relayDrvMu     sync.Mutex             // guards the cached relay drivers below
 	relayDrv       map[string]cachedRelay // deviceID → live driver (reused across polls; stateful boards can't be reopened per call)
-	pttPort        serial.Port     // open serial port while PTT (RTS/DTR) is asserted
-	pttKeyedMethod string          // "cat" | "rts" | "dtr" while keyed; "" when idle
-	pttGen         int64           // bumped on every key; a delayed unkey only fires if unchanged (guards against a stale release cutting a new transmission)
-	startupErr     string          // captured for surfacing to the frontend
-	dbPath         string          // active database file (may be a user-chosen location)
-	logDb          *sql.DB         // QSO logbook connection — MySQL when the shared backend is enabled, else == db (local SQLite)
-	dbBackend      string          // "sqlite" | "mysql" — the logbook backend actually opened at startup
-	dbBackendErr   string          // non-empty when a configured MySQL backend failed and we fell back to SQLite
-	offlineQ       *offlineq.Queue // ADIF outbox: QSOs logged while the DB was unreachable
-	offlineMode    bool            // last write failed because the DB was unreachable
+	pttPort        serial.Port            // open serial port while PTT (RTS/DTR) is asserted
+	pttKeyedMethod string                 // "cat" | "rts" | "dtr" while keyed; "" when idle
+	pttGen         int64                  // bumped on every key; a delayed unkey only fires if unchanged (guards against a stale release cutting a new transmission)
+	startupErr     string                 // captured for surfacing to the frontend
+	dbPath         string                 // active database file (may be a user-chosen location)
+	logDb          *sql.DB                // QSO logbook connection — MySQL when the shared backend is enabled, else == db (local SQLite)
+	dbBackend      string                 // "sqlite" | "mysql" — the logbook backend actually opened at startup
+	dbBackendErr   string                 // non-empty when a configured MySQL backend failed and we fell back to SQLite
+	offlineQ       *offlineq.Queue        // ADIF outbox: QSOs logged while the DB was unreachable
+	offlineMode    bool                   // last write failed because the DB was unreachable
 
 	catFlexSpots       bool       // push cluster spots to the FlexRadio panadapter
 	catFlexDecodeSpots bool       // push WSJT-X decodes (heard stations) to the panadapter
@@ -511,11 +513,13 @@ type App struct {
 	liveBand           string
 	liveMode           string
 	livePublishTimer   *time.Timer // debounced live-status publish on activity change
-	liveLastQSOAt      time.Time  // when this operator last logged a NEW contact — drives online/offline
-	awardSnapMu        sync.Mutex // guards the award QSO snapshot
-	awardSnap          []qso.QSO  // light-scanned + enriched logbook snapshot reused across award computations
-	awardSnapRev       string     // logbook revision the snapshot was built at ("" = none)
-	dataDir            string     // <exeDir>/data — holds config.json, logs, cty.dat
+	liveLastQSOAt      time.Time   // when this operator last logged a NEW contact — drives online/offline
+	liveTableMu        sync.Mutex  // guards liveTableFor
+	liveTableFor       *sql.DB     // logbook whose live_status DDL has been ensured (once per connection, not per call)
+	awardSnapMu        sync.Mutex  // guards the award QSO snapshot
+	awardSnap          []qso.QSO   // light-scanned + enriched logbook snapshot reused across award computations
+	awardSnapRev       string      // logbook revision the snapshot was built at ("" = none)
+	dataDir            string      // <exeDir>/data — holds config.json, logs, cty.dat
 
 	// shuttingDown gates beforeClose re-entry: the first user attempt to
 	// close fires shutdown tasks (backup, future LoTW upload, ...) while
@@ -859,9 +863,9 @@ 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.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
 
 	// cty.dat for offline DXCC / country resolution. Cached on disk; first
@@ -1934,7 +1938,13 @@ func (a *App) AddQSO(q qso.QSO) (id int64, err error) {
 	// was redundant with the entry lookup and only slowed logging (a call not yet in
 	// the cache made AddQSO wait on QRZ/HamQTH). If the entry lookup hadn't finished
 	// when you logged (fast CW: type → Enter), the e-mail is simply blank — fine.
+	insT0 := time.Now()
 	id, err = a.qso.Add(a.ctx, q)
+	if d := time.Since(insT0); d > 2*time.Second {
+		// Surface a genuinely slow INSERT (DB lock / overloaded server) — this is the
+		// value we need when someone reports "logging took N seconds".
+		applog.Printf("log: SLOW qso insert took %s (call=%s band=%s mode=%s)", d.Round(time.Millisecond), q.Callsign, q.Band, q.Mode)
+	}
 	if err != nil && db.IsConnLost(err) {
 		// The database is UNREACHABLE (not a data error) — park the QSO in the
 		// offline outbox rather than lose it. Returns id = -1 so the UI can say
@@ -1948,25 +1958,36 @@ func (a *App) AddQSO(q qso.QSO) (id int64, err error) {
 	}
 	if err == nil {
 		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).
+		a.noteWorked(q.Callsign, q.Band, q.Mode) // keep the alert worked-index fresh (in-memory)
+		a.noteLiveQSO()                          // multi-op: flip this operator back "online" (publishes async)
+		// Announce the log RIGHT AWAY so the grid/UI refresh at once and the entry
+		// form clears immediately — the operator is not made to wait on the DB.
 		wruntime.EventsEmit(a.ctx, "qso:logged", id)
-		a.saveQSORecording(&q)
-		if a.extsvc != nil {
-			a.extsvc.OnQSOLogged(id)
-		}
-		a.maybeAutoSendEQSL(q)
-		// Forward the ADIF of this QSO to any outbound "ADIF message" UDP rows.
-		if a.udp != nil {
-			go a.udp.EmitLoggedADIF(adif.SingleRecordADIF(q))
-		}
-		// A successful write means the link is healthy again — if QSOs are still
-		// parked, get them in now rather than waiting for the next tick.
-		if a.offlineMode && a.offlineQ != nil && a.offlineQ.Count() > 0 {
-			go func() { _, _ = a.replayOfflineQueue() }()
-		}
+		// Everything below writes to (or reads from) the shared DB. Run it OFF the
+		// critical path: on a busy multi-op MySQL the award_refs UPDATE alone could
+		// block ~40s (and hit "Too many connections"), which used to freeze the log
+		// (form stuck, "…" on the button) until it finished. The QSO row is already
+		// safely inserted; these just enrich it, so they can lag a beat.
+		qc := q
+		go func() {
+			a.materializeAwardRefs(qc) // fills the award_refs column
+			a.saveQSORecording(&qc)
+			if a.extsvc != nil {
+				a.extsvc.OnQSOLogged(id)
+			}
+			a.maybeAutoSendEQSL(qc)
+			if a.udp != nil {
+				a.udp.EmitLoggedADIF(adif.SingleRecordADIF(qc))
+			}
+			// Nudge the grid again so the award_refs columns appear once materialised.
+			if a.ctx != nil {
+				wruntime.EventsEmit(a.ctx, "qso:logged", id)
+			}
+			// A successful write means the link is healthy — flush any parked QSOs.
+			if a.offlineMode && a.offlineQ != nil && a.offlineQ.Count() > 0 {
+				_, _ = a.replayOfflineQueue()
+			}
+		}()
 	}
 	return id, err
 }
@@ -4317,8 +4338,8 @@ func (a *App) ExportAwardForCatalog(code string, version int) (string, error) {
 		return "", fmt.Errorf("load references: %w", err)
 	}
 	entry := struct {
-		Def        award.Def       `json:"def"`
-		References []awardref.Ref  `json:"references,omitempty"`
+		Def        award.Def      `json:"def"`
+		References []awardref.Ref `json:"references,omitempty"`
 	}{Def: def, References: refs}
 	b, err := json.MarshalIndent(entry, "", "  ")
 	if err != nil {
@@ -6292,7 +6313,7 @@ type clusterQueue struct {
 	mu     sync.Mutex
 	cond   *sync.Cond
 	buf    []clusterEvent
-	head   int  // index of the next event to pop (waste reclaimed by compaction)
+	head   int // index of the next event to pop (waste reclaimed by compaction)
 	closed bool
 }
 
@@ -9634,24 +9655,28 @@ func (a *App) LogUDPLoggedADIF(adifText string) (int64, error) {
 		return 0, fmt.Errorf("insert qso: %w", err)
 	}
 	q.ID = id
-	a.noteLiveQSO() // multi-op: flip this operator back "online"
-	a.materializeAwardRefs(q)
-	// Announce the log so UI widgets refresh AT ONCE (the Recent-QSOs grid, the
-	// ON-AIR badge and the "stations on air" widget). The manual log path always
-	// did this; the UDP/FT8 path did not, so a station running MSHV saw the top
-	// "on air" list lag ~15-45s behind the instant bottom badge.
+	a.noteLiveQSO() // multi-op: flip this operator back "online" (publishes async)
+	// Announce the log AT ONCE so the grid / ON-AIR badge / stations-on-air widget
+	// refresh immediately, then run the DB-heavy enrichment off the critical path
+	// (same reasoning as the manual path — award_refs on a busy shared MySQL blocked).
 	if a.ctx != nil {
 		wruntime.EventsEmit(a.ctx, "qso:logged", id)
 	}
-	a.saveQSORecording(&q)
-	if a.extsvc != nil {
-		a.extsvc.OnQSOLogged(id)
-	}
-	a.maybeAutoSendEQSL(q)
-	// A successful write means the link is healthy again — flush anything parked.
-	if a.offlineMode && a.offlineQ != nil && a.offlineQ.Count() > 0 {
-		go func() { _, _ = a.replayOfflineQueue() }()
-	}
+	qc := q
+	go func() {
+		a.materializeAwardRefs(qc)
+		a.saveQSORecording(&qc)
+		if a.extsvc != nil {
+			a.extsvc.OnQSOLogged(id)
+		}
+		a.maybeAutoSendEQSL(qc)
+		if a.ctx != nil {
+			wruntime.EventsEmit(a.ctx, "qso:logged", id) // refresh again so award_refs show
+		}
+		if a.offlineMode && a.offlineQ != nil && a.offlineQ.Count() > 0 {
+			_, _ = a.replayOfflineQueue()
+		}
+	}()
 	return id, nil
 }
 
@@ -11189,7 +11214,14 @@ func (a *App) ActivateProfile(id int64) error {
 	// target (local SQLite or its own MySQL) so QSOs go to the right logbook.
 	if p, err := a.profiles.Get(a.ctx, id); err == nil {
 		if err := a.switchLogbook(p); err != nil {
+			// The switch failed (typically: this profile's MySQL is unreachable right
+			// now) and the PREVIOUS logbook stays live. Silently staying on the old
+			// database is how QSOs end up in the wrong log — tell the operator.
 			applog.Printf("activate profile %d: logbook switch failed: %v", id, err)
+			if a.ctx != nil {
+				wruntime.EventsEmit(a.ctx, "toast", fmt.Sprintf(
+					"Profil %q : connexion à sa base impossible — l'ancienne base reste active ! (%v)", p.Name, err))
+			}
 		}
 	}
 	// Re-apply every settings-dependent subsystem for the new profile.
@@ -11321,7 +11353,6 @@ func (a *App) SaveRotatorSettings(s RotatorSettings) error {
 	return nil
 }
 
-
 // RotatorHeading is the live antenna heading for the status bar.
 type RotatorHeading struct {
 	Enabled bool   `json:"enabled"`
@@ -11440,14 +11471,14 @@ func boolStr(b bool) string {
 
 // StationDevice is one configured relay board for the Station Control tab.
 type StationDevice struct {
-	ID     string   `json:"id"`
-	Type   string   `json:"type"` // "webswitch" | "kmtronic" | "denkovi" | "usbrelay"
-	Name   string   `json:"name"`
-	Host   string   `json:"host"` // IP for network boards; FTDI serial for denkovi; COM port for usbrelay
-	User   string   `json:"user,omitempty"` // KMTronic HTTP auth (blank = none)
-	Pass   string   `json:"pass,omitempty"`
-	Channels int    `json:"channels,omitempty"` // usbrelay only: number of relays (1/2/4/8/16)
-	Labels []string `json:"labels"` // per-relay label (index 0 = relay 1)
+	ID       string   `json:"id"`
+	Type     string   `json:"type"` // "webswitch" | "kmtronic" | "denkovi" | "usbrelay"
+	Name     string   `json:"name"`
+	Host     string   `json:"host"`           // IP for network boards; FTDI serial for denkovi; COM port for usbrelay
+	User     string   `json:"user,omitempty"` // KMTronic HTTP auth (blank = none)
+	Pass     string   `json:"pass,omitempty"`
+	Channels int      `json:"channels,omitempty"` // usbrelay only: number of relays (1/2/4/8/16)
+	Labels   []string `json:"labels"`             // per-relay label (index 0 = relay 1)
 }
 
 // deviceRelayCount is the relay count for a configured device — fixed by type,
@@ -11720,12 +11751,12 @@ type motorAntenna interface {
 // convention, so commands pass straight through).
 type ubAdapter struct{ c *ultrabeam.Client }
 
-func (a ubAdapter) Start() error                { return a.c.Start() }
-func (a ubAdapter) Stop()                       { a.c.Stop() }
-func (a ubAdapter) SetFrequency(k, d int) error { return a.c.SetFrequency(k, d) }
-func (a ubAdapter) SetDirection(d int) error    { return a.c.SetDirection(d) }
-func (a ubAdapter) Retract() error              { return a.c.Retract() }
-func (a ubAdapter) LastSetKHz() int             { return a.c.LastSetKHz() }
+func (a ubAdapter) Start() error                 { return a.c.Start() }
+func (a ubAdapter) Stop()                        { a.c.Stop() }
+func (a ubAdapter) SetFrequency(k, d int) error  { return a.c.SetFrequency(k, d) }
+func (a ubAdapter) SetDirection(d int) error     { return a.c.SetDirection(d) }
+func (a ubAdapter) Retract() error               { return a.c.Retract() }
+func (a ubAdapter) LastSetKHz() int              { return a.c.LastSetKHz() }
 func (a ubAdapter) SetElement(n, mm int) error   { return a.c.ModifyElement(n, mm) }
 func (a ubAdapter) ReadElements() ([]int, error) { return a.c.ReadElements() }
 func (a ubAdapter) Elements() []int {
@@ -12248,11 +12279,12 @@ func (a *App) AntGeniusDeselect(port int) error {
 // ── PowerGenius XL (4O3A) amplifier fan control (TCP, default port 9008) ─────
 
 // PGXLSettings is the JSON shape for the Hardware → Amplifier panel. It covers
-// the 4O3A PowerGenius XL (TCP) and the SPE Expert amps (USB serial or an
-// RS232-to-Ethernet bridge). The type name is kept for binding compatibility.
+// the 4O3A PowerGenius XL (TCP), the SPE Expert amps and the ACOM S-series amps
+// (both: USB serial or an RS232-to-Ethernet bridge). The type name is kept for
+// binding compatibility.
 type PGXLSettings struct {
 	Enabled   bool   `json:"enabled"`
-	Type      string `json:"type"`      // "pgxl" | "spe13" | "spe15" | "spe2k"
+	Type      string `json:"type"`      // "pgxl" | "spe13" | "spe15" | "spe2k" | "acom500" | "acom600" | "acom700" | "acom1200" | "acom2020"
 	Transport string `json:"transport"` // "tcp" | "serial"
 	Host      string `json:"host"`      // TCP transport
 	Port      int    `json:"port"`      // TCP transport
@@ -12333,6 +12365,10 @@ func (a *App) startPGXL() {
 		go a.spe.Stop()
 		a.spe = nil
 	}
+	if a.acom != nil {
+		go a.acom.Stop()
+		a.acom = nil
+	}
 	s, err := a.GetPGXLSettings()
 	if err != nil || !s.Enabled {
 		return
@@ -12345,13 +12381,18 @@ func (a *App) startPGXL() {
 		_ = a.pgxl.Start()
 		return
 	}
-	// SPE Expert — USB serial or an RS232-to-Ethernet bridge.
+	// SPE Expert / ACOM — USB serial or an RS232-to-Ethernet bridge.
 	if s.Transport == "serial" && strings.TrimSpace(s.ComPort) == "" {
 		return
 	}
 	if s.Transport == "tcp" && strings.TrimSpace(s.Host) == "" {
 		return
 	}
+	if model, ok := strings.CutPrefix(s.Type, "acom"); ok {
+		a.acom = acom.New(acom.Config{Model: model + "S", Transport: s.Transport, ComPort: s.ComPort, Baud: s.Baud, Host: s.Host, Port: s.Port})
+		_ = a.acom.Start()
+		return
+	}
 	a.spe = spe.New(spe.Config{Transport: s.Transport, ComPort: s.ComPort, Baud: s.Baud, Host: s.Host, Port: s.Port})
 	_ = a.spe.Start()
 }
@@ -12392,6 +12433,35 @@ func (a *App) SPESetPowerLevel(level string) error {
 	return a.spe.SetPowerLevel(level)
 }
 
+// GetACOMStatus returns the ACOM amplifier state for the UI poll.
+func (a *App) GetACOMStatus() acom.Status {
+	if a.acom == nil {
+		return acom.Status{}
+	}
+	return a.acom.GetStatus()
+}
+
+// ACOMSetOperate puts the ACOM amp in OPERATE (true) or STANDBY (false) — the
+// protocol has explicit commands for each, unlike the SPE's toggle key.
+func (a *App) ACOMSetOperate(on bool) error {
+	if a.acom == nil {
+		return fmt.Errorf("ACOM amplifier not connected — enable it in Settings → Amplifier")
+	}
+	return a.acom.Operate(on)
+}
+
+// ACOMSetPower turns the ACOM amp on (true, a DTR/RTS pulse — serial only, needs
+// the power-on pins wired in the cable) or off (false, the OFF data command).
+func (a *App) ACOMSetPower(on bool) error {
+	if a.acom == nil {
+		return fmt.Errorf("ACOM amplifier not connected — enable it in Settings → Amplifier")
+	}
+	if on {
+		return a.acom.PowerOn()
+	}
+	return a.acom.PowerOff()
+}
+
 // GetPGXLStatus returns the amp's fan/connection state for the UI poll.
 func (a *App) GetPGXLStatus() powergenius.Status {
 	if a.pgxl == nil {

changelog.json

@@ -1,4 +1,20 @@
 [
+  {
+    "version": "0.20.7",
+    "date": "2026-07-21",
+    "en": [
+      "New: ACOM amplifier support (500S / 600S / 700S / 1200S / 2020S) — OPERATE/STANDBY/OFF, live telemetry (power, SWR, PA temperature, band, fan) in Settings and the radio panel, over USB serial or an RS232-to-Ethernet bridge. Power-ON works over serial when the cable wires the DTR/RTS pins. The Amplifier settings now pick Brand then Model.",
+      "Multi-operator live sync fixed: the shared-MySQL connection pool was too small, so after a while the grid, chat and 'stations on air' silently stopped updating. The pool is now sized for real multi-op use (with 5 operators it stays well within a max_connections=300 server).",
+      "Live operator status is now always published on a shared MySQL logbook — the Settings toggle is gone. You still go off-air automatically 5 minutes after your last QSO, and the 'stations on air' panel refreshes noticeably faster (a redundant table check on every read was removed).",
+      "The By-Continent statistics donut now totals the same as your QSO count — QSOs whose continent couldn't be resolved are shown as an 'Unknown' slice instead of being dropped (the Continents count still lists only real continents)."
+    ],
+    "fr": [
+      "Nouveau : prise en charge des amplificateurs ACOM (500S / 600S / 700S / 1200S / 2020S) — OPERATE/STANDBY/OFF, télémétrie en direct (puissance, ROS, température PA, bande, ventilateur) dans les Réglages et le panneau radio, en USB série ou via un pont RS232-vers-Ethernet. La mise en marche fonctionne en série si le câble relie les broches DTR/RTS. Les réglages Amplificateur se font maintenant par Marque puis Modèle.",
+      "Synchronisation multi-opérateurs corrigée : le pool de connexions MySQL partagé était trop petit, et au bout d'un moment la grille, le chat et « stations on air » cessaient silencieusement de se mettre à jour. Le pool est maintenant dimensionné pour un vrai multi-op (à 5 opérateurs, on reste largement sous un serveur à max_connections=300).",
+      "Le statut opérateur en direct est maintenant toujours publié sur un logbook MySQL partagé — l'option des Réglages a disparu. Vous passez toujours hors antenne automatiquement 5 minutes après votre dernier QSO, et le panneau « stations on air » se rafraîchit nettement plus vite (une vérification de table redondante à chaque lecture a été supprimée).",
+      "La donut « Par continent » des statistiques totalise maintenant le même nombre que le total de QSO — les QSO dont le continent n'a pas pu être résolu apparaissent dans un segment « Unknown » au lieu d'être ignorés (le compteur Continents ne liste toujours que les vrais continents)."
+    ]
+  },
   {
     "version": "0.20.6",
     "date": "2026-07-21",

frontend/src/App.tsx

@@ -42,7 +42,8 @@ import {
   QSOAudioBegin, QSOAudioCancel, QSOAudioRestart, QSOAudioResetClock,
   GetAwardDefs,
   GetUIPref, GetActiveProfile, QuitApp,
-  ReportLiveActivity, GetLiveStatusEnabled, LiveLastQSOAgeSec,
+  ReportLiveActivity, LiveLastQSOAgeSec,
+  GetPGXLSettings, GetPGXLStatus, GetSPEStatus, GetACOMStatus, SPESetOperate, ACOMSetOperate,
 } from '../wailsjs/go/main/App';
 import { Combobox } from '@/components/ui/combobox';
 import { applyAwardRefs } from '@/lib/awardRefs';
@@ -436,6 +437,27 @@ 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);
+  // Amplifier chip in the status bar: name + green OPERATE / orange STANDBY /
+  // red offline. Config re-read every 5s (so enabling the amp in Settings makes
+  // the chip appear); status polled every 2s while enabled.
+  const [ampCfg, setAmpCfg] = useState<{ enabled: boolean; type: string }>({ enabled: false, type: 'pgxl' });
+  const [ampSt, setAmpSt] = useState<any>({ connected: false });
+  useEffect(() => {
+    let alive = true;
+    const load = () => GetPGXLSettings().then((s: any) => { if (alive) setAmpCfg({ enabled: !!s?.enabled, type: s?.type || 'pgxl' }); }).catch(() => {});
+    load();
+    const id = window.setInterval(load, 5000);
+    return () => { alive = false; window.clearInterval(id); };
+  }, []);
+  useEffect(() => {
+    if (!ampCfg.enabled) { setAmpSt({ connected: false }); return; }
+    let alive = true;
+    const get = ampCfg.type === 'pgxl' ? GetPGXLStatus : ampCfg.type.startsWith('acom') ? GetACOMStatus : GetSPEStatus;
+    const tick = () => get().then((s: any) => alive && setAmpSt(s || { connected: false })).catch(() => {});
+    tick();
+    const id = window.setInterval(tick, 2000);
+    return () => { alive = false; window.clearInterval(id); };
+  }, [ampCfg.enabled, ampCfg.type]);
   // 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 };
@@ -1121,22 +1143,22 @@ export default function App() {
   useEffect(() => { if (!showSettings) setShowBeamOnMap(localStorage.getItem('opslog.showBeamOnMap') !== '0'); }, [showSettings]);
   // "ON AIR" status-bar badge: mirrors the multi-op live status this operator
   // publishes — online (blinking) when a QSO was logged in the last 5 min, else
-  // offline. Only shown when live-status publishing is enabled (Settings→General).
-  const [liveStatusOn, setLiveStatusOn] = useState(false);
+  // offline. Publishing is always on for a shared MySQL logbook (no user toggle:
+  // 5 min without a QSO removes the row automatically), so the badge simply
+  // follows the backend.
   const [onAir, setOnAir] = useState(false);
-  useEffect(() => { if (!showSettings) GetLiveStatusEnabled().then((v) => setLiveStatusOn(!!v)).catch(() => {}); }, [showSettings]);
   useEffect(() => {
     // 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))
+      .then((sec: number) => setOnAir(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)
+    const id = window.setInterval(refresh, 5 * 1000); // responsive without hammering (single indexed row)
     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]);
@@ -2147,39 +2169,45 @@ export default function App() {
     // Split the macro on <LOGQSO> so the log happens AT the token's position, not
     // only at the very end: "TU <LOGQSO> QRZ" sends "TU", logs, then sends "QRZ".
     // Each split boundary (every part except the last) is one <LOGQSO>.
-    const parts = rawText.split(/<LOGQSO>/i);
+    // RESOLVE every segment up front — while the form still holds the callsign — so a
+    // segment AFTER the <LOGQSO> (which logs and clears the form) still expands its
+    // variables correctly.
+    const parts = rawText.split(/<LOGQSO>/i).map((pt) => resolveCW(pt));
     const isRig = cwSourceRef.current === 'icom' || cwSourceRef.current === 'flex';
     for (let p = 0; p < parts.length; p++) {
       if (aborted()) return; // ESC / Stop before this segment → stop sending, don't log
-      const resolved = resolveCW(parts[p]);
+      const resolved = parts[p];
+      const isLast = p === parts.length - 1;
+      const logAfter = !isLast; // a <LOGQSO> follows this segment
       if (resolved) {
         // Trailing word space so back-to-back sends don't run together in the keyer
         // buffer ("CQ"+"TEST" → "CQTEST"); the keyer keys it as a word gap at the
         // current WPM, so it scales automatically.
         const keyed = resolved + ' ';
         setWkSent(resolved);
-        if (isRig) {
-          // The rig keyer (Icom 0x17 / Flex CWX) gives no busy echo we track, so
-          // wait the ESTIMATED send duration before moving on / logging.
-          const sendFn = cwSourceRef.current === 'flex' ? FlexSendCW : IcomSendCW;
-          await sendFn(keyed).catch((e) => setError(String(e?.message ?? e)));
-          await waitMs(Math.round(estimateCwMs(resolved, wkWpm)) + (p < parts.length - 1 ? 200 : 600));
-        } else {
-          await WinkeyerSend(keyed).catch((e) => setError(String(e?.message ?? e)));
-          // Wait for the keyer to actually finish this segment before we log /
-          // continue. We'd like to watch busy rise then fall, but over a
-          // remote/serial-over-IP link that echo can lag tens of seconds, so cap
-          // the wait at the ESTIMATED send duration + slack: proceed when busy
-          // clears OR the estimate elapses, whichever comes first.
-          const capMs = Math.round(estimateCwMs(resolved, wkWpm) * 1.4) + 2500;
-          for (let i = 0; i < 20 && !wkBusyRef.current && !aborted(); i++) await sleep(50); // ≤1s to start
-          const deadline = Date.now() + capMs;
-          while (wkBusyRef.current && !aborted() && Date.now() < deadline) await sleep(50);
+        const sendFn = cwSourceRef.current === 'flex' ? FlexSendCW : cwSourceRef.current === 'icom' ? IcomSendCW : null;
+        if (sendFn) await sendFn(keyed).catch((e) => setError(String(e?.message ?? e)));
+        else await WinkeyerSend(keyed).catch((e) => setError(String(e?.message ?? e)));
+        // Only WAIT for the CW to finish on the FINAL segment — auto-call needs the
+        // send done before its gap+resend. A segment a <LOGQSO> follows is NOT waited
+        // on: the keyer has already buffered the CW, so logging happens AT ONCE and
+        // never interrupts what's being sent. (Gating the log on a CW-length ESTIMATE
+        // made <LOGQSO> log up to ~10s late when the estimate ran long.)
+        if (isLast) {
+          if (isRig) {
+            await waitMs(Math.round(estimateCwMs(resolved, wkWpm)) + 600);
+          } else {
+            // WinKeyer: watch the busy echo, capped by the estimate (+slack) since
+            // over a remote/serial-over-IP link that echo can lag tens of seconds.
+            const capMs = Math.round(estimateCwMs(resolved, wkWpm) * 1.4) + 2500;
+            for (let i = 0; i < 20 && !wkBusyRef.current && !aborted(); i++) await sleep(50); // ≤1s to start
+            const deadline = Date.now() + capMs;
+            while (wkBusyRef.current && !aborted() && Date.now() < deadline) await sleep(50);
+          }
         }
       }
       if (aborted()) return; // aborted while this segment was sending → don't log
-      // A <LOGQSO> token follows every part except the last → log the contact here.
-      if (p < parts.length - 1) void save();
+      if (logAfter) void save(); // log NOW — the buffered CW keeps sending
     }
   }
   // stopAutoCall cancels any running auto-call loop.
@@ -3669,7 +3697,7 @@ export default function App() {
       case 'flex':
         return (
           <div className="h-full w-full min-h-0 rounded-lg overflow-hidden border border-border">
-            <FlexPanel onCWSpeed={(w) => { setWkWpm(w); WinkeyerSetSpeed(w).catch(() => {}); saveWk({ wpm: w }); }}
+            <FlexPanel onCWSpeed={(w) => { if (cwSourceRef.current === 'flex') setWkWpm(w); }}
               onReportRST={(r) => { setRstSent(r); rstUserEditedRef.current = true; }} />
           </div>
         );
@@ -4987,7 +5015,7 @@ export default function App() {
                 backend is a FlexRadio. */}
             {catState.backend === 'flex' && (
               <TabsContent value="flex" className="flex-1 min-h-0 p-0">
-                <FlexPanel onCWSpeed={(w) => { setWkWpm(w); WinkeyerSetSpeed(w).catch(() => {}); saveWk({ wpm: w }); }}
+                <FlexPanel onCWSpeed={(w) => { if (cwSourceRef.current === 'flex') setWkWpm(w); }}
               onReportRST={(r) => { setRstSent(r); rstUserEditedRef.current = true; }} />
               </TabsContent>
             )}
@@ -5116,16 +5144,49 @@ export default function App() {
               disabled={!rotatorHeading.enabled}
               onClick={() => { setSettingsSection('rotator'); setShowSettings(true); }}
             />
-            {liveStatusOn && (
-              <div
-                className={cn('inline-flex items-center gap-1.5 rounded-md border px-2 py-0.5 text-[11px] font-bold uppercase tracking-wider shrink-0 transition-colors',
-                  onAir ? 'border-danger-border bg-danger-muted text-danger-muted-foreground' : 'border-border text-muted-foreground')}
-                title={onAir ? t('live.onAirTip') : t('live.offlineTip')}
-              >
-                <span className={cn('size-2 rounded-full', onAir ? 'bg-danger animate-pulse' : 'bg-muted-foreground/40')} />
-                {onAir ? t('live.onAir') : t('live.offline')}
-              </div>
-            )}
+            {/* Amplifier chip: green = OPERATE, orange = STANDBY, red = offline.
+                CLICK toggles OPERATE ↔ STANDBY (SPE/ACOM; optimistic flip, the 2s
+                poll reconciles). The PGXL has no standby command here — its chip
+                opens Settings instead, and shows green when connected. */}
+            {ampCfg.enabled && (() => {
+              const isPGXL = ampCfg.type === 'pgxl';
+              const name = isPGXL ? 'PGXL'
+                : ampCfg.type.startsWith('acom') ? `ACOM ${ampSt.model || ''}`.trim()
+                : `SPE ${ampSt.model || ''}`.trim();
+              const dot = !ampSt.connected ? 'bg-danger' : (isPGXL || ampSt.operate) ? 'bg-success' : 'bg-warning';
+              const state = !ampSt.connected ? (ampSt.last_error || 'offline') : (isPGXL ? (ampSt.state || 'connected') : ampSt.operate ? 'OPERATE' : 'STANDBY');
+              const toggle = () => {
+                if (isPGXL) { setSettingsSection('pgxl'); setShowSettings(true); return; }
+                const want = !ampSt.operate;
+                setAmpSt((s: any) => ({ ...s, operate: want }));
+                (ampCfg.type.startsWith('acom') ? ACOMSetOperate(want) : SPESetOperate(want)).catch(() => {});
+              };
+              return (
+                <button
+                  type="button"
+                  disabled={!isPGXL && !ampSt.connected}
+                  title={`${name}: ${state}${!isPGXL && ampSt.connected ? (ampSt.operate ? ' — click for STANDBY' : ' — click for OPERATE') : ''}`}
+                  onClick={toggle}
+                  className={cn('inline-flex items-center gap-1.5 px-2 h-5 rounded border text-[11px] transition-colors',
+                    (!isPGXL && !ampSt.connected) ? 'opacity-60 cursor-default border-border' : 'border-border hover:bg-muted cursor-pointer')}
+                >
+                  <span className={cn('size-2 rounded-full', dot)} />
+                  {name}
+                </button>
+              );
+            })()}
+            {/* ON AIR badge: "did I log a QSO in the last 5 min" — meaningful on ANY
+                logbook backend (only the live_status PUBLISHING is MySQL-specific),
+                so it is always shown. Gating it on MySQL made it vanish for
+                local-SQLite operators when the Settings toggle was removed. */}
+            <div
+              className={cn('inline-flex items-center gap-1.5 rounded-md border px-2 py-0.5 text-[11px] font-bold uppercase tracking-wider shrink-0 transition-colors',
+                onAir ? 'border-danger-border bg-danger-muted text-danger-muted-foreground' : 'border-border text-muted-foreground')}
+              title={onAir ? t('live.onAirTip') : t('live.offlineTip')}
+            >
+              <span className={cn('size-2 rounded-full', onAir ? 'bg-danger animate-pulse' : 'bg-muted-foreground/40')} />
+              {onAir ? t('live.onAir') : t('live.offline')}
+            </div>
             {/* Toasts / errors: the status bar's free space is far wider than the
                 header band they used to sit in. Still one line (the bar is 28px),
                 but CLICK opens the full text wrapped — long messages (a TQSL or

frontend/src/components/FlexPanel.tsx

@@ -5,6 +5,7 @@ import {
   FlexSetProcessor, FlexSetProcessorLevel, FlexSetMon, FlexSetMonLevel, FlexSetMic,
   FlexMox, FlexAmpOperate,
   GetPGXLStatus, PGXLSetFanMode, GetPGXLSettings, GetSPEStatus, SPESetOperate, SPESetPower, SPESetPowerLevel,
+  GetACOMStatus, ACOMSetOperate, ACOMSetPower,
   FlexSetAGCMode, FlexSetAGCThreshold, FlexSetAudioLevel, FlexSetMute, FlexSetRXAntenna, FlexSetTXAntenna, FlexSetSplit, FlexSetActiveSlice, FlexSetTXSlice,
   FlexSetRIT, FlexSetRITFreq, FlexSetXIT, FlexSetXITFreq,
   FlexSetNB, FlexSetNBLevel, FlexSetNR, FlexSetNRLevel, FlexSetANF, FlexSetANFLevel,
@@ -288,6 +289,18 @@ export function FlexPanel({ onCWSpeed, onReportRST }: { onCWSpeed?: (wpm: number
   const { t } = useI18n();
   const [st, setSt] = useState<FlexState>(ZERO);
   const hold = useRef<Record<string, number>>({});
+  // Keep the host's keyer speed (used for CW-length estimates and the keyer panel)
+  // in step with the radio's ACTUAL CW speed — including when it's changed on the
+  // radio / in SmartSDR, not just via the slider below. Notify only on a real change.
+  const lastCwSpeed = useRef<number | null>(null);
+  useEffect(() => {
+    const w = st.cw_speed;
+    if (typeof w === 'number' && w > 0 && w !== lastCwSpeed.current) {
+      lastCwSpeed.current = w;
+      onCWSpeed?.(w);
+    }
+    // eslint-disable-next-line react-hooks/exhaustive-deps
+  }, [st.cw_speed]);
   // Peak-hold: keep the highest reading for ~2 s so the jittery VITA-49 meters
   // read steadily instead of jumping every poll.
   const peak = useRef<Record<string, { v: number; t: number }>>({});
@@ -340,7 +353,8 @@ export function FlexPanel({ onCWSpeed, onReportRST }: { onCWSpeed?: (wpm: number
     const id = window.setInterval(load, 5000);
     return () => { alive = false; window.clearInterval(id); };
   }, []);
-  const isSPE = ampEnabled && ampType !== 'pgxl';
+  const isACOM = ampEnabled && ampType.startsWith('acom');
+  const isSPE = ampEnabled && !isACOM && ampType !== 'pgxl';
   // SPE Expert live status (only polled when an SPE amp is configured).
   const [spe, setSpe] = useState<any>({ connected: false });
   useEffect(() => {
@@ -351,6 +365,16 @@ export function FlexPanel({ onCWSpeed, onReportRST }: { onCWSpeed?: (wpm: number
     const id = window.setInterval(tick, 1500);
     return () => { alive = false; window.clearInterval(id); };
   }, [isSPE]);
+  // ACOM live status (only polled when an ACOM amp is configured).
+  const [acom, setAcom] = useState<any>({ connected: false });
+  useEffect(() => {
+    if (!isACOM) return;
+    let alive = true;
+    const tick = () => GetACOMStatus().then((s: any) => alive && setAcom(s || { connected: false })).catch(() => {});
+    tick();
+    const id = window.setInterval(tick, 1500);
+    return () => { alive = false; window.clearInterval(id); };
+  }, [isACOM]);
 
   const change = (key: keyof FlexState, val: number | boolean | string, send: () => Promise<any>) => {
     hold.current[key] = Date.now() + 900;
@@ -860,10 +884,55 @@ export function FlexPanel({ onCWSpeed, onReportRST }: { onCWSpeed?: (wpm: number
           </Card>
         )}
 
+        {/* ACOM amplifier (serial/TCP) — shown when it's the configured amp. Driven
+            by OpsLog's own ACOM link (the Flex doesn't report ACOM amps). */}
+        {isACOM && (
+          <Card icon={Flame} title={`${t('flxp.amplifier')} · ACOM${acom.model ? ' ' + acom.model : ''}`} accent="#ea580c">
+            <div className="flex items-center gap-3 flex-wrap">
+              <button type="button" disabled={!acom.connected}
+                onClick={() => ACOMSetOperate(!acom.operate).catch(() => {})}
+                className={cn('px-4 py-2 rounded-lg text-sm font-extrabold tracking-wide border-2 transition-all disabled:opacity-30',
+                  acom.operate ? 'bg-warning text-warning-foreground border-warning shadow-[0_0_14px] shadow-warning/50' : 'bg-card text-warning border-warning hover:bg-warning-muted')}>
+                {acom.operate ? 'OPERATE' : 'STANDBY'}
+              </button>
+              {/* Power ON is a DTR/RTS pulse — serial only, and it works while the amp
+                  is off (the port stays open), so gate on port_open not connected. */}
+              <div className="inline-flex rounded-lg overflow-hidden border-2 border-success/70">
+                <button type="button" disabled={!(acom.port_open && acom.transport === 'serial')}
+                  onClick={() => ACOMSetPower(true).catch(() => {})}
+                  title={acom.transport === 'serial' ? 'Power on (DTR/RTS pulse — needs the power-on pins wired)' : 'Power-on needs the serial DTR/RTS lines — not available over a network bridge'}
+                  className="px-3 py-2 text-sm font-bold bg-card text-success hover:bg-success/15 disabled:opacity-30">ON</button>
+                <button type="button" disabled={!acom.connected}
+                  onClick={() => ACOMSetPower(false).catch(() => {})}
+                  className="px-3 py-2 text-sm font-bold bg-card text-danger border-l-2 border-success/70 hover:bg-danger/15 disabled:opacity-30">OFF</button>
+              </div>
+              <span className={cn('inline-flex items-center gap-1.5 text-sm', acom.connected ? 'text-muted-foreground' : 'text-danger')}>
+                <span className={cn('size-2 rounded-full', acom.connected ? 'bg-success' : 'bg-danger')} />
+                {acom.connected ? acom.state : t('flxp.acomOffline')}
+              </span>
+              {acom.connected && (
+                <span className="text-sm font-mono text-muted-foreground tabular-nums">
+                  {acom.band ? `${acom.band} · ` : ''}{acom.fwd_w}W · SWR {Number(acom.swr ?? 0).toFixed(1)} · {acom.temp_c}°C · Fan {acom.fan}
+                </span>
+              )}
+              <div className="flex-1" />
+              {acom.err_text && (
+                <span className="px-2 py-1 rounded bg-danger-muted text-danger-muted-foreground text-xs font-bold">⚠ {acom.err_text}</span>
+              )}
+            </div>
+            {acom.connected && (
+              <MeterBar label={t('flxp.outputPower')} value={Number(acom.fwd_w) || 0} unit="W"
+                lo={0} hi={Number(acom.max_w) || 800}
+                display={`${Number(acom.fwd_w) || 0} W`}
+                segColor={(f) => (f > 0.9 ? '#dc2626' : f > 0.75 ? '#f59e0b' : '#ea580c')} />
+            )}
+          </Card>
+        )}
+
         {/* External amplifier (PowerGenius XL) — only when the Flex reports one AND
-            PowerGenius is the selected amp type. Running an SPE Expert hides this
-            Flex-reported card so the two amps don't both show. */}
-        {st.amp_available && !isSPE && (
+            PowerGenius is the selected amp type. Running an SPE Expert or ACOM hides
+            this Flex-reported card so two amps don't both show. */}
+        {st.amp_available && !isSPE && !isACOM && (
           <Card icon={Flame} title={`${t('flxp.amplifier')}${st.amp_model ? ' · ' + st.amp_model : ''}`} accent="#ea580c">
             <div className="flex items-center gap-3">
               <button type="button" disabled={off}

frontend/src/components/SettingsModal.tsx

@@ -13,7 +13,7 @@ import {
   GetRotatorSettings, SaveRotatorSettings, TestRotator, RotatorPark, RotatorStop,
   GetUltrabeamSettings, SaveUltrabeamSettings, TestUltrabeam,
   GetAntGeniusSettings, SaveAntGeniusSettings,
-  GetPGXLSettings, SavePGXLSettings, GetSPEStatus, SPESetOperate,
+  GetPGXLSettings, SavePGXLSettings, GetSPEStatus, SPESetOperate, GetACOMStatus, ACOMSetOperate,
   GetWinkeyerSettings, SaveWinkeyerSettings, ListSerialPorts,
   GetAudioSettings, SaveAudioSettings, ListAudioInputDevices, ListAudioOutputDevices, PickAudioFolder, TestPTT,
   GetClublogCtyInfo, SetClublogCtyEnabled, DownloadClublogCty,
@@ -32,7 +32,6 @@ import {
   GetMySQLSettings, SaveMySQLSettings, TestMySQLConnection, GetDBBackendStatus,
   GetAutostartPrograms, SaveAutostartPrograms, BrowseExecutable, LaunchAutostartProgram,
   GetTelemetryEnabled, SetTelemetryEnabled,
-  GetLiveStatusEnabled, SetLiveStatusEnabled,
   GetQSLDefaults, SaveQSLDefaults,
   GetExternalServices, SaveExternalServices, TestQRZUpload, TestClublogUpload, TestHRDLogUpload, TestEQSLUpload,
   GetPOTAToken, SavePOTAToken,
@@ -566,26 +565,6 @@ function TelemetryToggle() {
   );
 }
 
-// LiveStatusToggle publishes this operator's current activity (call + band +
-// freq + mode) to the shared MySQL `live_status` table every ~15s, for multi-op
-// events — a small web script on your server renders it for the QRZ page. Only
-// useful on a MySQL logbook. Self-contained component (owns its async state).
-function LiveStatusToggle() {
-  const { t } = useI18n();
-  const [on, setOn] = useState(false);
-  const [loaded, setLoaded] = useState(false);
-  useEffect(() => {
-    GetLiveStatusEnabled().then((v) => setOn(!!v)).catch(() => {}).finally(() => setLoaded(true));
-  }, []);
-  return (
-    <label className="flex items-center gap-2 text-sm cursor-pointer">
-      <Checkbox checked={on} disabled={!loaded}
-        onCheckedChange={(c) => { const v = !!c; setOn(v); SetLiveStatusEnabled(v).catch(() => {}); }} />
-      {t('settings.liveStatus')} <span className="text-xs text-muted-foreground">({t('settings.liveStatusHint')})</span>
-    </label>
-  );
-}
-
 // ADIFMonitorPanel watches a list of external ADIF files (fldigi RTTY, N1MM,
 // VarAC…) and auto-imports newly appended QSOs — deliberately option-free: a
 // contact that arrives is imported and uploaded automatically like any log entry.
@@ -691,6 +670,47 @@ function SPEStatusCard() {
     </div>
   );
 }
+// Live ACOM amplifier status + OPERATE/STANDBY. Module-scoped for the same
+// remount reason as SPEStatusCard. Polls once a second while shown.
+function ACOMStatusCard() {
+  const [st, setSt] = useState<any>({ connected: false });
+  useEffect(() => {
+    let alive = true;
+    const tick = () => GetACOMStatus().then((s) => alive && setSt(s || {})).catch(() => {});
+    tick();
+    const id = window.setInterval(tick, 1000);
+    return () => { alive = false; window.clearInterval(id); };
+  }, []);
+  const operate = !!st.operate;
+  return (
+    <div className="rounded-md border border-border p-3 space-y-2 text-xs max-w-xl">
+      <div className="flex items-center gap-2">
+        <span className={cn('size-2 rounded-full', st.connected ? 'bg-success animate-pulse' : 'bg-danger')} />
+        <span className="font-semibold">{st.connected ? `ACOM ${st.model || ''}` : `ACOM ${st.model || ''} — not connected`}</span>
+        {!st.connected && st.last_error && <span className="text-danger truncate text-[10px]">{st.last_error}</span>}
+        <span className="flex-1" />
+        <Button size="sm" variant={operate ? 'default' : 'outline'} disabled={!st.connected}
+          onClick={() => ACOMSetOperate(!operate).catch(() => {})}
+          title="Toggle OPERATE / STANDBY">
+          {operate ? 'OPERATE' : 'STANDBY'}
+        </Button>
+      </div>
+      {st.connected && (
+        <div className="grid grid-cols-4 gap-x-3 gap-y-1 font-mono text-[11px]">
+          <div>{st.state}</div>
+          <div>Band {st.band || '—'}</div>
+          <div>{st.fwd_w} W</div>
+          <div>SWR {Number(st.swr ?? 0).toFixed(2)}</div>
+          <div>Refl {st.refl_w} W</div>
+          <div>Drive {st.drive_w} W</div>
+          <div>{st.temp_c}°C</div>
+          <div>Fan {st.fan}</div>
+          {st.err_text && <div className="col-span-4 text-warning">⚠ {st.err_text} ({st.err_code})</div>}
+        </div>
+      )}
+    </div>
+  );
+}
 function RelayAutoPanel() {
   const { t } = useI18n();
   const [enabled, setEnabled] = useState(false);
@@ -2690,7 +2710,32 @@ export function SettingsModal({ onClose, onSaved, initialSection, onMainPaneChan
 
   function PGXLPanelSettings() {
     const isPGXL = pgxl.type === 'pgxl';
+    const isACOM = (pgxl.type || '').startsWith('acom');
     const isSerial = pgxl.transport === 'serial';
+    // The stored `type` stays the single flat value ("spe13", "acom700", "pgxl" —
+    // binding compatibility); the UI presents it as brand + model.
+    const brand = isPGXL ? 'pgxl' : isACOM ? 'acom' : 'spe';
+    const brandModels: Record<string, { value: string; label: string }[]> = {
+      spe: [
+        { value: 'spe13', label: 'Expert 1.3K-FA' },
+        { value: 'spe15', label: 'Expert 1.5K-FA' },
+        { value: 'spe2k', label: 'Expert 2K-FA' },
+      ],
+      acom: [
+        { value: 'acom500', label: '500S' },
+        { value: 'acom600', label: '600S' },
+        { value: 'acom700', label: '700S' },
+        { value: 'acom1200', label: '1200S' },
+        { value: 'acom2020', label: '2020S' },
+      ],
+    };
+    // Each family has a fixed serial speed: SPE talks 115200, the ACOM S-series is
+    // 9600 8N1 — preset it so switching brand just works. PGXL is TCP-only.
+    const applyType = (v: string) => setPgxl((s) => ({
+      ...s, type: v,
+      transport: v === 'pgxl' ? 'tcp' : s.transport,
+      baud: v.startsWith('acom') ? 9600 : v.startsWith('spe') ? 115200 : s.baud,
+    }));
     return (
       <>
         <SectionHeader title="Amplifier" />
@@ -2700,21 +2745,44 @@ export function SettingsModal({ onClose, onSaved, initialSection, onMainPaneChan
             Enable amplifier control
           </label>
 
-          <div className="grid grid-cols-2 gap-3">
+          {/* Connection gets the widest column — "Network (RS232-to-Ethernet)" was
+              truncated with 3 equal columns. */}
+          <div className="grid grid-cols-[1fr_1fr_1.7fr] gap-3">
             <div className="space-y-1">
-              <Label>Amplifier</Label>
-              <Select value={pgxl.type} onValueChange={(v) => setPgxl((s) => ({ ...s, type: v, transport: v === 'pgxl' ? 'tcp' : s.transport }))}>
+              <Label>Brand</Label>
+              <Select value={brand} onValueChange={(b) => {
+                if (b === brand) return;
+                applyType(b === 'pgxl' ? 'pgxl' : brandModels[b][0].value);
+              }}>
                 <SelectTrigger className="h-9"><SelectValue /></SelectTrigger>
                 <SelectContent>
-                  <SelectItem value="pgxl">4O3A PowerGenius XL</SelectItem>
-                  <SelectItem value="spe13">SPE Expert 1.3K-FA</SelectItem>
-                  <SelectItem value="spe15">SPE Expert 1.5K-FA</SelectItem>
-                  <SelectItem value="spe2k">SPE Expert 2K-FA</SelectItem>
+                  <SelectItem value="pgxl">4O3A</SelectItem>
+                  <SelectItem value="spe">SPE</SelectItem>
+                  <SelectItem value="acom">ACOM</SelectItem>
                 </SelectContent>
               </Select>
             </div>
-            {/* PowerGenius is TCP-only; SPE amps connect over USB serial or an
-                RS232-to-Ethernet bridge, so they offer both. */}
+            <div className="space-y-1">
+              <Label>Model</Label>
+              {isPGXL ? (
+                // The PowerGenius is the brand's single model — fixed, no choice.
+                <Select value="pgxl" disabled>
+                  <SelectTrigger className="h-9"><SelectValue /></SelectTrigger>
+                  <SelectContent>
+                    <SelectItem value="pgxl">PowerGenius XL</SelectItem>
+                  </SelectContent>
+                </Select>
+              ) : (
+                <Select value={pgxl.type} onValueChange={applyType}>
+                  <SelectTrigger className="h-9"><SelectValue /></SelectTrigger>
+                  <SelectContent>
+                    {brandModels[brand].map((m) => <SelectItem key={m.value} value={m.value}>{m.label}</SelectItem>)}
+                  </SelectContent>
+                </Select>
+              )}
+            </div>
+            {/* PowerGenius is TCP-only; SPE and ACOM amps connect over USB serial or
+                an RS232-to-Ethernet bridge, so they offer both. */}
             {!isPGXL && (
               <div className="space-y-1">
                 <Label>Connection</Label>
@@ -2767,12 +2835,17 @@ export function SettingsModal({ onClose, onSaved, initialSection, onMainPaneChan
             </div>
           )}
 
-          {!isPGXL && pgxl.enabled && <SPEStatusCard />}
-          {!isPGXL && (
+          {!isPGXL && pgxl.enabled && (isACOM ? <ACOMStatusCard /> : <SPEStatusCard />)}
+          {!isPGXL && !isACOM && (
             <p className="text-[10px] text-muted-foreground">
               SPE control uses the amplifier's proprietary serial protocol (OPERATE toggle + live status). Save to (re)connect. Band / power-level / antenna are still managed on the amp from the transceiver CAT.
             </p>
           )}
+          {isACOM && (
+            <p className="text-[10px] text-muted-foreground">
+              ACOM control uses the amplifier's serial protocol (9600 8N1): OPERATE / STANDBY / OFF + live telemetry. Save to (re)connect. Power-ON needs the serial DTR/RTS pins wired in the cable (not available over a network bridge). Band tracking stays on the amp itself.
+            </p>
+          )}
         </div>
       </>
     );
@@ -4515,7 +4588,6 @@ export function SettingsModal({ onClose, onSaved, initialSection, onMainPaneChan
             {t('gen.checkUpdates')} <span className="text-xs text-muted-foreground">{t('gen.checkUpdatesHint')}</span>
           </label>
           <TelemetryToggle />
-          <LiveStatusToggle />
 
           <MainViewPanes onChanged={onMainPaneChanged} flexAvailable={flexAvailable} icomAvailable={icomAvailable} />
 

frontend/src/components/StationControlPanel.tsx

@@ -1,5 +1,5 @@
 import { useCallback, useEffect, useRef, useState } from 'react';
-import { Plus, Pencil, Trash2, Power, PlugZap, Loader2, Check, X, Compass, Square, Antenna as AntennaIcon, ArrowDownToLine, Minus, RefreshCw } from 'lucide-react';
+import { Plus, Pencil, Trash2, Power, PlugZap, Loader2, Check, X, Compass, Square, Antenna as AntennaIcon, ArrowDownToLine, Minus, RefreshCw, Flame } from 'lucide-react';
 import { Button } from '@/components/ui/button';
 import { Input } from '@/components/ui/input';
 import { Label } from '@/components/ui/label';
@@ -13,6 +13,9 @@ import {
   GetRotatorHeading, RotatorGoTo, RotatorStop,
   GetUltrabeamStatus, SetUltrabeamDirection, UltrabeamRetract, MotorSetElement, MotorReadElements,
   ListDenkoviDevices, ListSerialPorts, TestStationDevice,
+  GetPGXLSettings, GetPGXLStatus, PGXLSetFanMode,
+  GetSPEStatus, SPESetOperate, SPESetPower, SPESetPowerLevel,
+  GetACOMStatus, ACOMSetOperate, ACOMSetPower,
 } from '../../wailsjs/go/main/App';
 
 type RotatorProps = { centerLat?: number | null; centerLon?: number | null; bearing?: number | null };
@@ -246,6 +249,110 @@ function MotorAntennaWidget({ ant, refetch, t }: { ant: AntStatus; refetch: () =
   );
 }
 
+// AmplifierWidget brings the amplifier controls (Settings → Amplifier) into the
+// Station Control tab, so an operator WITHOUT a FlexRadio/Icom panel still has
+// them (the FlexPanel card only exists when a Flex is the rig). Same backends:
+// SPE Expert / ACOM (full control) and PowerGenius XL (fan mode + state).
+function AmplifierWidget({ ampType, t }: { ampType: string; t: (k: string, v?: any) => string }) {
+  const isACOM = ampType.startsWith('acom');
+  const isPGXL = ampType === 'pgxl';
+  const [st, setSt] = useState<any>({ connected: false });
+  useEffect(() => {
+    let alive = true;
+    const get = isPGXL ? GetPGXLStatus : isACOM ? GetACOMStatus : GetSPEStatus;
+    const tick = () => get().then((s: any) => alive && setSt(s || { connected: false })).catch(() => {});
+    tick();
+    const id = window.setInterval(tick, 1500);
+    return () => { alive = false; window.clearInterval(id); };
+  }, [ampType, isACOM, isPGXL]);
+
+  const title = isPGXL ? 'PowerGenius XL' : isACOM ? `ACOM ${st.model || ''}` : `SPE ${st.model || 'Expert'}`;
+  const maxW = isACOM ? (Number(st.max_w) || 800) : ({ '13K': 1300, '15K': 1500, '2K': 2000 } as Record<string, number>)[st.model] || 1500;
+  const outW = Number(isACOM ? st.fwd_w : st.output_w) || 0;
+  const frac = Math.min(1, outW / maxW);
+  return (
+    <div className="rounded-xl border border-border bg-card shadow-sm overflow-hidden h-full">
+      <div className="flex items-center gap-2 px-3 py-2 border-b border-border/60 bg-muted/30">
+        <Flame className="size-4 text-primary" />
+        <div className="min-w-0">
+          <div className="text-sm font-semibold truncate">{t('flxp.amplifier')}</div>
+          <div className="text-[10px] text-muted-foreground font-mono truncate">{title}</div>
+        </div>
+        <span className={cn('ml-auto size-2 rounded-full shrink-0', st.connected ? 'bg-success' : 'bg-muted-foreground/40')}
+          title={st.connected ? t('station.online') : (st.last_error || t('station.offline'))} />
+      </div>
+      <div className="p-3 space-y-2">
+        {isPGXL ? (
+          <div className="flex items-center gap-2 flex-wrap">
+            {(['STANDARD', 'CONTEST', 'BROADCAST'] as const).map((m) => (
+              <button key={m} type="button" disabled={!st.connected}
+                onClick={() => PGXLSetFanMode(m).catch(() => {})}
+                className={cn('px-2.5 py-1.5 rounded-md border text-xs font-semibold disabled:opacity-40',
+                  st.fan_mode === m ? 'bg-primary text-primary-foreground border-primary' : 'bg-muted/30 border-border hover:bg-muted')}>
+                {m === 'STANDARD' ? t('flxp.fanStandard') : m === 'CONTEST' ? t('flxp.fanContest') : t('flxp.fanBroadcast')}
+              </button>
+            ))}
+            <span className="text-xs text-muted-foreground font-mono">{st.state || ''}{st.temperature ? ` · ${Math.round(st.temperature)}°C` : ''}</span>
+          </div>
+        ) : (
+          <>
+            <div className="flex items-center gap-2 flex-wrap">
+              <button type="button" disabled={!st.connected}
+                onClick={() => (isACOM ? ACOMSetOperate(!st.operate) : SPESetOperate(!st.operate)).catch(() => {})}
+                className={cn('px-3 py-1.5 rounded-lg text-xs font-extrabold tracking-wide border-2 transition-all disabled:opacity-40',
+                  st.operate ? 'bg-warning text-warning-foreground border-warning' : 'bg-card text-warning border-warning hover:bg-warning-muted')}>
+                {st.operate ? 'OPERATE' : 'STANDBY'}
+              </button>
+              <div className="inline-flex rounded-lg overflow-hidden border border-success/70">
+                <button type="button"
+                  disabled={isACOM ? !(st.port_open && st.transport === 'serial') : !st.connected}
+                  onClick={() => (isACOM ? ACOMSetPower(true) : SPESetPower(true)).catch(() => {})}
+                  className="px-2.5 py-1.5 text-xs font-bold bg-card text-success hover:bg-success/15 disabled:opacity-40">ON</button>
+                <button type="button" disabled={!st.connected}
+                  onClick={() => (isACOM ? ACOMSetPower(false) : SPESetPower(false)).catch(() => {})}
+                  className="px-2.5 py-1.5 text-xs font-bold bg-card text-danger border-l border-success/70 hover:bg-danger/15 disabled:opacity-40">OFF</button>
+              </div>
+              {!isACOM && (
+                <div className="inline-flex rounded-lg overflow-hidden border border-border">
+                  {(['L', 'M', 'H'] as const).map((lvl, i) => (
+                    <button key={lvl} type="button" disabled={!st.connected}
+                      onClick={() => SPESetPowerLevel(lvl).catch(() => {})}
+                      className={cn('px-2.5 py-1.5 text-xs font-bold disabled:opacity-40', i > 0 && 'border-l border-border',
+                        (st.power_level || '').trim().toUpperCase() === lvl ? 'bg-primary text-primary-foreground' : 'bg-card text-muted-foreground hover:bg-muted')}>
+                      {lvl}
+                    </button>
+                  ))}
+                </div>
+              )}
+            </div>
+            <div className="text-xs font-mono text-muted-foreground tabular-nums">
+              {st.connected
+                ? <>
+                    {isACOM ? (st.state || '') : (st.tx ? 'TX' : 'RX')}
+                    {st.band ? ` · ${st.band}` : ''} · {outW}W · SWR {Number((isACOM ? st.swr : st.swr_ant) ?? 0).toFixed(1)} · {st.temp_c}°C
+                    {isACOM && st.fan ? ` · Fan ${st.fan}` : ''}
+                  </>
+                : (isACOM ? t('flxp.acomOffline') : t('flxp.speOffline'))}
+            </div>
+            {st.connected && (
+              <div>
+                <div className="h-2 rounded bg-muted overflow-hidden">
+                  <div className={cn('h-full transition-all', frac > 0.9 ? 'bg-danger' : frac > 0.75 ? 'bg-warning' : 'bg-primary')}
+                    style={{ width: `${Math.round(frac * 100)}%` }} />
+                </div>
+                <div className="text-[10px] text-muted-foreground mt-0.5">{t('flxp.outputPower')} — {outW} W / {maxW} W</div>
+              </div>
+            )}
+            {(st.err_text || st.warnings || st.alarms) && (
+              <div className="text-[11px] font-bold text-danger">⚠ {st.err_text || `${st.warnings || ''} ${st.alarms || ''}`}</div>
+            )}
+          </>
+        )}
+      </div>
+    </div>
+  );
+}
+
 export function StationControlPanel({ centerLat, centerLon, bearing }: RotatorProps) {
   const { t } = useI18n();
   const [devices, setDevices] = useState<Device[]>([]);
@@ -260,6 +367,17 @@ export function StationControlPanel({ centerLat, centerLon, bearing }: RotatorPr
   });
   const dragId = useRef<string | null>(null);
   const [cols, setCols] = useState<string>(() => localStorage.getItem('opslog.stationCols') || 'auto');
+  // Amplifier (Settings → Amplifier): shown here so operators without a
+  // FlexRadio panel still get the controls. Re-read every 5s so enabling the
+  // amp in Settings makes the widget appear without reopening the tab.
+  const [amp, setAmp] = useState<{ enabled: boolean; type: string }>({ enabled: false, type: 'pgxl' });
+  useEffect(() => {
+    let alive = true;
+    const load = () => GetPGXLSettings().then((s: any) => { if (alive) setAmp({ enabled: !!s?.enabled, type: s?.type || 'pgxl' }); }).catch(() => {});
+    load();
+    const id = window.setInterval(load, 5000);
+    return () => { alive = false; window.clearInterval(id); };
+  }, []);
 
   const loadDevices = useCallback(async () => {
     try { setDevices(((await GetStationDevices()) ?? []) as Device[]); } catch { /* db not ready */ }
@@ -380,13 +498,16 @@ export function StationControlPanel({ centerLat, centerLon, bearing }: RotatorPr
   if (ant.enabled) {
     widgets.push({ id: 'antenna', node: <MotorAntennaWidget ant={ant} refetch={pollAnt} t={t} /> });
   }
+  if (amp.enabled) {
+    widgets.push({ id: 'amplifier', node: <AmplifierWidget ampType={amp.type} t={t} /> });
+  }
   for (const dev of devices) widgets.push({ id: dev.id, node: deviceCard(dev) });
 
   const rank = (id: string) => { const i = order.indexOf(id); return i < 0 ? 1e6 : i; };
   const ordered = widgets.map((w, i) => ({ ...w, i })).sort((a, b) => (rank(a.id) - rank(b.id)) || (a.i - b.i));
   const widgetIds = ordered.map((w) => w.id);
 
-  const noDevices = devices.length === 0 && !rot.enabled && !ant.enabled;
+  const noDevices = devices.length === 0 && !rot.enabled && !ant.enabled && !amp.enabled;
 
   // Column count controls the layout: with 4 widgets, choosing "2" lays them out
   // 2×2 — which linear drag-reorder alone can't do, since the grid auto-flows to

frontend/src/lib/i18n.tsx

@@ -92,8 +92,6 @@ const en: Dict = {
   'settings.theme': 'Theme', 'settings.themeHint': 'Interface colour theme.',
   'settings.telemetry': 'Send anonymous usage statistics',
   'settings.telemetryHint': 'install ID + version + OS, once a day — no callsign or QSO data',
-  'settings.liveStatus': 'Publish live operator status',
-  'settings.liveStatusHint': 'multi-op on shared MySQL — feeds a QRZ live page',
   'settings.mainView': 'Main view',
   'settings.mainViewHint': 'Choose what the Main tab shows on each side (per profile).',
   'settings.leftPane': 'Left pane', 'settings.rightPane': 'Right pane',
@@ -283,7 +281,7 @@ const en: Dict = {
   'agp.portDeselect': 'Port {letter} — click to deselect', 'agp.portSelect': 'Select on port {letter}', 'agp.online': 'online', 'agp.offline': 'offline', 'agp.close': 'Close', 'agp.connecting': 'Connecting…', 'agp.noAntennas': 'No antennas configured.', 'agp.filterOnHint': 'Showing antennas for {band} only — click to show all bands', 'agp.filterOffHint': 'Showing all antennas — click to show only the current band',
   'flxp.ritHint': 'RIT — shifts your RECEIVE frequency only. Wheel, ± or arrow keys to adjust (Ctrl = 100 Hz). The offset is kept when you switch it off.', 'flxp.xitHint': 'XIT — shifts your TRANSMIT frequency only. Wheel, ± or arrow keys to adjust (Ctrl = 100 Hz). The offset is kept when you switch it off.',
   'flxp.smartsdrRemote': 'SmartSDR remote control', 'flxp.offline': 'OFFLINE', 'flxp.waiting': 'Waiting for the FlexRadio… (set CAT to FlexRadio and connect)', 'flxp.transmit': 'Transmit', 'flxp.rfPower': 'RF Power', 'flxp.tunePwr': 'Tune Pwr', 'flxp.splitHint': 'Split: RX/TX on separate slices. ON creates a TX slice +1 kHz (CW) / +5 kHz (SSB) up, like SmartSDR.', 'flxp.sliceHint': 'Click to make this the active slice — frequency, mode, DSP and spot-clicks all follow it.', 'flxp.txSlice': 'This slice transmits', 'flxp.setTxSlice': 'Move TX to this slice (transmit here)', 'flxp.voxDly': 'VOX Dly', 'flxp.speed': 'Speed', 'flxp.pitch': 'Pitch', 'flxp.delay': 'Delay',
-  'flxp.receiveActive': 'Receive (active slice)', 'flxp.muted': 'Muted — click to unmute', 'flxp.mute': 'Mute RX audio', 'flxp.filter': 'Filter', 'flxp.amplifier': 'Amplifier', 'flxp.ampInLine': 'Amplifier is in line (transmitting through PA).', 'flxp.ampBypassed': 'Amplifier bypassed (standby).', 'flxp.pgConnected': 'PowerGenius connected', 'flxp.pgOffline': 'PowerGenius offline', 'flxp.fan': 'Fan', 'flxp.fanStandard': 'Standard', 'flxp.fanContest': 'Contest', 'flxp.fanBroadcast': 'Broadcast', 'flxp.fault': 'FAULT', 'flxp.meters': 'Meters', 'flxp.voltage': 'VOLTAGE', 'flxp.paTemp': 'PA TEMP', 'flxp.txFilter': 'TX filter', 'flxp.micProfile': 'Mic profile', 'flxp.noMeters': "No meters yet — waiting for the radio's UDP stream…", 'flxp.amplifierHdr': 'AMPLIFIER', 'flxp.outputPower': 'OUTPUT POWER', 'flxp.speOffline': 'SPE offline',
+  'flxp.receiveActive': 'Receive (active slice)', 'flxp.muted': 'Muted — click to unmute', 'flxp.mute': 'Mute RX audio', 'flxp.filter': 'Filter', 'flxp.amplifier': 'Amplifier', 'flxp.ampInLine': 'Amplifier is in line (transmitting through PA).', 'flxp.ampBypassed': 'Amplifier bypassed (standby).', 'flxp.pgConnected': 'PowerGenius connected', 'flxp.pgOffline': 'PowerGenius offline', 'flxp.fan': 'Fan', 'flxp.fanStandard': 'Standard', 'flxp.fanContest': 'Contest', 'flxp.fanBroadcast': 'Broadcast', 'flxp.fault': 'FAULT', 'flxp.meters': 'Meters', 'flxp.voltage': 'VOLTAGE', 'flxp.paTemp': 'PA TEMP', 'flxp.txFilter': 'TX filter', 'flxp.micProfile': 'Mic profile', 'flxp.noMeters': "No meters yet — waiting for the radio's UDP stream…", 'flxp.amplifierHdr': 'AMPLIFIER', 'flxp.outputPower': 'OUTPUT POWER', 'flxp.speOffline': 'SPE offline', 'flxp.acomOffline': 'ACOM offline',
   'icmp.spectrum': 'Spectrum', 'icmp.scopeFixed': 'Fixed — double-click / wheel to tune', 'icmp.scopeCenter': 'Center — follows VFO', 'icmp.scopeOff': 'Scope off', 'icmp.scopePanDown': 'Shift scope −50 kHz', 'icmp.scopePanUp': 'Shift scope +50 kHz', 'icmp.scopeCenterVfo': 'Center scope on the current frequency (±50 kHz)', 'icmp.notConnected': "Icom not connected. Enable the Icom CI-V backend in Settings → CAT and connect the radio's USB port.", 'icmp.refresh': 'Refresh', 'icmp.meters': 'Meters', 'icmp.transmit': 'Transmit', 'icmp.power': 'Power', 'icmp.mic': 'Mic', 'icmp.receive': 'Receive', 'icmp.preamp': 'Preamp', 'icmp.filter': 'Filter', 'icmp.noiseNotch': 'Noise / Notch', 'icmp.autoNotch': 'Auto notch filter', 'icmp.apf': 'Audio peak filter (CW)', 'icmp.clarifiers': 'RIT / ΔTX', 'icmp.ritHint': 'Wheel or ± to shift · Ctrl+←/→ shifts RIT when active', 'icmp.bandsAntenna': 'Bands & Antenna', 'icmp.antenna': 'Antenna', 'icmp.passband': 'Passband / Notch', 'icmp.pbtCenter': 'Center PBT', 'icmp.manualNotch': 'Manual notch — MN on, then set position', 'icmp.squelch': 'Squelch', 'icmp.powerOnHint': 'Power the radio ON (boots ~15 s)', 'icmp.powerOffHint': 'Power the radio OFF', 'icmp.powerOffConfirm': 'Switch the radio OFF?',
   'rst.clickToFill': 'Click to set RST tx from the signal',
   'qrz.openTitle': 'Open {call} on QRZ.com',
@@ -407,8 +405,6 @@ const fr: Dict = {
   'settings.theme': 'Thème', 'settings.themeHint': "Thème de couleur de l'interface.",
   'settings.telemetry': "Envoyer des statistiques d'usage anonymes",
   'settings.telemetryHint': "ID d'installation + version + OS, une fois par jour — aucun indicatif ni donnée QSO",
-  'settings.liveStatus': 'Publier le statut opérateur en direct',
-  'settings.liveStatusHint': 'multi-op sur MySQL partagé — alimente une page live QRZ',
   'settings.mainView': 'Vue principale',
   'settings.mainViewHint': "Choisis ce que l'onglet Principal affiche de chaque côté (par profil).",
   'settings.leftPane': 'Volet gauche', 'settings.rightPane': 'Volet droit',
@@ -581,7 +577,7 @@ const fr: Dict = {
   'agp.portDeselect': 'Port {letter} — clic pour désélectionner', 'agp.portSelect': 'Sélectionner sur le port {letter}', 'agp.online': 'en ligne', 'agp.offline': 'hors ligne', 'agp.close': 'Fermer', 'agp.connecting': 'Connexion…', 'agp.noAntennas': 'Aucune antenne configurée.', 'agp.filterOnHint': 'Antennes du {band} uniquement — clic pour afficher toutes les bandes', 'agp.filterOffHint': 'Toutes les antennes affichées — clic pour n’afficher que la bande courante',
   'flxp.ritHint': "RIT — décale uniquement ta fréquence de RÉCEPTION. Molette, ± ou flèches pour ajuster (Ctrl = 100 Hz). Le décalage est conservé quand tu l'éteins.", 'flxp.xitHint': "XIT — décale uniquement ta fréquence d'ÉMISSION. Molette, ± ou flèches pour ajuster (Ctrl = 100 Hz). Le décalage est conservé quand tu l'éteins.",
   'flxp.smartsdrRemote': 'Contrôle à distance SmartSDR', 'flxp.offline': 'HORS LIGNE', 'flxp.waiting': 'En attente du FlexRadio… (règle le CAT sur FlexRadio et connecte)', 'flxp.transmit': 'Émission', 'flxp.rfPower': 'Puissance RF', 'flxp.tunePwr': 'Puiss. TUNE', 'flxp.splitHint': 'Split : RX/TX sur des slices séparées. ON crée une slice TX +1 kHz (CW) / +5 kHz (SSB) au-dessus, comme SmartSDR.', 'flxp.sliceHint': 'Cliquer pour rendre cette slice active — fréquence, mode, DSP et clics de spot la suivent tous.', 'flxp.txSlice': 'Cette slice émet', 'flxp.setTxSlice': 'Déplacer le TX sur cette slice (émettre ici)', 'flxp.voxDly': 'Délai VOX', 'flxp.speed': 'Vitesse', 'flxp.pitch': 'Tonalité', 'flxp.delay': 'Délai',
-  'flxp.receiveActive': 'Réception (slice active)', 'flxp.muted': 'Coupé — clic pour rétablir', 'flxp.mute': "Couper l'audio RX", 'flxp.filter': 'Filtre', 'flxp.amplifier': 'Amplificateur', 'flxp.ampInLine': 'Amplificateur en ligne (émission via le PA).', 'flxp.ampBypassed': 'Amplificateur en bypass (standby).', 'flxp.pgConnected': 'PowerGenius connecté', 'flxp.pgOffline': 'PowerGenius hors ligne', 'flxp.fan': 'Ventilo', 'flxp.fanStandard': 'Standard', 'flxp.fanContest': 'Contest', 'flxp.fanBroadcast': 'Diffusion', 'flxp.fault': 'DÉFAUT', 'flxp.meters': 'Mesures', 'flxp.voltage': 'TENSION', 'flxp.paTemp': 'TEMP PA', 'flxp.txFilter': 'Filtre TX', 'flxp.micProfile': 'Profil micro', 'flxp.noMeters': 'Aucune mesure — en attente du flux UDP de la radio…', 'flxp.amplifierHdr': 'AMPLIFICATEUR', 'flxp.outputPower': 'PUISSANCE DE SORTIE', 'flxp.speOffline': 'SPE hors ligne',
+  'flxp.receiveActive': 'Réception (slice active)', 'flxp.muted': 'Coupé — clic pour rétablir', 'flxp.mute': "Couper l'audio RX", 'flxp.filter': 'Filtre', 'flxp.amplifier': 'Amplificateur', 'flxp.ampInLine': 'Amplificateur en ligne (émission via le PA).', 'flxp.ampBypassed': 'Amplificateur en bypass (standby).', 'flxp.pgConnected': 'PowerGenius connecté', 'flxp.pgOffline': 'PowerGenius hors ligne', 'flxp.fan': 'Ventilo', 'flxp.fanStandard': 'Standard', 'flxp.fanContest': 'Contest', 'flxp.fanBroadcast': 'Diffusion', 'flxp.fault': 'DÉFAUT', 'flxp.meters': 'Mesures', 'flxp.voltage': 'TENSION', 'flxp.paTemp': 'TEMP PA', 'flxp.txFilter': 'Filtre TX', 'flxp.micProfile': 'Profil micro', 'flxp.noMeters': 'Aucune mesure — en attente du flux UDP de la radio…', 'flxp.amplifierHdr': 'AMPLIFICATEUR', 'flxp.outputPower': 'PUISSANCE DE SORTIE', 'flxp.speOffline': 'SPE hors ligne', 'flxp.acomOffline': 'ACOM hors ligne',
   'icmp.spectrum': 'Spectre', 'icmp.scopeFixed': 'Fixe — double-clic / molette pour accorder', 'icmp.scopeCenter': 'Centré — suit le VFO', 'icmp.scopeOff': 'Scope éteint', 'icmp.scopePanDown': 'Décaler le scope −50 kHz', 'icmp.scopePanUp': 'Décaler le scope +50 kHz', 'icmp.scopeCenterVfo': 'Centrer le scope sur la fréquence actuelle (±50 kHz)', 'icmp.notConnected': 'Icom non connecté. Active le backend CI-V Icom dans Réglages → CAT et connecte le port USB de la radio.', 'icmp.refresh': 'Rafraîchir', 'icmp.meters': 'Mesures', 'icmp.transmit': 'Émission', 'icmp.power': 'Puissance', 'icmp.mic': 'Micro', 'icmp.receive': 'Réception', 'icmp.preamp': 'Préampli', 'icmp.filter': 'Filtre', 'icmp.noiseNotch': 'Bruit / Notch', 'icmp.autoNotch': 'Filtre notch auto', 'icmp.apf': 'Filtre de pic audio (CW)', 'icmp.clarifiers': 'RIT / ΔTX', 'icmp.ritHint': 'Molette ou ± pour décaler · Ctrl+←/→ décale le RIT si actif', 'icmp.bandsAntenna': 'Bandes & Antenne', 'icmp.antenna': 'Antenne', 'icmp.passband': 'Passe-bande / Notch', 'icmp.pbtCenter': 'Centrer PBT', 'icmp.manualNotch': 'Notch manuel — active MN, puis règle la position', 'icmp.squelch': 'Squelch', 'icmp.powerOnHint': 'Allumer la radio (démarre en ~15 s)', 'icmp.powerOffHint': 'Éteindre la radio', 'icmp.powerOffConfirm': 'Éteindre la radio ?',
   'rst.clickToFill': 'Clic pour remplir le RST tx depuis le signal',
   'qrz.openTitle': 'Ouvrir {call} sur QRZ.com',

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

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

@@ -5,6 +5,7 @@ import {qso} from '../models';
 import {main} from '../models';
 import {cat} from '../models';
 import {profile} from '../models';
+import {acom} from '../models';
 import {antgenius} from '../models';
 import {award} from '../models';
 import {awardref} from '../models';
@@ -23,6 +24,10 @@ import {lotwusers} from '../models';
 import {lookup} from '../models';
 import {netctl} from '../models';
 
+export function ACOMSetOperate(arg1:boolean):Promise<void>;
+
+export function ACOMSetPower(arg1:boolean):Promise<void>;
+
 export function ADIFFields():Promise<Array<adif.FieldDef>>;
 
 export function ADIFVersion():Promise<string>;
@@ -289,6 +294,8 @@ export function FlexStopCW():Promise<void>;
 
 export function FlexTune(arg1:boolean):Promise<void>;
 
+export function GetACOMStatus():Promise<acom.Status>;
+
 export function GetADIFMonitor():Promise<main.ADIFMonitorConfig>;
 
 export function GetActiveProfile():Promise<profile.Profile>;
@@ -365,8 +372,6 @@ export function GetListsSettings():Promise<main.ListsSettings>;
 
 export function GetLiveStations():Promise<Array<main.LiveStation>>;
 
-export function GetLiveStatusEnabled():Promise<boolean>;
-
 export function GetLoTWUsersStatus():Promise<main.LoTWUsersStatus>;
 
 export function GetLogFilePath():Promise<string>;
@@ -813,8 +818,6 @@ export function SetCompactMode(arg1:boolean):Promise<void>;
 
 export function SetDVKLabel(arg1:number,arg2:string):Promise<void>;
 
-export function SetLiveStatusEnabled(arg1:boolean):Promise<void>;
-
 export function SetPassphrase(arg1:string):Promise<void>;
 
 export function SetTelemetryEnabled(arg1:boolean):Promise<void>;

frontend/wailsjs/go/main/App.js

@@ -2,6 +2,14 @@
 // Cynhyrchwyd y ffeil hon yn awtomatig. PEIDIWCH Â MODIWL
 // This file is automatically generated. DO NOT EDIT
 
+export function ACOMSetOperate(arg1) {
+  return window['go']['main']['App']['ACOMSetOperate'](arg1);
+}
+
+export function ACOMSetPower(arg1) {
+  return window['go']['main']['App']['ACOMSetPower'](arg1);
+}
+
 export function ADIFFields() {
   return window['go']['main']['App']['ADIFFields']();
 }
@@ -534,6 +542,10 @@ export function FlexTune(arg1) {
   return window['go']['main']['App']['FlexTune'](arg1);
 }
 
+export function GetACOMStatus() {
+  return window['go']['main']['App']['GetACOMStatus']();
+}
+
 export function GetADIFMonitor() {
   return window['go']['main']['App']['GetADIFMonitor']();
 }
@@ -686,10 +698,6 @@ export function GetLiveStations() {
   return window['go']['main']['App']['GetLiveStations']();
 }
 
-export function GetLiveStatusEnabled() {
-  return window['go']['main']['App']['GetLiveStatusEnabled']();
-}
-
 export function GetLoTWUsersStatus() {
   return window['go']['main']['App']['GetLoTWUsersStatus']();
 }
@@ -1582,10 +1590,6 @@ export function SetDVKLabel(arg1, arg2) {
   return window['go']['main']['App']['SetDVKLabel'](arg1, arg2);
 }
 
-export function SetLiveStatusEnabled(arg1) {
-  return window['go']['main']['App']['SetLiveStatusEnabled'](arg1);
-}
-
 export function SetPassphrase(arg1) {
   return window['go']['main']['App']['SetPassphrase'](arg1);
 }

frontend/wailsjs/go/models.ts

@@ -1,3 +1,58 @@
+export namespace acom {
+	
+	export class Status {
+	    connected: boolean;
+	    port_open: boolean;
+	    transport: string;
+	    last_error?: string;
+	    model?: string;
+	    state?: string;
+	    operate: boolean;
+	    tx: boolean;
+	    fwd_w: number;
+	    refl_w: number;
+	    swr: number;
+	    drive_w: number;
+	    dc_w: number;
+	    temp_c: number;
+	    band?: string;
+	    fan: number;
+	    err_code: number;
+	    err_text?: string;
+	    nominal_w: number;
+	    max_w: number;
+	
+	    static createFrom(source: any = {}) {
+	        return new Status(source);
+	    }
+	
+	    constructor(source: any = {}) {
+	        if ('string' === typeof source) source = JSON.parse(source);
+	        this.connected = source["connected"];
+	        this.port_open = source["port_open"];
+	        this.transport = source["transport"];
+	        this.last_error = source["last_error"];
+	        this.model = source["model"];
+	        this.state = source["state"];
+	        this.operate = source["operate"];
+	        this.tx = source["tx"];
+	        this.fwd_w = source["fwd_w"];
+	        this.refl_w = source["refl_w"];
+	        this.swr = source["swr"];
+	        this.drive_w = source["drive_w"];
+	        this.dc_w = source["dc_w"];
+	        this.temp_c = source["temp_c"];
+	        this.band = source["band"];
+	        this.fan = source["fan"];
+	        this.err_code = source["err_code"];
+	        this.err_text = source["err_text"];
+	        this.nominal_w = source["nominal_w"];
+	        this.max_w = source["max_w"];
+	    }
+	}
+
+}
+
 export namespace adif {
 	
 	export class ExportResult {

internal/acom/acom.go

@@ -0,0 +1,504 @@
+// Package acom drives the ACOM solid-state amplifiers (500S / 600S / 700S /
+// 1200S / 2020S) over their (unpublished) RS-232 protocol, reverse-engineered by
+// the ACOM-Controller project (bjornekelund, C#). The amp is reached either
+// directly over a serial COM port (9600 8N1) or over TCP via an RS232-to-Ethernet
+// bridge — both are just an io.ReadWriteCloser to this code, same as the SPE
+// backend.
+//
+// Wire format (host → amp): fixed raw byte strings, validated by the same rule as
+// telemetry (sum of ALL frame bytes ≡ 0 mod 256):
+//
+//	enable telemetry:  55 92 04 15
+//	disable telemetry: 55 91 04 16
+//	OPERATE:           55 81 08 02 00 06 00 1A
+//	STANDBY:           55 81 08 02 00 05 00 1B
+//	OFF (power down):  55 81 08 02 00 0A 00 16
+//
+// Power ON is NOT a data command: it is a hardware pulse on the serial DTR/RTS
+// lines (the amp's remote power-on pins) — serial transport only, and only if the
+// cable wires those pins (a telemetry-only cable uses just RX/TX/GND).
+//
+// IMPORTANT: DTR and RTS must be held LOW at all times otherwise — asserting them
+// permanently blocks the amplifier's front-panel power button.
+//
+// Telemetry (amp → host): once enabled, the amp streams 72-byte frames starting
+// 0x55 0x2F, valid when the sum of all 72 bytes ≡ 0 (mod 256). Field offsets are
+// decoded in decodeFrame below.
+package acom
+
+import (
+	"fmt"
+	"io"
+	"net"
+	"strconv"
+	"strings"
+	"sync"
+	"time"
+
+	"go.bug.st/serial"
+
+	"hamlog/internal/applog"
+)
+
+var (
+	cmdEnableTelemetry  = []byte{0x55, 0x92, 0x04, 0x15}
+	cmdDisableTelemetry = []byte{0x55, 0x91, 0x04, 0x16}
+	cmdOperate          = []byte{0x55, 0x81, 0x08, 0x02, 0x00, 0x06, 0x00, 0x1A}
+	cmdStandby          = []byte{0x55, 0x81, 0x08, 0x02, 0x00, 0x05, 0x00, 0x1B}
+	cmdOff              = []byte{0x55, 0x81, 0x08, 0x02, 0x00, 0x0A, 0x00, 0x16}
+)
+
+const (
+	frameLen    = 72
+	sync0       = 0x55
+	sync1       = 0x2F
+	dialTimeout = 5 * time.Second
+	ioTimeout   = 3 * time.Second
+	// The amp streams roughly 4-5 frames/s once telemetry is on; if nothing valid
+	// arrives for this long the link (or the amp) is considered down.
+	staleAfter = 5 * time.Second
+)
+
+// model carries the per-model constants: the temperature word offset and the
+// nominal/max forward power (for UI bar scaling).
+type model struct {
+	Name       string
+	TempOffset int
+	NominalW   int
+	MaxW       int
+}
+
+var models = map[string]model{
+	"500S":  {"500S", 282, 500, 600},
+	"600S":  {"600S", 273, 600, 700},
+	"700S":  {"700S", 282, 700, 800},
+	"1200S": {"1200S", 281, 1200, 1400},
+	"2020S": {"2020S", 282, 1800, 2000},
+}
+
+// paStatusNames maps the PAstatus nibble to a display string.
+var paStatusNames = map[int]string{
+	1: "RESET", 2: "INIT", 3: "DEBUG", 4: "SERVICE",
+	5: "STANDBY", 6: "RECEIVE", 7: "TRANSMIT", 9: "SYSTEM", 10: "OFF",
+}
+
+// acomBands maps the band nibble to a band label.
+var acomBands = []string{"?", "160m", "80m", "40/60m", "30m", "20m", "17m", "15m", "12m", "10m", "6m", "4m"}
+
+// errText translates the error code (frame byte 66) shown on the amp's display.
+// 0xFF means NO error — everything else, including 0x00, is a fault/warning.
+func errText(code int) string {
+	switch code {
+	case 0xFF:
+		return ""
+	case 0x00, 0x08:
+		return "Hot switching"
+	case 0x03:
+		return "Drive power at wrong time"
+	case 0x04, 0x05:
+		return "Reflected power warning"
+	case 0x06, 0x07:
+		return "Drive power too high"
+	case 0x0C:
+		return "RF power at wrong time"
+	case 0x0E:
+		return "Stop transmission first"
+	case 0x0F:
+		return "Remove drive power"
+	case 0x24, 0x25, 0x39, 0x44, 0x45, 0x59:
+		return "Excessive PAM current"
+	case 0x70:
+		return "CAT error"
+	default:
+		return "ERROR — see display"
+	}
+}
+
+// Status is the decoded amplifier state for the UI.
+type Status struct {
+	Connected bool    `json:"connected"` // valid telemetry is flowing
+	PortOpen  bool    `json:"port_open"` // transport is open (serial port / TCP socket) — power-on possible even when the amp itself is off
+	Transport string  `json:"transport"` // "serial" | "tcp" — the UI disables power-ON over tcp (no DTR line)
+	LastError string  `json:"last_error,omitempty"`
+	Model     string  `json:"model,omitempty"`
+	State     string  `json:"state,omitempty"` // STANDBY / RECEIVE / TRANSMIT / OFF / …
+	Operate   bool    `json:"operate"`         // RECEIVE or TRANSMIT (vs STANDBY)
+	TX        bool    `json:"tx"`
+	FwdW      int     `json:"fwd_w"`  // forward/output power
+	ReflW     int     `json:"refl_w"` // reflected power
+	SWR       float64 `json:"swr"`
+	DriveW    int     `json:"drive_w"`
+	DCPowerW  int     `json:"dc_w"`
+	TempC     int     `json:"temp_c"` // PA temperature
+	Band      string  `json:"band,omitempty"`
+	FanLevel  int     `json:"fan"`                // 1..4
+	ErrCode   int     `json:"err_code"`           // raw code from the frame; 0xFF = none
+	ErrText   string  `json:"err_text,omitempty"` // human message; empty = no error
+	NominalW  int     `json:"nominal_w"`
+	MaxW      int     `json:"max_w"`
+}
+
+// Config selects the transport and amplifier model.
+type Config struct {
+	Model     string // "500S" | "600S" | "700S" | "1200S" | "2020S"
+	Transport string // "serial" | "tcp"
+	ComPort   string // serial
+	Baud      int    // serial (the amp is fixed 9600 8N1)
+	Host      string // tcp (RS232-to-Ethernet bridge)
+	Port      int    // tcp
+}
+
+type Client struct {
+	cfg Config
+	mdl model
+
+	mu   sync.Mutex // serialises access to the connection
+	conn io.ReadWriteCloser
+
+	statusMu sync.RWMutex
+	status   Status
+
+	// Diagnostics: raw byte count + first-bytes capture, so a hardware session log
+	// tells apart "nothing on the wire" (cable/COM/amp) from "bytes but no valid
+	// frame" (framing/checksum) without a serial sniffer.
+	rawSeen     int64
+	dbgBytes    []byte
+	dbgLogged   bool
+	ckFails     int
+	frameLogged bool
+
+	stop    chan struct{}
+	running bool
+}
+
+func New(cfg Config) *Client {
+	if cfg.Baud <= 0 {
+		cfg.Baud = 9600
+	}
+	mdl, ok := models[strings.ToUpper(strings.TrimSpace(cfg.Model))]
+	if !ok {
+		mdl = models["700S"]
+	}
+	c := &Client{cfg: cfg, mdl: mdl, stop: make(chan struct{})}
+	c.status.Model = mdl.Name
+	c.status.Transport = cfg.Transport
+	c.status.NominalW = mdl.NominalW
+	c.status.MaxW = mdl.MaxW
+	return c
+}
+
+func (c *Client) Start() error {
+	if c.running {
+		return nil
+	}
+	c.running = true
+	go c.readLoop()
+	return nil
+}
+
+func (c *Client) Stop() {
+	if !c.running {
+		return
+	}
+	c.running = false
+	close(c.stop)
+	c.mu.Lock()
+	if c.conn != nil {
+		_, _ = c.conn.Write(cmdDisableTelemetry) // best effort: stop the stream
+	}
+	c.dropLocked()
+	c.mu.Unlock()
+}
+
+func (c *Client) GetStatus() Status {
+	c.statusMu.RLock()
+	defer c.statusMu.RUnlock()
+	return c.status
+}
+
+func (c *Client) setErr(msg string) {
+	c.statusMu.Lock()
+	c.status.Connected = false
+	c.status.LastError = msg
+	c.statusMu.Unlock()
+}
+
+// Operate puts the amp in OPERATE (true) or STANDBY (false). Unlike the SPE's
+// single toggle key, the ACOM protocol has explicit commands for each state.
+func (c *Client) Operate(on bool) error {
+	if on {
+		return c.send(cmdOperate)
+	}
+	return c.send(cmdStandby)
+}
+
+// PowerOff sends the power-down command (same as pressing OFF on the amp).
+func (c *Client) PowerOff() error { return c.send(cmdOff) }
+
+// PowerOn pulses the serial DTR/RTS lines — the amp's remote power-on pins, wired
+// like a press of the front-panel power button. Hardware line ⇒ serial transport
+// only (an RS232-to-Ethernet bridge doesn't forward DTR), and the cable must have
+// those pins connected. Pulse length to be confirmed on real hardware.
+func (c *Client) PowerOn() error {
+	c.mu.Lock()
+	defer c.mu.Unlock()
+	sp, ok := c.conn.(serial.Port)
+	if !ok {
+		return fmt.Errorf("power-on needs the serial DTR/RTS lines — not available over a network bridge")
+	}
+	if err := sp.SetDTR(true); err != nil {
+		return err
+	}
+	if err := sp.SetRTS(true); err != nil {
+		_ = sp.SetDTR(false)
+		return err
+	}
+	time.Sleep(2500 * time.Millisecond)
+	err1 := sp.SetDTR(false)
+	err2 := sp.SetRTS(false)
+	if err1 != nil {
+		return err1
+	}
+	return err2
+}
+
+func (c *Client) send(cmd []byte) error {
+	c.mu.Lock()
+	defer c.mu.Unlock()
+	if c.conn == nil {
+		return fmt.Errorf("not connected")
+	}
+	if nc, ok := c.conn.(net.Conn); ok {
+		_ = nc.SetWriteDeadline(time.Now().Add(ioTimeout))
+	}
+	_, err := c.conn.Write(cmd)
+	return err
+}
+
+// readLoop keeps the link up and consumes the telemetry stream. When no valid
+// frame arrives for a while it re-arms telemetry (the amp forgets the enable
+// across a power cycle) and, on TCP, reconnects. A serial port is kept open even
+// with the amp off, so the DTR power-on pulse stays available.
+func (c *Client) readLoop() {
+	var lastFrame time.Time
+	var lastEnable time.Time
+	for {
+		select {
+		case <-c.stop:
+			return
+		default:
+		}
+		if err := c.ensureConn(); err != nil {
+			c.setErr("connect: " + err.Error())
+			select {
+			case <-c.stop:
+				return
+			case <-time.After(2 * time.Second):
+			}
+			continue
+		}
+		frame, err := c.readFrame()
+		now := time.Now()
+		if err == nil {
+			lastFrame = now
+			if !c.frameLogged {
+				c.frameLogged = true
+				applog.Printf("acom: telemetry up — first valid frame received")
+			}
+			c.decodeFrame(frame)
+			continue
+		}
+		// No valid frame. Re-send the telemetry enable briskly — there is no way to
+		// know whether the amp has it on (the reference controller re-sends every
+		// 200ms until frames flow), and it revives the stream after a power cycle.
+		if now.Sub(lastEnable) >= 500*time.Millisecond {
+			lastEnable = now
+			_ = c.send(cmdEnableTelemetry)
+		}
+		if lastFrame.IsZero() || now.Sub(lastFrame) > staleAfter {
+			if c.cfg.Transport == "tcp" {
+				// The bridge socket may be dead — force a reconnect.
+				c.mu.Lock()
+				c.dropLocked()
+				c.mu.Unlock()
+			}
+			if prev := c.GetStatus(); prev.Connected || prev.LastError == "" {
+				applog.Printf("acom: no telemetry (raw bytes seen so far: %d, checksum fails: %d)", c.rawSeen, c.ckFails)
+			}
+			c.setErr("no telemetry — amplifier off or cable/bridge issue")
+		}
+	}
+}
+
+func (c *Client) ensureConn() error {
+	c.mu.Lock()
+	defer c.mu.Unlock()
+	if c.conn != nil {
+		return nil
+	}
+	if c.cfg.Transport == "tcp" {
+		nc, err := net.DialTimeout("tcp", net.JoinHostPort(c.cfg.Host, strconv.Itoa(c.cfg.Port)), dialTimeout)
+		if err != nil {
+			return err
+		}
+		c.conn = nc
+	} else {
+		sp, err := serial.Open(c.cfg.ComPort, &serial.Mode{BaudRate: c.cfg.Baud})
+		if err != nil {
+			return err
+		}
+		// CRITICAL: hold DTR/RTS LOW. Windows may assert them on open, and while
+		// asserted the amp's front-panel power button is blocked (they are its
+		// remote power-on lines).
+		_ = sp.SetDTR(false)
+		_ = sp.SetRTS(false)
+		// Short read timeout so the frame reader can poll the stop channel and
+		// detect staleness rather than blocking forever.
+		_ = sp.SetReadTimeout(200 * time.Millisecond)
+		c.conn = sp
+	}
+	c.statusMu.Lock()
+	c.status.PortOpen = true
+	c.statusMu.Unlock()
+	applog.Printf("acom: %s link open (%s)", c.mdl.Name, c.cfg.Transport)
+	_, _ = c.conn.Write(cmdEnableTelemetry)
+	return nil
+}
+
+func (c *Client) dropLocked() {
+	if c.conn != nil {
+		c.conn.Close()
+		c.conn = nil
+	}
+	c.statusMu.Lock()
+	c.status.PortOpen = false
+	c.statusMu.Unlock()
+}
+
+// readByte reads a single byte, honouring the transport's short timeout. A serial
+// read that times out returns (0, nil) with go.bug.st/serial — mapped to an error
+// here so callers can distinguish "no data yet".
+var errNoData = fmt.Errorf("no data")
+
+func (c *Client) readByte(deadline time.Time) (byte, error) {
+	c.mu.Lock()
+	conn := c.conn
+	c.mu.Unlock()
+	if conn == nil {
+		return 0, fmt.Errorf("not connected")
+	}
+	buf := make([]byte, 1)
+	for {
+		if nc, ok := conn.(net.Conn); ok {
+			_ = nc.SetReadDeadline(time.Now().Add(300 * time.Millisecond))
+		}
+		n, err := conn.Read(buf)
+		if n == 1 {
+			c.rawSeen++
+			// Capture the first 144 raw bytes (~2 frames) once, so a session log shows
+			// what the wire actually carries when frames won't validate.
+			if !c.dbgLogged {
+				c.dbgBytes = append(c.dbgBytes, buf[0])
+				if len(c.dbgBytes) >= 144 {
+					c.dbgLogged = true
+					applog.Printf("acom: first raw bytes: % X", c.dbgBytes)
+					c.dbgBytes = nil
+				}
+			}
+			return buf[0], nil
+		}
+		if err != nil {
+			if ne, ok := err.(net.Error); ok && ne.Timeout() {
+				err = nil // treat like the serial short-timeout: just no data yet
+			} else {
+				return 0, err
+			}
+		}
+		select {
+		case <-c.stop:
+			return 0, fmt.Errorf("stopped")
+		default:
+		}
+		if time.Now().After(deadline) {
+			return 0, errNoData
+		}
+	}
+}
+
+// readFrame syncs on 0x55 0x2F, reads the rest of the 72-byte frame and verifies
+// the mod-256 checksum (sum of ALL 72 bytes ≡ 0).
+func (c *Client) readFrame() ([]byte, error) {
+	deadline := time.Now().Add(ioTimeout)
+	// Sync: hunt for 0x55 followed by 0x2F.
+	for {
+		b, err := c.readByte(deadline)
+		if err != nil {
+			return nil, err
+		}
+		if b != sync0 {
+			continue
+		}
+		b2, err := c.readByte(deadline)
+		if err != nil {
+			return nil, err
+		}
+		if b2 == sync1 {
+			break
+		}
+	}
+	frame := make([]byte, frameLen)
+	frame[0], frame[1] = sync0, sync1
+	for i := 2; i < frameLen; i++ {
+		b, err := c.readByte(deadline)
+		if err != nil {
+			return nil, err
+		}
+		frame[i] = b
+	}
+	var sum int
+	for _, b := range frame {
+		sum += int(b)
+	}
+	if sum%256 != 0 {
+		c.ckFails++
+		if c.ckFails <= 3 {
+			applog.Printf("acom: bad checksum (fail #%d): % X", c.ckFails, frame)
+		}
+		return nil, fmt.Errorf("bad checksum")
+	}
+	return frame, nil
+}
+
+// decodeFrame extracts the telemetry fields (see the package comment for the
+// reverse-engineered layout; 16-bit values are little-endian lo + hi*256).
+func (c *Client) decodeFrame(f []byte) {
+	u16 := func(i int) int { return int(f[i]) + int(f[i+1])*256 }
+	paStatus := int(f[3]&0xF0) >> 4
+	state := paStatusNames[paStatus]
+	if state == "" {
+		state = fmt.Sprintf("?%d", paStatus)
+	}
+	bandIdx := int(f[69] & 0x0F)
+	band := ""
+	if bandIdx > 0 && bandIdx < len(acomBands) {
+		band = acomBands[bandIdx]
+	}
+
+	c.statusMu.Lock()
+	defer c.statusMu.Unlock()
+	c.status.Connected = true
+	c.status.LastError = ""
+	c.status.State = state
+	c.status.Operate = paStatus == 6 || paStatus == 7
+	c.status.TX = paStatus == 7
+	c.status.DCPowerW = u16(8) / 10
+	c.status.TempC = u16(16) - c.mdl.TempOffset
+	c.status.DriveW = u16(20)
+	c.status.FwdW = u16(22)
+	c.status.ReflW = u16(24)
+	c.status.SWR = float64(u16(26)) / 100
+	c.status.ErrCode = int(f[66])
+	c.status.ErrText = errText(int(f[66]))
+	c.status.Band = band
+	c.status.FanLevel = int(f[69]&0xF0) >> 4
+}

internal/applog/applog.go

@@ -47,10 +47,15 @@ func Init(dataDir string) (string, error) {
 			_ = os.Rename(oldLog, logPath)
 		}
 	}
-	// Truncate if the file grew past ~5MB so we don't accumulate logs
-	// forever. We keep one file — simple and adequate for diagnostics.
-	if fi, err := os.Stat(logPath); err == nil && fi.Size() > 5*1024*1024 {
-		_ = os.Remove(logPath)
+	// Rotate (don't delete) once the file grows past ~10MB: rename it to
+	// opslog.log.1 so the PREVIOUS session's log survives. Deleting it outright used
+	// to erase exactly the diagnostics we needed when a user reported an issue from
+	// the session that just ended. One generation kept — enough, without unbounded growth.
+	if fi, err := os.Stat(logPath); err == nil && fi.Size() > 10*1024*1024 {
+		_ = os.Remove(logPath + ".1")     // drop the older generation
+		if err := os.Rename(logPath, logPath+".1"); err != nil {
+			_ = os.Remove(logPath) // rename failed (locked?) → fall back to the old behaviour
+		}
 	}
 	f, err := os.OpenFile(logPath, os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0o644)
 	if err != nil {

internal/db/mysql.go

@@ -129,6 +129,28 @@ func translateTextColumns(s string) string {
 // OpenMySQL opens the shared MySQL logbook, creating the database if needed,
 // then applies the (translated) embedded migrations. multiStatements is enabled
 // so multi-statement migration files run in a single Exec.
+// tuneMySQLPool sizes the connection pool for a SHARED server. Two opposing needs:
+//   - A big per-instance pool (we shipped 50) let a handful of ops exhaust the
+//     server's global max_connections — "Error 1040: Too many connections".
+//   - Too SMALL a pool starves this instance's OWN concurrent UI queries — the live
+//     multi-op sync (revision poll every 2s + a 3-query grid refresh), live_status,
+//     chat, stats, cluster. Under real multi-op load, 8 and even 16 stalled: hot
+//     paths (WorkedBefore fires ~10 sequential round-trips; every poll uses the
+//     app-lifetime ctx with no per-query timeout) hold a connection for the whole
+//     chain of remote-MySQL latency, so a handful of concurrent UI bursts drained
+//     the pool and "after a while nothing updated" — grid, chat, live_status froze.
+// 40 fits the actual deployment (max 5 ops on a server with max_connections=300 →
+// 40*5 = 200, leaving ~100 for phpMyAdmin/server overhead). This is the per-INSTANCE
+// pool, so keep max_connections >= pool*ops + headroom.
+// Brisk idle reaping returns slots to the server; no max lifetime so a slow first
+// migration on one connection isn't reaped mid-run (drops the selected database).
+func tuneMySQLPool(conn *sql.DB) {
+	conn.SetMaxOpenConns(40)
+	conn.SetMaxIdleConns(8)
+	conn.SetConnMaxIdleTime(30 * time.Second)
+	conn.SetConnMaxLifetime(0)
+}
+
 func OpenMySQL(c MySQLConfig) (*sql.DB, error) {
 	if strings.TrimSpace(c.Host) == "" {
 		return nil, fmt.Errorf("host is required")
@@ -141,18 +163,7 @@ func OpenMySQL(c MySQLConfig) (*sql.DB, error) {
 	if err != nil {
 		return nil, fmt.Errorf("open mysql: %w", err)
 	}
-	// The UI fires bursts of concurrent queries (the Preferences dialog alone
-	// loads ~8 settings in parallel, plus the grid and live cluster status). A
-	// low cap turns such a burst into a deadlock-like stall against a remote
-	// server, so keep a generous pool with idle reaping. SQLite ran uncapped.
-	conn.SetMaxOpenConns(50)
-	conn.SetMaxIdleConns(10)
-	conn.SetConnMaxIdleTime(90 * time.Second)
-	// No max lifetime: a slow server's first migration can run for minutes on a
-	// single connection, and reaping it mid-migration drops the selected database
-	// (surfacing as "Unknown database"). Idle connections are still recycled
-	// after 90s, and the driver retries stale pooled connections.
-	conn.SetConnMaxLifetime(0)
+	tuneMySQLPool(conn)
 	// Connect DIRECTLY to the database first. Only if that fails — the DB doesn't
 	// exist yet (first-time setup) or the server is unreachable — do we pay for the
 	// server-level connect + CREATE DATABASE (two more handshakes). On a normal
@@ -167,10 +178,7 @@ func OpenMySQL(c MySQLConfig) (*sql.DB, error) {
 		if err != nil {
 			return nil, fmt.Errorf("open mysql: %w", err)
 		}
-		conn.SetMaxOpenConns(50)
-		conn.SetMaxIdleConns(10)
-		conn.SetConnMaxIdleTime(90 * time.Second)
-		conn.SetConnMaxLifetime(0)
+		tuneMySQLPool(conn)
 		if err := conn.Ping(); err != nil {
 			_ = conn.Close()
 			return nil, fmt.Errorf("connect to %s: %w", name, err)

internal/qso/qso.go

@@ -1954,23 +1954,21 @@ func (r *Repo) Count(ctx context.Context) (int64, error) {
 // operator who just worked someone before (re)starting OpsLog shows online right
 // away instead of waiting for their next QSO. Empty operator matches every QSO.
 func (r *Repo) LastQSOTime(ctx context.Context, operator string) (time.Time, bool) {
-	rows, err := r.db.QueryContext(ctx, `SELECT operator, qso_date FROM qso ORDER BY id DESC LIMIT 400`)
-	if err != nil {
-		return time.Time{}, false
-	}
-	defer rows.Close()
+	// ONE indexed row, not 400 filtered in Go: this runs every ~5 s (the ON-AIR
+	// badge) and ~15 s (live-status publish), so pulling 400 rows each time over a
+	// remote MySQL hammered the connection pool and, on a busy multi-op event, was a
+	// big part of "after a while nothing updates". Match the operator the same
+	// (case/space-insensitive) way, newest first.
 	opFilter := strings.ToUpper(strings.TrimSpace(operator))
-	for rows.Next() {
-		var oper, dateStr sql.NullString
-		if err := rows.Scan(&oper, &dateStr); err != nil {
-			return time.Time{}, false
-		}
-		if strings.ToUpper(strings.TrimSpace(oper.String)) != opFilter {
-			continue
-		}
-		if t := parseTimeLoose(dateStr.String).UTC(); !t.IsZero() {
-			return t, true
-		}
+	var dateStr sql.NullString
+	err := r.db.QueryRowContext(ctx,
+		`SELECT qso_date FROM qso WHERE UPPER(TRIM(operator)) = ? AND qso_date IS NOT NULL AND qso_date <> '' ORDER BY id DESC LIMIT 1`,
+		opFilter).Scan(&dateStr)
+	if err != nil {
+		return time.Time{}, false // ErrNoRows or a real error — no known last QSO
+	}
+	if t := parseTimeLoose(dateStr.String).UTC(); !t.IsZero() {
+		return t, true
 	}
 	return time.Time{}, false
 }

internal/qso/stats.go

@@ -392,8 +392,13 @@ func (r *Repo) Stats(ctx context.Context, from, to time.Time, contestID string,
 		if st := strings.ToUpper(strings.TrimSpace(station.String)); st != "" {
 			stationC[st]++
 		}
+		// Bucket a blank/unknown continent under "Unknown" rather than dropping it,
+		// so the continent breakdown totals the same as the QSO count (a handful of
+		// QSOs with no resolved continent made the donut read a few short).
 		if c := strings.ToUpper(strings.TrimSpace(cont.String)); c != "" {
 			contC[c]++
+		} else {
+			contC["Unknown"]++
 		}
 		if c := strings.TrimSpace(country.String); c != "" {
 			entityC[c]++
@@ -436,6 +441,9 @@ func (r *Repo) Stats(ctx context.Context, from, to time.Time, contestID string,
 	s.UniqueCalls = len(calls)
 	s.Entities = len(entities)
 	s.Continents = len(contC)
+	if _, ok := contC["Unknown"]; ok {
+		s.Continents-- // "Unknown" is a catch-all bucket, not a real continent
+	}
 	if !first.IsZero() {
 		s.FirstQSO = first.UTC().Format(time.RFC3339)
 		s.LastQSO = last.UTC().Format(time.RFC3339)

livestatus.go

@@ -2,7 +2,6 @@ package main
 
 import (
 	"database/sql"
-	"fmt"
 	"strings"
 	"time"
 
@@ -30,8 +29,6 @@ func (a *App) emitLiveStatusChanged() {
 // to the DB — it is not a web server. Rows older than a couple of minutes are
 // "stale" (operator went offline); the web side ignores them.
 
-const keyLiveStatusEnabled = "livestatus.enabled"
-
 // liveOnlineWindow is how long after the last logged contact an operator still
 // counts as "on air". Leaving the log open without working anyone flips them
 // offline once this elapses; logging a new QSO flips them back online.
@@ -49,37 +46,6 @@ func (a *App) noteLiveQSO() {
 	}
 }
 
-// GetLiveStatusEnabled reports whether this operator publishes live status.
-func (a *App) GetLiveStatusEnabled() bool {
-	if a.settings == nil {
-		return false
-	}
-	v, _ := a.settings.Get(a.ctx, keyLiveStatusEnabled)
-	return strings.TrimSpace(v) == "1"
-}
-
-// SetLiveStatusEnabled turns live-status publishing on or off (off also removes
-// this operator's row immediately).
-func (a *App) SetLiveStatusEnabled(on bool) error {
-	if a.settings == nil {
-		return fmt.Errorf("db not initialized")
-	}
-	val := "0"
-	if on {
-		val = "1"
-	}
-	if err := a.settings.Set(a.ctx, keyLiveStatusEnabled, val); err != nil {
-		return err
-	}
-	if on {
-		applog.Printf("livestatus: enabled (logbook backend=%q, mysql conn=%v)", a.dbBackend, a.logDb != nil)
-		go a.publishLiveStatus() // show up right away
-	} else {
-		a.clearLiveStatus()
-	}
-	return nil
-}
-
 // seedLiveLastQSO primes liveLastQSOAt from the DB at launch, so an operator who
 // worked someone shortly before (re)starting OpsLog is shown "on air" right away
 // instead of offline until their next QSO.
@@ -143,9 +109,11 @@ func (a *App) liveStatusLoop() {
 	}
 }
 
-// liveStatusActive reports whether publishing should run (MySQL logbook + on).
+// liveStatusActive reports whether publishing should run. Always on for a shared
+// MySQL logbook (no user toggle: going offline is automatic — no QSO for 5 min
+// removes the row — so there is nothing to opt out of).
 func (a *App) liveStatusActive() bool {
-	return a.logDb != nil && a.dbBackend == "mysql" && a.GetLiveStatusEnabled()
+	return a.logDb != nil && a.dbBackend == "mysql"
 }
 
 // liveStatusOperator returns this instance's operator id (the operator callsign,
@@ -197,9 +165,6 @@ func (a *App) publishLiveStatus() {
 	if a.logDb == nil || a.dbBackend != "mysql" {
 		return // not a MySQL logbook — nothing to do (silent, runs every 15s)
 	}
-	if !a.GetLiveStatusEnabled() {
-		return // disabled (silent)
-	}
 	op, station := a.liveStatusOperator()
 	if op == "" {
 		applog.Printf("livestatus: nothing published — no operator/callsign set (Settings → Station)")
@@ -316,7 +281,29 @@ func (a *App) GetLiveStations() []LiveStation {
 	return out
 }
 
+// ensureLiveStatusTable creates/upgrades the live_status table ONCE per logbook
+// connection. It used to run the CREATE + 3 ALTERs on every call — and it is
+// called from every publish (15s heartbeat) AND every GetLiveStations poll (5s),
+// so that was 4 wasted round-trips per call on a remote MySQL, adding latency to
+// the "who's on air" widget and holding pool connections for nothing.
 func (a *App) ensureLiveStatusTable() error {
+	db := a.logDb
+	a.liveTableMu.Lock()
+	done := a.liveTableFor == db // re-ensure after a profile switch swaps the logbook
+	a.liveTableMu.Unlock()
+	if done {
+		return nil
+	}
+	if err := a.ensureLiveStatusTableDDL(); err != nil {
+		return err
+	}
+	a.liveTableMu.Lock()
+	a.liveTableFor = db
+	a.liveTableMu.Unlock()
+	return nil
+}
+
+func (a *App) ensureLiveStatusTableDDL() error {
 	if _, err := a.logDb.ExecContext(a.ctx,
 		"CREATE TABLE IF NOT EXISTS live_status ("+
 			"operator VARCHAR(32) PRIMARY KEY, "+

telemetry.go

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