Create a package that implements a JSON-RPC 2.0 server.

pkg/json_rpc_2/test/server/batch_test.dart

+// 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}]}
+      }
+    }])));
+  });
+}