Function TestStaleToolResultDoesNotEnterLiveHistory

internal/tui/tui_test.go:2642–2674

TestStaleToolResultDoesNotEnterLiveHistory: a bash result from cancelled turn N must not append to turn N+1's history (its unmatched tool_call_id would 400 the next /v1 request) and must not steal the live stream via startChat.

(t *testing.T)

	m.sessionTokens = 50

	out, _ := m.Update(streamEventMsg{ch: stale, e: llm.Event{Kind: llm.EventContent, Content: "ghost"}})
	om := out.(Model)
	if om.streaming.Len() != 0 {
		t.Fatalf("stale content event leaked into live turn's streaming buffer: %q", om.streaming.String())
	}
	if om.sessionTokens != 50 {
		t.Fatalf("stale event credited tokens to live session: %d", om.sessionTokens)
	}
	if om.stream != live {
		t.Fatal("stale event must not overwrite live m.stream")
	}
}

// TestStaleStreamCloseDoesNotKillLiveTurn: the prior turn's channel closing
// after a fresh submit must NOT run handleStreamClosed against the live turn.
// Doing so would (a) nil out m.stream, breaking the live read loop, and
// (b) finalizeTurn + endTurn the current request out from under the user.
func TestStaleStreamCloseDoesNotKillLiveTurn(t *testing.T) {
	m := newTestModel(t, func(http.ResponseWriter, *http.Request) {})
	stale := make(chan llm.Event)
	live := make(chan llm.Event, 1)
	ctx, cancel := context.WithCancel(context.Background())
	t.Cleanup(cancel)
	m.turnCtx = ctx
	m.cancel = cancel
	m.stream = live
	m.phase = phaseStreaming

	out, _ := m.Update(streamClosedMsg{ch: stale})
	om := out.(Model)
	if om.stream != live {
		t.Fatal("stale close must not overwrite m.stream - live read loop would die")
	}
	if !om.phase.active() {
		t.Fatalf("stale close finalised the live turn - phase is now %v", om.phase)
	}