|
|
|
@@ -29,6 +29,15 @@ amqp.connect(process.env.AMQP_SERVER).then(async conn => { |
|
|
|
}).catch(console.warn) |
|
|
|
|
|
|
|
function sendReceipt(message) { |
|
|
|
try { |
|
|
|
const parsedData = JSON.parse(message.email); |
|
|
|
if (Array.isArray(parsedData)) { |
|
|
|
message.email = parsedData |
|
|
|
} |
|
|
|
} catch (error) { |
|
|
|
console.log("Data bukan dalam format JSON."); |
|
|
|
} |
|
|
|
|
|
|
|
const now = new Date() |
|
|
|
const msg = { |
|
|
|
to: message.email, |
|
|
|
|