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

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

import type { MatrixQaObservedEvent } from "./events.js";

import {

createMatrixQaRoomObserver,

const observedEvents: MatrixQaObservedEvent[] = [];

const result = await waitForOptionalMatrixQaRoomEvent({

accessToken: "token",

baseUrl: "http://127.0.0.1:28008/",

fetchImpl,

observedEvents,

predicate: (event) => event.sender === "@sut:matrix-qa.test",

roomId: "!room:matrix-qa.test",

since: "start-batch",

timeoutMs: 1_000,

});

const nowSpy = vi.spyOn(Date, "now").mockReturnValueOnce(0).mockReturnValue(1);

let result: Awaited<ReturnType<typeof waitForOptionalMatrixQaRoomEvent>>;

try {

result = await waitForOptionalMatrixQaRoomEvent({

accessToken: "token",

baseUrl: "http://127.0.0.1:28008/",

fetchImpl,

observedEvents,

predicate: (event) => event.sender === "@sut:matrix-qa.test",

roomId: "!room:matrix-qa.test",

since: "start-batch",

timeoutMs: 1,

});

} finally {

nowSpy.mockRestore();

}

expect(result).toEqual({

matched: false,

const startSince = await this.prime();

const startedAt = Date.now();

let cursorIndex = roomObserver.cursorIndex;

let didPoll = false;

while (true) {

const matched = findMatrixQaObservedEventMatch({

cursorIndex,

}

const elapsedMs = Date.now() - startedAt;

if (elapsedMs >= waitParams.timeoutMs) {

if (elapsedMs >= waitParams.timeoutMs && (didPoll || waitParams.timeoutMs <= 0)) {

roomObserver.cursorIndex = Math.max(roomObserver.cursorIndex, cursorIndex);

return {

matched: false,

roomObserver,

timeoutMs: remainingMs,

});

didPoll = true;

}

},

async waitForRoomEvent(waitParams) {