LoadDataFixturesCommand::execute() - Code Metrics - Inspection of "[DataLoader] Inject the service container" - hautelook/AliceBundle - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — 1.x (#218)

by Théo

created 2016-05-09 15:37 UTC

LoadDataFixturesCommand::execute() C

↳ Parent: LoadDataFixturesCommand

Complexity

Conditions	12
Paths	102

Size

Total Lines	73
Code Lines	41

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	37
CRAP Score	14.5309

Importance

Changes	9
Bugs	2	Features	4

Metric	Value
c	9
b	2
f	4
dl	0
loc	73
ccs	37
cts	50
cp	0.74
rs	5.4117
cc	12
eloc	41
nc	102
nop	2
crap	14.5309

How to fix Long Method Complexity

<?php

/*
 * This file is part of the Hautelook\AliceBundle package.
 *
 * (c) Baldur Rensch <[email protected]>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Hautelook\AliceBundle\Doctrine\Command;

use Doctrine\Bundle\DoctrineBundle\Registry;
use Doctrine\Common\Persistence\ManagerRegistry;
use Doctrine\DBAL\Sharding\PoolingShardConnection;
use Hautelook\AliceBundle\Alice\DataFixtures\Fixtures\LoaderInterface as FixturesLoaderInterface;
use Hautelook\AliceBundle\Alice\DataFixtures\LoaderInterface;
use Hautelook\AliceBundle\Doctrine\DataFixtures\Executor\FixturesExecutorInterface;
use Hautelook\AliceBundle\Doctrine\Finder\FixturesFinder;
use Hautelook\AliceBundle\Doctrine\Generator\LoaderGeneratorInterface;
use Hautelook\AliceBundle\Finder\FixturesFinderInterface;
use Hautelook\AliceBundle\Resolver\BundlesResolverInterface;
use Symfony\Bundle\FrameworkBundle\Console\Application;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Helper\DialogHelper;
use Symfony\Component\Console\Helper\QuestionHelper;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Question\ConfirmationQuestion;

/**
 * Command used to load the fixtures.
 *
 * @author Théo FIDRY <[email protected]>
 */
class LoadDataFixturesCommand extends Command
{
    /**
     * @var BundlesResolverInterface
     */
    private $bundlesResolver;

    /**
     * @var ManagerRegistry
     */
    private $doctrine;

    /**
     * @var FixturesExecutorInterface
     */
    private $fixturesExecutor;

    /**
     * @var FixturesFinderInterface|FixturesFinder
     */
    private $fixturesFinder;

    /**
     * @var FixturesLoaderInterface
     */
    private $fixturesLoader;

    /**
     * @var LoaderInterface
     */
    private $loader;

    /**
     * @var LoaderGeneratorInterface
     */
    private $loaderGenerator;

    /**
     * @param string                    $name             Command name
     * @param ManagerRegistry           $doctrine
     * @param LoaderInterface           $loader
     * @param FixturesLoaderInterface   $fixturesLoader
     * @param FixturesFinderInterface   $fixturesFinder
     * @param BundlesResolverInterface  $bundlesResolver
     * @param LoaderGeneratorInterface  $loaderGenerator
     * @param FixturesExecutorInterface $fixturesExecutor
     */
    public function __construct(
        $name,
        ManagerRegistry $doctrine,
        LoaderInterface $loader,
        FixturesLoaderInterface $fixturesLoader,
        FixturesFinderInterface $fixturesFinder,
        BundlesResolverInterface $bundlesResolver,
        LoaderGeneratorInterface $loaderGenerator,
        FixturesExecutorInterface $fixturesExecutor
    ) {
        $this->doctrine = $doctrine;
        $this->loader = $loader;
        $this->fixturesLoader = $fixturesLoader;
        $this->fixturesFinder = $fixturesFinder;
        $this->bundlesResolver = $bundlesResolver;
        $this->loaderGenerator = $loaderGenerator;
        $this->fixturesExecutor = $fixturesExecutor;

        parent::__construct($name);
    }

    /**
     * {@inheritdoc}
     */
    protected function configure()
    {
        $this
            ->setDescription('Load data fixtures to your database.')
            ->addOption(
                'bundle',
                'b',
                InputOption::VALUE_OPTIONAL | InputOption::VALUE_IS_ARRAY,
                'Bundles where fixtures should be loaded.'
            )
            ->addOption(
                'manager',
                'em',
                InputOption::VALUE_REQUIRED,
                'The entity manager to use for this command.'
            )
            ->addOption(
                'append',
                null,
                InputOption::VALUE_NONE,
                'Append the data fixtures instead of deleting all data from the database first.'
            )
            ->addOption(
                'shard',
                null,
                InputOption::VALUE_REQUIRED,
                'The shard database id to use for this command.'
            )
        ;

        if ($this->doctrine instanceof Registry) {
            $this->addOption('purge-with-truncate',
                null,
                InputOption::VALUE_NONE,
                'Purge data by using a database-level TRUNCATE statement when using Doctrine ORM.'
            );
        }
    }

    /**
     * {@inheritdoc}
     *
     * \RuntimeException Unsupported Application type
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        if (false !== strpos($input->getFirstArgument(), 'hautelook_alice:fixtures:load')
            || false !== strpos($input->getFirstArgument(), 'h:f:l')
        ) {
            $output->writeln('<comment>The use of "hautelook_alice:fixtures:load" command is deprecated since 1.0 and will be removed in 2.0. Use the
"hautelook_alice:doctrine:fixtures:load" instead.</comment>');
        }

        // Warn the user that the database will be purged
        // Ask him to confirm his choice
        if ($input->isInteractive() && !$input->getOption('append')) {
            if (false === $this->askConfirmation(
                    $input,
                    $output,
                    '<question>Careful, database will be purged. Do you want to continue y/N ?</question>',
                    false
                )
            ) {
                return;
            }
        }

        $manager = $this->doctrine->getManager($input->getOption('manager'));
        $environment = $input->getOption('env');
        $bundles = $input->getOption('bundle');

        /** @var Application $application */
        $application = $this->getApplication();
        if (false === $application instanceof Application) {
            throw new \RuntimeException('Expected Symfony\Bundle\FrameworkBundle\Console\Application application.');
        }

        // Get bundles
        if (true === empty($bundles)) {
            $bundles = $application->getKernel()->getBundles();
        } else {
            $bundles = $this->bundlesResolver->resolveBundles($application, $bundles);
        }

        $fixtures = $this->fixturesFinder->getFixtures($application->getKernel(), $bundles, $environment);

        $output->writeln(sprintf('  <comment>></comment> <info>%s</info>', 'fixtures found:'));
        foreach ($fixtures as $fixture) {
            $output->writeln(sprintf('      <comment>-</comment> <info>%s</info>', $fixture));
        }

        $truncate = $input->hasOption('purge-with-truncate') ? $input->getOption('purge-with-truncate') : false;

        // Shard database
        $shard = $input->getOption('shard');
        if (!empty($shard)) {
            $connection = $manager->getConnection();
            if (!$connection instanceof PoolingShardConnection) {
                throw new \RuntimeException('Expected Doctrine\DBAL\Sharding\PoolingShardConnection connection when using shard option.');
            }

            // Switch to shard database
            $connection->connect($shard);
        }

        $this->fixturesExecutor->execute(
            $manager,
            $this->loaderGenerator->generate($this->loader, $this->fixturesLoader, $bundles, $environment),
            $fixtures,
            $input->getOption('append'),
            function ($message) use ($output) {
                $output->writeln(sprintf('  <comment>></comment> <info>%s</info>', $message));
            },
            $truncate
        );
        $output->writeln(sprintf('  <comment>></comment> <info>%s</info>', 'fixtures loaded'));
    }

    /**
     * Prompt to the user a message to ask him a confirmation.
     *
     * @param InputInterface  $input
     * @param OutputInterface $output
     * @param string          $question
     * @param bool            $default
     *
     * @return bool User choice.
     */
    private function askConfirmation(InputInterface $input, OutputInterface $output, $question, $default)
    {
        if (false === class_exists('Symfony\Component\Console\Question\ConfirmationQuestion')) {
            /** @var DialogHelper $dialogHelper */
            $dialogHelper = $this->getHelperSet()->get('dialog');

            return $dialogHelper->askConfirmation($output, $question, $default);
        }

        /** @var QuestionHelper $questionHelper */
        $questionHelper = $this->getHelperSet()->get('question');
        $question = new ConfirmationQuestion($question, $default);

        return (bool) $questionHelper->ask($input, $output, $question);
    }
}


