Gendoria\CommandQueue\SendDriver\DirectProcessingDriver

Complexity

Total Complexity

10

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	8

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	2
A	send()	0	10	3
A	process()	0	12	3
A	getProcessor()	0	6	1
A	setProcessorFactory()	0	4	1

<?php

namespace Gendoria\CommandQueue\SendDriver;

use Gendoria\CommandQueue\Command\CommandInterface;
use Gendoria\CommandQueue\ProcessorFactory\ProcessorFactoryInterface;
use Gendoria\CommandQueue\ProcessorFactory\ProcessorNotFoundException;
use Gendoria\CommandQueue\Worker\Exception\ProcessorErrorException;
use Gendoria\CommandQueue\Worker\Exception\TranslateErrorException;
use Gendoria\CommandQueue\Worker\WorkerInterface;
use Psr\Log\LoggerAwareInterface;
use Psr\Log\LoggerInterface;
use Psr\Log\NullLogger;

/**
 * Description of DirectProcessingDriver.
 *
 * @author Tomasz Struczyński <t.struczynski@gmail.com>
 */
class DirectProcessingDriver implements SendDriverInterface, WorkerInterface, LoggerAwareInterface
{
    use \Psr\Log\LoggerAwareTrait;
    
    /**
     * Processor factory.
     *
     * @var ProcessorFactoryInterface
     */
    private $processorFactory;
    
    /**
     * Class constructor.
     * 
     * @param ProcessorFactoryInterface $processorFactory
     */
    public function __construct(ProcessorFactoryInterface $processorFactory, LoggerInterface $logger = null)
    {
        $this->processorFactory = $processorFactory;
        $this->setLogger($logger ? $logger : new NullLogger());
    }

    /**
     * {@inheritdoc}
     */
    public function send(CommandInterface $command)
    {
        try {
            $this->process($command);
        } catch (ProcessorNotFoundException $e) {
            $this->logger->error('Exception while sending command: '.$e->getMessage());
        } catch (\Exception $e) {
            $this->logger->error('Exception while sending command: '.$e->getMessage());
        }
    }

    /**
     * {@inheritdoc}
     */
    public function process($command)
    {
        if (!$command instanceof CommandInterface) {
            throw new TranslateErrorException($command, "Command has to be instance of command interface for direct processing driver", 500);
        }
        $processor = $this->getProcessor($command);
        try {
            $processor->process($command);
        } catch (\Exception $e) {
            throw new ProcessorErrorException($command, $processor, $e->getMessage(), $e->getCode(), $e);
        }
    }
    
    /**
     * {@inheritdoc}
     */
    public function getProcessor(CommandInterface $command)
    {
        $processor = $this->processorFactory->getProcessor($command);
        $processor->setLogger($this->logger);
        return $processor;
    }    

    /**
     * {@inheritdoc}
     */
    public function setProcessorFactory(ProcessorFactoryInterface $processorFactory)
    {
        $this->processorFactory = $processorFactory;
    }
}