Puzzle\AMQP\Workers\ProcessorInterfaceAdapter

Complexity

Total Complexity

6

Size/Duplication

Total Lines	58
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

92.31%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	2
B	process()	0	25	2
A	onWorkerProcess()	0	4	1
A	onWorkerProcessed()	0	4	1

<?php

namespace Puzzle\AMQP\Workers;

use Swarrot\Processor\ProcessorInterface;
use Puzzle\Pieces\EventDispatcher\NullEventDispatcher;
use Puzzle\Pieces\EventDispatcher\EventDispatcherAware;
use Puzzle\AMQP\Clients\Processors\MessageProcessorAware;

class ProcessorInterfaceAdapter implements ProcessorInterface
{
    use
        EventDispatcherAware,
        MessageProcessorAware;
    
    private
        $messageAdapterFactory,
        $workerContext;
    
    public function __construct(WorkerContext $workerContext, MessageAdapterFactory $factory = null)
    {
        $this->workerContext = $workerContext;
        $this->eventDispatcher = new NullEventDispatcher();
        
        if(! $factory instanceof MessageAdapterFactory)
        {
            $factory = new MessageAdapterFactory();
        }
        $this->messageAdapterFactory = $factory;
    }
    
    public function process(\Swarrot\Broker\Message $message, array $options)
    {
        $message = $this->messageAdapterFactory->build($message);
        
        $message = $this->onConsume($message);
        
        $this->workerContext->getLogger()->debug((string) $message);
        
        $this->onWorkerProcess();

        try
        {
            $processResult = $this->workerContext->getWorker()->process($message);
        }
        catch(\Exception $exception)
        {
            $this->onWorkerProcessed();

            throw $exception;
        }
        
        $this->onWorkerProcessed();

        return $processResult;
    }

    private function onWorkerProcess()
    {
        $this->eventDispatcher->dispatch('worker.process');
    }
    
    private function onWorkerProcessed()
    {
        $this->eventDispatcher->dispatch('worker.processed');
    }
}