Revert "Revert "Use native async/await support in pub.""

sdk/lib/_internal/pub_generated/lib/src/executable.dart

Index: sdk/lib/_internal/pub_generated/lib/src/executable.dart
diff --git a/sdk/lib/_internal/pub_generated/lib/src/executable.dart b/sdk/lib/_internal/pub_generated/lib/src/executable.dart
deleted file mode 100644
index 4df8afabe757b0e8cf398662d679f0c3faecefb6..0000000000000000000000000000000000000000
--- a/sdk/lib/_internal/pub_generated/lib/src/executable.dart
+++ /dev/null
@@ -1,320 +0,0 @@
-// Copyright (c) 2014, 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.
-
-library pub.executable;
-
-import 'dart:async';
-import 'dart:io';
-
-import 'package:barback/barback.dart';
-import 'package:path/path.dart' as p;
-import 'package:stack_trace/stack_trace.dart';
-
-import 'barback/asset_environment.dart';
-import 'entrypoint.dart';
-import 'exit_codes.dart' as exit_codes;
-import 'io.dart';
-import 'log.dart' as log;
-import 'utils.dart';
-
-/// Runs [executable] from [package] reachable from [entrypoint].
-///
-/// The executable string is a relative Dart file path using native path
-/// separators with or without a trailing ".dart" extension. It is contained
-/// within [package], which should either be the entrypoint package or an
-/// immediate dependency of it.
-///
-/// Arguments from [args] will be passed to the spawned Dart application.
-///
-/// If [mode] is passed, it's used as the barback mode; it defaults to
-/// [BarbackMode.RELEASE].
-///
-/// Returns the exit code of the spawned app.
-Future<int> runExecutable(Entrypoint entrypoint, String package,
-    String executable, Iterable<String> args, {bool isGlobal: false,
-    BarbackMode mode}) {
-  final completer0 = new Completer();
-  scheduleMicrotask(() {
-    try {
-      join0() {
-        join1() {
-          join2() {
-            join3() {
-              var localSnapshotPath =
-                  p.join(".pub", "bin", package, "${executable}.dart.snapshot");
-              join4() {
-                var rootDir = "bin";
-                var parts = p.split(executable);
-                join5() {
-                  var assetPath = "${p.url.joinAll(p.split(executable))}.dart";
-                  var id = new AssetId(package, assetPath);
-                  new Future.value(
-                      AssetEnvironment.create(
-                          entrypoint,
-                          mode,
-                          useDart2JS: false,
-                          entrypoints: [id])).then((x0) {
-                    try {
-                      var environment = x0;
-                      environment.barback.errors.listen(((error) {
-                        log.error(log.red("Build error:\n$error"));
-                      }));
-                      var server;
-                      join6() {
-                        join7() {
-                          var vmArgs = [];
-                          vmArgs.add("--checked");
-                          var relativePath =
-                              p.url.relative(assetPath, from: p.url.joinAll(p.split(server.rootDirectory)));
-                          vmArgs.add(
-                              server.url.resolve(relativePath).toString());
-                          vmArgs.addAll(args);
-                          new Future.value(
-                              Process.start(Platform.executable, vmArgs)).then((x1) {
-                            try {
-                              var process = x1;
-                              process.stderr.listen(stderr.add);
-                              process.stdout.listen(stdout.add);
-                              stdin.listen(process.stdin.add);
-                              completer0.complete(process.exitCode);
-                            } catch (e0, s0) {
-                              completer0.completeError(e0, s0);
-                            }
-                          }, onError: completer0.completeError);
-                        }
-                        catch0(error, stackTrace) {
-                          try {
-                            if (error is AssetNotFoundException) {
-                              var message =
-                                  "Could not find ${log.bold(executable + ".dart")}";
-                              join8() {
-                                log.error("${message}.");
-                                log.fine(new Chain.forTrace(stackTrace));
-                                completer0.complete(exit_codes.NO_INPUT);
-                              }
-                              if (package != entrypoint.root.name) {
-                                message +=
-                                    " in package ${log.bold(server.package)}";
-                                join8();
-                              } else {
-                                join8();
-                              }
-                            } else {
-                              throw error;
-                            }
-                          } catch (error, stackTrace) {
-                            completer0.completeError(error, stackTrace);
-                          }
-                        }
-                        try {
-                          new Future.value(
-                              environment.barback.getAssetById(id)).then((x2) {
-                            try {
-                              x2;
-                              join7();
-                            } catch (e1, s1) {
-                              catch0(e1, s1);
-                            }
-                          }, onError: catch0);
-                        } catch (e2, s2) {
-                          catch0(e2, s2);
-                        }
-                      }
-                      if (package == entrypoint.root.name) {
-                        new Future.value(
-                            environment.serveDirectory(rootDir)).then((x3) {
-                          try {
-                            server = x3;
-                            join6();
-                          } catch (e3, s3) {
-                            completer0.completeError(e3, s3);
-                          }
-                        }, onError: completer0.completeError);
-                      } else {
-                        new Future.value(
-                            environment.servePackageBinDirectory(package)).then((x4) {
-                          try {
-                            server = x4;
-                            join6();
-                          } catch (e4, s4) {
-                            completer0.completeError(e4, s4);
-                          }
-                        }, onError: completer0.completeError);
-                      }
-                    } catch (e5, s5) {
-                      completer0.completeError(e5, s5);
-                    }
-                  }, onError: completer0.completeError);
-                }
-                if (parts.length > 1) {
-                  assert(!isGlobal && package == entrypoint.root.name);
-                  rootDir = parts.first;
-                  join5();
-                } else {
-                  executable = p.join("bin", executable);
-                  join5();
-                }
-              }
-              if (!isGlobal &&
-                  fileExists(localSnapshotPath) &&
-                  mode == BarbackMode.RELEASE) {
-                completer0.complete(
-                    _runCachedExecutable(entrypoint, localSnapshotPath, args));
-              } else {
-                join4();
-              }
-            }
-            if (p.extension(executable) == ".dart") {
-              executable = p.withoutExtension(executable);
-              join3();
-            } else {
-              join3();
-            }
-          }
-          if (log.verbosity == log.Verbosity.NORMAL) {
-            log.verbosity = log.Verbosity.WARNING;
-            join2();
-          } else {
-            join2();
-          }
-        }
-        if (entrypoint.root.name != package &&
-            !entrypoint.root.immediateDependencies.any(((dep) {
-          return dep.name == package;
-        }))) {
-          new Future.value(entrypoint.loadPackageGraph()).then((x5) {
-            try {
-              var graph = x5;
-              join9() {
-                join1();
-              }
-              if (graph.packages.containsKey(package)) {
-                dataError(
-                    'Package "${package}" is not an immediate dependency.\n'
-                        'Cannot run executables in transitive dependencies.');
-                join9();
-              } else {
-                dataError(
-                    'Could not find package "${package}". Did you forget to add a ' 'dependency?');
-                join9();
-              }
-            } catch (e6, s6) {
-              completer0.completeError(e6, s6);
-            }
-          }, onError: completer0.completeError);
-        } else {
-          join1();
-        }
-      }
-      if (mode == null) {
-        mode = BarbackMode.RELEASE;
-        join0();
-      } else {
-        join0();
-      }
-    } catch (e, s) {
-      completer0.completeError(e, s);
-    }
-  });
-  return completer0.future;
-}
-
-/// Runs the snapshot at [path] with [args] and hooks its stdout, stderr, and
-/// sdtin to this process's.
-///
-/// If [recompile] is passed, it's called if the snapshot is out-of-date. It's
-/// expected to regenerate a snapshot at [path], after which the snapshot will
-/// be re-run. It may return a Future.
-///
-/// If [checked] is set, runs the snapshot in checked mode.
-///
-/// Returns the snapshot's exit code.
-///
-/// This doesn't do any validation of the snapshot's SDK version.
-Future<int> runSnapshot(String path, Iterable<String> args, {recompile(),
-    bool checked: false}) {
-  final completer0 = new Completer();
-  scheduleMicrotask(() {
-    try {
-      var vmArgs = [path]..addAll(args);
-      join0() {
-        var stdin1;
-        var stdin2;
-        join1() {
-          runProcess(input) {
-            final completer0 = new Completer();
-            scheduleMicrotask(() {
-              try {
-                new Future.value(
-                    Process.start(Platform.executable, vmArgs)).then((x0) {
-                  try {
-                    var process = x0;
-                    process.stderr.listen(stderr.add);
-                    process.stdout.listen(stdout.add);
-                    input.listen(process.stdin.add);
-                    completer0.complete(process.exitCode);
-                  } catch (e0, s0) {
-                    completer0.completeError(e0, s0);
-                  }
-                }, onError: completer0.completeError);
-              } catch (e, s) {
-                completer0.completeError(e, s);
-              }
-            });
-            return completer0.future;
-          }
-          new Future.value(runProcess(stdin1)).then((x0) {
-            try {
-              var exitCode = x0;
-              join2() {
-                new Future.value(recompile()).then((x1) {
-                  try {
-                    x1;
-                    completer0.complete(runProcess(stdin2));
-                  } catch (e0, s0) {
-                    completer0.completeError(e0, s0);
-                  }
-                }, onError: completer0.completeError);
-              }
-              if (recompile == null || exitCode != 253) {
-                completer0.complete(exitCode);
-              } else {
-                join2();
-              }
-            } catch (e1, s1) {
-              completer0.completeError(e1, s1);
-            }
-          }, onError: completer0.completeError);
-        }
-        if (recompile == null) {
-          stdin1 = stdin;
-          join1();
-        } else {
-          var pair = tee(stdin);
-          stdin1 = pair.first;
-          stdin2 = pair.last;
-          join1();
-        }
-      }
-      if (checked) {
-        vmArgs.insert(0, "--checked");
-        join0();
-      } else {
-        join0();
-      }
-    } catch (e, s) {
-      completer0.completeError(e, s);
-    }
-  });
-  return completer0.future;
-}
-
-/// Runs the executable snapshot at [snapshotPath].
-Future<int> _runCachedExecutable(Entrypoint entrypoint, String snapshotPath,
-    List<String> args) {
-  return runSnapshot(snapshotPath, args, checked: true, recompile: () {
-    log.fine("Precompiled executable is out of date.");
-    return entrypoint.precompileExecutables();
-  });
-}