triadev / LaravelElasticsearchProvider

src/ElasticsearchIndex.php

<?php
namespace Triadev\Es;

use Elasticsearch\Client;
use Triadev\Es\Business\Helper\Version;
use Triadev\Es\Contract\ElasticsearchClientContract;
use Triadev\Es\Contract\ElasticsearchIndexContract;
use Triadev\Es\Exception\Index\IndexFoundException;
use Triadev\Es\Exception\Index\IndexNotFoundException;

class ElasticsearchIndex implements ElasticsearchIndexContract
{
    use Version;

    /**
     * @var Client
     */
    private $client;
    
    /**
     * ElasticsearchIndex constructor.
     * @param ElasticsearchClientContract $clientBuilder
     */
    public function __construct(ElasticsearchClientContract $clientBuilder)
    {
        $this->client = $clientBuilder->getEsClient();
    }
    
    /**
     * Create index
     *
     * @param string $index
     * @param array $params
     * @param string|null $version
     * @return array
     * @throws IndexFoundException
     */
    public function createIndex(string $index, array $params, string $version = null) : array
    {
        if (!$this->existIndex([$index], $version)) {
            $params['index'] = $this->createIndexWithVersion($index, $version);

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

        throw new IndexFoundException($index, $version);
    }

    /**
     * Delete index
     *
     * @param array $index
     * @param string|null $version
     * @return array
     * @throws IndexNotFoundException
     */
    public function deleteIndex(array $index, string $version = null) : array
    {
        $indices = [];

        foreach ($index as $i) {
            if ($this->existIndex([$i], $version)) {
                $indices[] = $this->createIndexWithVersion($i, $version);
            }
        }

        if (!empty($indices)) {
            return $this->client->indices()->delete([
                'index' => implode(',', $indices)
            ]);
        }

        throw new IndexNotFoundException(implode(',', $index), $version);
    }

    /**
     * Delete all indexes
     *
     * @return array
     */
    public function deleteAllIndexes() : array
    {
        return $this->client->indices()->delete([
            'index' => '_all'
        ]);
    }

    /**
     * Exist index
     *
     * @param array $index
     * @param string|null $version
     * @return bool
     */
    public function existIndex(array $index, ?string $version = null) : bool
    {
        $indices = [];

        foreach ($index as $i) {
            $indices[] = $this->createIndexWithVersion($i, $version);
        }

        return $this->client->indices()->exists([
            'index' => implode(',', $indices)
        ]);
    }

    /**
     * Get versioned indices
     *
     * @param string $index
     * @return array
     */
    public function getVersionedIndices(string $index) : array
    {
        return array_keys($this->client->indices()->get([

$this->client->indices()->get(array('index' => sprintf('%s_*', $index))) of type boolean is incompatible with the type array expected by parameter $input of array_keys().

            'index' => sprintf("%s_*", $index)
        ]));
    }

    /**
     * Reindex
     *
     * @param string $index
     * @param string $from_version
     * @param string $to_version
     * @param array $params
     * @param array|null $source
     * @return array
     */
    public function reindex(
        string $index,
        string $from_version,
        string $to_version,
        array $params = [],
        ?array $source = null
    ) : array {
        $params['body'] = [
            'source' => [
                'index' => $this->createIndexWithVersion($index, $from_version)
            ],
            'dest' => [
                'index' => $this->createIndexWithVersion($index, $to_version)
            ]
        ];

        if (is_array($source)) {
            $params['body']['source']['_source'] = $source;
        }

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