ElasticEngine.php

<?php

namespace App\Scout;

use Elasticsearch\ClientBuilder;
use Laravel\Scout\Builder;
use Laravel\Scout\Engines\Engine;

/**
 * Class ElasticEngine
 * @package App\Scout
 * @author Ali Cinci <[email protected]>
 */
class ElasticEngine extends Engine
{
    /**
     * @var Elastic
     */
    protected $elastic;

    /**
     * Determines if soft deletes for Scout are enabled or not.
     *
     * @var bool
     */
    protected $softDelete;

    /**
     * Create a new engine instance.
     *
     * @param false $softDelete
     * @return void
     */
    public function __construct($softDelete = false)
    {
        $elastic_ip = config('scout.elastic.connection.ip');
        $elastic_port = config('scout.elastic.connection.port');

        $host = [
            "{$elastic_ip}:{$elastic_port}"
        ];

        $elastic = ClientBuilder::create()
            ->setHosts($host)
            ->build();

        $this->elastic = $elastic;
        $this->softDelete = $softDelete;
    }

    /**
     * @param \Illuminate\Database\Eloquent\Collection $models
     */
    public function update($models) : void
    {
        $models->map(function ($model) {
            $params = [
                'index' => $model->searchableAs(),
                'id'    => $model->getScoutKey(),
                'body'  => [
                    'doc' => $model->toSearchableArray(),
                    'doc_as_upsert' => true
                ]
            ];

            $this->elastic->index($params);
        });
    }

    /**
     * @param Builder $builder
     * @param array $options
     * @return mixed|void
     */
    public function search(Builder $builder, array $options = [])
    {
        $params = [
            'index' => $builder->index ?: $builder->model->searchableAs(),
            'type' => '_doc',
            'body'  => [
                'query' => [
                    'bool' => [
                        'must' => [['query_string' => [ 'query' => "*{$builder->query}*"]]]
                    ]
                ]
            ]
        ];

        return $this->elastic->search($params);
    }
}