graze / guzzle-jsonrpc

test/unit/ClientTest.php

<?php
/*
 * This file is part of Guzzle HTTP JSON-RPC
 *
 * Copyright (c) 2014 Nature Delivered Ltd. <http://graze.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 *
 * @see  http://github.com/graze/guzzle-jsonrpc/blob/master/LICENSE
 * @link http://github.com/graze/guzzle-jsonrpc
 */
namespace Graze\GuzzleHttp\JsonRpc;

use Graze\GuzzleHttp\JsonRpc\Message\RequestInterface;
use Graze\GuzzleHttp\JsonRpc\Test\UnitTestCase;
use Mockery;

class ClientTest extends UnitTestCase
{
    /** @var mixed */
    private $httpClient;
    /** @var mixed */
    private $httpHandler;
    /** @var mixed */
    private $messageFactory;
    /** @var Client */
    private $client;

    public function setup()
    {
        $this->httpClient = $this->mockHttpClient();
        $this->httpHandler = $this->mockHttpHandler();
        $this->messageFactory = $this->mockMessageFactory();

        $this->httpClient->shouldReceive('getConfig')->once()->with('handler')->andReturn($this->httpHandler);

The call to Mockery\MockInterface::shouldReceive() has too many arguments starting with 'getConfig'.

        $this->httpHandler->shouldReceive('push')->times(4);

        $this->client = new Client($this->httpClient, $this->messageFactory);

$this->httpClient of type Mockery\MockInterface is incompatible with the type GuzzleHttp\ClientInterface expected by parameter $httpClient of Graze\GuzzleHttp\JsonRpc\Client::__construct().

$this->messageFactory of type Mockery\MockInterface is incompatible with the type Graze\GuzzleHttp\JsonRpc\Message\MessageFactoryInterface expected by parameter $factory of Graze\GuzzleHttp\JsonRpc\Client::__construct().

    }

    public function testInterface()
    {
        $this->assertInstanceOf('Graze\GuzzleHttp\JsonRpc\ClientInterface', $this->client);
    }

    public function testStaticFactory()
    {
        $this->assertInstanceOf('Graze\GuzzleHttp\JsonRpc\ClientInterface', Client::factory('http://foo'));
    }

    public function testNotification()
    {
        $request = $this->mockRequest();
        $jsonrpc = ['jsonrpc'=>ClientInterface::SPEC, 'method'=>'foo'];
        $type = RequestInterface::NOTIFICATION;
        $uri = 'http://foo';

        $this->httpClient->shouldReceive('getConfig')->once()->with('base_uri')->andReturn($uri);
        $this->httpClient->shouldReceive('getConfig')->once()->with('defaults')->andReturn([]);
        $this->messageFactory->shouldReceive('createRequest')->once()->with($type, $uri, [], $jsonrpc)->andReturn($request);

        $this->assertSame($request, $this->client->notification('foo'));
    }

    public function testNotificationWithParams()
    {
        $request = $this->mockRequest();
        $jsonrpc = ['jsonrpc'=>ClientInterface::SPEC, 'method'=>'foo', 'params'=>['bar'=>true]];
        $type = RequestInterface::NOTIFICATION;
        $uri = 'http://foo';

        $this->httpClient->shouldReceive('getConfig')->once()->with('base_uri')->andReturn($uri);
        $this->httpClient->shouldReceive('getConfig')->once()->with('defaults')->andReturn([]);
        $this->messageFactory->shouldReceive('createRequest')->once()->with($type, $uri, [], $jsonrpc)->andReturn($request);

        $this->assertSame($request, $this->client->notification('foo', ['bar'=>true]));
    }

    public function testRequest()
    {
        $request = $this->mockRequest();
        $jsonrpc = ['jsonrpc'=>ClientInterface::SPEC, 'method'=>'foo', 'id'=>123];
        $type = RequestInterface::REQUEST;
        $uri = 'http://foo';

        $this->httpClient->shouldReceive('getConfig')->once()->with('base_uri')->andReturn($uri);
        $this->httpClient->shouldReceive('getConfig')->once()->with('defaults')->andReturn([]);
        $this->messageFactory->shouldReceive('createRequest')->once()->with($type, $uri, [], $jsonrpc)->andReturn($request);

        $this->assertSame($request, $this->client->request(123, 'foo'));
    }

