OpsLog/internal/antgenius/antgenius.go

// Package antgenius drives a 4O3A Antenna Genius switch over its v4 TCP/IP
// text API (default port 9007). On connect the device sends a banner line
// (e.g. "V4.1.16 AG"); commands are "C<seq>|<command>\r" and the device replies
// with "R<seq>|<hex>|<message>" (hex "0" = success) plus asynchronous
// "S<0>|<message>" status pushes once you subscribe with "sub port/antenna".
//
// (The older "GSCP" binary-ish framing documented at gscp.arula.rs is only used
// by pre-v4 firmware and is NOT what v4 speaks.)
package antgenius

import (
	"bufio"
	"fmt"
	"net"
	"sort"
	"strconv"
	"strings"
	"sync"
	"time"
)

const (
	defaultPort     = 9007
	dialTimeout     = 5 * time.Second
	writeTimeout    = 3 * time.Second
	readIdleTimeout = 12 * time.Second // no data for this long → assume the link is dead
	keepaliveEvery  = 3 * time.Second  // periodic "port get" refreshes state + keeps the link alive
	reconnectDelay  = 2 * time.Second
)

// Antenna is one configured antenna (index + name as stored on the device).
type Antenna struct {
	Index int    `json:"index"`
	Name  string `json:"name"`
}

// Status is the snapshot the UI renders.
type Status struct {
	Connected bool      `json:"connected"`
	Host      string    `json:"host,omitempty"`
	LastError string    `json:"last_error,omitempty"`
	PortA     int       `json:"port_a"` // active antenna index on port A (0 = none)
	PortB     int       `json:"port_b"` // active antenna index on port B
	TxA       bool      `json:"tx_a"`   // port A is transmitting
	TxB       bool      `json:"tx_b"`   // port B is transmitting
	Antennas  []Antenna `json:"antennas"`
}

type Client struct {
	host string
	port int

	mu   sync.Mutex // guards conn + writes
	conn net.Conn

	statusMu sync.RWMutex
	status   Status
	antennas map[int]string // index → name (rebuilt into status.Antennas)

	stop    chan struct{}
	running bool
}

func New(host string, port int) *Client {
	if port <= 0 || port > 65535 {
		port = defaultPort
	}
	return &Client{
		host:     host,
		port:     port,
		stop:     make(chan struct{}),
		antennas: map[int]string{},
		status:   Status{Host: host},
	}
}

func (c *Client) Start() error {
	c.running = true
	go c.runLoop()
	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.Close()
		c.conn = nil
	}
	c.mu.Unlock()
}

func (c *Client) GetStatus() Status {
	c.statusMu.RLock()
	defer c.statusMu.RUnlock()
	return c.status
}

func (c *Client) setStatus(fn func(*Status)) {
	c.statusMu.Lock()
	fn(&c.status)
	c.statusMu.Unlock()
}

// Activate selects antenna on a port (1 = A, 2 = B). antenna 0 deselects (sets
// the port to "None"). We set both RX and TX antennas and force manual mode so
// the choice sticks regardless of the device's auto band-following.
func (c *Client) Activate(port, antenna int) error {
	if port != 1 && port != 2 {
		return fmt.Errorf("antgenius: invalid port %d (1=A, 2=B)", port)
	}
	if antenna < 0 {
		return fmt.Errorf("antgenius: invalid antenna %d", antenna)
	}
	if err := c.send(fmt.Sprintf("port set %d rxant=%d txant=%d", port, antenna, antenna)); err != nil {
		return err
	}
	// Ask for the new port state so the snapshot reflects it promptly (the
	// subscription also pushes it, but this makes the change deterministic).
	_ = c.send(fmt.Sprintf("port get %d", port))
	return nil
}

func (c *Client) runLoop() {
	for {
		if !c.running {
			return
		}
		conn, err := net.DialTimeout("tcp", net.JoinHostPort(c.host, strconv.Itoa(c.port)), dialTimeout)
		if err != nil {
			c.setStatus(func(s *Status) { s.Connected = false; s.LastError = "dial: " + err.Error() })
			if c.sleep(reconnectDelay) {
				return
			}
			continue
		}
		c.mu.Lock()
		c.conn = conn
		c.mu.Unlock()
		c.setStatus(func(s *Status) { s.Connected = true; s.LastError = ""; s.Host = c.host })

		// Subscribe to live updates and pull the initial state. Command set and
		// order mirror a known-working Node-RED v4 client (WA9WUD).
		_ = c.send("antenna list")
		_ = c.send("sub port all")
		_ = c.send("port get 1")
		_ = c.send("port get 2")

		done := make(chan struct{})
		go c.keepalive(conn, done)
		err = c.readLoop(conn) // blocks until the link errors
		close(done)

		c.mu.Lock()
		if c.conn == conn {
			c.conn = nil
		}
		c.mu.Unlock()
		conn.Close()
		c.setStatus(func(s *Status) {
			s.Connected = false
			if err != nil {
				s.LastError = "read: " + err.Error()
			}
		})
		if c.sleep(reconnectDelay) {
			return
		}
	}
}

// keepalive periodically re-reads a port so an idle-but-dead link is detected
// (the read loop's idle timeout fires if these stop producing replies).
func (c *Client) keepalive(conn net.Conn, done chan struct{}) {
	t := time.NewTicker(keepaliveEvery)
	defer t.Stop()
	for {
		select {
		case <-done:
			return
		case <-c.stop:
			return
		case <-t.C:
			_ = c.send("port get 1")
			_ = c.send("port get 2")
		}
	}
}

