Nord\Lumen\Elasticsearch\Console\ApplyMigrationCommand

Complexity

Total Complexity

2

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
A	handle()	0	24	2

<?php

namespace Nord\Lumen\Elasticsearch\Console;

use League\Pipeline\Pipeline;
use Nord\Lumen\Elasticsearch\Exceptions\IndexExistsException;
use Nord\Lumen\Elasticsearch\IndexNamePrefixer;
use Nord\Lumen\Elasticsearch\Pipelines\Payloads\ApplyMigrationPayload;
use Nord\Lumen\Elasticsearch\Pipelines\Stages\CheckIndexExistsStage;
use Nord\Lumen\Elasticsearch\Pipelines\Stages\CreateIndexStage;
use Nord\Lumen\Elasticsearch\Pipelines\Stages\DetermineTargetVersionStage;
use Nord\Lumen\Elasticsearch\Pipelines\Stages\ReIndexStage;
use Nord\Lumen\Elasticsearch\Pipelines\Stages\StoreIndexSettingsStage;
use Nord\Lumen\Elasticsearch\Pipelines\Stages\UpdateIndexAliasStage;

/**
 * Class ApplyMigrationCommand
 * @package Nord\Lumen\Elasticsearch\Commands\Migrations
 */
class ApplyMigrationCommand extends AbstractCommand
{
    public const DEFAULT_BATCH_SIZE = 1000;

    /**
     * @var string
     */
    protected $signature = 'elastic:migrations:migrate 
                            { config : The path to the index configuration file } 
                            { --batchSize=' . self::DEFAULT_BATCH_SIZE . ' : The number of documents to handle per batch while re-indexing }
                            { --updateAllTypes : Forces update across all types }';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Migrates the specified index to a new index using the newest configuration version';

    /**
     * @inheritDoc
     */
    public function handle()
    {
        $configurationPath = (string)$this->argument('config');
        $batchSize         = (int)$this->option('batchSize');
        $updateAllTypes    = (bool)$this->option('updateAllTypes');

        $pipeline = new Pipeline([
            new DetermineTargetVersionStage(),
            new CheckIndexExistsStage($this->elasticsearchService),
            new CreateIndexStage($this->elasticsearchService),
            new StoreIndexSettingsStage($this->elasticsearchService),
            new ReIndexStage($this->elasticsearchService),
            new UpdateIndexAliasStage($this->elasticsearchService),
        ]);

        $payload = new ApplyMigrationPayload($configurationPath, $batchSize, $updateAllTypes);

        try {
            $pipeline->process($payload);

            $this->output->writeln(sprintf('Migrated %s to %s', $payload->getPrefixedIndexName(),
                $payload->getPrefixedTargetVersionName()));
        } catch (IndexExistsException $e) {
            $this->output->writeln('No migration required');
        }
    }
}