Gendoria\CommandQueue\ProcessorFactory\ProcessorFactory

Complexity

Total Complexity

10

Size/Duplication

Total Lines	64
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	2
A	registerProcessorForCommand()	0	14	4
A	getProcessor()	0	8	3
A	hasProcessor()	0	4	1

<?php

namespace Gendoria\CommandQueue\ProcessorFactory;

use Gendoria\CommandQueue\Command\CommandInterface;
use Gendoria\CommandQueue\CommandProcessor\CommandProcessorInterface;
use Gendoria\CommandQueue\Exception\MultipleProcessorsException;
use InvalidArgumentException;
use Psr\Log\LoggerInterface;
use Psr\Log\NullLogger;
use ReflectionClass;

/**
 * Command Processor factory - used for registering and retrieving command processor.
 *
 * @author Tomasz Struczyński <t.struczynski@gmail.com>
 */
class ProcessorFactory implements ProcessorFactoryInterface
{
    /**
     * Array of registered command processors.
     *
     * @var CommandProcessorInterface[]
     */
    private $commandTypes = array();

    /**
     * Logger instance.
     *
     * @var LoggerInterface
     */
    private $logger;

    /**
     * Class constructor.
     *
     * @param LoggerInterface $logger
     */
    public function __construct(LoggerInterface $logger = null)
    {
        $this->logger = $logger ? $logger : new NullLogger();
    }

    /**
     * {@inheritdoc}
     */
    public function registerProcessorForCommand($commandClassName, CommandProcessorInterface $service)
    {
        if (!class_exists($commandClassName)) {
            throw new InvalidArgumentException('Registering service for non existing command class.');
        }
        $classData = new ReflectionClass($commandClassName);
        if (!$classData->implementsInterface('Gendoria\CommandQueue\Command\CommandInterface')) {
            throw new InvalidArgumentException('Command class has to implement CommandInterface interface.');
        }
        if (array_key_exists($commandClassName, $this->commandTypes)) {
            throw new MultipleProcessorsException($commandClassName);
        }
        $this->commandTypes[$commandClassName] = $service;
    }

    /**
     * {@inheritdoc}
     */
    public function getProcessor(CommandInterface $command)
    {
        if (!array_key_exists(get_class($command), $this->commandTypes) || !$this->commandTypes[get_class($command)]->supports($command)) {
            throw new ProcessorNotFoundException('No processor registered for given command class: '.get_class($command));
        }

        return $this->commandTypes[get_class($command)];
    }
    
    /**
     * {@inheritdoc}
     */
    public function hasProcessor($commandClassName)
    {
        return array_key_exists($commandClassName, $this->commandTypes);
    }
}