RemoteClaimManager::updateRemoteClaimUri() - Code Metrics - Inspection of "Merge pull request #280 from PROCERGS/issue#799" - redelivre/login-cidadao - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( b4ede8...73596f )

by Guilherme

created 2018-08-01 20:59 UTC

RemoteClaimManager::updateRemoteClaimUri() A

↳ Parent: RemoteClaimManager

Complexity

Conditions	2
Paths	2

Size

Total Lines	14
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	7
CRAP Score	2

Importance

Changes

Metric	Value
cc	2
eloc	6
nc	2
nop	2
dl	0
loc	14
ccs	7
cts	7
cp	1
crap	2
rs	10
c	0
b	0
f	0

<?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\RemoteClaimsBundle\Model;

use Doctrine\ORM\EntityManagerInterface;
use LoginCidadao\CoreBundle\Entity\Authorization;
use LoginCidadao\CoreBundle\Model\PersonInterface;
use LoginCidadao\CoreBundle\Service\AuthorizationManager;
use LoginCidadao\OAuthBundle\Model\ClientInterface;
use LoginCidadao\RemoteClaimsBundle\Entity\RemoteClaimAuthorization;
use LoginCidadao\RemoteClaimsBundle\Entity\RemoteClaimAuthorizationRepository;
use LoginCidadao\RemoteClaimsBundle\Entity\RemoteClaimRepository;

class RemoteClaimManager implements RemoteClaimManagerInterface
{
    /** @var EntityManagerInterface */
    private $em;

    /** @var RemoteClaimAuthorizationRepository */
    private $remoteClaimAuthorizationRepository;

    /** @var RemoteClaimRepository */
    private $remoteClaimRepository;

    /** @var AuthorizationManager */
    private $authorizationManager;

    /**
     * RemoteClaimManager constructor.
     * @param EntityManagerInterface $em
     * @param RemoteClaimAuthorizationRepository $remoteClaimAuthorizationRepository
     * @param RemoteClaimRepository $remoteClaimRepository
     * @param AuthorizationManager $authorizationManager
     */
    public function __construct(
        EntityManagerInterface $em,
        RemoteClaimAuthorizationRepository $remoteClaimAuthorizationRepository,
        RemoteClaimRepository $remoteClaimRepository,
        AuthorizationManager $authorizationManager
    ) {
        $this->em = $em;
        $this->remoteClaimAuthorizationRepository = $remoteClaimAuthorizationRepository;
        $this->remoteClaimRepository = $remoteClaimRepository;
        $this->authorizationManager = $authorizationManager;
    }

    /**
     * {@inheritdoc}
     * @throws \Doctrine\ORM\NonUniqueResultException
     */
    public function enforceAuthorization(RemoteClaimAuthorizationInterface $authorization)
    {
        $remoteClaim = $this->getExistingRemoteClaim($authorization->getClaimName());
        $this->enforceImplicitAuthorization($authorization, $remoteClaim);

        $existingAuthorization = $this->remoteClaimAuthorizationRepository->findAuthorization($authorization);
        if ($existingAuthorization instanceof RemoteClaimAuthorizationInterface) {
            return $existingAuthorization;
        }

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

        return $authorization;
    }

    /**
     * {@inheritdoc}
     * @throws \Doctrine\ORM\NonUniqueResultException
     */
    public function isAuthorized($claimName, PersonInterface $person, ClientInterface $client)
    {
        if (!$claimName instanceof TagUri) {
            $claimName = TagUri::createFromString($claimName);
        }
        $authorization = (new RemoteClaimAuthorization())
            ->setClaimName($claimName)
            ->setPerson($person)
            ->setClient($client);
        $existingAuthorization = $this->remoteClaimAuthorizationRepository->findAuthorization($authorization);

        return $existingAuthorization instanceof RemoteClaimAuthorizationInterface;
    }

    /**
     * {@inheritdoc}
     */
    public function revokeAllAuthorizations(Authorization $authorization)
    {
        $remoteClaimAuthorizations = $this->remoteClaimAuthorizationRepository
            ->findAllByClientAndPerson($authorization->getClient(), $authorization->getPerson());

        foreach ($remoteClaimAuthorizations as $remoteClaimAuthorization) {
            $this->em->remove($remoteClaimAuthorization);
        }
        $this->em->flush();

        return true;
    }

