Проверка / применение инвариантов в приложении CQRS

У вас есть бизнес-процесс, который охватывает несколько агрегатов, это точно. Для этого у вас есть два варианта:

1. Измените границу агрегатов, объединив несколько типов агрегатов в один. Код проще, компенсации выполняются базой данных автоматически при откате. Масштабируемость не так велика.

2. Используйте сагу для моделирования всего процесса. Вам нужно отправлять компенсирующие команды для каждого сбоя. Это вариант, о котором я напишу в оставшейся части ответа.

В основном вам приходится выбирать между одной большой (глобальной) транзакцией и несколькими меньшими (локальными) транзакциями.

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

Бизнес-правила (инварианты) должны проверяться каждым Агрегатом, которому принадлежат данные, необходимые для проверки. Например:

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

Правило 2: они должны быть активными (поскольку участники могут быть забанены — Агрегат покупателя

Правило 3: реклама должна быть активной (реклама может быть приостановлена) — Агрегат рекламы

Правила 1 и 3 проверяются Ad::buyedBy($buyerId, $quantity) и правило 2 проверяется Buyer::buyAd($buyerId, $quantity), Сага просто склеит эти вызовы методов. Как это сделать, это зависит от ваших низкоуровневых требований архитектуры и устойчивости.

Предположим, что вы будете использовать стиль, продвигаемый cqrs.nu где Агрегаты обрабатывают Команды (у них есть такие методы, как handleXXX(XXX $command)), лайк Я бы сделал, тогда ваши агрегаты и ваша сага будут выглядеть так:

class Ad
{
function handleBuyAd(BuyAd $command)
{
if (!$this->active) {
throw new \Exception("Ad not active");
}
if ($command->quantity < $this->minimum || $command->quantity > $this->maximum) {
throw new \Exception("Too litle or too many");
}

yield new AdWasBuyed($this->id, $command->buyerId, $command->quantity);
}

function handleCancelAdBuy(CancelAdBuy $command)
{
yield new AdBuyinWasCancelled($this->id, $command->buyerId, $command->quantity);
}
}

class Buyer
{
function handleBuyerBuysAd(BuyerBuysAd $command)
{
if ($this->banned) {
throw new \Exception("Buyer is banned");
}

yield new BuyerBuyedAd($command->transactionId, $this->id, $command->buyerId, $command->quantity);
}
}

class BuyAdSaga
{
/** @var CommandDispather  */
private $commandDispatcher; //injected

function start($transactionId, $adId, $buyerId, $quantity)
{
$this->commandDispatcher->dispatchCommand(new BuyAd($transactionId, $adId, $buyerId, $quantity));
}

function processAdWasBuyed(AdWasBuyed $event) //"process" means only once
{
try {
$this->commandDispatcher->dispatchCommand(new BuyerBuysAd($event->transactionId, $event->adId, $event->buyerId, $event->quantity));
} catch (\Exception $exception) {
// this is a compensating command
$this->commandDispatcher->dispatchCommand(new CancelAdBuy($event->transactionId, $event->adId, $event->buyerId, $event->quantity));
}
}
}

Команды содержат $transationId используется для идентификации процесса покупки рекламы. Это также можно рассматривать как тип Id корреляции. Вы можете выбросить это.

Сага начинается start метод. Вы также можете сбросить его и считать, что Сага началась, отправив первую команду в Агрегат объявлений. Я сделал это, чтобы быть более понятным, как этот процесс начинается.

Если BuyAd команда не выполняется, тогда компенсация не требуется, но если BuyerBuysAd команда не выполняется, тогда компенсация выполняется путем отправки команды CancelAdBuy к рекламному агрегату.

Обратите внимание, что эта сага реагирует только на события, отправляя команды и ничего более. Он не применяет никаких бизнес-инвариантов, он просто координирует весь процесс.