TimeToogo / Pinq

Source/Providers/QueryProvider.php

<?php

namespace Pinq\Providers;

use Pinq\Expressions as O;
use Pinq\Queries;
use Pinq\Queries\Builders;
use Pinq\Queryable;

/**
 * Base class for the query provider.
 *
 * @author Elliot Levin <elliotlevin@hotmail.com>
 */
abstract class QueryProvider extends ProviderBase implements IQueryProvider
{
    /**
     * @var Builders\IRequestQueryBuilder
     */
    protected $requestBuilder;

    public function __construct(
            Queries\ISourceInfo $sourceInfo,
            Configuration\IQueryConfiguration $configuration = null
    ) {
        parent::__construct($sourceInfo, $configuration ?: new Configuration\DefaultQueryConfiguration());

        $this->requestBuilder        = $this->configuration->getRequestQueryBuilder();
        $this->queryResultCollection = $this->configuration->getQueryResultCollection();
    }

    public function getQueryResultCollection()
    {
        return $this->queryResultCollection;
    }

    public function createQueryable(O\TraversalExpression $scopeExpression = null)
    {
        return new Queryable($this, $this->sourceInfo, $scopeExpression, $this->scheme);
    }

    public function load(O\Expression $requestExpression)
    {
        if ($this->queryResultCollection === null) {
            return $this->loadRequestExpression($requestExpression);
        }

        if ($this->queryResultCollection->tryComputeResults($requestExpression, $results)) {
            return $results;
        }

        $queryExpression = $this->queryResultCollection->optimizeQuery($requestExpression);
        $results = $this->loadRequestExpression($queryExpression);
        $this->queryResultCollection->saveResults($queryExpression, $results);

        return $this->queryResultCollection->computeResults($requestExpression);
    }

    protected function loadRequestExpression(O\Expression $requestExpression)

This method seems to be duplicated in your project.

    {
        $resolution = $this->requestBuilder->resolveRequest($requestExpression);
        $queryHash  = $resolution->getHash();
        $query      = $this->queryCache->tryGet($queryHash);

        if (!($query instanceof Queries\IRequestQuery)) {
            $query = $this->requestBuilder->parseRequest($requestExpression);
            $this->queryCache->save($queryHash, $query);
        }

        $resolvedParameters = $query->getParameters()->resolve($resolution);

        return $this->loadRequest($query, $resolvedParameters);
    }

    /**
     * @param Queries\IRequestQuery              $request
     * @param Queries\IResolvedParameterRegistry $resolvedParameters
     *
     * @return mixed
     */
    abstract protected function loadRequest(
            Queries\IRequestQuery $request,
            Queries\IResolvedParameterRegistry $resolvedParameters
    );
}