    /**
     * {@inheritdoc}
     */
    public function filterRemoteClaims($scopes)
    {
        $returnString = is_string($scopes);
        if ($returnString) {
            $scopes = explode(' ', $scopes);
        }

        $response = [];
        foreach ($scopes as $scope) {
            try {
                TagUri::createFromString($scope);
            } catch (\InvalidArgumentException $e) {
                $response[] = $scope;
            }
        }

        if ($returnString) {
            return implode(' ', $response);
        }

        return $response;
    }

    /**
     * @inheritDoc
     */
    public function getExistingRemoteClaim(TagUri $claimName)
    {
        return $this->remoteClaimRepository->findOneBy([
            'name' => $claimName,
        ]);
    }

    /**
     * @inheritDoc
     */
    public function getRemoteClaimsFromAuthorization(Authorization $authorization)
    {
        return $this->remoteClaimRepository
            ->findByClientAndPerson($authorization->getClient(), $authorization->getPerson());
    }

    /**
     * @inheritDoc
     */
    public function getRemoteClaimsAuthorizationsFromAuthorization(Authorization $authorization)
    {
        return $this->remoteClaimAuthorizationRepository->findAllByClientAndPerson(
            $authorization->getClient(), $authorization->getPerson()
        );
    }

    /**
     * @inheritDoc
     */
    public function getRemoteClaimsWithTokens(ClientInterface $client, PersonInterface $person)
    {
        /** @var RemoteClaimAuthorizationInterface[] $remoteClaimAuthorizations */
        $remoteClaimAuthorizations = $this->remoteClaimAuthorizationRepository
            ->findAllByClientAndPerson($client, $person);

        /** @var RemoteClaimInterface[] $remoteClaims */
        $remoteClaims = $this->remoteClaimRepository->findByClientAndPerson($client, $person);

        $response = [];
        foreach ($remoteClaimAuthorizations as $authorization) {
            $tag = $this->getTagString($authorization->getClaimName());
            $response[$tag]['authorization'] = $authorization;
        }
        foreach ($remoteClaims as $remoteClaim) {
            $tag = $this->getTagString($remoteClaim->getName());
            $response[$tag]['remoteClaim'] = $remoteClaim;
        }

        return $response;
    }

    /**
     * @inheritDoc
     */
    public function getRemoteClaimAuthorizationByAccessToken(ClaimProviderInterface $claimProvider, $accessToken)
    {
        return $this->remoteClaimAuthorizationRepository->findOneBy([
            'claimProvider' => $claimProvider,
            'accessToken' => $accessToken,
        ]);
    }

    /**
     * @inheritDoc
     */
    public function updateRemoteClaimUri(TagUri $claimName, $uri)
    {
        $remoteClaim = $this->getExistingRemoteClaim($claimName);

        if (!$remoteClaim instanceof RemoteClaimInterface) {
            // TODO: log
            // TODO: throw exception?
            return null;
        }

        $remoteClaim->setUri($uri);
        $this->em->flush();

        return $remoteClaim;
    }

    /**
     * @inheritDoc
     */
    public function enforceImplicitAuthorization(
        RemoteClaimAuthorizationInterface $claimAuthorization,
        RemoteClaimInterface $remoteClaim
    ): Authorization {
        /** @var ClaimProviderInterface|ClientInterface $provider */
        $provider = $claimAuthorization->getClaimProvider();

        return $this->authorizationManager->enforceAuthorization(
            $claimAuthorization->getPerson(),
            $provider,
            array_merge($remoteClaim->getEssentialScope(), $remoteClaim->getRecommendedScope()),
            AuthorizationManager::SCOPE_MERGE
        );
    }

    /**
     * @param string|TagUri $tag
     * @return string
     */
    private function getTagString($tag)
    {
        return is_string($tag) ? $tag : $tag->__toString();
    }
}


