Function awaitStart

src/cluster/node.ts:91–154

(i: number, shardArray: number[])

const broadcastTypes = ["broadcastEnd", "broadcastStart", "eval", "mediareload", "reload", "soundreload"];

function awaitStart(i: number, shardArray: number[]): Promise<Worker> {
  const worker = cluster.fork({
    SHARDS: JSON.stringify(shardArray),
    CLUSTER_TYPE: "node",
    pm_id: i,
  });

  worker.on("message", async (message: IncomingProcMessage) => {
    if (message.data?.type === "getCount") {
      worker.send({
        data: {
          type: "countResponse",
          serverCount,
        },
      });
    }
    if (message.data?.type === "getMem") {
      try {
        await updateStats(true);
      } catch (e) {
        logger.error(e);
      }
      worker.send({
        data: {
          type: "memResponse",
          totalMem,
        },
      });
    }

    // relay broadcast messages
    if (message.data && broadcastTypes.includes(message.data.type)) {
      for (const proc of processes) {
        if (proc.id === worker.id || !proc.isConnected()) continue;
        proc.send(message);
      }
    }
  });

  return new Promise((resolve, reject) => {
    const message = (msg: IncomingProcMessage) => {
      if (msg.data?.type === "ready") {
        worker.off("message", message);
        worker.off("error", error);
        worker.off("exit", exit);
        resolve(worker);
      }
    };
    const error = (e: Error) => {
      worker.off("message", message);
      worker.off("exit", exit);
      reject(e);
    };
    const exit = (c: number) => {
      worker.off("message", message);
      worker.off("error", error);
      reject(Error(`Process exited with code ${c}`));
    };