Chromium Code Reviews| 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 | 4 |
| 5 import 'dart:async'; | 5 import 'dart:async'; |
| 6 import 'dart:convert'; | 6 import 'dart:convert'; |
| 7 | 7 |
| 8 import '../../backend/group.dart'; | 8 import '../../backend/group.dart'; |
| 9 import '../../backend/group_entry.dart'; | |
| 9 import '../../backend/live_test.dart'; | 10 import '../../backend/live_test.dart'; |
| 10 import '../../backend/metadata.dart'; | 11 import '../../backend/metadata.dart'; |
| 11 import '../../backend/suite.dart'; | 12 import '../../backend/suite.dart'; |
| 12 import '../../frontend/expect.dart'; | 13 import '../../frontend/expect.dart'; |
| 13 import '../../utils.dart'; | 14 import '../../utils.dart'; |
| 14 import '../engine.dart'; | 15 import '../engine.dart'; |
| 15 import '../load_suite.dart'; | 16 import '../load_suite.dart'; |
| 16 import '../reporter.dart'; | 17 import '../reporter.dart'; |
| 17 import '../version.dart'; | 18 import '../version.dart'; |
| 18 | 19 |
| 19 /// A reporter that prints machine-readable JSON-formatted test results. | 20 /// A reporter that prints machine-readable JSON-formatted test results. |
| 20 class JsonReporter implements Reporter { | 21 class JsonReporter implements Reporter { |
| 21 /// Whether to use verbose stack traces. | 22 /// Whether to use verbose stack traces. |
| 22 final bool _verboseTrace; | 23 final bool _verboseTrace; |
| 23 | 24 |
| 25 /// Whether to emit location information for JS tests. | |
| 26 final bool _jsLocations; | |
| 27 | |
| 24 /// The engine used to run the tests. | 28 /// The engine used to run the tests. |
| 25 final Engine _engine; | 29 final Engine _engine; |
| 26 | 30 |
| 27 /// A stopwatch that tracks the duration of the full run. | 31 /// A stopwatch that tracks the duration of the full run. |
| 28 final _stopwatch = new Stopwatch(); | 32 final _stopwatch = new Stopwatch(); |
| 29 | 33 |
| 30 /// Whether we've started [_stopwatch]. | 34 /// Whether we've started [_stopwatch]. |
| 31 /// | 35 /// |
| 32 /// We can't just use `_stopwatch.isRunning` because the stopwatch is stopped | 36 /// We can't just use `_stopwatch.isRunning` because the stopwatch is stopped |
| 33 /// when the reporter is paused. | 37 /// when the reporter is paused. |
| (...skipping 12 matching lines...) Expand all Loading... | |
| 46 final _suiteIDs = new Map<Suite, int>(); | 50 final _suiteIDs = new Map<Suite, int>(); |
| 47 | 51 |
| 48 /// An expando that associates unique IDs with [Group]s. | 52 /// An expando that associates unique IDs with [Group]s. |
| 49 final _groupIDs = new Map<Group, int>(); | 53 final _groupIDs = new Map<Group, int>(); |
| 50 | 54 |
| 51 /// The next ID to associate with a [LiveTest]. | 55 /// The next ID to associate with a [LiveTest]. |
| 52 var _nextID = 0; | 56 var _nextID = 0; |
| 53 | 57 |
| 54 /// Watches the tests run by [engine] and prints their results as JSON. | 58 /// Watches the tests run by [engine] and prints their results as JSON. |
| 55 /// | 59 /// |
| 56 /// If [verboseTrace] is `true`, this will print core library frames. | 60 /// If [verboseTrace] is `true`, this will print core library frames. If |
| 57 static JsonReporter watch(Engine engine, {bool verboseTrace: false}) { | 61 /// [jsLocations] is `false`, this will not emit location information for JS |
| 58 return new JsonReporter._(engine, verboseTrace: verboseTrace); | 62 /// tests. |
| 63 static JsonReporter watch(Engine engine, {bool verboseTrace: false, | |
| 64 bool jsLocations: true}) { | |
| 65 return new JsonReporter._(engine, | |
| 66 verboseTrace: verboseTrace, jsLocations: jsLocations); | |
| 59 } | 67 } |
| 60 | 68 |
| 61 JsonReporter._(this._engine, {bool verboseTrace: false}) | 69 JsonReporter._(this._engine, {bool verboseTrace: false, |
| 62 : _verboseTrace = verboseTrace { | 70 bool jsLocations: true}) |
| 71 : _verboseTrace = verboseTrace, | |
| 72 _jsLocations = jsLocations { | |
| 63 _subscriptions.add(_engine.onTestStarted.listen(_onTestStarted)); | 73 _subscriptions.add(_engine.onTestStarted.listen(_onTestStarted)); |
| 64 | 74 |
| 65 /// Convert the future to a stream so that the subscription can be paused or | 75 /// Convert the future to a stream so that the subscription can be paused or |
| 66 /// canceled. | 76 /// canceled. |
| 67 _subscriptions.add(_engine.success.asStream().listen(_onDone)); | 77 _subscriptions.add(_engine.success.asStream().listen(_onDone)); |
| 68 | 78 |
| 69 _subscriptions.add(_engine.onSuiteAdded.listen(null, onDone: () { | 79 _subscriptions.add(_engine.onSuiteAdded.listen(null, onDone: () { |
| 70 _emit("allSuites", { | 80 _emit("allSuites", { |
| 71 "count": _engine.addedSuites.length | 81 "count": _engine.addedSuites.length |
| 72 }); | 82 }); |
| (...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 113 _stopwatchStarted = true; | 123 _stopwatchStarted = true; |
| 114 _stopwatch.start(); | 124 _stopwatch.start(); |
| 115 } | 125 } |
| 116 | 126 |
| 117 var suiteID = _idForSuite(liveTest.suite); | 127 var suiteID = _idForSuite(liveTest.suite); |
| 118 | 128 |
| 119 // Don't emit groups for load suites. They're always empty and they provide | 129 // Don't emit groups for load suites. They're always empty and they provide |
| 120 // unnecessary clutter. | 130 // unnecessary clutter. |
| 121 var groupIDs = liveTest.suite is LoadSuite | 131 var groupIDs = liveTest.suite is LoadSuite |
| 122 ? [] | 132 ? [] |
| 123 : _idsForGroups(liveTest.groups, suiteID); | 133 : _idsForGroups(liveTest.groups, liveTest.suite); |
| 124 | 134 |
| 125 var id = _nextID++; | 135 var id = _nextID++; |
| 126 _liveTestIDs[liveTest] = id; | 136 _liveTestIDs[liveTest] = id; |
| 127 _emit("testStart", { | 137 _emit("testStart", { |
| 128 "test": { | 138 "test": _addFrameInfo({ |
| 129 "id": id, | 139 "id": id, |
| 130 "name": liveTest.test.name, | 140 "name": liveTest.test.name, |
| 131 "suiteID": suiteID, | 141 "suiteID": suiteID, |
| 132 "groupIDs": groupIDs, | 142 "groupIDs": groupIDs, |
| 133 "metadata": _serializeMetadata(liveTest.test.metadata) | 143 "metadata": _serializeMetadata(liveTest.test.metadata) |
| 134 } | 144 }, liveTest.test, liveTest.suite.platform) |
| 135 }); | 145 }); |
| 136 | 146 |
| 137 /// Convert the future to a stream so that the subscription can be paused or | 147 /// Convert the future to a stream so that the subscription can be paused or |
| 138 /// canceled. | 148 /// canceled. |
| 139 _subscriptions.add(liveTest.onComplete.asStream().listen((_) => | 149 _subscriptions.add(liveTest.onComplete.asStream().listen((_) => |
| 140 _onComplete(liveTest))); | 150 _onComplete(liveTest))); |
| 141 | 151 |
| 142 _subscriptions.add(liveTest.onError.listen((error) => | 152 _subscriptions.add(liveTest.onError.listen((error) => |
| 143 _onError(liveTest, error.error, error.stackTrace))); | 153 _onError(liveTest, error.error, error.stackTrace))); |
| 144 | 154 |
| (...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 176 } | 186 } |
| 177 }); | 187 }); |
| 178 return id; | 188 return id; |
| 179 } | 189 } |
| 180 | 190 |
| 181 /// Returns a list of the IDs for all the groups in [groups], which are | 191 /// Returns a list of the IDs for all the groups in [groups], which are |
| 182 /// contained in the suite identified by [suiteID]. | 192 /// contained in the suite identified by [suiteID]. |
| 183 /// | 193 /// |
| 184 /// If a group doesn't have an ID yet, this assigns one and emits a new event | 194 /// If a group doesn't have an ID yet, this assigns one and emits a new event |
| 185 /// for that group. | 195 /// for that group. |
| 186 List<int> _idsForGroups(Iterable<Group> groups, int suiteID) { | 196 List<int> _idsForGroups(Iterable<Group> groups, Suite suite) { |
| 187 int parentID; | 197 int parentID; |
| 188 return groups.map((group) { | 198 return groups.map((group) { |
| 189 if (_groupIDs.containsKey(group)) { | 199 if (_groupIDs.containsKey(group)) { |
| 190 parentID = _groupIDs[group]; | 200 parentID = _groupIDs[group]; |
| 191 return parentID; | 201 return parentID; |
| 192 } | 202 } |
| 193 | 203 |
| 194 var id = _nextID++; | 204 var id = _nextID++; |
| 195 _groupIDs[group] = id; | 205 _groupIDs[group] = id; |
| 196 | 206 |
| 197 _emit("group", { | 207 _emit("group", { |
| 198 "group": { | 208 "group": _addFrameInfo({ |
| 199 "id": id, | 209 "id": id, |
| 200 "suiteID": suiteID, | 210 "suiteID": _idForSuite(suite), |
| 201 "parentID": parentID, | 211 "parentID": parentID, |
| 202 "name": group.name, | 212 "name": group.name, |
| 203 "metadata": _serializeMetadata(group.metadata), | 213 "metadata": _serializeMetadata(group.metadata), |
| 204 "testCount": group.testCount | 214 "testCount": group.testCount |
| 205 } | 215 }, group, suite.platform) |
| 206 }); | 216 }); |
| 207 parentID = id; | 217 parentID = id; |
| 208 return id; | 218 return id; |
| 209 }).toList(); | 219 }).toList(); |
| 210 } | 220 } |
| 211 | 221 |
| 212 /// Serializes [metadata] into a JSON-protocol-compatible map. | 222 /// Serializes [metadata] into a JSON-protocol-compatible map. |
| 213 Map _serializeMetadata(Metadata metadata) => | 223 Map _serializeMetadata(Metadata metadata) => |
| 214 {"skip": metadata.skip, "skipReason": metadata.skipReason}; | 224 {"skip": metadata.skip, "skipReason": metadata.skipReason}; |
| 215 | 225 |
| (...skipping 26 matching lines...) Expand all Loading... | |
| 242 | 252 |
| 243 _emit("done", {"success": success}); | 253 _emit("done", {"success": success}); |
| 244 } | 254 } |
| 245 | 255 |
| 246 /// Emits an event with the given type and attributes. | 256 /// Emits an event with the given type and attributes. |
| 247 void _emit(String type, Map attributes) { | 257 void _emit(String type, Map attributes) { |
| 248 attributes["type"] = type; | 258 attributes["type"] = type; |
| 249 attributes["time"] = _stopwatch.elapsed.inMilliseconds; | 259 attributes["time"] = _stopwatch.elapsed.inMilliseconds; |
| 250 print(JSON.encode(attributes)); | 260 print(JSON.encode(attributes)); |
| 251 } | 261 } |
| 262 | |
| 263 /// Modifies [map] to include line, column, and URL information from the first | |
| 264 /// frame of [entry.trace]. | |
| 265 /// | |
| 266 /// Returns [map]. | |
| 267 Map<String, dynamic> _addFrameInfo(Map<String, dynamic> map, | |
| 268 GroupEntry entry, TestPlatform platform) { | |
|
kevmoo
2016/06/15 19:50:38
no import for `TestPlatform` class
nweiz
2016/06/15 20:35:39
Done.
| |
| 269 var frame = entry.trace?.frames?.first; | |
| 270 if (!_jsLocations && platform.isJS) frame = null; | |
| 271 | |
| 272 map["line"] = frame?.line; | |
| 273 map["column"] = frame?.column; | |
| 274 map["url"] = frame?.uri?.toString(); | |
| 275 return map; | |
| 276 } | |
| 252 } | 277 } |
| OLD | NEW |