Function startDev

packages/world-cli/src/dev.js:139–429

({ directory, port, targets, user })

const withoutPayload = ({ payload: _payload, ...report }) => report;

export async function startDev({ directory, port, targets, user }) {
  const clients = new Set();
  const builders = new Map();
  const removedTargets = new Map();
  const fileHashes = new Map();
  let version = 0;

  const send = (res, event) => {
    res.write(`data: ${JSON.stringify(event)}\n\n`);
  };
  const broadcast = (event) => {
    for (const res of clients) send(res, event);
  };
  const snapshot = () => ({
    protocol: PROTOCOL_VERSION,
    user,
    version,
    entries: [...builders.values()].flatMap(({ good }) =>
      good ? [good] : []
    ),
    reports: [...builders.values()].map(({ status }) => status),
    removals: [...removedTargets.values()],
  });
  const readyFrame = () => ({
    type: "ready",
    protocol: PROTOCOL_VERSION,
    user,
    version,
    builders: snapshot().entries.length,
  });

  const removeFile = (file) => {
    const removals = [];
    for (const [key, builder] of builders) {
      if (builder.file !== file) continue;
      builders.delete(key);
      if (builder.good) {
        removals.push(builder.target);
        removedTargets.set(key, builder.target);
      }
    }
    fileHashes.delete(file);
    return removals;
  };

  const install = (file, target, report) => {
    const frame = frameFor(report, target);
    const key = keyOf(target);
    const previous = builders.get(key);
    if (report.ok) removedTargets.delete(key);
    const status = withoutPayload(frame);
    builders.set(key, {
      file,
      target,
      status,
      good: report.ok ? frame : previous?.good,
    });
    printReport(report, { json: false, file });