GpsLab\Bundle\DomainEvent\Event\Subscriber\DoctrineSubscriber

Complexity

Total Complexity

9

Size/Duplication

Total Lines	87
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

0%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	17	2
A	getSubscribedEvents()	0	4	1
A	prePersist()	0	4	1
A	preUpdate()	0	4	1
A	preRemove()	0	4	1
A	preFlush()	0	4	1
A	pullAndPublish()	0	7	2

<?php
/**
 * GpsLab component.
 *
 * @author    Peter Gribanov <info@peter-gribanov.ru>
 * @copyright Copyright (c) 2016, Peter Gribanov
 * @license   http://opensource.org/licenses/MIT
 */
namespace GpsLab\Bundle\DomainEvent\Event\Subscriber;

use Doctrine\Common\EventSubscriber;
use Doctrine\Common\Persistence\Event\LifecycleEventArgs;
use Doctrine\ORM\Events;
use GpsLab\Domain\Event\Aggregator\AggregateEventsInterface;
use GpsLab\Domain\Event\Bus\Bus;
use Symfony\Bridge\Doctrine\RegistryInterface;

class DoctrineSubscriber implements EventSubscriber
{
    /**
     * @var Bus
     */
    private $bus;

    /**
     * @var array
     */
    private $events = [];

    /**
     * @param Bus $bus
     * @param RegistryInterface $doctrine
     * @param array $events
     * @param array $connections
     */
    public function __construct(Bus $bus, RegistryInterface $doctrine, array $events, array $connections)
    {
        $this->bus = $bus;
        $this->events = array_intersect([
            Events::prePersist,
            Events::preUpdate,
            Events::preRemove,
            Events::preFlush,
        ], $events);

        foreach ($connections as $connection) {
            $doctrine
                ->getEntityManager($connection)
                ->getEventManager()
                ->addEventSubscriber($this);
        }
    }

    /**
     * @return array
     */
    public function getSubscribedEvents()
    {
        return $this->events;
    }

    /**
     * @param LifecycleEventArgs $args
     */
    public function prePersist(LifecycleEventArgs $args)
    {
        $this->pullAndPublish($args);
    }

    /**
     * @param LifecycleEventArgs $args
     */
    public function preUpdate(LifecycleEventArgs $args)
    {
        $this->pullAndPublish($args);
    }

    /**
     * @param LifecycleEventArgs $args
     */
    public function preRemove(LifecycleEventArgs $args)
    {
        $this->pullAndPublish($args);
    }

    /**
     * @param LifecycleEventArgs $args
     */
    public function preFlush(LifecycleEventArgs $args)
    {
        $this->pullAndPublish($args);
    }

    /**
     * @param LifecycleEventArgs $args
     */
    protected function pullAndPublish(LifecycleEventArgs $args)
    {
        $object = $args->getObject();
        if ($object instanceof AggregateEventsInterface) {
            $this->bus->pullAndPublish($object);
        }
    }
}