Function TestManagerDeleteTask

internal/task/manager_test.go:2844–3039

(t *testing.T)

}

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

	buildTask := func(id string, actor ActorContext) Task {
		now := time.Date(2026, 4, 14, 15, 0, 0, 0, time.UTC)
		return Task{
			ID:             id,
			Scope:          ScopeGlobal,
			Title:          id,
			Priority:       DefaultPriority,
			MaxAttempts:    1,
			Status:         TaskStatusReady,
			ApprovalPolicy: ApprovalPolicyNone,
			ApprovalState:  ApprovalStateNotRequired,
			CreatedBy:      actor.Actor,
			Origin:         actor.Origin,
			CreatedAt:      now,
			UpdatedAt:      now,
		}
	}

	t.Run("ShouldRemoveAllActorTriageStateEntriesForTheDeletedTask", func(t *testing.T) {
		t.Parallel()

		actor := validActorContext()
		store := newDeleteTaskStore()
		manager := newTaskManagerForTest(t, store)
		record := buildTask("task-delete", actor)
		now := time.Date(2026, 4, 14, 16, 0, 0, 0, time.UTC)

		if err := store.CreateTask(context.Background(), record); err != nil {
			t.Fatalf("CreateTask() error = %v", err)
		}
		if err := store.UpsertTaskTriageState(context.Background(), TriageState{
			TaskID:             record.ID,
			Actor:              actor.Actor,
			Read:               true,
			LastSeenActivityAt: now,
			UpdatedAt:          now,
		}); err != nil {
			t.Fatalf("UpsertTaskTriageState(primary actor) error = %v", err)
		}
		if err := store.UpsertTaskTriageState(context.Background(), TriageState{
			TaskID: record.ID,
			Actor: ActorIdentity{
				Kind: ActorKindHuman,
				Ref:  "user-2",
			},
			Archived:           true,
			LastSeenActivityAt: now,
			UpdatedAt:          now,
		}); err != nil {
			t.Fatalf("UpsertTaskTriageState(second actor) error = %v", err)
		}

		if err := manager.DeleteTask(context.Background(), record.ID, actor); err != nil {
			t.Fatalf("DeleteTask() error = %v", err)
		}