Function TestManagerCreateTaskRecordsIntentWithoutRuns

internal/task/manager_test.go:3102–3166

(t *testing.T)

}

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

	tests := []struct {
		name  string
		actor func(t *testing.T) ActorContext
		spec  CreateTask
	}{
		{
			name: "user-created ready task",
			actor: func(t *testing.T) ActorContext {
				t.Helper()
				return validActorContext()
			},
			spec: CreateTask{
				Scope: ScopeGlobal,
				Title: "User intent only",
			},
		},
		{
			name: "agent-created approval task",
			actor: func(t *testing.T) ActorContext {
				t.Helper()
				actor, err := DeriveAgentSessionActorContext("sess-agent-create")
				if err != nil {
					t.Fatalf("DeriveAgentSessionActorContext() error = %v", err)
				}
				return actor
			},
			spec: CreateTask{
				Scope:          ScopeGlobal,
				Title:          "Agent intent only",
				ApprovalPolicy: ApprovalPolicyManual,
			},
		},
	}

	for _, tc := range tests {
		t.Run(tc.name, func(t *testing.T) {
			t.Parallel()

			store := newInMemoryManagerStore()
			manager := newTaskManagerForTest(t, store)
			actor := tc.actor(t)

			created, err := manager.CreateTask(context.Background(), tc.spec, actor)
			if err != nil {
				t.Fatalf("CreateTask() error = %v", err)
			}
			runs, err := store.ListTaskRuns(context.Background(), RunQuery{TaskID: created.ID})
			if err != nil {
				t.Fatalf("ListTaskRuns() error = %v", err)
			}
			if len(runs) != 0 {
				t.Fatalf("len(runs) = %d, want 0", len(runs))
			}
			if got, want := created.CreatedBy, actor.Actor; got != want {
				t.Fatalf("created.CreatedBy = %#v, want %#v", got, want)