Kreta\SharedKernel\Projection\Projector

Complexity

Total Complexity

10

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	3

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	instance()	0	8	2
A	__construct()	0	4	1
A	__clone()	0	4	1
A	register()	0	6	2
A	add()	0	4	1
A	project()	0	8	3

<?php

/*
 * This file is part of the Kreta package.
 *
 * (c) Beñat Espiña <benatespina@gmail.com>
 * (c) Gorka Laucirica <gorka.lauzirika@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Kreta\SharedKernel\Projection;

use Kreta\SharedKernel\Domain\Model\DomainEventCollection;
use Kreta\SharedKernel\Domain\Model\Exception;
use Kreta\SharedKernel\Domain\ReadEvent\EventHandler;

final class Projector
{
    private $eventHandlers;
    private static $instance = null;

    public static function instance() : self
    {
        if (null === self::$instance) {
            self::$instance = new self();
        }

        return self::$instance;
    }

    private function __construct()
    {
        $this->eventHandlers = [];
    }

    public function __clone()
    {
        throw new Exception('Clone is not supported');
    }

    public function register(array $eventHandlers)
    {
        foreach ($eventHandlers as $eventHandler) {
            $this->add($eventHandler);
        }
    }

    private function add(EventHandler $eventHandler)
    {
        $this->eventHandlers[$eventHandler->isSubscribeTo()] = $eventHandler;
    }

    public function project(DomainEventCollection $events) : void
    {
        foreach ($events->toArray() as $event) {
            if (isset($this->eventHandlers[get_class($event)])) {
                $this->eventHandlers[get_class($event)]->handle($event);
            }
        }
    }
}