Passed
Pull Request — master (#84)
by Frank
02:32
created

DummyCommandHandler::handle()   A

Complexity

Conditions 6
Paths 12

Size

Total Lines 24
Code Lines 16

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 15
CRAP Score 6

Importance

Changes 0
Metric Value
cc 6
eloc 16
nc 12
nop 1
dl 0
loc 24
ccs 15
cts 15
cp 1
crap 6
rs 9.1111
c 0
b 0
f 0
1
<?php
2
3
declare(strict_types=1);
4
5
namespace EventSauce\EventSourcing\TestUtilities\TestingAggregates;
6
7
use EventSauce\EventSourcing\AggregateRootRepository;
8
use EventSauce\EventSourcing\Time\Clock;
9
10
class DummyCommandHandler
11
{
12
    /**
13
     * @var AggregateRootRepository
14
     */
15
    private $repository;
16
17
    /**
18
     * @var Clock
19
     */
20
    private $clock;
21
22 9
    public function __construct(AggregateRootRepository $repository, Clock $clock)
23
    {
24 9
        $this->repository = $repository;
25 9
        $this->clock = $clock;
26 9
    }
27
28
    /**
29
     * @param $command
30
     *
31
     * @throws DummyException
32
     */
33 9
    public function handle($command): void
34
    {
35
        try {
36 9
            if ($command instanceof InitiatorCommand) {
37 1
                $aggregate = DummyAggregate::create($command->aggregateRootId());
38 1
                goto end;
39
            }
40
41
            /** @var DummyAggregate $aggregate */
42
            /** @var DummyCommand $command */
43 8
            $aggregate = $this->repository->retrieve($command->aggregateRootId());
44
45 8
            if ($command instanceof DummyCommand) {
0 ignored issues
show
introduced by
$command is always a sub-type of EventSauce\EventSourcing...Aggregates\DummyCommand.
Loading history...
46 1
                $aggregate->performDummyTask();
47 7
            } elseif ($command instanceof IgnoredCommand) {
48 1
                $aggregate->dontDoAnything();
49 6
            } elseif ($command instanceof ExceptionInducingCommand) {
50 3
                $aggregate->throwAnException();
51 3
            } elseif ($command instanceof DummyIncrementCommand) {
52 3
                $aggregate->increment();
53
            }
54
            end:
55 6
        } finally {
56 9
            $this->repository->persist($aggregate);
57
        }
58 6
    }
59
}
60