root/fusion
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

FN-8100: restore PostgreSQL task delegation collision coverage

Browse Source 
Restore PostgreSQL-backed collision coverage for the built task-delegation extension.

- Seed an occupied task ID through the shared PostgreSQL TaskStore.
- Override the allocator once to exercise the real unique-violation error path.
- Assert that fn_delegate_task returns the structured task-ID collision error.

Files changed:
 .../src/__tests__/extension-integration.test.ts    | 53 +++++++++++++---------
 1 file changed, 32 insertions(+), 21 deletions(-)

Fusion-Task-Id: FN-8100

Fusion-Task-Lineage: d26b825e-2abd-482e-899e-51c0db753176

Co-authored-by: Fusion (runfusion.ai) <noreply@runfusion.ai>
This commit is contained in:
gsxdsm
2026-07-16 09:24:56 -07:00
parent fcd400f02e
commit c803a2d906
1 changed files with 30 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
packages/cli/src/__tests__/extension-integration.test.ts
View File

@@ -280,29 +280,40 @@ pgDescribe.skipIf(!SHOULD_RUN_EXTENSION_INTEGRATION)("built fn pi extension inte
});
/*
* FNXC:PostgresCutover 2026-07-16-16:00:
* SQLite triggers were removed with the backend cutover. Inject the collision
* at the shared PostgreSQL TaskStore boundary so this built-extension test
* continues to prove the user-facing delegate error rather than skipping it.
* FNXC:CliTests 2026-07-16-09:00:
* FN-8100 restores built `fn_delegate_task` collision coverage after SQLite
* trigger support was removed. Re-issue an occupied id through the injected
* PostgreSQL store's allocator so the real insert translates unique_violation
* into the structured task-id collision error.
*/
it("returns explicit error when fn_delegate_task hits task-id collision", async () => {
const store = h.store();
const agent = await seedAgent(tmpDir, h.layer(), { name: "release-agent" });
const createTask = vi
.spyOn(h.store(), "createTask")
.mockRejectedValueOnce(new Error("Task ID already exists: FN-001"));
const existing = await store.createTask({ description: "occupied", column: "todo" });
const realAllocator = store.getDistributedTaskIdAllocator();
const allocatorSpy = vi.spyOn(store, "getDistributedTaskIdAllocator").mockReturnValue({
...realAllocator,
reserveDistributedTaskId: async (input) => {
const reservation = await realAllocator.reserveDistributedTaskId(input);
return { ...reservation, taskId: existing.id };
},
});
const delegateTool = api.tools.get("fn_delegate_task")!;
const result = await delegateTool.execute(
"delegate-collision",
{ agent_id: agent.id, description: "collision task" },
undefined,
undefined,
makeCtx(tmpDir),
);
try {
const delegateTool = api.tools.get("fn_delegate_task")!;
const result = await delegateTool.execute(
"delegate-collision",
{ agent_id: agent.id, description: "collision task" },
undefined,
undefined,
makeCtx(tmpDir),
);
expect(createTask).toHaveBeenCalledTimes(1);
expect(result.isError).toBe(true);
expect(result.content[0].text).toContain("Task ID already exists: FN-001");
expect(result.details.error).toContain("Task ID already exists: FN-001");
expect(result.isError).toBe(true);
expect(result.content[0].text).toContain(`Task ID already exists: ${existing.id}`);
expect(result.details.error).toContain(`Task ID already exists: ${existing.id}`);
} finally {
allocatorSpy.mockRestore();
}
});
});