Function TestTaskRunCommandsMapLifecycleRequests

internal/cli/task_test.go:772–1088

(t *testing.T)

}

func TestTaskRunCommandsMapLifecycleRequests(t *testing.T) {
	t.Parallel()

	tests := []struct {
		name string
		run  func(t *testing.T)
	}{
		{
			name: "Should parse task run list filters",
			run: func(t *testing.T) {
				t.Helper()

				var runListQuery TaskRunListQuery
				deps := newTestDeps(t, &stubClient{
					listTaskRunsFn: func(_ context.Context, _ string, query TaskRunListQuery) ([]TaskRunRecord, error) {
						runListQuery = query
						return []TaskRunRecord{sampleTaskRunRecord(taskpkg.TaskRunStatusRunning)}, nil
					},
				})

				if _, _, err := executeRootCommand(
					t,
					deps,
					"task",
					"run",
					"list",
					"task-1",
					"--status",
					"running",
					"--session",
					"sess-1",
					"--last",
					"2",
					"-o",
					"json",
				); err != nil {
					t.Fatalf("task run list error = %v", err)
				}
				if runListQuery.Status != taskpkg.TaskRunStatusRunning || runListQuery.SessionID != "sess-1" ||
					runListQuery.Limit != 2 {
					t.Fatalf("runListQuery = %#v, want parsed run filters", runListQuery)
				}
			},
		},
		{
			name: "Should show task run",
			run: func(t *testing.T) {
				t.Helper()

				var gotID string
				deps := newTestDeps(t, &stubClient{
					getTaskRunFn: func(_ context.Context, id string) (TaskRunDetailRecord, error) {
						gotID = id
						return sampleTaskRunDetailRecord(taskpkg.TaskRunStatusQueued), nil
					},
				})

				stdout, _, err := executeRootCommand(t, deps, "task", "run", "show", "run-1", "-o", "json")