PiouPiou\RibsAdminBundle\Service\Version

Complexity

Total Complexity

28

Size/Duplication

Total Lines	224
Duplicated Lines	0 %

Importance

Changes	14
Bugs	1	Features	7

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	getVersionDate()	0	10	3
A	updatePackage()	0	25	5
A	getComposerLockJson()	0	14	5
A	getMessages()	0	3	1
A	getToken()	0	11	3
A	save()	0	19	4
A	setPackageEntity()	0	3	1
A	getVersion()	0	3	2
A	getPackage()	0	15	3

<?php

namespace PiouPiou\RibsAdminBundle\Service;

use DateTime;
use Doctrine\ORM\EntityManagerInterface;
use PiouPiou\RibsAdminBundle\Entity\Package;
use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
use Symfony\Component\Mime\Part\Multipart\FormDataPart;
use Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface;
use Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface;
use Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface;
use Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface;
use Symfony\Contracts\HttpClient\HttpClientInterface;
use Exception;

class Version
{
    /**
     * @var EntityManagerInterface
     */
    private $em;

    /**
     * @var HttpClientInterface
     */
    private $client;

    /**
     * @var ParameterBagInterface
     */
    private $parameter;

    /**
     * @var PackagistApi
     */
    private $packagist;

    /**
     * @var mixed
     */
    private $local_token;

    /**
     * @var Package
     */
    private $package;

    private $messages = [];

    /**
     * Version constructor.
     * @param EntityManagerInterface $em
     * @param HttpClientInterface $client
     * @param ParameterBagInterface $parameter
     * @param PackagistApi $packagist
     */
    public function __construct(EntityManagerInterface $em, HttpClientInterface $client, ParameterBagInterface $parameter, PackagistApi $packagist)
    {
        $this->em = $em;
        $this->client = $client;
        $this->parameter = $parameter;
        $this->packagist = $packagist;
        $this->local_token = $parameter->get("ribs_admin.packages_token");
    }

    /**
     * @return array
     */
    public function getMessages(): array
    {
        return $this->messages;
    }

    /**
     * @param Package $package
     */
    public function setPackageEntity(Package $package)
    {
        $this->package = $package;
    }

    /**
     * @return mixed|null
     * @throws ClientExceptionInterface
     * @throws RedirectionExceptionInterface
     * @throws ServerExceptionInterface
     * @throws TransportExceptionInterface
     */
    private function getToken()
    {
        $token = null;
        $response = $this->client->request("GET", $this->package->getProjectUrl()."ribs-admin/packages/dist/send-token/");
        $datas = $response->getStatusCode() == 200 ? $response->getContent() : null;

        if ($datas) {
            $token = json_decode($datas, true)["token"];
        }

        return $token;
    }

    /**
     * @return mixed|null
     * @throws ClientExceptionInterface
     * @throws RedirectionExceptionInterface
     * @throws ServerExceptionInterface
     * @throws TransportExceptionInterface
     */
    private function getComposerLockJson()
    {
        if ($this->package && !$this->package->isIsLocal()) {
            $response = $this->client->request("GET", $this->package->getProjectUrl().$this->package->getComposerLockUrl());
            $composer_lock = $response->getStatusCode() == 200 ? $response->getContent() : null;
        } else {
            $composer_lock = file_get_contents('../composer.lock');
        }

        if ($composer_lock) {
            return json_decode($composer_lock, true);
        }

        return null;
    }

    /**
     * @return mixed|null
     * @throws ClientExceptionInterface
     * @throws RedirectionExceptionInterface
     * @throws ServerExceptionInterface
     * @throws TransportExceptionInterface
     */
    public function getPackage()
    {
        $composer_lock = $this->getComposerLockJson();
        if ($composer_lock) {
            $packages = $composer_lock["packages"];
            $key = array_search($this->package->getPackageName(), array_column($packages, 'name'));

            if ($key) {
                return $packages[$key];
            }
        }

        $this->messages["composer_lock"] = "Composer lock not found at " . $this->package->getProjectUrl();

        return null;
    }

    /**
     * @return mixed|null
     * @throws ClientExceptionInterface
     * @throws RedirectionExceptionInterface
     * @throws ServerExceptionInterface
     * @throws TransportExceptionInterface
     */
    public function getVersion()
    {
        return $this->getPackage($this->package->getPackageName()) ? $this->getPackage($this->package->getPackageName())["version"] : null;

The call to PiouPiou\RibsAdminBundle\Service\Version::getPackage() has too many arguments starting with $this->package->getPackageName().

    }

    /**
     * @return DateTime|null
     * @throws Exception
     */
    public function getVersionDate(): ?DateTime
    {
        $string_date = $this->getPackage($this->package->getPackageName()) ? explode("T", $this->getPackage($this->package->getPackageName())["time"])[0] : null;

The call to PiouPiou\RibsAdminBundle\Service\Version::getPackage() has too many arguments starting with $this->package->getPackageName().

        $version_date = null;

        if ($string_date) {
            $version_date = new DateTime($string_date);
        }

        return $version_date;
    }

    /**
     * @param string $guid
     * @param string $version
     * @return string|void|null
     * @throws ClientExceptionInterface
     * @throws RedirectionExceptionInterface
     * @throws ServerExceptionInterface
     * @throws TransportExceptionInterface
     */
    public function updatePackage(string $guid, string $version)
    {
        $package = $this->em->getRepository(Package::class)->findOneBy(["guid" => $guid]);

        if ($package) {
            $this->setPackageEntity($package);

            if (!$this->getToken() || $this->getToken() !== $this->local_token) {
                $this->messages["token_error"] = "Token not matching on : " . $this->package->getProjectUrl();
                return;
            }

            $form_data = new FormDataPart([
                "package_name" => $package->getPackageName(),
                "version" => $version,
            ]);

            $response = $this->client->request("POST", $this->package->getProjectUrl().'ribs-admin/packages/dist/change-version/', [
                "headers" => $form_data->getPreparedHeaders()->toArray(),
                "body" => $form_data->bodyToIterable()
            ]);

            $this->save($guid);

            return $response->getStatusCode() == 200 ? $response->getContent() : null;
        }
    }

    /**
     * @param string $package_guid
     * @throws ClientExceptionInterface
     * @throws RedirectionExceptionInterface
     * @throws ServerExceptionInterface
     * @throws TransportExceptionInterface
     */
    public function save(string $package_guid)
    {
        $package = $this->em->getRepository(Package::class)->findOneBy(["guid" => $package_guid]);

        if ($package) {
            $this->setPackageEntity($package);

            if (!$this->getToken() || $this->getToken() !== $this->local_token) {
                $this->messages["token_error"] = "Token not matching on : " . $this->package->getProjectUrl();
                return;
            }

            $package->setVersion($this->getVersion());
            $package->setVersionDate($this->getVersionDate());
            $package->setLastPackagistVersion($this->packagist->getLastPackagistVersion($package->getPackageName()));
            $package->setLastCheck(new DateTime());

            $this->em->persist($package);
            $this->em->flush();
        }
    }
}