ongr-io / FilterManagerBundle

Filter/Widget/Search/MatchSearch.php

<?php
/*
 * This file is part of the ONGR package.
 *
 * (c) NFQ Technologies UAB <info@nfq.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */
namespace ONGR\FilterManagerBundle\Filter\Widget\Search;

use ONGR\ElasticsearchDSL\BuilderInterface;
use ONGR\ElasticsearchDSL\Query\BoolQuery;
use ONGR\ElasticsearchDSL\Query\MatchQuery;
use ONGR\ElasticsearchDSL\Query\NestedQuery;
use ONGR\ElasticsearchDSL\Search;
use ONGR\FilterManagerBundle\Filter\FilterState;
use ONGR\FilterManagerBundle\Search\SearchRequest;

/**
 * This class runs match search.
 */
class MatchSearch extends AbstractSingleValue
{
    /**
     * @var array
     */
    private $parameters = [];

    /**
     * {@inheritdoc}
     */
    public function modifySearch(Search $search, FilterState $state = null, SearchRequest $request = null)
    {
        if ($state && $state->isActive()) {
            if (strpos($this->getField(), ',') !== false) {
                $subQuery = new BoolQuery();
                foreach (explode(',', $this->getField()) as $field) {
                    $subQuery->add($this->buildMatchPart($field, $state), 'should');
                }
                $search->addQuery($subQuery, 'must');
            } else {
                $search->addQuery($this->buildMatchPart($this->getField(), $state), 'must');
            }
        }
    }

    /**
     * Build possibly nested match part.
     *
     * @param string      $field
     * @param FilterState $state
     *
     * @return BuilderInterface
     */
    private function buildMatchPart($field, FilterState $state)
    {
        if (strpos($field, '+') !== false) {

This code seems to be duplicated across your project.

            list ($path, $field) = explode('+', $field);
        }

        if (strpos($field, '^') !== false) {

This code seems to be duplicated across your project.

            list ($field, $boost) = explode('^', $field);
        }

        $query =  new MatchQuery($field, $state->getValue(), $this->parameters);
        !isset($boost) ? : $query->addParameter('boost', $boost);

        if (isset($path)) {
            $query = new NestedQuery($path, $query);
        }

        return $query;
    }

    /**
     * Sets operator
     *
     * @param string $operator
     */
    public function setOperator($operator)
    {
        $this->parameters['operator'] = $operator;
    }

    /**
     * Sets the maximum edit distance
     *
     * @param string|int|float $fuzziness
     */
    public function setFuzziness($fuzziness)
    {
        $this->parameters['fuzziness'] = $fuzziness;
    }
}