Fluxter\SaasProviderBundle\Service\SaasClientService

Complexity

Total Complexity

18

Size/Duplication

Total Lines	129
Duplicated Lines	0 %

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	saveSaasClientSession()	0	3	1
A	resetSaasClientSession()	0	3	1
A	createClient()	0	14	2
B	tryGetCurrentClient()	0	36	8
A	getCurrentClient()	0	5	1
A	getCurrentHttpHost()	0	9	2
A	__construct()	0	6	1
A	discoverClient()	0	12	2

<?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 Exception;
use Fluxter\SaasProviderBundle\Model\Exception\ClientCouldNotBeDiscoveredException;
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 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;
    }

    public function tryGetCurrentClient(bool $autodiscover = true): ?SaasClientInterface
    {
        try {
            if (!$this->session->has(self::SaasClientSessionIndex) || null == $this->session->get(self::SaasClientSessionIndex)) {
                if ($autodiscover) {
                    $this->discoverClient();

                    return $this->tryGetCurrentClient(false);
                }

                return null;
            }

            $repo = $this->em->getRepository($this->saasClientEntity);
            /** @var SaasClientInterface $client */
            $client = $repo->findOneById($this->session->get(self::SaasClientSessionIndex));

The method findOneById() does not exist on Doctrine\Persistence\ObjectRepository. Did you maybe mean findOneBy()?

            if (null == $client) {
                throw new ClientCouldNotBeDiscoveredException();
            }

            // Validate
            $url = $this->getCurrentHttpHost();
            if (strtolower($client->getUrl()) != strtolower($url)) {
                $this->resetSaasClientSession();
                $this->discoverClient();

                return $this->tryGetCurrentClient(false);
            }

            if (null == $client) {
                throw new ClientCouldNotBeDiscoveredException();
            }

            return $client;
        } catch (Exception $ex) {
            return null;
        }
    }

    /**
     * Returns the current client, recognized by the url and the client entity.
     *
     * @return SaasClientInterface|null
     */
    public function getCurrentClient(bool $autodiscover = true): ?SaasClientInterface
    {
        $client = $this->tryGetCurrentClient($autodiscover);

        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".
     */
    public function getCurrentHttpHost(): string
    {
        $url = $this->requestStack->getCurrentRequest()->getHttpHost();
        $url = strtolower($url);
        if (false !== strpos($url, ':')) {
            $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 (null == $client) {
            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());
    }
}