Function TestQueueAutoFireUnitFromStreamClosed

internal/tui/queue_test.go:343–370

TestQueueAutoFireUnitFromStreamClosed: a clean, trivial finish with a prompt queued must submit it from handleStreamClosed: phase back to thinking, a chat Cmd returned, the queued user message appended, and the slot cleared.

(t *testing.T)

// TestQueueAutoFireUnitFromStreamClosed: a clean, trivial finish with a prompt
// queued must submit it from handleStreamClosed: phase back to thinking, a chat
// Cmd returned, the queued user message appended, and the slot cleared.
func TestQueueAutoFireUnitFromStreamClosed(t *testing.T) {
	m := newTestModel(t, func(http.ResponseWriter, *http.Request) {})
	m.installTurnContext()
	m.phase = phaseStreaming
	m.stream = make(chan llm.Event) // non-nil so handleStreamClosed proceeds
	m.history = []chmctx.Message{
		{Role: chmctx.RoleUser, Content: "first"},
		{Role: chmctx.RoleAssistant, Content: "done"},
	}
	m.queued = &queuedPrompt{send: "next task", echo: "next task"}

	out, cmd := m.handleStreamClosed()
	om := out.(Model)

	if cmd == nil {
		t.Fatal("a queued prompt must start the next turn (non-nil Cmd)")
	}
	if om.phase != phaseThinking {
		t.Fatalf("auto-fire must begin a new turn (thinking), got %v", om.phase)
	}
	if om.queued != nil {
		t.Fatalf("slot must clear on auto-fire, got %+v", om.queued)
	}
	last := om.history[len(om.history)-1]
	if last.Role != chmctx.RoleUser || last.Content != "next task" {
		t.Fatalf("auto-fire must append the queued user message, got %+v", last)
	}
}