Dev/fix ririko avc (#327)

* [FIX] Fixes bug on RirikoAVC

* 0.14.2

index.js

@@ -10,6 +10,15 @@ const cli = require(`./${buildDir}/ririkoCli`);
 
 const configFileExists = fs.existsSync("./config.js");
 
+process
+  .on("unhandledRejection", (reason, p) => {
+    console.error(reason, "Unhandled Rejection at Promise", p);
+  })
+  .on("uncaughtException", (err) => {
+    console.error(err, "Uncaught Exception thrown");
+    console.oLog(err);
+  });
+
 function createLogDirectory() {
   if (!fs.existsSync(logDirectory)) {
     fs.mkdirSync(logDirectory);

package.json

@@ -1,6 +1,6 @@
 {
   "name": "ririko",
-  "version": "0.14.1",
+  "version": "0.14.2",
   "description": "Ririko - A powerful AI-powered general Discord bot that you can call your companion",
   "author": "Earnest Angel",
   "email": "[email protected]",

src/app/RirikoAVC.js

@@ -94,38 +94,43 @@ class RirikoAVC {
   }
 
   checkAVC(client) {
-    //remove deleted channels from data
-    let updatePersistance = false;
-    this.#_content.primary.forEach((id) => {
-      if (client.channels.cache.get(id) == null) {
-        this.#_content.primary.splice(this.#_content.primary.indexOf(id), 1);
-        updatePersistance = true;
-      }
-    });
-    this.#_content.children.forEach((id) => {
-      if (client.channels.cache.get(id) == null) {
-        this.#_content.children.splice(this.#_content.children.indexOf(id), 1);
-        updatePersistance = true;
-      }
-    });
-    if (updatePersistance) this.#save();
+    try {
+      //remove deleted channels from data
+      let updatePersistance = false;
+      this.#_content.primary.forEach((id) => {
+        if (client.channels.cache.get(id) == null) {
+          this.#_content.primary.splice(this.#_content.primary.indexOf(id), 1);
+          updatePersistance = true;
+        }
+      });
+      this.#_content.children.forEach((id) => {
+        if (client.channels.cache.get(id) == null) {
+          this.#_content.children.splice(
+            this.#_content.children.indexOf(id),
+            1
+          );
+          updatePersistance = true;
+        }
+      });
+      if (updatePersistance) this.#save();
 
-    // Check if channels need to be created
-    this.#_content.primary.forEach((id) => {
-      let primary = client.channels.cache.get(id);
-      if (primary?.members.first() != null) {
-        primary.members.every((member) => {
-          this.createChildVoice(primary, member);
-        });
-      }
-    });
-    //Check if channels need to be deleted
-    this.#_content.children.forEach((id) => {
-      let children = client.channels.cache.get(id);
-      if (children != null && children?.members.first() == null) {
-        this.deleteChildrenVoice(children);
-      }
-    });
+      // Check if channels need to be created
+      this.#_content.primary.forEach((id) => {
+        let primary = client.channels.cache.get(id);
+        if (primary?.members.first() != null) {
+          primary.members.every((member) => {
+            this.createChildVoice(primary, member);
+          });
+        }
+      });
+      //Check if channels need to be deleted
+      this.#_content.children.forEach((id) => {
+        let children = client.channels.cache.get(id);
+        if (children != null && children?.members.first() == null) {
+          this.deleteChildrenVoice(children);
+        }
+      });
+    } catch (e) {}
   }
 }
 

src/ririkoBot.js

@@ -19,9 +19,14 @@ const { RirikoMusic } = require("app/RirikoMusic");
 const { getLang } = require("./helpers/language");
 const { RirikoAVC } = require("./app/RirikoAVC");
 
-process.on("uncaughtException", function (err) {
-  console.log("Caught exception: " + err);
-});
+process
+  .on("unhandledRejection", (reason, p) => {
+    console.error(reason, "Unhandled Rejection at Promise", p);
+  })
+  .on("uncaughtException", (err) => {
+    console.error(err, "Uncaught Exception thrown");
+    console.oLog(err);
+  });
 
 console.info("0------------------| Ririko AI (Bot):".brightCyan);
 
@@ -166,7 +171,7 @@ module.exports = client;
         })
         .on("uncaughtException", (err) => {
           console.error(err, "Uncaught Exception thrown");
-          process.exit(1);
+          console.oLog(err);
         });
 
       // Use this to remove commands list

src/ririkoCli.js

@@ -8,6 +8,15 @@ const NODE_ENV = process.env.NODE_ENV || "development";
 let initialized = false;
 let showPrompt = false; // Flag to control prompt display
 
+process
+  .on("unhandledRejection", (reason, p) => {
+    console.error(reason, "Unhandled Rejection at Promise", p);
+  })
+  .on("uncaughtException", (err) => {
+    console.error(err, "Uncaught Exception thrown");
+    console.oLog(err);
+  });
+
 const rl = readline.createInterface({
   input: process.stdin,
   output: process.stdout,

src/ririkoExpress.js

@@ -16,6 +16,15 @@ const path = require("path");
 
 const configFileExists = fs.existsSync("./config.js");
 
+process
+  .on("unhandledRejection", (reason, p) => {
+    console.error(reason, "Unhandled Rejection at Promise", p);
+  })
+  .on("uncaughtException", (err) => {
+    console.error(err, "Uncaught Exception thrown");
+    console.oLog(err);
+  });
+
 console.info("0------------------| Ririko Express (Web Server):".brightCyan);
 
 let Hostname, Port;

src/ririkoQueueManager.js

@@ -13,6 +13,15 @@ overrideLoggers();
 
 console.info("[Ririko Queue Manager] Started".brightMagenta);
 
+process
+  .on("unhandledRejection", (reason, p) => {
+    console.error(reason, "Unhandled Rejection at Promise", p);
+  })
+  .on("uncaughtException", (err) => {
+    console.error(err, "Uncaught Exception thrown");
+    console.oLog(err);
+  });
+
 const { Client, Intents, GatewayIntentBits } = require("discord.js");
 
 const client = new Client({

src/ririkoStreamChecker.js

@@ -27,6 +27,15 @@ let retries = 0,
   max_retries = 5;
 let iteration = 1;
 
+process
+  .on("unhandledRejection", (reason, p) => {
+    console.error(reason, "Unhandled Rejection at Promise", p);
+  })
+  .on("uncaughtException", (err) => {
+    console.error(err, "Uncaught Exception thrown");
+    console.oLog(err);
+  });
+
 (async function () {
   require("handlers/mongoose")(false, "Stream Checker", true);