TreeHouse\IoBundle\Command\ImportCloseCommand

Complexity

Total Complexity

12

Size/Duplication

Total Lines	94
Duplicated Lines	5.32 %

Coupling/Cohesion

Components	2
Dependencies	6

Test Coverage

Coverage

0%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	configure()	0	6	1
A	findImportById()	0	4	1
A	getRepository()	0	4	1
B	execute()	5	45	8

<?php

namespace TreeHouse\IoBundle\Command;

use Doctrine\Common\Persistence\ManagerRegistry;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use TreeHouse\IoBundle\Entity\Import;
use TreeHouse\IoBundle\Entity\ImportRepository;

class ImportCloseCommand extends Command
{
    /**
     * @var ManagerRegistry
     */
    protected $doctrine;

    /**
     * @param ManagerRegistry $doctrine
     */
    public function __construct(ManagerRegistry $doctrine)
    {
        $this->doctrine = $doctrine;

        parent::__construct();
    }

    /**
     * @inheritdoc
     */
    protected function configure()
    {
        $this->setName('io:import:close');
        $this->addArgument('import', InputArgument::REQUIRED, 'The id of the import');
        $this->setDescription('Closes an import');
    }

    /**
     * @inheritdoc
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        if (null === $import = $this->findImportById($input->getArgument('import'))) {

This code seems to be duplicated across your project.

$input->getArgument('import') is of type string|array<integer,string>|null, but the function expects a integer.

            $output->writeln(sprintf('<error>Import %d does not exist</error>', $input->getArgument('import')));

            return 1;
        }

        // start import if it hasn't already
        if (!$import->isStarted()) {
            $output->writeln(sprintf('Starting import <comment>%d</comment> before closing it', $import->getId()));
            $this->getRepository()->startImport($import);
        }

        if ($import->isFinished()) {
            $output->writeln(sprintf('Import <comment>%d</comment> is already finished', $import->getId()));

            return 1;
        }

        $output->writeln(sprintf('Closing import <comment>%d</comment>', $import->getId()));

        if ($this->getRepository()->importHasUnfinishedParts($import)) {
            $output->writeln('Closing unfinished parts first');

            foreach ($import->getParts() as $part) {
                $output->writeln(sprintf('Closing part <comment>%d</comment>', $part->getPosition()));

                if (!$part->isStarted()) {
                    $part->setProcess(0);
                    $this->getRepository()->startImportPart($part);
                }

                if (!$part->isFinished()) {
                    $this->getRepository()->finishImportPart($part);
                }
            }
        }

        $this->getRepository()->finishImport($import);

        $output->writeln('<info>Import closed</info>');

        return 0;
    }

    /**
     * @param int $id
     *
     * @return Import
     */
    protected function findImportById($id)
    {
        return $this->getRepository()->find($id);
    }

    /**
     * @return ImportRepository
     */
    protected function getRepository()
    {
        return $this->doctrine->getRepository('TreeHouseIoBundle:Import');
    }
}