Function buildViewRunDir

pkg/cli/view_command_test.go:100–128

─── ViewWorkflowRun (local dir with pre-populated JSONL) ──────────────────── buildViewRunDir creates a temporary run directory populated with synthetic JSONL files so that ViewWorkflowRun can read them without network access.

(t *testing.T)

// buildViewRunDir creates a temporary run directory populated with synthetic
// JSONL files so that ViewWorkflowRun can read them without network access.
func buildViewRunDir(t *testing.T) string {
	t.Helper()
	dir := t.TempDir()
	runDir := filepath.Join(dir, "run-9999")
	if err := os.MkdirAll(runDir, 0755); err != nil {
		t.Fatalf("MkdirAll: %v", err)
	}

	// Write a minimal events.jsonl so the agent timeline source is populated.
	// Include content in user/assistant/reasoning messages to test snippet rendering.
	// Use distinct timestamps to guarantee deterministic sort order in BuildUnifiedTimeline.
	base := time.Now().UTC().Add(-time.Minute)
	timestampAt := func(offset time.Duration) string { return base.Add(offset).Format(time.RFC3339Nano) }
	eventsContent := strings.Join([]string{
		`{"type":"user.message","id":"id1","timestamp":"` + timestampAt(0) + `","data":{"content":"What files are in the repo?"}}`,
		`{"type":"tool.execution_start","id":"id2","timestamp":"` + timestampAt(10*time.Millisecond) + `","data":{"toolCallId":"c1","toolName":"search","mcpServerName":"github"}}`,
		`{"type":"tool.execution_complete","id":"id3","timestamp":"` + timestampAt(20*time.Millisecond) + `","data":{"toolCallId":"c1","toolName":"search","mcpServerName":"github","success":true}}`,
		`{"type":"assistant.message","id":"id4","timestamp":"` + timestampAt(30*time.Millisecond) + `","data":{"content":"I found the following files in the repo."}}`,
		`{"type":"reasoning","id":"id5","timestamp":"` + timestampAt(40*time.Millisecond) + `","data":{"content":"The user wants a list of files."}}`,
	}, "\n") + "\n"
	if err := os.WriteFile(filepath.Join(runDir, "events.jsonl"), []byte(eventsContent), 0600); err != nil {
		t.Fatalf("WriteFile events.jsonl: %v", err)
	}

	// Mark the directory as already downloaded so downloadRunArtifacts skips
	// network calls (it returns early when the dir is non-empty and has no cached
	// summary — it just skips the download and lets the caller process what's there).
	return dir
}

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