fix: only reset invalidated once

NezuChan · Jan 3, 2023 · ffca848 · ffca848
1 parent 3f1e7b4
commit ffca848
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 3 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@nezuchan/nezu-gateway",
-  "version": "1.2.3",
+  "version": "1.2.4",
   "description": "A standalone service for connecting to the Discord gateway.",
   "main": "dist",
   "scripts": {

diff --git a/src/Listeners/Sockets/SocketDebugListener.ts b/src/Listeners/Sockets/SocketDebugListener.ts
@@ -19,7 +19,7 @@ export class SocketDebugListener extends Listener {
             await collection.set(`${payload.shardId}`, { ping, shardId: payload.shardId });
         }
 
-        if (payload.shardId === 0 && payload.message.includes("Invalid session; will attempt to resume: false")) {
+        if (this.container.gateway.resetInvalidatedOnStart && payload.shardId === 0 && payload.message.includes("Invalid session; will attempt to resume: false")) {
             await new RedisCollection({ redis: this.container.gateway.redis, hash: process.env.USE_ROUTING === "true" ? `${this.container.gateway.clientId}:${Constants.GUILD_KEY}` : Constants.GUILD_KEY }).clear();
             await new RedisCollection({ redis: this.container.gateway.redis, hash: process.env.USE_ROUTING === "true" ? `${this.container.gateway.clientId}:${Constants.CHANNEL_KEY}` : Constants.CHANNEL_KEY }).clear();
             await new RedisCollection({ redis: this.container.gateway.redis, hash: process.env.USE_ROUTING === "true" ? `${this.container.gateway.clientId}:${Constants.MESSAGE_KEY}` : Constants.MESSAGE_KEY }).clear();

diff --git a/src/Listeners/Sockets/SocketReadyListener.ts b/src/Listeners/Sockets/SocketReadyListener.ts
@@ -9,6 +9,6 @@ import { WebSocketShardEvents } from "@discordjs/ws";
 
 export class SocketReadyListener extends Listener {
     public run(payload: { shardId: number }): void {
-        this.container.gateway.logger.info(`Shard ${payload.shardId} ready`);
+        this.container.gateway.logger.info(`Shard ${payload.shardId} ready`); this.container.gateway.resetInvalidatedOnStart = false;
     }
 }
diff --git a/src/Structures/NezuGateway.ts b/src/Structures/NezuGateway.ts
@@ -34,6 +34,7 @@ export class NezuGateway extends EventEmitter {
 
     public clientId = Buffer.from(process.env.DISCORD_TOKEN!.split(".")[0], "base64").toString();
     public stores = new StoreRegistry();
+    public resetInvalidatedOnStart = true;
 
     public prometheus = new APM({
         PORT: process.env.PROMETHEUS_PORT ?? 9090,