EventSauce\EventSourcing\TestUtilities\TestingAggregates\DummyCommandHandler

Complexity

Total Complexity

9

Size/Duplication

Total Lines	42
Duplicated Lines	0 %

Importance

Changes	3
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
B	handle()	0	24	8

<?php

declare(strict_types=1);

namespace EventSauce\EventSourcing\TestUtilities\TestingAggregates;

use EventSauce\EventSourcing\AggregateRoot;
use EventSauce\EventSourcing\AggregateRootRepository;

/**
 * @testAsset
 */
class DummyCommandHandler
{
    /**
     * @phpstan-var AggregateRootRepository<DummyAggregate>
     */
    private AggregateRootRepository $repository;

    /**
     * @phpstan-param AggregateRootRepository<DummyAggregate> $repository
     */
    public function __construct(AggregateRootRepository $repository)
    {
        $this->repository = $repository;
    }

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

                return;
            }

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

            if ($command instanceof PerformDummyTask) {
                $aggregate->performDummyTask();
            } elseif ($command instanceof IgnoredCommand) {
                $aggregate->dontDoAnything();
            } elseif ($command instanceof ExceptionInducingCommand) {
                $aggregate->throwAnException();
            } elseif ($command instanceof DummyIncrementCommand) {
                $aggregate->increment();
            }
        } finally {
            if (isset($aggregate) && $aggregate instanceof AggregateRoot) {
                $this->repository->persist($aggregate);
            }
        }
    }
}