PiouPiou\RibsAdminBundle\Service\Version

Complexity

Total Complexity

23

Size/Duplication

Total Lines	156
Duplicated Lines	0 %

Importance

Changes	3
Bugs	0	Features	2

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getVersionDate()	0	10	3
A	getComposerLockJson()	0	14	5
A	save()	0	19	2
A	getVersion()	0	3	2
A	setVersionEntity()	0	2	1
A	getPackage()	0	13	3
A	getLastPackagistVersion()	0	14	6

<?php

namespace PiouPiou\RibsAdminBundle\Service;

use Doctrine\ORM\EntityManagerInterface;
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 \PiouPiou\RibsAdminBundle\Entity\Version
     */
    private $version_entity;

    /**
     * Version constructor.
     * @param EntityManagerInterface $em
     * @param HttpClientInterface $client
     */
    public function __construct(EntityManagerInterface $em, HttpClientInterface $client)
    {
        $this->em = $em;
        $this->client = $client;
    }

    /**
     * @param \PiouPiou\RibsAdminBundle\Entity\Version $version
     */
    public function setVersionEntity(\PiouPiou\RibsAdminBundle\Entity\Version $version) {
        $this->version_entity = $version;
    }

    /**
     * @return mixed|null
     * @throws ClientExceptionInterface
     * @throws RedirectionExceptionInterface
     * @throws ServerExceptionInterface
     * @throws TransportExceptionInterface
     */
    private function getComposerLockJson()
    {
        if ($this->version_entity && !$this->version_entity->isIsLocal()) {
            $response = $this->client->request("GET", $this->version_entity->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;
    }

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

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

        return null;
    }

    /**
     * @param $package_name
     * @return mixed|null
     */
    public function getVersion($package_name)
    {
        return $this->getPackage($package_name) ? $this->getPackage($package_name)["version"] : null;
    }

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

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

        return $version_date;
    }

    /**
     * @param $package_name
     * @return false|int|string|null
     * @throws ClientExceptionInterface
     * @throws RedirectionExceptionInterface
     * @throws ServerExceptionInterface
     * @throws TransportExceptionInterface
     */
    public function getLastPackagistVersion($package_name)
    {
        if (!strpos($package_name, "/")) {
            return false;
        }

        $packgist_url = "https://repo.packagist.org/p/".$package_name.".json";

        $response = $this->client->request("GET", $packgist_url);

        if ($response->getStatusCode() == 200) {
            $content = json_decode($response->getContent(), true);
            if (is_array($content) && $content["packages"] && $content["packages"][$package_name]) {
                return array_key_first($content["packages"][$package_name]);
            }
        }
    }

    /**
     * @param $package_name
     * @throws Exception
     */
    public function save($package_name)
    {
        $version = $this->em->getRepository(\PiouPiou\RibsAdminBundle\Entity\Version::class)->findOneBy(["package_name" => $package_name]);

        if (!$version) {
            $version = new \PiouPiou\RibsAdminBundle\Entity\Version();
            $version->setProjectName($package_name);
            $version->setPackageName($package_name);
            $version->setProjectUrl($package_name);
            $version->setCheckVersionUrl($package_name);
        }

        $version->setVersion($this->getVersion($package_name));

It seems like $this->getVersion($package_name) can also be of type null; however, parameter $version of PiouPiou\RibsAdminBundle\Entity\Version::setVersion() does only seem to accept string, maybe add an additional type check?

        $version->setVersionDate($this->getVersionDate($package_name));

It seems like $this->getVersionDate($package_name) can also be of type null; however, parameter $version_date of PiouPiou\RibsAdminBundle\Entity\Version::setVersionDate() does only seem to accept DateTime, maybe add an additional type check?

        $version->setLastPackagistVersion($this->getLastPackagistVersion($package_name));

It seems like $this->getLastPackagistVersion($package_name) can also be of type false and null; however, parameter $last_packagist_version of PiouPiou\RibsAdminBundle\Entity\Version::setLastPackagistVersion() does only seem to accept string, maybe add an additional type check?

        $version->setLastCheck(new \DateTime());

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