GuzzleHttpRequest.php

Go to the documentation of this file.

<?php
use GuzzleHttp\Client;
use GuzzleHttp\HandlerStack;
use GuzzleHttp\MessageFormatter;
use GuzzleHttp\Middleware;
use GuzzleHttp\Psr7\Request;
use MediaWiki\Status\Status;
use Psr\Http\Message\RequestInterface;
use Psr\Log\NullLogger;
 
class GuzzleHttpRequest extends MWHttpRequest {
    public const SUPPORTS_FILE_POSTS = true;
 
    protected $handler = null;
    protected $sink = null;
    protected $guzzleOptions = [ 'http_errors' => false ];
 
    public function __construct(
        $url, array $options = [], $caller = __METHOD__, Profiler $profiler = null
    ) {
        parent::__construct( $url, $options, $caller, $profiler );
 
        if ( isset( $options['handler'] ) ) {
            $this->handler = $options['handler'];
        }
        if ( isset( $options['sink'] ) ) {
            $this->sink = $options['sink'];
        }
    }
 
    public function setCallback( $callback ) {
        $this->sink = null;
        $this->doSetCallback( $callback );
    }
 
    protected function doSetCallback( $callback ) {
        if ( !$this->sink ) {
            parent::doSetCallback( $callback );
            $this->sink = new MWCallbackStream( $this->callback );
        }
    }
 
    public function execute() {
        $this->prepare();
 
        if ( !$this->status->isOK() ) {
            return Status::wrap( $this->status ); // TODO B/C; move this to callers
        }
 
        if ( $this->proxy ) {
            $this->guzzleOptions['proxy'] = $this->proxy;
        }
 
        $this->guzzleOptions['timeout'] = $this->timeout;
        $this->guzzleOptions['connect_timeout'] = $this->connectTimeout;
        $this->guzzleOptions['version'] = '1.1';
 
        if ( !$this->followRedirects ) {
            $this->guzzleOptions['allow_redirects'] = false;
        } else {
            $this->guzzleOptions['allow_redirects'] = [
                'max' => $this->maxRedirects
            ];
        }
 
        if ( $this->method == 'POST' ) {
            $postData = $this->postData;
            if ( is_array( $postData ) ) {
                $this->guzzleOptions['form_params'] = $postData;
            } else {
                $this->guzzleOptions['body'] = $postData;
                // mimic CURLOPT_POST option
                if ( !isset( $this->reqHeaders['Content-Type'] ) ) {
                    $this->reqHeaders['Content-Type'] = 'application/x-www-form-urlencoded';
                }
            }
 
            // Suppress 'Expect: 100-continue' header, as some servers
            // will reject it with a 417 and Curl won't auto retry
            // with HTTP 1.0 fallback
            $this->guzzleOptions['expect'] = false;
        }
 
        $stack = HandlerStack::create( $this->handler );
 
        // Create Middleware to use cookies from $this->getCookieJar(),
        // which is in MediaWiki CookieJar format, not in Guzzle-specific CookieJar format.
        // Note: received cookies (from HTTP response) don't need to be handled here,
        // they will be added back into the CookieJar by MWHttpRequest::parseCookies().
        // @phan-suppress-next-line PhanUndeclaredFunctionInCallable
        $stack->remove( 'cookies' );
        $mwCookieJar = $this->getCookieJar();
        $stack->push( Middleware::mapRequest(
            static function ( RequestInterface $request ) use ( $mwCookieJar ) {
                $uri = $request->getUri();
                $cookieHeader = $mwCookieJar->serializeToHttpRequest(
                    $uri->getPath() ?: '/',
                    $uri->getHost()
                );
                if ( !$cookieHeader ) {
                    return $request;
                }
 
                return $request->withHeader( 'Cookie', $cookieHeader );
            }
        ), 'cookies' );
 
        if ( !$this->logger instanceof NullLogger ) {
            $stack->push( Middleware::log( $this->logger, new MessageFormatter(
                // TODO {error} will be 'NULL' on success which is unfortunate, but
                //   doesn't seem fixable without a custom formatter. Same for using
                //   PSR-3 variable replacement instead of raw strings.
                '[{ts}] {method} {uri} HTTP/{version} - {code} {error}'
            ) ), 'logger' );
        }
 
        $this->guzzleOptions['handler'] = $stack;
 
        if ( $this->sink ) {
            $this->guzzleOptions['sink'] = $this->sink;
        }
 
        if ( $this->caInfo ) {
            $this->guzzleOptions['verify'] = $this->caInfo;
        } elseif ( !$this->sslVerifyHost && !$this->sslVerifyCert ) {
            $this->guzzleOptions['verify'] = false;
        }
 
        $client = new Client( $this->guzzleOptions );
        $request = new Request( $this->method, $this->url );
        foreach ( $this->reqHeaders as $name => $value ) {
            $request = $request->withHeader( $name, $value );
        }
 
        try {
            $response = $client->send( $request );
            $this->headerList = $response->getHeaders();
 
            $this->respVersion = $response->getProtocolVersion();
            $this->respStatus = $response->getStatusCode() . ' ' . $response->getReasonPhrase();
        } catch ( GuzzleHttp\Exception\ConnectException $e ) {
            // ConnectException is thrown for several reasons besides generic "timeout":
            //   Connection refused
            //   couldn't connect to host
            //   connection attempt failed
            //   Could not resolve IPv4 address for host
            //   Could not resolve IPv6 address for host
            if ( $this->usingCurl() ) {
                $handlerContext = $e->getHandlerContext();
                if ( $handlerContext['errno'] == CURLE_OPERATION_TIMEOUTED ) {
                    $this->status->fatal( 'http-timed-out', $this->url );
                } else {
                    $this->status->fatal( 'http-curl-error', $handlerContext['error'] );
                }
            } else {
                $this->status->fatal( 'http-request-error' );
            }
        } catch ( GuzzleHttp\Exception\RequestException $e ) {
            if ( $this->usingCurl() ) {
                $handlerContext = $e->getHandlerContext();
                $this->status->fatal( 'http-curl-error', $handlerContext['error'] );
            } else {
                // Non-ideal, but the only way to identify connection timeout vs other conditions
                $needle = 'Connection timed out';
                if ( strpos( $e->getMessage(), $needle ) !== false ) {
                    $this->status->fatal( 'http-timed-out', $this->url );
                } else {
                    $this->status->fatal( 'http-request-error' );
                }
            }
        } catch ( GuzzleHttp\Exception\GuzzleException $e ) {
            $this->status->fatal( 'http-internal-error' );
        }
 
        if ( $this->profiler ) {
            $profileSection = $this->profiler->scopedProfileIn(
                __METHOD__ . '-' . $this->profileName
            );
        }
 
        if ( $this->profiler ) {
            $this->profiler->scopedProfileOut( $profileSection );
        }
 
        $this->parseHeader();
        $this->setStatus();
 
        return Status::wrap( $this->status ); // TODO B/C; move this to callers
    }
 
    protected function prepare() {
        $this->doSetCallback( $this->callback );
        parent::prepare();
    }
 
    protected function usingCurl() {
        return ( $this->handler && is_a( $this->handler, 'GuzzleHttp\Handler\CurlHandler' ) ) ||
            ( !$this->handler && extension_loaded( 'curl' ) );
    }
 
    protected function parseHeader() {
        // Failure without (valid) headers gets a response status of zero
        if ( !$this->status->isOK() ) {
            $this->respStatus = '0 Error';
        }
 
        foreach ( $this->headerList as $name => $values ) {
            $this->respHeaders[strtolower( $name )] = $values;
        }
 
        $this->parseCookies();
    }
}