FOS\ElasticaBundle\Command\CreateCommand

Complexity

Total Complexity

7

Size/Duplication

Total Lines	56
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	9

Test Coverage

Coverage

92.31%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	8	1
A	__construct()	0	13	1
A	execute()	0	23	5

<?php

/*
 * This file is part of the FOSElasticaBundle package.
 *
 * (c) FriendsOfSymfony <http://friendsofsymfony.github.com/>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace FOS\ElasticaBundle\Command;

use FOS\ElasticaBundle\Configuration\ConfigManager;
use FOS\ElasticaBundle\Index\AliasProcessor;
use FOS\ElasticaBundle\Index\IndexManager;
use FOS\ElasticaBundle\Index\MappingBuilder;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;

/**
 * @author Oleg Andreyev <oleg.andreyev@intexsys.lv>
 */
class CreateCommand extends Command
{
    protected static $defaultName = 'fos:elastica:create';

    private $indexManager;
    private $mappingBuilder;
    private $configManager;
    private $aliasProcessor;

    public function __construct(
        IndexManager $indexManager,
        MappingBuilder $mappingBuilder,
        ConfigManager $configManager,
        AliasProcessor $aliasProcessor
    ) {
        parent::__construct();

        $this->indexManager = $indexManager;
        $this->mappingBuilder = $mappingBuilder;
        $this->configManager = $configManager;
        $this->aliasProcessor = $aliasProcessor;
    }

    protected function configure()
    {
        $this
            ->setName('fos:elastica:create')
            ->addOption('index', null, InputOption::VALUE_OPTIONAL, 'Index that needs to be created')
            ->setDescription('Creating empty index with mapping')
        ;
    }

    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $indexName = $input->getOption('index');
        $indexes = null === $indexName ? array_keys($this->indexManager->getAllIndexes()) : [$indexName];

        foreach ($indexes as $indexName) {
            $output->writeln(sprintf('<info>Creating</info> <comment>%s</comment>', $indexName));

            $indexConfig = $this->configManager->getIndexConfiguration($indexName);
            $index = $this->indexManager->getIndex($indexName);
            if ($indexConfig->isUseAlias()) {
                $this->aliasProcessor->setRootName($indexConfig, $index);
            }
            $mapping = $this->mappingBuilder->buildIndexMapping($indexConfig);
            $index->create($mapping, false);

            if ($indexConfig->isUseAlias()) {
                $index->addAlias($indexName);
            }
        }

        return 0;
    }
}