123456789101112131415161718192021222324252627282930313233
import { GatewayIntents } from "../../types/shared.ts";import { createLeakyBucket } from "../../util/bucket.ts";import { createShard } from "../shard/createShard.ts";import { Shard } from "../shard/types.ts";import { createGatewayManager, 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) => {    // gateway.debug("GW DEBUG", `2. Running forEach loop in spawnShards function.`);
    for (const worker of bucket.workers) {      // gateway.debug("GW DEBUG", `3. Running for of loop in spawnShards function.`);
      for (const shardId of worker.queue) {        await gateway.tellWorkerToIdentify(worker.id, shardId, bucketId);      }    }  });}