blob: 751a478549abf9a64e6ed60f3715947002897d2a [file] [log] [blame]
// 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.
import 'dart:async';
import 'dart:convert';
import 'dart:io';
import 'package:args/args.dart';
import 'cache.dart';
import 'cache_new.dart';
import 'logger.dart';
/// Checks that [haystack] contains substring [needle], case insensitive.
/// Throws an exception if either parameter is `null`.
bool containsIgnoreCase(String haystack, String needle) {
if (haystack == null) {
throw "Unexpected null as the first paramter value of containsIgnoreCase";
}
if (needle == null) {
throw "Unexpected null as the second parameter value of containsIgnoreCase";
}
return haystack.toLowerCase().contains(needle.toLowerCase());
}
/// Split [text] using [infixes] as infix markers.
List<String> split(String text, List<String> infixes) {
List<String> result = <String>[];
int start = 0;
for (String infix in infixes) {
int index = text.indexOf(infix, start);
if (index == -1)
throw "'$infix' not found in '$text' from offset ${start}.";
result.add(text.substring(start, index));
start = index + infix.length;
}
result.add(text.substring(start));
return result;
}
/// Pad [text] with spaces to the right to fit [length].
String padRight(String text, int length) {
if (text.length < length) return '${text}${' ' * (length - text.length)}';
return text;
}
/// Pad [text] with spaces to the left to fit [length].
String padLeft(String text, int length) {
if (text.length < length) return '${' ' * (length - text.length)}${text}';
return text;
}
bool LOG = const bool.fromEnvironment('LOG', defaultValue: false);
void log(Object text) {
if (LOG) print(text);
}
Logger createLogger({bool verbose: false}) {
return new StdOutLogger(verbose ? Level.debug : Level.info);
}
CreateCacheFunction createCacheFunction(Logger logger,
{bool disableCache: false}) {
return disableCache
? noCache()
: initCache(Uri.base.resolve('temp/gardening-cache/'), logger);
}
class HttpException implements Exception {
final Uri uri;
final int statusCode;
HttpException(this.uri, this.statusCode);
String toString() => '$uri: $statusCode';
}
/// Reads the content of [uri] as text.
Future<String> readUriAsText(
HttpClient client, Uri uri, Duration timeout) async {
HttpClientRequest request = await client.getUrl(uri);
HttpClientResponse response = await request.close();
if (response.statusCode != 200) {
response.drain();
throw new HttpException(uri, response.statusCode);
}
if (timeout != null) {
return response.timeout(timeout).transform(UTF8.decoder).join();
} else {
return response.transform(UTF8.decoder).join();
}
}
class Flags {
static const String cache = 'cache';
static const String commit = 'commit';
static const String help = 'help';
static const String logdog = 'logdog';
static const String noCache = 'no-cache';
static const String verbose = 'verbose';
}
ArgParser createArgParser() {
ArgParser argParser = new ArgParser(allowTrailingOptions: true);
argParser.addFlag(Flags.help, help: "Help");
argParser.addFlag(Flags.verbose,
abbr: 'v', negatable: false, help: "Turn on logging output.");
argParser.addFlag(Flags.noCache, help: "Disable caching.");
argParser.addOption(Flags.cache,
help: "Use <dir> for caching test output.\n"
"Defaults to 'temp/gardening-cache/'.");
argParser.addFlag(Flags.logdog,
negatable: false, help: "Pull test results from logdog.");
return argParser;
}
void processArgResults(ArgResults argResults) {
if (argResults[Flags.verbose]) {
LOG = true;
}
if (argResults[Flags.cache] != null) {
cache.base = Uri.base.resolve('${argResults[Flags.cache]}/');
}
if (argResults[Flags.noCache]) {
cache.base = null;
}
}
/// Strips un-wanted characters from string [category] from CBE json.
String sanitizeCategory(String category) {
var reg = new RegExp(r"^[0-9]+(.*)\|all$");
var match = reg.firstMatch(category);
return match != null ? match.group(1) : category;
}
exceptionPrint(String message) {
return (dynamic ex, StackTrace st) {
if (message != null) {
print(message);
}
print(ex);
if (st != null) {
print(st);
}
};
}