TechDivision\Import\Cli\Plugins\DebugCreatePlugin::process()

Complexity

Conditions	10
Paths	26

Size

Total Lines	87
Code Lines	39

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    public function process()
    {
        if ($this->getConfiguration()->isConfigOutput()) {

The method isConfigOutput() does not exist on TechDivision\Import\Configuration\ConfigurationInterface.

            $configurationFiles = $this->getConfigurationFiles();
            $this->getSystemLogger()->info(
                print_r($configurationFiles, true)

It seems like print_r($configurationFiles, true) can also be of type true; however, parameter $message of Psr\Log\LoggerInterface::info() does only seem to accept string, maybe add an additional type check?

            );
            return;
        }

        // load the actual status
        $status = $this->getRegistryProcessor()->getAttribute(RegistryKeys::STATUS);

        // query whether or not the configured source directory is available
        if (isset($status[RegistryKeys::SOURCE_DIRECTORY])) {
            $sourceDir = $status[RegistryKeys::SOURCE_DIRECTORY];
        } else {
            throw new \Exception('Source directory is not available!');
        }

        // try to load the archive directory
        $archiveDir = $this->getConfiguration()->getArchiveDir();

        // try to initialize a default archive directory by concatenating 'archive' to the target directory
        if ($archiveDir === null) {

The condition $archiveDir === null is always false.

            $archiveDir = sprintf('var/import_history');
        }

        // retrieve the question helper
        $questionHelper = $this->getHelper('question');

        // initialize the array for the available serials
        $availableSerials = array();

        // load the directories from the actual working directory (broken imports, etc.)
        foreach (glob(sprintf('%s/*', $sourceDir), GLOB_ONLYDIR) as $possibleImportDir) {
            $availableSerials[basename($possibleImportDir)] = filemtime($possibleImportDir);
        }

        // load the ZIP artefacts from the archive directory
        foreach (glob(sprintf('%s/*.zip', $archiveDir)) as $possibleArtefact) {
            $availableSerials[ basename($possibleArtefact, '.zip')] = filemtime($possibleArtefact);
        }

        // sort the available serials by modification time
        uasort($availableSerials, function ($a, $b) {
            // return zero, if the passed values are equal
            if ($a == $b) {
                return 0;
            }
            // otherwise return -1 or 1
            return ($a > $b) ? -1 : 1;
        });

        // finally create the array with the available serials to render on the console
        $availableSerials = array_slice(array_keys($availableSerials), 0, $this->getInput()->getOption(InputOptionKeysInterface::RENDER_DEBUG_SERIALS));

        // this is, when the import:debug send command has been invoked
        // WITHOUT the --serial=<UUID> parameter or an invalid serial
        if (!in_array($serial = $this->getSerial(), $availableSerials, true)) {
            // create the question instance to choose the serial
            $chooseSerialQuestion = new ChoiceQuestion('Please select the serial to create the debug artefact for', $availableSerials);
            $chooseSerialQuestion->setErrorMessage('Selected serial "%s" is invalid.');

            // abort the operation if the user does not confirm with 'y' or enter
            if (!$serial = $questionHelper->ask($this->getInput(), $this->getOutput(), $chooseSerialQuestion)) {

The method ask() does not exist on Symfony\Component\Console\Helper\Helper. It seems like you code against a sub-type of Symfony\Component\Console\Helper\Helper such as Symfony\Component\Console\Helper\QuestionHelper.

                $this->getOutput()->writeln('<info>Aborting operation - debug report has NOT been sent.</info>');
                return;
            }
        }

        // update the registry with the (probably new) serial and the source directory
        $this->getRegistryProcessor()->mergeAttributesRecursive(
            RegistryKeys::STATUS,
            array(
                RegistryKeys::DEBUG_SERIAL     => $serial,
                RegistryKeys::SOURCE_DIRECTORY => sprintf('%s/%s', $sourceDir, $serial)
            )
        );

        // prepare the debug dump
        $this->getDebugUtil()->extractArchive($serial);
        $this->getDebugUtil()->prepareDump($serial);
        $dumpFilename = $this->getDebugUtil()->createDump($serial);

        // write a success message to the console
        $this->getOutput()->writeln(sprintf('<info>Successfully created debug dump "%s"</info>', $dumpFilename));
    }