Index: pkg/json_rpc_2/test/server/batch_test.dart |
diff --git a/pkg/json_rpc_2/test/server/batch_test.dart b/pkg/json_rpc_2/test/server/batch_test.dart |
new file mode 100644 |
index 0000000000000000000000000000000000000000..441df589375d868db8686276c89fde828b277493 |
--- /dev/null |
+++ b/pkg/json_rpc_2/test/server/batch_test.dart |
@@ -0,0 +1,105 @@ |
+// Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file |
+// for details. All rights reserved. Use of this source code is governed by a |
+// BSD-style license that can be found in the LICENSE file. |
+ |
+library json_rpc_2.test.server.batch_test; |
+ |
+import 'dart:convert'; |
+ |
+import 'package:unittest/unittest.dart'; |
+import 'package:json_rpc_2/error_code.dart' as error_code; |
+import 'package:json_rpc_2/json_rpc_2.dart' as json_rpc; |
+ |
+import 'utils.dart'; |
+ |
+void main() { |
+ var server; |
+ setUp(() { |
+ server = new json_rpc.Server() |
+ ..registerMethod('foo', () => 'foo') |
+ ..registerMethod('id', (params) => params.value) |
+ ..registerMethod('arg', (params) => params['arg'].value); |
+ }); |
+ |
+ test('handles a batch of requests', () { |
+ expect(server.handleRequest([ |
+ {'jsonrpc': '2.0', 'method': 'foo', 'id': 1}, |
+ {'jsonrpc': '2.0', 'method': 'id', 'params': ['value'], 'id': 2}, |
+ {'jsonrpc': '2.0', 'method': 'arg', 'params': {'arg': 'value'}, 'id': 3} |
+ ]), completion(equals([ |
+ {'jsonrpc': '2.0', 'result': 'foo', 'id': 1}, |
+ {'jsonrpc': '2.0', 'result': ['value'], 'id': 2}, |
+ {'jsonrpc': '2.0', 'result': 'value', 'id': 3} |
+ ]))); |
+ }); |
+ |
+ test('handles errors individually', () { |
+ expect(server.handleRequest([ |
+ {'jsonrpc': '2.0', 'method': 'foo', 'id': 1}, |
+ {'jsonrpc': '2.0', 'method': 'zap', 'id': 2}, |
+ {'jsonrpc': '2.0', 'method': 'arg', 'params': {'arg': 'value'}, 'id': 3} |
+ ]), completion(equals([ |
+ {'jsonrpc': '2.0', 'result': 'foo', 'id': 1}, |
+ { |
+ 'jsonrpc': '2.0', |
+ 'id': 2, |
+ 'error': { |
+ 'code': error_code.METHOD_NOT_FOUND, |
+ 'message': 'Unknown method "zap".', |
+ 'data': {'request': {'jsonrpc': '2.0', 'method': 'zap', 'id': 2}}, |
+ } |
+ }, |
+ {'jsonrpc': '2.0', 'result': 'value', 'id': 3} |
+ ]))); |
+ }); |
+ |
+ test('handles notifications individually', () { |
+ expect(server.handleRequest([ |
+ {'jsonrpc': '2.0', 'method': 'foo', 'id': 1}, |
+ {'jsonrpc': '2.0', 'method': 'id', 'params': ['value']}, |
+ {'jsonrpc': '2.0', 'method': 'arg', 'params': {'arg': 'value'}, 'id': 3} |
+ ]), completion(equals([ |
+ {'jsonrpc': '2.0', 'result': 'foo', 'id': 1}, |
+ {'jsonrpc': '2.0', 'result': 'value', 'id': 3} |
+ ]))); |
+ }); |
+ |
+ test('returns nothing if every request is a notification', () { |
+ expect(server.handleRequest([ |
+ {'jsonrpc': '2.0', 'method': 'foo'}, |
+ {'jsonrpc': '2.0', 'method': 'id', 'params': ['value']}, |
+ {'jsonrpc': '2.0', 'method': 'arg', 'params': {'arg': 'value'}} |
+ ]), completion(isNull)); |
+ }); |
+ |
+ test('returns an error if the batch is empty', () { |
+ expectErrorResponse(server, [], error_code.INVALID_REQUEST, |
+ 'A batch must contain at least one request.'); |
+ }); |
+ |
+ test('handles a batch of requests parsed from JSON', () { |
+ expect(server.parseRequest(JSON.encode([ |
+ {'jsonrpc': '2.0', 'method': 'foo', 'id': 1}, |
+ {'jsonrpc': '2.0', 'method': 'id', 'params': ['value'], 'id': 2}, |
+ {'jsonrpc': '2.0', 'method': 'arg', 'params': {'arg': 'value'}, 'id': 3} |
+ ])), completion(equals(JSON.encode([ |
+ {'jsonrpc': '2.0', 'result': 'foo', 'id': 1}, |
+ {'jsonrpc': '2.0', 'result': ['value'], 'id': 2}, |
+ {'jsonrpc': '2.0', 'result': 'value', 'id': 3} |
+ ])))); |
+ }); |
+ |
+ test('disallows nested batches', () { |
+ expect(server.handleRequest([ |
+ [{'jsonrpc': '2.0', 'method': 'foo', 'id': 1}] |
+ ]), completion(equals([{ |
+ 'jsonrpc': '2.0', |
+ 'id': null, |
+ 'error': { |
+ 'code': error_code.INVALID_REQUEST, |
+ 'message': 'Request must be an Array or an Object.', |
+ 'data': {'request': [{'jsonrpc': '2.0', 'method': 'foo', 'id': 1}]} |
+ } |
+ }]))); |
+ }); |
+} |