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

Reviewed-on: #44

.gitignore

@@ -4,3 +4,4 @@ node_modules
 request.http
 *.rest
 package-lock.json
+*.log

ecosystem.config.js

@@ -1,7 +1,7 @@
 module.exports = {
   apps: [
     {
-      name: "bengkel-api",
+      name: "cod-api",
       script: "./index.js", // Path to your entry file
       env: {
         NODE_ENV: "development",
@@ -9,6 +9,14 @@ module.exports = {
       env_production: {
         NODE_ENV: "production",
       },
+      // Logging configuration
+      // error_file: "C:\IDETAMA\pm2-log\cod-api\cod-api-error.log",
+      // out_file: "C:\IDETAMA\pm2-log\cod-api\cod-api-out.log",
+      // log_file: "C:\IDETAMA\pm2-log\cod-api\cod-api-combined.log", // optional combined file
+      error_file: "cod-api-error.log",
+      out_file: "cod-api-out.log",
+      log_file: "cod-api-combined.log", // optional combined file
+      time: true, // adds timestamps to logs
     },
   ],
 };

services/notification_error.service.js

@@ -173,7 +173,8 @@ class NotificationService {
 
   static async resendNotification(id) {
     const deviceNotification = await getNotificationByIdDb(id);
-    if (!deviceNotification) throw new ErrorHandler(404, "Data not found");
+    if (!deviceNotification)
+      throw new ErrorHandler(404, "Notification Data not found");
 
     const errorCode = await getErrorCodeByBrandAndCodeDb(deviceNotification?.brand_id ?? 0,
       deviceNotification.error_code_id

services/notifikasi-wa.service.js

@@ -14,7 +14,10 @@ const {
 } = require("../db/notification_wa.db");
 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");
 
@@ -107,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,
@@ -146,41 +150,48 @@ class NotifikasiWaService {
   }
 
   async restartWhatsapp() {
-    return new Promise((resolve, reject) => {
-      exec('pm2 jlist', (err, stdout) => {
-        if (err) return reject({ success: false, message: "Error list PM2" });
-
     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 => 
+      const waProcess = processes.find((p) => p.name === processName);
-            p.name.toLowerCase().includes('whatsapp') || 
-            p.name.toLowerCase().includes('wa-api')
-          );
 
-          if (!waProcess) return reject({ success: false, message: "PM2 List PM2 Not Found" });
+      if (!waProcess) throw new Error(`PM2 ${processName} not found`);
 
-          const processId = waProcess.pm_id;
+      const waProcessId = waProcess.pm_id;
+      const pathDelete = waProcess.pm2_env.pm_cwd;
 
-          exec(`pm2 stop ${processId}`, () => {
+      // const execLogs = (cmd) => {
-            const paths = [
+      //   const p = exec(cmd);
-              path.join(__dirname, "../../.wwebjs_auth"),
+      //   p.stdout.pipe(process.stdout);
-              path.join(__dirname, "../../.wwebjs_cache")
+      //   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"),
       ];
 
-            paths.forEach(dir => {
+      // console.log(`path: ${pathDelete}`);
-              if (fs.existsSync(dir)) fs.rmSync(dir, { recursive: true, force: true });
-            });
 
-            exec(`pm2 restart ${processId}`, (reErr) => {
+      pathFolderDelete.forEach((dir) => {
-              if (reErr) return reject({ success: false, message: "Gagal restart" });
+        if (fs.existsSync(dir)) {
-              resolve({ success: true, message: `WA has been restart.` });
+          // console.log(`path folder: ${dir}`);
-            });
+          fs.rmSync(dir, { recursive: true, force: true });
-          });
-        } catch (e) {
-          reject({ success: false, message: "JSON Parse Error: " + e.message });
         }
       });
-    });
+
+      // 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;
+    }
   }
 }