Function waitForEvent

packages/server/test/ws-handshake.e2e.test.ts:47–61

(
  records: readonly TelemetryRecord[],
  event: string,
  timeoutMs: number,
)

}

async function waitForEvent(
  records: readonly TelemetryRecord[],
  event: string,
  timeoutMs: number,
): Promise<TelemetryRecord> {
  const deadline = Date.now() + timeoutMs;
  while (Date.now() < deadline) {
    const found = records.find((r) => r.event === event);
    if (found !== undefined) return found;
    await new Promise((res) => {
      setTimeout(res, 10);
    });
  }
  throw new Error(`event ${event} not observed; got ${JSON.stringify(records)}`);
}

let tmpDir: string;
let lockPath: string;