fathomminds / php-rest-models

src/Database/Clusterpoint/Finder.php

<?php
namespace Fathomminds\Rest\Database\Clusterpoint;

use Fathomminds\Rest\Exceptions\RestException;
use Fathomminds\Rest\Database\Finder as BaseFinder;
use Clusterpoint\Client;

class Finder extends BaseFinder
{
    /**
     * @param \Clusterpoint\Instance\Service $collection
     */
    protected function setLimit($collection)
    {
        if ($this->queryConfiguration->limit !== null) {
            $collection->limit($this->queryConfiguration->limit);
        }
    }

    /**
     * @param \Clusterpoint\Instance\Service $collection
     */
    protected function setOffset($collection)
    {
        if ($this->queryConfiguration->offset !== null) {
            $collection->offset($this->queryConfiguration->offset);
        }
    }

    /**
     * @param \Clusterpoint\Instance\Service $collection
     */
    protected function setOrderBy($collection)
    {
        foreach ($this->queryConfiguration->orderBy as $orderBy) {
            $collection->orderBy(key($orderBy), current($orderBy));
        }
    }

    /**
     * @param \Clusterpoint\Instance\Service $collection
     */
    protected function setSelect($collection)
    {
        if ($this->queryConfiguration->select !== '*') {
            $collection->select($this->queryConfiguration->select);
        }
    }

    /**
     * @param \Clusterpoint\Instance\Service $collection
     */
    protected function setWhere($collection)
    {
        if (!empty($this->queryConfiguration->where)) {
            $this->parseWhere($collection, $this->queryConfiguration->where, $this->mainLogical);
        }
    }

    /**
     * @param \Clusterpoint\Instance\Service $collection
     */
    protected function configQuery($collection)
    {
        $this->setLimit($collection);
        $this->setOffset($collection);
        $this->setOrderBy($collection);
        $this->setSelect($collection);
        $this->setWhere($collection);
    }

    public function get()
    {
        if (!($this->client instanceof Client)) {
            throw new RestException(
                'Clusterpoint Finder can be used with Clusterpoint Client only',
                ['type' => get_class($this->client)]
            );
        }
        $collection = $this->client->database(
            $this->queryConfiguration->databaseName .
            '.' .
            $this->queryConfiguration->from
        );
        $this->configQuery($collection);
        $items = json_decode(json_encode($collection->get()->toArray()));
        $count = count($items);
        for ($idx = 0; $idx < $count; $idx++) {
            $this->resultSet[] = $items[$idx];
        }
        return $this;
    }

    protected function createClient()
    {
        $this->client = new Client;
        return $this;
    }

    /**
     * @param \Clusterpoint\Instance\Service $collection
     * @param array $conditions @param string $logical
     * @return \Closure
     */
    protected function addWhereGroup($collection, $conditions, $logical)

The parameter $collection is not used and could be removed.

    {
        /**
         * @codeCoverageIgnore
         * Passing anonymous function to Clusterpoint API
         */
        return function($collection) use ($conditions, $logical) {
            $this->parseWhere($collection, $conditions, $logical);
        };
    }

    /**
     * @param string $logical
     * @param \Clusterpoint\Instance\Service $collection
     * @param array $condition
     * @param string $nextLogical
     */
    protected function parseWhereGroup($logical, $collection, $condition, $nextLogical)
    {
        if ($logical === '||') {
            $collection->orWhere($this->addWhereGroup($collection, $condition, $nextLogical));
        }
        if ($logical === '&&') {
            $collection->where($this->addWhereGroup($collection, $condition, $nextLogical));
        }
    }

    /**
     * @param \Clusterpoint\Instance\Service $collection
     * @param array $conditions
     * @param string $logical
     */
    private function parseWhere($collection, $conditions, $logical)
    {
        foreach ($conditions as $key => $condition) {
            switch (strtoupper($key)) {
                case 'AND':
                    $this->parseWhereGroup($logical, $collection, $condition, '&&');
                    break;
                case 'OR':
                    $this->parseWhereGroup($logical, $collection, $condition, '||');
                    break;
                default:
                    list($fieldName, $operator, $value) = $condition;
                    $collection->where($fieldName, $operator, $value, $logical, false);
            }
        }
    }
}