Psi\Component\ObjectAgent\EventDispatchingAgent

Complexity

Total Complexity

14

Size/Duplication

Total Lines	118
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

14 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	getCapabilities()	0	4	1
A	find()	0	4	1
A	findMany()	0	4	1
A	persist()	0	6	1
A	query()	0	4	1
A	queryCount()	0	4	1
A	remove()	0	6	1
A	flush()	0	4	1
A	getIdentifier()	0	4	1
A	supports()	0	4	1
A	setParent()	0	4	1
A	getCanonicalClassFqn()	0	4	1
A	dispatch()	0	4	1

<?php

declare(strict_types=1);

namespace Psi\Component\ObjectAgent;

use Psi\Component\ObjectAgent\Event\ObjectEvent;
use Psi\Component\ObjectAgent\Query\Query;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;

class EventDispatchingAgent implements AgentInterface
{
    private $dispatcher;
    private $agent;

    public function __construct(
        AgentInterface $agent,
        EventDispatcherInterface $dispatcher
    ) {
        $this->agent = $agent;
        $this->dispatcher = $dispatcher;
    }

    /**
     * {@inheritdoc}
     */
    public function getCapabilities(): Capabilities
    {
        return $this->agent->getCapabilities();
    }

    /**
     * {@inheritdoc}
     */
    public function find($identifier, string $class = null)
    {
        return $this->agent->find($identifier, $class);
    }

    /**
     * {@inheritdoc}
     */
    public function findMany(array $identifiers, string $class = null)
    {
        return $this->agent->findMany($identifiers, $class);
    }

    /**
     * {@inheritdoc}
     */
    public function persist($object)
    {
        $this->dispatch(Events::PRE_PERSIST, $object);
        $this->agent->persist($object);
        $this->dispatch(Events::POST_PERSIST, $object);
    }

    /**
     * {@inheritdoc}
     */
    public function query(Query $query): \Traversable
    {
        return $this->agent->query($query);
    }

    /**
     * {@inheritdoc}
     */
    public function queryCount(Query $query): int
    {
        return $this->agent->queryCount($query);
    }

    /**
     * {@inheritdoc}
     */
    public function remove($object)
    {
        $this->dispatch(Events::PRE_REMOVE, $object);
        $this->agent->remove($object);
        $this->dispatch(Events::POST_REMOVE, $object);
    }

    /**
     * {@inheritdoc}
     */
    public function flush()
    {
        $this->agent->flush();
    }

    /**
     * {@inheritdoc}
     */
    public function getIdentifier($object)
    {
        return $this->agent->getIdentifier($object);
    }

    /**
     * {@inheritdoc}
     */
    public function supports(string $class): bool
    {
        return $this->agent->supports($class);
    }

    /**
     * {@inheritdoc}
     */
    public function setParent($object, $parent)
    {
        return $this->agent->setParent($object, $parent);
    }

    /**
     * {@inheritdoc}
     */
    public function getCanonicalClassFqn(string $classFqn): string
    {
        return $this->agent->getCanonicalClassFqn($classFqn);
    }

    private function dispatch(string $eventName, $object)
    {
        $this->dispatcher->dispatch($eventName, new ObjectEvent($this->agent, $object));
    }
}