});

}

function requireRecordInboundSessionArgs() {

const [call] = recordInboundSessionMock.mock.calls;

if (!call) {

throw new Error("expected inbound session record call");

}

const [recordArgs] = call;

return recordArgs;

}

it("routes one accepted webhook event to one visible reply across duplicate replay", async () => {

dispatchReplyWithBufferedBlockDispatcherMock.mockImplementation(

async ({ dispatcherOptions }) => {

);

expect(recordInboundSessionMock).toHaveBeenCalledTimes(1);

const [recordArgs] = recordInboundSessionMock.mock.calls[0] ?? [];

const recordArgs = requireRecordInboundSessionArgs();

expect(recordArgs?.sessionKey).toBe("agent:main:zalo:direct:dm-chat-1");

expect(recordArgs?.ctx?.AccountId).toBe("acct-zalo-lifecycle");

expect(recordArgs?.ctx?.SessionKey).toBe("agent:main:zalo:direct:dm-chat-1");