Function TestManagerBlockTaskServiceValidation

internal/task/manager_test.go:4551–4682

(t *testing.T)

}

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

	t.Run(
		"Should reject empty reason and unsupported kind before inserting a block",
		func(t *testing.T) {
			t.Parallel()

			tests := []struct {
				name string
				req  func(taskID string) BlockRequest
			}{
				{
					name: "empty reason",
					req: func(taskID string) BlockRequest {
						return BlockRequest{TaskID: taskID, Kind: BlockKindNeedsInput, Reason: " "}
					},
				},
				{
					name: "unsupported kind",
					req: func(taskID string) BlockRequest {
						return BlockRequest{
							TaskID: taskID,
							Kind:   BlockKind("operator"),
							Reason: "waiting",
						}
					},
				},
			}

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

					store := newInMemoryManagerStore()
					manager := newTaskManagerForTest(t, store)
					actor := validActorContext()
					taskRecord, err := manager.CreateTask(context.Background(), CreateTask{
						Scope:       ScopeWorkspace,
						WorkspaceID: "ws-block-validation-" + strings.ReplaceAll(tt.name, " ", "-"),
						Title:       "Block validation",
					}, actor)
					if err != nil {
						t.Fatalf("CreateTask() error = %v", err)
					}

					if _, err := manager.BlockTask(
						context.Background(),
						tt.req(taskRecord.ID),
						actor,
					); !errors.Is(err, ErrValidation) {
						t.Fatalf("BlockTask() error = %v, want %v", err, ErrValidation)
					}
					blocks, err := manager.ListTaskBlocks(
						context.Background(),
						taskRecord.ID,
						true,
						actor,