ElasticSearchEngine::mapIds() - Code Metrics - Inspection of "paginate function" - arunfung/scout-elasticsearch - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 03414a...cb523d )

by Arun

created 2019-07-28 15:04 UTC

ElasticSearchEngine::mapIds() A

↳ Parent: ElasticSearchEngine

Complexity

Conditions	1
Paths	1

Size

Total Lines	3
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	1
eloc	1
c	1
b	0
f	0
nc	1
nop	1
dl	0
loc	3
rs	10

<?php
/**
 * Created by PhpStorm.
 * User: arun
 * Date: 2019-07-07
 * Time: 12:59
 */

namespace ArunFung\ScoutElasticSearch;

use Laravel\Scout\Builder;
use Laravel\Scout\Engines\Engine;
use Elasticsearch\Client as ElasticSearch;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Database\Eloquent\Collection;

/**
 * Class ElasticSearchEngine
 * @package ArunFung\ScoutElasticSearch
 */
class ElasticSearchEngine extends Engine
{
    /**
     * ElasticSearch instance
     *
     * @var ElasticSearch
     */
    protected $elasticSearch;

    /**
     * @var ElasticSearch Index
     */
    protected $index;

    /**
     * Create a new engine instance.
     *
     * @param ElasticSearch $elasticSearch
     * @param  $index
     * @return void
     */
    public function __construct(ElasticSearch $elasticSearch, $index)
    {
        $this->elasticSearch = $elasticSearch;
        $this->index = $index;
    }

    /**
     * Update the given model in the index.
     *
     * @param Collection $models
     * @return void
     */
    public function update($models)
    {
        $params = [];
        $models->each(function ($model) use (&$params) {
            $params['body'][] = [
                'index' => [
                    '_index' => $this->index,
                    '_type' => $model->searchableAs(),
                    '_id' => $model->getScoutKey()
                ]
            ];
            $params['body'][] = $model->toSearchableArray();
        });

        $this->elasticSearch->bulk($params);
    }

    /**
     * Remove the given model from the index.
     *
     * @param Collection $models
     * @return void
     */
    public function delete($models)
    {
        $params = [];
        $models->each(function ($model) use (&$params) {
            $params['body'][] = [
                'delete' => [
                    '_index' => $this->index,
                    '_type' => $model->searchableAs(),
                    '_id' => $model->getScoutKey()
                ]
            ];
        });
        $this->elasticSearch->bulk($params);
    }

    /**
     * Perform the given search on the engine.
     *
     * @param \Laravel\Scout\Builder $builder
     * @return mixed
     */
    public function search(Builder $builder)
    {
        // TODO: Implement search() method.
    }

    /**
     * Perform the given search on the engine.
     *
     * @param Builder $builder
     * @param int $perPage
     * @param int $page
     * @return mixed
     */
    public function paginate(Builder $builder, $perPage, $page)
    {
        $options = [
            'numericFilters' => $this->filters($builder),
            'from' => (($page - 1) * $perPage),
            'size' => $perPage,
        ];

        return $this->performSearch($builder, $options);
    }

    /**
     * Perform the given search on the engine.
     *
     * @param Builder $builder
     * @param array $options
     * @return mixed
     */
    protected function performSearch(Builder $builder, array $options = [])
    {
        $params = [
            'index' => $this->index,
            'type' => $builder->model->searchableAs(),
        ];

        $must = [['query_string' => ['query' => "*{$builder->query}*"]]];

        if (isset($options['numericFilters']) && count($options['numericFilters'])) {
            $must = array_merge($must, $options['numericFilters']);
        }

        $body['query'] = [

            'query' => [
                'bool' => [
                    'must' => $must
                ]
            ]
        ];

        if (isset($options['from'])) {
            $body['from'] = $options['from'];
        }

        if (isset($options['size'])) {
            $body['size'] = $options['size'];
        }

        $params['body'] = $body;

        if ($builder->callback) {
            return call_user_func(
                $builder->callback,
                $this->elasticSearch,
                $builder->query,
                $params
            );
        }
        return $this->elasticSearch->search();
    }

