bug fixes and improvements

Author: mrepol742

package.json

@@ -6,7 +6,8 @@
   "main": "src/index.ts",
   "scripts": {
     "build": "tsc",
-    "start": "ts-node src/index.ts"
+    "start": "clear && while [ true ]; do npm run canis ; done",
+    "canis": "ts-node src/index.ts"
   },
   "author": {
     "name": "Melvin Jones Repol",

src/commands/hotreload.ts

@@ -0,0 +1,19 @@
+import { Message } from "whatsapp-web.js";
+import fs from "fs/promises";
+import log from "../components/utils/log";
+
+export const command = "hotreload";
+export const role = "admin";
+
+export default async function (msg: Message) {
+  await msg.react("🔄");
+
+  const tempDir = "./.temp";
+  await fs.mkdir(tempDir, { recursive: true });
+
+  const tempPath = `${tempDir}/hotreload`;
+  await fs.writeFile(tempPath, JSON.stringify(msg));
+
+  log.info("hotreload", "exiting...");
+  process.exit(0);
+}

src/commands/uptime.ts

@@ -9,9 +9,8 @@ export const role = "user";
 export default async function (msg: Message) {
   const uptimeMinutes = Math.floor(process.uptime() / 60);
   const statsMessage = `
-      *Update*
-
-      ${uptimeMinutes} minutes #${process.pid}
+      *${uptimeMinutes} minutes*
+      #${process.pid}
       `;
 
   await msg.reply(statsMessage);

src/components/client.ts

@@ -8,9 +8,13 @@ import {
 } from "whatsapp-web.js";
 import qrcode from "qrcode-terminal";
 import messageEvent from "./events/message";
-import groupJoin from "./events/groups/join";
 import groupLeave from "./events/groups/leave";
+import groupJoin from "./events/groups/join";
 import reaction from "./events/reaction";
+import ready from "./events/ready";
+
+import fs from "fs";
+import path from "path";
 
 const client = new Client({
   authStrategy: new LocalAuth(),
@@ -22,7 +26,7 @@ client.on("qr", (qr: string) => {
   qrcode.generate(qr, { small: true });
 });
 
-client.on("ready", () => log.info("Client", "WhatsApp client is ready!"));
+client.on("ready", async () => ready());
 client.on("message_reaction", async (react: Reaction) =>
   reaction(client, react)
 );

src/components/events/groups/join.ts

@@ -9,11 +9,11 @@ export default async function join(notif: GroupNotification) {
 
     for (const contact of recipients) {
       const name = contact.pushname || contact.name || contact.id.user;
-      log.info("Group Leave", `${name} left the group ${group.name}`);
-      await sleep(1500); // prevent flooding
-      await notif.reply(`👋 *${name}* has left. I’ll miss you!`);
+      log.info("Group Join", `${name} joined the group ${group.name}`);
+      await sleep(2000); // prevent flooding
+      await notif.reply(`👋 Welcome *${name}* 🎉`);
     }
   } catch (err) {
-    log.error("Group Leave", "Failed to process group leave event:", err);
+    log.error("Group Join", "Failed to process group join event:", err);
   }
 }

src/components/events/groups/leave.ts

@@ -9,11 +9,11 @@ export default async function leave(notif: GroupNotification) {
 
     for (const contact of recipients) {
       const name = contact.pushname || contact.name || contact.id.user;
-      log.info("Group Join", `${name} joined the group ${group.name}`);
-      await sleep(2000); // prevent flooding
-      await notif.reply(`👋 Welcome *${name}* 🎉`);
+      log.info("Group Leave", `${name} left the group ${group.name}`);
+      await sleep(1500); // prevent flooding
+      await notif.reply(`👋 *${name}* has left. I’ll miss you!`);
     }
   } catch (err) {
-    log.error("Group Join", "Failed to process group join event:", err);
+    log.error("Group Leave", "Failed to process group leave event:", err);
   }
 }

src/components/events/ready.ts

@@ -0,0 +1,43 @@
+import log from "../utils/log";
+import fs from "fs";
+import path from "path";
+import { client } from "../client";
+import sleep from "../utils/sleep";
+
+export default async function ready() {
+  log.info("Client", "WhatsApp client is ready!");
+
+  await sleep(5000); // Give some time for the client to stabilize
+
+  const hotReloadPath = path.resolve(__dirname, "../../../.temp/hotreload");
+  if (fs.existsSync(hotReloadPath)) {
+    try {
+      const tempData = JSON.parse(fs.readFileSync(hotReloadPath, "utf-8"));
+
+      let chatId = null;
+      if (typeof tempData.id === "string") {
+        chatId = tempData.id;
+      } else if (tempData.id?._serialized) {
+        chatId = tempData.id._serialized;
+      } else if (tempData.id?.id) {
+        chatId = tempData.id.id + "@c.us";
+      }
+
+      if (chatId) {
+        await client.sendMessage(chatId, "Hot reload done.");
+        return;
+      }
+      log.error("Hot Reload", "Could not resolve chat ID for message.");
+    } catch (err) {
+      log.error("Hot Reload", err);
+    } finally {
+      fs.unlink(hotReloadPath, (err) => {
+        if (err) {
+          log.error("Hot Reload", "Failed to delete hot reload file:", err);
+        } else {
+          log.info("Hot Reload", "Hot reload file deleted successfully.");
+        }
+      });
+    }
+  }
+};