RouteLoader::parseOpenapiBundleSpecificationExtension() - Code Metrics - Inspection of "Add support for request body deserialization and a..." - nijens/openapi-bundle - Measure and Improve Code Quality continuously with Scrutinizer

Passed
Pull Request — main (#65)

by Niels
created 2022-07-09 20:41 UTC
parseOpenapiBundleSpecificationExtension() B

↳ Parent: RouteLoader
Complexity

Conditions	8
Paths	48
Size

Total Lines	22
Code Lines	12
Duplication

Lines	0
Ratio	0 %
Importance

Changes
Metric	Value
cc	8
eloc	12
nc	48
nop	3
dl	0
loc	22
rs	8.4444
c	0
b	0
f	0
<?php

declare(strict_types=1);

/*
 * This file is part of the OpenapiBundle package.
 *
 * (c) Niels Nijens <[email protected]>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Nijens\OpenapiBundle\Routing;

use Nijens\OpenapiBundle\Controller\CatchAllController;
use Nijens\OpenapiBundle\Json\JsonPointer;
use Nijens\OpenapiBundle\Json\SchemaLoaderInterface;
use stdClass;
use Symfony\Component\Config\FileLocatorInterface;
use Symfony\Component\Config\Loader\FileLoader;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\Routing\Route;
use Symfony\Component\Routing\RouteCollection;

/**
 * Loads the paths from an OpenAPI specification as routes.
 *
 * @author Niels Nijens <[email protected]>
 */
class RouteLoader extends FileLoader
{
    /**
     * @var string
     */
    public const TYPE = 'openapi';

    /**
     * @var SchemaLoaderInterface
     */
    private $schemaLoader;

    /**
     * @var bool
     */
    private $useOperationIdAsRouteName;

    /**
     * Constructs a new RouteLoader instance.
     */
    public function __construct(
        FileLocatorInterface $locator,
        SchemaLoaderInterface $schemaLoader,
        bool $useOperationIdAsRouteName = false
    ) {
        parent::__construct($locator);

        $this->schemaLoader = $schemaLoader;
        $this->useOperationIdAsRouteName = $useOperationIdAsRouteName;
    }

    /**
     * {@inheritdoc}
     */
    public function supports($resource, $type = null): bool
    {
        return self::TYPE === $type;
    }

    /**
     * {@inheritdoc}
     */
    public function load($resource, $type = null): RouteCollection
    {
        $file = $this->getLocator()->locate($resource, null, true);

        $schema = $this->schemaLoader->load($file);
        $schema = $this->schemaLoader->load(/** @scrutinizer ignore-type */ $file);

        $jsonPointer = new JsonPointer($schema);

        $routeCollection = new RouteCollection();
        $routeCollection->addResource($this->schemaLoader->getFileResource($file));
        $routeCollection->addResource(/** @scrutinizer ignore-type */ $this->schemaLoader->getFileResource($file));

        $paths = get_object_vars($jsonPointer->get('/paths'));
        foreach ($paths as $path => $pathItem) {
            $this->parsePathItem($jsonPointer, $file, $routeCollection, $path, $pathItem);
            $this->parsePathItem($jsonPointer, /** @scrutinizer ignore-type */ $file, $routeCollection, $path, $pathItem);
        }

        $this->addDefaultRoutes($routeCollection, $file);
        $this->addDefaultRoutes($routeCollection, /** @scrutinizer ignore-type */ $file);

        return $routeCollection;
    }

    /**
     * Parses a path item of the OpenAPI specification for a route.
     */
    private function parsePathItem(
        JsonPointer $jsonPointer,
        string $resource,
        RouteCollection $collection,
        string $path,
        stdClass $pathItem
    ): void {
        $operations = get_object_vars($pathItem);
        foreach ($operations as $requestMethod => $operation) {
            if ($this->isValidRequestMethod($requestMethod) === false) {
                return;
            }

            $this->parseOperation($jsonPointer, $resource, $collection, $path, $requestMethod, $operation);
        }
    }

    /**
     * Parses an operation of the OpenAPI specification for a route.
     */
    private function parseOperation(
        JsonPointer $jsonPointer,
        string $resource,
        RouteCollection $collection,
        string $path,
        string $requestMethod,
        stdClass $operation
    ): void {
        $defaults = [];
        $openapiRouteContext = [
            RouteContext::RESOURCE => $resource,
        ];

        $this->parseOpenapiBundleSpecificationExtension($operation, $defaults, $openapiRouteContext);

        if (isset($operation->requestBody->content->{'application/json'})) {
            $openapiRouteContext[RouteContext::JSON_REQUEST_VALIDATION_POINTER] = sprintf(
                '/paths/%s/%s/requestBody/content/%s/schema',
                $jsonPointer->escape($path),
                $requestMethod,
                $jsonPointer->escape('application/json')
            );
        }

        $defaults[RouteContext::REQUEST_ATTRIBUTE] = $openapiRouteContext;

        $route = new Route($path, $defaults, []);
        $route->setMethods($requestMethod);

        $routeName = null;
        if ($this->useOperationIdAsRouteName && isset($operation->operationId)) {
            $routeName = $operation->operationId;
        }

        $collection->add(
            $routeName ?? $this->createRouteName($path, $requestMethod),
            $route
        );
    }

    private function parseOpenapiBundleSpecificationExtension(stdClass $operation, array &$defaults, array &$openapiRouteContext): void
    {
        if (isset($operation->{'x-openapi-bundle'}->controller)) {
            $defaults['_controller'] = $operation->{'x-openapi-bundle'}->controller;
        }

        if (isset($defaults['_controller']) === false && isset($operation->{'x-symfony-controller'})) {
            $defaults['_controller'] = $operation->{'x-symfony-controller'};
        }

        if (isset($operation->{'x-openapi-bundle'}->deserializationObject)) {
            $openapiRouteContext[RouteContext::DESERIALIZATION_OBJECT] = $operation->{'x-openapi-bundle'}->deserializationObject;
        }

        if (isset($operation->{'x-openapi-bundle'}->deserializationObjectArgumentName)) {
            $openapiRouteContext[RouteContext::DESERIALIZATION_OBJECT_ARGUMENT_NAME] = $operation->{'x-openapi-bundle'}->deserializationObjectArgumentName;
        }

        if (isset($operation->{'x-openapi-bundle'}->additionalRouteAttributes)) {
            $additionalRouteAttributes = get_object_vars($operation->{'x-openapi-bundle'}->additionalRouteAttributes);
            foreach ($additionalRouteAttributes as $key => $value) {
                $defaults[$key] = $value;
            }
        }
    }

    /**
     * Returns true when the provided request method is a valid request method in the OpenAPI specification.
     */
    private function isValidRequestMethod(string $requestMethod): bool
    {
        return in_array(
            strtoupper($requestMethod),
            [
                Request::METHOD_GET,
                Request::METHOD_PUT,
                Request::METHOD_POST,
                Request::METHOD_DELETE,
                Request::METHOD_OPTIONS,
                Request::METHOD_HEAD,
                Request::METHOD_PATCH,
                Request::METHOD_TRACE,
            ]
        );
    }

    /**
     * Creates a route name based on the path and request method.
     */
    private function createRouteName(string $path, string $requestMethod): string
    {
        return sprintf('%s_%s',
            trim(preg_replace('/[^a-zA-Z0-9]+/', '_', $path), '_'),
            $requestMethod
        );
    }

    /**
     * Adds a catch-all route to handle responses for non-existing routes.
     */
    private function addDefaultRoutes(RouteCollection $collection, string $resource): void
    {
        $catchAllRoute = new Route(
            '/{catchall}',
            [
                '_controller' => CatchAllController::CONTROLLER_REFERENCE,
                RouteContext::REQUEST_ATTRIBUTE => [RouteContext::RESOURCE => $resource],
            ],
            ['catchall' => '.*']
        );

        $collection->add('catch_all', $catchAllRoute);
    }
}

nijens / openapi-bundle

Pull Request — main (#65)

parseOpenapiBundleSpecificationExtension() B

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like
