Add REST request/429 debugging, temporarily disable message fetch hotfix

Author: Dragory

backend/src/index.ts

@@ -22,6 +22,26 @@ import { errorMessage, isDiscordAPIError, isDiscordHTTPError, SECONDS, successMe
 import { loadYamlSafely } from "./utils/loadYamlSafely";
 import { DecayingCounter } from "./utils/DecayingCounter";
 
+// === START REST DEBUG ===
+import fs from "fs";
+import path from "path";
+const APIRequest = require("discord.js/src/rest/APIRequest.js");
+
+const dateStr = new Date().toISOString().replace(/[:.]/g, "-");
+const restDebugFile = path.join("../debug", `rest_${dateStr}.log`);
+fs.writeFileSync(restDebugFile, "");
+
+const originalMake = APIRequest.prototype.make;
+// tslint:disable-next-line:only-arrow-functions
+APIRequest.prototype.make = function(...args) {
+  const debugInfo = `${new Date().toISOString()} ${this.method.toUpperCase()} ${this.route}`;
+  fs.appendFileSync(restDebugFile, debugInfo + "\n", { encoding: "utf8" });
+  // tslint:disable-next-line:no-console
+  console.log(`[API REQUEST] ${this.method} ${this.route}`);
+  return originalMake.call(this, ...args);
+};
+// === END REST DEBUG ===
+
 if (!process.env.KEY) {
   // tslint:disable-next-line:no-console
   console.error("Project root .env with KEY is required!");
@@ -152,8 +172,8 @@ connect().then(async () => {
   const client = new Client({
     partials: ["USER", "CHANNEL", "GUILD_MEMBER", "MESSAGE", "REACTION"],
 
-    restGlobalRateLimit: 20,
-    restTimeOffset: 1000,
+    restGlobalRateLimit: 50,
+    // restTimeOffset: 1000,
 
     // Disable mentions by default
     allowedMentions: {

backend/src/utils/hotfixMessageFetch.ts

@@ -8,14 +8,16 @@ let n = 0;
 export function hotfixMessageFetch(channel: TextChannel | ThreadChannel, messageId: string): Promise<Message> {
   const thisN = ++n;
 
-  // tslint:disable-next-line:no-console
-  console.trace(
-    `[${thisN}] Queueing to fetch message id ${messageId} from channel ${channel.id} (queue size: ${queue.length})`,
-  );
-  return queue.add(async () => {
-    await sleep(3000);
-    // tslint:disable-next-line:no-console
-    console.log(`[${thisN}] Fetching message id ${messageId} from channel ${channel.id}`);
-    return channel.messages.fetch(messageId);
-  });
+  return channel.messages.fetch(messageId);
+
+  // // tslint:disable-next-line:no-console
+  // console.trace(
+  //   `[${thisN}] Queueing to fetch message id ${messageId} from channel ${channel.id} (queue size: ${queue.length})`,
+  // );
+  // return queue.add(async () => {
+  //   await sleep(3000);
+  //   // tslint:disable-next-line:no-console
+  //   console.log(`[${thisN}] Fetching message id ${messageId} from channel ${channel.id}`);
+  //   return channel.messages.fetch(messageId);
+  // });
 }

debug/.gitignore

@@ -0,0 +1,2 @@
+*
+!/.gitignore