Dispatch Domain Events After Doctrine Flush with a postFlush Subscriber in Symfony

<?php

namespace App\Event;

final class OrderPlaced
{
    public function __construct(
        private readonly string $orderId,
        private readonly string $customerId,
    ) {
    }

    public function orderId(): string
    {
        return $this->orderId;
    }

    public function customerId(): string
    {
        return $this->customerId;
    }
}

<?php

namespace App\Doctrine;

use App\Entity\RecordsEvents;
use Doctrine\Bundle\DoctrineBundle\Attribute\AsDoctrineListener;
use Doctrine\Common\EventSubscriber;
use Doctrine\ORM\Event\OnFlushEventArgs;
use Doctrine\ORM\Event\PostFlushEventArgs;
use Doctrine\ORM\Events;
use Symfony\Component\Messenger\MessageBusInterface;

class DomainEventSubscriber implements EventSubscriber
{
    private array $pendingEntities = [];

    public function __construct(private readonly MessageBusInterface $eventBus)
    {
    }

    public function getSubscribedEvents(): array
    {
        return [Events::onFlush, Events::postFlush];
    }

    public function onFlush(OnFlushEventArgs $args): void
    {
        $uow = $args->getObjectManager()->getUnitOfWork();

        $changes = array_merge(
            $uow->getScheduledEntityInsertions(),
            $uow->getScheduledEntityUpdates(),
            $uow->getScheduledEntityDeletions(),
        );

        foreach ($changes as $entity) {
            if (in_array(RecordsEvents::class, class_uses($entity) ?: [], true)) {
                $this->pendingEntities[spl_object_id($entity)] = $entity;
            }
        }
    }

    public function postFlush(PostFlushEventArgs $args): void
    {
        $entities = $this->pendingEntities;
        $this->pendingEntities = [];

        foreach ($entities as $entity) {
            foreach ($entity->releaseEvents() as $event) {
                $this->eventBus->dispatch($event);
            }
        }
    }
}

<?php

namespace App\MessageHandler;

use App\Event\OrderPlaced;
use App\Notification\CustomerNotifier;
use Psr\Log\LoggerInterface;
use Symfony\Component\Messenger\Attribute\AsMessageHandler;

#[AsMessageHandler]
final class OrderPlacedHandler
{
    public function __construct(
        private readonly CustomerNotifier $notifier,
        private readonly LoggerInterface $logger,
    ) {
    }

    public function __invoke(OrderPlaced $event): void
    {
        $this->logger->info('Order placed', [
            'order' => $event->orderId(),
            'customer' => $event->customerId(),
        ]);

        $this->notifier->orderConfirmation(
            $event->customerId(),
            $event->orderId(),
        );
    }
}