seen.push(evt.runId);

});

expect(() =>

expect(

emitAgentEvent({

runId: "run-safe",

stream: "assistant",

data: { text: "hi" },

}),

).not.toThrow();

).toBeUndefined();

stopGood();

stopBad();

const scoped = createTaskScopedChannelRuntime({});

expect(scoped.channelRuntime).toBeUndefined();

expect(() => scoped.dispose()).not.toThrow();

expect(scoped.dispose()).toBeUndefined();

});

it("disposes only task-scoped registrations", () => {

},

});

if (params.expected === "allow") {

expect(run).not.toThrow();

expect(run()).toBeUndefined();

return;

}

expect(run).toThrow(params.expected);

it("supports idempotent remote node removal", () => {

const nodeId = `node-${randomUUID()}`;

expect(() => {

removeRemoteNodeInfo(nodeId);

removeRemoteNodeInfo(nodeId);

}).not.toThrow();

expect(removeRemoteNodeInfo(nodeId)).toBeUndefined();

expect(removeRemoteNodeInfo(nodeId)).toBeUndefined();

});

it("bumps the skills snapshot version when an eligible remote node disconnects", async () => {

},

});

expect(() => module.listChannelCatalogEntries({ env: ENV })).not.toThrow();

expect(module.listChannelCatalogEntries({ env: ENV })).toEqual([]);

expect(loadRecordsSpy).toHaveBeenCalledTimes(1);

expect(discoverSpy).toHaveBeenCalledTimes(1);

return realSymlinkSync(String(target), linkPath, type);

}) as typeof fs.symlinkSync);

expect(() => stageBundledPluginRuntime({ repoRoot })).not.toThrow();

stageBundledPluginRuntime({ repoRoot });

const runtimeAssetPath = path.join(

repoRoot,