repair resend notif wa

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) {

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 {
+      try {
-            console.log(`Mengirim ke: ${user.contact_phone}`);
+        const tokenRedirect = await generateTokenRedirect(
+          user.contact_phone,
+          user.contact_name,
+          id
+        );
+        const encodedToken = encodeURIComponent(tokenRedirect);
+        const shortUrl = await shortUrltiny(encodedToken);
 
-            const tokenRedirect = await generateTokenRedirect(user.contact_phone, user.contact_name, id);
+        const bodyWithUrl =
-            const encodedToken = encodeURIComponent(tokenRedirect);
+          `Hai ${user.contact_name || "-"}\n` +
-            
+          `Terjadi peringatan dengan kode ${errorCode?.error_code || "-"} - ${
-            const shortUrl = await shortUrltiny(encodedToken);
+            errorCode?.error_code_name
-            console.log(`Link: ${shortUrl}`);
+          } pada device ${deviceNotification.device_name || "-"}.\n` +
+          `Silahkan cek detail pada link berikut:\n ${shortUrl}`;
 
-            const bodyWithUrl = `Hai ${user.contact_name || "-"}\n` +
+        const resultSend = await sendNotifikasi(
-                `Terjadi peringatan dengan kode ${errorCode?.error_code || "-"} - ${errorCode?.error_code_name}  pada device ${deviceNotification.device_name || "-"}.\n` +
+          user.contact_phone,
-                `silahkan cek detail pada link berikut:\n ${shortUrl}`;
+          bodyWithUrl
+        );
 
-            const resultSend = await sendNotifikasi(user.contact_phone, bodyWithUrl);
+        const isSuccess = resultSend?.error ? false : true;
-            
-            console.log(`WHATSAPP API Respon:`, JSON.stringify(resultSend));
 
-            const isSuccess = !resultSend?.error;
+        await updateNotificationErrorDb(user.notification_error_id, {
+          is_send: isSuccess,
+          is_delivered: isSuccess,
+        });
 
-            await updateNotificationErrorDb(user.notification_error_id, {
+        return { phone: user.contact_phone, status: true };
-                is_send: isSuccess,
+      } catch (err) {
-                is_delivered: isSuccess,
-            });
 
-        } catch (err) {
+        console.log(`Gagal mengirim ke ${user.contact_phone}:`, err.message);
-            console.log(`error pada ${user.contact_phone}:`, err.message);
+        return {
-        }
+          phone: user.contact_phone,
-    }
+          status: "failed",
-    console.log(` pesan untuk ID: ${id} selesai diproses.`);
+          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}`
+    );
+  }
 }
 
 module.exports = NotificationService;