feat: TUI overhaul — terminal safety, task system, VS Code integration, permission UX

Phase A — Terminal Safety:
- Signal handling + panic recovery with deferred restoreTerminal()
- Boot Ctrl+C audio cleanup, PlayChime lifecycle management
- Context propagation for LLM streaming cancellation
- Agent goroutine wait-before-exit with agentDone channel
- Cleanup method on appModel for orderly shutdown

Phase B — TUI Visual Overhaul:
- Status bar shows live tool activity ("reading auth.go", "running go test")
- Turn dividers show "continuing..." instead of developer jargon "turn N"
- Faster narration: 3s initial delay, 6s interval, tool-triggered
- Retro theme with demoscene-inspired C64 palette
- PETSCII block character spinner for retro theme
- Scanline flash sweep on completion

Phase C — VS Code / Cursor Integration:
- Terminal detection via TERM_PROGRAM (vscode.go)
- OSC 8 file hyperlinks in tool blocks (clickable paths)
- OSC 633 shell integration prompt markers
- /diff command for VS Code native diff viewer
- Boot animation throttled to 8fps in IDE terminals

Task System (Claude Code-style):
- TaskStore with create/get/update/list, blocked-by dependencies
- 4 LLM tools: create_task, update_task, list_tasks, get_task
- Live task panel with progress bar and checklist indicators
- Active task activeForm shown in status bar spinner
- /tasks slash command, 14 unit tests

Permission UX:
- Enter = allow (default action), single-key y/n/a shortcuts
- Bordered permission block with clear action display
- First-time tip notification for /trust all
- Non-blocking channel sends to prevent TUI freeze
- waitForEvent bails out on stopCh close

Other:
- Token cost estimates in /session command
- Tool activity text for all tools (git, web_search, tasks)
- estimateCost() with pricing for common models

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: halfaipg

agent.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"context"
 	"encoding/json"
 	"fmt"
 	"os"
@@ -72,17 +73,29 @@ Available tools:
 - git_log: Show recent commit history.
 - git_commit: Stage files and create a commit.
 - git_branch: List, create, or switch branches.
+- create_task: Create a task to track progress. The user sees these as a live checklist.
+- update_task: Update task status (pending → in_progress → completed).
+- list_tasks: List all tasks with status.
+- get_task: Get full details of a specific task.
 
 Guidelines:
-- You can call multiple tools in parallel — read_file, list_files, search_files, web_search, and dispatch_agent all run concurrently
+- You can call multiple tools in parallel — read_file, list_files, search_files, web_search, dispatch_agent, list_tasks, and get_task all run concurrently
 - Use list_files and search_files to explore the project before making changes
 - Read files before editing them — understand existing code first
 - Make targeted, minimal changes — don't rewrite entire files unnecessarily
 - For multiple related edits, prefer multi_edit over separate edit_file calls
 - Use git tools instead of shell for git operations — they provide structured output
 - After you edit files, the system may report diagnostics (errors, warnings) from language tools. If diagnostics appear, fix the issues before moving on.
 - If a tool fails, read the error and try a different approach
