Как должен быть устроен слой приема события — и можно ли доверять событию, которое пришло от внешней системы?

Зачем нужен отдельный слой приема событий

В событийно-ориентированной архитектуре внешние системы могут отправлять события в вашу систему. Если принимать их напрямую в бизнес-логику, вы рискуете получить некорректные данные, дубликаты или даже атаки. Поэтому слой приема события — это пограничный компонент, который выполняет несколько задач: принимает событие, проверяет его, преобразует в внутренний формат и передает дальше в обработчики.

Доверие к внешним событиям

Внешнее событие — это данные, которые вы не контролируете. Оно может быть изменено злоумышленником, содержать ошибки или не соответствовать ожидаемой структуре. Поэтому нельзя доверять событию без проверки. Основные меры: аутентификация источника (например, через API-ключи или JWT), проверка целостности (подпись или HMAC), валидация схемы (например, JSON Schema) и санитизация данных.

Практический пример

Предположим, внешняя система отправляет событие о новом заказе. Слой приема может выглядеть так:

// Псевдокод на Node.js
const express = require('express');
const app = express();

app.post('/events/order', (req, res) => {
  const event = req.body;
  // 1. Проверка подписи
  if (!verifySignature(req.headers['x-signature'], event)) {
    return res.status(401).send('Invalid signature');
  }
  // 2. Валидация схемы
  if (!validateOrderSchema(event)) {
    return res.status(400).send('Invalid event format');
  }
  // 3. Нормализация и сохранение
  const normalized = normalizeOrder(event);
  saveToQueue(normalized);
  res.status(202).send('Accepted');
});

Здесь слой приема изолирует внешний мир от внутренней логики. Если событие не прошло проверку, оно отклоняется, и система остается безопасной.

Вывод

Слой приема события обязателен в любой системе, которая интегрируется с внешними источниками. Он обеспечивает безопасность, надежность и согласованность данных. Применяйте его всегда, когда событие приходит извне, чтобы защитить ядро системы от некорректных или вредоносных данных.