Moss\Storage\Query\Storage

Complexity

Total Complexity

13

Size/Duplication

Total Lines	216
Duplicated Lines	27.78 %

Coupling/Cohesion

Components	1
Dependencies	12

Importance

Changes	8
Bugs	0	Features	0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	8	8	1
A	connection()	0	4	1
A	registerEventListener()	0	6	1
A	read()	0	10	1
A	readOne()	0	10	1
A	write()	13	13	1
A	update()	13	13	1
A	insert()	13	13	1
A	delete()	13	13	1
A	reassignEntity()	0	12	4

<?php

/*
 * This file is part of the Storage package
 *
 * (c) Michal Wachowski <wachowski.michal@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Moss\Storage\Query;

use Doctrine\DBAL\Connection;
use Moss\Storage\Model\ModelBag;
use Moss\Storage\Query\Accessor\Accessor;
use Moss\Storage\Query\Accessor\AccessorInterface;
use Moss\Storage\Query\EventDispatcher\EventDispatcherInterface;
use Moss\Storage\Query\Relation\RelationFactory;
use Moss\Storage\Query\Relation\RelationFactoryInterface;
use Moss\Storage\NormalizeNamespaceTrait;
use Moss\Storage\StorageException;

/**
 * Storage - query source, used to create and execute CRUD operations on entities
 *
 * @author  Michal Wachowski <wachowski.michal@gmail.com>
 * @package Moss\Storage
 */
class Storage implements StorageInterface
{
    use NormalizeNamespaceTrait;

    /**
     * @var Connection
     */
    protected $connection;

    /**
     * @var ModelBag
     */
    protected $models;

    /**
     * @var RelationFactoryInterface
     */
    protected $factory;

    /**
     * @var AccessorInterface
     */
    protected $accessor;

    /**
     * @var EventDispatcherInterface
     */
    protected $dispatcher;

    /**
     * Constructor
     *
     * @param Connection               $connection
     * @param ModelBag                 $models
     * @param EventDispatcherInterface $dispatcher
     */
    public function __construct(Connection $connection, ModelBag $models, EventDispatcherInterface $dispatcher)

This method seems to be duplicated in your project.

    {
        $this->connection = $connection;
        $this->models = $models;
        $this->factory = new RelationFactory($this, $models);
        $this->accessor = new Accessor();
        $this->dispatcher = $dispatcher;
    }

    /**
     * Returns connection
     *
     * @return Connection
     */
    public function connection()
    {
        return $this->connection;
    }

    /**
     * Registers event listener
     *
     * @param string   $event
     * @param callable $listener
     *
     * @return $this
     */
    public function registerEventListener($event, callable $listener)
    {
        $this->dispatcher->register($event, $listener);

        return $this;
    }

    /**
     * Sets read operation
     *
     * @param string $entityName
     *
     * @return ReadQueryInterface
     */
    public function read($entityName)
    {
        return new ReadQuery(
            $this->connection,
            $this->models->get($entityName),
            $this->factory,
            $this->accessor,
            $this->dispatcher
        );
    }

    /**
     * Sets read one operation
     *
     * @param string $entityName
     *
     * @return ReadQueryInterface
     */
    public function readOne($entityName)
    {
        return new ReadOneQuery(
            $this->connection,
            $this->models->get($entityName),
            $this->factory,
            $this->accessor,
            $this->dispatcher
        );
    }

    /**
     * Sets write operation
     *
     * @param array|object       $instance
     * @param null|string|object $entity
     *
     * @return WriteQueryInterface
     */
    public function write($instance, $entity = null)

This method seems to be duplicated in your project.

    {
        list($instance, $entity) = $this->reassignEntity($instance, $entity);

        return new WriteQuery(
            $this->connection,
            $instance,
            $this->models->get($entity),
            $this->factory,
            $this->accessor,
            $this->dispatcher
        );
    }

    /**
     * Sets update operation
     *
     * @param array|object       $instance
     * @param null|string|object $entity
     *
     * @return UpdateQueryInterface
     */
    public function update($instance, $entity = null)

This method seems to be duplicated in your project.

    {
        list($instance, $entity) = $this->reassignEntity($instance, $entity);

        return new UpdateQuery(
            $this->connection,
            $instance,
            $this->models->get($entity),
            $this->factory,
            $this->accessor,
            $this->dispatcher
        );
    }

    /**
     * Sets insert operation
     *
     * @param array|object       $instance
     * @param null|string|object $entity
     *
     * @return InsertQueryInterface
     */
    public function insert($instance, $entity = null)

This method seems to be duplicated in your project.

    {
        list($instance, $entity) = $this->reassignEntity($instance, $entity);

        return new InsertQuery(
            $this->connection,
            $instance,
            $this->models->get($entity),
            $this->factory,
            $this->accessor,
            $this->dispatcher
        );
    }

    /**
     * Sets delete operation
     *
     * @param array|object       $instance
     * @param null|string|object $entity
     *
     * @return DeleteQueryInterface
     */
    public function delete($instance, $entity = null)

This method seems to be duplicated in your project.

    {
        list($instance, $entity) = $this->reassignEntity($instance, $entity);

        return new DeleteQuery(
            $this->connection,
            $instance,
            $this->models->get($entity),
            $this->factory,
            $this->accessor,
            $this->dispatcher
        );
    }

    /**
     * Reassigns entity/instance variables if entity is object
     *
     * @param array|object       $instance
     * @param null|string|object $entity
     *
     * @return array
     * @throws StorageException
     */
    protected function reassignEntity($instance, $entity = null)
    {
        if ($entity === null && !is_object($instance)) {
            throw new StorageException('When entity class is omitted, instance must be an object');
        }

        if (is_object($instance)) {
            return [$instance, $this->normalizeNamespace($instance)];
        }

        return [$instance, $entity];
    }
}