import { beforeEach, describe, expect, it, vi } from "vitest";

import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";

import {

__testing,

registerSessionBindingAdapter,

type SessionBindingAdapter,

type SessionBindingRecord,

} from "../../infra/outbound/session-binding-service.js";

import type { ResolvedAgentRoute } from "../../routing/resolve-route.js";

import { resolveRuntimeConversationBindingRoute } from "./binding-routing.js";

import {

ensureConfiguredBindingRouteReady,

resolveRuntimeConversationBindingRoute,

} from "./binding-routing.js";

import {

registerStatefulBindingTargetDriver,

unregisterStatefulBindingTargetDriver,

} from "./stateful-target-drivers.js";

function createRoute(): ResolvedAgentRoute {

return {

expect(result.route).toBe(route);

});

});

describe("ensureConfiguredBindingRouteReady", () => {

afterEach(() => {

vi.useRealTimers();

unregisterStatefulBindingTargetDriver("slow");

});

it("returns a bounded failure when target readiness never settles", async () => {

vi.useFakeTimers();

registerStatefulBindingTargetDriver({

id: "slow",

ensureReady: async () => await new Promise<never>(() => {}),

ensureSession: async () => ({

ok: false,

sessionKey: "agent:slow:binding",

error: "not used",

}),

});

const resultPromise = ensureConfiguredBindingRouteReady({

cfg: {} as never,

bindingResolution: { statefulTarget: { driverId: "slow" } } as never,

});

await vi.advanceTimersByTimeAsync(30_000);

await expect(resultPromise).resolves.toEqual({

ok: false,

error: "Configured binding route ready check timed out",

});

});

});