Function TestReasoningChunksAreEmitted

internal/llm/llm_test.go:595–632

TestReasoningChunksAreEmitted: reasoning models stream chain-of-thought in `delta.reasoning`. The decoder must surface these as EventReasoning (else the UI freezes for the whole reasoning phase) and must NOT fold them into the assistant content: reasoning has no business in history.

(t *testing.T)

		t.Fatalf("error should include status and message: %v", evs[0].Err)
	}
	if strings.Contains(evs[0].Err.Error(), `{"error"`) {
		t.Fatalf("raw envelope JSON must not leak through to the user: %v", evs[0].Err)
	}
}

// TestReasoningChunksAreEmitted: reasoning models stream chain-of-thought in
// `delta.reasoning`. The decoder must surface these as EventReasoning (else the
// UI freezes for the whole reasoning phase) and must NOT fold them into the
// assistant content: reasoning has no business in history.
func TestReasoningChunksAreEmitted(t *testing.T) {
	chunks := []string{
		`{"choices":[{"delta":{"reasoning":"Hmm"},"finish_reason":null}]}`,
		`{"choices":[{"delta":{"reasoning":" OK"},"finish_reason":null}]}`,
		`{"choices":[{"delta":{"content":"hi"},"finish_reason":null}]}`,
		`{"choices":[{"delta":{},"finish_reason":"stop"}],"usage":{"completion_tokens":3}}`,
	}
	srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		sseOK(w, chunks)
	}))
	defer srv.Close()

	evs := collect(New(srv.URL, "m", "").Chat(context.Background(), nil, nil))
	var reasoning, content string
	var done Event
	for _, e := range evs {
		switch e.Kind {
		case EventReasoning:
			reasoning += e.Content
		case EventContent:
			content += e.Content
		case EventDone:
			done = e
		}
	}
	if reasoning != "Hmm OK" {
		t.Fatalf("want reasoning %q, got %q", "Hmm OK", reasoning)
	}
	if content != "hi" {
		t.Fatalf("want content %q, got %q", "hi", content)
	}
	if done.Final == nil || done.Final.Content != "hi" {