TYPO3GmbH / elasticorn

Classes/Commands/Index/CornifyCommand.php

<?php
declare(strict_types = 1);
namespace T3G\Elasticorn\Commands\Index;


use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Question\ConfirmationQuestion;
use T3G\Elasticorn\Commands\BaseCommand;

/**
 * Class CornifyCommand
 *
 * Converts an existing index with mapping configuration and data to an elasticorn index
 *
 * @package T3G\Elasticorn\Commands\Index
 */
class CornifyCommand extends BaseCommand
{

    /**
     * Configure the cornify command
     *
     * @return void
     */
    protected function configure()
    {
        parent::configure();
        $this
            ->setName('index:cornify')
            ->setDescription('Convert existing index to elasticorn managed index.');

        $this->addArgument('indexName', InputArgument::REQUIRED, 'The index name.');
    }

    /**
     * @param InputInterface $input
     * @param OutputInterface $output
     * @return int|null|void
     */
    public function execute(InputInterface $input, OutputInterface $output)
    {
        parent::execute($input, $output);
        $indexName = $input->getArgument('indexName');
        $helper = $this->getHelper('question');
        $continue = false;
        try {
            $continue = $this->compareConfiguration($input, $output, $helper, $indexName);
        } catch (\InvalidArgumentException $e) {
            if ($e->getCode() === 666) {
                $continue = $this->createConfiguration($input, $output, $helper, $indexName);
            }
        }

        if (true === $continue) {
            $suffix = uniqid('_', true);
            $this->indexService->renameIndex($indexName . $suffix);
            $this->indexService->initIndex($indexName);
            $this->indexService->copyData($indexName . $suffix, $indexName);
        }
    }

    /**
     * @param \Symfony\Component\Console\Input\InputInterface $input
     * @param \Symfony\Component\Console\Output\OutputInterface $output
     * @param $helper
     * @param $indexName
     * @return bool
     */
    private function createConfiguration(InputInterface $input, OutputInterface $output, $helper, $indexName)

This method seems to be duplicated in your project.

    {
        $question = new ConfirmationQuestion('Configuration does not exist. Shall I create it? [Y/n]', true);
        if (!$helper->ask($input, $output, $question)) {
            $output->writeln('Cannot continue without configuration.');
            return false;
        }
        $this->configurationService->createConfigurationFromExistingIndex($indexName, $this->indexService->getIndex());
        return true;
    }

    /**
     * @param \Symfony\Component\Console\Input\InputInterface $input
     * @param \Symfony\Component\Console\Output\OutputInterface $output
     * @param $helper
     * @return bool
     */
    private function compareConfiguration(InputInterface $input, OutputInterface $output, $helper, $indexName)

This method seems to be duplicated in your project.

    {
        $this->configurationService->compareMappingConfiguration($indexName, $this->indexService->getIndex());
        $question = new ConfirmationQuestion('Continue? [Y/n]', true);
        if (!$helper->ask($input, $output, $question)) {
            $output->writeln('User aborted.');
            return false;
        } else {
            return true;
        }
    }
}