Acme\App\Infrastructure\Auth\Authentication\Oauth\OauthProtectedControllerSubscriber

Complexity

Total Complexity

10

Size/Duplication

Total Lines	81
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getSubscribedEvents()	0	7	1
A	onKernelController()	0	29	5
A	enrichSymfonyRequestWithAuthData()	0	9	1
A	onKernelException()	0	9	2

<?php

declare(strict_types=1);

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

use Acme\App\Core\Port\Auth\Authentication\Oauth\OauthProtectedControllerInterface;
use Exception;
use League\OAuth2\Server\Exception\OAuthServerException;
use League\OAuth2\Server\ResourceServer;
use Psr\Http\Message\ServerRequestInterface;
use Symfony\Bridge\PsrHttpMessage\Factory\DiactorosFactory;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\HttpFoundation\JsonResponse;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\HttpKernel\Event\FilterControllerEvent;
use Symfony\Component\HttpKernel\Event\GetResponseForExceptionEvent;
use Symfony\Component\HttpKernel\KernelEvents;
use function is_array;

final class OauthProtectedControllerSubscriber implements EventSubscriberInterface
{
    private const DEFAULT_PRIORITY = 20;

    /**
     * @var ResourceServer
     */
    private $resourceServer;

    public function __construct(ResourceServer $resourceServer)
    {
        $this->resourceServer = $resourceServer;
    }

    /**
     * Return the subscribed events, their methods and possibly their priorities
     * (the higher the priority the earlier the method is called).
     *
     * @see http://symfony.com/doc/current/event_dispatcher.html#creating-an-event-subscriber
     */
    public static function getSubscribedEvents(): array
    {
        return [
            KernelEvents::CONTROLLER => ['onKernelController', self::DEFAULT_PRIORITY],
            KernelEvents::EXCEPTION => ['onKernelException', self::DEFAULT_PRIORITY],
        ];
    }

    /**
     * @throws OAuthServerException
     */
    public function onKernelController(FilterControllerEvent $event): void
    {
        $controller = $event->getController();
        /*
         * $controller passed can be either a class or a Closure.
         * This is not usual in Symfony but it may happen.
         * If it is a class, it comes in array format
         */
        if (!is_array($controller)) {
            return;
        }
        if ($controller[0] instanceof OauthProtectedControllerInterface) {
            $request = $event->getRequest();
            $psrRequest = (new DiactorosFactory)->createRequest($request);
            try {
                $psrRequest = $this->resourceServer->validateAuthenticatedRequest($psrRequest);
            } catch (OAuthServerException $exception) {

The class League\OAuth2\Server\Exception\OAuthServerException does not exist. Did you forget a USE statement, or did you not list all dependencies?

                throw $exception;
            } catch (Exception $exception) {
                throw new OAuthServerException(
                    $exception->getMessage(),
                    0,
                    'unknown_error',
                    Response::HTTP_INTERNAL_SERVER_ERROR
                );
            }
            $this->enrichSymfonyRequestWithAuthData($request, $psrRequest);
        }
    }

    private function enrichSymfonyRequestWithAuthData(Request $request, ServerRequestInterface $psrRequest): void
    {
        $request = $request->request;
        $requestArray = $request->all();
        $requestArray['oauth_user_id'] = $psrRequest->getAttribute('oauth_user_id');
        $requestArray['oauth_access_token_id'] = $psrRequest->getAttribute('oauth_access_token_id');
        $requestArray['oauth_client_id'] = $psrRequest->getAttribute('oauth_client_id');
        $request->replace($requestArray);
    }

    public function onKernelException(GetResponseForExceptionEvent $event): void
    {
        $exception = $event->getException();
        if (!$exception instanceof OAuthServerException) {

The class League\OAuth2\Server\Exception\OAuthServerException does not exist. Did you forget a USE statement, or did you not list all dependencies?

            return;
        }
        $response = new JsonResponse(['error' => $exception->getMessage()], $exception->getHttpStatusCode());
        $event->setResponse($response);
    }
}