Function openSocketWithHello

packages/server-e2e/test/refresh-replay.test.ts:84–135

(opts: {
  sid: string;
  lastSeq?: number;
  clientId?: string;
  log?: (label: string, value?: unknown) => void;
})

}

async function openSocketWithHello(opts: {
  sid: string;
  lastSeq?: number;
  clientId?: string;
  log?: (label: string, value?: unknown) => void;
}): Promise<HelloResult> {
  const wsUrl = `${BASE_URL.replace(/^http/, 'ws')}${API_PREFIX}/ws`;
  const ws = new WsClient({ url: wsUrl, wsImpl: WsWebSocket, logger: () => {} });
  opts.log?.('refresh ws open', { url: wsUrl, sid: opts.sid, last_seq: opts.lastSeq });
  await ws.open();

  const arrivals: AnyFrame[] = [];
  ws.onFrame((f) => arrivals.push(f));

  const serverHello = await ws.waitForFrame((f) => f.type === 'server_hello', HANDSHAKE_TIMEOUT_MS);
  opts.log?.('refresh ws server_hello', frameForLog(serverHello));

  const helloId = `hello-${Date.now()}-${Math.random().toString(36).slice(2, 8)}`;
  const payload: Record<string, unknown> = {
    client_id: opts.clientId ?? `vitest-refresh-${process.pid}`,
    subscriptions: [opts.sid],
  };
  if (opts.lastSeq !== undefined) {
    payload['cursors'] = { [opts.sid]: { seq: opts.lastSeq } };
  }
  opts.log?.('refresh ws client_hello', { id: helloId, payload });
  ws.send({ type: 'client_hello', id: helloId, payload });

  const ack = await ws.waitForFrame(
    (f) => f.type === 'ack' && f.id === helloId,
    HANDSHAKE_TIMEOUT_MS,
  );
  opts.log?.('refresh ws ack', frameForLog(ack));

  const replayed = arrivals.filter(
    (f) =>
      f.type !== 'server_hello' &&
      f.type !== 'ack' &&
      f.type !== 'ping' &&
      f.type !== 'resync_required' &&
      f.type !== 'error' &&
      typeof f.seq === 'number' &&
      f.session_id === opts.sid &&
      (opts.lastSeq === undefined || f.seq > opts.lastSeq),
  );
  opts.log?.('refresh ws replayed', {
    count: replayed.length,
    frames: replayed.map(frameForLog),
  });

  return { ws, ack, replayed };
}

const reachable = await daemonReachable();
const describeLive = reachable ? describe : describe.skip;