yogiedigital/cod-api
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request 'repair: resend wa' (#29) from wisdom into main

Browse Source 
Reviewed-on: #29
This commit is contained in:
Bragas Rexita Ecos Fernanda
2026-01-07 05:18:12 +00:00
parent ed77576958 2a25339478
commit f5494fb4a1
1 changed files with 34 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

69
services/notification_error.service.js
View File

@@ -172,58 +172,57 @@ class NotificationService {
static async resendNotification(id) {
const deviceNotification = await getNotificationByIdDb(id);
if (!deviceNotification) throw new ErrorHandler(404, "Notification Data not found");
if (!deviceNotification) throw new ErrorHandler(404, "Data not found");
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 found");
}
if (activeUsers.length < 1) throw new ErrorHandler(404, "No active contacts");
this._executeResendInBackground(id, activeUsers, deviceNotification, errorCode)
.catch(err => console.error("Background Resend Error:", err));
.catch(err => console.log("error:", err));
return {
message: "Notification Error resend has prosseced",
total_users: activeUsers.length,
status: true
status: "success",
message: "Pesan sedang diproses di background",
count: activeUsers.length
};
}
static async _executeResendInBackground(id, activeUsers, deviceNotification, errorCode) {
const batchSize = 100;
for (let i = 0; i < activeUsers.length; i += batchSize) {
const batch = activeUsers.slice(i, i + batchSize);
await Promise.all(batch.map(async (user) => {
try {
const tokenRedirect = await generateTokenRedirect(user.contact_phone, user.contact_name, id);
const encodedToken = encodeURIComponent(tokenRedirect);
const shortUrl = await shortUrltiny(encodedToken);
console.log(`Background process untuk ID: ${id}`);
const bodyWithUrl =
`Hai ${user.contact_name || "-"}\n` +
`Terjadi peringatan dengan kode error ${errorCode?.error_code || "-"} - ${errorCode?.error_code_name || "-"} ` +
`pada device ${deviceNotification.device_name || "-"}, silahkan cek detail pada link berikut:\n` +
`${shortUrl}`;
for (const user of activeUsers) {
try {
console.log(`Mengirim ke: ${user.contact_phone}`);
const resultSend = await sendNotifikasi(user.contact_phone, bodyWithUrl);
const isSuccess = !resultSend?.error;
const tokenRedirect = await generateTokenRedirect(user.contact_phone, user.contact_name, id);
const encodedToken = encodeURIComponent(tokenRedirect);
const shortUrl = await shortUrltiny(encodedToken);
console.log(`Link: ${shortUrl}`);
await updateNotificationErrorDb(user.notification_error_id, {
is_send: isSuccess,
is_delivered: isSuccess,
});
} catch (err) {
console.error(`Error sending to ${user.contact_phone}:`, err.message);
}
}));
await new Promise(resolve => setTimeout(resolve, 500));
const bodyWithUrl = `Hai ${user.contact_name || "-"}\n` +
`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);
console.log(`WHATSAPP API Respon:`, JSON.stringify(resultSend));
const isSuccess = !resultSend?.error;
await updateNotificationErrorDb(user.notification_error_id, {
is_send: isSuccess,
is_delivered: isSuccess,
});
} catch (err) {
console.log(`error pada ${user.contact_phone}:`, err.message);
}
}
console.log(` pesan untuk ID: ${id} selesai diproses.`);
}
}