RestbaseVirtualRESTService.php

Go to the documentation of this file.

<?php
class RestbaseVirtualRESTService extends VirtualRESTService {
    public function __construct( array $params ) {
        // set up defaults and merge them with the given params
        $mparams = array_merge( [
            'name' => 'restbase',
            'url' => 'http://localhost:7231/',
            'domain' => 'localhost',
            'timeout' => 100,
            'forwardCookies' => false,
            'HTTPProxy' => null,
            'parsoidCompat' => false,
            'fixedUrl' => false,
        ], $params );
        // Ensure that the url parameter has a trailing slash.
        // @phan-suppress-next-line PhanTypeMismatchArgumentNullableInternal url has default value
        if ( substr( $mparams['url'], -1 ) !== '/' ) {
            $mparams['url'] .= '/';
        }
        // Ensure the correct domain format: strip protocol, port,
        // and trailing slash if present.  This lets us use
        // $wgCanonicalServer as a default value, which is very convenient.
        $mparams['domain'] = preg_replace(
            '/^((https?:)?\/\/)?([^\/:]+?)(:\d+)?\/?$/',
            '$3',
            // @phan-suppress-next-line PhanTypeMismatchArgumentNullableInternal domain has default value
            $mparams['domain']
        );
        parent::__construct( $mparams );
    }
 
    public function onRequests( array $reqs, Closure $idGenFunc ) {
        if ( $this->params['parsoidCompat'] ) {
            return $this->onParsoidRequests( $reqs, $idGenFunc );
        }
 
        $result = [];
        foreach ( $reqs as $key => $req ) {
            if ( $this->params['fixedUrl'] ) {
                $version = explode( '/', $req['url'] )[1];
                $req['url'] =
                    str_replace( '#version#', $version, $this->params['url'] ) .
                    preg_replace( '#^local/v./#', '', $req['url'] );
            } else {
                // replace /local/ with the current domain
                $req['url'] = preg_replace( '#^local/#', $this->params['domain'] . '/', $req['url'] );
                // and prefix it with the service URL
                $req['url'] = $this->params['url'] . $req['url'];
            }
 
            // set the appropriate proxy, timeout and headers
            if ( $this->params['HTTPProxy'] ) {
                $req['proxy'] = $this->params['HTTPProxy'];
            }
            if ( $this->params['timeout'] != null ) {
                $req['reqTimeout'] = $this->params['timeout'];
            }
            if ( $this->params['forwardCookies'] ) {
                $req['headers']['Cookie'] = $this->params['forwardCookies'];
            }
            $result[$key] = $req;
        }
 
        return $result;
    }
 
    public function onParsoidRequests( array $reqs, Closure $idGeneratorFunc ) {
        $result = [];
        foreach ( $reqs as $key => $req ) {
            $version = explode( '/', $req['url'] )[1];
            if ( $version === 'v3' ) {
                $result[$key] = $this->onParsoid3Request( $req, $idGeneratorFunc );
            } else {
                throw new Exception( "Only Parsoid v3 is supported." );
            }
        }
 
        return $result;
    }
 
    public function onParsoid3Request( array $req, Closure $idGeneratorFunc ) {
        $parts = explode( '/', $req['url'] );
        [ $targetWiki, $version, ] = $parts;
        if ( $targetWiki !== 'local' ) {
            throw new Exception( "Only 'local' target wiki is currently supported" );
        } elseif ( $version !== 'v3' ) {
            throw new Exception( "Version mismatch: should not happen." );
        }
        // replace /local/ with the current domain, change v3 to v1,
        $req['url'] = preg_replace( '#^local/v3/#', $this->params['domain'] . '/v1/', $req['url'] );
        // and prefix it with the service URL
        $req['url'] = $this->params['url'] . $req['url'];
        // set the appropriate proxy, timeout and headers
        if ( $this->params['HTTPProxy'] ) {
            $req['proxy'] = $this->params['HTTPProxy'];
        }
        if ( $this->params['timeout'] != null ) {
            $req['reqTimeout'] = $this->params['timeout'];
        }
        if ( $this->params['forwardCookies'] ) {
            $req['headers']['Cookie'] = $this->params['forwardCookies'];
        }
 
        return $req;
    }
 
}