EsIndexSwitcher\EsIndexSwitcher

Complexity

Total Complexity

14

Size/Duplication

Total Lines	187
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

97.87%

Importance

Changes

0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	14	2
A	getClient()	0	4	1
A	getAlias()	0	4	1
A	getIndexPrefix()	0	4	1
A	getIndexSuffix()	0	4	1
A	getNewIndexName()	0	4	1
A	createNewIndex()	0	10	1
A	finish()	0	17	1
A	updateAlias()	0	19	1
A	fetchCurrentIndices()	0	8	1
A	removeOldIndices()	0	19	3

<?php
namespace EsIndexSwitcher;

use Elasticsearch\Client;
use DateTime;

class EsIndexSwitcher
{

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

    /**
     *
     * @var string
     */
    private $alias;

    /**
     *
     * @var string
     */
    private $indexPrefix;

    /**
     *
     * @var string
     */
    private $indexSuffix;

    public function __construct(Client $client, string $alias, string $indexPrefix, string $indexSuffix = null)
    {
        $this->client = $client;
        
        $this->alias = $alias;
        
        if ($indexSuffix === null) {
            $indexSuffix = new DateTime();
            $indexSuffix = $indexSuffix->format('Y-m-d_H-i-s');
        }
        
        $this->indexPrefix = $indexPrefix;
        $this->indexSuffix = $indexSuffix;
    }

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

    /**
     *
     * @return string
     */
    public function getAlias()
    {
        return $this->alias;
    }

    /**
     *
     * @return string
     */
    public function getIndexPrefix()
    {
        return $this->indexPrefix;
    }

    /**
     *
     * @return string
     */
    public function getIndexSuffix()
    {
        return $this->indexSuffix;
    }

    /**
     *
     * @return string
     */
    public function getNewIndexName()
    {
        return $this->getIndexPrefix() . '_' . $this->getIndexSuffix();
    }

    /**
     *
     * @param array $indexBody
     * @return array
     */
    public function createNewIndex(array $indexBody = [])
    {
        $client = $this->getClient();
        
        $params = [
            'index' => $this->getNewIndexName(),
            'body' => $indexBody
        ];
        return $client->indices()->create($params);
    }

    /**
     *
     * @return void
     */
    public function finish()
    {
        /*
         * Step 2) Update now the alias
         */
        $response = $this->updateAlias();

$response is not used, you could remove the assignment.

        
        /*
         * Step 3) list all indices with the given prefix
         */
        $indices = $this->fetchCurrentIndices();
        
        /*
         * Step 3) Remove old indices
         */
        $response = $this->removeOldIndices($indices);

$response is not used, you could remove the assignment.

    }

    /**
     *
     * @return array
     */
    private function updateAlias()
    {
        $client = $this->getClient();
        
        $params = [
            'body' => [
                'actions' => [
                    [
                        'add' => [
                            'index' => $this->getNewIndexName(),
                            'alias' => $this->getAlias()
                        ]
                    ]
                ]
            ]
        ];
        
        return $client->indices()->updateAliases($params);
    }

    /**
     *
     * @return array
     */
    private function fetchCurrentIndices()
    {
        $client = $this->getClient();
        
        return $client->cat()->indices([
            'index' => $this->getIndexPrefix() . '*'
        ]);
    }

    /**
     *
     * @param array $indices
     * @return array
     */
    private function removeOldIndices(array $indices)
    {
        $client = $this->getClient();
        
        $response = [];
        foreach ($indices as $index) {
            // do not delete the just new created index
            if ($index['index'] === $this->getNewIndexName()) {
                continue;
            }
            
            // but all other
            $response[$index['index']] = $client->indices()->delete([
                'index' => $index['index']
            ]);
        }
        
        return $response;
    }
}