GuzzleHttpRequestTest.php

Go to the documentation of this file.

<?php
 
use GuzzleHttp\Handler\MockHandler;
use GuzzleHttp\HandlerStack;
use GuzzleHttp\Middleware;
use GuzzleHttp\Psr7\Response;
use GuzzleHttp\Psr7\Request;
 
class GuzzleHttpRequestTest extends MediaWikiTestCase {
    protected $exampleUrl = 'http://www.example.test';
 
    protected $exampleBodyText = 'x';
 
    protected $bodyTextReceived = '';
 
    public function processHttpDataChunk( $req, $buffer ) {
        $this->bodyTextReceived .= $buffer;
        return strlen( $buffer );
    }
 
    public function testSuccess() {
        $handler = HandlerStack::create( new MockHandler( [ new Response( 200, [
            'status' => 200,
        ], $this->exampleBodyText ) ] ) );
        $r = new GuzzleHttpRequest( $this->exampleUrl, [ 'handler' => $handler ] );
        $r->execute();
 
        $this->assertEquals( 200, $r->getStatus() );
        $this->assertEquals( $this->exampleBodyText, $r->getContent() );
    }
 
    public function testSuccessConstructorCallback() {
        $this->bodyTextReceived = '';
        $handler = HandlerStack::create( new MockHandler( [ new Response( 200, [
            'status' => 200,
        ], $this->exampleBodyText ) ] ) );
        $r = new GuzzleHttpRequest( $this->exampleUrl, [
            'callback' => [ $this, 'processHttpDataChunk' ],
            'handler' => $handler,
        ] );
        $r->execute();
 
        $this->assertEquals( 200, $r->getStatus() );
        $this->assertEquals( $this->exampleBodyText, $this->bodyTextReceived );
    }
 
    public function testSuccessSetCallback() {
        $this->bodyTextReceived = '';
        $handler = HandlerStack::create( new MockHandler( [ new Response( 200, [
            'status' => 200,
        ], $this->exampleBodyText ) ] ) );
        $r = new GuzzleHttpRequest( $this->exampleUrl, [
            'handler' => $handler,
        ] );
        $r->setCallback( [ $this, 'processHttpDataChunk' ] );
        $r->execute();
 
        $this->assertEquals( 200, $r->getStatus() );
        $this->assertEquals( $this->exampleBodyText, $this->bodyTextReceived );
    }
 
    public function testSuccessSink() {
        $this->bodyTextReceived = '';
        $handler = HandlerStack::create( new MockHandler( [ new Response( 200, [
            'status' => 200,
        ], $this->exampleBodyText ) ] ) );
        $r = new GuzzleHttpRequest( $this->exampleUrl, [
            'handler' => $handler,
            'sink' => new MWCallbackStream( [ $this, 'processHttpDataChunk' ] ),
        ] );
        $r->execute();
 
        $this->assertEquals( 200, $r->getStatus() );
        $this->assertEquals( $this->exampleBodyText, $this->bodyTextReceived );
    }
 
    public function testBadUrl() {
        $r = new GuzzleHttpRequest( '' );
        $s = $r->execute();
        $errorMsg = $s->getErrorsByType( 'error' )[0]['message'];
 
        $this->assertEquals( 0, $r->getStatus() );
        $this->assertEquals( 'http-invalid-url', $errorMsg );
    }
 
    public function testConnectException() {
        $handler = HandlerStack::create( new MockHandler( [ new GuzzleHttp\Exception\ConnectException(
            'Mock Connection Exception', new Request( 'GET', $this->exampleUrl )
        ) ] ) );
        $r = new GuzzleHttpRequest( $this->exampleUrl, [ 'handler' => $handler ] );
        $s = $r->execute();
        $errorMsg = $s->getErrorsByType( 'error' )[0]['message'];
 
        $this->assertEquals( 0, $r->getStatus() );
        $this->assertEquals( 'http-request-error', $errorMsg );
    }
 
    public function testTimeout() {
        $handler = HandlerStack::create( new MockHandler( [ new GuzzleHttp\Exception\RequestException(
            'Connection timed out', new Request( 'GET', $this->exampleUrl )
        ) ] ) );
        $r = new GuzzleHttpRequest( $this->exampleUrl, [ 'handler' => $handler ] );
        $s = $r->execute();
        $errorMsg = $s->getErrorsByType( 'error' )[0]['message'];
 
        $this->assertEquals( 0, $r->getStatus() );
        $this->assertEquals( 'http-timed-out', $errorMsg );
    }
 
    public function testNotFound() {
        $handler = HandlerStack::create( new MockHandler( [ new Response( 404, [
            'status' => '404',
        ] ) ] ) );
        $r = new GuzzleHttpRequest( $this->exampleUrl, [ 'handler' => $handler ] );
        $s = $r->execute();
        $errorMsg = $s->getErrorsByType( 'error' )[0]['message'];
 
        $this->assertEquals( 404, $r->getStatus() );
        $this->assertEquals( 'http-bad-status', $errorMsg );
    }
 
    /*
     * Test of POST requests header
     */
    public function testPostBody() {
        $container = [];
        $history = Middleware::history( $container );
        $stack = HandlerStack::create();
        $stack->push( $history );
        $client = new GuzzleHttpRequest( $this->exampleUrl, [
            'method' => 'POST',
            'handler' => $stack,
            'post' => 'key=value',
        ] );
        $client->execute();
 
        $request = $container[0]['request'];
        $this->assertEquals( 'POST', $request->getMethod() );
        $this->assertEquals( 'application/x-www-form-urlencoded',
            $request->getHeader( 'Content-Type' )[0] );
    }
}