WebnetFr\DatabaseAnonymizer\Command\AnonymizeCommand

Complexity

Total Complexity

7

Size/Duplication

Total Lines	83
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	execute()	0	40	5
A	configure()	0	15	1
A	__construct()	0	5	1

<?php

namespace WebnetFr\DatabaseAnonymizer\Command;

use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Question\ConfirmationQuestion;
use WebnetFr\DatabaseAnonymizer\Anonymizer;
use WebnetFr\DatabaseAnonymizer\Config\TargetFactory;
use WebnetFr\DatabaseAnonymizer\GeneratorFactory\GeneratorFactoryInterface;

/**
 * @author Vlad Riabchenko <vriabchenko@webnet.fr>
 */
class AnonymizeCommand extends Command
{
    use AnonymizeCommandTrait;

    /**
     * @var GeneratorFactoryInterface
     */
    private $generatorFactory;

    /**
     * @param GeneratorFactoryInterface $generatorFactory
     */
    public function __construct(GeneratorFactoryInterface $generatorFactory)
    {
        parent::__construct();

        $this->generatorFactory = $generatorFactory;
    }

    /**
     * @inheritdoc
     */
    protected function configure()
    {
        parent::configure();

        $this->setName('webnet-fr:anonymizer:anonymize')
            ->setDescription('Anoymize database.')
            ->setHelp('Anoymize database according to GDPR (General Data Protection Regulation).')
            ->addArgument('config', InputArgument::REQUIRED, 'Configuration file.')
            ->addOption('url', 'U', InputOption::VALUE_REQUIRED, 'Database connection string.')
            ->addOption('type', 't', InputOption::VALUE_REQUIRED, 'Database type.')
            ->addOption('host', 'H', InputOption::VALUE_REQUIRED, 'Database connection string.')
            ->addOption('port', 'P', InputOption::VALUE_REQUIRED, 'Database connection string.')
            ->addOption('database', 'd', InputOption::VALUE_REQUIRED, 'Database connection string.')
            ->addOption('user', 'u', InputOption::VALUE_REQUIRED, 'Database connection string.')
            ->addOption('password', 'p', InputOption::VALUE_REQUIRED, 'Database connection string.')
        ;
    }

    /**
     * @inheritdoc
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $questionHelper = $this->getHelper('question');
        $question = new ConfirmationQuestion('Are you sure you want to anonymize your database?', false);

        if (!$input->getOption('no-interaction') && !$questionHelper->ask($input, $output, $question)) {
            return;
        }

        if ($dbURL = $input->getOption('url')) {
            $params = ['url' => $dbURL];
        } else {
            $params = [
                'driver' => $input->getOption('type'),
                'host' => $input->getOption('host'),
                'port' => $input->getOption('port'),
                'dbname' => $input->getOption('database'),
                'user' => $input->getOption('user'),
                'password' => $input->getOption('password'),
            ];
        }

        $connection = $this->getConnection($params);

        $configFile = $input->getArgument('config');
        $configFilePath = realpath($input->getArgument('config'));

It seems like $input->getArgument('config') can also be of type string[]; however, parameter $path of realpath() does only seem to accept string, maybe add an additional type check?

        if (!is_file($configFilePath)) {
            $output->writeln(sprintf('<error>Configuration file "%s" does not exist.</error>', $configFile));

It seems like $configFile can also be of type string[]; however, parameter $args of sprintf() does only seem to accept string, maybe add an additional type check?

            return;
        }

        $config = $this->getConfigFromFile($configFilePath);

        $targetFactory = (new TargetFactory($this->generatorFactory))
            ->setConnection($connection);
        $targetTables = $targetFactory->createTargets($config);

        $anonymizer = new Anonymizer();
        $anonymizer->anonymize($connection, $targetTables);
    }
}