Fluxter\SaasProviderBundle\Service\SaasClientService

Complexity

Total Complexity

18

Size/Duplication

Total Lines	128
Duplicated Lines	0 %

Importance

Changes	4
Bugs	2	Features	1

8 Methods

Rating	Name	Duplication	Size	Complexity
A	createClient()	0	14	2
A	getCurrentClient()	0	27	6
A	saveSaasClientSession()	0	2	1
A	getCurrentHttpHost()	0	9	2
A	__construct()	0	6	1
A	__call()	0	14	3
A	discoverClient()	0	11	2
A	resetSaasClientSession()	0	2	1

<?php

/*
 * This file is part of the SaasProviderBundle package.
 * (c) Fluxter <http://fluxter.net/>
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Fluxter\SaasProviderBundle\Service;

use Doctrine\ORM\EntityManagerInterface;
use Fluxter\SaasProviderBundle\Model\SaasClientInterface;
use Fluxter\SaasProviderBundle\Model\SaasParameterInterface;
use Symfony\Component\DependencyInjection\ContainerInterface;
use Symfony\Component\HttpFoundation\RequestStack;
use Symfony\Component\HttpFoundation\Session\SessionInterface;

class SaasClientService
{
    private const SaasClientSessionIndex = 'SAASCLIENT';

    /** @var EntityManagerInterface */
    private $em;

    /** @var SessionInterface */
    private $session;

    /** @var string */
    private $saasClientEntity;

    /** @var RequestStack */
    private $requestStack;

    public function __construct(ContainerInterface $container, EntityManagerInterface $em, SessionInterface $session, RequestStack $requestStack)
    {
        $this->em = $em;
        $this->session = $session;
        $this->saasClientEntity = $container->getParameter('saas_provider.client_entity');
        $this->requestStack = $requestStack;
    }

    public function __call($name, $arguments)
    {
        $client = $this->getCurrentClient();

        $method = "get$name";
        if (method_exists($client, $method)) {
            return $client->$method();
        }
        $method = "is$name";
        if (method_exists($client, $method)) {
            return $client->$method();
        }

        throw new \Exception("Unknown SaaS-Client function / variable: {$name}!");
    }

    public function createClient(array $parameters)
    {
        /** @var SaasClientInterface $client */
        $client = new $this->saasClientEntity();

        /** @var SaasParameterInterface $parameter */
        foreach ($parameters as $parameter) {
            $client->addParameter($parameter);
        }

        $this->em->persist($client);
        $this->em->flush($client);

The call to Doctrine\Persistence\ObjectManager::flush() has too many arguments starting with $client.

        return $client;
    }

    /**
     * Returns the current http host in lower case.
     * For example: "http://localhost:8000" returns "localhost"
     * https://test.test.de would return "test.test.de"
     *
     * @return string
     */
    private function getCurrentHttpHost() : string
    {
        $url = $this->requestStack->getCurrentRequest()->getHttpHost();
        $url = strtolower($url);
        if (strpos($url, ':') !== false) {
            $url = preg_replace('/:(.*)/', '', $url);
        }

        return strtolower($url);
    }

    private function discoverClient() : ?SaasClientInterface
    {
        $url = $this->getCurrentHttpHost();
        $repo = $this->em->getRepository($this->saasClientEntity);
        $client = $repo->findOneBy(['url' => $url]);
        if ($client == null) {
            return null;
        }
        
        $this->saveSaasClientSession($client);
        return $client;
    }

    private function resetSaasClientSession() {
        $this->session->set(self::SaasClientSessionIndex, null);
    }

    private function saveSaasClientSession(SaasClientInterface $client) {
        $this->session->set(self::SaasClientSessionIndex, $client->getId());
    }

    /**
     * Returns the current client, recognized by the url and the client entity
     *
     * @param boolean $autodiscover
     * @return SaasClientInterface|null
     */
    public function getCurrentClient(bool $autodiscover = true) : ?SaasClientInterface
    {
        if (!$this->session->has(self::SaasClientSessionIndex) || $this->session->get(self::SaasClientSessionIndex) == null) {
            if ($autodiscover) {
                $this->discoverClient();
                return $this->getCurrentClient(false);
            }

            return null;
        }

        $repo = $this->em->getRepository($this->saasClientEntity);
        /** @var SaasClientInterface $client */
        $client = $repo->find($this->session->get(self::SaasClientSessionIndex));
        if (null == $client) {
            return null;
        }
        
        // Validate
        $url = $this->getCurrentHttpHost();
        if (strtolower($client->getUrl()) != strtolower($url)) {
            $this->resetSaasClientSession();
            $this->discoverClient();
            return $this->getCurrentClient(false);
        }

        return $client;
    }
}