$ show openclaw/clawgo
Clawgo is a minimal headless Go client node for the Clawdbot voice assistant gateway. It connects to a bridge over TCP, handles pairing and authentication, then streams voice transcripts from stdin, a FIFO, or a subprocess STT engine (brabble) as `voice.transcript` or `agent.request` events. It supports bidirectional chat: it can subscribe to chat events and speak responses via local TTS (espeak-ng or custom command) through a serialized speech queue. The node advertises itself via mDNS and supports configurable routing plugins for pre-processing transcripts (e.g., quick actions like 'telegram ping'). The architecture is a single binary with a reconnection loop, context-cancellable waits, and graceful shutdown on SIGINT/SIGTERM. The codebase demonstrates solid Go practices: clean separation of concerns, a plugin registry for routing policies, a thread-safe TTS queue that cancels active speech on disconnect, and careful handling of external subprocess stdout/stderr.
The LLM identified 4 files worth highlighting for reuse:
A reusable LineCapture that reads lines from a file or FIFO, reopens on modification (including truncation), tracks offsets using os.SameFile, and handles both pipe and regular file semantics. It can start from an arbitrary io.Reader or from a path, making it suitable for tailing logs, FIFOs, or rotating files in a cross-platform way. The implementation demonstrates careful stat-based change detection and context-aware sleep loops.
A speech-to-text engine that launches an external process (brabble), reads transcripts from both JSON-encoded events and plain text lines on stdout, and drains stderr to prevent blocking. It correctly handles process lifecycle: cancels the context on read errors, waits for stderr draining before calling cmd.Wait, and ensures all stdout lines are consumed before the process reaps. This pattern is reusable for any external tool that emits line-based output.
A minimal plugin registry for routing policies. It defines a Router interface and a Factory function type, provides a global Register/New with mutex-protected map, and allows external packages to register implementations via init(). The transport abstraction (SendVoiceTranscript, SendAgentRequest, SendProviderMessage) decouples routing from the bridge protocol. This is a clean, reusable extension point pattern.
The TTSQueue implementation within main.go demonstrates a serialized speech queue that cancels active speech on context cancellation (e.g., bridge disconnect or shutdown). It uses a buffered channel and a single worker goroutine, and provides a replaceTTSQueue helper for graceful swap during reconnection. The SystemTTSEngine uses exec.CommandContext with WaitDelay and passes the utterance after '--' to prevent espeak option injection. This is a well-structured pattern for queuing external commands with cancellation.