fix: email bcc bug

backend/src/email/services/email-transactional.service.ts

@@ -191,6 +191,7 @@ async function handleStatusCallbacks(
       }
       break
     case SesEventType.Open:
+      // Cannot check that open applies to the main recipient
       await EmailMessageTransactional.update(
         {
           status: TransactionalEmailMessageStatus.Opened,
@@ -202,6 +203,7 @@ async function handleStatusCallbacks(
       )
       break
     case SesEventType.Send:
+      // Cannot check that send applies to the main recipient
       await EmailMessageTransactional.update(
         {
           status: TransactionalEmailMessageStatus.Sent,

backend/src/email/utils/callback/parsers/ses.ts

@@ -137,6 +137,14 @@ const parseNotificationAndEvent = async (
   message: any,
   metadata: Metadata
 ): Promise<void> => {
+  if (!isNotificationAndEventForMainRecipient(message, type)) {
+    logger.info({
+      message: 'SES notification or event is not for the main recipient',
+      action: 'filterNotification',
+      body: message,
+    })
+    return
+  }
   switch (type) {
     case SesEventType.Delivery:
       await updateDeliveredStatus(metadata)
@@ -250,4 +258,32 @@ const parseRecord = async (record: SesRecord): Promise<void> => {
   }
 }
 
+// Checks whether the notification/event is meant for the main recipient of the email.
+function isNotificationAndEventForMainRecipient(
+  message: any,
+  type: SesEventType
+): boolean {
+  // We cannot filter "OPEN" and "SEND" events due to the response given by AWS SES
+  if (type === SesEventType.Open || type === SesEventType.Send) {
+    return true
+  }
+  const mainRecipient: string = message?.mail?.commonHeaders?.to[0]
+  if (!mainRecipient) {
+    throw new Error('Failed to find main recipient in message')
+  }
+  const mainRecipientDelivered = message?.delivery?.recipients?.some(
+    (e: string) => e === mainRecipient
+  )
+  const mainRecipientBounced = message.bounce?.bouncedRecipients?.some(
+    (e: any) => e.emailAddress === mainRecipient
+  )
+  const mainRecipientComplained = message.complaint?.complainedRecipients?.some(
+    (e: any) => e.emailAddress === mainRecipient
+  )
+
+  return (
+    mainRecipientBounced || mainRecipientDelivered || mainRecipientComplained
+  )
+}
+
 export { HttpEvent, SesRecord, isEvent, parseRecord, validateSignature }