Function TestViewWorkflowRun_LocalCache_NoError

pkg/cli/view_command_test.go:130–183

(t *testing.T)

}

func TestViewWorkflowRun_LocalCache_NoError(t *testing.T) {
	logsDir := buildViewRunDir(t)

	opts := ViewOptions{
		OutputDir: logsDir,
		Verbose:   false,
	}
	// Capture stdout so we can assert on the rendered timeline output.
	origStdout := os.Stdout
	r, w, err := os.Pipe()
	if err != nil {
		t.Fatalf("os.Pipe: %v", err)
	}
	os.Stdout = w

	runErr := ViewWorkflowRun(context.Background(), 9999, opts)

	// Restore stdout and read captured output.
	w.Close()
	os.Stdout = origStdout
	outBytes, readErr := io.ReadAll(r)
	if readErr != nil {
		t.Fatalf("reading captured output: %v", readErr)
	}
	output := string(outBytes)

	if runErr != nil {
		t.Errorf("ViewWorkflowRun returned unexpected error: %v", runErr)
	}

	// Verify that renderUnifiedTimelineStream produced streaming output:
	// agent turns as "> Turn N [time]" headers, tool events with icons, no stats or table.
	for _, want := range []string{"> Turn 1", "github/search"} {
		if !strings.Contains(output, want) {
			t.Errorf("output missing %q; got:\n%s", want, output)
		}
	}
	// Verify user/assistant/reasoning message content snippets are rendered.
	for _, want := range []string{
		"What files are in the repo?",
		"I found the following files in the repo.",
		"The user wants a list of files.",
	} {
		if !strings.Contains(output, want) {
			t.Errorf("output missing message snippet %q; got:\n%s", want, output)
		}
	}
	// Confirm there are no stats or table headers in the stream output.
	for _, notWant := range []string{"Total Events", "Event Timeline", "Gateway", "Firewall"} {
		if strings.Contains(output, notWant) {
			t.Errorf("stream output should not contain %q; got:\n%s", notWant, output)
		}
	}
}

func TestViewWorkflowRun_WithOwnerRepo_ShowsRunURL(t *testing.T) {
	logsDir := buildViewRunDir(t)