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

feat(FN-4296): complete Step 5 — finalize sync wiring and verification fixes

Browse Source 
Fusion-Task-Id: FN-4296
Fusion-Task-Lineage: 9d061861-547a-4905-8fdd-4b66dd7bff97
This commit is contained in:
Fusion
2026-05-14 05:33:12 -07:00
committed by gsxdsm
parent 300e023e2c
commit b5b7ca9b09
5 changed files with 12 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
packages/engine/src/__tests__/self-healing-agent-link-drift.test.ts
View File

@@ -2,7 +2,7 @@ import { describe, expect, it, vi } from "vitest";
import { isEphemeralAgent, type Agent, type AgentStore, type Task } from "@fusion/core";
import { SelfHealingManager } from "../self-healing";
import { SelfHealingManager } from "../self-healing.js";
function makeAgent(id: string, taskId: string, state: Agent["state"] = "active"): Agent {
return { id, state, taskId, updatedAt: new Date(Date.now() - 120_000).toISOString() } as Agent;

2
packages/engine/src/__tests__/task-agent-sync.test.ts
View File

@@ -6,7 +6,7 @@ import { join } from "node:path";
import { AgentStore, type AgentCreateInput, type Task } from "@fusion/core";
import { describe, expect, it, vi } from "vitest";
import { attachAgentLinkSync } from "../task-agent-sync";
import { attachAgentLinkSync } from "../task-agent-sync.js";
class EventedStore extends EventEmitter {
on(event: "task:moved", listener: (data: { task: Task; from: string; to: string }) => void): this {

8
packages/engine/src/runtimes/__tests__/in-process-runtime.test.ts
View File

@@ -484,10 +484,10 @@ describe("InProcessRuntime", () => {
const moveData = { task: mockTask, from: "todo", to: "in-progress" };
const onCalls = (taskStore.on as ReturnType<typeof vi.fn>).mock.calls;
const taskMovedHandler = onCalls.find((call: unknown[]) => call[0] === "task:moved");
if (taskMovedHandler) {
(taskMovedHandler[1] as (data: { task: Task; from: string; to: string }) => void)(moveData);
const taskMovedHandlers = onCalls.filter((call: unknown[]) => call[0] === "task:moved");
for (const handler of taskMovedHandlers) {
(handler[1] as (data: { task: Task; from: string; to: string }) => void)(moveData);
}
expect(taskMovedSpy).toHaveBeenCalledWith(moveData);

2
packages/engine/src/runtimes/in-process-runtime.ts
View File

@@ -676,7 +676,7 @@ export class InProcessRuntime
this.stuckTaskDetector.start();
this.detachAgentLinkSync = attachAgentLinkSync({
store: this.taskStore,
agentStore: this.agentStore,
agentStore: this.agentStore!,
hasActiveAgentExecution: (agentId: string) => this.heartbeatMonitor?.getTrackedAgents().includes(agentId) ?? false,
logger: runtimeLog,
});