    /**
     * Get the filter array for the query.
     *
     * @param Builder $builder
     * @return array
     */
    protected function filters(Builder $builder)
    {
        return collect($builder->wheres)->map(function ($value, $key) {
            if (is_array($value)) {
                return ['terms' => [$key => $value]];
            }
            return ['match_phrase' => [$key => $value]];
        })->values()->all();
    }

    /**
     * Pluck and return the primary keys of the given results.
     *
     * @param mixed $results
     * @return \Illuminate\Support\Collection
     */
    public function mapIds($results)
    {
        return collect($results['hits']['hits'])->pluck('_id');
    }

    /**
     * Map the given results to instances of the given model.
     *
     * @param Builder $builder
     * @param mixed $results
     * @param Model $model
     * @return Collection
     */
    public function map(Builder $builder, $results, $model)
    {
        if ($this->getTotalCount($results) == 0) {
            return $model->newCollection();
        }

        $ids = $this->mapIds($results)->all();

        return $model->getScoutModelsByIds(

            $builder, $ids
        )->filter(function ($model) use ($ids) {
            return in_array($model->getScoutKey(), $ids);
        })->values();
    }

    /**
     * Get the total count from a raw result returned by the engine.
     *
     * @param mixed $results
     * @return int
     */
    public function getTotalCount($results)
    {
        return $results['hits']['total']['value'];
    }

    /**
     * Flush all of the model's records from the engine.
     *
     * @param Model $model
     * @return void
     */
    public function flush($model)
    {
        $model->newQuery()->orderBy($model->getKeyName())->unsearchable();
    }
}


