DH\DoctrineAuditBundle\Command\UpdateSchemaCommand::execute()

Complexity

Conditions	11
Paths	23

Size

Total Lines	97
Code Lines	48

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	1	Features	0

<?php
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        if (null === $this->container) {
            throw new RuntimeException('No container.');
        }

        if (!$this->lock()) {
            $output->writeln('The command is already running in another process.');

            return 0;
        }

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

        $dumpSql = true === $input->getOption('dump-sql');
        $force = true === $input->getOption('force');

        /**
         * @var TransactionManager
         */
        $manager = $this->container->get('dh_doctrine_audit.manager');

        /**
         * @var Reader
         */
        $reader = $this->container->get('dh_doctrine_audit.reader');

        /**
         * @var \DH\DoctrineAuditBundle\Updater\UpdateManager
         */
        $updater = new UpdateManager($manager, $reader);

It seems like $manager can also be of type null; however, parameter $transactionManager of DH\DoctrineAuditBundle\Updater\UpdateManager::__construct() does only seem to accept DH\DoctrineAuditBundle\Transaction\TransactionManager, maybe add an additional type check?

It seems like $reader can also be of type null; however, parameter $reader of DH\DoctrineAuditBundle\Updater\UpdateManager::__construct() does only seem to accept DH\DoctrineAuditBundle\Reader\Reader, maybe add an additional type check?

        $sqls = $updater->getUpdateAuditSchemaSql();

        if (empty($sqls)) {
            $io->success('Nothing to update.');

            $this->release();

            return 0;
        }

        if ($dumpSql) {
            $io->text('The following SQL statements will be executed:');
            $io->newLine();

            foreach ($sqls as $sql) {
                $io->text(sprintf('    %s;', $sql));
            }
        }

        if ($force) {
            if ($dumpSql) {
                $io->newLine();
            }
            $io->text('Updating database schema...');
            $io->newLine();

            $progressBar = new ProgressBar($output, \count($sqls));
            $progressBar->start();

            $updater->updateAuditSchema($sqls, static function (array $progress) use ($progressBar): void {
                $progressBar->advance();
            });

            $progressBar->finish();

            $io->newLine(2);

            $pluralization = (1 === \count($sqls)) ? 'query was' : 'queries were';

            $io->text(sprintf('    <info>%s</info> %s executed', \count($sqls), $pluralization));
            $io->success('Database schema updated successfully!');
        }

        if ($dumpSql || $force) {
            $this->release();

            return 0;
        }

        $io->caution('This operation should not be executed in a production environment!');

        $io->text(
            [
                sprintf('The Schema-Tool would execute <info>"%s"</info> queries to update the database.', \count($sqls)),
                '',
                'Please run the operation by passing one - or both - of the following options:',
                '',
                sprintf('    <info>%s --force</info> to execute the command', $this->getName()),
                sprintf('    <info>%s --dump-sql</info> to dump the SQL statements to the screen', $this->getName()),
            ]
        );

        $this->release();

        return 1;
    }