|
<?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()); |
|
} |
|
} |
|
|