Acme\App\Infrastructure\Auth\Authentication\Oauth\OauthScopeRepository

Complexity

Total Complexity

7

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	getScopeEntityByIdentifier()	0	4	1
A	finalizeScopes()	0	16	3
A	find()	0	13	2

<?php

declare(strict_types=1);

namespace Acme\App\Infrastructure\Auth\Authentication\Oauth;

use Acme\App\Core\Port\Persistence\DQL\DqlQueryBuilderInterface;
use Acme\App\Core\Port\Persistence\Exception\EmptyQueryResultException;
use Acme\App\Core\Port\Persistence\QueryServiceRouterInterface;
use League\OAuth2\Server\Entities\ClientEntityInterface;
use League\OAuth2\Server\Entities\ScopeEntityInterface;
use League\OAuth2\Server\Repositories\ScopeRepositoryInterface;

final class OauthScopeRepository implements ScopeRepositoryInterface
{
    /**
     * @var DqlQueryBuilderInterface
     */
    private $dqlQueryBuilder;

    /**
     * @var QueryServiceRouterInterface
     */
    private $queryService;

    public function __construct(
        DqlQueryBuilderInterface $dqlQueryBuilder,
        QueryServiceRouterInterface $queryService
    ) {
        $this->dqlQueryBuilder = $dqlQueryBuilder;
        $this->queryService = $queryService;
    }

    /**
     * {@inheritdoc}
     */
    public function getScopeEntityByIdentifier($identifier): ?ScopeEntityInterface
    {
        return $this->find($identifier);
    }

    /**
     * Given a client, grant type and optional user identifier validate the set of scopes requested are valid and
     * optionally append additional scopes or remove requested scopes.
     *
     * @param ScopeEntityInterface[] $scopes
     * @param string $grantType
     * @param ClientEntityInterface $clientEntity
     * @param null|string $userIdentifier
     *
     * @return ScopeEntityInterface[]
     */
    public function finalizeScopes(
        array $scopes,
        $grantType,
        ClientEntityInterface $clientEntity,
        $userIdentifier = null
    ): array {
        $filteredScopes = [];

        foreach ($scopes as $scope) {
            if (OauthScope::hasScope($scope->getIdentifier())) {
                $filteredScopes[] = $scope;
            }
        }

        return $filteredScopes;
    }

    private function find(string $oauthScopeId): ?OauthScope
    {
        $dqlQuery = $this->dqlQueryBuilder->create(OauthScope::class)
            ->where('OauthScope.identifier = :identifier')
            ->setParameter('identifier', $oauthScopeId)
            ->build();

        try {
            return $this->queryService->query($dqlQuery)->getSingleResult();
        } catch (EmptyQueryResultException $e) {
            return null;
        }
    }
}