Gica\Cqrs\Command\CommandSubscriber\CommandSubscriberByMap

Complexity

Total Complexity

4

Size/Duplication

Total Lines	29
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	getHandlerForCommand()	0	19	4
	getCommandHandlersDefinitions()	0	1	?

<?php
/******************************************************************************
 * Copyright (c) 2016 Constantin Galbenu <gica.galbenu@gmail.com>             *
 ******************************************************************************/

namespace Gica\Cqrs\Command\CommandSubscriber;


use Gica\Cqrs\Command;
use Gica\Cqrs\Command\CommandSubscriber;
use Gica\Cqrs\Command\Exception\CommandHandlerNotFound;
use Gica\Cqrs\Command\ValueObject\CommandHandlerDescriptor;

abstract class CommandSubscriberByMap implements CommandSubscriber
{
    /**
     * @param Command $command
     * @return CommandHandlerDescriptor
     * @throws CommandHandlerNotFound
     */
    public function getHandlerForCommand(Command $command)
    {
        $definitions = $this->getCommandHandlersDefinitions();

        if (isset($definitions[get_class($command)])) {
            $handlersForCommand = $definitions[get_class($command)];

            if ($handlersForCommand) {
                foreach ($handlersForCommand as $commandDefinition) {

                    list($aggregateClass, $methodName) = $commandDefinition;

                    return new CommandHandlerDescriptor($aggregateClass, $methodName);
                }
            }
        }

        throw new CommandHandlerNotFound(sprintf("A handler for command %s was not found", get_class($command)));
    }

    abstract protected function getCommandHandlersDefinitions(): array;
}