Gendoria\CommandQueueBundle\Worker\BaseSymfonyWorker

Complexity

Total Complexity

10

Size/Duplication

Total Lines	93
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	8

Test Coverage

Coverage

100%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
	getSubsystemName()	0	1	?
A	beforeTranslateHook()	0	7	1
A	beforeGetProcessorHook()	0	5	1
A	beforeProcessHook()	0	5	1
A	afterProcessHook()	0	6	1
A	processorErrorHook()	0	5	1
A	clearLogs()	0	14	4

<?php

namespace Gendoria\CommandQueueBundle\Worker;

use Exception;
use Gendoria\CommandQueue\Command\CommandInterface;
use Gendoria\CommandQueue\CommandProcessor\CommandProcessorInterface;
use Gendoria\CommandQueue\ProcessorFactory\ProcessorFactoryInterface;
use Gendoria\CommandQueue\Serializer\SerializerInterface;
use Gendoria\CommandQueue\Worker\BaseWorker;
use Gendoria\CommandQueueBundle\Event\QueueBeforeGetProcessorEvent;
use Gendoria\CommandQueueBundle\Event\QueueBeforeTranslateEvent;
use Gendoria\CommandQueueBundle\Event\QueueEvents;
use Gendoria\CommandQueueBundle\Event\QueueProcessErrorEvent;
use Gendoria\CommandQueueBundle\Event\QueueProcessEvent;
use Monolog\Handler\FingersCrossedHandler;
use Monolog\Logger;
use Psr\Log\LoggerInterface;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;

/**
 * Base for Symfony based queue workers.
 * 
 * This class takes care of correctly handling long-running process logs, 
 * as well as sending some events on Symfony event bus.
 *
 * @author Tomasz Struczyński <t.struczynski@gmail.com>
 */
abstract class BaseSymfonyWorker extends BaseWorker
{
    /**
     * Symfony event dispatcher.
     *
     * @var EventDispatcherInterface
     */
    private $eventDispatcher;
    
    public function __construct(ProcessorFactoryInterface $processorFactory, SerializerInterface $serializer, EventDispatcherInterface $eventDispatcher, LoggerInterface $logger = null)
    {
        parent::__construct($processorFactory, $serializer, $logger);
        $this->eventDispatcher = $eventDispatcher;
    }

    /**
     * Get subsystem name.
     * 
     * This name may be used further to identify worker subsystem in logs or events.
     * 
     * @return string
     */
    abstract public function getSubsystemName();

    /**
     * {@inheritdoc}
     */
    protected function beforeTranslateHook(&$commandData)
    {
        parent::beforeTranslateHook($commandData);

        $this->eventDispatcher->dispatch(QueueEvents::WORKER_RUN_BEFORE_TRANSLATE, new QueueBeforeTranslateEvent($this, $commandData, $this->getSubsystemName()));
        $this->clearLogs();
    }
    
    /**
     * {@inheritdoc}
     */
    protected function beforeGetProcessorHook(CommandInterface $command)
    {
        parent::beforeGetProcessorHook($command);
        $this->eventDispatcher->dispatch(QueueEvents::WORKER_RUN_BEFORE_GET_PROCESSOR, new QueueBeforeGetProcessorEvent($this, $command, $this->getSubsystemName()));
    }

    /**
     * {@inheritdoc}
     */
    protected function beforeProcessHook(CommandInterface $command, CommandProcessorInterface $processor)
    {
        parent::beforeProcessHook($command, $processor);
        $this->eventDispatcher->dispatch(QueueEvents::WORKER_RUN_BEFORE_PROCESS, new QueueProcessEvent($this, $command, $processor, $this->getSubsystemName()));
    }

    /**
     * {@inheritdoc}
     */
    protected function afterProcessHook(CommandInterface $command, CommandProcessorInterface $processor)
    {
        parent::afterProcessHook($command, $processor);
        $this->eventDispatcher->dispatch(QueueEvents::WORKER_RUN_AFTER_PROCESS, new QueueProcessEvent($this, $command, $processor, $this->getSubsystemName()));
        $this->clearLogs();
    }

    /**
     * {@inheritdoc}
     */
    protected function processorErrorHook(CommandInterface $command, CommandProcessorInterface $processor, Exception $e)
    {
        parent::processorErrorHook($command, $processor, $e);
        $this->eventDispatcher->dispatch(QueueEvents::WORKER_RUN_PROCESSOR_ERROR, new QueueProcessErrorEvent($this, $command, $processor, $e, $this->getSubsystemName()));
    }

    /**
     * Clear logs.
     * 
     * @return void
     */
    private function clearLogs()
    {
        if (!$this->logger instanceof Logger) {
            return;
        }
        /* @var $logger Logger */
        $logger = $this->logger;

        foreach ($logger->getHandlers() as $handler) {
            if ($handler instanceof FingersCrossedHandler) {
                $handler->clear();
            }
        }
    }

}