xprt64/cqrs-es

<?php
/**
 * Copyright (c) 2018 Constantin Galbenu <xprt64@gmail.com>
 */

namespace Dudulina\Command\CommandDispatcher\SideEffectsDispatcher;


use Dudulina\Command\CommandDispatcher\DefaultCommandDispatcher\SideEffects;
use Dudulina\Command\CommandDispatcher\SideEffectsDispatcher;
use Dudulina\Event\EventDispatcher;
use Dudulina\Scheduling\CommandScheduler;

class DefaultSideEffectsDispatcher implements SideEffectsDispatcher
{
    /**
     * @var EventDispatcher
     */
    private $eventDispatcher;
    /**
     * @var CommandScheduler|null
     */
    private $commandScheduler;

    public function __construct(
        EventDispatcher $eventDispatcher,
        ?CommandScheduler $commandScheduler = null
    )
    {
        $this->eventDispatcher = $eventDispatcher;
        $this->commandScheduler = $commandScheduler;
    }

    public function dispatchSideEffects(SideEffects $sideEffects):void
    {
        foreach ($sideEffects->getEventsForNow() as $eventWithMetaData) {
            $this->eventDispatcher->dispatchEvent($eventWithMetaData);
        }

        if ($this->commandScheduler && !empty($sideEffects->getScheduledCommands())) {
            foreach ($sideEffects->getScheduledCommands() as $scheduledCommand) {
                $this->commandScheduler->scheduleCommand($scheduledCommand, $sideEffects->getAggregateDescriptor(), $sideEffects->getCommandMetadata());
            }
        }
    }
}