EventSaucePHP / EventSauce

src/Integration/TestingAggregates/DummyCommandHandler.php

<?php

declare(strict_types=1);

namespace EventSauce\EventSourcing\Integration\TestingAggregates;

use EventSauce\EventSourcing\AggregateRootRepository;
use EventSauce\EventSourcing\Time\Clock;

class DummyCommandHandler
{
    /**
     * @var AggregateRootRepository
     */
    private $repository;

    /**
     * @var Clock
     */
    private $clock;

    public function __construct(AggregateRootRepository $repository, Clock $clock)
    {
        $this->repository = $repository;
        $this->clock = $clock;
    }

    /**
     * @param $command
     *
     * @throws DummyException
     */
    public function handle($command)
    {
        try {
            if ($command instanceof InitiatorCommand) {
                $aggregate = DummyAggregate::create($command->aggregateRootId());
                goto end;
            }

            /** @var DummyAggregate $aggregate */
            /** @var DummyCommand $command */
            $aggregate = $this->repository->retrieve($command->aggregateRootId());

            if ($command instanceof DummyCommand) {

$command is always a sub-type of EventSauce\EventSourcing\Integration\TestingAggregates\DummyCommand.

                $aggregate->performDummyTask();
            } elseif ($command instanceof IgnoredCommand) {
                $aggregate->dontDoAnything();
            } elseif ($command instanceof ExceptionInducingCommand) {
                $aggregate->throwAnException();
            } elseif ($command instanceof DummyIncrementCommand) {
                $aggregate->increment();
            }
            end:
        } finally {
            $this->repository->persist($aggregate);
        }
    }
}