libs/jsonrpc/tests/ServerProtocolTest.php

<?php

use JsonRPC\Server;

require_once __DIR__.'/../../../vendor/autoload.php';
require_once __DIR__.'/Response/HeaderMockTest.php';

class C
{
    public function doSomething()
    {
        return 'something';
    }
}

class ServerProtocolTest extends \JsonRPC\Response\HeaderMockTest
{
    public function testPositionalParameters()
    {
        $subtract = function ($minuend, $subtrahend) {
            return $minuend - $subtrahend;
        };

        $server = new Server('{"jsonrpc": "2.0", "method": "subtract", "params": [42, 23], "id": 1}');
        $server->register('subtract', $subtract);

        $this->assertEquals(
            json_decode('{"jsonrpc": "2.0", "result": 19, "id": 1}', true),
            json_decode($server->execute(), true)
        );

        $server = new Server('{"jsonrpc": "2.0", "method": "subtract", "params": [23, 42], "id": 1}');
        $server->register('subtract', $subtract);

        $this->assertEquals(
            json_decode('{"jsonrpc": "2.0", "result": -19, "id": 1}', true),
            json_decode($server->execute(), true)
        );
    }

    public function testNamedParameters()
    {
        $subtract = function ($minuend, $subtrahend) {
            return $minuend - $subtrahend;
        };

        $server = new Server('{"jsonrpc": "2.0", "method": "subtract", "params": {"subtrahend": 23, "minuend": 42}, "id": 3}');
        $server->register('subtract', $subtract);

        $this->assertEquals(
            json_decode('{"jsonrpc": "2.0", "result": 19, "id": 3}', true),
            json_decode($server->execute(), true)
        );

        $server = new Server('{"jsonrpc": "2.0", "method": "subtract", "params": {"minuend": 42, "subtrahend": 23}, "id": 4}');
        $server->register('subtract', $subtract);

        $this->assertEquals(
            json_decode('{"jsonrpc": "2.0", "result": 19, "id": 4}', true),
            json_decode($server->execute(), true)
        );
    }

    public function testNotification()
    {
        $update = function($p1, $p2, $p3, $p4, $p5) {};
        $foobar = function() {};

        $server = new Server('{"jsonrpc": "2.0", "method": "update", "params": [1,2,3,4,5]}');
        $server->register('update', $update);
        $server->register('foobar', $foobar);

        $this->assertEquals('', $server->execute());

        $server = new Server('{"jsonrpc": "2.0", "method": "foobar"}');
        $server->register('update', $update);
        $server->register('foobar', $foobar);

        $this->assertEquals('', $server->execute());
    }

    public function testNoMethod()
    {
        $server = new Server('{"jsonrpc": "2.0", "method": "foobar", "id": "1"}');

        $this->assertEquals(
            json_decode('{"jsonrpc": "2.0", "error": {"code": -32601, "message": "Method not found"}, "id": "1"}', true),
            json_decode($server->execute(), true)
        );
    }

    public function testInvalidJson()
    {
        $server = new Server('{"jsonrpc": "2.0", "method": "foobar, "params": "bar", "baz]');

        $this->assertEquals(
            json_decode('{"jsonrpc": "2.0", "error": {"code": -32700, "message": "Parse error"}, "id": null}', true),
            json_decode($server->execute(), true)
        );
    }

    public function testInvalidRequest()
    {
        $server = new Server('{"jsonrpc": "2.0", "method": 1, "params": "bar", "id": 1}');

        $this->assertEquals(
            json_decode('{"jsonrpc": "2.0", "error": {"code": -32600, "message": "Invalid Request"}, "id": null}', true),
            json_decode($server->execute(), true)
        );
    }

    public function testInvalidResponse_MalformedCharacters()
    {
        $server = new Server('{"jsonrpc": "2.0", "method": "invalidresponse","id": 1}');

        $invalidresponse = function() {
            return pack("H*" ,'c32e');
        };

        $server->register('invalidresponse', $invalidresponse);

        $this->assertEquals(
            json_decode('{"jsonrpc": "2.0","id": 1, "error": {"code": -32603, "message": "Internal error","data": "Malformed UTF-8 characters, possibly incorrectly encoded"}}', true),
            json_decode($server->execute(), true)
        );
    }

