From 55b3e83ae6e6802b36157e24dc989105ab3a5bf7 Mon Sep 17 00:00:00 2001 From: Hongbo Wu Date: Thu, 22 Aug 2024 11:23:29 +0800 Subject: [PATCH] add debugging logs for inbound-email-handler and keep email job data once completed or failed --- packages/inbound-email-handler/src/index.ts | 7 +++++-- packages/inbound-email-handler/src/job.ts | 2 -- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/packages/inbound-email-handler/src/index.ts b/packages/inbound-email-handler/src/index.ts index 8d3232109..5b7f4d33f 100644 --- a/packages/inbound-email-handler/src/index.ts +++ b/packages/inbound-email-handler/src/index.ts @@ -55,7 +55,10 @@ export const inboundEmailHandler = Sentry.GCPFunction.wrapHttpFunction( console.log('no data or name for ', part) } } + console.log('parsed', parsed) + const headers = parseHeaders(parsed.headers) + console.log('headers', headers) // original sender email address const from = parsed['from'] @@ -89,7 +92,7 @@ export const inboundEmailHandler = Sentry.GCPFunction.wrapHttpFunction( // check if it is a subscription or google confirmation email const isGoogleConfirmation = isGoogleConfirmationEmail(from, subject) if (isGoogleConfirmation || isSubscriptionConfirmationEmail(subject)) { - console.debug('handleConfirmation', from, subject) + console.log('handleConfirmation', from, subject) // we need to parse the confirmation code from the email if (isGoogleConfirmation) { await handleGoogleConfirmationEmail( @@ -114,7 +117,7 @@ export const inboundEmailHandler = Sentry.GCPFunction.wrapHttpFunction( return res.send('ok') } if (attachments.length > 0) { - console.debug('handle attachments', from, to, subject) + console.log('handle attachments', from, to, subject) // save the attachments as articles await handleAttachments( redisDataSource, diff --git a/packages/inbound-email-handler/src/job.ts b/packages/inbound-email-handler/src/job.ts index 2d379daf5..5e336329c 100644 --- a/packages/inbound-email-handler/src/job.ts +++ b/packages/inbound-email-handler/src/job.ts @@ -49,8 +49,6 @@ const getPriority = (jobType: EmailJobType): number => { const getOpts = (jobType: EmailJobType): BulkJobOptions => { return { - removeOnComplete: true, - removeOnFail: true, attempts: 3, priority: getPriority(jobType), backoff: {