},

};

let pullCount = 0;

let idlePullStarted = false;

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

const fullConfig = { models: { providers: {} } } as never;

const sessionStore: Record<string, unknown> = {};

const runtime = {

if (pullCount === 1) {

return { bridgeId: "bridge-1", base64: Buffer.from([9, 8, 7]).toString("base64") };

}

await new Promise((resolve) => setTimeout(resolve, 10));

idlePullStarted = true;

await new Promise<void>((resolve) => {

releaseIdlePull = resolve;

});

return { bridgeId: "bridge-1" };

}

releaseIdlePull?.();

releaseIdlePull = undefined;

return { ok: true };

}),

},

}

expect(talkEvents[0]?.sessionId).toBe("google-meet:meet-1:bridge-1:node-realtime");

await vi.waitFor(() => {

expect(idlePullStarted).toBe(true);

});

await handle.stop();

expect(bridge.close).toHaveBeenCalled();

createBridge: () => bridge,

};

let pullCount = 0;

let idlePullStarted = false;

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

const runtime = {

nodes: {

invoke: vi.fn(async ({ params }: { params?: { action?: string } }) => {

if (pullCount === 2) {

return { bridgeId: "bridge-1", base64: Buffer.from([5, 4, 3]).toString("base64") };

}

await new Promise((resolve) => setTimeout(resolve, 10));

idlePullStarted = true;

await new Promise<void>((resolve) => {

releaseIdlePull = resolve;

});

return { bridgeId: "bridge-1" };

}

releaseIdlePull?.();

releaseIdlePull = undefined;

return { ok: true };

}),

},

expect(health.lastInputBytes).toBe(3);

expect(health.consecutiveInputErrors).toBe(0);

await vi.waitFor(() => {

expect(idlePullStarted).toBe(true);

});

await handle.stop();

});