Add BuildBotClient to abstract http/logdog access

tools/gardening/lib/src/logdog.dart

 // 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:io';
 import 'dart:async';
 import 'dart:collection';
+import 'dart:convert';
+
+import 'util.dart';
 
 final String cit = Platform.isWindows ? 'cit.bat' : 'cit';
 
+enum LogdogExitKind {
+  /// Normal program termination with a negative exit code.
+  normal,
+
+  /// Program killed due to error output.
+  error,
+
+  /// Program killed due to timeout.
+  timeout,
+}
+
 class LogdogException implements Exception {
+  final List<String> command;
   final int errorCode;
   final String stdout;
   final String stderr;
+  final LogdogExitKind exitKind;
 
-  LogdogException(this.errorCode, this.stdout, this.stderr);
+  LogdogException(
+      this.command, this.errorCode, this.stdout, this.stderr, this.exitKind);
   LogdogException.fromProcessResult(ProcessResult result)
-      : this(result.exitCode, result.stdout, result.stderr);
+      : this(null, result.exitCode, result.stdout, result.stderr,
+            LogdogExitKind.normal);
 
-  toString() => "Error during logdog execution:\n$stderr";
+  toString() => "Error during logdog execution"
+      "${command != null ? ' `${command.join(' ')}`': ''}"
+      ":\n$stderr";
 }
 
 bool logdogCheckDone = false;
 
 void checkLogdog({bool tryToInstall: true}) {
   if (logdogCheckDone) return;
   var result = Process.runSync(cit, []);
   if (result.exitCode != 0) {
     print("cit (from depot_tools) must be in the path.");
     throw new StateError("cit not accessible");
   }
   String stdout = result.stdout;
   if (stdout.contains("logdog")) {
     logdogCheckDone = true;
     return;
   }
   if (tryToInstall) {
     print("logdog isn't yet installed. Installation might take some time");
     result = Process.runSync(cit, ["logdog"]);
     checkLogdog(tryToInstall: false);
   } else {
     print("Couldn't install logdog");
     throw new StateError("logdog not accessible");
   }
 }
 
-String logdog(List<String> args) {
+Future<String> logdog(List<String> args,
+    {bool exitOnError: true,
+    Duration timeout: const Duration(seconds: 10)}) async {
   checkLogdog();
   args = args.toList()..insert(0, "logdog");
-  var result = Process.runSync(cit, args);
-  if (result.exitCode == 0) return result.stdout;
-  throw new LogdogException.fromProcessResult(result);
+
+  LogdogExitKind exitKind = LogdogExitKind.normal;
+  Process process = await Process.start(cit, args);
+  StringBuffer stdout = new StringBuffer();
+  StringBuffer stderr = new StringBuffer();
+  StreamSubscription stdoutSubscription =
+      process.stdout.transform(UTF8.decoder).listen(stdout.write);
+  StreamSubscription stderrSubscription =
+      process.stderr.transform(UTF8.decoder).listen((String text) {
+    stderr.write(text);
+    if (exitOnError) {
+      exitKind = LogdogExitKind.error;
+      log('Error on `${args.join(' ')}`: $text');
+      process.kill();
+    }
+  });
+  Timer timer;
+  if (timeout != null) {
+    timer = new Timer(timeout, () {
+      exitKind = LogdogExitKind.timeout;
+      log('Timeout on `${args.join(' ')}`');
+      process.kill();
+    });
+  }
+  int exitCode = await process.exitCode;
+  // Cancel the timer; it might still be running.
+  timer?.cancel();
+  // Cancel the stdout/stderr subscriptions; if the process is killed the
+  // streams might not have closed.
+  stdoutSubscription.cancel();
+  stderrSubscription.cancel();
+  if (exitCode == 0) return stdout.toString();
+  throw new LogdogException(
+      args, exitCode, stdout.toString(), stderr.toString(), exitKind);
 }
 
-String cat(String log) {
+Future<String> cat(String log) async {
   return logdog(["cat", "-raw", log]);
 }
 
 /// Returns the content for [path], for instance the available build numbers
 /// for 'dart2js-linux-chromeff-1-4-be' using the path
 /// `chromium/bb/client.dart/dart2js-linux-chromeff-1-4-be`.
-String ls(String path) {
+Future<String> ls(String path) async {
   return logdog(["ls", path]);
 }
 
 class LogResult<T> {
   final String log;
   final T result;
 
   LogResult(this.log, this.result);
 }
 
@@ skipping 54 matching lines @@
   })).listen((logResult) {
     print("--------------------------");
     if (logResult.result == null) {
       print("${logResult.log} - empty");
     } else {
       print(logResult.result.substring(0, 200));
     }
   });
 }
 */