Broadway elasticsearch index generator

CreateElasticsearchIndicesCommand.php

<?php

use Broadway\ReadModel\ElasticSearch\ElasticSearchRepository;
use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

class CreateElasticsearchIndicesCommand extends ContainerAwareCommand
{
    protected function configure()
    {
        $this
            ->setName('read_model:create_elasticsearch_indices')
            ->setDescription('Creates the elasticsearch indices')
            ->setHelp(<<<EOT
The <info>%command.name%</info>command creates the elasticsearch indices for the given environment .
EOT
            )
            ->addArgument('index', InputArgument::OPTIONAL, 'Index to create');
    }

    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $indexGenerator = $this->getContainer()->get('read_model.index_generator');

        if ($input->getArgument('index')) {
            $indexGenerator->generateElasticsearchIndex($input->getArgument('index'));

            return 0;
        }

        $indexGenerator->generateElasticsearchIndices();
    }
}

ElasticSearchIndexGenerator.php

<?php

class ElasticSearchIndexGenerator
{
    /**
     * @param array $repositories
     */
    public function __construct(array $repositories)
    {
        $this->repositories = $repositories;
    }

    public function generateElasticsearchIndices()
    {
        foreach ($this->repositories as $repository) {
            $repository->createIndex();
        }
    }

    /**
     * @param string $index
     */
    public function generateElasticsearchIndex($index)
    {
        foreach ($this->repositories as $repository) {
            if ($index === get_class($repository)) {
                $repository->createIndex();

                return;
            }
        }
    }
}
=

services.xml

<service id="read_model.index_generator" class="ElasticSearchIndexGenerator">
    <argument type="collection">
        <argument type="service" id="read_model.repository1" />
        <argument type="service" id="read_model.repository2" />
        <argument type="service" id="read_model.repository3" />
        <!-- .. -->
    </argument>
</service>

Makes sense. Thanks!