Function openRegisteredSocket

scripts/daemon-memory-check.ts:342–381

(
  port: number,
  sessionId: string,
  cycle: number,
  sessionIndex: number,
  options: CliOptions,
)

}

async function openRegisteredSocket(
  port: number,
  sessionId: string,
  cycle: number,
  sessionIndex: number,
  options: CliOptions,
) {
  const socket = new WebSocket(`ws://127.0.0.1:${port}/session`);
  await new Promise<void>((resolve, reject) => {
    const timeout = setTimeout(
      () => reject(new Error(`Timed out opening websocket for ${sessionId}.`)),
      2_000,
    );
    socket.addEventListener(
      "open",
      () => {
        clearTimeout(timeout);
        resolve();
      },
      { once: true },
    );
    socket.addEventListener(
      "error",
      () => {
        clearTimeout(timeout);
        reject(new Error(`Websocket failed for ${sessionId}.`));
      },
      { once: true },
    );
  });

  socket.send(
    JSON.stringify({
      type: "register",
      registration: makeRegistration(sessionId, cycle, sessionIndex, options),
      snapshot: makeSnapshot(sessionId, 0, options),
    }),
  );
  return socket;
}

async function sendSnapshotUpdates(
  sockets: WebSocket[],