(_params?: unknown) => async (payload: ReplyPayload) => payload,

),

}));

const runtimePluginMocks = vi.hoisted(() => ({

ensureRuntimePluginsLoaded: vi.fn(),

}));

const threadInfoMocks = vi.hoisted(() => ({

parseSessionThreadInfo: vi.fn<

(sessionKey: string | undefined) => {

createReplyMediaPathNormalizer: (params: unknown) =>

replyMediaPathMocks.createReplyMediaPathNormalizer(params),

}));

vi.mock("../../agents/runtime-plugins.js", () => ({

ensureRuntimePluginsLoaded: runtimePluginMocks.ensureRuntimePluginsLoaded,

}));

vi.mock("../../tts/status-config.js", () => ({

resolveStatusTtsSnapshot: () => ({

autoMode: "always",

replyMediaPathMocks.createReplyMediaPathNormalizer.mockReturnValue(

async (payload: ReplyPayload) => payload,

);

runtimePluginMocks.ensureRuntimePluginsLoaded.mockClear();

});

it("loads runtime plugins before reading inbound hook state", async () => {

setNoAbort();

const cfg = emptyConfig;

const dispatcher = createDispatcher();

const ctx = buildTestCtx({

Provider: "whatsapp",

SessionKey: "agent:main:main",

});

const replyResolver = async () => ({ text: "hi" }) satisfies ReplyPayload;

await dispatchReplyFromConfig({ ctx, cfg, dispatcher, replyResolver });

expect(runtimePluginMocks.ensureRuntimePluginsLoaded).toHaveBeenCalledWith({

config: cfg,

workspaceDir: expect.any(String),

});

expect(runtimePluginMocks.ensureRuntimePluginsLoaded.mock.invocationCallOrder[0]).toBeLessThan(

hookMocks.runner.hasHooks.mock.invocationCallOrder[0],

);

});

it("does not route when Provider matches OriginatingChannel (even if Surface is missing)", async () => {

setNoAbort();

mocks.routeReply.mockClear();