Coyote\Services\Elasticsearch\Builders\Job\SearchBuilder

Complexity

Total Complexity

27

Size/Duplication

Total Lines	227
Duplicated Lines	0 %

Importance

Changes

0

15 Methods

Rating	Name	Duplication	Size	Complexity
A	boostLocation()	0	3	1
A	__construct()	0	7	1
A	getSort()	0	3	1
A	addSalaryFilter()	0	4	1
A	setupAggregations()	0	6	1
A	addFirmFilter()	0	3	1
B	setPreferences()	0	17	5
A	setLanguages()	0	3	1
A	setSessionId()	0	3	1
B	build()	0	43	6
A	setupScoreFunctions()	0	7	1
A	addRemoteFilter()	0	10	3
A	addUserFilter()	0	3	1
A	setSort()	0	3	2
A	setupFilters()	0	5	1

<?php

namespace Coyote\Services\Elasticsearch\Builders\Job;

use Coyote\Services\Elasticsearch\Aggs;
use Coyote\Services\Elasticsearch\Functions\Decay;
use Coyote\Services\Elasticsearch\Functions\FieldValueFactor;
use Coyote\Services\Elasticsearch\Functions\Random;
use Coyote\Services\Elasticsearch\Functions\ScriptScore;
use Coyote\Services\Elasticsearch\MatchAll;
use Coyote\Services\Elasticsearch\MultiMatch;
use Coyote\Services\Elasticsearch\QueryBuilder;
use Coyote\Services\Elasticsearch\Filters;
use Coyote\Services\Elasticsearch\Sort;
use Coyote\Services\Geocoder\Location;
use Illuminate\Http\Request;

class SearchBuilder extends QueryBuilder
{
    const PER_PAGE = 15;
    const DEFAULT_SORT = 'boost_at';

    /**
     * @var Filters\Job\City
     */
    public $city;

    /**
     * @var Filters\Job\Location
     */
    public $location;

    /**
     * @var Filters\Job\Tag
     */
    public $tag;

    /**
     * @var string|null
     */
    protected $sessionId = null;

    /**
     * @var array
     */
    protected $languages = [];

    /**
     * @var Request
     */
    protected $request;

    /**
     * @var string
     */
    protected $sort;

    /**
     * @param Request $request
     */
    public function __construct(Request $request)
    {
        $this->request = $request;

        $this->city = new Filters\Job\City();
        $this->tag = new Filters\Job\Tag();
        $this->location = new Filters\Job\Location();
    }

    /**
     * @param string $sessionId
     */
    public function setSessionId(string $sessionId)
    {
        $this->sessionId = $sessionId;
    }

    /**
     * @param array $languages
     */
    public function setLanguages(array $languages)
    {
        $this->languages = $languages;
    }

    /**
     * @param \Coyote\Job\Preferences $preferences
     */
    public function setPreferences($preferences)
    {
        if (!empty($preferences->locations)) {
            $this->should(new Filters\Job\Location($preferences->locations));
        }

        if (!empty($preferences->tags)) {
            $this->should(new Filters\Job\Tag($preferences->tags));
        }

        if (!empty($preferences->is_remote)) {
            $this->should(new Filters\Job\Remote());
        }

        if (!empty($preferences->salary)) {

The property salary does not exist on Coyote\Job\Preferences. Since you implemented __get, consider adding a @property annotation.

            $this->should(new Filters\Range('salary', ['gte' => $preferences->salary]));
            $this->should(new Filters\Job\Currency($preferences->currency_id));
        }
    }

    /**
     * @param string $sort
     */
    public function setSort($sort)
    {
        $this->sort = in_array($sort, ['boost_at', '_score', 'salary']) ? $sort : self::DEFAULT_SORT;
    }

    /**
     * @return string
     */
    public function getSort()
    {
        return $this->sort;
    }

    /**
     * @param Location|null $location
     */
    public function boostLocation(Location $location = null)
    {
        $this->should(new Filters\Job\LocationScore($location));
    }

    /**
     * Apply remote job filter
     */
    public function addRemoteFilter()
    {
        // @see https://github.com/adam-boduch/coyote/issues/374
        // jezeli szukamy ofert pracy zdalnej ORAZ z danego miasta, stosujemy operator OR zamiast AND
        $method = count($this->city->getCities()) ? 'should' : 'must';

        $this->$method(new Filters\Job\Remote());

        if ($this->request->has('remote_range')) {
            $this->$method(new Filters\Job\RemoteRange());
        }
    }

    /**
     * @param int $salary
     * @param int $currencyId
     */
    public function addSalaryFilter($salary, $currencyId)
    {
        $this->must(new Filters\Range('salary', ['gte' => $salary]));
        $this->must(new Filters\Job\Currency($currencyId));
    }

    /**
     * @param string $name
     */
    public function addFirmFilter($name)
    {
        $this->must(new Filters\Job\Firm($name));
    }

    /**
     * @param int $userId
     */
    public function addUserFilter($userId)
    {
        $this->must(new Filters\Term('user_id', $userId));
    }

    /**
     * @return array
     */
    public function build()
    {
        if ($this->request->has('q')) {
            $this->must(
                new MultiMatch(
                    $this->request->get('q'),
                    ['title^3', 'description', 'requirements', 'recruitment', 'tags^2', 'firm.name']
                )
            );
        } else {
            // no keywords were provided -- let's calculate score based on score functions
            $this->setupScoreFunctions();
            $this->must(new MatchAll());
        }

        if ($this->request->has('city')) {
            $this->city->addCity($this->request->get('city'));
        }

        if ($this->request->has('tag')) {
            $this->tag->addTag($this->request->get('tag'));
        }

        if ($this->request->has('salary')) {
            $this->addSalaryFilter($this->request->get('salary'), $this->request->get('currency'));
        }

        if ($this->request->has('remote')) {
            $this->addRemoteFilter();
        }

        $this->score(new Random($this->sessionId, 2));
        $this->score(new ScriptScore('_score'));
        $this->sort(new Sort($this->sort, 'desc'));

        $this->setupFilters();

        // facet search
        $this->setupAggregations();

        $this->size(self::PER_PAGE * (max(0, (int) $this->request->get('page', 1) - 1)), self::PER_PAGE);

        return parent::build();
    }

    protected function setupFilters()
    {
        $this->must($this->city);
        $this->must($this->tag);
        $this->must($this->location);
    }

    protected function setupScoreFunctions()
    {
        // wazniejsze sa te ofery, ktorych pole score jest wyzsze. obliczamy to za pomoca wzoru: log(score * 1)
        $this->score(new FieldValueFactor('score', 'log', 1));
        // strsze ogloszenia traca na waznosci, glownie po 14d. z kazdym dniem score bedzie malalo o 1/10
        // za wyjatkiem pierwszych 2h publikacji
        $this->score(new Decay('boost_at', '14d', 0.1, '2h'));

'2h' of type string is incompatible with the type null|integer|double expected by parameter $offset of Coyote\Services\Elasticsearch\Functions\Decay::__construct().

    }

    protected function setupAggregations()
    {
        $this->aggs(new Aggs\Job\Location());
        $this->aggs(new Aggs\Job\Remote());
        $this->aggs(new Aggs\Job\Tag($this->languages));
        $this->aggs(new Aggs\Job\TopSpot());
    }
}