Stratadox\CardGame\EventHandler\MatchPublisher

Complexity

Total Complexity

6

Size/Duplication

Total Lines	43
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	events()	0	5	1
A	startMatch()	0	8	1
A	setupMatch()	0	4	1
A	handle()	0	7	2

<?php declare(strict_types=1);

namespace Stratadox\CardGame\EventHandler;

use function assert;
use Stratadox\CardGame\DomainEvent;
use Stratadox\CardGame\Match\Event\MatchHasBegun;
use Stratadox\CardGame\Match\Event\StartedMatchForProposal;
use Stratadox\CardGame\ReadModel\Match\OngoingMatch;
use Stratadox\CardGame\ReadModel\Match\OngoingMatches;

final class MatchPublisher implements EventHandler
{
    private $proposalFor = [];
    private $playersFor = [];
    private $matches;

    public function __construct(OngoingMatches $matches)
    {
        $this->matches = $matches;
    }

    public function events(): iterable
    {
        return [
            StartedMatchForProposal::class,
            MatchHasBegun::class,
        ];
    }

    public function handle(DomainEvent $event): void
    {
        if ($event instanceof StartedMatchForProposal) {
            $this->setupMatch($event);
        } else {
            assert($event instanceof MatchHasBegun);
            $this->startMatch($event);
        }
    }

    private function setupMatch(StartedMatchForProposal $event): void
    {
        $this->proposalFor[(string) $event->aggregateId()] = $event->proposal();
        $this->playersFor[(string) $event->aggregateId()] = $event->players();
    }

    private function startMatch(MatchHasBegun $event): void
    {
        $this->matches->addFromProposal(
            $this->proposalFor[(string) $event->aggregateId()],
            new OngoingMatch(
                $event->aggregateId(),
                $event->whoBegins(),
                ...$this->playersFor[(string) $event->aggregateId()]
            )
        );
    }
}