Function TestManagerClearAndListTaskBlocks

internal/task/manager_test.go:4803–4907

(t *testing.T)

}

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

	store := newInMemoryManagerStore()
	manager := newTaskManagerForTest(t, store)
	actor := validActorContext()
	target, err := manager.CreateTask(context.Background(), CreateTask{
		Scope:       ScopeWorkspace,
		WorkspaceID: "ws-block-list-target",
		Title:       "Block list target",
	}, actor)
	if err != nil {
		t.Fatalf("CreateTask(target) error = %v", err)
	}
	other, err := manager.CreateTask(context.Background(), CreateTask{
		Scope:       ScopeWorkspace,
		WorkspaceID: "ws-block-list-other",
		Title:       "Other workspace task",
	}, actor)
	if err != nil {
		t.Fatalf("CreateTask(other) error = %v", err)
	}

	openBlock, err := manager.BlockTask(context.Background(), BlockRequest{
		TaskID: target.ID,
		Kind:   BlockKindNeedsInput,
		Reason: "creator input required",
	}, actor)
	if err != nil {
		t.Fatalf("BlockTask(open) error = %v", err)
	}
	clearable, err := manager.BlockTask(context.Background(), BlockRequest{
		TaskID: target.ID,
		Kind:   BlockKindCapability,
		Reason: "missing connector",
	}, actor)
	if err != nil {
		t.Fatalf("BlockTask(clearable) error = %v", err)
	}
	if _, err := manager.BlockTask(context.Background(), BlockRequest{
		TaskID: other.ID,
		Kind:   BlockKindNeedsInput,
		Reason: "other workspace block",
	}, actor); err != nil {
		t.Fatalf("BlockTask(other) error = %v", err)
	}

	cleared, err := manager.ClearTaskBlock(
		context.Background(),
		target.ID,
		clearable.ID,
		"connector restored",
		actor,
	)
	if err != nil {
		t.Fatalf("ClearTaskBlock() error = %v", err)
	}
	if cleared.ClearedAt.IsZero() {