    public function testRequestWithParams()
    {
        $request = $this->mockRequest();
        $jsonrpc = ['jsonrpc'=>ClientInterface::SPEC, 'method'=>'foo', 'params'=>['bar'=>true], 'id'=>123];
        $type = RequestInterface::REQUEST;
        $uri = 'http://foo';

        $this->httpClient->shouldReceive('getConfig')->once()->with('base_uri')->andReturn($uri);
        $this->httpClient->shouldReceive('getConfig')->once()->with('defaults')->andReturn([]);
        $this->messageFactory->shouldReceive('createRequest')->once()->with($type, $uri, [], $jsonrpc)->andReturn($request);

        $this->assertSame($request, $this->client->request(123, 'foo', ['bar'=>true]));
    }

    public function testRequestWithEmptyParams()
    {
        $request = $this->mockRequest();
        $jsonrpc = ['jsonrpc'=>ClientInterface::SPEC, 'method'=>'foo', 'id'=>123];
        $type = RequestInterface::REQUEST;
        $uri = 'http://foo';

        $this->httpClient->shouldReceive('getConfig')->once()->with('base_uri')->andReturn($uri);
        $this->httpClient->shouldReceive('getConfig')->once()->with('defaults')->andReturn([]);
        $this->messageFactory->shouldReceive('createRequest')->once()->with($type, $uri, [], $jsonrpc)->andReturn($request);

        $this->assertSame($request, $this->client->request(123, 'foo', []));
    }

    public function testSendNotification()
    {
        $request = $this->mockRequest();
        $response = $this->mockResponse();
        $promise = $this->mockPromise();

        $request->shouldReceive('getRpcId')->once()->withNoArgs()->andReturn(null);

The call to Mockery\MockInterface::shouldReceive() has too many arguments starting with 'getRpcId'.

        $this->httpClient->shouldReceive('sendAsync')->once()->with($request)->andReturn($promise);
        $promise->shouldReceive('then')->once()->with(Mockery::on(function ($args) use ($response) {
            return null === $args($response);
        }))->andReturn($promise);
        $promise->shouldReceive('wait')->once()->withNoArgs()->andReturn(null);

        $this->assertNull($this->client->send($request));

$request of type Mockery\MockInterface is incompatible with the type Graze\GuzzleHttp\JsonRpc\Message\RequestInterface expected by parameter $request of Graze\GuzzleHttp\JsonRpc\Client::send().

    }

    public function testSendNotificationAsync()
    {
        $request = $this->mockRequest();
        $response = $this->mockResponse();
        $promise = $this->mockPromise();

        $request->shouldReceive('getRpcId')->once()->withNoArgs()->andReturn(null);

The call to Mockery\MockInterface::shouldReceive() has too many arguments starting with 'getRpcId'.

        $this->httpClient->shouldReceive('sendAsync')->once()->with($request)->andReturn($promise);
        $promise->shouldReceive('then')->once()->with(Mockery::on(function ($args) use ($response) {
            return null === $args($response);
        }))->andReturn($promise);

        $this->assertSame($promise, $this->client->sendAsync($request));

$request of type Mockery\MockInterface is incompatible with the type Graze\GuzzleHttp\JsonRpc\Message\RequestInterface expected by parameter $request of Graze\GuzzleHttp\JsonRpc\Client::sendAsync().

    }

    public function testSendRequest()
    {
        $request = $this->mockRequest();
        $response = $this->mockResponse();
        $promise = $this->mockPromise();

        $request->shouldReceive('getRpcId')->once()->withNoArgs()->andReturn('foo');

The call to Mockery\MockInterface::shouldReceive() has too many arguments starting with 'getRpcId'.

        $this->httpClient->shouldReceive('sendAsync')->once()->with($request)->andReturn($promise);
        $promise->shouldReceive('then')->once()->with(Mockery::on(function ($args) use ($response) {
            return $response === $args($response);
        }))->andReturn($promise);
        $promise->shouldReceive('wait')->once()->withNoArgs()->andReturn($response);

        $this->assertSame($response, $this->client->send($request));

$request of type Mockery\MockInterface is incompatible with the type Graze\GuzzleHttp\JsonRpc\Message\RequestInterface expected by parameter $request of Graze\GuzzleHttp\JsonRpc\Client::send().

    }

    public function testSendRequestAsync()
    {
        $request = $this->mockRequest();
        $response = $this->mockResponse();
        $promise = $this->mockPromise();

        $request->shouldReceive('getRpcId')->once()->withNoArgs()->andReturn('foo');

The call to Mockery\MockInterface::shouldReceive() has too many arguments starting with 'getRpcId'.

        $this->httpClient->shouldReceive('sendAsync')->once()->with($request)->andReturn($promise);
        $promise->shouldReceive('then')->once()->with(Mockery::on(function ($args) use ($response) {
            return $response === $args($response);
        }))->andReturn($promise);

        $this->assertSame($promise, $this->client->sendAsync($request));

$request of type Mockery\MockInterface is incompatible with the type Graze\GuzzleHttp\JsonRpc\Message\RequestInterface expected by parameter $request of Graze\GuzzleHttp\JsonRpc\Client::sendAsync().

    }