-- When finished, briefly summarize what you changed and why`
+- When finished, briefly summarize what you changed and why
+
+Task management:
+- For multi-step work (3+ steps), create tasks upfront so the user can track progress
+- Set status to "in_progress" BEFORE starting work on a task
+- Set status to "completed" only when fully done — not when partially done
+- Keep task subjects short and imperative (e.g. "Add auth middleware")
+- Provide active_form in present continuous (e.g. "Adding auth middleware") — it shows in the spinner
+- For simple or single-step tasks, skip task creation — just do the work directly`
 
 type Agent struct {
 	client    *LLMClient
@@ -94,9 +107,10 @@ type Agent struct {
 	permCh    chan PermissionResponse
 	permState *PermissionState
 	diag      *DiagnosticsEngine
+	tasks     *TaskStore
 }
 
-func NewAgent(client *LLMClient, workDir string, events chan<- AgentEvent, stopCh <-chan struct{}) *Agent {
+func NewAgent(client *LLMClient, workDir string, events chan<- AgentEvent, stopCh <-chan struct{}, tasks *TaskStore) *Agent {
 	sysContent := buildSystemPrompt(workDir)
 	return &Agent{
 		client:  client,
@@ -109,6 +123,7 @@ func NewAgent(client *LLMClient, workDir string, events chan<- AgentEvent, stopC
 		permCh:    make(chan PermissionResponse, 1),
 		permState: &PermissionState{TrustedTools: map[string]bool{}},
 		diag:      NewDiagnosticsEngine(workDir),
+		tasks:     tasks,
 	}
 }
 
@@ -252,9 +267,17 @@ func (a *Agent) Run(prompt string) {
 
 		a.events <- AgentEvent{Type: EventTurnStart, Turn: turn}
 
-		// Stream LLM call
+		// Stream LLM call with context derived from stopCh
+		ctx, cancel := context.WithCancel(context.Background())
+		go func() {
+			select {
+			case <-a.stopCh:
+				cancel()
+			case <-ctx.Done():
+			}
+		}()
 		streamCh := make(chan StreamEvent, 64)
-		go a.client.StreamChat(a.history, toolDefs, streamCh)
+		go a.client.StreamChat(ctx, a.history, toolDefs, streamCh)
 
 		var textContent strings.Builder
 		var toolCalls []ToolCall
@@ -264,6 +287,7 @@ func (a *Agent) Run(prompt string) {
 			// Check stop between stream events
 			select {
 			case <-a.stopCh:
+				cancel()
 				a.events <- AgentEvent{Type: EventDone, Text: "Stopped by user."}
 				return
 			default:
@@ -285,6 +309,7 @@ func (a *Agent) Run(prompt string) {
 				}
 
 			case StreamError:
+				cancel()
 				a.events <- AgentEvent{Type: EventError, Error: fmt.Errorf("%s", humanizeError(evt.Error))}
 				a.events <- AgentEvent{Type: EventDone, Text: "Error occurred."}
 				return
@@ -293,6 +318,7 @@ func (a *Agent) Run(prompt string) {
 				// handled below
 			}
 		}
+		cancel() // ensure context goroutine exits
 
 		_ = lastUsage
 
@@ -375,7 +401,8 @@ func (a *Agent) executeToolCalls(toolCalls []ToolCall, consecutiveErrors *int) {
 				defer wg.Done()
 				var output string
 				var success bool
-				if tc.Function.Name == "dispatch_agent" {
+				switch tc.Function.Name {
+				case "dispatch_agent":
 					task := ""
 					if args != nil {
 						task, _ = args["task"].(string)
@@ -388,7 +415,11 @@ func (a *Agent) executeToolCalls(toolCalls []ToolCall, consecutiveErrors *int) {
 						output = res
 						success = true
 					}
-				} else {
+				case "list_tasks":
+					output, success = toolListTasks(args, a.tasks)
+				case "get_task":
+					output, success = toolGetTask(args, a.tasks)
+				default:
 					output, success = ExecuteTool(tc.Function.Name, tc.Function.Arguments, a.workDir)
 				}
 				results[idx] = result{tc: tc, args: args, output: output, success: success}
@@ -462,7 +493,8 @@ func (a *Agent) executeToolCalls(toolCalls []ToolCall, consecutiveErrors *int) {
 
 		var output string
 		var success bool
-		if tc.Function.Name == "dispatch_agent" {
+		switch tc.Function.Name {
+		case "dispatch_agent":
 			task := ""
 			if argsMap != nil {
 				task, _ = argsMap["task"].(string)
@@ -475,7 +507,15 @@ func (a *Agent) executeToolCalls(toolCalls []ToolCall, consecutiveErrors *int) {
 				output = res
 				success = true
 			}
-		} else {
+		case "create_task":
+			output, success = toolCreateTask(argsMap, a.tasks)
+		case "update_task":
+			output, success = toolUpdateTask(argsMap, a.tasks)
+		case "list_tasks":
+			output, success = toolListTasks(argsMap, a.tasks)
+		case "get_task":
+			output, success = toolGetTask(argsMap, a.tasks)
+		default:
 			output, success = ExecuteTool(tc.Function.Name, tc.Function.Arguments, a.workDir)
 		}
 

app.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	"os"
+	"time"
 
 	tea "github.com/charmbracelet/bubbletea"
 )
@@ -48,6 +49,7 @@ func (m appModel) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
 	// Global key handling
 	if keyMsg, ok := msg.(tea.KeyMsg); ok {
 		if keyMsg.String() == "ctrl+c" && m.screen == screenBoot {
+			m.boot.audio.Stop()
 			return m, tea.Quit
 		}
 	}
@@ -93,3 +95,32 @@ func (m appModel) View() string {
 	}
 	return ""
 }
+
+// Cleanup gracefully shuts down background goroutines and processes.
+// Called from main.go's defer chain before terminal restoration.
+func (m *appModel) Cleanup() {
+	// Stop boot audio if still playing
+	m.boot.audio.Stop()
+
+	// Signal agent to stop
+	if m.chat.stopCh != nil {
+		select {
+		case <-m.chat.stopCh:
+		default:
+			close(m.chat.stopCh)
+		}
+	}
+
+	// Wait briefly for agent goroutine to finish
+	if m.chat.agentDone != nil {
+		select {
+		case <-m.chat.agentDone:
+		case <-time.After(2 * time.Second):
+		}
+	}
+
+	// Stop chime audio
+	if m.chat.chimePlayer != nil {
+		m.chat.chimePlayer.Stop()
+	}
+}

audio.go

@@ -433,19 +433,21 @@ var chimePattern = []patternRow{
 	{"G-5", "C-5", "---", "---"},
 }
 
-// PlayChime plays a short success chime (~0.3 seconds).
-// Runs in the background. Respects CODEBASE_NOBOOT / CODEBASE_NOSOUND env vars.
-func PlayChime() {
+// PlayChimeAsync plays a short success chime (~0.3 seconds) in the background.
+// Returns the AudioPlayer so the caller can call Stop() for cleanup.
+// Returns nil if audio is disabled or unavailable.
+func PlayChimeAsync() *AudioPlayer {
 	if os.Getenv("CODEBASE_NOBOOT") != "" || os.Getenv("CODEBASE_NOSOUND") != "" {
-		return
+		return nil
 	}
 
 	player := tryChimePlayer()
 	if player == nil {
-		return
+		return nil
 	}
 
 	go func() {
+		defer close(player.done)
 		synth := &chipSynth{
 			pattern: chimePattern,
 			lead:    channel{envDecay: 0.9995},
@@ -477,6 +479,8 @@ func PlayChime() {
 		player.writer.Close()
 		player.cmd.Wait()
 	}()
+
+	return player
 }
 
 // tryChimePlayer creates a raw PCM audio pipe for the chime.

boot.go

@@ -195,19 +195,30 @@ func buildBootSteps(cfg *Config) []bootStep {
 		{label: "config", value: "loaded"},
 		{label: "provider", value: cfg.Model},
 		{label: "workspace", value: fmt.Sprintf("%s (%d files)", workDisplay, fileCount)},
+		{label: "terminal", value: TerminalName()},
 		{label: "status", value: "ready"},
 	}
 }
 
 // ── Bubble Tea ───────────────────────────────────────────────
 
+// demoFPS returns the frame interval for the boot animation.
+// Throttled in VS Code/Cursor to prevent PTY flooding that affects other terminals.
+func demoFPS() time.Duration {
+	if termInfo.IsVSCode || termInfo.IsCursor {
+		return 120 * time.Millisecond // ~8fps — gentle on VS Code's terminal handler
+	}
+	return 50 * time.Millisecond // ~20fps — full speed in standalone terminals
+}
+
 func (m bootModel) Init() tea.Cmd {
+	fps := demoFPS()
 	return tea.Batch(
 		func() tea.Msg {
 			// Start boot music in background (nil if no audio device)
 			return bootAudioMsg{player: StartBootMusic()}
 		},
-		tea.Tick(50*time.Millisecond, func(t time.Time) tea.Msg { return demoTickMsg(t) }),
+		tea.Tick(fps, func(t time.Time) tea.Msg { return demoTickMsg(t) }),
 		// First boot step after 4 seconds (drawn-out demo intro)
 		tea.Tick(4*time.Second, func(t time.Time) tea.Msg { return bootTickMsg{} }),
 	)
@@ -224,7 +235,7 @@ func (m bootModel) Update(msg tea.Msg) (bootModel, tea.Cmd) {
 
 	case demoTickMsg:
 		m.frame++
-		return m, tea.Tick(50*time.Millisecond, func(t time.Time) tea.Msg { return demoTickMsg(t) })
+		return m, tea.Tick(demoFPS(), func(t time.Time) tea.Msg { return demoTickMsg(t) })
 
 	case bootTickMsg:
 		if m.current < len(m.steps) {
@@ -522,7 +533,10 @@ func (m bootModel) renderLogo(px []rgb, w, h, ox, oy, scale int, t, reveal float
 				}
 			}
 
-			// Glow
+			// Glow (skip in VS Code to reduce ANSI output volume)
+			if termInfo.IsVSCode || termInfo.IsCursor {
+				continue
+			}
 			for dy := -glowR; dy <= scale+glowR; dy++ {
 				for dx := -glowR; dx <= scale+glowR; dx++ {
 					x := ox + lx*scale + dx

boot_test.go

@@ -37,7 +37,7 @@ func TestBootStepAdvancement(t *testing.T) {
 	m := newBootModel(testBootConfig())
 	m, _ = m.Update(tea.WindowSizeMsg{Width: 80, Height: 24})
 
-	for i := 0; i < 4; i++ {
+	for i := 0; i < len(m.steps); i++ {
 		m, _ = m.Update(bootTickMsg{})
 		if !m.steps[i].done {
 			t.Errorf("step %d not done after tick", i)