1		<?php
2
3		/*
4		* This file is part of the Hautelook\AliceBundle package.
5		*
6		* (c) Baldur Rensch <[email protected]>
7		*
8		* For the full copyright and license information, please view the LICENSE
9		* file that was distributed with this source code.
10		*/
11
12		namespace Hautelook\AliceBundle\Doctrine\Command;
13
14		use Doctrine\Bundle\DoctrineBundle\Registry;
15		use Doctrine\Common\Persistence\ManagerRegistry;
16		use Doctrine\DBAL\Sharding\PoolingShardConnection;
17		use Hautelook\AliceBundle\Alice\DataFixtures\Fixtures\LoaderInterface as FixturesLoaderInterface;
18		use Hautelook\AliceBundle\Alice\DataFixtures\LoaderInterface;
19		use Hautelook\AliceBundle\Doctrine\DataFixtures\Executor\FixturesExecutorInterface;
20		use Hautelook\AliceBundle\Doctrine\Finder\FixturesFinder;
21		use Hautelook\AliceBundle\Doctrine\Generator\LoaderGeneratorInterface;
22		use Hautelook\AliceBundle\Finder\FixturesFinderInterface;
23		use Hautelook\AliceBundle\Resolver\BundlesResolverInterface;
24		use Symfony\Bundle\FrameworkBundle\Console\Application;
25		use Symfony\Component\Console\Command\Command;
26		use Symfony\Component\Console\Helper\DialogHelper;
27		use Symfony\Component\Console\Helper\QuestionHelper;
28		use Symfony\Component\Console\Input\InputInterface;
29		use Symfony\Component\Console\Input\InputOption;
30		use Symfony\Component\Console\Output\OutputInterface;
31		use Symfony\Component\Console\Question\ConfirmationQuestion;
32
33		/**
34		* Command used to load the fixtures.
35		*
36		* @author Théo FIDRY <[email protected]>
37		*/
38		class LoadDataFixturesCommand extends Command
39		{
40		/**
41		* @var BundlesResolverInterface
42		*/
43		private $bundlesResolver;
44
45		/**
46		* @var ManagerRegistry
47		*/
48		private $doctrine;
49
50		/**
51		* @var FixturesExecutorInterface
52		*/
53		private $fixturesExecutor;
54
55		/**
56		* @var FixturesFinderInterface\|FixturesFinder
57		*/
58		private $fixturesFinder;
59
60		/**
61		* @var FixturesLoaderInterface
62		*/
63		private $fixturesLoader;
64
65		/**
66		* @var LoaderInterface
67		*/
68		private $loader;
69
70		/**
71		* @var LoaderGeneratorInterface
72		*/
73		private $loaderGenerator;
74
75		/**
76		* @param string $name Command name
77		* @param ManagerRegistry $doctrine
78		* @param LoaderInterface $loader
79		* @param FixturesLoaderInterface $fixturesLoader
80		* @param FixturesFinderInterface $fixturesFinder
81		* @param BundlesResolverInterface $bundlesResolver
82		* @param LoaderGeneratorInterface $loaderGenerator
83		* @param FixturesExecutorInterface $fixturesExecutor
84		*/
85	120	public function __construct(
86		$name,
87		ManagerRegistry $doctrine,
88		LoaderInterface $loader,
89		FixturesLoaderInterface $fixturesLoader,
90		FixturesFinderInterface $fixturesFinder,
91		BundlesResolverInterface $bundlesResolver,
92		LoaderGeneratorInterface $loaderGenerator,
93		FixturesExecutorInterface $fixturesExecutor
94		) {
95	120	$this->doctrine = $doctrine;
96	120	$this->loader = $loader;
97	120	$this->fixturesLoader = $fixturesLoader;
98	120	$this->fixturesFinder = $fixturesFinder;
99	120	$this->bundlesResolver = $bundlesResolver;
100	120	$this->loaderGenerator = $loaderGenerator;
101	120	$this->fixturesExecutor = $fixturesExecutor;
102
103	120	parent::__construct($name);
104	120	}
105
106		/**
107		* {@inheritdoc}
108		*/
109	120	protected function configure()
110		{
111	120	$this
112	120	->setDescription('Load data fixtures to your database.')
113	120	->addOption(
114	120	'bundle',
115	120	'b',
116	120	InputOption::VALUE_OPTIONAL \| InputOption::VALUE_IS_ARRAY,
117		'Bundles where fixtures should be loaded.'
118	120	)
119	120	->addOption(
120	120	'manager',
121	120	'em',
122	120	InputOption::VALUE_REQUIRED,
123		'The entity manager to use for this command.'
124	120	)
125	120	->addOption(
126	120	'append',
127	120	null,
128	120	InputOption::VALUE_NONE,
129		'Append the data fixtures instead of deleting all data from the database first.'
130	120	)
131	120	->addOption(
132	120	'shard',
133	120	null,
134	120	InputOption::VALUE_REQUIRED,
135		'The shard database id to use for this command.'
136	120	)
137		;
138
139	120	if ($this->doctrine instanceof Registry) {
140	118	$this->addOption('purge-with-truncate',
141	118	null,
142	118	InputOption::VALUE_NONE,
143		'Purge data by using a database-level TRUNCATE statement when using Doctrine ORM.'
144	118	);
145	118	}
146	120	}
147
148		/**
149		* {@inheritdoc}
150		*
151		* \RuntimeException Unsupported Application type
152		*/
153	114	protected function execute(InputInterface $input, OutputInterface $output)
154		{
155	114	if (false !== strpos($input->getFirstArgument(), 'hautelook_alice:fixtures:load')
156	114	\|\| false !== strpos($input->getFirstArgument(), 'h:f:l')
157	114	) {
158		$output->writeln('<comment>The use of "hautelook_alice:fixtures:load" command is deprecated since 1.0 and will be removed in 2.0. Use the
159		"hautelook_alice:doctrine:fixtures:load" instead.</comment>');
160		}
161
162		// Warn the user that the database will be purged
163		// Ask him to confirm his choice
164	114	if ($input->isInteractive() && !$input->getOption('append')) {
165		if (false === $this->askConfirmation(
166		$input,
167		$output,
168		'<question>Careful, database will be purged. Do you want to continue y/N ?</question>',
169		false
170		)
171		) {
172		return;
173		}
174		}
175
176	114	$manager = $this->doctrine->getManager($input->getOption('manager'));
177	78	$environment = $input->getOption('env');
178	78	$bundles = $input->getOption('bundle');
179
180		/** @var Application $application */
181	78	$application = $this->getApplication();
182	78	if (false === $application instanceof Application) {
183		throw new \RuntimeException('Expected Symfony\Bundle\FrameworkBundle\Console\Application application.');
184		}
185
186		// Get bundles
187	78	if (true === empty($bundles)) {
188	30	$bundles = $application->getKernel()->getBundles();
189	30	} else {
190	48	$bundles = $this->bundlesResolver->resolveBundles($application, $bundles);
191		}
192
193	78	$fixtures = $this->fixturesFinder->getFixtures($application->getKernel(), $bundles, $environment);
194
195	78	$output->writeln(sprintf(' <comment>></comment> <info>%s</info>', 'fixtures found:'));
196	78	foreach ($fixtures as $fixture) {
197	78	$output->writeln(sprintf(' <comment>-</comment> <info>%s</info>', $fixture));
198	78	}
199
200	78	$truncate = $input->hasOption('purge-with-truncate') ? $input->getOption('purge-with-truncate') : false;
201
202		// Shard database
203	78	$shard = $input->getOption('shard');
204	78	if (!empty($shard)) {
205	6	$connection = $manager->getConnection();
206	6	if (!$connection instanceof PoolingShardConnection) {
207		throw new \RuntimeException('Expected Doctrine\DBAL\Sharding\PoolingShardConnection connection when using shard option.');
208		}
209
210		// Switch to shard database
211	6	$connection->connect($shard);
212	6	}
213
214	78	$this->fixturesExecutor->execute(
215	78	$manager,
216	78	$this->loaderGenerator->generate($this->loader, $this->fixturesLoader, $bundles, $environment),
217	78	$fixtures,
218	78	$input->getOption('append'),
219	78	function ($message) use ($output) {
220	78	$output->writeln(sprintf(' <comment>></comment> <info>%s</info>', $message));
221	78	},
222		$truncate
223	78	);
224	78	$output->writeln(sprintf(' <comment>></comment> <info>%s</info>', 'fixtures loaded'));
225	78	}
226
227		/**
228		* Prompt to the user a message to ask him a confirmation.
229		*
230		* @param InputInterface $input
231		* @param OutputInterface $output
232		* @param string $question
233		* @param bool $default
234		*
235		* @return bool User choice.
236		*/
237		private function askConfirmation(InputInterface $input, OutputInterface $output, $question, $default)
238		{
239		if (false === class_exists('Symfony\Component\Console\Question\ConfirmationQuestion')) {
240		/** @var DialogHelper $dialogHelper */
241		$dialogHelper = $this->getHelperSet()->get('dialog');
242
243		return $dialogHelper->askConfirmation($output, $question, $default);
244		}
245
246		/** @var QuestionHelper $questionHelper */
247		$questionHelper = $this->getHelperSet()->get('question');
248		$question = new ConfirmationQuestion($question, $default);
249
250		return (bool) $questionHelper->ask($input, $output, $question);
251		}
252		}
253

hautelook / AliceBundle

GitHub Access Token became invalid

Pull Request — 1.x (#218)

LoadDataFixturesCommand::execute() C

Complexity

Size

Duplication

Code Coverage

Importance

How to fix Long Method Complexity

Long Method

Duplication Side-by-Side

Filter issues like