Record every match

import { mkdir, writeFile } from 'node:fs/promises';
import { createRoom, readReplay } from 'ball2d/node';

const directory = 'recordings';
await mkdir(directory, { recursive: true });

const room = await createRoom({
  apiKey: process.env.BALL2D_API_KEY,
  roomName: 'Recorded matches',
  noPlayer: true,
  public: true,
});

async function save(blob, reason) {
  const stamp = new Date().toISOString().replace(/[:.]/g, '-');
  const name = `${directory}/${stamp}`;
  await writeFile(
    `${name}.ball2drep`,
    Buffer.from(await blob.arrayBuffer()),
  );
  const replay = await readReplay(blob);
  const summary = {
    reason,
    seconds: (replay.end - replay.initial.tick) / 60,
    players: [
      ...new Set(
        replay.roster
          .map((entry) => entry.name)
          .filter(Boolean),
      ),
    ],
  };
  await writeFile(
    `${name}.json`,
    `${JSON.stringify(summary, null, 2)}\n`,
  );
  console.log('Saved', name);
}

room.onGameStart = () => room.startRecording();

room.onGameStop = () => {
  const blob = room.stopRecording();
  if (blob)
    void save(blob, 'Match ended').catch((error) =>
      console.error(error),
    );
};

// The room finishes recordings on its own at a limit,
// on a stadium change and on close.
room.onRecordingComplete = (blob, reason) => {
  void save(blob, reason).catch((error) =>
    console.error(error),
  );
};

room.onError = (message) => console.error(message);
console.log(room.roomLink);

for (const signal of ['SIGINT', 'SIGTERM']) {
  process.once(signal, async () => {
    // Delivers the running recording to onRecordingComplete.
    room.close();
    await room.closed;
    // Let the last write finish.
    setTimeout(() => process.exit(0), 1000);
  });
}