refractor: update log for consistent logging and realtime monitoring

Author: mrepol742

src/components/events/edit.ts

@@ -1,6 +1,7 @@
 import { Message } from "whatsapp-web.js";
 import { getUserbyLid } from "../services/user";
 import { addMessage } from "../services/message";
+import log from "../utils/log";
 
 /*
  * TODO: Implement settings to enable/disable this event.
@@ -13,6 +14,8 @@ export default async function (
 ) {
   // const isGroup = !!msg.author;
   // const user = await getUserbyLid(msg.from) || "Your";
+  //
+  log.info("EditMessage", prevBody);
   await addMessage(msg, prevBody, "edit");
   // await msg.reply(
   //   `${isGroup ? user : "Your"} message was edited from "${prevBody}".`

src/components/events/groups/join.ts

@@ -18,7 +18,7 @@ export default async function (notif: GroupNotification) {
       const name = contact.pushname || contact.name || contact.id.user;
       const isSelf = contact.id._serialized === client.info.wid._serialized;
 
-      log.info("Group Join", `${name} joined the group ${group.name}`);
+      log.info("GroupJoin", `${name} joined the group ${group.name}`);
 
       if (isSelf) {
         await notif.reply(
@@ -40,6 +40,6 @@ export default async function (notif: GroupNotification) {
       await notif.reply(getMessage("welcome", `*${newMembers.join(", ")}*`));
     }
   } catch (err) {
-    log.error("Group Join", "Failed to process group join event:", err);
+    log.error("GroupJoin", "Failed to process group join event:", err);
   }
 }

src/components/events/groups/leave.ts

@@ -16,16 +16,16 @@ export default async function (notif: GroupNotification) {
       const name = contact.pushname || contact.name || contact.id.user;
       const isSelf = contact.id._serialized === client.info.wid._serialized;
       if (!isSelf) {
-        log.info("Group Leave", `${name} left the group ${group.name}`);
+        log.info("GroupLeave", `${name} left the group ${group.name}`);
         leavers.push(name);
       } else {
-        log.info("Group Leave", `the bot left the group ${group.name}`);
+        log.info("GroupLeave", `the bot left the group ${group.name}`);
       }
     }
 
     if (leavers.length > 0)
       await notif.reply(getMessage("leaving", `*${leavers.join(", ")}*`));
   } catch (err) {
-    log.error("Group Leave", "Failed to process group leave event:", err);
+    log.error("GroupLeave", "Failed to process group leave event:", err);
   }
 }

src/components/events/message.ts

@@ -74,6 +74,7 @@ export default async function (msg: Message, type: string) {
 
     await sleep(randomMs);
     const isEmoji = /.*[A-Za-z0-9].*/.test(reaction);
+    log.info("AutoReact", reaction);
 
     if (Math.random() < 0.1 && !isEmoji)
       if (Math.random() < 0.2)
@@ -157,6 +158,8 @@ export default async function (msg: Message, type: string) {
   ): Promise<Message> => {
     let messageBody = typeof content === "string" ? Font(content) : content;
 
+    log.info("ReplyMessage", lid, content.toString().slice(0, 150));
+
     if (Math.random() < 0.5)
       return await client.sendMessage(msg.id.remote, messageBody, options);
     return await originalReply(messageBody, chatId, options);

src/components/events/quiz.ts

@@ -1,6 +1,7 @@
 import { Message } from "whatsapp-web.js";
 import { getQuizAttempts, setQuizAttemptAnswered } from "../services/quiz";
 import { quiz } from "../utils/data";
+import log from "../utils/log";
 
 const done = [
   "Correct! 🎉",
@@ -56,11 +57,13 @@ export default async function (
           msg.reply(done[Math.floor(Math.random() * done.length)]),
           setQuizAttemptAnswered(msg, quoted),
           quoted.delete(true, true),
+          log.info("QuizAnswered", "Correct", quoted.body),
         ]);
       } else {
         await Promise.all([
           msg.reply(wrong[Math.floor(Math.random() * wrong.length)]),
           quoted.delete(true, true),
+          log.info("QuizAnswered", "Wrong", quoted.body),
         ]);
       }
       return true;

src/components/events/ready.ts

@@ -16,13 +16,13 @@ export default async function () {
 
       await client.sendMessage(tempData.id.remote, "Restart Finished.");
     } catch (err) {
-      log.error("restart", err);
+      log.error("Restart", err);
     } finally {
       fs.unlink(hotReloadPath, (err) => {
         if (err) {
-          log.error("restart", "Failed to delete restart file:", err);
+          log.error("Restart", "Failed to delete restart file:", err);
         } else {
-          log.info("restart", "Restart file deleted successfully.");
+          log.info("Restart", "Restart file deleted successfully.");
         }
       });
     }

src/components/events/revoke.ts

@@ -1,6 +1,7 @@
 import { Message } from "whatsapp-web.js";
 import { getUserbyLid } from "../services/user";
 import { addMessage } from "../services/message";
+import log from "../utils/log";
 
 /*
  * TODO: Implement settings to enable/disable this event.
@@ -11,6 +12,7 @@ export default async function (msg: Message, revoked_msg?: Message) {
   if (msg.timestamp < Date.now() / 1000 - 10) return;
   // const isGroup = !!msg.author;
   // const user = (await getUserbyLid(msg.from)) || "Your";
+  log.info("RevokeMessage", revoked_msg?.body);
   await addMessage(msg, revoked_msg?.body, "revoke");
   // await msg.reply(
   //   `${isGroup ? user : "Your"} message "${revoked_msg?.body}" was deleted.`

src/components/process.ts

@@ -15,21 +15,21 @@ process.on("SIGINT", function () {
 
 process.on("uncaughtException", (err, origin) => {
   log.error(
-    "Uncaught Exception",
+    "UncaughtException",
     `Exception: ${err.message}\nOrigin: ${origin}`
   );
 });
 
 process.on("unhandledRejection", (reason, promise) => {
-  log.error("Unhandled Rejection", `Reason: ${reason}\nPromise: ${promise}`);
+  log.error("UnhandledRejection", `Reason: ${reason}\nPromise: ${promise}`);
 });
 
 process.on("beforeExit", (code) => {
-  log.info("Before Exit", `Process is about to exit with code: ${code}`);
+  log.info("BeforeExit", `Process is about to exit with code: ${code}`);
 });
 
 process.on("exit", (code) => {
   console.log("");
 });
 
-log.info("Process", "Event listeners for process signals have been set up.");
+log.info("Process", "Event listeners for process signals have been set up.");