func (c *Client) readLoop(conn net.Conn) error {
	r := bufio.NewReader(conn)
	var sb strings.Builder
	for {
		_ = conn.SetReadDeadline(time.Now().Add(readIdleTimeout))
		b, err := r.ReadByte()
		if err != nil {
			return err
		}
		if b == '\r' || b == '\n' {
			if sb.Len() > 0 {
				c.handleLine(sb.String())
				sb.Reset()
			}
			continue
		}
		sb.WriteByte(b)
	}
}

// send writes a "C<seq>|<command>\r" line to the device.
func (c *Client) send(command string) error {
	c.mu.Lock()
	defer c.mu.Unlock()
	if c.conn == nil {
		return fmt.Errorf("antgenius: not connected")
	}
	_ = c.conn.SetWriteDeadline(time.Now().Add(writeTimeout))
	// The device only accepts the constant "C1|" sequence prefix for every
	// command (using incrementing sequence numbers makes it drop the link);
	// commands are LF-terminated.
	_, err := fmt.Fprintf(c.conn, "C1|%s\n", command)
	return err
}

// handleLine parses one response/status/banner line and updates the snapshot.
func (c *Client) handleLine(line string) {
	line = strings.TrimSpace(line)
	if line == "" {
		return
	}
	// Banner like "V4.1.16 AG" — just confirms the link is up.
	if line[0] == 'V' && strings.Contains(line, "AG") {
		c.setStatus(func(s *Status) { s.Connected = true; s.LastError = "" })
		return
	}
	// R<seq>|<hex>|<message>  or  S<seq>|<message>
	var msg string
	switch {
	case strings.HasPrefix(line, "R"):
		p := strings.SplitN(line, "|", 3)
		if len(p) == 3 {
			msg = p[2]
		}
	case strings.HasPrefix(line, "S"):
		p := strings.SplitN(line, "|", 2)
		if len(p) == 2 {
			msg = p[1]
		}
	}
	msg = strings.TrimSpace(msg)
	switch {
	case strings.HasPrefix(msg, "antenna "):
		c.parseAntenna(msg)
	case strings.HasPrefix(msg, "port "):
		c.parsePort(msg)
	}
}

// parseAntenna handles "antenna <id> name=<name> tx=.. rx=.. inband=..".
// The name may contain spaces, so it's extracted up to the " tx=" field.
func (c *Client) parseAntenna(msg string) {
	fields := strings.Fields(msg)
	if len(fields) < 2 {
		return
	}
	id, err := strconv.Atoi(fields[1])
	if err != nil {
		return
	}
	name := ""
	if i := strings.Index(msg, "name="); i >= 0 {
		name = msg[i+len("name="):]
		if j := strings.Index(name, " tx="); j >= 0 {
			name = name[:j]
		}
		// The device stores spaces as underscores in names.
		name = strings.TrimSpace(strings.ReplaceAll(name, "_", " "))
	}
	c.statusMu.Lock()
	if name != "" && !isPlaceholderName(name) {
		c.antennas[id] = name
	} else {
		delete(c.antennas, id) // unconfigured slot ("Antenna 4", etc.) → not shown
	}
	c.status.Antennas = sortedAntennas(c.antennas)
	c.status.Connected = true
	c.statusMu.Unlock()
}

// parsePort handles "port <id> ... rxant=<n> txant=<n> ...". The active antenna
// shown is the TX antenna, falling back to the RX antenna when TX is none.
func (c *Client) parsePort(msg string) {
	fields := strings.Fields(msg)
	if len(fields) < 2 {
		return
	}
	id, err := strconv.Atoi(fields[1])
	if err != nil || (id != 1 && id != 2) {
		return
	}
	tx := kvInt(msg, "txant")
	rx := kvInt(msg, "rxant")
	active := tx
	if active == 0 {
		active = rx
	}
	txOn := kvInt(msg, "tx") != 0 // the standalone "tx=0|1" transmit flag
	c.setStatus(func(s *Status) {
		s.Connected = true
		if id == 1 {
			s.PortA, s.TxA = active, txOn
		} else {
			s.PortB, s.TxB = active, txOn
		}
	})
}

func (c *Client) sleep(d time.Duration) (stopped bool) {
	select {
	case <-c.stop:
		return true
	case <-time.After(d):
		return false
	}
}

// kvInt extracts the integer value of a "key=<int>" token from a space-
// separated string (returns 0 if absent).
func kvInt(s, key string) int {
	i := strings.Index(s, key+"=")
	if i < 0 {
		return 0
	}
	v := s[i+len(key)+1:]
	if sp := strings.IndexByte(v, ' '); sp >= 0 {
		v = v[:sp]
	}
	n, _ := strconv.Atoi(strings.TrimSpace(v))
	return n
}

// isPlaceholderName reports whether name is an unconfigured-slot default like
// "Antenna 4" / "antenna_5" (after underscores become spaces): the word
// "antenna" followed by a number, which the UI shouldn't list.
func isPlaceholderName(name string) bool {
	f := strings.Fields(strings.ToLower(name))
	if len(f) != 2 || f[0] != "antenna" {
		return false
	}
	_, err := strconv.Atoi(f[1])
	return err == nil
}

func sortedAntennas(m map[int]string) []Antenna {
	out := make([]Antenna, 0, len(m))
	for idx, name := range m {
		out = append(out, Antenna{Index: idx, Name: name})
	}
	sort.Slice(out, func(i, j int) bool { return out[i].Index < out[j].Index })
	return out
}