| // Copyright (c) 2013, 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. |
| |
| import 'dart:async'; |
| import 'dart:convert'; |
| import 'dart:math' as math; |
| import 'dart:typed_data'; |
| |
| import 'package:async/async.dart' hide StreamQueue; |
| import 'package:matcher/matcher.dart'; |
| import 'package:path/path.dart' as p; |
| import 'package:term_glyph/term_glyph.dart' as glyph; |
| |
| import 'backend/invoker.dart'; |
| import 'backend/operating_system.dart'; |
| import 'util/stream_queue.dart'; |
| |
| /// The maximum console line length. |
| const _lineLength = 100; |
| |
| /// A typedef for a possibly-asynchronous function. |
| /// |
| /// The return type should only ever by [Future] or void. |
| typedef AsyncFunction(); |
| |
| /// A typedef for a zero-argument callback function. |
| typedef void Callback(); |
| |
| /// A transformer that decodes bytes using UTF-8 and splits them on newlines. |
| final lineSplitter = new StreamTransformer<List<int>, String>( |
| (stream, cancelOnError) => stream |
| .transform(UTF8.decoder) |
| .transform(const LineSplitter()) |
| .listen(null, cancelOnError: cancelOnError)); |
| |
| /// A regular expression to match the exception prefix that some exceptions' |
| /// [Object.toString] values contain. |
| final _exceptionPrefix = new RegExp(r'^([A-Z][a-zA-Z]*)?(Exception|Error): '); |
| |
| /// A regular expression matching a single vowel. |
| final _vowel = new RegExp('[aeiou]'); |
| |
| /// Directories that are specific to OS X. |
| /// |
| /// This is used to try to distinguish OS X and Linux in [currentOSGuess]. |
| final _macOSDirectories = new Set<String>.from( |
| ["/Applications", "/Library", "/Network", "/System", "/Users"]); |
| |
| /// Returns the best guess for the current operating system without using |
| /// `dart:io`. |
| /// |
| /// This is useful for running test files directly and skipping tests as |
| /// appropriate. The only OS-specific information we have is the current path, |
| /// which we try to use to figure out the OS. |
| final OperatingSystem currentOSGuess = (() { |
| if (p.style == p.Style.url) return OperatingSystem.none; |
| if (p.style == p.Style.windows) return OperatingSystem.windows; |
| if (_macOSDirectories.any(p.current.startsWith)) return OperatingSystem.macOS; |
| return OperatingSystem.linux; |
| })(); |
| |
| /// A regular expression matching a hyphenated identifier. |
| /// |
| /// This is like a standard Dart identifier, except that it can also contain |
| /// hyphens. |
| final hyphenatedIdentifier = new RegExp(r"[a-zA-Z_-][a-zA-Z0-9_-]*"); |
| |
| /// Like [hyphenatedIdentifier], but anchored so that it must match the entire |
| /// string. |
| final anchoredHyphenatedIdentifier = |
| new RegExp("^${hyphenatedIdentifier.pattern}\$"); |
| |
| /// A pair of values. |
| class Pair<E, F> { |
| E first; |
| F last; |
| |
| Pair(this.first, this.last); |
| |
| String toString() => '($first, $last)'; |
| |
| bool operator ==(other) { |
| if (other is! Pair) return false; |
| return other.first == first && other.last == last; |
| } |
| |
| int get hashCode => first.hashCode ^ last.hashCode; |
| } |
| |
| /// Get a string description of an exception. |
| /// |
| /// Many exceptions include the exception class name at the beginning of their |
| /// [toString], so we remove that if it exists. |
| String getErrorMessage(error) => |
| error.toString().replaceFirst(_exceptionPrefix, ''); |
| |
| /// Indent each line in [string] by [size] spaces. |
| /// |
| /// If [first] is passed, it's used in place of the first line's indentation and |
| /// [size] defaults to `first.length`. Otherwise, [size] defaults to 2. |
| String indent(String string, {int size, String first}) { |
| size ??= first == null ? 2 : first.length; |
| return prefixLines(string, " " * size, first: first); |
| } |
| |
| /// Returns a sentence fragment listing the elements of [iter]. |
| /// |
| /// This converts each element of [iter] to a string and separates them with |
| /// commas and/or [conjunction] where appropriate. The [conjunction] defaults to |
| /// "and". |
| String toSentence(Iterable iter, {String conjunction}) { |
| if (iter.length == 1) return iter.first.toString(); |
| |
| var result = iter.take(iter.length - 1).join(", "); |
| if (iter.length > 2) result += ","; |
| return "$result ${conjunction ?? 'and'} ${iter.last}"; |
| } |
| |
| /// Returns [name] if [number] is 1, or the plural of [name] otherwise. |
| /// |
| /// By default, this just adds "s" to the end of [name] to get the plural. If |
| /// [plural] is passed, that's used instead. |
| String pluralize(String name, int number, {String plural}) { |
| if (number == 1) return name; |
| if (plural != null) return plural; |
| return '${name}s'; |
| } |
| |
| /// Returns [noun] with an indefinite article ("a" or "an") added, based on |
| /// whether its first letter is a vowel. |
| String a(String noun) => noun.startsWith(_vowel) ? "an $noun" : "a $noun"; |
| |
| /// Wraps [text] so that it fits within [lineLength], which defaults to 100 |
| /// characters. |
| /// |
| /// This preserves existing newlines and doesn't consider terminal color escapes |
| /// part of a word's length. |
| String wordWrap(String text, {int lineLength}) { |
| if (lineLength == null) lineLength = _lineLength; |
| return text.split("\n").map((originalLine) { |
| var buffer = new StringBuffer(); |
| var lengthSoFar = 0; |
| for (var word in originalLine.split(" ")) { |
| var wordLength = withoutColors(word).length; |
| if (wordLength > lineLength) { |
| if (lengthSoFar != 0) buffer.writeln(); |
| buffer.writeln(word); |
| } else if (lengthSoFar == 0) { |
| buffer.write(word); |
| lengthSoFar = wordLength; |
| } else if (lengthSoFar + 1 + wordLength > lineLength) { |
| buffer.writeln(); |
| buffer.write(word); |
| lengthSoFar = wordLength; |
| } else { |
| buffer.write(" $word"); |
| lengthSoFar += 1 + wordLength; |
| } |
| } |
| return buffer.toString(); |
| }).join("\n"); |
| } |
| |
| /// A regular expression matching terminal color codes. |
| final _colorCode = new RegExp('\u001b\\[[0-9;]+m'); |
| |
| /// Returns [str] without any color codes. |
| String withoutColors(String str) => str.replaceAll(_colorCode, ''); |
| |
| /// Flattens nested [Iterable]s inside an [Iterable] into a single [List] |
| /// containing only non-[Iterable] elements. |
| List flatten(Iterable nested) { |
| var result = []; |
| helper(iter) { |
| for (var element in iter) { |
| if (element is Iterable) { |
| helper(element); |
| } else { |
| result.add(element); |
| } |
| } |
| } |
| |
| helper(nested); |
| return result; |
| } |
| |
| /// Truncates [text] to fit within [maxLength]. |
| /// |
| /// This will try to truncate along word boundaries and preserve words both at |
| /// the beginning and the end of [text]. |
| String truncate(String text, int maxLength) { |
| // Return the full message if it fits. |
| if (text.length <= maxLength) return text; |
| |
| // If we can fit the first and last three words, do so. |
| var words = text.split(' '); |
| if (words.length > 1) { |
| var i = words.length; |
| var length = words.first.length + 4; |
| do { |
| i--; |
| length += 1 + words[i].length; |
| } while (length <= maxLength && i > 0); |
| if (length > maxLength || i == 0) i++; |
| if (i < words.length - 4) { |
| // Require at least 3 words at the end. |
| var buffer = new StringBuffer(); |
| buffer.write(words.first); |
| buffer.write(' ...'); |
| for (; i < words.length; i++) { |
| buffer.write(' '); |
| buffer.write(words[i]); |
| } |
| return buffer.toString(); |
| } |
| } |
| |
| // Otherwise truncate to return the trailing text, but attempt to start at |
| // the beginning of a word. |
| var result = text.substring(text.length - maxLength + 4); |
| var firstSpace = result.indexOf(' '); |
| if (firstSpace > 0) { |
| result = result.substring(firstSpace); |
| } |
| return '...$result'; |
| } |
| |
| /// Returns a human-friendly representation of [duration]. |
| String niceDuration(Duration duration) { |
| var minutes = duration.inMinutes; |
| var seconds = duration.inSeconds % 60; |
| var decaseconds = (duration.inMilliseconds % 1000) ~/ 100; |
| |
| var buffer = new StringBuffer(); |
| if (minutes != 0) buffer.write("$minutes minutes"); |
| |
| if (minutes == 0 || seconds != 0) { |
| if (minutes != 0) buffer.write(", "); |
| buffer.write(seconds); |
| if (decaseconds != 0) buffer.write(".$decaseconds"); |
| buffer.write(" seconds"); |
| } |
| |
| return buffer.toString(); |
| } |
| |
| /// Returns the first value [stream] emits, or `null` if [stream] closes before |
| /// emitting a value. |
| Future maybeFirst(Stream stream) { |
| var completer = new Completer(); |
| |
| var subscription; |
| subscription = stream.listen((data) { |
| completer.complete(data); |
| subscription.cancel(); |
| }, onError: (error, stackTrace) { |
| completer.completeError(error, stackTrace); |
| subscription.cancel(); |
| }, onDone: () { |
| completer.complete(); |
| }); |
| |
| return completer.future; |
| } |
| |
| /// Returns a [CancelableOperation] that returns the next value of [queue] |
| /// unless it's canceled. |
| /// |
| /// If the operation is canceled, [queue] is not moved forward at all. Note that |
| /// it's not safe to call further methods on [queue] until this operation has |
| /// either completed or been canceled. |
| CancelableOperation cancelableNext(StreamQueue queue) { |
| var fork = queue.fork(); |
| var canceled = false; |
| var completer = new CancelableCompleter(onCancel: () { |
| canceled = true; |
| return fork.cancel(immediate: true); |
| }); |
| |
| completer.complete(fork.next.then((_) { |
| fork.cancel(); |
| return canceled ? null : queue.next; |
| })); |
| |
| return completer.operation; |
| } |
| |
| /// Returns a single-subscription stream that emits the results of [operations] |
| /// in the order they complete. |
| /// |
| /// If the subscription is canceled, any pending operations are canceled as |
| /// well. |
| Stream/*<T>*/ inCompletionOrder/*<T>*/( |
| Iterable<CancelableOperation/*<T>*/ > operations) { |
| var operationSet = operations.toSet(); |
| var controller = new StreamController/*<T>*/( |
| sync: true, |
| onCancel: () { |
| return Future.wait(operationSet.map((operation) => operation.cancel())); |
| }); |
| |
| for (var operation in operationSet) { |
| operation.value |
| .then((value) => controller.add(value)) |
| .catchError(controller.addError) |
| .whenComplete(() { |
| operationSet.remove(operation); |
| if (operationSet.isEmpty) controller.close(); |
| }); |
| } |
| |
| return controller.stream; |
| } |
| |
| /// Returns a stream that emits [error] and [stackTrace], then closes. |
| /// |
| /// This is useful for adding errors to streams defined via `async*`. |
| Stream errorStream(error, StackTrace stackTrace) { |
| var controller = new StreamController(); |
| controller.addError(error, stackTrace); |
| controller.close(); |
| return controller.stream; |
| } |
| |
| /// Runs [fn] and discards its return value. |
| /// |
| /// This is useful for making a block of code async without forcing the |
| /// containing method to return a future. |
| void invoke(fn()) { |
| fn(); |
| } |
| |
| /// Runs [body] with special error-handling behavior. |
| /// |
| /// Errors emitted [body] will still cause the current test to fail, but they |
| /// won't cause it to *stop*. In particular, they won't remove any outstanding |
| /// callbacks registered outside of [body]. |
| /// |
| /// This may only be called within a test. |
| Future errorsDontStopTest(body()) { |
| var completer = new Completer(); |
| |
| Invoker.current.addOutstandingCallback(); |
| Invoker.current.waitForOutstandingCallbacks(() { |
| new Future.sync(body).whenComplete(completer.complete); |
| }).then((_) => Invoker.current.removeOutstandingCallback()); |
| |
| return completer.future; |
| } |
| |
| /// Returns a random base64 string containing [bytes] bytes of data. |
| /// |
| /// [seed] is passed to [math.Random]. |
| String randomBase64(int bytes, {int seed}) { |
| var random = new math.Random(seed); |
| var data = new Uint8List(bytes); |
| for (var i = 0; i < bytes; i++) { |
| data[i] = random.nextInt(256); |
| } |
| return BASE64.encode(data); |
| } |
| |
| /// Throws an [ArgumentError] if [message] isn't recursively JSON-safe. |
| void ensureJsonEncodable(Object message) { |
| if (message == null || |
| message is String || |
| message is num || |
| message is bool) { |
| // JSON-encodable, hooray! |
| } else if (message is List) { |
| for (var element in message) { |
| ensureJsonEncodable(element); |
| } |
| } else if (message is Map) { |
| message.forEach((key, value) { |
| if (key is! String) { |
| throw new ArgumentError("$message can't be JSON-encoded."); |
| } |
| |
| ensureJsonEncodable(value); |
| }); |
| } else { |
| throw new ArgumentError.value("$message can't be JSON-encoded."); |
| } |
| } |
| |
| /// Prepends a vertical bar to [text]. |
| String addBar(String text) => prefixLines(text, "${glyph.verticalLine} ", |
| first: "${glyph.downEnd} ", last: "${glyph.upEnd} ", single: "| "); |
| |
| /// Indents [text], and adds a bullet at the beginning. |
| String addBullet(String text) => |
| prefixLines(text, " ", first: "${glyph.bullet} "); |
| |
| /// Converts [strings] to a bulleted list. |
| String bullet(Iterable<String> strings) => strings.map(addBullet).join("\n"); |
| |
| /// Prepends each line in [text] with [prefix]. |
| /// |
| /// If [first] or [last] is passed, the first and last lines, respectively, are |
| /// prefixed with those instead. If [single] is passed, it's used if there's |
| /// only a single line; otherwise, [first], [last], or [prefix] is used, in that |
| /// order of precedence. |
| String prefixLines(String text, String prefix, |
| {String first, String last, String single}) { |
| first ??= prefix; |
| last ??= prefix; |
| single ??= first ?? last ?? prefix; |
| |
| var lines = text.split('\n'); |
| if (lines.length == 1) return "$single$text"; |
| |
| var buffer = new StringBuffer("$first${lines.first}\n"); |
| |
| // Write out all but the first and last lines with [prefix]. |
| for (var line in lines.skip(1).take(lines.length - 2)) { |
| buffer.writeln("$prefix$line"); |
| } |
| buffer.write("$last${lines.last}"); |
| return buffer.toString(); |
| } |
| |
| /// Returns a pretty-printed representation of [value]. |
| /// |
| /// The matcher package doesn't expose its pretty-print function directly, but |
| /// we can use it through StringDescription. |
| String prettyPrint(value) => |
| new StringDescription().addDescriptionOf(value).toString(); |