repair resend notif wa

Reviewed-on: #29

.gitignore

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

db/notification_wa.db.js

@@ -1,10 +1,10 @@
 const { default: axios } = require('axios');
 const CryptoJS = require('crypto-js');
-const https = require('https');
+// const https = require('https');
 
-const httpsAgent = new https.Agent({
+// const httpsAgent = new https.Agent({
-  rejectUnauthorized: false,
+//   rejectUnauthorized: false,
-});
+// });
 
 const generateTokenRedirect = async (userPhone, userName, id) => {
 
@@ -23,7 +23,7 @@ const shortUrltiny = async (encodedToken) => {
 
   const encodedUrl = encodeURIComponent(url); // ⬅️ Encode dulu!
 
-  const response = await axios.get(`https://tinyurl.com/api-create.php?url=${encodedUrl}`,{ httpsAgent });
+  const response = await axios.get(`https://tinyurl.com/api-create.php?url=${encodedUrl}`);
 
   let shortUrl = response.data;
   if (!shortUrl.startsWith('http')) {
@@ -44,7 +44,7 @@ const sendNotifikasi = async (phone, message) => {
   const endPointWhatsapp = process.env.ENDPOINT_WHATSAPP;
 
   try {
-    const response = await axios.post(endPointWhatsapp, payload, { httpsAgent });
+    const response = await axios.post(endPointWhatsapp, payload);
     // console.log(response.data);
     return response?.data
   } catch (error) {

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

@@ -172,58 +172,86 @@ 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 getErrorCodeByIdDb(deviceNotification.error_code_id);
+    const errorCode = await getErrorCodeByIdDb(
+      deviceNotification.error_code_id
+    );
     const dataExist = await getUsersNotificationErrorDb(id);
-    const activeUsers = dataExist?.filter((user) => user.is_active === true) || [];
 
-    if (activeUsers.length < 1) throw new ErrorHandler(404, "No active contacts");
+    const activeUsers =
+      dataExist?.filter((user) => user.is_active === true) || [];
 
-    this._executeResendInBackground(id, activeUsers, deviceNotification, errorCode)
+    if (activeUsers.length < 1)
-        .catch(err => console.log("error:", err));
+      throw new ErrorHandler(404, "No active contacts");
+
+    this._executeResendWA(id, activeUsers, deviceNotification, errorCode).catch(
+      (err) => console.error("process error:", err)
+    );
 
     return {
-        status: "success",
+      count: activeUsers.length,
-        message: "Pesan sedang diproses di background",
-        count: activeUsers.length
     };
-}
+  }
 
-static async _executeResendInBackground(id, activeUsers, deviceNotification, errorCode) {
+  static async _executeResendWA(
-    console.log(`Background process untuk ID: ${id}`);
+    id,
+    activeUsers,
+    deviceNotification,
+    errorCode
+  ) {
+    console.log(`process id: ${id}`);
 
-    for (const user of activeUsers) {
+    const sendPromises = activeUsers.map(async (user) => {
       try {
-            console.log(`Mengirim ke: ${user.contact_phone}`);
+        const tokenRedirect = await generateTokenRedirect(
-
+          user.contact_phone,
-            const tokenRedirect = await generateTokenRedirect(user.contact_phone, user.contact_name, id);
+          user.contact_name,
+          id
+        );
         const encodedToken = encodeURIComponent(tokenRedirect);
-            
         const shortUrl = await shortUrltiny(encodedToken);
-            console.log(`Link: ${shortUrl}`);
 
-            const bodyWithUrl = `Hai ${user.contact_name || "-"}\n` +
+        const bodyWithUrl =
-                `Terjadi peringatan dengan kode ${errorCode?.error_code || "-"} - ${errorCode?.error_code_name}  pada device ${deviceNotification.device_name || "-"}.\n` +
+          `Hai ${user.contact_name || "-"}\n` +
-                `silahkan cek detail pada link berikut:\n ${shortUrl}`;
+          `Terjadi peringatan dengan kode ${errorCode?.error_code || "-"} - ${
+            errorCode?.error_code_name
+          } pada device ${deviceNotification.device_name || "-"}.\n` +
+          `Silahkan cek detail pada link berikut:\n ${shortUrl}`;
 
-            const resultSend = await sendNotifikasi(user.contact_phone, bodyWithUrl);
+        const resultSend = await sendNotifikasi(
+          user.contact_phone,
+          bodyWithUrl
+        );
 
-            console.log(`WHATSAPP API Respon:`, JSON.stringify(resultSend));
+        const isSuccess = resultSend?.error ? false : true;
-
-            const isSuccess = !resultSend?.error;
 
         await updateNotificationErrorDb(user.notification_error_id, {
           is_send: isSuccess,
           is_delivered: isSuccess,
         });
 
+        return { phone: user.contact_phone, status: true };
       } catch (err) {
-            console.log(`error pada ${user.contact_phone}:`, err.message);
+
+        console.log(`Gagal mengirim ke ${user.contact_phone}:`, err.message);
+        return {
+          phone: user.contact_phone,
+          status: "failed",
+          error: err.message,
+        };
       }
+    });
+
+    const results = await Promise.all(sendPromises);
+
+    console.log(
+      `Notification resend has been succesfully: ${
+        results.filter((r) => r.status === "success").length
+      }, Error: ${results.filter((r) => r.status === "failed").length}`
+    );
   }
-    console.log(` pesan untuk ID: ${id} selesai diproses.`);
-}
 }
 
 module.exports = NotificationService;