discordeno/gateway/manager/spawnShards.ts

import { GatewayManager } from "./gatewayManager.ts";

/** Begin spawning shards. */
export function spawnShards(gateway: GatewayManager) {
  // PREPARES THE MAX SHARD COUNT BY CONCURRENCY
  // if (manager.resharding.useOptimalLargeBotSharding) {
  //   // gateway.debug("GW DEBUG", "[Spawning] Using optimal large bot sharding solution.");
  //   manager.manager.totalShards = manager.calculateTotalShards(
  //     manager,
  //   );
  // }

  // PREPARES ALL SHARDS IN SPECIFIC BUCKETS
  gateway.prepareBuckets();

  // SPREAD THIS OUT TO DIFFERENT WORKERS TO BEGIN STARTING UP
  gateway.buckets.forEach(async (bucket, bucketId) => {
    for (const worker of bucket.workers) {
      for (const shardId of worker.queue) {
        await gateway.tellWorkerToIdentify(worker.id, shardId, bucketId);
      }
    }
  });
}