Duplicate notification
+ missing follower email

// BUG: forEach là sync, sendMailQueue.add trả Promise không await
membersToSendEmail.forEach((subscriber) => {
  this.sendMailQueue.add({
    receiver: subscriber.email,
    subject: publicVideoForSubscribers.subject,
    content: format(...),
    summary: NotificationRedirectType[PUBLIC_VIDEO_FOR_FOLLOWER],
    memberId: subscriber.id,
    senderId: owner.id,
    emailType: EmailType.CONTENT_VIDEO,
  });  // ← Promise bay vào event loop, KHÔNG đợi
});

await Promise.all(
  membersToSendEmail.map((subscriber) =>
    this.sendMailQueue.add({...})
  )
);

async deleteMessageBatch(messages: AWS.SQS.Message[]) {
  const producer = this.sqsService.producers.get(this.queueName);
  producer.sqs.deleteMessageBatch({...}, (err) => {
    if (err) console.error(...);
    else     console.log(...);
  });  // ← callback style, không await, không retry
}

async deleteMessageBatch(messages: AWS.SQS.Message[]) {
  const producer = this.sqsService.producers.get(this.queueName);
  await producer.sqs.deleteMessageBatch({
    QueueUrl: producer.queueUrl,
    Entries: messages.map(m => ({ Id: m.MessageId, ReceiptHandle: m.ReceiptHandle })),
  }).promise();  // ← promisify + await, surface error
}

outputObject.forEach(async (output) => {  // ← forEach không await async callbacks
  const video = await videoRepository.findOne({
    where: { uniqueLink, status: PROCESS_HLS_VIDEO }
  });
  if (!!video && !!outputLink) {
    // transaction update + push notif + publishingVideoProducer.add
  }
});

• ▸forEach không await async callbacks → iterations chạy song song
• ▸Nếu MediaConvert callback outputObject có ≥2 entries match cùng uniqueLink, race condition khiến nhiều iteration cùng pass status check
• ▸Cùng enqueue PUBLISHING_VIDEO → 2 SQS message khác MessageId → worker xử lý song song
• ▸Trên video bug này KHÔNG kích hoạt — gap=300s xác nhận SQS retry, không phải race <5s

for (const output of outputObject) {
  await processOutput(output);  // sequential await
}

if (redirectType === NotificationRedirectType.PUBLIC_VIDEO_FOR_FOLLOWER) {
  // ... build content ...
  Object.assign(notification, { content });

  // const previousNotification = await this.findNotification(
  //   ['id', 'memberId', 'metadata'],
  //   {
  //     redirectType: PUBLIC_VIDEO_FOR_FOLLOWER,
  //     memberId,
  //     createdAt: moment().subtract(NOTIFICATION_COMBINATION_EXPIRE_IN_HOUR, 'hours').toDate(),
  //   },
  // );
  // if (previousNotification) { ... update existing row + uniqBy videos ... }
  // ← TOÀN BỘ logic UPSERT bị comment out
}

• ▸Các redirect type khác (HEART, STAR, GIVE_GIFT, COMMENT...) VẪN GIỮ previousNotification lookup → upsert đúng
• ▸Riêng PUBLIC_VIDEO_FOR_FOLLOWER bị comment out → mỗi consumer run = INSERT 1,482 row mới, không dedup
• ▸Combined với Bug #2 (SQS retry 300s): mỗi retry = thêm 1,482 row → 2,964 row sau 1 retry, 4,446 sau 2 retry, etc.
• ▸Mỗi follower cảm nhận nhiều thông báo cho cùng 1 video trong app (UX rất tệ)
• ▸Lý do comment out CHƯA RÕ — cần check git blame; có thể do bug regression nào đó trong upsert logic được patch tạm bằng cách bỏ luôn

// Uncomment previousNotification lookup + update logic
if (redirectType === NotificationRedirectType.PUBLIC_VIDEO_FOR_FOLLOWER) {
  // ... build content ...
  const previousNotification = await this.findNotification(
    ['id', 'memberId', 'metadata'],
    {
      redirectType: PUBLIC_VIDEO_FOR_FOLLOWER,
      memberId,
      createdAt: moment().subtract(NOTIFICATION_COMBINATION_EXPIRE_IN_HOUR, 'hours').toDate(),
    },
  );
  if (previousNotification) {
    metadata.videos.push(...videos);
    metadata.videos = _uniqBy(metadata.videos, 'id');  // ← key: dedup by video id
    Object.assign(notification, { id: previousNotification.id, metadata });
  }
}

Lưu ý: trước khi uncomment, cần verify lý do nó bị comment out ban đầu — có thể có bug regression. Nếu là regression đã fix → uncomment an toàn. Nếu không, cần re-test edge cases.