diff --git a/index-nota.mjs b/index-nota.mjs index 9df873c..4e19459 100644 --- a/index-nota.mjs +++ b/index-nota.mjs @@ -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, diff --git a/index-payleter.mjs b/index-payleter.mjs index 32af953..9f0be0f 100644 --- a/index-payleter.mjs +++ b/index-payleter.mjs @@ -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,