    public function testBatchInvalidJson()
    {
        $server = new Server('[
          {"jsonrpc": "2.0", "method": "sum", "params": [1,2,4], "id": "1"},
          {"jsonrpc": "2.0", "method"
        ]');

        $this->assertEquals(
            json_decode('{"jsonrpc": "2.0", "error": {"code": -32700, "message": "Parse error"}, "id": null}', true),
            json_decode($server->execute(), true)
        );
    }

    public function testBatchEmptyArray()
    {
        $server = new Server('[]');

        $this->assertEquals(
            json_decode('{"jsonrpc": "2.0", "error": {"code": -32600, "message": "Invalid Request"}, "id": null}', true),
            json_decode($server->execute(), true)
        );
    }

    public function testBatchNotEmptyButInvalid()
    {
        $server = new Server('[1]');

        $this->assertEquals(
            json_decode('[{"jsonrpc": "2.0", "error": {"code": -32700, "message": "Parse error"}, "id": null}]', true),
            json_decode($server->execute(), true)
        );
    }

    public function testBatchInvalid()
    {
        $server = new Server('[1,2,3]');

        $this->assertEquals(
            json_decode('[
                {"jsonrpc": "2.0", "error": {"code": -32700, "message": "Parse error"}, "id": null},
                {"jsonrpc": "2.0", "error": {"code": -32700, "message": "Parse error"}, "id": null},
                {"jsonrpc": "2.0", "error": {"code": -32700, "message": "Parse error"}, "id": null}
            ]', true),
            json_decode($server->execute(), true)
        );
    }

    public function testBatchOk()
    {
        $server = new Server('[
            {"jsonrpc": "2.0", "method": "sum", "params": [1,2,4], "id": "1"},
            {"jsonrpc": "2.0", "method": "notify_hello", "params": [7]},
            {"jsonrpc": "2.0", "method": "subtract", "params": [42,23], "id": "2"},
            {"foo": "boo"},
            {"jsonrpc": "2.0", "method": "foo.get", "params": {"name": "myself"}, "id": "5"},
            {"jsonrpc": "2.0", "method": "get_data", "id": "9"},
            {"jsonrpc": "2.0", "method": "doSomething", "id": 10},
            {"jsonrpc": "2.0", "method": "doStuff", "id": 15}
        ]');

        $server->register('sum', function($a, $b, $c) {
            return $a + $b + $c;
        });

        $server->register('subtract', function($minuend, $subtrahend) {
            return $minuend - $subtrahend;
        });

        $server->register('get_data', function() {
            return array('hello', 5);
        });

        $server->attach(new C);

        $server->bind('doStuff', 'C', 'doSomething');

        $response = $server->execute();

        $this->assertEquals(
            json_decode('[
                {"jsonrpc": "2.0", "result": 7, "id": "1"},
                {"jsonrpc": "2.0", "result": 19, "id": "2"},
                {"jsonrpc": "2.0", "error": {"code": -32600, "message": "Invalid Request"}, "id": null},
                {"jsonrpc": "2.0", "error": {"code": -32601, "message": "Method not found"}, "id": "5"},
                {"jsonrpc": "2.0", "result": ["hello", 5], "id": "9"},
                {"jsonrpc": "2.0", "result": "something", "id": "10"},
                {"jsonrpc": "2.0", "result": "something", "id": "15"}
            ]', true),
            json_decode($response, true)
        );
    }

    public function testBatchNotifications()
    {
        $server = new Server('[
            {"jsonrpc": "2.0", "method": "notify_sum", "params": [1,2,4]},
            {"jsonrpc": "2.0", "method": "notify_hello", "params": [7]}
        ]');

        $server->register('notify_sum', function($a, $b, $c) {

        });

        $server->register('notify_hello', function($id) {

        });

        $this->assertEquals('', $server->execute());
    }
}