Как сериализовать / десериализовать события в хранилище событий и так ли плохо хранить в них агрегированные корни?

Я пытаюсь сделать приложение CQRS источником событий в PHP. И мне интересно, нормально ли помещать агрегатный корень (AbstractItem в следующем примере) в событие, которое сериализуется в БД? (Полагаю, нет, но какая альтернатива?)

Нет, ты не можешь. Я согласен с @Codescribler.
Я думаю, что у вас есть проблемы с вашим дизайном.

Тогда как Cart и AbstractItem являются совокупными корнями.

Почему ты сделал AbstractItem Aggregate root? Что делает инвариант AbstractItem защищает? Какие Commands это обрабатывает и что Events доходность? Это ваша главная проблема дизайна. И вы должны назвать его в соответствии с вашим Ubiquitous language, лайк Product или если вам нужно более абстрактное имя, то CartItem,

Product Агрегированный корень, но в другом ограниченном контексте, например Inventory, Или это может быть объект CRUD, если не нужно защищать какие-либо инварианты. В этом BC он занимается созданием, изменением и удалением товара из вашего магазина.

Вы сейчас в Ordering bounded context и вы должны пересмотреть правила домена в этом BC. Итак, каковы ваши правила? Вы разрешаете изменение цены в Inventory До н.э., чтобы распространяться на элементы в Cart? Я так не думаю. Ваши клиенты будут очень злы, по крайней мере, без уведомлений об изменении цен с момента добавления товара в корзину. Итак, предположим, что как только товар был добавлен в корзину, цена зависает. Так что это будет неизменным.

Теперь о Cart, Какая информация вам нужна о Products которые добавляются к Cart чтобы защитить ваш инварианты? Каковы Cart инварианты? Ну, вы могли бы иметь максимум Order стоимость, скажем, 10000 грн. Так что вам нужно идентифицировать Product и Product price,
Итак, CartItem является неизменным Value Object, содержащий ProductId а также ProductPrice,
Итак, ваш код должен выглядеть так:

namespace Domain\Ordering;

class Cart
{
/** @var CartItem[] */
private $items = [];

const MAXIMUM_CART_VALUE = 10000;

public function handleAddItemToCart(AddItemToCart $command)
{
if ($this->getTotalCartValue() + $command->getItem()->getTotalItemPrice() > self::MAXIMUM_CART_VALUE) {
throw new \Exception(sprintf("A cart value cannot be more than %d USD", self::MAXIMUM_CART_VALUE));
}

yield new AnItemWasAddedToCart($command->getCartId(), $command->getItem());
}

public function applyAnItemWasAddedToCart(AnItemWasAddedToCart $event)
{
$this->items[] = $event->getItem();
}

private function getTotalCartValue()
{
return array_reduce($this->items, function (float $acc, CartItem $item) {
return $acc + $item->getTotalItemPrice();
}, 0.0);
}
}

class AddItemToCart implements Command
{

/**
* @var CartId
*/
private $cartId;
/**
* @var CartItem
*/
private $item;

public function __construct(
CartId $cartId,
CartItem $item
)
{
$this->cartId = $cartId;
$this->item = $item;
}

public function getCartId(): CartId
{
return $this->cartId;
}

public function getItem(): CartItem
{
return $this->item;
}
}

class AnItemWasAddedToCart implements Event
{
/**
* @var CartId
*/
private $cartId;
/**
* @var CartItem
*/
private $item;

public function __construct(
CartId $cartId,
CartItem $item
)
{
$this->cartId = $cartId;
$this->item = $item;
}

public function getCartId(): CartId
{
return $this->cartId;
}

public function getItem(): CartItem
{
return $this->item;
}
}

class CartId
{
//...
}

class ProductId
{
//...
}

class CartItem
{
/**
* @var ProductId
*/
private $productId;
/**
* @var float
*/
private $pricePerUnit;
/**
* @var int
*/
private $quantity;

public function __construct(
ProductId $productId,
float $pricePerUnit,
int $quantity
)
{
$this->productId = $productId;
$this->pricePerUnit = $pricePerUnit;
$this->quantity = $quantity;
}

public function getProductId(): ProductId
{
return $this->productId;
}

public function getTotalItemPrice()
{
return $this->pricePerUnit * $this->quantity;
}
}