Igni\Storage\Driver\MongoDB\Repository

Complexity

Total Complexity

7

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Test Coverage

Coverage

56.76%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	remove()	0	8	1
A	get()	0	17	2
A	update()	0	5	1
A	__construct()	0	6	1
A	create()	0	15	2

<?php declare(strict_types=1);

namespace Igni\Storage\Driver\MongoDB;

use Igni\Storage\Exception\RepositoryException;
use Igni\Storage\Repository as RepositoryInterface;
use Igni\Storage\EntityManager;
use Igni\Storage\Entity;

abstract class Repository implements RepositoryInterface
{
    protected $connection;
    protected $entityManager;
    protected $hydrator;
    protected $metaData;

    final public function __construct(Connection $connection, EntityManager $entityManager)
    {
        $this->connection = $connection;
        $this->entityManager = $entityManager;
        $this->metaData = $entityManager->getMetaData($this->getEntityClass());
        $this->hydrator = $entityManager->getHydrator($this->getEntityClass());
    }

    public function get($id): Entity
    {
        $cursor = $this->connection->find(
            $this->metaData->getSource(),
            ['_id' => $id],
            ['limit' => 1]
        );
        $cursor->setHydrator($this->hydrator);

        $entity = $cursor->current();
        $cursor->close();

        if (!$entity instanceof Entity) {
            throw RepositoryException::forNotFound($id);
        }

        return $entity;
    }

    public function create(Entity $entity): Entity
    {
        // Support id auto-generation.
        $entity->getId();
        $data = $this->hydrator->extract($entity);
        if (isset($data['id'])) {
            $data['_id'] = $data['id'];
            unset($data['id']);
        }
        $this->connection->insert(
            $this->metaData->getSource(),
            $data
        );

        return $entity;
    }

    public function remove(Entity $entity): Entity
    {
        $this->connection->remove(
            $this->metaData->getSource(),
            $entity->getId()->getValue()
        );

        return $entity;
    }

    public function update(Entity $entity): Entity
    {
        $this->connection->update(
            $this->metaData->getSource(),
            $this->hydrator->extract($entity)
        );

In this branch, the function will implicitly return null which is incompatible with the type-hinted return Igni\Storage\Entity. Consider adding a return statement or allowing null as return value.

    }

    abstract public function getEntityClass(): string;
}