    public function testSendAll()
    {
        $promise = $this->mockPromise();
        $batchRequest = $this->mockRequest();
        $requestA = $this->mockRequest();
        $requestB = $this->mockRequest();
        $batchResponse = $this->mockResponse();
        $responseA = $this->mockResponse();
        $responseB = $this->mockResponse();

        $factory = $this->mockMessageFactory();
        $this->httpClient->messageFactory = $factory;

        $requestA->shouldReceive('getBody')->once()->withNoArgs()->andReturn('["foo"]');

The call to Mockery\MockInterface::shouldReceive() has too many arguments starting with 'getBody'.

        $requestB->shouldReceive('getBody')->once()->withNoArgs()->andReturn('["bar"]');

        $type = RequestInterface::BATCH;
        $uri = 'http://foo';
        $this->messageFactory->shouldReceive('createRequest')->once()->with($type, $uri, [], [['foo'], ['bar']])->andReturn($batchRequest);
        $this->httpClient->shouldReceive('getConfig')->once()->with('base_uri')->andReturn($uri);
        $this->httpClient->shouldReceive('getConfig')->once()->with('defaults')->andReturn([]);
        $this->httpClient->shouldReceive('sendAsync')->once()->with($batchRequest)->andReturn($promise);

        $promise->shouldReceive('then')->once()->with(Mockery::on(function ($args) use ($batchResponse, $responseA, $responseB) {
            return [$responseA, $responseB] === $args($batchResponse);
        }))->andReturn($promise);
        $promise->shouldReceive('wait')->once()->withNoArgs()->andReturn([$responseA, $responseB]);

        $batchResponse->shouldReceive('getBody')->once()->withNoArgs()->andReturn('[["foo"], ["bar"]]');
        $batchResponse->shouldReceive('getStatusCode')->times(2)->withNoArgs()->andReturn(200);
        $batchResponse->shouldReceive('getHeaders')->times(2)->withNoArgs()->andReturn(['headers']);

        $this->messageFactory->shouldReceive('createResponse')->once()->with(200, ['headers'], ['foo'])->andReturn($responseA);
        $this->messageFactory->shouldReceive('createResponse')->once()->with(200, ['headers'], ['bar'])->andReturn($responseB);

        $this->assertSame([$responseA, $responseB], $this->client->sendAll([$requestA, $requestB]));
    }

    public function testSendAllAsync()
    {
        $promise = $this->mockPromise();
        $batchRequest = $this->mockRequest();
        $requestA = $this->mockRequest();
        $requestB = $this->mockRequest();
        $batchResponse = $this->mockResponse();
        $responseA = $this->mockResponse();
        $responseB = $this->mockResponse();

        $factory = $this->mockMessageFactory();
        $this->httpClient->messageFactory = $factory;

        $requestA->shouldReceive('getBody')->once()->withNoArgs()->andReturn('["foo"]');

The call to Mockery\MockInterface::shouldReceive() has too many arguments starting with 'getBody'.

        $requestB->shouldReceive('getBody')->once()->withNoArgs()->andReturn('["bar"]');

        $type = RequestInterface::BATCH;
        $uri = 'http://foo';
        $this->messageFactory->shouldReceive('createRequest')->once()->with($type, $uri, [], [['foo'], ['bar']])->andReturn($batchRequest);
        $this->httpClient->shouldReceive('getConfig')->once()->with('base_uri')->andReturn($uri);
        $this->httpClient->shouldReceive('getConfig')->once()->with('defaults')->andReturn([]);
        $this->httpClient->shouldReceive('sendAsync')->once()->with($batchRequest)->andReturn($promise);

        $promise->shouldReceive('then')->once()->with(Mockery::on(function ($args) use ($batchResponse, $responseA, $responseB) {
            return [$responseA, $responseB] === $args($batchResponse);
        }))->andReturn($promise);

        $batchResponse->shouldReceive('getBody')->once()->withNoArgs()->andReturn('[["foo"], ["bar"]]');
        $batchResponse->shouldReceive('getStatusCode')->times(2)->withNoArgs()->andReturn(200);
        $batchResponse->shouldReceive('getHeaders')->times(2)->withNoArgs()->andReturn(['headers']);

        $this->messageFactory->shouldReceive('createResponse')->once()->with(200, ['headers'], ['foo'])->andReturn($responseA);
        $this->messageFactory->shouldReceive('createResponse')->once()->with(200, ['headers'], ['bar'])->andReturn($responseB);

        $this->assertSame($promise, $this->client->sendAllAsync([$requestA, $requestB]));
    }
}