Pinq\Repository

Complexity

Total Complexity

15

Size/Duplication

Total Lines	103
Duplicated Lines	15.53 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

13 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	10	1
A	addRange()	8	8	2
A	apply()	0	4	1
A	remove()	0	4	1
A	removeRange()	8	8	2
A	removeWhere()	0	4	1
A	clear()	0	4	1
A	executeQuery()	0	4	1
A	newMethodSegment()	0	4	1
A	join()	0	6	1
A	groupJoin()	0	6	1
A	offsetSet()	0	4	1
A	offsetUnset()	0	4	1

<?php

namespace Pinq;

use Pinq\Expressions as O;
use Pinq\Iterators\IIteratorScheme;

/**
 * The standard repository class, fully implements the repository API
 *
 * @author Elliot Levin <elliotlevin@hotmail.com>
 */
class Repository extends Queryable implements IRepository, Interfaces\IOrderedRepository
{
    /**
     * The repository provider for the current instance
     *
     * @var Providers\IRepositoryProvider
     */
    protected $repositoryProvider;

    public function __construct(
            Providers\IRepositoryProvider $provider,
            Queries\ISourceInfo $sourceInfo,
            O\TraversalExpression $queryExpression = null,
            IIteratorScheme $scheme = null
    ) {
        parent::__construct($provider, $sourceInfo, $queryExpression, $scheme);

        $this->repositoryProvider = $provider;
    }

    /**
     * Executes the supplied operation query expression on the underlying repository provider.
     *
     * @param O\Expression $expression
     *
     * @return void
     */
    private function executeQuery(O\Expression $expression)
    {
        $this->repositoryProvider->execute($expression);
    }

    /**
     * {@inheritDoc}
     * @return IRepository
     */
    protected function newMethodSegment($name, array $arguments = [])
    {
        return $this->repositoryProvider->createRepository($this->newMethod($name, $arguments));
    }

    public function join($values)
    {
        return new Connectors\JoiningRepository(
                $this->repositoryProvider,
                $this->newMethod(__FUNCTION__, [$values]));
    }

    public function groupJoin($values)
    {
        return new Connectors\JoiningRepository(
                $this->repositoryProvider,
                $this->newMethod(__FUNCTION__, [$values]));
    }

    public function addRange($values)

This method seems to be duplicated in your project.

    {
        if (!Utilities::isIterable($values)) {
            throw PinqException::invalidIterable(__METHOD__, $values);
        }

        $this->executeQuery($this->newMethod(__FUNCTION__, [$values]));
    }

    public function apply(callable $function)
    {
        $this->executeQuery($this->newMethod(__FUNCTION__, [$function]));
    }

    public function remove($value)
    {
        $this->executeQuery($this->newMethod(__FUNCTION__, [$value]));
    }

    public function removeRange($values)

This method seems to be duplicated in your project.

    {
        if (!Utilities::isIterable($values)) {
            throw PinqException::invalidIterable(__METHOD__, $values);
        }

        $this->executeQuery($this->newMethod(__FUNCTION__, [$values]));
    }

    public function removeWhere(callable $predicate)
    {
        $this->executeQuery($this->newMethod(__FUNCTION__, [$predicate]));
    }

    public function clear()
    {
        $this->executeQuery($this->newMethod(__FUNCTION__));
    }

    public function offsetSet($index, $value)
    {
        $this->executeQuery($this->newMethod(__FUNCTION__, [$index, $value]));
    }

    public function offsetUnset($index)
    {
        $this->executeQuery($this->newMethod(__FUNCTION__, [$index]));
    }
}