Compare commits
3 Commits
2a2df58b7d
...
wisdom
| Author | SHA1 | Date | |
|---|---|---|---|
| 436ea1cf89 | |||
| 8e0dc4bb88 | |||
| b680a249d5 |
@@ -292,11 +292,11 @@ const mqttOptions = {
|
||||
clientId: 'express_mqtt_client_' + Math.random().toString(16).substr(2, 8),
|
||||
clean: true,
|
||||
connectTimeout: 4000,
|
||||
username: '', // jika ada
|
||||
password: '', // jika ada
|
||||
username: 'morekmorekmorek', // jika ada
|
||||
password: 'morek888', // jika ada
|
||||
};
|
||||
|
||||
const mqttUrl = 'ws://localhost:1884'; // Ganti dengan broker kamu
|
||||
const mqttUrl = 'ws://117.102.231.130:7001'; // Ganti dengan broker kamu
|
||||
const topic = process.env.TOPIC_COD ?? 'morek';
|
||||
|
||||
const mqttClient = mqtt.connect(mqttUrl, mqttOptions);
|
||||
|
||||
@@ -104,6 +104,8 @@ class AuthController {
|
||||
const bytes = CryptoJS.AES.decrypt(tokenRedirect, process.env.VITE_KEY_SESSION);
|
||||
const decrypted = JSON.parse(bytes.toString(CryptoJS.enc.Utf8));
|
||||
|
||||
console.log("decrypted: ", decrypted);
|
||||
|
||||
const userPhone = decrypted?.user_phone
|
||||
const userName = decrypted?.user_name
|
||||
const idData = decrypted?.id
|
||||
|
||||
@@ -95,7 +95,8 @@ const getAllNotificationDb = async (searchParams = {}) => {
|
||||
],
|
||||
queryParams
|
||||
);
|
||||
if (whereParamAnd) queryParams = whereParamAnd;
|
||||
|
||||
queryParams = whereParamAnd ? whereParamAnd : queryParams;
|
||||
|
||||
const queryText = `
|
||||
SELECT
|
||||
@@ -108,12 +109,12 @@ const getAllNotificationDb = async (searchParams = {}) => {
|
||||
a.is_delivered,
|
||||
a.is_read,
|
||||
a.is_active,
|
||||
a.created_at,
|
||||
|
||||
b.error_code,
|
||||
b.error_code_name,
|
||||
b.error_code_color,
|
||||
b.path_icon,
|
||||
b.created_at,
|
||||
|
||||
c.solution_name,
|
||||
c.type_solution,
|
||||
|
||||
@@ -67,8 +67,8 @@ class NotifikasiWaService {
|
||||
for (const dataUser of dataUsers) {
|
||||
if (dataUser.is_active) {
|
||||
const tokenRedirect = await generateTokenRedirect(
|
||||
dataUser.userPhone,
|
||||
dataUser.userName,
|
||||
dataUser.contact_phone,
|
||||
dataUser.contact_name,
|
||||
resultNotificationError.notification_error_id
|
||||
);
|
||||
|
||||
@@ -105,6 +105,8 @@ class NotifikasiWaService {
|
||||
param.bodyMessage
|
||||
);
|
||||
|
||||
console.log("resultSend: ", resultSend);
|
||||
|
||||
await updateNotificationErrorUserDb(
|
||||
resultNotificationErrorUser[0].notification_error_user_id,
|
||||
{
|
||||
|
||||
Reference in New Issue
Block a user