Triadev\Leopard\ElasticsearchManager

Complexity

Total Complexity

18

Size/Duplication

Total Lines	197
Duplicated Lines	0 %

Test Coverage

Coverage

95%

Importance

Changes

0

17 Methods

Rating	Name	Duplication	Size	Complexity
A	repository()	0	3	1
A	bulkStatement()	0	3	1
A	map()	0	3	1
A	getEsDefaultIndex()	0	3	1
A	indexStatement()	0	3	1
A	suggestStatement()	0	3	1
A	getEsClient()	0	3	1
A	deleteStatement()	0	3	1
A	updateStatement()	0	3	1
A	putMappingStatement()	0	3	1
A	getStatement()	0	6	2
A	searchStatement()	0	3	1
A	existStatement()	0	3	1
A	existIndexStatement()	0	3	1
A	search()	0	8	1
A	__construct()	0	3	1
A	suggest()	0	3	1

<?php
namespace Triadev\Leopard;

use Elasticsearch\Client;
use Elasticsearch\Common\Exceptions\Missing404Exception;
use Illuminate\Database\Eloquent\Model;
use Triadev\Es\Contract\ElasticsearchContract;
use Triadev\Leopard\Business\Dsl\Search;
use Triadev\Leopard\Business\Dsl\Suggestion;
use Triadev\Leopard\Business\Mapping\Builder;
use Triadev\Leopard\Contract\ElasticsearchManagerContract;
use Triadev\Leopard\Contract\Repository\ElasticsearchRepositoryContract;

class ElasticsearchManager implements ElasticsearchManagerContract
{
    /** @var Client */
    private $esClient;
    
    /**
     * ElasticsearchManager constructor.
     * @param ElasticsearchContract $elasticsearch
     */
    public function __construct(ElasticsearchContract $elasticsearch)
    {
        $this->esClient = $elasticsearch->getClient();
    }
    
    /**
     * Get elasticsearch client
     *
     * @return Client
     */
    public function getEsClient(): Client
    {
        return $this->esClient;
    }
    
    /**
     * Get es default index
     *
     * @return string
     */
    public function getEsDefaultIndex() : string
    {
        return config('leopard.index');
    }
    
    /**
     * Search
     *
     * @param \ONGR\ElasticsearchDSL\Search|null $search
     * @param Model|null $model
     * @return Search
     */
    public function search(
        ?\ONGR\ElasticsearchDSL\Search $search = null,
        ?Model $model = null
    ) : Search
    {
        return app()->make(Search::class, [
            'search' => $search,
            'model' => $model
        ]);
    }
    
    /**
     * Suggestion
     *
     * @return Suggestion
     */
    public function suggest() : Suggestion
    {
        return app()->make(Suggestion::class);
    }
    
    /**
     * Repository
     *
     * @return ElasticsearchRepositoryContract
     */
    public function repository() : ElasticsearchRepositoryContract
    {
        return app(ElasticsearchRepositoryContract::class);
    }
    
    /**
     * Map
     *
     * @param \Closure $blueprint
     * @param string $index
     * @param string $type
     * @param bool $createIndex
     */
    public function map(\Closure $blueprint, string $index, string $type, bool $createIndex = false)
    {
        (new Builder())->create($blueprint, $index, $type, $createIndex);
    }
    
    /**
     * Search statement
     *
     * @param array $params
     * @return array
     */
    public function searchStatement(array $params) : array
    {
        return $this->esClient->search($params);
    }
    
    /**
     * Put mapping statement
     *
     * @param array $params
     * @return array
     */
    public function putMappingStatement(array $params): array
    {
        return $this->esClient->indices()->putMapping($params);
    }
    
    /**
     * Index statement
     *
     * @param array $params
     * @return array
     */
    public function indexStatement(array $params) : array
    {
        return $this->esClient->index($params);
    }
    
    /**
     * Update statement
     *
     * @param array $params
     * @return array
     */
    public function updateStatement(array $params) : array
    {
        return $this->esClient->update($params);
    }
    
    /**
     * Exist statement
     *
     * @param array $params
     * @return bool
     */
    public function existStatement(array $params) : bool
    {
        return $this->esClient->exists($params);
    }
    
    /**
     * Exist index statement
     *
     * @param array $params
     * @return bool
     */
    public function existIndexStatement(array $params) : bool
    {
        return $this->esClient->indices()->exists($params);
    }
    
    /**
     * Delete statement
     *
     * @param array $params
     * @return array
     */
    public function deleteStatement(array $params) : array
    {
        return $this->esClient->delete($params);
    }
    
    /**
     * Get statement
     *
     * @param array $params
     * @return array|null
     */
    public function getStatement(array $params) : ?array
    {
        try {
            return $this->esClient->get($params);
        } catch (Missing404Exception $e) {
            return null;
        }
    }
    
    /**
     * Suggest statement
     *
     * @param array $params
     * @return array
     */
    public function suggestStatement(array $params): array
    {
        return $this->esClient->suggest($params);
    }
    
    /**
     * Bulk statement
     *
     * @param array $params
     * @return array
     */
    public function bulkStatement(array $params): array
    {
        return $this->esClient->bulk($params);
    }
}