Psi\Component\ObjectAgent\EventDispatchingAgent

Complexity

Total Complexity

9

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	find()	0	4	1
A	save()	0	6	1
A	query()	0	4	1
A	delete()	0	6	1
A	getIdentifier()	0	4	1
A	supports()	0	4	1
A	setParent()	0	4	1
A	dispatch()	0	4	1

<?php

namespace Psi\Component\ObjectAgent;

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

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

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

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

    /**
     * {@inheritdoc}
     */
    public function save($object)
    {
        $this->dispatch(Events::PRE_SAVE, $object);
        $this->agent->save($object);
        $this->dispatch(Events::POST_SAVE, $object);
    }

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

    /**
     * {@inheritdoc}
     */
    public function delete($object)
    {
        $this->dispatch(Events::PRE_DELETE, $object);
        $this->agent->delete($object);
        $this->dispatch(Events::POST_DELETE, $object);
    }

    /**
     * {@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);
    }

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