Locastic\Loggastic\Command\PopulateCurrentDataTrackersCommand::execute()

Complexity

Conditions	9
Paths	16

Size

Total Lines	76
Code Lines	39

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        // List all loggable classes
        $loggableContextCollection = iterator_to_array($this->loggableContextCollectionFactory->create()->getIterator());

        $loggableClasses = array_keys($loggableContextCollection);
        $loggableClasses[] = 'ALL';

        // aks for the class
        $helper = $this->getHelper('question');
        $question = new ChoiceQuestion(
            'Choose loggable class to repopulate current data:',
            $loggableClasses,
            0
        );
        $question->setErrorMessage('Loggable class %s is invalid.');

        $loggableClass = $helper->ask($input, $output, $question);

The method ask() does not exist on Symfony\Component\Console\Helper\HelperInterface.

        // ask for the limit
        $question = new Question(
            'Limit number of latest objects to be populated (leave empty for no limit):',
            0
        );

        $limit = $helper->ask($input, $output, $question);

        $io = new SymfonyStyle($input, $output);

        $io->title('Creating current data log trackers ...');

        if ('ALL' !== $loggableClass) {
            $loggableClasses = [$loggableClass];
        }

        foreach ($loggableClasses as $loggableClass) {
            if ('ALL' === $loggableClass) {
                continue;
            }

            try {
                $this->elasticsearchIndexFactory->recreateCurrentDataTrackerLogIndex($loggableClass);
            } catch (\Exception $e) {
                $io->error($e->getMessage());

                return Command::FAILURE;
            }

            // get repository for current loggable class and pull all data from DB
            $manager = $this->managerRegistry->getManagerForClass($loggableClass);

            // loggable class not mapped to the db, skip
            if (!$manager) {
                continue;
            }

            $io->title('Processing '.$loggableClass);
            $repository = $manager->getRepository($loggableClass);

            $batchSize = 250;
            $messagesCount = 0;
            $count = $repository->count([]);

            if (0 === $limit || (int) $limit > $count) {
                $limit = $count;
            }

            for ($offset = 0; $offset < $limit; $offset += $batchSize) {
                $this->bus->dispatch(new PopulateCurrentDataTrackersMessage($offset, $batchSize, $loggableClass, $loggableContextCollection[$loggableClass]));
                ++$messagesCount;
            }

            $io->success('Dispatched '.$messagesCount.' messages for populating '.$loggableClass.' data trackers');
        }

        return Command::SUCCESS;
    }