Bir odayı çevrimiçi tut

import { createRoom, RoomAdmissionError } from 'ball2d/node';

const config = {
  apiKey: process.env.BALL2D_API_KEY,
  roomName: 'Always-on football',
  noPlayer: true,
  public: true,
};

const stopping = new AbortController();
for (const signal of ['SIGINT', 'SIGTERM'])
  process.once(signal, () => stopping.abort());

const sleep = (seconds) =>
  new Promise((resolve) => {
    const timer = setTimeout(resolve, seconds * 1000);
    stopping.signal.addEventListener(
      'abort',
      () => (clearTimeout(timer), resolve()),
      { once: true },
    );
  });

function setUp(room) {
  room.onError = (message) =>
    console.error(`[${room.roomId}]`, message);
  room.onPlayerJoin = (player) =>
    room.setPlayerTeam(player.id, 1);
  return room.setDefaultStadium('Classic');
}

let failures = 0;
while (!stopping.signal.aborted) {
  let room;
  try {
    room = await createRoom(config, {
      signal: stopping.signal,
    });
  } catch (error) {
    if (stopping.signal.aborted) break;
    // Bad configuration.
    if (error instanceof TypeError) throw error;
    if (
      error instanceof RoomAdmissionError &&
      [400, 401, 403].includes(error.status)
    )
      throw error;
    failures++;
    const wait =
      error.retryAfterSeconds ??
      Math.min(300, 2 ** failures) + Math.random() * 3;
    console.warn(
      `Room did not open: ${error.message}.` +
        ` Retrying in ${Math.round(wait)} s.`,
    );
    await sleep(wait);
    continue;
  }

  failures = 0;
  console.log('Room open:', room.roomLink);
  await setUp(room).catch((error) =>
    console.error('Setup failed:', error),
  );

  // Wait until the room ends or we are asked to stop.
  await new Promise((resolve) => {
    room.signal.addEventListener('abort', resolve, {
      once: true,
    });
    stopping.signal.addEventListener('abort', resolve, {
      once: true,
    });
  });
  room.close();
  await room.closed;
  if (!stopping.signal.aborted) await sleep(5);
}