FlushDeferredEvents.php

<?php

/*
 * Copyright 2025 Cloud Creativity Limited
 *
 * Use of this source code is governed by an MIT-style
 * license that can be found in the LICENSE file or at
 * https://opensource.org/licenses/MIT.
 */

declare(strict_types=1);

namespace CloudCreativity\Modules\Application\InboundEventBus\Middleware;

use Closure;
use CloudCreativity\Modules\Contracts\Application\DomainEventDispatching\DeferredDispatcher;
use CloudCreativity\Modules\Contracts\Application\InboundEventBus\InboundEventMiddleware;
use CloudCreativity\Modules\Contracts\Toolkit\Messages\IntegrationEvent;
use Throwable;

final readonly class FlushDeferredEvents implements InboundEventMiddleware
{
    /**
     * FlushDeferredEvents constructor.
     *
     * @param DeferredDispatcher $dispatcher
     */
    public function __construct(private DeferredDispatcher $dispatcher)
    {
    }

    /**
     * @inheritDoc
     */
    public function __invoke(IntegrationEvent $event, Closure $next): void
    {
        try {
            $next($event);
        } catch (Throwable $ex) {
            $this->dispatcher->forget();
            throw $ex;
        }

        $this->dispatcher->flush();
    }
}