SpecBasedModule.php

Go to the documentation of this file.

<?php
 
namespace MediaWiki\Rest\Module;
 
use MediaWiki\Rest\BasicAccess\BasicAuthorizerInterface;
use MediaWiki\Rest\Handler\RedirectHandler;
use MediaWiki\Rest\PathTemplateMatcher\ModuleConfigurationException;
use MediaWiki\Rest\Reporter\ErrorReporter;
use MediaWiki\Rest\ResponseFactory;
use MediaWiki\Rest\RouteDefinitionException;
use MediaWiki\Rest\Router;
use MediaWiki\Rest\Validator\Validator;
use Wikimedia\ObjectFactory\ObjectFactory;
 
class SpecBasedModule extends MatcherBasedModule {
 
    private string $definitionFile;
 
    private ?array $moduleDef = null;
 
    private ?int $routeFileTimestamp = null;
 
    private ?string $configHash = null;
 
    public function __construct(
        string $definitionFile,
        Router $router,
        string $pathPrefix,
        ResponseFactory $responseFactory,
        BasicAuthorizerInterface $basicAuth,
        ObjectFactory $objectFactory,
        Validator $restValidator,
        ErrorReporter $errorReporter
    ) {
        parent::__construct(
            $router,
            $pathPrefix,
            $responseFactory,
            $basicAuth,
            $objectFactory,
            $restValidator,
            $errorReporter
        );
        $this->definitionFile = $definitionFile;
    }
 
    protected function getConfigHash(): string {
        if ( $this->configHash === null ) {
            $this->configHash = md5( json_encode( [
                'class' => __CLASS__,
                'version' => 1,
                'fileTimestamps' => $this->getRouteFileTimestamp()
            ] ) );
        }
        return $this->configHash;
    }
 
    private function loadDefinition(): array {
        if ( $this->moduleDef !== null ) {
            return $this->moduleDef;
        }
 
        $this->routeFileTimestamp = filemtime( $this->definitionFile );
        $moduleDef = $this->loadJsonFile( $this->definitionFile );
 
        if ( !$moduleDef ) {
            throw new ModuleConfigurationException(
                'Malformed module definition file: ' . $this->definitionFile
            );
        }
 
        if ( !isset( $moduleDef['mwapi'] ) ) {
            throw new ModuleConfigurationException(
                'Missing mwapi version field in ' . $this->definitionFile
            );
        }
 
        // Require OpenAPI version 3.1 or compatible.
        if ( !version_compare( $moduleDef['mwapi'], '1.0.999', '<=' ) ||
            !version_compare( $moduleDef['mwapi'], '1.0.0', '>=' )
        ) {
            throw new ModuleConfigurationException(
                "Unsupported openapi version {$moduleDef['mwapi']} in "
                    . $this->definitionFile
            );
        }
 
        $this->moduleDef = $moduleDef;
        return $this->moduleDef;
    }
 
    private function getRouteFileTimestamp(): int {
        if ( $this->routeFileTimestamp === null ) {
            $this->routeFileTimestamp = filemtime( $this->definitionFile );
        }
        return $this->routeFileTimestamp;
    }
 
    public function getDefinedPaths(): array {
        $paths = [];
        $moduleDef = $this->loadDefinition();
 
        foreach ( $moduleDef['paths'] as $path => $pSpec ) {
            $paths[$path] = [];
            foreach ( $pSpec as $method => $opSpec ) {
                $paths[$path][] = strtoupper( $method );
            }
        }
 
        return $paths;
    }
 
    protected function initRoutes(): void {
        $moduleDef = $this->loadDefinition();
 
        // The structure is similar to OpenAPI, see docs/rest/mwapi.1.0.json
        foreach ( $moduleDef['paths'] as $path => $pathSpec ) {
            foreach ( $pathSpec as $method => $opSpec ) {
                $info = $this->makeRouteInfo( $path, $opSpec );
                $this->addRoute( $method, $path, $info );
            }
        }
    }
 
    private function makeRouteInfo( string $path, array $opSpec ): array {
        static $objectSpecKeys = [
            'class',
            'factory',
            'services',
            'optional_services',
            'args',
        ];
 
        static $oasKeys = [
            'parameters',
            'responses',
            'summary',
            'description',
            'tags',
            'externalDocs',
        ];
 
        if ( isset( $opSpec['redirect'] ) ) {
            // Redirect shorthand
            $opSpec['handler'] = [
                'class' => RedirectHandler::class,
                'redirect' => $opSpec['redirect'],
            ];
            unset( $opSpec['redirect'] );
        }
 
        $handlerSpec = $opSpec['handler'] ?? null;
        if ( !$handlerSpec ) {
            throw new RouteDefinitionException( 'Missing handler spec' );
        }
 
        $info = [
            'spec' => array_intersect_key( $handlerSpec, array_flip( $objectSpecKeys ) ),
            'config' => array_diff_key( $handlerSpec, array_flip( $objectSpecKeys ) ),
            'OAS' => array_intersect_key( $opSpec, array_flip( $oasKeys ) ),
            'path' => $path,
        ];
 
        return $info;
    }
}