diff --git a/email_api/email_api/app.js b/email_api/email_api/app.js index bc9563e..804ea84 100644 --- a/email_api/email_api/app.js +++ b/email_api/email_api/app.js @@ -138,6 +138,8 @@ app.post('/process/:domain', async (req, res) => { logger.info(`[${requestId}] INCOMING POST /process/${domain}: payload_summary=${JSON.stringify(payloadSummary)}`); let recipients = []; + let parser; + let fromAddr = `lambda@${req.params.domain}`; try { // Decode and parse email const content = data.email_content; @@ -146,8 +148,8 @@ app.post('/process/:domain', async (req, res) => { const emailBytes = compressed ? gunzipSync(Buffer.from(raw, 'binary')).toString('binary') : raw; const emailBuffer = Buffer.from(emailBytes, 'binary'); - const parser = await simpleParser(emailBuffer); - const fromAddr = parser.from?.value[0]?.address || `lambda@${domain}`; + parser = await simpleParser(emailBuffer); + fromAddr = parser.from?.value[0]?.address || `lambda@${domain}`; recipients = [ ...(parser.to?.value || []), ...(parser.cc?.value || []),