App\Composer\PackageImporter

Complexity

Total Complexity

11

Size/Duplication

Total Lines	91
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	updateReplaceProviderSignature()	0	7	3
A	__construct()	0	6	1
A	import()	0	42	4
A	getPackages()	0	14	3

<?php

namespace App\Composer;

use App\Document\Package;
use App\Document\Provider;
use Composer\Config;
use Composer\IO\IOInterface;
use Composer\Package\Dumper\ArrayDumper;
use Composer\Repository\ComposerRepository;
use Composer\Repository\VcsRepository;
use Doctrine\ODM\MongoDB\DocumentManager;

class PackageImporter
{
    private $factory;
    private $dm;
    private $mirrorUrl;
    private $packageDumper;

    public function __construct(DocumentManager $dm, string $mirrorUrl, Factory $factory, PackageDumper $packageDumper)
    {
        $this->dm = $dm;
        $this->mirrorUrl = $mirrorUrl;
        $this->factory = $factory;
        $this->packageDumper = $packageDumper;
    }

    public function import(Provider $provider): bool
    {
        $config = $this->factory->createConfig();
        $io = new LogIO();
        $io->loadConfiguration($config);

        $packages = $this->getPackages($provider, $config, $io);

        if (0 == count($packages)) {
            return false;
        }

        $dumper = new ArrayDumper();

        $provider->clearPackages();

        $replace = [];

        foreach ($packages as $package) {
            $data = $dumper->dump($package);
            $data['uid'] = uniqid();
            unset($data['notification-url']);

            // get provided packages
            if(isset($data['replace'])) {
                $replace = array_unique(array_merge($replace, array_keys($data['replace'])));
            }

            $document = new Package();
            $document
                ->setVersion($package->getPrettyVersion())
                ->setData($data);

            $provider->addPackage($document);
        }

        $provider->setReplace($replace);
        $provider->setLogs($io->getLogs());

        $provider->setSha256(hash('sha256', json_encode($this->packageDumper->dump($provider))));

        return true;
    }

    public function updateReplaceProviderSignature(Provider $provider) :void
    {
        foreach ($provider->getReplace() as $replaceName) {
            /** @var Provider $replacePackage */
            $replacePackage = $this->dm->getRepository('App:Provider')->find($replaceName);
            if($replacePackage) {
                $replacePackage->setSha256(hash('sha256', json_encode($this->packageDumper->dump($replacePackage))));
            }
        }
    }

    /**
     * @param Provider    $provider
     * @param Config      $config
     * @param IOInterface $io
     *
     * @return \Composer\Package\Package[]
     */
    private function getPackages(Provider $provider, Config $config, IOInterface $io): array
    {
        switch ($provider->getType()) {
            case Provider::TYPE_COMPOSER:
                $repository = new ComposerRepository(['url' => $this->mirrorUrl], $io, $config);
                break;
            case Provider::TYPE_VCS:
                $repository = new VcsRepository(['url' => $provider->getVcsUri()], $io, $config);
                break;
            default:
                throw new \LogicException('Invalid provider type');
        }

        return $repository->findPackages($provider->getName());
    }
}