feat: watch dispatched session

Makefile

@@ -1,4 +1,8 @@
-.PHONY: build install clean lint test
+.PHONY: build install clean lint test hooks
+
+hooks:
+	git config core.hooksPath .githooks
+	@chmod +x .githooks/pre-commit
 
 build:
 	go build -o bin/td .

README.md

@@ -327,7 +327,16 @@ Dispatch profiles:
 | MCP (`notion`, `linear`, …) | `generic_workspace` | MCP-focused prompt; deliverable in the external tool |
 | `generic` | `generic_workspace` | Files, research, bootstraps — no required MCP |
 
-The confirmation panel shows the target and path. Press `Enter` to launch headless `claude` (stream-json log under `~/.config/td/trackers/`). The task tag updates to `@dispatched`. Press `r` to resume in iTerm2.
+The confirmation panel shows the target and path. Press `Enter` to launch headless `claude` (stream-json log on disk; path below). The task tag updates to `@dispatched`.
+
+While a session is running:
+
+- **`w`** — watch the live stream-json log in the TUI (does not interrupt the agent)
+- **`r`** — resume in iTerm2 (kills the headless process; requires **two presses** while status is `running`)
+
+Open the sessions sidebar with **`h`** for the same shortcuts plus **`L`** (open raw log in your editor).
+
+Tracker logs live under `$(go env USERCONFIGDIR)/td/trackers/` on macOS that is `~/Library/Application Support/td/trackers/`.
 
 The dispatch flow requires:
 - At least one `[[repos]]`, `[[mcp]]`, or use of `generic` routing

internal/ai/client.go

