Function getGatewayData

src/cluster/common.ts:31–58

()

export type IncomingProcMessage = BaseProcMessage | ServerCountMessage;

export async function getGatewayData() {
  const base =
    process.env.REST_PROXY && process.env.REST_PROXY !== "" ? process.env.REST_PROXY : "https://discord.com/api/v10";

  const request = await fetch(`${base}/gateway/bot`, {
    headers: {
      Authorization: `Bot ${process.env.TOKEN}`,
    },
  });
  if (!request.ok) {
    throw new Error(`Failed to get gateway connection data: ${request.statusText}`);
  }

  const connectionData = (await request.json()) as {
    shards?: number;
    message: string;
  };
  if (!connectionData.shards) {
    throw new Error(`Failed to read gateway connection data: ${connectionData.message}`);
  }

  const cpuAmount = availableParallelism();
  const procAmount = Math.min(connectionData.shards, cpuAmount);
  return {
    procAmount,
    shards: connectionData.shards,
  };
}

// from eris-fleet
export function calcShards(shards: number[], procs: number) {