Hirak\Prestissimo\Plugin

Complexity

Total Complexity

19

Size/Duplication

Total Lines	143
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

83.58%

Importance

Changes	13
Bugs	2	Features	3

8 Methods

Rating	Name	Duplication	Size	Complexity
A	activate()	0	19	3
A	getSubscribedEvents()	0	11	1
A	onPreFileDownload()	0	18	4
A	onPostDependenciesSolving()	0	13	3
A	filterPackages()	0	15	4
A	setPluginConfig()	0	8	2
A	disable()	0	4	1
A	isDisabled()	0	4	1

<?php
/*
 * hirak/prestissimo
 * @author Hiraku NAKANO
 * @license MIT https://github.com/hirak/prestissimo
 */
namespace Hirak\Prestissimo;

use Composer\Composer;
use Composer\IO;
use Composer\Plugin as CPlugin;
use Composer\EventDispatcher;
use Composer\Package;
use Composer\Installer;
use Composer\DependencyResolver;

class Plugin implements
    CPlugin\PluginInterface,
    EventDispatcher\EventSubscriberInterface
{
    /** @var Composer */
    private $composer;

    /** @var IO\IOInterface */
    private $io;

    /** @var Composer\Config */
    private $config;

    /** @var Config */
    private $pluginConfig;

    /** @var boolean */
    private $disabled = false;

    private static $pluginClasses = array(
        'Aspects\AspectAuth',
        'Aspects\AspectProxy',
        'Aspects\AspectRedirect',
        'Aspects\GitHubRequest',
        'Aspects\GitLabRequest',
        'Aspects\HttpGetRequest',
        'Aspects\HttpGetResponse',
        'Aspects\JoinPoint',
        'Config',
        'CurlRemoteFilesystem',
        'Factory',
        'OutputFile',
        'ParallelDownloader',
        'Plugin',
    );

    public function activate(Composer $composer, IO\IOInterface $io)
    {
        // @codeCoverageIgnoreStart
        // guard for self-update problem
        if (__CLASS__ !== 'Hirak\Prestissimo\Plugin') {
            return $this->disable();
        }
        // @codeCoverageIgnoreEnd

        // load all classes
        foreach (self::$pluginClasses as $class) {
            class_exists(__NAMESPACE__ . '\\' . $class);
        }

        $this->composer = $composer;
        $this->config = $composer->getConfig();

It seems like $composer->getConfig() of type object<Composer\Config> is incompatible with the declared type object<Composer\Composer\Config> of property $config.

        $this->io = $io;
        $this->pluginConfig = $this->setPluginConfig();
    }

    public static function getSubscribedEvents()
    {
        return array(
            CPlugin\PluginEvents::PRE_FILE_DOWNLOAD => array(
                array('onPreFileDownload', 0),
            ),
            Installer\InstallerEvents::POST_DEPENDENCIES_SOLVING => array(
                array('onPostDependenciesSolving', PHP_INT_MAX),
            ),
        );
    }

    public function onPreFileDownload(CPlugin\PreFileDownloadEvent $ev)
    {
        if ($this->disabled) {
            return;
        }
        $scheme = parse_url($ev->getProcessedUrl(), PHP_URL_SCHEME);
        if ($scheme === 'http' || $scheme === 'https') {
            $rfs = $ev->getRemoteFilesystem();

            $curlrfs = new CurlRemoteFilesystem(
                $this->io,
                $this->config,
                $rfs->getOptions()
            );
            $curlrfs->setPluginConfig($this->pluginConfig->get());
            $ev->setRemoteFilesystem($curlrfs);
        }
    }

    /**
     * pre-fetch parallel by curl_multi
     */
    public function onPostDependenciesSolving(Installer\InstallerEvent $ev)
    {
        if ($this->disabled) {
            return;
        }
        $ops = $ev->getOperations();
        $packages = $this->filterPackages($ops);
        $pluginConfig = $this->pluginConfig->get();
        if (count($packages) >= $pluginConfig['minConnections']) {
            $downloader = new ParallelDownloader($this->io, $this->config);
            $downloader->download($packages, $pluginConfig);
        }
    }

    /**
     * @param DependencyResolver\Operation\OperationInterface[]
     * @return Package\PackageInterface[]
     */
    private static function filterPackages(array $operations)
    {
        $packs = array();
        foreach ($operations as $op) {
            switch ($op->getJobType()) {
                case 'install':
                    $packs[] = $op->getPackage();
                    break;
                case 'update':
                    $packs[] = $op->getTargetPackage();
                    break;
            }
        }
        return $packs;
    }

    private function setPluginConfig()
    {
        $config = $this->config->get('prestissimo');
        if (!is_array($config)) {
            $config = array();
        }
        return new Config($config);
    }

    public function disable()
    {
        $this->disabled = true;
    }

    public function isDisabled()
    {
        return $this->disabled;
    }
}