mdiyakov / DoctrineSolrBundle

Query/UpdateQueryBuilder.php

<?php

namespace Mdiyakov\DoctrineSolrBundle\Query;

use Mdiyakov\DoctrineSolrBundle\Config\Config;
use Mdiyakov\DoctrineSolrBundle\Exception\SchemaNotFoundException;
use Mdiyakov\DoctrineSolrBundle\Query\Update\UpdateQuery;
use Mdiyakov\DoctrineSolrBundle\Schema\Schema;
use Nelmio\SolariumBundle\ClientRegistry;

class UpdateQueryBuilder
{
    /**
     * @var ClientRegistry
     */
    private $clientRegistry;

    /**
     * @var Config
     */
    private $config;

    /**
     * @param Config $config
     * @param ClientRegistry $clientRegistry
     */
    public function __construct(Config $config, ClientRegistry $clientRegistry)
    {
        $this->config = $config;
        $this->clientRegistry = $clientRegistry;
    }

    /**
     * @param string $schemaName
     * @return UpdateQuery
     * @throws \InvalidArgumentException
     * @throws SchemaNotFoundException
     */
    public function buildUpdateQueryBySchemaName($schemaName)
    {
        if (!is_string($schemaName)) {

The condition is_string($schemaName) is always true.

            throw new \InvalidArgumentException('Argument $schemaName must be a string');
        }

        $schema = $this->config->getSchemaByName($schemaName);
        if (!$schema) {
            throw new SchemaNotFoundException(
                sprintf('Schema "%s" is not found', $schemaName)
            );
        }

        return $this->buildUpdateQuery($schema);
    }

    /**
     * @param Schema $schema
     * @return UpdateQuery
     */
    public function buildUpdateQuery(Schema $schema)
    {
        return new UpdateQuery(
            $this->clientRegistry->getClient(
                $this->config->getSolariumClient($schema->getClient())
            ),
            $schema
        );
    }
}