Psi\Bridge\ObjectAgent\Doctrine\Collections\CollectionsAgent

Complexity

Total Complexity

12

Size/Duplication

Total Lines	93
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	supports()	0	4	1
A	find()	0	17	3
A	save()	0	4	1
A	delete()	0	4	1
A	query()	0	10	1
A	getIdentifier()	0	13	3
A	setParent()	0	4	1

<?php

declare(strict_types=1);

namespace Psi\Bridge\ObjectAgent\Doctrine\Collections;

use Doctrine\Common\Collections\Criteria;
use Psi\Component\ObjectAgent\AgentInterface;
use Psi\Component\ObjectAgent\Exception\BadMethodCallException;
use Psi\Component\ObjectAgent\Exception\ObjectNotFoundException;
use Psi\Component\ObjectAgent\Query\Query;

class CollectionsAgent implements AgentInterface
{
    private $store;

    public function __construct(Store $store)
    {
        $this->store = $store;
    }

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

    /**
     * {@inheritdoc}
     */
    public function find($identifier, string $classFqn = null)
    {
        if (null === $classFqn) {
            throw BadMethodCallException::classArgumentIsMandatory(__CLASS__);
        }

        $object = $this->store->find($classFqn, $identifier);

        if (null === $object) {
            throw new ObjectNotFoundException(sprintf(
                'Could not find object of class "%s" with identifier "%s"',
                $classFqn, $identifier
            ));
        }

        return $object;
    }

    /**
     * {@inheritdoc}
     */
    public function save($object)
    {
        // do nothing ...
    }

    /**
     * {@inheritdoc}
     */
    public function delete($object)
    {
        $this->store->delete($object);
    }

    /**
     * {@inheritdoc}
     */
    public function query(Query $query): \Traversable
    {
        $collection = $this->store->getCollection($query->getClassFqn());
        $expressionBuilder = Criteria::expr();
        $visitor = new CollectionsVisitor($expressionBuilder);
        $doctrineExpression = $visitor->dispatch($query->getExpression());
        $criteria = new Criteria($doctrineExpression);

        return $collection->matching($criteria);
    }

    /**
     * {@inheritdoc}
     */
    public function getIdentifier($object)
    {
        foreach ($this->store->getCollection(get_class($object)) as $identifier => $element) {
            if ($element === $object) {
                return $identifier;
            }
        }

        throw new \RuntimeException(sprintf(
            'Could not find identifier for object of class "%s"',
            get_class($object)
        ));
    }

    /**
     * {@inheritdoc}
     */
    public function setParent($object, $parent)
    {
        throw BadMethodCallException::setParentNotSupported(__CLASS__);
    }
}