| Index: runtime/observatory/tests/service/external_service_asynchronous_invocation_test.dart
|
| diff --git a/runtime/observatory/tests/service/external_service_asynchronous_invocation_test.dart b/runtime/observatory/tests/service/external_service_asynchronous_invocation_test.dart
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..597bf359b44351c4462b48b67b1785316e96083a
|
| --- /dev/null
|
| +++ b/runtime/observatory/tests/service/external_service_asynchronous_invocation_test.dart
|
| @@ -0,0 +1,163 @@
|
| +// Copyright (c) 2017, 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.
|
| +// VMOptions=--error_on_bad_type --error_on_bad_override
|
| +
|
| +import 'package:observatory/service_io.dart';
|
| +import 'package:unittest/unittest.dart';
|
| +import 'test_helper.dart';
|
| +import 'dart:io' show WebSocket;
|
| +import 'dart:convert' show JSON;
|
| +import 'dart:async' show Future, StreamController;
|
| +
|
| +var tests = [
|
| + (Isolate isolate) async {
|
| + VM vm = isolate.owner;
|
| +
|
| + final serviceEvents =
|
| + (await vm.getEventStream('_Service')).asBroadcastStream();
|
| +
|
| + WebSocket _socket =
|
| + await WebSocket.connect((vm as WebSocketVM).target.networkAddress);
|
| +
|
| + final socket = new StreamController();
|
| +
|
| + // Avoid to manually encode and decode messages from the stream
|
| + socket.stream.map(JSON.encode).pipe(_socket);
|
| + final client = _socket.map(JSON.decode).asBroadcastStream();
|
| +
|
| + const successServiceName = 'successService';
|
| + const errorServiceName = 'errorService';
|
| + const serviceAlias = 'serviceAlias';
|
| + const paramKey = 'pkey';
|
| + const paramValue = 'pvalue';
|
| + const resultKey = 'rkey';
|
| + const resultValue = 'rvalue';
|
| + const errorCode = 5000;
|
| + const errorKey = 'ekey';
|
| + const errorValue = 'evalue';
|
| + const repetition = 5;
|
| +
|
| + socket.add({
|
| + 'jsonrpc': '2.0',
|
| + 'id': 1,
|
| + 'method': '_registerService',
|
| + 'params': {'service': successServiceName, 'alias': serviceAlias}
|
| + });
|
| +
|
| + // Avoid flaky test.
|
| + // We cannot assume the order in which two messages will arrive
|
| + // from two different sockets
|
| + await Future.wait([client.first, serviceEvents.first]);
|
| +
|
| + // Registering second service
|
| + socket.add({
|
| + 'jsonrpc': '2.0',
|
| + 'id': 1,
|
| + 'method': '_registerService',
|
| + 'params': {'service': errorServiceName, 'alias': serviceAlias}
|
| + });
|
| +
|
| + // Avoid flaky test.
|
| + // We cannot assume the order in which two messages will arrive
|
| + // from two different sockets
|
| + await Future.wait([client.first, serviceEvents.first]);
|
| +
|
| + // Testing parallel invocation of service which succeeds
|
| + {
|
| + final results = new List<Future<Map>>.generate(repetition, (iteration) {
|
| + final end = iteration.toString();
|
| + return vm.invokeRpcRaw(
|
| + vm.services.first.method, {paramKey + end: paramValue + end});
|
| + });
|
| + final requests = await (client.take(repetition).toList());
|
| +
|
| + final completions = requests.map((final request) {
|
| + final iteration = requests.indexOf(request);
|
| + final end = iteration.toString();
|
| +
|
| + // check requests while they arrive
|
| + expect(request, contains('id'));
|
| + expect(request['id'], isNotNull);
|
| + expect(request['method'], equals(successServiceName));
|
| + expect(request['params'], isNotNull);
|
| + expect(request['params'][paramKey + end], equals(paramValue + end));
|
| +
|
| + // answer later
|
| + return () => socket.add({
|
| + 'jsonrpc': '2.0',
|
| + 'id': request['id'],
|
| + 'result': {resultKey + end: resultValue + end}
|
| + });
|
| + }).toList();
|
| + // random order
|
| + completions.shuffle();
|
| + // answer out of order
|
| + completions.forEach((complete) => complete());
|
| +
|
| + final responses = await Future.wait(results);
|
| + responses.forEach((final response) {
|
| + final iteration = responses.indexOf(response);
|
| + final end = iteration.toString();
|
| +
|
| + expect(response, isNotNull);
|
| + expect(response[resultKey + end], equals(resultValue + end));
|
| + });
|
| + }
|
| +
|
| + // Testing parallel invocation of service which fails
|
| + {
|
| + final results = new List<Future<Map>>.generate(repetition, (iteration) {
|
| + final end = iteration.toString();
|
| + return vm.invokeRpcRaw(
|
| + vm.services[1].method, {paramKey + end: paramValue + end});
|
| + });
|
| + final requests = await (client.take(repetition).toList());
|
| +
|
| + final completions = requests.map((final request) {
|
| + final iteration = requests.indexOf(request);
|
| + final end = iteration.toString();
|
| +
|
| + // check requests while they arrive
|
| + expect(request, contains('id'));
|
| + expect(request['id'], isNotNull);
|
| + expect(request['method'], equals(errorServiceName));
|
| + expect(request['params'], isNotNull);
|
| + expect(request['params'][paramKey + end], equals(paramValue + end));
|
| +
|
| + // answer later
|
| + return () => socket.add({
|
| + 'jsonrpc': '2.0',
|
| + 'id': request['id'],
|
| + 'error': {
|
| + 'code': errorCode + iteration,
|
| + 'data': {errorKey + end: errorValue + end}
|
| + }
|
| + });
|
| + }).toList();
|
| + // random order
|
| + completions.shuffle();
|
| + // answer out of order
|
| + completions.forEach((complete) => complete());
|
| +
|
| + final errors = await Future.wait(results.map((future) {
|
| + return future.then((_) {
|
| + expect(false, isTrue, reason: 'shouldn\'t get here');
|
| + }).catchError((e) => e);
|
| + }));
|
| + errors.forEach((final ServerRpcException error) {
|
| + final iteration = errors.indexOf(error);
|
| + final end = iteration.toString();
|
| +
|
| + expect(error, isNotNull);
|
| + expect(error.code, equals(errorCode + iteration));
|
| + expect(error.data, isNotNull);
|
| + expect(error.data[errorKey + end], equals(errorValue + end));
|
| + });
|
| + }
|
| +
|
| + await socket.close();
|
| + },
|
| +];
|
| +
|
| +main(args) => runIsolateTests(args, tests);
|
|
|