import {

cancelTaskById,

createTaskRecord as createTaskRecordOrNull,

findLatestTaskForOwnerKey,

findLatestTaskForRelatedSessionKey,

findTaskByRunId,

getTaskById,

getTaskRegistrySummary,

isParentFlowLinkError,

listTasksForAgentId,

listTasksForOwnerKey,

sweepTaskRegistry,

} from "./task-registry.maintenance.js";

import { configureTaskRegistryRuntime } from "./task-registry.store.js";

import { summarizeTaskRecords } from "./task-registry.summary.js";

import type { TaskDeliveryState, TaskRecord } from "./task-registry.types.js";

const DEFAULT_TASK_RETENTION_MS = 7 * 24 * 60 * 60_000;

deliveryStatus: "session_queued",

});

expect(getTaskRegistrySummary()).toEqual({

expect(summarizeTaskRecords(listTaskRecords())).toEqual({

total: 3,

active: 2,

terminal: 1,

});

nowSpy.mockRestore();

expect(findLatestTaskForOwnerKey("agent:main:main")?.taskId).toBe(latest.taskId);

expect(listTasksForOwnerKey("agent:main:main")[0]?.taskId).toBe(latest.taskId);

expect(listTasksForOwnerKey("agent:main:main").map((task) => task.taskId)).toEqual([

latest.taskId,

older.taskId,

startedAt: now - 60_000,

lastEventAt: now - 60_000,

});

expect(getTaskRegistrySummary().active).toBe(1);

expect(summarizeTaskRecords(listTaskRecords()).active).toBe(1);

durableTasks = new Map([

[

taskId: "task-durable",

status: "cancelled",

});

expect(getTaskRegistrySummary().active).toBe(0);

expect(summarizeTaskRecords(listTaskRecords()).active).toBe(0);

});

});