Solr\Bridge\ResultConverter

Complexity

Total Complexity

10

Size/Duplication

Total Lines	76
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes	1
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
C	convert()	0	41	8
A	factory()	0	4	1

<?php
/**
 * YAWIK
 *
 * @filesource
 * @copyright (c) 2013 - 2016 Cross Solution (http://cross-solution.de)
 * @license   MIT
 */

namespace Solr\Bridge;

use Core\Repository\RepositoryService;
use Solr\Filter\AbstractPaginationQuery;
use Zend\ServiceManager\ServiceLocatorInterface;
use ArrayAccess;
use InvalidArgumentException;

/**
 * Class ResultConverter
 *
 * Convert SOLR query result into Doctrine ODM Entity
 *
 * @author Anthonius Munthi <me@itstoni.com>
 * @author Miroslav Fedeleš <miroslav.fedeles@gmail.com>
 * @package Solr\Bridge
 * @since 0.26
 */
class ResultConverter
{

    /**
     * @var RepositoryService
     */
    protected $repositories;

    /**
     * @param RepositoryService $repositories
     */
    public function __construct(RepositoryService $repositories)
    {
        $this->repositories = $repositories;
    }

    /**
     * Convert result into entities
     *
     * @param AbstractPaginationQuery $filter
     * @param ArrayAccess $response
     * @return array Array of entities
     * @throws InvalidArgumentException
     */
    public function convert(AbstractPaginationQuery $filter, ArrayAccess $response)
    {
        $entities = [];
        $ids = [];
        $return = [];

        if (!isset($response['response'])
            || !isset($response['response']['docs'])
            || !is_array($response['response']['docs']))
        {
            throw new InvalidArgumentException('invalid response');
        }
        
        foreach ($response['response']['docs'] as $doc) {
            $ids[] = $doc->id;
        }

        // fetch entities with given IDs
        $repository = $this->repositories->get($filter->getRepositoryName());
        $qb = $repository->createQueryBuilder()
            ->field('id')
            ->in($ids);
        $result = $qb->getQuery()->execute();
        
        foreach ($result as $document) {
            $entities[$document->getId()] = $document;
        }
        
        // iterate over Solr response to preserve sorting
        foreach ($response['response']['docs'] as $doc) {
            // check if entity exists
            if (!isset($entities[$doc->id])) {
                // skip non-existent entity
                continue;
            }
            
            $return[] = $filter->proxyFactory($entities[$doc->id], $doc);
        }
        
        return $return;
    }

    /**
     * Create a new instance of ResultConverter
     * @param   ServiceLocatorInterface $sl
     * @return  ResultConverter
     */
    static public function factory(ServiceLocatorInterface $sl)

As per PSR2, the static declaration should come after the visibility declaration.

    {
        return new static($sl->get('repositories'));

$sl->get('repositories') is of type object|array, but the function expects a object<Core\Repository\RepositoryService>.

    }
}