@@ -71,7 +71,7 @@ func (c *Client) Complete(system, prompt string) (string, error) {
 	if err != nil {
 		return "", fmt.Errorf("request failed: %w", err)
 	}
-	defer resp.Body.Close()
+	defer func() { _ = resp.Body.Close() }()
 
 	respBody, err := io.ReadAll(resp.Body)
 	if err != nil {

internal/ai/router.go

@@ -83,11 +83,7 @@ func (c *Client) Route(taskText string, repos []config.Repo, mcps []config.MCP)
 
 	var route RouteResult
 	if err := json.Unmarshal([]byte(result), &route); err != nil {
-		// Fallback: treat raw text as a repo name (backward compat)
-		if strings.EqualFold(result, "generic") {
-			return &RouteResult{Generic: true, Actionable: true}, nil
-		}
-		return &RouteResult{Repo: result, Actionable: true}, nil
+		return &RouteResult{Actionable: false, Missing: "routing response was not valid JSON"}, nil
 	}
 
 	// Normalise: a literal "generic" repo name is the generic workspace.

internal/config/config.go

@@ -165,10 +165,10 @@ func AppendRepos(repos []Repo) error {
 	if err != nil {
 		return err
 	}
-	defer f.Close()
+	defer func() { _ = f.Close() }()
 
 	for _, r := range repos {
-		fmt.Fprintf(f, "\n[[repos]]\nname = %q\npath = %q\ndescription = %q\n", r.Name, r.Path, r.Description)
+		_, _ = fmt.Fprintf(f, "\n[[repos]]\nname = %q\npath = %q\ndescription = %q\n", r.Name, r.Path, r.Description)
 	}
 	return nil
 }

internal/scan/scan.go

@@ -26,7 +26,7 @@ func FindRepos(dir string) ([]string, error) {
 	}
 
 	var repos []string
-	filepath.WalkDir(dir, func(path string, d fs.DirEntry, err error) error {
+	if err := filepath.WalkDir(dir, func(path string, d fs.DirEntry, err error) error {
 		if err != nil {
 			return nil
 		}
@@ -42,7 +42,9 @@ func FindRepos(dir string) ([]string, error) {
 			repos = append(repos, path)
 		}
 		return nil
-	})
+	}); err != nil {
+		return nil, err
+	}
 
 	return repos, nil
 }
@@ -59,7 +61,7 @@ Output format:
 
 func DescribeRepos(paths []string, apiKey, model string) ([]Suggestion, error) {
 	var prompt strings.Builder
-	prompt.WriteString(fmt.Sprintf("Analyze these %d git repositories:\n\n", len(paths)))
+	fmt.Fprintf(&prompt, "Analyze these %d git repositories:\n\n", len(paths))
 
 	for i, p := range paths {
 		ctx := collectContext(p)
@@ -125,7 +127,7 @@ func SaveSelected(suggestions []Suggestion) error {
 
 func collectContext(repoPath string) string {
 	var ctx strings.Builder
-	ctx.WriteString(fmt.Sprintf("Path: %s\n", repoPath))
+	fmt.Fprintf(&ctx, "Path: %s\n", repoPath)
 
 	entries, err := os.ReadDir(repoPath)
 	if err == nil {
@@ -135,7 +137,7 @@ func collectContext(repoPath string) string {
 				names = append(names, e.Name())
 			}
 		}
-		ctx.WriteString(fmt.Sprintf("Files: %s\n", strings.Join(names, ", ")))
+		fmt.Fprintf(&ctx, "Files: %s\n", strings.Join(names, ", "))
 	}
 
 	for _, readme := range []string{"README.md", "readme.md", "README"} {
@@ -145,7 +147,7 @@ func collectContext(repoPath string) string {
 			if len(content) > 500 {
 				content = content[:500] + "..."
 			}
-			ctx.WriteString(fmt.Sprintf("README:\n%s\n", content))
+			fmt.Fprintf(&ctx, "README:\n%s\n", content)
 			break
 		}
 	}
@@ -157,7 +159,7 @@ func collectContext(repoPath string) string {
 			if len(content) > 300 {
 				content = content[:300] + "..."
 			}
-			ctx.WriteString(fmt.Sprintf("%s:\n%s\n", cfgFile, content))
+			fmt.Fprintf(&ctx, "%s:\n%s\n", cfgFile, content)
 			break
 		}
 	}

internal/taskfile/carry.go

@@ -66,15 +66,17 @@ func findCarriedTasks(tasksDir, todayPath string) []Task {
 func findPreviousFile(tasksDir, todayPath string) string {
 	var files []string
 
-	filepath.WalkDir(tasksDir, func(path string, d fs.DirEntry, err error) error {
+	if err := filepath.WalkDir(tasksDir, func(path string, d fs.DirEntry, err error) error {
 		if err != nil || d.IsDir() {
 			return nil
 		}
 		if strings.HasSuffix(path, ".md") && path != todayPath {
 			files = append(files, path)
 		}
 		return nil
-	})
+	}); err != nil {
+		return ""
+	}
 
 	if len(files) == 0 {
 		return ""
@@ -87,7 +89,7 @@ func findPreviousFile(tasksDir, todayPath string) string {
 func generateTemplate(date time.Time, carried []Task) string {
 	var b strings.Builder
 
-	b.WriteString(fmt.Sprintf("# %s\n", date.Format("Monday, January 2 2006")))
+	fmt.Fprintf(&b, "# %s\n", date.Format("Monday, January 2 2006"))
 
 	if len(carried) > 0 {
 		b.WriteString("\n## Carried over\n")

internal/tracker/parser.go

@@ -23,7 +23,7 @@ func (s *Store) Poll(t *Task) {
 		}
 		return
 	}
-	defer f.Close()
+	defer func() { _ = f.Close() }()
 
 	scanner := bufio.NewScanner(f)
 	scanner.Buffer(make([]byte, 512*1024), 512*1024)
@@ -53,12 +53,10 @@ func (s *Store) Poll(t *Task) {
 			t.DurationMs = ev.DurationMs
 			t.Turns = ev.NumTurns
 
-			if ev.Subtype == "success" && ev.StopReason == "end_turn" && len(ev.PermissionDenials) == 0 {
-				t.Status = StatusDone
-			} else if len(ev.PermissionDenials) > 0 {
+			if len(ev.PermissionDenials) > 0 {
 				t.Status = StatusNeedsInput
 				t.Error = "permission denied: " + ev.PermissionDenials[0]
-			} else if ev.Subtype != "success" {
+			} else if ev.Subtype != "success" && ev.Subtype != "" {
 				t.Status = StatusFailed
 				t.Error = ev.Subtype
 			} else {
@@ -86,7 +84,7 @@ func parseToolUse(ev *event, t *Task) {
 }
 
 func extractDetail(tool string, input json.RawMessage) string {
-	var m map[string]interface{}
+	var m map[string]any
 	if json.Unmarshal(input, &m) != nil {
 		return ""
 	}

internal/tracker/store.go

@@ -7,10 +7,12 @@ import (
 	"os"
 	"path/filepath"
 	"sort"
+	"sync"
 	"syscall"
 )
 
 type Store struct {
+	mu  sync.Mutex
 	dir string
 }
 
@@ -65,6 +67,8 @@ func (s *Store) save(st *state) error {
 }
 
 func (s *Store) Register(t *Task) error {
+	s.mu.Lock()
+	defer s.mu.Unlock()
 	st := s.load()
 	st.Tasks[t.ID] = t
 	return s.save(st)
@@ -75,11 +79,15 @@ func (s *Store) Update(t *Task) error {
 }
 
 func (s *Store) Get(id string) *Task {
+	s.mu.Lock()
+	defer s.mu.Unlock()
 	st := s.load()
 	return st.Tasks[id]
 }
 
 func (s *Store) ActiveTasks() []*Task {
+	s.mu.Lock()
+	defer s.mu.Unlock()
 	st := s.load()
 	var active []*Task
 	for _, t := range st.Tasks {
@@ -91,12 +99,16 @@ func (s *Store) ActiveTasks() []*Task {
 }
 
 func (s *Store) AllTasks() map[string]*Task {
+	s.mu.Lock()
+	defer s.mu.Unlock()
 	return s.load().Tasks
 }
 
 // ListRecent returns tasks sorted by StartedAt (newest first), capped at limit.
 // limit <= 0 means no cap.
 func (s *Store) ListRecent(limit int) []*Task {
+	s.mu.Lock()
+	defer s.mu.Unlock()
 	st := s.load()
 	all := make([]*Task, 0, len(st.Tasks))
 	for _, t := range st.Tasks {
@@ -113,9 +125,11 @@ func (s *Store) ListRecent(limit int) []*Task {
 
 // Remove deletes a tracker and its log file.
 func (s *Store) Remove(id string) error {
+	s.mu.Lock()
+	defer s.mu.Unlock()
 	st := s.load()
 	delete(st.Tasks, id)
-	os.Remove(s.LogPath(id))
+	_ = os.Remove(s.LogPath(id))
 	return s.save(st)
 }