1		<?php
2		/**
3		* This file is part of the login-cidadao project or it's bundles.
4		*
5		* (c) Guilherme Donato <guilhermednt on github>
6		*
7		* For the full copyright and license information, please view the LICENSE
8		* file that was distributed with this source code.
9		*/
10
11		namespace LoginCidadao\RemoteClaimsBundle\Model;
12
13		use Doctrine\ORM\EntityManagerInterface;
14		use LoginCidadao\CoreBundle\Entity\Authorization;
15		use LoginCidadao\CoreBundle\Model\PersonInterface;
16		use LoginCidadao\CoreBundle\Service\AuthorizationManager;
17		use LoginCidadao\OAuthBundle\Model\ClientInterface;
18		use LoginCidadao\RemoteClaimsBundle\Entity\RemoteClaimAuthorization;
19		use LoginCidadao\RemoteClaimsBundle\Entity\RemoteClaimAuthorizationRepository;
20		use LoginCidadao\RemoteClaimsBundle\Entity\RemoteClaimRepository;
21
22		class RemoteClaimManager implements RemoteClaimManagerInterface
23		{
24		/** @var EntityManagerInterface */
25		private $em;
26
27		/** @var RemoteClaimAuthorizationRepository */
28		private $remoteClaimAuthorizationRepository;
29
30		/** @var RemoteClaimRepository */
31		private $remoteClaimRepository;
32
33		/** @var AuthorizationManager */
34		private $authorizationManager;
35
36		/**
37		* RemoteClaimManager constructor.
38		* @param EntityManagerInterface $em
39		* @param RemoteClaimAuthorizationRepository $remoteClaimAuthorizationRepository
40		* @param RemoteClaimRepository $remoteClaimRepository
41		* @param AuthorizationManager $authorizationManager
42		*/
43	18	public function __construct(
44		EntityManagerInterface $em,
45		RemoteClaimAuthorizationRepository $remoteClaimAuthorizationRepository,
46		RemoteClaimRepository $remoteClaimRepository,
47		AuthorizationManager $authorizationManager
48		) {
49	18	$this->em = $em;
50	18	$this->remoteClaimAuthorizationRepository = $remoteClaimAuthorizationRepository;
51	18	$this->remoteClaimRepository = $remoteClaimRepository;
52	18	$this->authorizationManager = $authorizationManager;
53	18	}
54
55		/**
56		* {@inheritdoc}
57		* @throws \Doctrine\ORM\NonUniqueResultException
58		*/
59	2	public function enforceAuthorization(RemoteClaimAuthorizationInterface $authorization)
60		{
61	2	$remoteClaim = $this->getExistingRemoteClaim($authorization->getClaimName());
62	2	$this->enforceImplicitAuthorization($authorization, $remoteClaim);
63
64	2	$existingAuthorization = $this->remoteClaimAuthorizationRepository->findAuthorization($authorization);
65	2	if ($existingAuthorization instanceof RemoteClaimAuthorizationInterface) {
66	1	return $existingAuthorization;
67		}
68
69	1	$this->em->persist($authorization);
70
71	1	return $authorization;
72		}
73
74		/**
75		* {@inheritdoc}
76		* @throws \Doctrine\ORM\NonUniqueResultException
77		*/
78	3	public function isAuthorized($claimName, PersonInterface $person, ClientInterface $client)
79		{
80	3	if (!$claimName instanceof TagUri) {
81	1	$claimName = TagUri::createFromString($claimName);
82		}
83	3	$authorization = (new RemoteClaimAuthorization())
84	3	->setClaimName($claimName)
85	3	->setPerson($person)
86	3	->setClient($client);
87	3	$existingAuthorization = $this->remoteClaimAuthorizationRepository->findAuthorization($authorization);
88
89	3	return $existingAuthorization instanceof RemoteClaimAuthorizationInterface;
90		}
91
92		/**
93		* {@inheritdoc}
94		*/
95	1	public function revokeAllAuthorizations(Authorization $authorization)
96		{
97	1	$remoteClaimAuthorizations = $this->remoteClaimAuthorizationRepository
98	1	->findAllByClientAndPerson($authorization->getClient(), $authorization->getPerson());
99
100	1	foreach ($remoteClaimAuthorizations as $remoteClaimAuthorization) {
101	1	$this->em->remove($remoteClaimAuthorization);
102		}
103	1	$this->em->flush();
104
105	1	return true;
106		}
107
108		/**
109		* {@inheritdoc}
110		*/
111	5	public function filterRemoteClaims($scopes)
112		{
113	5	$returnString = is_string($scopes);
114	5	if ($returnString) {
115	3	$scopes = explode(' ', $scopes);
116		}
117
118	5	$response = [];
119	5	foreach ($scopes as $scope) {
120		try {
121	4	TagUri::createFromString($scope);
122	4	} catch (\InvalidArgumentException $e) {
123	4	$response[] = $scope;
124		}
125		}
126
127	5	if ($returnString) {
128	3	return implode(' ', $response);
129		}
130
131	2	return $response;
132		}
133
134		/**
135		* @inheritDoc
136		*/
137	5	public function getExistingRemoteClaim(TagUri $claimName)
138		{
139	5	return $this->remoteClaimRepository->findOneBy([
140	5	'name' => $claimName,
141		]);
142		}
143
144		/**
145		* @inheritDoc
146		*/
147	1	public function getRemoteClaimsFromAuthorization(Authorization $authorization)
148		{
149	1	return $this->remoteClaimRepository
150	1	->findByClientAndPerson($authorization->getClient(), $authorization->getPerson());
151		}
152
153		/**
154		* @inheritDoc
155		*/
156	1	public function getRemoteClaimsAuthorizationsFromAuthorization(Authorization $authorization)
157		{
158	1	return $this->remoteClaimAuthorizationRepository->findAllByClientAndPerson(
159	1	$authorization->getClient(), $authorization->getPerson()
160		);
161		}
162
163		/**
164		* @inheritDoc
165		*/
166	1	public function getRemoteClaimsWithTokens(ClientInterface $client, PersonInterface $person)
167		{
168		/** @var RemoteClaimAuthorizationInterface[] $remoteClaimAuthorizations */
169	1	$remoteClaimAuthorizations = $this->remoteClaimAuthorizationRepository
170	1	->findAllByClientAndPerson($client, $person);
171
172		/** @var RemoteClaimInterface[] $remoteClaims */
173	1	$remoteClaims = $this->remoteClaimRepository->findByClientAndPerson($client, $person);
174
175	1	$response = [];
176	1	foreach ($remoteClaimAuthorizations as $authorization) {
177	1	$tag = $this->getTagString($authorization->getClaimName());
178	1	$response[$tag]['authorization'] = $authorization;
179		}
180	1	foreach ($remoteClaims as $remoteClaim) {
181	1	$tag = $this->getTagString($remoteClaim->getName());
182	1	$response[$tag]['remoteClaim'] = $remoteClaim;
183		}
184
185	1	return $response;
186		}
187
188		/**
189		* @inheritDoc
190		*/
191	1	public function getRemoteClaimAuthorizationByAccessToken(ClaimProviderInterface $claimProvider, $accessToken)
192		{
193	1	return $this->remoteClaimAuthorizationRepository->findOneBy([
194	1	'claimProvider' => $claimProvider,
195	1	'accessToken' => $accessToken,
196		]);
197		}
198
199		/**
200		* @inheritDoc
201		*/
202	2	public function updateRemoteClaimUri(TagUri $claimName, $uri)
203		{
204	2	$remoteClaim = $this->getExistingRemoteClaim($claimName);
205
206	2	if (!$remoteClaim instanceof RemoteClaimInterface) {
207		// TODO: log
208		// TODO: throw exception?
209	1	return null;
210		}
211
212	1	$remoteClaim->setUri($uri);
213	1	$this->em->flush();
214
215	1	return $remoteClaim;
216		}
217
218		/**
219		* @inheritDoc
220		*/
221	2	public function enforceImplicitAuthorization(
222		RemoteClaimAuthorizationInterface $claimAuthorization,
223		RemoteClaimInterface $remoteClaim
224		): Authorization {
225		/** @var ClaimProviderInterface\|ClientInterface $provider */
226	2	$provider = $claimAuthorization->getClaimProvider();
227
228	2	return $this->authorizationManager->enforceAuthorization(
229	2	$claimAuthorization->getPerson(),
230	2	$provider,
231	2	array_merge($remoteClaim->getEssentialScope(), $remoteClaim->getRecommendedScope()),
232	2	AuthorizationManager::SCOPE_MERGE
233		);
234		}
235
236		/**
237		* @param string\|TagUri $tag
238		* @return string
239		*/
240	1	private function getTagString($tag)
241		{
242	1	return is_string($tag) ? $tag : $tag->__toString();
243		}
244		}
245

redelivre / login-cidadao

Push — master ( b4ede8...73596f )

RemoteClaimManager::updateRemoteClaimUri() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like