¿Cómo implementar el patrón Inbox en el lado del servicio de notificación para garantizar el procesamiento de mensajes?

Inbox Pattern используется для гарантии обработки сообщений в распределённых системах. В сервисе Notification его можно реализовать следующим образом:

1. При получении сообщения сервис сохраняет его в специальную таблицу "Inbox" с уникальным идентификатором и статусом "новое".
2. Затем сервис обрабатывает сообщение (например, отправляет уведомление).
3. После успешной обработки обновляет статус записи в таблице на "обработано".

Это позволяет избежать повторной обработки одного и того же сообщения при сбоях или повторных доставках, так как перед обработкой проверяется наличие записи в Inbox и её статус.

Пример таблицы Inbox:

message_id	payload	status	received_at
12345	{...}	new	2024-06-01 10:00:00

Пример кода на псевдо-JavaScript:

async function processMessage(message) {
  const exists = await inboxTable.find({ message_id: message.id });
  if (exists && exists.status === 'processed') {
    return; // Уже обработано
  }
  if (!exists) {
    await inboxTable.insert({ message_id: message.id, payload: message.payload, status: 'new', received_at: new Date() });
  }

  // Обработка сообщения
  await sendNotification(message.payload);

  // Обновление статуса
  await inboxTable.update({ message_id: message.id }, { status: 'processed' });
}