- Scan terminal output for "esc to " pattern to detect busy state

  - Strip ANSI escape sequences and lowercase on-the-fly for matching
  - Debounce idle transition (500ms) to avoid flickering
  - Send agent-status:busy/idle control messages to mobile
  - Document update-required and mobile-info control messages in CLAUDE.md

Author: hhfrancois

CLAUDE.md

@@ -45,7 +45,7 @@ make major   # X.0.0
 | Fichier | Role |
 |---------|------|
 | `main.go` | Entry point, parsing flags, demarrage PTY, boucle I/O |
-| `types.go` | Struct `Daemon`, `Message`, constantes ANSI |
+| `types.go` | Struct `Daemon`, `Message`, constantes ANSI, `MinAppVersion` |
 | `constants.go` | Timeouts, buffer sizes, permissions |
 | `agents.go` | Detection agents IA (claude, gemini, codex), selection |
 | `encryption.go` | AES-256-GCM pour chiffrement donnees session |
@@ -59,7 +59,7 @@ make major   # X.0.0
 | `ssh.go` | Detection SSH, installation cles authorized_keys |
 | `commands_session.go` | Commande /qr (affichage QR pairing) |
 | `commands_pairing.go` | Affichage QR pairing depuis daemon |
-| `commands_info.go` | Envoi info CLI au mobile |
+| `commands_info.go` | Envoi info CLI au mobile, handleMobileInfo (version check) |
 | `commands_terminal.go` | Traitement messages controle (resize, file-upload) |
 | `commands_upload.go` | Upload fichiers (simple et chunked) |
 | `utils.go` | Utilitaires (openFile cross-platform) |
@@ -81,6 +81,7 @@ Les messages de controle passent par le canal data avec prefix `\x00CTRL:`.
 | `file-upload-ack` | `file-upload-ack:uploadId:chunkIndex` | Confirmation chunk recu |
 | `file-upload-result` | `file-upload-result:success\|error:path\|msg` | Resultat upload |
 | `ssh-setup-result` | `ssh-setup-result:success\|error:message` | Resultat installation cle SSH |
+| `update-required` | `update-required:{"min_app_version":"X.Y.Z","cli_version":"...","message":"..."}` | Demande au mobile de se mettre a jour |
 
 ### Recus (Mobile -> CLI)
 
@@ -93,6 +94,7 @@ Les messages de controle passent par le canal data avec prefix `\x00CTRL:`.
 | `file-upload-start` | `file-upload-start:uploadId:filename:totalChunks:totalSize` | Debut upload chunked |
 | `file-upload-chunk` | `file-upload-chunk:uploadId:chunkIndex:dataBase64` | Chunk upload |
 | `file-upload-cancel` | `file-upload-cancel:uploadId` | Annule upload chunked |
+| `mobile-info` | `mobile-info:{"app_version":"X.Y.Z"}` | Version mobile, CLI compare avec `MinAppVersion` |
 
 ---
 

agent_status.go

@@ -0,0 +1,86 @@
+package main
+
+import (
+	"bytes"
+	"time"
+)
+
+// Agent busy/idle detection via PTY output scanning.
+// Detects "esc to " pattern (case-insensitive) in terminal output
+// to determine if the agent is busy (thinking/processing).
+
+const (
+	// AgentIdleDebounce is the delay before declaring idle after pattern disappears
+	AgentIdleDebounce = 500 * time.Millisecond
+	// agentStatusBufSize is the rolling buffer size for pattern scanning
+	agentStatusBufSize = 256
+)
+
+// busyPattern is the lowercase pattern to detect in PTY output
+var busyPattern = []byte("esc to ")
+
+// initAgentStatus initializes the agent status detection fields
+func (d *Daemon) initAgentStatus() {
+	d.agentStatusBuf = make([]byte, 0, agentStatusBufSize)
+}
+
+// scanAgentStatus scans PTY output for the busy pattern.
+// Called from startPTYReader on every read — must be fast.
+func (d *Daemon) scanAgentStatus(data []byte) {
+	// Append printable chars (lowercased) to rolling buffer, skip ANSI sequences
+	inEscape := d.agentStatusInEscape
+	buf := d.agentStatusBuf
+
+	for _, b := range data {
+		if inEscape {
+			// Inside ANSI escape: wait for terminating letter
+			if (b >= 'A' && b <= 'Z') || (b >= 'a' && b <= 'z') {
+				inEscape = false
+			}
+			continue
+		}
+		if b == 0x1b {
+			inEscape = true
+			continue
+		}
+		// Only keep printable ASCII
+		if b >= 0x20 && b <= 0x7e {
+			// Lowercase on the fly
+			if b >= 'A' && b <= 'Z' {
+				b += 0x20
+			}
+			buf = append(buf, b)
+		}
+	}
+	d.agentStatusInEscape = inEscape
+
+	// Trim buffer to max size (keep tail)
+	if len(buf) > agentStatusBufSize {
+		buf = buf[len(buf)-agentStatusBufSize:]
+	}
+	d.agentStatusBuf = buf
+
+	// Check for pattern
+	found := bytes.Contains(buf, busyPattern)
+
+	if found {
+		// Agent is busy — notify immediately if state changed
+		if d.agentIdleTimer != nil {
+			d.agentIdleTimer.Stop()
+			d.agentIdleTimer = nil
+		}
+		if !d.agentBusy {
+			d.agentBusy = true
+			d.sendControlMessage("agent-status:busy")
+		}
+	} else if d.agentBusy {
+		// Pattern gone — debounce before declaring idle
+		if d.agentIdleTimer == nil {
+			d.agentIdleTimer = time.AfterFunc(AgentIdleDebounce, func() {
+				d.agentBusy = false
+				d.agentIdleTimer = nil
+				d.sendControlMessage("agent-status:idle")
+			})
+		}
+	}
+}

main.go

@@ -238,6 +238,9 @@ func createDaemon(session, token, relay, command, workDir string, agentType Agen
 		log.Fatal("Failed to initialize encryption:", err)
 	}
 
+	// Initialize agent busy/idle detection
+	daemon.initAgentStatus()
+
 	return daemon
 }
 
@@ -337,6 +340,7 @@ func startPTYReader(daemon *Daemon) {
 				return
 			}
 
+			daemon.scanAgentStatus(buf[:n])
 			os.Stdout.Write(buf[:n])
 			daemon.sendToMobile(buf[:n])
 		}

types.go

@@ -100,6 +100,12 @@ type Daemon struct {
 	// Context for cancelling ping goroutine
 	pingCtx    context.Context
 	pingCancel context.CancelFunc
+
+	// Agent busy/idle detection
+	agentBusy           bool
+	agentIdleTimer      *time.Timer
+	agentStatusBuf      []byte
+	agentStatusInEscape bool
 }
 
 // Message types for WebSocket communication