Nord\Lumen\Elasticsearch\ElasticsearchService

Complexity

Total Complexity

19

Size/Duplication

Total Lines	182
Duplicated Lines	0 %

Importance

Changes

0

19 Methods

Rating	Name	Duplication	Size	Complexity
A	index()	0	3	1
A	__construct()	0	3	1
A	search()	0	3	1
A	reindex()	0	3	1
A	updateByQuery()	0	3	1
A	delete()	0	3	1
A	bulk()	0	3	1
A	deleteByQuery()	0	3	1
A	createSortStringParser()	0	3	1
A	createSearch()	0	3	1
A	create()	0	3	1
A	createQueryBuilder()	0	3	1
A	tasks()	0	3	1
A	execute()	0	6	1
A	indices()	0	3	1
A	createSortBuilder()	0	3	1
A	createSort()	0	3	1
A	exists()	0	3	1
A	createAggregationBuilder()	0	3	1

<?php namespace Nord\Lumen\Elasticsearch;

use Elasticsearch\Client;
use Nord\Lumen\Elasticsearch\Contracts\ElasticsearchServiceContract;
use Nord\Lumen\Elasticsearch\Parsers\SortStringParser;
use Nord\Lumen\Elasticsearch\Search\Aggregation\AggregationBuilder;
use Nord\Lumen\Elasticsearch\Search\Query\QueryBuilder;
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 = [])
    {
        return $this->client->search($params);
    }


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


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


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


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


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


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


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


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


    /**
     * @inheritdoc
     */
    public function exists(array $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 createQueryBuilder()
    {
        return new QueryBuilder();
    }


    /**
     * @inheritdoc
     */
    public function createSortBuilder()
    {
        return new Sort\SortBuilder();
    }


    /**
     * @inheritdoc
     */
    public function createSortStringParser(array $config = [])
    {
        return new SortStringParser($config);
    }


    /**
     * @inheritdoc
     */
    public function createAggregationBuilder()
    {
        return new AggregationBuilder();
    }


    /**
     * @inheritdoc
     */
    public function execute(Search $search)
    {
        return $this->search([
            'index' => $search->getIndex(),
            'type'  => $search->getType(),
            'body'  => $search->buildBody(),
        ]);
    }
}