Merge pull request 'wisdom' (#44) from wisdom into main

Reviewed-on: #44

db/notification_error.db.js

@@ -21,7 +21,8 @@ const getNotificationByIdDb = async (id) => {
       d.device_name,
       d.device_location,
       d.listen_channel,
-      e.brand_name
+      e.brand_name,
+      e.brand_id
 
     FROM notification_error a
 

db/notification_error_user.db.js

@@ -67,7 +67,9 @@ const getNotificationErrorUserByIdDb = async (id) => {
       d.error_code,
       d.error_code_name,
 
-      e.device_name
+      e.device_name,
+
+      c.error_chanel as chanel_id
       
     FROM notification_error_user a
     

package.json

@@ -47,6 +47,7 @@
     "nodemailer": "^6.8.0",
     "pg": "^8.8.0",
     "pino": "^6.11.3",
+    "pm2": "^6.0.14",
     "stripe": "^8.138.0",
     "svg-captcha": "^1.4.0",
     "swagger-ui-express": "^4.6.0",

routes/index.js

@@ -19,7 +19,8 @@ const notificationErrorSparepart = require("./notification_error_sparepart.route
 const sparepart = require("./sparepart.route")
 const notificationErrorLog = require("./notification_error_log.route")
 const notificationErrorUser = require("./notification_error_user.route")
-const errorCode = require("./error_code.route")
+const errorCode = require("./error_code.route");
+const notifikasiWA = require("./notifikasi-wa.route");
 
 router.use("/auth", auth);
 router.use("/user", users);
@@ -42,5 +43,6 @@ router.use("/sparepart", sparepart)
 router.use("/notification-log", notificationErrorLog)
 router.use("/notification-user", notificationErrorUser)
 router.use("/error-code", errorCode)
+router.use("/notifikasi-wa", notifikasiWA)
 
 module.exports = router;

routes/notifikasi-wa.route.js

@@ -0,0 +1,14 @@
+const express = require('express');
+const router = express.Router();
+const NotifikasiWaService = require('../services/notifikasi-wa.service');
+
+router.post('/restart-wa', async (req, res) => {
+  try {
+    const result = await NotifikasiWaService.restartWhatsapp();
+    return res.status(200).json(result);
+  } catch (error) {
+    return res.status(500).json(error);
+  }
+});
+
+module.exports = router;

services/notification_error.service.js

@@ -7,7 +7,7 @@ const {
   updateNotificationErrorDb,
 } = require("../db/notification_error.db");
 
-const { getErrorCodeByIdDb } = require("../db/brand_code.db");
+const { getErrorCodeByIdDb, getErrorCodeByBrandAndCodeDb } = require("../db/brand_code.db");
 
 const { getSolutionsByErrorCodeIdDb } = require("../db/brand_code_solution.db");
 
@@ -176,7 +176,7 @@ class NotificationService {
     if (!deviceNotification)
       throw new ErrorHandler(404, "Notification Data not found");
 
-    const errorCode = await getErrorCodeByIdDb(
+    const errorCode = await getErrorCodeByBrandAndCodeDb(deviceNotification?.brand_id ?? 0,
       deviceNotification.error_code_id
     );
     const dataExist = await getUsersNotificationErrorDb(id);
@@ -209,7 +209,7 @@ class NotificationService {
 
     const sendPromises = activeUsers.map(async (user) => {
       try {
-       console.log(`user: ${user.contact_name} (${user.contact_phone})`);
+        console.log(`user: ${user.contact_name} (${user.contact_phone})`);
         const tokenRedirect = await generateTokenRedirect(
           user.contact_phone,
           user.contact_name,
@@ -222,17 +222,17 @@ class NotificationService {
         console.log("URL:", shortUrl);
 
         const bodyWithUrl =
-          `Hai ${user.contact_name || "-"}\n` +
+          `Hai ${user.contact_name || "-"},\n` +
-          `Terjadi peringatan dengan kode ${errorCode?.error_code || "-"} - ${
+          `Terjadi peringatan dengan kode ${errorCode?.error_code ?? "-"} "${errorCode?.error_code_name}", Chanel ${deviceNotification?.error_chanel ?? "-"} ` +
-            errorCode?.error_code_name
+          `pada device ${deviceNotification.device_name ?? "berikut"}` +
-          } pada device ${deviceNotification.device_name || "-"}.\n` +
+          `\nSilahkan cek detail pada link :` +
-          `Silahkan cek detail pada link berikut:\n ${shortUrl}`;
+          `${shortUrl}`;
 
         const resultSend = await sendNotifikasi(
           user.contact_phone,
           bodyWithUrl
         );
-        
+
         console.log("notifikasi wa:", resultSend)
 
         const isSuccess = resultSend.success;
@@ -257,8 +257,7 @@ class NotificationService {
     console.log("result akhir: ", results)
 
     console.log(
-      `Resend chat: ${
+      `Resend chat: ${results.filter((r) => r.status === "success").length
-        results.filter((r) => r.status === "success").length
       }, Gagal: ${results.filter((r) => r.status === "failed").length}`
     );
   }

services/notification_error_user.service.js

@@ -20,7 +20,7 @@ class NotificationErrorUserService {
     try {
       const results = await getAllNotificationErrorUserDb(param);
 
-      results.data.map((element) => {});
+      results.data.map((element) => { });
 
       return results;
     } catch (error) {
@@ -139,13 +139,10 @@ class NotificationErrorUserService {
         const shortUrl = await shortUrltiny(encodedToken);
 
         const bodyWithUrl =
-          `Hai ${data.contact_name || "-"}\n` +
+          `Hai ${data.contact_name || "-"},\n` +
-          `Terjadi peringatan dengan kode error ${data.error_code || "-"} - ${
+          `Terjadi peringatan dengan kode ${data?.error_code ?? "-"} "${data?.error_code_name ?? ""}", Chanel ${data?.chanel_id ?? "-"} ` +
-            data.error_code_name || "-"
+          `pada device ${data?.device_name ?? "berikut"},` +
-          } ` +
+          `\nSilahkan cek detail pada link :` +
-          `pada device ${
-            data.device_name || "-"
-          }, silahkan cek detail pada link berikut:\n` +
           `${shortUrl}`;
 
         const resultSend = await sendNotifikasi(
@@ -165,9 +162,8 @@ class NotificationErrorUserService {
           results.push({
             id,
             status: "failed",
-            message: `WhatsApp API Gagal: ${
+            message: `WhatsApp API Gagal: ${resultSend?.message || "Unknown Error"
-              resultSend?.message || "Unknown Error"
+              }`,
-            }`,
           });
         } else {
           results.push({

services/notifikasi-wa.service.js

@@ -1,5 +1,8 @@
 const { getAllContactDb } = require("../db/contact.db");
-const { InsertNotificationErrorDb, updateNotificationErrorDb } = require("../db/notification_error.db");
+const {
+  InsertNotificationErrorDb,
+  updateNotificationErrorDb,
+} = require("../db/notification_error.db");
 const {
   createNotificationErrorUserDb,
   updateNotificationErrorUserDb,
@@ -12,6 +15,12 @@ const {
 const { getErrorCodeByBrandAndCodeDb } = require("../db/brand_code.db");
 const { getDeviceNotificationByIdDb } = require("../db/notification_error.db");
 
+const { exec } = require("child_process");
+const util = require("util");
+const execPromise = util.promisify(exec);
+const fs = require("fs");
+const path = require("path");
+
 class NotifikasiWaService {
   async onNotification(topic, message) {
     try {
@@ -52,7 +61,10 @@ class NotifikasiWaService {
             Number(chanel.chanel_id)
           );
 
-          const errorCode = await getErrorCodeByBrandAndCodeDb(deviceNotification?.brand_id ?? 0, chanel.value);
+          const errorCode = await getErrorCodeByBrandAndCodeDb(
+            deviceNotification?.brand_id ?? 0,
+            chanel.value
+          );
 
           const data = {
             error_code_id: chanel.value,
@@ -65,7 +77,7 @@ class NotifikasiWaService {
 
           const resultNotificationError = await InsertNotificationErrorDb(data);
 
-          let isSendNotification = false
+          let isSendNotification = false;
 
           for (const dataUser of dataUsers) {
             if (dataUser.is_active) {
@@ -80,10 +92,12 @@ class NotifikasiWaService {
               const shortUrl = await shortUrltiny(encodedToken);
 
               const bodyMessage =
-                `Hai ${dataUser.contact_name || "-"}\n` +
+                `Hai ${dataUser.contact_name || "-"},\n` +
-                `Terjadi kode error ${chanel?.value ?? "-"} ${errorCode?.error_code_name ?? ""}Chanel ${chanel?.chanel_id ?? "-"} ` +
+                `Terjadi peringatan dengan kode ${chanel?.value ?? "-"} "${
-                `pada device ${deviceNotification?.device_name ?? "berikut"
+                  errorCode?.error_code_name ?? ""
-                }, Silahkan cek detail pada link berikut:\n` +
+                }", Chanel ${chanel?.chanel_id ?? "-"} ` +
+                `pada device ${deviceNotification?.device_name ?? "berikut"},` +
+                `\nSilahkan cek detail pada link :` +
                 `${shortUrl}`;
 
               const param = {
@@ -96,6 +110,7 @@ class NotifikasiWaService {
               const resultNotificationErrorUser =
                 await createNotificationErrorUserDb({
                   notification_error_id: param.idData,
+
                   contact_phone: param.userPhone,
                   contact_name: param.userName,
                   message_error_issue: param.bodyMessage,
@@ -107,8 +122,6 @@ class NotifikasiWaService {
                 param.bodyMessage
               );
 
-
-
               await updateNotificationErrorUserDb(
                 resultNotificationErrorUser[0].notification_error_user_id,
                 {
@@ -117,7 +130,7 @@ class NotifikasiWaService {
               );
 
               if (resultSend.success) {
-                isSendNotification = resultSend.success
+                isSendNotification = resultSend.success;
               }
             }
           }
@@ -131,9 +144,53 @@ class NotifikasiWaService {
           );
         }
       }
-    } catch (error) {
+    } catch (err) {
-      // throw new ErrorHandler(error.statusCode, error.message);
+      return err;
-      return error;
+    }
+  }
+
+  async restartWhatsapp() {
+    try {
+      const processName = "Whatsapp-API-notification" && "cod-whatsapp-notif";
+      const { stdout } = await execPromise("pm2 jlist");
+      const processes = JSON.parse(stdout);
+      const waProcess = processes.find((p) => p.name === processName);
+
+      if (!waProcess) throw new Error(`PM2 ${processName} not found`);
+
+      const waProcessId = waProcess.pm_id;
+      const pathDelete = waProcess.pm2_env.pm_cwd;
+
+      // const execLogs = (cmd) => {
+      //   const p = exec(cmd);
+      //   p.stdout.pipe(process.stdout);
+      //   p.stderr.pipe(process.stderr);
+      //   return new Promise((res) => p.on("exit", res));
+      // };
+
+      // console.log(`stop proses id: ${waProcessId}`)
+      await execPromise(`start powershell -Command "pm2 stop ${waProcessId}"`);
+
+      const pathFolderDelete = [
+        path.join(pathDelete, ".wwebjs_auth"),
+        path.join(pathDelete, ".wwebjs_cache"),
+      ];
+
+      // console.log(`path: ${pathDelete}`);
+
+      pathFolderDelete.forEach((dir) => {
+        if (fs.existsSync(dir)) {
+          // console.log(`path folder: ${dir}`);
+          fs.rmSync(dir, { recursive: true, force: true });
+        }
+      });
+
+      // console.log(`start proses id: ${waProcessId}`);
+      await execPromise(`start powershell -Command "pm2 start ${waProcessId}"`);
+
+      return { success: true, message: "WhatsApp has been restarted." };
+    } catch (err) {
+      return err;
     }
   }
 }