Itkg\DelayEventBundle\Processor\EventProcessor

Complexity

Total Complexity

4

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

0%

Importance

Changes	2
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	process()	0	13	3

<?php

namespace Itkg\DelayEventBundle\Processor;

use Itkg\DelayEventBundle\Event\FailProcessedEvent;
use Itkg\DelayEventBundle\Event\ProcessedEvents;
use Itkg\DelayEventBundle\Event\SuccessProcessedEvent;
use Itkg\DelayEventBundle\Model\Event;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;

/**
 * Class EventProcessor
 */
class EventProcessor implements EventProcessorInterface
{
    /**
     * @var EventDispatcherInterface
     */
    private $eventDispatcher;

    /**
     * @var array
     */
    private $config = array();

    /**
     * @var array
     */
    private $eventsConfig = array();

    /**
     * @param EventDispatcherInterface $eventDispatcher
     * @param array                    $config
     * @param array                    $eventsConfig
     */
    public function __construct(EventDispatcherInterface $eventDispatcher, array $config, array $eventsConfig)
    {
        $this->eventDispatcher = $eventDispatcher;
        $this->config = $config;
        $this->eventsConfig = $eventsConfig;
    }

    /**
     * {@inheritDoc}
     */
    public function process(Event $event)
    {
        try {
            $this->eventDispatcher->dispatch($event->getOriginalName(), $event);
            $this->eventDispatcher->dispatch(ProcessedEvents::SUCCESS, new SuccessProcessedEvent($event));
        } catch (\Exception $e) {
            $maxRetryCount = $this->config['retry_count'][$this->eventsConfig[$event->getOriginalName()]['type']];
            $this->eventDispatcher->dispatch(ProcessedEvents::FAIL, new FailProcessedEvent($event, $maxRetryCount));
            if ($event->isFailed()) {
                throw $e;
            }
        }
    }
}