| OLD | NEW |
| 1 // Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 // VMOptions=--error_on_bad_type --error_on_bad_override | 4 // VMOptions=--error_on_bad_type --error_on_bad_override |
| 5 | 5 |
| 6 import 'dart:async'; | 6 import 'dart:async'; |
| 7 import 'dart:convert'; | 7 import 'dart:convert'; |
| 8 import 'dart:developer'; | 8 import 'dart:developer'; |
| 9 import 'package:observatory/service_io.dart'; | 9 import 'package:observatory/service_io.dart'; |
| 10 import 'package:observatory/cpu_profile.dart'; | 10 import 'package:observatory/cpu_profile.dart'; |
| 11 import 'package:unittest/unittest.dart'; | 11 import 'package:unittest/unittest.dart'; |
| 12 | 12 |
| 13 import 'test_helper.dart'; | 13 import 'test_helper.dart'; |
| 14 | 14 |
| 15 Future<ServiceExtensionResponse> Handler(String method, | 15 Future<ServiceExtensionResponse> Handler(String method, |
| 16 Map paremeters) { | 16 Map paremeters) { |
| 17 print('Invoked extension: $method'); | 17 print('Invoked extension: $method'); |
| 18 switch (method) { | 18 switch (method) { |
| 19 case '__delay': | 19 case 'ext..delay': |
| 20 Completer c = new Completer(); | 20 Completer c = new Completer(); |
| 21 new Timer(new Duration(seconds: 1), () { | 21 new Timer(new Duration(seconds: 1), () { |
| 22 c.complete(new ServiceExtensionResponse.result(JSON.encode({ | 22 c.complete(new ServiceExtensionResponse.result(JSON.encode({ |
| 23 'type': '_delayedType', | 23 'type': '_delayedType', |
| 24 'method': method, | 24 'method': method, |
| 25 'parameters': paremeters, | 25 'parameters': paremeters, |
| 26 }))); | 26 }))); |
| 27 }); | 27 }); |
| 28 return c.future; | 28 return c.future; |
| 29 case '__error': | 29 case 'ext..error': |
| 30 return new Future.value( | 30 return new Future.value( |
| 31 new ServiceExtensionResponse.error( | 31 new ServiceExtensionResponse.error( |
| 32 ServiceExtensionResponse.kExtensionErrorMin, | 32 ServiceExtensionResponse.extensionErrorMin, |
| 33 'My error detail.')); | 33 'My error detail.')); |
| 34 case '__exception': | 34 case 'ext..exception': |
| 35 throw "I always throw!"; | 35 throw "I always throw!"; |
| 36 case '__success': | 36 case 'ext..success': |
| 37 return new Future.value( | 37 return new Future.value( |
| 38 new ServiceExtensionResponse.result(JSON.encode({ | 38 new ServiceExtensionResponse.result(JSON.encode({ |
| 39 'type': '_extensionType', | 39 'type': '_extensionType', |
| 40 'method': method, | 40 'method': method, |
| 41 'parameters': paremeters, | 41 'parameters': paremeters, |
| 42 }))); | 42 }))); |
| 43 case '__null': | 43 case 'ext..null': |
| 44 return null; | 44 return null; |
| 45 case '__nullFuture': | 45 case 'ext..nullFuture': |
| 46 return new Future.value(null); | 46 return new Future.value(null); |
| 47 } | 47 } |
| 48 } | 48 } |
| 49 | 49 |
| 50 Future<ServiceExtensionResponse> LanguageErrorHandler(String method, | 50 Future<ServiceExtensionResponse> LanguageErrorHandler(String method, |
| 51 Map paremeters) { | 51 Map paremeters) { |
| 52 // The following is an intentional syntax error. | 52 // The following is an intentional syntax error. |
| 53 klajsdlkjfad | 53 klajsdlkjfad |
| 54 } | 54 } |
| 55 | 55 |
| 56 void test() { | 56 void test() { |
| 57 registerExtension('__delay', Handler); | 57 registerExtension('ext..delay', Handler); |
| 58 debugger(); | 58 debugger(); |
| 59 postEvent('ALPHA', { | 59 postEvent('ALPHA', { |
| 60 'cat': 'dog' | 60 'cat': 'dog' |
| 61 }); | 61 }); |
| 62 debugger(); | 62 debugger(); |
| 63 registerExtension('__error', Handler); | 63 registerExtension('ext..error', Handler); |
| 64 registerExtension('__exception', Handler); | 64 registerExtension('ext..exception', Handler); |
| 65 registerExtension('__null', Handler); | 65 registerExtension('ext..null', Handler); |
| 66 registerExtension('__nullFuture', Handler); | 66 registerExtension('ext..nullFuture', Handler); |
| 67 registerExtension('__success', Handler); | 67 registerExtension('ext..success', Handler); |
| 68 bool exceptionThrown = false; | 68 bool exceptionThrown = false; |
| 69 try { | 69 try { |
| 70 registerExtension('__delay', Handler); | 70 registerExtension('ext..delay', Handler); |
| 71 } catch (e) { | 71 } catch (e) { |
| 72 exceptionThrown = true; | 72 exceptionThrown = true; |
| 73 } | 73 } |
| 74 expect(exceptionThrown, isTrue); | 74 expect(exceptionThrown, isTrue); |
| 75 registerExtension('__languageError', LanguageErrorHandler); | 75 registerExtension('ext..languageError', LanguageErrorHandler); |
| 76 } | 76 } |
| 77 | 77 |
| 78 var tests = [ | 78 var tests = [ |
| 79 hasStoppedAtBreakpoint, | 79 hasStoppedAtBreakpoint, |
| 80 (Isolate isolate) async { | 80 (Isolate isolate) async { |
| 81 await isolate.load(); | 81 await isolate.load(); |
| 82 expect(isolate.extensionRPCs.length, 1); | 82 expect(isolate.extensionRPCs.length, 1); |
| 83 expect(isolate.extensionRPCs[0], equals('__delay')); | 83 expect(isolate.extensionRPCs[0], equals('ext..delay')); |
| 84 }, | 84 }, |
| 85 resumeIsolateAndAwaitEvent(Isolate.kExtensionStream, (ServiceEvent event) { | 85 resumeIsolateAndAwaitEvent(Isolate.kExtensionStream, (ServiceEvent event) { |
| 86 expect(event.kind, equals(ServiceEvent.kExtension)); | 86 expect(event.kind, equals(ServiceEvent.kExtension)); |
| 87 expect(event.extensionKind, equals('ALPHA')); | 87 expect(event.extensionKind, equals('ALPHA')); |
| 88 expect(event.extensionData, new isInstanceOf<Map>()); | 88 expect(event.extensionData, new isInstanceOf<Map>()); |
| 89 expect(event.extensionData['cat'], equals('dog')); | 89 expect(event.extensionData['cat'], equals('dog')); |
| 90 }), | 90 }), |
| 91 hasStoppedAtBreakpoint, | 91 hasStoppedAtBreakpoint, |
| 92 resumeIsolateAndAwaitEvent(VM.kIsolateStream, (ServiceEvent event) { | 92 resumeIsolateAndAwaitEvent(VM.kIsolateStream, (ServiceEvent event) { |
| 93 // Check that we received an event when '__error' was registered. | 93 // Check that we received an event when '__error' was registered. |
| 94 expect(event.kind, equals(ServiceEvent.kServiceExtensionAdded)); | 94 expect(event.kind, equals(ServiceEvent.kServiceExtensionAdded)); |
| 95 expect(event.extensionRPC, equals('__error')); | 95 expect(event.extensionRPC, equals('ext..error')); |
| 96 }), | 96 }), |
| 97 // Initial. | 97 // Initial. |
| 98 (Isolate isolate) async { | 98 (Isolate isolate) async { |
| 99 var result; | 99 var result; |
| 100 | 100 |
| 101 result = await isolate.invokeRpcNoUpgrade('__delay', {}); | 101 result = await isolate.invokeRpcNoUpgrade('ext..delay', {}); |
| 102 expect(result['type'], equals('_delayedType')); | 102 expect(result['type'], equals('_delayedType')); |
| 103 expect(result['method'], equals('__delay')); | 103 expect(result['method'], equals('ext..delay')); |
| 104 expect(result['parameters']['isolateId'], isNotNull); | 104 expect(result['parameters']['isolateId'], isNotNull); |
| 105 | 105 |
| 106 try { | 106 try { |
| 107 await isolate.invokeRpcNoUpgrade('__error', {}); | 107 await isolate.invokeRpcNoUpgrade('ext..error', {}); |
| 108 } on ServerRpcException catch (e, st) { | 108 } on ServerRpcException catch (e, st) { |
| 109 expect(e.code, equals(ServiceExtensionResponse.kExtensionErrorMin)); | 109 expect(e.code, equals(ServiceExtensionResponse.extensionErrorMin)); |
| 110 expect(e.message, equals('My error detail.')); | 110 expect(e.message, equals('My error detail.')); |
| 111 } | 111 } |
| 112 | 112 |
| 113 try { | 113 try { |
| 114 await isolate.invokeRpcNoUpgrade('__exception', {}); | 114 await isolate.invokeRpcNoUpgrade('ext..exception', {}); |
| 115 } on ServerRpcException catch (e, st) { | 115 } on ServerRpcException catch (e, st) { |
| 116 expect(e.code, equals(ServiceExtensionResponse.kExtensionError)); | 116 expect(e.code, equals(ServiceExtensionResponse.extensionError)); |
| 117 expect(e.message.startsWith('I always throw!\n'), isTrue); | 117 expect(e.message.startsWith('I always throw!\n'), isTrue); |
| 118 } | 118 } |
| 119 | 119 |
| 120 try { | 120 try { |
| 121 await isolate.invokeRpcNoUpgrade('__null', {}); | 121 await isolate.invokeRpcNoUpgrade('ext..null', {}); |
| 122 } on ServerRpcException catch (e, st) { | 122 } on ServerRpcException catch (e, st) { |
| 123 expect(e.code, equals(ServiceExtensionResponse.kExtensionError)); | 123 expect(e.code, equals(ServiceExtensionResponse.extensionError)); |
| 124 expect(e.message, equals('Extension handler must return a Future')); | 124 expect(e.message, equals('Extension handler must return a Future')); |
| 125 } | 125 } |
| 126 | 126 |
| 127 try { | 127 try { |
| 128 await isolate.invokeRpcNoUpgrade('__nullFuture', {}); | 128 await isolate.invokeRpcNoUpgrade('ext..nullFuture', {}); |
| 129 } on ServerRpcException catch (e, st) { | 129 } on ServerRpcException catch (e, st) { |
| 130 expect(e.code, equals(ServiceExtensionResponse.kExtensionError)); | 130 expect(e.code, equals(ServiceExtensionResponse.extensionError)); |
| 131 expect(e.message, equals('Extension handler must complete to a ' | 131 expect(e.message, equals('Extension handler must complete to a ' |
| 132 'ServiceExtensionResponse')); | 132 'ServiceExtensionResponse')); |
| 133 } | 133 } |
| 134 | 134 |
| 135 result = await isolate.invokeRpcNoUpgrade('__success', | 135 result = await isolate.invokeRpcNoUpgrade('ext..success', |
| 136 {'apple': 'banana'}); | 136 {'apple': 'banana'}); |
| 137 expect(result['type'], equals('_extensionType')); | 137 expect(result['type'], equals('_extensionType')); |
| 138 expect(result['method'], equals('__success')); | 138 expect(result['method'], equals('ext..success')); |
| 139 expect(result['parameters']['isolateId'], isNotNull); | 139 expect(result['parameters']['isolateId'], isNotNull); |
| 140 expect(result['parameters']['apple'], equals('banana')); | 140 expect(result['parameters']['apple'], equals('banana')); |
| 141 | 141 |
| 142 | 142 |
| 143 try { | 143 try { |
| 144 result = await isolate.invokeRpcNoUpgrade('__languageError', {}); | 144 result = await isolate.invokeRpcNoUpgrade('ext..languageError', {}); |
| 145 } on ServerRpcException catch (e, st) { | 145 } on ServerRpcException catch (e, st) { |
| 146 expect(e.code, equals(ServiceExtensionResponse.kExtensionError)); | 146 expect(e.code, equals(ServiceExtensionResponse.extensionError)); |
| 147 expect(e.message, stringContainsInOrder([ | 147 expect(e.message, stringContainsInOrder([ |
| 148 'Error in extension `__languageError`:', | 148 'Error in extension `ext..languageError`:', |
| 149 'developer_extension_test.dart', | 149 'developer_extension_test.dart', |
| 150 'semicolon expected'])); | 150 'semicolon expected'])); |
| 151 } | 151 } |
| 152 | 152 |
| 153 }, | 153 }, |
| 154 ]; | 154 ]; |
| 155 | 155 |
| 156 main(args) async => runIsolateTests(args, tests, testeeConcurrent:test); | 156 main(args) async => runIsolateTests(args, tests, testeeConcurrent:test); |
| OLD | NEW |