daenamnu/discordeno
1
0
Fork 0
mirror of https://github.com/discordeno/discordeno.git synced 2026-09-17 00:37:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(gateway): Use gateway instead of options in functions (#5169)

Browse Source
This commit is contained in:
Fleny
2026-07-23 01:29:27 +05:30
committed by GitHub
parent 94d14db0ec
commit 6c57211303
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/gateway/src/manager.ts
+4 -4
View File
@@ -186,14 +186,14 @@ export function createGatewayManager(options: CreateGatewayManagerOptions): Gate
// Move the events from the old shards to the new ones // Move the events from the old shards to the new ones
for (const shard of gateway.resharding.shards.values()) { for (const shard of gateway.resharding.shards.values()) {
shard.events = options.events ?? {}; shard.events = gateway.events ?? {};
} }
// Old shards stop processing events // Old shards stop processing events
for (const shard of gateway.shards.values()) { for (const shard of gateway.shards.values()) {
const oldHandler = shard.events.message; const oldHandler = shard.events.message;
// Change with spread operator to not affect new shards, as changing anything on shard.events will directly change options.events, which changes new shards' events // Change with spread operator to not affect new shards, as changing anything on shard.events will directly change gateway.events, which changes new shards' events
shard.events = { shard.events = {
...shard.events, ...shard.events,
message: async function (_, message) { message: async function (_, message) {
@@ -232,7 +232,7 @@ export function createGatewayManager(options: CreateGatewayManagerOptions): Gate
); );
}, },
calculateWorkerId(shardId) { calculateWorkerId(shardId) {
const workerId = options.spreadShardsInRoundRobin const workerId = gateway.spreadShardsInRoundRobin
? shardId % gateway.totalWorkers ? shardId % gateway.totalWorkers
: Math.min(Math.floor(shardId / gateway.shardsPerWorker), gateway.totalWorkers - 1); : Math.min(Math.floor(shardId / gateway.shardsPerWorker), gateway.totalWorkers - 1);
gateway.logger.debug( gateway.logger.debug(
@@ -354,7 +354,7 @@ export function createGatewayManager(options: CreateGatewayManagerOptions): Gate
url: this.url, url: this.url,
version: this.version, version: this.version,
}, },
events: options.events ?? {}, events: gateway.events ?? {},
logger: this.logger, logger: this.logger,
requestIdentify: async () => await gateway.requestIdentify(shardId), requestIdentify: async () => await gateway.requestIdentify(shardId),
makePresence: gateway.makePresence, makePresence: gateway.makePresence,