Nord\Lumen\Elasticsearch\ElasticsearchService

Complexity

Total Complexity

16

Size/Duplication

Total Lines	164
Duplicated Lines	0 %

Importance

Changes	7
Bugs	0	Features	1

16 Methods

Rating	Name	Duplication	Size	Complexity
A	createSearch()	0	3	1
A	reindex()	0	3	1
A	deleteByQuery()	0	5	1
A	index()	0	5	1
A	updateByQuery()	0	5	1
A	delete()	0	5	1
A	create()	0	5	1
A	bulk()	0	5	1
A	tasks()	0	3	1
A	execute()	0	8	1
A	indices()	0	3	1
A	createSort()	0	3	1
A	exists()	0	5	1
A	__construct()	0	3	1
A	search()	0	5	1
A	count()	0	9	1

<?php namespace Nord\Lumen\Elasticsearch;

use Elasticsearch\Client;
use Nord\Lumen\Elasticsearch\Contracts\ElasticsearchServiceContract;
use Nord\Lumen\Elasticsearch\Search\Search;
use Nord\Lumen\Elasticsearch\Search\Sort;

class ElasticsearchService implements ElasticsearchServiceContract
{

    /**
     * @var Client
     */
    private $client;

    /**
     * ElasticsearchService constructor.
     *
     * @param Client $client
     */
    public function __construct(Client $client)
    {
        $this->client = $client;
    }

    /**
     * @inheritdoc
     */
    public function search(array $params = [])
    {
        $params = IndexNamePrefixer::getPrefixedIndexParameters($params);

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

    /**
     * @inheritdoc
     */
    public function index(array $params = [])
    {
        $params = IndexNamePrefixer::getPrefixedIndexParameters($params);

        return $this->client->index($params);
    }

    /**
     * @inheritdoc
     */
    public function reindex(array $params = [])
    {
        return $this->client->reindex($params);
    }

    /**
     * @inheritdoc
     */
    public function updateByQuery(array $params = [])
    {
        $params = IndexNamePrefixer::getPrefixedIndexParameters($params);

        return $this->client->updateByQuery($params);
    }

    /**
     * @inheritdoc
     */
    public function bulk(array $params = [])
    {
        $params = IndexNamePrefixer::getPrefixedIndexParameters($params);

        return $this->client->bulk($params);
    }

    /**
     * @inheritdoc
     */
    public function delete(array $params = [])
    {
        $params = IndexNamePrefixer::getPrefixedIndexParameters($params);

        return $this->client->delete($params);
    }

    /**
     * @inheritdoc
     */
    public function deleteByQuery(array $params = [])
    {
        $params = IndexNamePrefixer::getPrefixedIndexParameters($params);

        return $this->client->deleteByQuery($params);
    }

    /**
     * @inheritdoc
     */
    public function tasks()
    {
        return $this->client->tasks();
    }

    /**
     * @inheritdoc
     */
    public function create(array $params = [])
    {
        $params = IndexNamePrefixer::getPrefixedIndexParameters($params);

        return $this->client->create($params);
    }

    /**
     * @inheritdoc
     */
    public function exists(array $params = [])
    {
        $params = IndexNamePrefixer::getPrefixedIndexParameters($params);

        return $this->client->exists($params);
    }

    /**
     * @inheritdoc
     */
    public function indices()
    {
        return $this->client->indices();
    }

    /**
     * @inheritdoc
     */
    public function createSearch()
    {
        return new Search();
    }

    /**
     * @inheritdoc
     */
    public function createSort()
    {
        return new Sort();
    }

    /**
     * @inheritdoc
     */
    public function execute(Search $search)
    {
        $index = IndexNamePrefixer::getPrefixedIndexName($search->getIndex());

        return $this->search([
            'index' => $index,
            'type'  => $search->getType(),
            'body'  => $search->buildBody(),
        ]);
    }

    /**
     * @inheritdoc
     */
    public function count(Search $search): int
    {
        $index = IndexNamePrefixer::getPrefixedIndexName($search->getIndex());

        return $this->client->count([
            'index' => $index,
            'type'  => $search->getType(),
            'body'  => $search->buildBody(),
        ])['count'];
    }
}