LoginCidadao\OpenIDBundle\Manager\ClientManager

Complexity

Total Complexity

14

Size/Duplication

Total Lines	113
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getClientById()	0	23	3
B	sanitizeClient()	0	17	5
B	register()	0	36	5
A	__construct()	0	10	1

<?php
/**
 * This file is part of the login-cidadao project or it's bundles.
 *
 * (c) Guilherme Donato <guilhermednt on github>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace LoginCidadao\OpenIDBundle\Manager;

use Doctrine\ORM\EntityManagerInterface;
use LoginCidadao\CoreBundle\Entity\PersonRepository;
use LoginCidadao\CoreBundle\Event\GetClientEvent;
use LoginCidadao\CoreBundle\Event\LoginCidadaoCoreEvents;
use LoginCidadao\CoreBundle\Model\PersonInterface;
use LoginCidadao\OAuthBundle\Model\ClientInterface;
use LoginCidadao\OpenIDBundle\Entity\ClientMetadata;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;

class ClientManager
{
    /** @var EventDispatcherInterface */
    private $dispatcher;

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

    /** @var PersonRepository */
    private $personRepository;

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

    /**
     * ClientManager constructor.
     * @param EntityManagerInterface $em
     * @param EventDispatcherInterface $dispatcher
     * @param PersonRepository $personRepository
     * @param $publicScopes
     */
    public function __construct(
        EntityManagerInterface $em,
        EventDispatcherInterface $dispatcher,
        PersonRepository $personRepository,
        $publicScopes
    ) {
        $this->em = $em;
        $this->dispatcher = $dispatcher;
        $this->personRepository = $personRepository;
        $this->publicScopes = $publicScopes;
    }

    public function getClientById($id)
    {
        $randomId = null;
        if (strstr($id, '_') !== false) {
            $parts = explode('_', $id);
            $id = $parts[0];
            $randomId = $parts[1];
        }

        $repo = $this->em->getRepository('LoginCidadaoOAuthBundle:Client');

        if ($randomId) {
            $client = $repo->findOneBy([
                'id' => $id,
                'randomId' => $randomId,
            ]);
        } else {
            $client = $repo->find($id);
        }
        $event = new GetClientEvent($client);
        $this->dispatcher->dispatch(LoginCidadaoCoreEvents::GET_CLIENT, $event);

        return $event->getClient();
    }

    public function register(ClientMetadata $data)
    {
        if ($data->getClient() === null) {
            $client = $data->toClient();
        } else {
            $client = $data->getClient();
        }

        $client = $this->sanitizeClient($client);

        if (count($data->getContacts()) > 0) {
            /** @var PersonInterface[] $owners */
            $owners = $this->personRepository->findBy([
                'email' => $data->getContacts(),
            ]);

            foreach ($owners as $person) {
                if (!$person->getEmailConfirmedAt() instanceof \DateTime) {
                    // Email is not verified. Skipping...
                    continue;
                }
                $client->getOwners()->add($person);
            }
        }

        $publicScopes = explode(' ', $this->publicScopes);
        $client->setAllowedScopes($publicScopes);

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

        $data->setClient($client);
        $this->em->persist($data);

        $this->em->flush();

        return $client;
    }

    private function sanitizeClient(ClientInterface $client)
    {
        if ($client->getName() === null) {
            $firstUrl = parse_url($client->getRedirectUris()[0], PHP_URL_HOST);
            $client->setName($firstUrl);
        }
        if ($client->getDescription() === null) {
            $client->setDescription('');
        }
        if ($client->getTermsOfUseUrl() === null) {
            $client->setTermsOfUseUrl('');
        }
        if ($client->getSiteUrl() === null) {
            $client->setSiteUrl('');
        }

        return $client;
    }
}