Function openConn

packages/server/test/auth-wiring.e2e.test.ts:83–107

(url: string, protocols?: string[])

}

function openConn(url: string, protocols?: string[]): Promise<Conn> {
  return new Promise((resolve, reject) => {
    const ws = new WebSocket(url, protocols);
    const queue: WsFrame[] = [];
    const waiters: Array<(frame: WsFrame) => void> = [];
    let closedResolve: (v: { code: number; reason: string }) => void;
    const closed = new Promise<{ code: number; reason: string }>((res) => {
      closedResolve = res;
    });
    // Attach the message listener BEFORE 'open' can fire so the immediate
    // `server_hello` frame is never dropped.
    ws.on('message', (data: RawData) => {
      try {
        const frame = JSON.parse(rawDataToString(data)) as WsFrame;
        if (waiters.length > 0) waiters.shift()?.(frame);
        else queue.push(frame);
      } catch {
        // ignore non-JSON frames
      }
    });
    ws.on('close', (code, reason) => closedResolve({ code, reason: String(reason) }));
    ws.once('open', () => resolve({ ws, queue, waiters, closed }));
    ws.once('error', reject);
  });
}

function receive(conn: Conn, timeoutMs: number): Promise<WsFrame> {
  return new Promise((resolve, reject) => {