DH\DoctrineAuditBundle\Command\UpdateSchemaCommand

Complexity

Total Complexity

11

Size/Duplication

Total Lines	120
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	unlock()	0	3	1
A	setContainer()	0	3	1
A	configure()	0	5	1
B	execute()	0	94	8

<?php

namespace DH\DoctrineAuditBundle\Command;

use DH\DoctrineAuditBundle\AuditManager;
use DH\DoctrineAuditBundle\Exception\UpdateException;
use DH\DoctrineAuditBundle\Helper\UpdateHelper;
use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Schema\AbstractSchemaManager;
use Doctrine\ORM\EntityManager;
use Symfony\Bridge\Doctrine\RegistryInterface;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Command\LockableTrait;
use Symfony\Component\Console\Helper\ProgressBar;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Style\SymfonyStyle;
use Symfony\Component\DependencyInjection\ContainerAwareInterface;
use Symfony\Component\DependencyInjection\ContainerInterface;

class UpdateSchemaCommand extends Command implements ContainerAwareInterface
{
    use LockableTrait;

    private $container;

    protected static $defaultName = 'audit:schema:update';

    protected function configure()
    {
        $this
            ->setDescription('Update audit tables structure')
            ->setName(self::$defaultName)
        ;
    }

    protected function execute(InputInterface $input, OutputInterface $output)
    {
        if (!$this->lock()) {
            $output->writeln('The command is already running in another process.');

            return 0;
        }

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

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

        /**
         * @var UpdateHelper $updater
         */
        $updater = new UpdateHelper($manager);

        /**
         * @var RegistryInterface $registry
         */
        $registry = $this->container->get('doctrine');

        /**
         * @var EntityManager $em
         */
        $em = $registry->getManager();

        /**
         * @var Connection $connection
         */
        $connection = $em->getConnection();

        /**
         * @var AbstractSchemaManager
         */
        $schemaManager = $connection->getSchemaManager();
        $tables = $schemaManager->listTables();
        $audits = [];
        $errors = [];

        $regex = sprintf(
            '#^%s(.*)%s$#',
            preg_quote($updater->getConfiguration()->getTablePrefix(), '#'),
            preg_quote($updater->getConfiguration()->getTableSuffix(), '#')
        );

        foreach ($tables as $table) {
            if (preg_match($regex, $table->getName())) {
                $audits[] = $table;
            }
        }

        $progressBar = new ProgressBar($output, \count($audits));
        $progressBar->setBarWidth(70);
        $progressBar->setFormat("%message%\n".$progressBar->getFormatDefinition('debug'));

        $progressBar->setMessage('Starting...');
        $progressBar->start();

        foreach ($audits as $table) {
            $progressBar->setMessage("Processing audit tables... (<info>{$table->getName()}</info>)");
            $progressBar->display();

            try {
                $updater->updateAuditTable($schemaManager, $table, $em);
            } catch (UpdateException $e) {
                $errors[] = $e->getMessage();
                $io->error($e->getMessage());
            }

            $progressBar->advance();
        }

        $progressBar->setMessage('Processing audit tables... (<info>done</info>)');
        $progressBar->display();

        $io->newLine(2);

        if (empty($errors)) {
            $io->success('Success.');
        } else {
            foreach ($errors as $error) {
                $io->error($error);
            }
        }

        // if not released explicitly, Symfony releases the lock
        // automatically when the execution of the command ends
        $this->release();

        return (int) empty($errors);
    }

    public function setContainer(ContainerInterface $container = null): void
    {
        $this->container = $container;
    }

    public function unlock()
    {
        return $this->release();

Are you sure the usage of $this->release() targeting DH\DoctrineAuditBundle\Command\UpdateSchemaCommand::release() seems to always return null.

    }
}