1			<?php
2			/**
3			* Created by PhpStorm.
4			* User: arun
5			* Date: 2019-07-07
6			* Time: 12:59
7			*/
8
9			namespace ArunFung\ScoutElasticSearch;
10
11			use Laravel\Scout\Builder;
12			use Laravel\Scout\Engines\Engine;
13			use Elasticsearch\Client as ElasticSearch;
14			use Illuminate\Database\Eloquent\Model;
15			use Illuminate\Database\Eloquent\Collection;
16
17			/**
18			* Class ElasticSearchEngine
19			* @package ArunFung\ScoutElasticSearch
20			*/
21			class ElasticSearchEngine extends Engine
22			{
23			/**
24			* ElasticSearch instance
25			*
26			* @var ElasticSearch
27			*/
28			protected $elasticSearch;
29
30			/**
31			* @var ElasticSearch Index
32			*/
33			protected $index;
34
35			/**
36			* Create a new engine instance.
37			*
38			* @param ElasticSearch $elasticSearch
39			* @param $index
40			* @return void
41			*/
42			public function __construct(ElasticSearch $elasticSearch, $index)
43			{
44			$this->elasticSearch = $elasticSearch;
45			$this->index = $index;
46			}
47
48			/**
49			* Update the given model in the index.
50			*
51			* @param Collection $models
52			* @return void
53			*/
54			public function update($models)
55			{
56			$params = [];
57			$models->each(function ($model) use (&$params) {
58			$params['body'][] = [
59			'index' => [
60			'_index' => $this->index,
61			'_type' => $model->searchableAs(),
62			'_id' => $model->getScoutKey()
63			]
64			];
65			$params['body'][] = $model->toSearchableArray();
66			});
67
68			$this->elasticSearch->bulk($params);
69			}
70
71			/**
72			* Remove the given model from the index.
73			*
74			* @param Collection $models
75			* @return void
76			*/
77			public function delete($models)
78			{
79			$params = [];
80			$models->each(function ($model) use (&$params) {
81			$params['body'][] = [
82			'delete' => [
83			'_index' => $this->index,
84			'_type' => $model->searchableAs(),
85			'_id' => $model->getScoutKey()
86			]
87			];
88			});
89			$this->elasticSearch->bulk($params);
90			}
91
92			/**
93			* Perform the given search on the engine.
94			*
95			* @param \Laravel\Scout\Builder $builder
96			* @return mixed
97			*/
98			public function search(Builder $builder)
99			{
100			// TODO: Implement search() method.
101			}
102
103			/**
104			* Perform the given search on the engine.
105			*
106			* @param Builder $builder
107			* @param int $perPage
108			* @param int $page
109			* @return mixed
110			*/
111			public function paginate(Builder $builder, $perPage, $page)
112			{
113			$options = [
114			'numericFilters' => $this->filters($builder),
115			'from' => (($page - 1) * $perPage),
116			'size' => $perPage,
117			];
118
119			return $this->performSearch($builder, $options);
120			}
121
122			/**
123			* Perform the given search on the engine.
124			*
125			* @param Builder $builder
126			* @param array $options
127			* @return mixed
128			*/
129			protected function performSearch(Builder $builder, array $options = [])
130			{
131			$params = [
132			'index' => $this->index,
133			'type' => $builder->model->searchableAs(),
134			];
135
136			$must = [['query_string' => ['query' => "{$builder->query}"]]];
137
138			if (isset($options['numericFilters']) && count($options['numericFilters'])) {
139			$must = array_merge($must, $options['numericFilters']);
140			}
141
142			$body['query'] = [
			0 ignored issues – show Comprehensibility Best Practice introduced 2019-07-28 15:06 UTC by Report Bug Copy Issue Report `$body` was never initialized. Although not strictly required by PHP, it is generally a good practice to add `$body = array();` before regardless. Loading history...
143			'query' => [
144			'bool' => [
145			'must' => $must
146			]
147			]
148			];
149
150			if (isset($options['from'])) {
151			$body['from'] = $options['from'];
152			}
153
154			if (isset($options['size'])) {
155			$body['size'] = $options['size'];
156			}
157
158			$params['body'] = $body;
159
160			if ($builder->callback) {
161			return call_user_func(
162			$builder->callback,
163			$this->elasticSearch,
164			$builder->query,
165			$params
166			);
167			}
168			return $this->elasticSearch->search();
169			}
170
171			/**
172			* Get the filter array for the query.
173			*
174			* @param Builder $builder
175			* @return array
176			*/
177			protected function filters(Builder $builder)
178			{
179			return collect($builder->wheres)->map(function ($value, $key) {
180			if (is_array($value)) {
181			return ['terms' => [$key => $value]];
182			}
183			return ['match_phrase' => [$key => $value]];
184			})->values()->all();
185			}
186
187			/**
188			* Pluck and return the primary keys of the given results.
189			*
190			* @param mixed $results
191			* @return \Illuminate\Support\Collection
192			*/
193			public function mapIds($results)
194			{
195			return collect($results['hits']['hits'])->pluck('_id');
196			}
197
198			/**
199			* Map the given results to instances of the given model.
200			*
201			* @param Builder $builder
202			* @param mixed $results
203			* @param Model $model
204			* @return Collection
205			*/
206			public function map(Builder $builder, $results, $model)
207			{
208			if ($this->getTotalCount($results) == 0) {
209			return $model->newCollection();
210			}
211
212			$ids = $this->mapIds($results)->all();
213
214			return $model->getScoutModelsByIds(
			0 ignored issues – show Bug Best Practice introduced 2019-07-28 15:06 UTC by Report Bug Copy Issue Report The expression `return $model->getScoutM... /* ... */ })->values()` also could return the type `Illuminate\Database\Eloquent\Builder` which is incompatible with the documented return type `Illuminate\Database\Eloquent\Collection`. Loading history...
215			$builder, $ids
216			)->filter(function ($model) use ($ids) {
217			return in_array($model->getScoutKey(), $ids);
218			})->values();
219			}
220
221			/**
222			* Get the total count from a raw result returned by the engine.
223			*
224			* @param mixed $results
225			* @return int
226			*/
227			public function getTotalCount($results)
228			{
229			return $results['hits']['total']['value'];
230			}
231
232			/**
233			* Flush all of the model's records from the engine.
234			*
235			* @param Model $model
236			* @return void
237			*/
238			public function flush($model)
239			{
240			$model->newQuery()->orderBy($model->getKeyName())->unsearchable();
241			}
242			}
243

arunfung / scout-elasticsearch

Push — master ( 03414a...cb523d )

ElasticSearchEngine::mapIds() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like