Function TestCmdDoFreshSpawnFailureRollsBackSessionID

internal/app/do_test.go:353–393

TestCmdDoFreshSpawnFailureRollsBackSessionID pins the rollback invariant: when a fresh-bootstrap spawn fails (e.g. Terminal.app Accessibility denied), BOTH the session_id pre-allocation AND the status flip must be undone so the next `flow do` retries bootstrap fresh. Under the session-id invariant (

(t *testing.T)

	stubPS(t,
		"  PID COMMAND\n"+
			"12345 /bin/claude --session-id "+pinnedSID+"\n"+
			"67890 /bin/claude --resume "+pinnedSID+"\n",
	)

	// iterm focus succeeds against the first match.
	oldFocusPS := iterm.PSRunner
	iterm.PSRunner = func() ([]byte, error) {
		return []byte(
			"  PID TTY      COMMAND\n" +
				"12345 ttys012  /bin/claude --session-id " + pinnedSID + "\n" +
				"67890 ttys013  /bin/claude --resume " + pinnedSID + "\n",
		), nil
	}
	t.Cleanup(func() { iterm.PSRunner = oldFocusPS })

	oldRunnerOut := iterm.RunnerOutput
	iterm.RunnerOutput = func(args []string) ([]byte, error) { return []byte("ok\n"), nil }
	t.Cleanup(func() { iterm.RunnerOutput = oldRunnerOut })

	stderr := captureStderr(t)
	count, _ := stubITerm(t)
	if rc := cmdDo([]string{"dup-task"}); rc != 0 {
		t.Errorf("cmdDo with duplicates: rc=%d, want 0 (focus should still succeed)", rc)
	}
	if *count != 0 {
		t.Errorf("iterm spawn count = %d, want 0 (focus should not spawn)", *count)
	}
	got := stderr()
	for _, want := range []string{"2 claude processes", pinnedSID, "may race"} {
		if !strings.Contains(got, want) {
			t.Errorf("warning missing %q\n--- stderr ---\n%s", want, got)
		}
	}
}

// captureStderr redirects os.Stderr through an os.Pipe for the duration
// of the test and returns a closure that drains and returns whatever
// was written. The original stderr is restored on Cleanup.
func captureStderr(t *testing.T) func() string {
	t.Helper()
	origStderr := os.Stderr
	r, w, err := os.Pipe()
	if err != nil {
		t.Fatalf("pipe: %v", err)