Gruberro\MongoDbMigrations\Console\Command\MigrationsCommand::execute()

Complexity

Conditions	13
Paths	490

Size

Total Lines	78
Code Lines	52

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	44
CRAP Score	13.292

Importance

Changes	2
Bugs	0	Features	0

<?php declare(strict_types=1);
    protected function execute(Console\Input\InputInterface $input, Console\Output\OutputInterface $output)
    {
        $directories = $input->getArgument('migration-directories');
        $migrations = $this->getMigrations($directories);

It seems like $directories can also be of type null and string; however, parameter $directories of Gruberro\MongoDbMigrations\Console\Command\AbstractCommand::getMigrations() does only seem to accept array, maybe add an additional type check?

        $db = $this->connect($input->getOption('server'), $input->getArgument('database'));

        $this->acquireLock($db);

        try {
            $databaseMigrationsCollection = $this->getMigrationsCollection($db);
            $progress = new Console\Helper\ProgressBar($output, count($migrations));

            switch ($output->getVerbosity()) {
                case $output::VERBOSITY_VERBOSE:
                    $format = 'verbose';
                    break;
                case $output::VERBOSITY_VERY_VERBOSE:
                    $format = 'very_verbose';
                    break;
                case $output::VERBOSITY_DEBUG:
                    $format = 'debug';
                    break;
                default:
                    $format = 'normal';
            }

            $progress->setFormat($format);
            $progress->start();
            $executedMigrations = 0;

            foreach ($migrations as $id => $migration) {
                $progress->advance();

                if ($migration instanceof MongoDbMigrations\ContextualMigrationInterface && $input->getOption('contexts') !== []) {
                    if ($migration->getContexts() === []) {
                        throw new \InvalidArgumentException('An empty context specification is not allowed');
                    }

                    if (array_intersect($migration->getContexts(), $input->getOption('contexts')) === []) {

It seems like $input->getOption('contexts') can also be of type boolean and null and string; however, parameter $array2 of array_intersect() does only seem to accept array, maybe add an additional type check?

                        continue;
                    }
                }

                if (!$migration instanceof MongoDbMigrations\RunAlwaysMigrationInterface) {
                    if ($databaseMigrationsCollection->countDocuments(['migration_id' => $id]) > 0) {
                        continue;
                    }
                }

                $migration->execute($db);
                $executedMigrations++;

                $migrationInfo = [
                    'migration_id' => $id,
                    'migration_class' => get_class($migration),
                    'last_execution_date' => new MongoDB\BSON\UTCDatetime((new \DateTime())->getTimestamp() * 1000),
                    'run_always' => $migration instanceof MongoDbMigrations\RunAlwaysMigrationInterface,
                ];

                if ($migration instanceof MongoDbMigrations\ContextualMigrationInterface) {
                    $migrationInfo['contexts'] = $migration->getContexts();
                }

                $databaseMigrationsCollection->updateOne(
                    ['migration_id' => $id],
                    ['$set' => $migrationInfo],
                    ['upsert' => true]
                );
            }

            $progress->finish();
            $output->writeln('');

            $output->writeln("<info>✓ Successfully executed {$executedMigrations} migrations</info>");
        } catch (\Exception $e) {
            throw new Console\Exception\RuntimeException('Error while executing migrations', $e->getCode(), $e);
        } finally {
            $this->releaseLock($db);
        }