AbterPhp\Admin\Oauth2\Repository\Scope

Complexity

Total Complexity

10

Size/Duplication

Total Lines	116
Duplicated Lines	0 %

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	queryWithoutUser()	0	19	2
A	finalizeScopes()	0	18	3
A	checkScopes()	0	25	3
A	getScopeEntityByIdentifier()	0	7	1
A	__construct()	0	3	1

<?php

declare(strict_types=1);

namespace AbterPhp\Admin\Oauth2\Repository;

use AbterPhp\Admin\Oauth2\Entity\Scope as Entity;
use League\OAuth2\Server\Entities\ClientEntityInterface;

The type League\OAuth2\Server\Entities\ClientEntityInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use League\OAuth2\Server\Entities\ScopeEntityInterface;

The type League\OAuth2\Server\Entities\ScopeEntityInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use League\OAuth2\Server\Repositories\ScopeRepositoryInterface;

The type League\OAuth2\Server\Repositories\ScopeRepositoryInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Opulence\Databases\ConnectionPools\ConnectionPool;
use Opulence\QueryBuilders\Conditions\ConditionFactory;
use Opulence\QueryBuilders\MySql\QueryBuilder;

class Scope implements ScopeRepositoryInterface
{
    /** @var ConnectionPool */
    protected $connectionPool;

    /**
     * Scope constructor.
     *
     * @param ConnectionPool $connectionPool
     */
    public function __construct(ConnectionPool $connectionPool)
    {
        $this->connectionPool = $connectionPool;
    }

    /**
     * @param string $identifier
     *
     * @return ScopeEntityInterface
     */
    public function getScopeEntityByIdentifier($identifier)
    {
        $scopeData = $this->queryWithoutUser($identifier);

        $scope = new Entity($scopeData['id']);

        return $scope;
    }

    /**
     * @param string $clientId
     *
     * @return array|bool
     */
    protected function queryWithoutUser(string $clientId)
    {
        $query = (new QueryBuilder())
            ->select('ar.id')
            ->from('admin_resources', 'ar')
            ->where('ar.deleted = 0')
            ->andWhere('ar.identifier = :id');

        $sql    = $query->getSql();
        $params = ['id' => $clientId];

        $connection = $this->connectionPool->getReadConnection();
        $statement  = $connection->prepare($sql);
        $statement->bindValues($params);
        if (!$statement->execute()) {
            return false;
        }

        return $statement->fetch(\PDO::FETCH_ASSOC);
    }

    /**
     * @SuppressWarnings(PHPMD.UnusedFormalParameter)
     *
     * @param array                 $scopes
     * @param string                $grantType
     * @param ClientEntityInterface $clientEntity
     * @param null                  $userIdentifier

Are you sure the doc-type for parameter $userIdentifier is correct as it would always require null to be passed?

     *
     * @return ScopeEntityInterface[]
     */
    public function finalizeScopes(
        array $scopes,
        $grantType,
        ClientEntityInterface $clientEntity,
        $userIdentifier = null
    ) {
        $scopeIds = [];
        /** @var Entity $scope */
        foreach ($scopes as $scope) {
            $scopeIds[] = $scope->getIdentifier();
        }

        $finalScopes = [];
        foreach ($this->checkScopes($clientEntity->getIdentifier(), ...$scopeIds) as $scopeData) {
            $finalScopes[] = new Entity($scopeData['admin_resource_id']);
        }

        return $finalScopes;
    }

    /**
     * @param string $clientId
     * @param string ...$scopeIds
     *
     * @return array|bool
     */
    protected function checkScopes(string $clientId, string ...$scopeIds)
    {
        $scopeIdIn = [];
        foreach ($scopeIds as $scopeId) {
            $scopeIdIn[] = [$scopeId, \PDO::PARAM_STR];
        }

        $conditions = new ConditionFactory();
        $query      = (new QueryBuilder())
            ->select('acar.admin_resource_id')
            ->from('api_clients_admin_resources', 'acar')
            ->andWhere('acar.api_client_id = ?')
            ->andWhere($conditions->in('acar.admin_resource_id', $scopeIdIn));

        $sql    = $query->getSql();
        $params = array_merge([[$clientId, \PDO::PARAM_STR]], $scopeIdIn);

        $connection = $this->connectionPool->getReadConnection();
        $statement  = $connection->prepare($sql);
        $statement->bindValues($params);
        if (!$statement->execute()) {
            return false;
        }

        return $statement->fetchAll(\PDO::FETCH_ASSOC);
    }
}