Function Test_createRun

pkg/cmd/agent-task/create/create_test.go:128–543

(t *testing.T)

}

func Test_createRun(t *testing.T) {
	tmpDir := t.TempDir()
	taskDescFile := filepath.Join(tmpDir, "task-description.md")
	emptyTaskDescFile := filepath.Join(tmpDir, "empty-task-description.md")
	require.NoError(t, os.WriteFile(taskDescFile, []byte("task description from file"), 0600))
	require.NoError(t, os.WriteFile(emptyTaskDescFile, []byte("  \n\n"), 0600))

	sampleDateString := "2025-08-29T00:00:00Z"
	sampleDate, err := time.Parse(time.RFC3339, sampleDateString)
	require.NoError(t, err)

	createdJobSuccess := capi.Job{
		ID:        "job123",
		SessionID: "sess1",
		Actor: &capi.JobActor{
			ID:    1,
			Login: "octocat",
		},
		CreatedAt: sampleDate,
		UpdatedAt: sampleDate,
	}
	createdJobSuccessWithPR := capi.Job{
		ID:        "job123",
		SessionID: "sess1",
		Actor: &capi.JobActor{
			ID:    1,
			Login: "octocat",
		},
		CreatedAt: sampleDate,
		UpdatedAt: sampleDate,
		PullRequest: &capi.JobPullRequest{
			ID:     101,
			Number: 42,
		},
	}

	tests := []struct {
		name             string
		isTTY            bool
		opts             *CreateOptions // input options (IO & BackOff set later)
		capiStubs        func(*testing.T, *capi.CapiClientMock)
		logRendererStubs func(*testing.T, *shared.LogRendererMock)
		wantStdout       string
		wantStdErr       string
		wantErr          string
		wantErrIs        error
	}{
		{
			name:  "interactive, problem statement from arg",
			isTTY: true,
			opts: &CreateOptions{
				BaseRepo:         func() (ghrepo.Interface, error) { return ghrepo.New("OWNER", "REPO"), nil },
				ProblemStatement: "task description from arg",
			},
			capiStubs: func(t *testing.T, m *capi.CapiClientMock) {
				m.CreateJobFunc = func(ctx context.Context, owner, repo, problemStatement, baseBranch, customAgent string) (*capi.Job, error) {
					require.Equal(t, "OWNER", owner)
					require.Equal(t, "REPO", repo)