Skip to content

Commit a873ec1

Browse files
feat: Add message to send resume event to shard (#9626)
* fix(WebSocketManager): Fix not ready after reconnect * fix(WebSocketManager): Move fixes from Ready to Resume * fix: undo changes * feat: Add message to send resume event to shard --------- Co-authored-by: GrapeColor <grapecolor@users.noreply.github.com> Co-authored-by: kodiakhq[bot] <49736102+kodiakhq[bot]@users.noreply.github.com>
1 parent db925fa commit a873ec1

File tree

2 files changed

+12
-0
lines changed

2 files changed

+12
-0
lines changed

packages/discord.js/src/sharding/Shard.js

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -367,6 +367,12 @@ class Shard extends EventEmitter {
367367
return;
368368
}
369369

370+
// Shard has resumed
371+
if (message._resume) {
372+
this.ready = true;
373+
return;
374+
}
375+
370376
// Shard is requesting a property fetch
371377
if (message._sFetchProp) {
372378
const resp = { _sFetchProp: message._sFetchProp, _sFetchPropShard: message._sFetchPropShard };

packages/discord.js/src/sharding/ShardClientUtil.js

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,9 @@ class ShardClientUtil {
4242
client.on(Events.ShardReconnecting, () => {
4343
process.send({ _reconnecting: true });
4444
});
45+
client.on(Events.ShardResume, () => {
46+
process.send({ _resume: true });
47+
});
4548
break;
4649
case 'worker':
4750
this.parentPort = require('node:worker_threads').parentPort;
@@ -55,6 +58,9 @@ class ShardClientUtil {
5558
client.on(Events.ShardReconnecting, () => {
5659
this.parentPort.postMessage({ _reconnecting: true });
5760
});
61+
client.on(Events.ShardResume, () => {
62+
this.parentPort.postMessage({ _resume: true });
63+
});
5864
break;
5965
}
6066
}

0 commit comments

Comments
 (0)