Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(292)

Side by Side Diff: runtime/observatory/tests/service/developer_extension_test.dart

Issue 1680593004: dart:developer service extension fixes (Closed) Base URL: git@github.com:dart-lang/sdk.git@master
Patch Set: Created 4 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « runtime/bin/socket_patch.dart ('k') | runtime/observatory/tests/service/file_service_test.dart » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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);
OLDNEW
« no previous file with comments | « runtime/bin/socket_patch.dart ('k') | runtime/observatory/tests/service/file_service_test.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698