Clean::flush() - Code Metrics - Inspection of "Fixer" - Webysther/packagist-mirror - Measure and Improve Code Quality continuously with Scrutinizer

Test Failed
Branch — feature/decoupled (5e8293)

by Webysther
created 2017-10-31 21:00 UTC
Clean::flush() A

↳ Parent: Clean
Complexity

Conditions	3
Paths	3
Size

Total Lines	16
Code Lines	8
Duplication

Lines	0
Ratio	0 %
Code Coverage

Tests	0
CRAP Score	12
Importance

Changes
Metric	Value
cc	3
eloc	8
nc	3
nop	2
dl	0
loc	16
ccs	0
cts	12
cp	0
crap	12
rs	9.4285
c	0
b	0
f	0
<?php

declare(strict_types=1);

/*
 * This file is part of the Packagist Mirror.
 *
 * For the full license information, please view the LICENSE.md
 * file that was distributed with this source code.
 */

namespace Webs\Mirror\Command;

use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;
use Webs\Mirror\ShortName;

/**
 * Clean mirror outdated files.
 *
 * @author Webysther Nunes <[email protected]>
 */
class Clean extends Base
{
    use ShortName;

    /**
     * @var array
     */
    protected $changed = [];

    /**
     * @var array
     */
    protected $packageRemoved = [];

    /**
     * @var bool
     */
    protected $isScrub = false;

    /**
     * {@inheritdoc}
     */
    public function __construct($name = '')
    {
        parent::__construct('clean');
        $this->setDescription(
            'Clean outdated files of mirror'
        );
    }

    /**
     * Console params configuration.
     */
    protected function configure():void
    {
        parent::configure();
        $this->addOption(
            'scrub',
            null,
            InputOption::VALUE_NONE,
            'Check all directories for old files, use only to check all disk'
        );
    }

    /**
     * {@inheritdoc}
     */
    public function execute(InputInterface $input, OutputInterface $output):int
    {
        $this->progressBar->setConsole($input, $output);
        $this->package->setConsole($input, $output);
        $this->provider->setConsole($input, $output);

        if ($this->input->hasOption('scrub') && $this->input->getOption('scrub')) {
            $this->isScrub = true;
        }

        if ($this->flushProviders()->stop()) {
            return $this->exitCode;
        }

        if ($this->flushPackages()->stop()) {
            return $this->exitCode;
        }

        if (!count($this->changed)) {
            $output->writeln('<info>Nothing to clean</>');
        }

        return $this->exitCode;
    }

    /**
     * Flush old cached files of providers.
     *
     * @return Clean
     */
    protected function flushProviders():Clean
    {
        $providers = $this->package->loadMainJson();
        $includes = array_keys($this->provider->normalize($providers));

        $this->initialized = $this->filesystem->has(self::INIT);

        foreach ($includes as $uri) {
            $pattern = $this->filesystem->normalize($this->shortname($uri));
            $glob = $this->filesystem->glob($pattern);

            $this->output->writeln(
                'Check old file of <info>'.
                $pattern.
                '</>'
            );

            // If have one file and not scrubing
            if (count($glob) < 2 && !$this->isScrub) {
                continue;
            }

            $this->changed[] = $uri;
            $glob = array_diff($glob, [$uri]);

            foreach ($glob as $file) {
                if ($this->isVerbose()) {
                    $this->output->writeln(
                        'Old provider <fg=blue;>'.$file.'</> was removed!'
                    );
                }

                $this->filesystem->remove($file);
                                   remove($file);
            }
        }

        return $this;
    }

    /**
     * Flush old cached files of packages.
     *
     * @return bool True if work, false otherside
     */
    protected function flushPackages():bool
    {
        $increment = 0;

        foreach ($this->changed as $uri) {
            $providers = json_decode($this->filesystem->read($uri));
            $list = $this->package->normalize($providers->providers);

            $this->output->writeln(
                '['.++$increment.'/'.count($this->changed).'] '.
                'Check old packages for provider '.
                '<info>'.$this->shortname($uri).'</>'
            );
            $this->progressBar->start(count($list));
            $this->flushPackage(array_keys($list));
            $this->progressBar->end();
            $this->showRemovedPackages();
        }

        return true;
    }

    /**
     * Flush from one provider.
     *
     * @param array $list List of packages
     */
    protected function flushPackage(array $list):void
    {
        $packages = $this->package->getDownloaded();

        foreach ($list as $uri) {
            $this->progressBar->progress();

            if ($this->initialized) {
                continue;
            }

            $folder = dirname($uri);

            // This folder was changed by last download?
            if (count($packages) && !in_array($folder, $packages)) {
                continue;
            }

            // If only have the file and link dont exist old files
            if ($this->filesystem->count($folder) < 3) {
            if ($this->filesystem->/** @scrutinizer ignore-call */ count($folder) < 3) {
                continue;
            }

            $pattern = $this->shortname($this->filesystem->normalize($uri));
            $glob = $this->filesystem->glob($pattern);

            // If only have the file dont exist old files
            if (count($glob) < 2) {
                continue;
            }

            // Remove current value
            $glob = array_diff($glob, [$this->filesystem->normalize($uri)]);
            foreach ($glob as $file) {
                if ($this->isVerbose()) {
                    $this->packageRemoved[] = $file;
                }

                $this->filesystem->remove($file);
            }
        }
    }

    /**
     * Show packages removed.
     */
    protected function showRemovedPackages():void
    {
        foreach ($this->packageRemoved as $file) {
            $this->output->writeln(
                'Old package <fg=blue;>'.$file.'</> was removed!'
            );
        }
    }
}

Webysther / packagist-mirror

Branch — feature/decoupled (5e8293)

Clean::flush() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like
