);

});

it("ignores malformed event ids when deciding whether to ack", async () => {

const mockUrbitFetch = vi.mocked(urbitFetch);

mockUrbitFetch.mockResolvedValue({

response: { ok: true, status: 200 } as unknown as Response,

finalUrl: "https://example.com",

release: vi.fn().mockResolvedValue(undefined),

});

const client = new UrbitSSEClient("https://example.com", "urbauth-~zod=123");

client.processEvent('id: 25abc\ndata: {"json":{"ok":true}}');

await Promise.resolve();

expect(mockUrbitFetch).not.toHaveBeenCalled();

expect((client as unknown as { lastHeardEventId: number }).lastHeardEventId).toBe(-1);

});

it("tracks lastHeardEventId and ackThreshold", () => {

const client = new UrbitSSEClient("https://example.com", "urbauth-~zod=123");

}

}

function parseUrbitSseEventId(value: string): number | null {

const trimmed = value.trim();

if (!/^\d+$/.test(trimmed)) {

return null;

}

const parsed = Number(trimmed);

return Number.isSafeInteger(parsed) ? parsed : null;

}

export class UrbitSSEClient {

url: string;

cookie: string;

for (const line of lines) {

if (line.startsWith("id: ")) {

eventId = Number.parseInt(line.slice(4), 10);

eventId = parseUrbitSseEventId(line.slice(4));

}

if (line.startsWith("data: ")) {

data = line.slice(6);