expect(dispatched.message.message_id).toBe("om_new_latest_fresh");

const combined = JSON.parse(dispatched.message.content) as { text?: string };

expect(combined.text).toBe("fresh");

expect(recordSpy).toHaveBeenCalledWith("om_old_latest_fresh", "default", expect.any(Function));

expect(recordSpy).not.toHaveBeenCalledWith(

"om_new_latest_fresh",

"default",

expect.any(Function),

);

expect(recordSpy).toHaveBeenCalledTimes(1);

const [recordedMessageId, recordedNamespace, recordedLogger] = recordSpy.mock.calls[0] ?? [];

expect(recordedMessageId).toBe("om_old_latest_fresh");

expect(recordedNamespace).toBe("default");

expect(typeof recordedLogger).toBe("function");

});

it("releases early event dedupe when debounced dispatch fails", async () => {