});

it("disposes catalog startup in-flight without leaving cached runtimes", async () => {

let notifyCatalogStarted!: () => void;

let notifyCatalogStarted: (() => void) | undefined;

const catalogStarted = new Promise<void>((resolve) => {

notifyCatalogStarted = resolve;

});

workspaceDir: params.workspaceDir,

configFingerprint: params.configFingerprint ?? "fingerprint",

getCatalog: async () => {

if (!notifyCatalogStarted) {

throw new Error("Expected bundle MCP catalog start callback to be initialized");

}

notifyCatalogStarted();

return await new Promise((_, reject) => {

rejectCatalog = reject;

describe("rotate_profile branch", () => {

it("rotates before waiting on auth profile failure marking", async () => {

const events: string[] = [];

let releaseMark!: () => void;

let releaseMark: (() => void) | undefined;

const markFinished = new Promise<void>((resolve) => {

releaseMark = resolve;

});

expect(outcome.action).toBe("retry");

expect(events).toEqual(["advance", "mark-start"]);

if (!releaseMark) {

throw new Error("Expected auth profile failure mark release callback to be initialized");

}

releaseMark();

await markSettled;

await vi.waitFor(() => expect(events).toEqual(["advance", "mark-start", "mark-finish"]));

};

const createDeferredAnnounceResolver = (): ((value: boolean) => void) => {

let resolveAnnounce!: (value: boolean) => void;

let resolveAnnounce: ((value: boolean) => void) | undefined;

announceSpy.mockImplementationOnce(

() =>

new Promise<boolean>((resolve) => {

resolveAnnounce = resolve;

}),

);

return (value: boolean) => {

if (!resolveAnnounce) {

throw new Error("Expected subagent announcement resolver to be initialized");

}

resolveAnnounce(value);

};

};

it("keeps long-running media tasks fresh while provider work is pending", async () => {

vi.useFakeTimers();

let resolveRun!: (value: string) => void;

let resolveRun: ((value: string) => void) | undefined;

const runPromise = new Promise<string>((resolve) => {

resolveRun = resolve;

});

progressSummary: "Generating video",

});

if (!resolveRun) {

throw new Error("Expected video generation run resolver to be initialized");

}

resolveRun("done");

await expect(task).resolves.toBe("done");

const callsAfterCompletion = taskExecutorMocks.recordTaskRunProgressByRunId.mock.calls.length;