feat: bug fixes and improvements

Author: mrepol742

src/commands/mute.ts

@@ -0,0 +1,20 @@
+import { Message } from "../../types/message";
+import log from "../components/utils/log";
+
+export const info = {
+  command: "mute",
+  description: "Mute this chat",
+  usage: "mute",
+  example: "mute",
+  role: "admin",
+  cooldown: 5000,
+};
+
+export default async function (msg: Message) {
+  if (!/^mute/i.test(msg.body)) return;
+
+  const chat = await msg.getChat();
+  await chat.mute();
+
+  await msg.reply("This chat is now muted.");
+}

src/commands/play.ts

@@ -80,6 +80,10 @@ export default async function play(msg: Message) {
     writeStream.on("error", reject);
   });
 
+  // simulates audio recording
+  const chat = await msg.getChat();
+  chat.sendStateRecording();
+
   await execPromise(
     `ffmpeg -y -i "${tempPath}" -vn -ar 44100 -ac 2 -b:a 192k "${tempPath}.mp3"`,
   );

src/commands/say.ts

@@ -1,5 +1,5 @@
 import { MessageMedia } from "whatsapp-web.js";
-import { Message } from "../../types/message"
+import { Message } from "../../types/message";
 import log from "../components/utils/log";
 import * as GoogleTTS from "google-tts-api";
 import fs from "fs";
@@ -28,6 +28,10 @@ export default async function (msg: Message) {
     host: "https://translate.google.com",
   });
 
+  // simulates audio recording
+  const chat = await msg.getChat();
+  chat.sendStateRecording();
+
   const response = await axios.get(url, { responseType: "arraybuffer" });
   const buffer = Buffer.from(response.data);
   const tempDir = "./.temp";
@@ -42,7 +46,7 @@ export default async function (msg: Message) {
   const media = new MessageMedia(
     "audio/mpeg",
     audioBuffer.toString("base64"),
-    `${filename}.mp3`
+    `${filename}.mp3`,
   );
   await msg.reply(media, msg.from, {
     sendAudioAsVoice: true,

src/commands/stats.ts

@@ -53,6 +53,8 @@ export default async function (msg: Message) {
     blockUserCount,
     waStatus,
     waVersion,
+    deviceCount,
+    chats,
   ] = await Promise.all([
     si.graphics(),
     si.osInfo(),
@@ -62,6 +64,8 @@ export default async function (msg: Message) {
     getBlockUserCount(),
     client.getState(),
     client.getWWebVersion(),
+    client.getContactDeviceCount(msg.from),
+    client.getChats(),
   ]);
 
   const statsMessage = `
@@ -91,6 +95,8 @@ export default async function (msg: Message) {
 
     Status: ${waStatus}
     Version: ${waVersion}
+    Devices: ${deviceCount}
+    Chats: ${chats.length}
 
     \`${PROJECT_CANIS_ALIAS}\`
 

src/commands/unmute.ts

@@ -0,0 +1,20 @@
+import { Message } from "../../types/message";
+import log from "../components/utils/log";
+
+export const info = {
+  command: "unmute",
+  description: "Unmute this chat",
+  usage: "unmute",
+  example: "unmute",
+  role: "admin",
+  cooldown: 5000,
+};
+
+export default async function (msg: Message) {
+  if (!/^unmute/i.test(msg.body)) return;
+
+  const chat = await msg.getChat();
+  await chat.unmute();
+
+  await msg.reply("This chat is now unmuted.");
+}

src/components/events/groups/join.ts

@@ -39,6 +39,10 @@ export default async function (notif: GroupNotification) {
     if (newMembers.length > 0) {
       await notif.reply(getMessage("welcome", `*${newMembers.join(", ")}*`));
     }
+
+    // mute the chat forever
+    const chat = await notif.getChat();
+    await chat.mute();
   } catch (err) {
     log.error("GroupJoin", "Failed to process group join event:", err);
   }