up

This reverts commit b8884d89e3.

internal/api/device_manager.go

@@ -121,6 +121,9 @@ func (dm *DeviceManager) Initialize() error {
 			dm.config.Devices.FlexRadio.Port,
 		)
 
+		dm.flexRadio.SetReconnectInterval(3 * time.Second)  // Retry every 3 seconds
+		dm.flexRadio.SetMaxReconnectDelay(30 * time.Second) // Max 30 second delay
+
 		// Set callback for immediate frequency changes (no waiting for update cycle)
 		dm.flexRadio.SetFrequencyChangeCallback(func(freqMHz float64) {
 			dm.handleFrequencyChange(freqMHz)
@@ -421,9 +424,7 @@ func (dm *DeviceManager) updateStatus() {
 
 						// Check cooldown to prevent rapid fire commands
 						timeSinceLastUpdate := time.Since(dm.lastFreqUpdateTime)
-						if timeSinceLastUpdate < dm.freqUpdateCooldown {
-							log.Printf("Auto-track: Cooldown active (%v remaining), skipping update", dm.freqUpdateCooldown-timeSinceLastUpdate)
-						} else {
+						if timeSinceLastUpdate > dm.freqUpdateCooldown {
 							log.Printf("Auto-track (%s): Frequency differs by %d kHz, updating Ultrabeam to %d kHz (direction=%d)", radioSource, freqDiff, radioFreqKhz, directionToUse)
 
 							// Send to Ultrabeam with saved or current direction

internal/devices/flexradio/flexradio.go

@@ -9,6 +9,7 @@ import (
 	"strings"
 	"sync"
 	"time"
+	"unicode"
 )
 
 type Client struct {
@@ -17,8 +18,8 @@ type Client struct {
 
 	conn    net.Conn
 	reader  *bufio.Reader
-	connMu  sync.Mutex // For connection management
-	writeMu sync.Mutex // For writing to connection (separate from reads)
+	connMu  sync.Mutex
+	writeMu sync.Mutex
 
 	lastStatus *Status
 	statusMu   sync.RWMutex
@@ -29,12 +30,21 @@ type Client struct {
 	running  bool
 	stopChan chan struct{}
 
-	// Callbacks
-	onFrequencyChange    func(freqMHz float64)
-	checkTransmitAllowed func() bool // Returns true if transmit allowed (motors not moving)
-
-	// Reconnection settings
 	reconnectInterval time.Duration
+	reconnectAttempts int
+	maxReconnectDelay time.Duration
+
+	radioInfo      map[string]string
+	radioInfoMu    sync.RWMutex
+	lastInfoCheck  time.Time
+	infoCheckTimer *time.Timer
+
+	activeSlices   []int
+	activeSlicesMu sync.RWMutex
+	sliceListTimer *time.Timer
+
+	onFrequencyChange    func(freqMHz float64)
+	checkTransmitAllowed func() bool
 }
 
 func New(host string, port int) *Client {
@@ -42,13 +52,27 @@ func New(host string, port int) *Client {
 		host:              host,
 		port:              port,
 		stopChan:          make(chan struct{}),
+		reconnectInterval: 5 * time.Second,
+		maxReconnectDelay: 60 * time.Second,
+		radioInfo:         make(map[string]string),
+		activeSlices:      []int{},
 		lastStatus: &Status{
 			Connected: false,
+			RadioOn:   false,
 		},
-		reconnectInterval: 5 * time.Second, // Reconnect every 5 seconds if disconnected
 	}
 }
 
+// SetReconnectInterval sets the reconnection interval
+func (c *Client) SetReconnectInterval(interval time.Duration) {
+	c.reconnectInterval = interval
+}
+
+// SetMaxReconnectDelay sets the maximum delay for exponential backoff
+func (c *Client) SetMaxReconnectDelay(delay time.Duration) {
+	c.maxReconnectDelay = delay
+}
+
 // SetFrequencyChangeCallback sets the callback function called when frequency changes
 func (c *Client) SetFrequencyChangeCallback(callback func(freqMHz float64)) {
 	c.onFrequencyChange = callback
@@ -72,14 +96,14 @@ func (c *Client) Connect() error {
 
 	conn, err := net.DialTimeout("tcp", addr, 5*time.Second)
 	if err != nil {
-		log.Printf("FlexRadio: Connection failed: %v", err)
 		return fmt.Errorf("failed to connect: %w", err)
 	}
 
 	c.conn = conn
 	c.reader = bufio.NewReader(conn)
+	c.reconnectAttempts = 0
 
-	log.Println("FlexRadio: Connected successfully")
+	log.Println("FlexRadio: TCP connection established")
 	return nil
 }
 
@@ -88,37 +112,48 @@ func (c *Client) Start() error {
 		return nil
 	}
 
-	c.running = true
+	// Try initial connection
+	if err := c.Connect(); err != nil {
+		log.Printf("FlexRadio: Initial connection failed: %v", err)
+	}
 
-	// Try initial connection but don't fail if it doesn't work
-	// The messageLoop will handle reconnection
-	err := c.Connect()
-	if err != nil {
-		log.Printf("FlexRadio: Initial connection failed, will retry: %v", err)
-	} else {
 	// Update connected status
 	c.statusMu.Lock()
 	if c.lastStatus != nil {
-			c.lastStatus.Connected = true
+		c.lastStatus.Connected = (c.conn != nil)
+		c.lastStatus.RadioOn = false
 	}
 	c.statusMu.Unlock()
 
-		// Subscribe to slice updates for frequency tracking
-		c.subscribeToSlices()
-	}
+	c.running = true
 
-	// Start message listener (handles reconnection)
+	// Start message listener
 	go c.messageLoop()
 
-	return nil
+	// Start reconnection monitor
+	go c.reconnectionMonitor()
+
+	// Start radio status checker
+	go c.radioStatusChecker()
+
+	// Start slice list checker
+	go c.sliceListChecker()
+
+	// Try to get initial radio info and subscribe to slices
+	if c.conn != nil {
+		go func() {
+			time.Sleep(500 * time.Millisecond)
+			c.SendInfo()
+
+			time.Sleep(500 * time.Millisecond)
+			c.SendSliceList()
+
+			time.Sleep(500 * time.Millisecond)
+			c.SubscribeToSlices()
+		}()
 	}
 
-func (c *Client) subscribeToSlices() {
-	log.Println("FlexRadio: Subscribing to slice updates...")
-	_, err := c.sendCommand("sub slice all")
-	if err != nil {
-		log.Printf("FlexRadio: Warning - failed to subscribe to slices: %v", err)
-	}
+	return nil
 }
 
 func (c *Client) Stop() {
@@ -129,6 +164,14 @@ func (c *Client) Stop() {
 	c.running = false
 	close(c.stopChan)
 
+	// Stop timers
+	if c.infoCheckTimer != nil {
+		c.infoCheckTimer.Stop()
+	}
+	if c.sliceListTimer != nil {
+		c.sliceListTimer.Stop()
+	}
+
 	c.connMu.Lock()
 	if c.conn != nil {
 		c.conn.Close()
@@ -137,23 +180,34 @@ func (c *Client) Stop() {
 	}
 	c.connMu.Unlock()
 
-	// Update connected status
+	// Update status
 	c.statusMu.Lock()
 	if c.lastStatus != nil {
 		c.lastStatus.Connected = false
+		c.lastStatus.RadioOn = false
+		c.lastStatus.RadioInfo = "Disconnected"
+		c.lastStatus.ActiveSlices = 0
+		c.lastStatus.Frequency = 0
+		c.lastStatus.Mode = ""
+		c.lastStatus.Tx = false
 	}
 	c.statusMu.Unlock()
 }
 
-func (c *Client) getNextSeq() int {
-	c.cmdSeqMu.Lock()
-	defer c.cmdSeqMu.Unlock()
-	c.cmdSeq++
-	return c.cmdSeq
+// Helper functions for common commands
+func (c *Client) SendInfo() error {
+	return c.sendCommand("info")
 }
 
-func (c *Client) sendCommand(cmd string) (string, error) {
-	// Use writeMu instead of connMu to avoid blocking on messageLoop reads
+func (c *Client) SendSliceList() error {
+	return c.sendCommand("slice list")
+}
+
+func (c *Client) SubscribeToSlices() error {
+	return c.sendCommand("sub slice all")
+}
+
+func (c *Client) sendCommand(cmd string) error {
 	c.writeMu.Lock()
 	defer c.writeMu.Unlock()
 
@@ -162,7 +216,7 @@ func (c *Client) sendCommand(cmd string) (string, error) {
 	c.connMu.Unlock()
 
 	if conn == nil {
-		return "", fmt.Errorf("not connected")
+		return fmt.Errorf("not connected")
 	}
 
 	seq := c.getNextSeq()
@@ -172,80 +226,7 @@ func (c *Client) sendCommand(cmd string) (string, error) {
 
 	_, err := conn.Write([]byte(fullCmd))
 	if err != nil {
-		c.connMu.Lock()
-		c.conn = nil
-		c.reader = nil
-		c.connMu.Unlock()
-		return "", fmt.Errorf("failed to send command: %w", err)
-	}
-
-	return "", nil
-}
-
-func (c *Client) messageLoop() {
-	log.Println("FlexRadio: Message loop started")
-
-	reconnectTicker := time.NewTicker(c.reconnectInterval)
-	defer reconnectTicker.Stop()
-
-	for c.running {
-		c.connMu.Lock()
-		isConnected := c.conn != nil && c.reader != nil
-		c.connMu.Unlock()
-
-		if !isConnected {
-			// Update status to disconnected
-			c.statusMu.Lock()
-			if c.lastStatus != nil {
-				c.lastStatus.Connected = false
-			}
-			c.statusMu.Unlock()
-
-			// Wait for reconnect interval
-			select {
-			case <-reconnectTicker.C:
-				log.Println("FlexRadio: Attempting to reconnect...")
-				if err := c.Connect(); err != nil {
-					log.Printf("FlexRadio: Reconnect failed: %v", err)
-					continue
-				}
-
-				// Successfully reconnected
-				c.statusMu.Lock()
-				if c.lastStatus != nil {
-					c.lastStatus.Connected = true
-				}
-				c.statusMu.Unlock()
-
-				// Re-subscribe to slices after reconnection
-				c.subscribeToSlices()
-
-			case <-c.stopChan:
-				log.Println("FlexRadio: Message loop stopping (stop signal received)")
-				return
-			}
-			continue
-		}
-
-		// Read from connection
-		c.connMu.Lock()
-		if c.conn == nil || c.reader == nil {
-			c.connMu.Unlock()
-			continue
-		}
-
-		// Set read deadline to allow periodic checks
-		c.conn.SetReadDeadline(time.Now().Add(2 * time.Second))
-
-		line, err := c.reader.ReadString('\n')
-		c.connMu.Unlock()
-
-		if err != nil {
-			if netErr, ok := err.(net.Error); ok && netErr.Timeout() {
-				// Timeout is expected, continue
-				continue
-			}
-			log.Printf("FlexRadio: Read error: %v", err)
+		// Mark connection as broken
 		c.connMu.Lock()
 		if c.conn != nil {
 			c.conn.Close()
@@ -254,14 +235,65 @@ func (c *Client) messageLoop() {
 		}
 		c.connMu.Unlock()
 
-			// Update connected status
+		// Update status
 		c.statusMu.Lock()
 		if c.lastStatus != nil {
 			c.lastStatus.Connected = false
+			c.lastStatus.RadioOn = false
+			c.lastStatus.RadioInfo = "Connection lost"
 		}
 		c.statusMu.Unlock()
 
-			log.Println("FlexRadio: Connection lost, will attempt reconnection...")
+		return fmt.Errorf("failed to send command: %w", err)
+	}
+
+	return nil
+}
+
+func (c *Client) getNextSeq() int {
+	c.cmdSeqMu.Lock()
+	defer c.cmdSeqMu.Unlock()
+	c.cmdSeq++
+	return c.cmdSeq
+}
+
+func (c *Client) messageLoop() {
+	log.Println("FlexRadio: Message loop started")
+
+	for c.running {
+		c.connMu.Lock()
+		if c.conn == nil || c.reader == nil {
+			c.connMu.Unlock()
+			time.Sleep(1 * time.Second)
+			continue
+		}
+
+		c.conn.SetReadDeadline(time.Now().Add(2 * time.Second))
+		line, err := c.reader.ReadString('\n')
+		c.connMu.Unlock()
+
+		if err != nil {
+			if netErr, ok := err.(net.Error); ok && netErr.Timeout() {
+				continue
+			}
+
+			log.Printf("FlexRadio: Read error: %v", err)
+
+			c.connMu.Lock()
+			if c.conn != nil {
+				c.conn.Close()
+				c.conn = nil
+				c.reader = nil
+			}
+			c.connMu.Unlock()
+
+			c.statusMu.Lock()
+			if c.lastStatus != nil {
+				c.lastStatus.Connected = false
+				c.lastStatus.RadioOn = false
+				c.lastStatus.RadioInfo = "Connection lost"
+			}
+			c.statusMu.Unlock()
 			continue
 		}
 
@@ -276,87 +308,402 @@ func (c *Client) messageLoop() {
 	log.Println("FlexRadio: Message loop stopped")
 }
 
+// Message handling - SIMPLIFIED VERSION
 func (c *Client) handleMessage(msg string) {
-	// Response format: R<seq>|<status>|<data>
-	if strings.HasPrefix(msg, "R") {
-		c.handleResponse(msg)
+	msg = strings.TrimSpace(msg)
+	if msg == "" {
 		return
 	}
 
-	// Status format: S<handle>|<key>=<value> ...
-	if strings.HasPrefix(msg, "S") {
-		c.handleStatus(msg)
-		return
-	}
+	// DEBUG: Log tous les messages reçus
+	log.Printf("FlexRadio RAW: %s", msg)
 
-	// Version/handle format: V<version>|H<handle>
-	if strings.HasPrefix(msg, "V") {
-		log.Printf("FlexRadio: Version/Handle received: %s", msg)
-		return
-	}
-
-	// Message format: M<handle>|<message>
-	if strings.HasPrefix(msg, "M") {
+	// Router selon le premier caractère
+	switch msg[0] {
+	case 'R': // Réponse à une commande
+		c.handleCommandResponse(msg)
+	case 'S': // Message de statut
+		c.handleStatusMessage(msg)
+	case 'V': // Version/Handle
+		log.Printf("FlexRadio: Version/Handle: %s", msg)
+	case 'M': // Message général
 		log.Printf("FlexRadio: Message: %s", msg)
-		return
+	default:
+		log.Printf("FlexRadio: Unknown message type: %s", msg)
 	}
 }
 
-func (c *Client) handleResponse(msg string) {
+func (c *Client) handleCommandResponse(msg string) {
 	// Format: R<seq>|<status>|<data>
-	// Example: R21|0|000000F4
 	parts := strings.SplitN(msg, "|", 3)
-	if len(parts) < 2 {
+	if len(parts) < 3 {
+		log.Printf("FlexRadio: Malformed response: %s", msg)
 		return
 	}
 
+	seqStr := strings.TrimPrefix(parts[0], "R")
 	status := parts[1]
+	data := parts[2]
+
+	seq, _ := strconv.Atoi(seqStr)
+
 	if status != "0" {
-		log.Printf("FlexRadio: Command error: status=%s, message=%s", status, msg)
+		log.Printf("FlexRadio: Command error (seq=%d): %s", seq, msg)
 		return
 	}
+
+	log.Printf("FlexRadio: Command success (seq=%d)", seq)
+
+	// Identifier le type de réponse par son contenu
+	switch {
+	case strings.Contains(data, "model="):
+		c.parseInfoResponse(data)
+
+	case isSliceListResponse(data):
+		c.parseSliceListResponse(data)
+
+	default:
+		log.Printf("FlexRadio: Generic response: %s", data)
+	}
 }
 
-func (c *Client) handleStatus(msg string) {
-	// Format: S<handle>|<key>=<value> ...
+func isSliceListResponse(data string) bool {
+	data = strings.TrimSpace(data)
+	if data == "" {
+		return true
+	}
+
+	for _, char := range data {
+		if !unicode.IsDigit(char) && char != ' ' {
+			return false
+		}
+	}
+	return true
+}
+
+func (c *Client) handleStatusMessage(msg string) {
 	parts := strings.SplitN(msg, "|", 2)
 	if len(parts) < 2 {
 		return
 	}
 
+	handle := parts[0][1:]
 	data := parts[1]
 
-	// Parse key=value pairs
-	pairs := strings.Fields(data)
 	statusMap := make(map[string]string)
+	pairs := strings.Fields(data)
 
 	for _, pair := range pairs {
-		kv := strings.SplitN(pair, "=", 2)
-		if len(kv) == 2 {
+		if kv := strings.SplitN(pair, "=", 2); len(kv) == 2 {
 			statusMap[kv[0]] = kv[1]
 		}
 	}
 
-	// Check for slice updates (frequency changes)
-	if strings.Contains(msg, "slice") {
-		if rfFreq, ok := statusMap["RF_frequency"]; ok {
-			freq, err := strconv.ParseFloat(rfFreq, 64)
-			if err == nil {
+	switch {
+	case strings.Contains(msg, "interlock"):
+		c.handleInterlockStatus(handle, statusMap)
+
+	case strings.Contains(msg, "slice"):
+		c.handleSliceStatus(handle, statusMap)
+
+	case strings.Contains(msg, "radio"):
+		c.handleRadioStatus(handle, statusMap)
+
+	default:
+		log.Printf("FlexRadio: Unknown status (handle=%s): %s", handle, msg)
+	}
+}
+
+func (c *Client) handleInterlockStatus(handle string, statusMap map[string]string) {
 	c.statusMu.Lock()
-				oldFreq := c.lastStatus.Frequency
+	defer c.statusMu.Unlock()
+
+	if state, ok := statusMap["state"]; ok {
+		c.lastStatus.Tx = (state == "TRANSMITTING" || state == "TUNE")
+		log.Printf("FlexRadio: Interlock state=%s, TX=%v", state, c.lastStatus.Tx)
+	}
+}
+
+func (c *Client) handleSliceStatus(handle string, statusMap map[string]string) {
+	c.statusMu.Lock()
+	defer c.statusMu.Unlock()
+
+	// Quand on reçoit un message de slice, on a au moins une slice active
+	c.lastStatus.ActiveSlices = 1
+
+	if rfFreq, ok := statusMap["RF_frequency"]; ok {
+		if freq, err := strconv.ParseFloat(rfFreq, 64); err == nil && freq > 0 {
 			c.lastStatus.Frequency = freq
-				c.statusMu.Unlock()
+			c.lastStatus.RadioInfo = fmt.Sprintf("Active on %.3f MHz", freq)
 
-				// Only log significant frequency changes (> 1 kHz)
-				if oldFreq == 0 || (freq-oldFreq)*(freq-oldFreq) > 0.001 {
-					log.Printf("FlexRadio: Frequency updated to %.6f MHz", freq)
-
-					// Trigger callback for immediate auto-track
 			if c.onFrequencyChange != nil {
 				go c.onFrequencyChange(freq)
 			}
+		} else if freq == 0 {
+			// Fréquence 0 dans le message de slice = slice inactive
+			c.lastStatus.Frequency = 0
+			c.lastStatus.RadioInfo = "Slice inactive"
 		}
 	}
+
+	if mode, ok := statusMap["mode"]; ok {
+		c.lastStatus.Mode = mode
+	}
+
+	if tx, ok := statusMap["tx"]; ok {
+		c.lastStatus.Tx = (tx == "1")
+	}
+}
+
+func (c *Client) handleRadioStatus(handle string, statusMap map[string]string) {
+	if slices, ok := statusMap["slices"]; ok {
+		if num, err := strconv.Atoi(slices); err == nil {
+			c.statusMu.Lock()
+			c.lastStatus.NumSlices = num
+			c.statusMu.Unlock()
+		}
+	}
+}
+
+func (c *Client) parseInfoResponse(data string) {
+	log.Printf("FlexRadio: Parsing info response: %s", data)
+
+	pairs := []string{}
+	current := ""
+	inQuotes := false
+
+	for _, char := range data {
+		if char == '"' {
+			inQuotes = !inQuotes
+		}
+		if char == ',' && !inQuotes {
+			pairs = append(pairs, strings.TrimSpace(current))
+			current = ""
+		} else {
+			current += string(char)
+		}
+	}
+	if current != "" {
+		pairs = append(pairs, strings.TrimSpace(current))
+	}
+
+	c.radioInfoMu.Lock()
+	c.radioInfo = make(map[string]string)
+
+	for _, pair := range pairs {
+		kv := strings.SplitN(pair, "=", 2)
+		if len(kv) == 2 {
+			key := strings.TrimSpace(kv[0])
+			value := strings.TrimSpace(kv[1])
+
+			if len(value) >= 2 && value[0] == '"' && value[len(value)-1] == '"' {
+				value = value[1 : len(value)-1]
+			}
+
+			c.radioInfo[key] = value
+		}
+	}
+
+	c.radioInfoMu.Unlock()
+
+	c.updateRadioStatus(true, "Radio is on")
+
+	go func() {
+		time.Sleep(300 * time.Millisecond)
+		c.SendSliceList()
+	}()
+}
+
+func (c *Client) parseSliceListResponse(data string) {
+	slices := []int{}
+
+	if strings.TrimSpace(data) != "" {
+		parts := strings.Fields(data)
+		for _, part := range parts {
+			if sliceNum, err := strconv.Atoi(part); err == nil {
+				slices = append(slices, sliceNum)
+			}
+		}
+	}
+
+	c.activeSlicesMu.Lock()
+	c.activeSlices = slices
+	c.activeSlicesMu.Unlock()
+
+	c.statusMu.Lock()
+	if c.lastStatus != nil {
+		c.lastStatus.ActiveSlices = len(slices)
+
+		// NE PAS effacer la fréquence ici !
+		// La fréquence est gérée par handleSliceStatus
+
+		// Seulement mettre à jour RadioInfo si vraiment pas de slices
+		if len(slices) == 0 && c.lastStatus.Frequency == 0 {
+			c.lastStatus.RadioInfo = "Radio is on without any active slice"
+		} else if len(slices) == 0 && c.lastStatus.Frequency > 0 {
+			// Cas spécial : fréquence mais pas de slice dans la liste
+			// Peut arriver temporairement, garder l'info actuelle
+			c.lastStatus.RadioInfo = fmt.Sprintf("Active on %.3f MHz", c.lastStatus.Frequency)
+		}
+	}
+	c.statusMu.Unlock()
+
+	log.Printf("FlexRadio: Active slices updated: %v (total: %d)", slices, len(slices))
+}
+
+func (c *Client) updateRadioStatus(isOn bool, info string) {
+	c.statusMu.Lock()
+	defer c.statusMu.Unlock()
+
+	if c.lastStatus != nil {
+		c.lastStatus.RadioOn = isOn
+		c.lastStatus.RadioInfo = info
+
+		c.radioInfoMu.RLock()
+		if callsign, ok := c.radioInfo["callsign"]; ok {
+			c.lastStatus.Callsign = callsign
+		}
+		if model, ok := c.radioInfo["model"]; ok {
+			c.lastStatus.Model = model
+		}
+		if softwareVer, ok := c.radioInfo["software_ver"]; ok {
+			c.lastStatus.SoftwareVer = softwareVer
+		}
+		if numSlicesStr, ok := c.radioInfo["num_slice"]; ok {
+			if numSlices, err := strconv.Atoi(numSlicesStr); err == nil {
+				c.lastStatus.NumSlices = numSlices
+			}
+		}
+		c.radioInfoMu.RUnlock()
+
+		if isOn && c.lastStatus.Frequency == 0 && c.lastStatus.ActiveSlices == 0 {
+			c.lastStatus.RadioInfo = "Radio is on without any active slice"
+		}
+	}
+}
+
+func (c *Client) reconnectionMonitor() {
+	log.Println("FlexRadio: Reconnection monitor started")
+
+	for c.running {
+		c.connMu.Lock()
+		connected := (c.conn != nil)
+		c.connMu.Unlock()
+
+		if !connected {
+			c.reconnectAttempts++
+
+			delay := c.calculateReconnectDelay()
+
+			log.Printf("FlexRadio: Attempting to reconnect in %v (attempt %d)...", delay, c.reconnectAttempts)
+
+			select {
+			case <-time.After(delay):
+				if err := c.reconnect(); err != nil {
+					log.Printf("FlexRadio: Reconnection attempt %d failed: %v", c.reconnectAttempts, err)
+				} else {
+					log.Printf("FlexRadio: Reconnected successfully on attempt %d", c.reconnectAttempts)
+					c.reconnectAttempts = 0
+
+					go func() {
+						time.Sleep(500 * time.Millisecond)
+						c.SendInfo()
+					}()
+				}
+			case <-c.stopChan:
+				return
+			}
+		} else {
+			select {
+			case <-time.After(10 * time.Second):
+			case <-c.stopChan:
+				return
+			}
+		}
+	}
+}
+
+func (c *Client) calculateReconnectDelay() time.Duration {
+	delay := c.reconnectInterval
+
+	if c.reconnectAttempts > 1 {
+		multiplier := 1 << (c.reconnectAttempts - 1)
+		delay = c.reconnectInterval * time.Duration(multiplier)
+
+		if delay > c.maxReconnectDelay {
+			delay = c.maxReconnectDelay
+		}
+	}
+
+	return delay
+}
+
+func (c *Client) reconnect() error {
+	c.connMu.Lock()
+	defer c.connMu.Unlock()
+
+	// Close existing connection if any
+	if c.conn != nil {
+		c.conn.Close()
+		c.conn = nil
+		c.reader = nil
+	}
+
+	addr := fmt.Sprintf("%s:%d", c.host, c.port)
+	log.Printf("FlexRadio: Reconnecting to %s...", addr)
+
+	conn, err := net.DialTimeout("tcp", addr, 5*time.Second)
+	if err != nil {
+		c.statusMu.Lock()
+		if c.lastStatus != nil {
+			c.lastStatus.Connected = false
+			c.lastStatus.RadioOn = false
+			c.lastStatus.RadioInfo = "Disconnected"
+		}
+		c.statusMu.Unlock()
+		return fmt.Errorf("reconnect failed: %w", err)
+	}
+
+	c.conn = conn
+	c.reader = bufio.NewReader(conn)
+
+	c.statusMu.Lock()
+	if c.lastStatus != nil {
+		c.lastStatus.Connected = true
+		c.lastStatus.RadioInfo = "TCP connected, checking radio..."
+	}
+	c.statusMu.Unlock()
+
+	log.Println("FlexRadio: TCP connection reestablished")
+	return nil
+}
+
+func (c *Client) radioStatusChecker() {
+	c.infoCheckTimer = time.NewTimer(10 * time.Second)
+
+	for c.running {
+		select {
+		case <-c.infoCheckTimer.C:
+			c.SendInfo()
+			c.infoCheckTimer.Reset(10 * time.Second)
+		case <-c.stopChan:
+			return
+		}
+	}
+}
+
+func (c *Client) sliceListChecker() {
+	c.sliceListTimer = time.NewTimer(10 * time.Second)
+
+	for c.running {
+		select {
+		case <-c.sliceListTimer.C:
+			if c.IsRadioOn() {
+				c.SendSliceList()
+			}
+			c.sliceListTimer.Reset(10 * time.Second)
+		case <-c.stopChan:
+			return
 		}
 	}
 }
@@ -366,14 +713,25 @@ func (c *Client) GetStatus() (*Status, error) {
 	defer c.statusMu.RUnlock()
 
 	if c.lastStatus == nil {
-		return &Status{Connected: false}, nil
+		return &Status{
+			Connected: false,
+			RadioOn:   false,
+			RadioInfo: "Not initialized",
+		}, nil
 	}
 
-	// Create a copy
 	status := *c.lastStatus
-
-	// DON'T lock connMu here - it causes 4-second blocking!
-	// The messageLoop updates Connected status, and we trust the cached value
-
 	return &status, nil
 }
+
+// IsRadioOn returns true if radio is powered on and responding
+func (c *Client) IsRadioOn() bool {
+	c.statusMu.RLock()
+	defer c.statusMu.RUnlock()
+
+	if c.lastStatus == nil {
+		return false
+	}
+
+	return c.lastStatus.RadioOn
+}

internal/devices/flexradio/types.go

@@ -3,12 +3,16 @@ package flexradio
 // Status represents the FlexRadio status
 type Status struct {
 	Connected    bool    `json:"connected"`
-	InterlockID    string  `json:"interlock_id"`
-	InterlockState string  `json:"interlock_state"`
-	Frequency      float64 `json:"frequency"` // MHz
-	Model          string  `json:"model"`
-	Serial         string  `json:"serial"`
-	Version        string  `json:"version"`
+	Frequency    float64 `json:"frequency"`
+	Mode         string  `json:"mode"`
+	Tx           bool    `json:"tx"`
+	RadioOn      bool    `json:"radio_on"`      // Radio is powered on and responding
+	RadioInfo    string  `json:"radio_info"`    // Additional info about radio state
+	Callsign     string  `json:"callsign"`      // From info command
+	Model        string  `json:"model"`         // From info command
+	SoftwareVer  string  `json:"software_ver"`  // From info command
+	NumSlices    int     `json:"num_slices"`    // From info command
+	ActiveSlices int     `json:"active_slices"` // Count of active slices
 }
 
 // InterlockState represents possible interlock states

web/src/components/StatusBanner.svelte

@@ -9,11 +9,16 @@
   export let gustWarningThreshold = 50; // km/h
   export let graylineWindow = 30; // minutes avant/après sunrise/sunset
 
-  // FlexRadio frequency and mode
+  // FlexRadio status
   $: frequency = flexradio?.frequency || 0;
   $: mode = flexradio?.mode || '';
   $: txEnabled = flexradio?.tx || false;
   $: connected = flexradio?.connected || false;
+  $: radioOn = flexradio?.radio_on || false;
+  $: radioInfo = flexradio?.radio_info || '';
+  $: callsign = flexradio?.callsign || '';
+  $: model = flexradio?.model || '';
+  $: activeSlices = flexradio?.active_slices || 0;
 
   // Grayline calculation
   let sunrise = null;
@@ -55,6 +60,16 @@
     updateTimeToNextEvent();
   }
 
+  $: console.log('FlexRadio status:', {
+    connected,
+    radioOn,
+    frequency,
+    activeSlices,
+    radioInfo,
+    callsign,
+    model
+  });
+
   // Simplified sun calculation (based on NOAA algorithm)
   function getSunTimes(date, lat, lon) {
     const rad = Math.PI / 180;
@@ -228,6 +243,13 @@
 
   $: currentBand = getBand(frequency);
   $: bandColor = getBandColor(currentBand);
+  
+  // Determine what to show for FlexRadio - MODIFIÉ
+  $: showFrequency = radioOn && frequency > 0;
+  $: showRadioOnNoSlice = radioOn && frequency === 0 && activeSlices === 0;
+  $: showRadioOnWithSliceNoFreq = radioOn && frequency === 0 && activeSlices > 0;
+  $: showNotConnected = !connected;
+  $: showConnectedNoRadio = connected && !radioOn;
 </script>
 
 <div class="status-banner" class:has-warning={hasAnyWarning}>
@@ -237,7 +259,8 @@
         📻
     </div>
     
-    {#if connected && frequency > 0}
+    {#if showFrequency}
+      <!-- Radio is on and has active slice with frequency -->
       <div class="frequency-display">
         <span class="frequency" style="--band-color: {bandColor}">
           {formatFrequency(frequency)}
@@ -257,16 +280,57 @@
         </span>
       {/if}
 
+      <!-- AFFICHAGE TX - SEULEMENT SI TX EST VRAI -->
       {#if txEnabled}
         <span class="tx-indicator">
           TX
         </span>
       {/if}
-    {:else}
-      <span class="no-signal">FlexRadio non connecté</span>
+               
+    {:else if showRadioOnWithSliceNoFreq}
+      <!-- Radio is on with slice but frequency is 0 (maybe slice just created) -->
+      <div class="radio-status">
+        <span class="radio-on-indicator">●</span>
+        <span class="radio-status-text">Slice active, waiting for frequency...</span>
+        {#if model}
+          <span class="model-badge">{model}</span>
+        {/if}
+        {#if callsign}
+          <span class="callsign-badge">{callsign}</span>
         {/if}
       </div>
       
+    {:else if showRadioOnNoSlice}
+      <!-- Radio is on but no active slice -->
+      <div class="radio-status">
+        <span class="radio-on-indicator">●</span>
+        <span class="radio-status-text">{radioInfo || 'Radio is on'}</span>
+        {#if model}
+          <span class="model-badge">{model}</span>
+        {/if}
+        {#if callsign}
+          <span class="callsign-badge">{callsign}</span>
+        {/if}
+      </div>
+      
+    {:else if showConnectedNoRadio}
+      <!-- TCP connected but radio not responding -->
+      <div class="radio-status">
+        <span class="radio-off-indicator">○</span>
+        <span class="radio-status-text">TCP connected, radio off</span>
+      </div>
+      
+    {:else if showNotConnected}
+      <!-- Not connected at all -->
+      <span class="no-signal">FlexRadio not connected</span>
+      
+    {:else}
+      <!-- Default/unknown state -->
+      <span class="no-signal">Checking FlexRadio...</span>
+    {/if}
+  </div>
+
+
   <!-- Separator -->
   <div class="separator"></div>
 
@@ -304,7 +368,7 @@
       
       {#if isGrayline}
         <span class="grayline-badge" class:sunrise={graylineType === 'sunrise'} class:sunset={graylineType === 'sunset'}>
-          ✨ GRAYLINE
+          ✨ Grayline
         </span>
       {:else if timeToNextEvent}
         <span class="next-event">
@@ -312,7 +376,7 @@
         </span>
       {/if}
     {:else}
-      <span class="no-location">📍 Position non configurée</span>
+      <span class="no-location">📍 Position not set</span>
     {/if}
   </div>
 
@@ -342,7 +406,7 @@
     {#if !hasAnyWarning}
       <div class="status-ok">
         <span class="ok-icon">✓</span>
-        <span class="ok-text">Météo OK</span>
+        <span class="ok-text">Weather OK</span>
       </div>
     {/if}
   </div>
@@ -444,6 +508,58 @@
     50% { opacity: 0.6; }
   }
 
+  .slice-waiting {
+  color: #fbbf24; /* Jaune pour "en attente" */
+  animation: pulse 1.5s infinite;
+}
+
+  /* Radio status indicators */
+  .radio-status {
+    display: flex;
+    align-items: center;
+    gap: 8px;
+  }
+
+  .radio-on-indicator {
+    color: #22c55e;
+    font-size: 16px;
+    animation: pulse 2s infinite;
+  }
+
+  .radio-off-indicator {
+    color: #ef4444;
+    font-size: 16px;
+  }
+
+  @keyframes pulse {
+    0%, 100% { opacity: 1; }
+    50% { opacity: 0.5; }
+  }
+
+  .radio-status-text {
+    color: rgba(255, 255, 255, 0.9);
+    font-size: 14px;
+  }
+
+  .model-badge {
+    padding: 3px 8px;
+    background: rgba(79, 195, 247, 0.2);
+    border: 1px solid rgba(79, 195, 247, 0.4);
+    border-radius: 4px;
+    font-size: 12px;
+    color: #4fc3f7;
+  }
+
+  .callsign-badge {
+    padding: 3px 8px;
+    background: rgba(34, 197, 94, 0.2);
+    border: 1px solid rgba(34, 197, 94, 0.4);
+    border-radius: 4px;
+    font-size: 12px;
+    font-weight: 600;
+    color: #22c55e;
+  }
+
   .no-signal {
     color: rgba(255, 255, 255, 0.4);
     font-size: 14px;