| Index: sdk/lib/_internal/pub/lib/src/command/run.dart
|
| diff --git a/sdk/lib/_internal/pub/lib/src/command/run.dart b/sdk/lib/_internal/pub/lib/src/command/run.dart
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..a315ae59f20014d975f31f0b24a0c35b0d4ba881
|
| --- /dev/null
|
| +++ b/sdk/lib/_internal/pub/lib/src/command/run.dart
|
| @@ -0,0 +1,93 @@
|
| +// 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.command.run;
|
| +
|
| +import 'dart:async';
|
| +import 'dart:io';
|
| +
|
| +import 'package:barback/barback.dart';
|
| +import 'package:stack_trace/stack_trace.dart';
|
| +
|
| +import '../barback/asset_environment.dart';
|
| +import '../command.dart';
|
| +import '../exit_codes.dart' as exit_codes;
|
| +import '../io.dart';
|
| +import '../log.dart' as log;
|
| +import '../utils.dart';
|
| +
|
| +final _arrow = getSpecial('\u2192', '=>');
|
| +
|
| +/// Handles the `run` pub command.
|
| +class RunCommand extends PubCommand {
|
| + bool get takesArguments => true;
|
| + bool get allowTrailingOptions => false;
|
| + String get description => "Run an executable from a package.";
|
| + String get usage => "pub run <executable> [args...]";
|
| +
|
| + Future onRun() {
|
| + if (commandOptions.rest.isEmpty) {
|
| + usageError("Must specify an executable to run.");
|
| + }
|
| +
|
| + // Unless the user overrides the verbosity, we want to filter out the
|
| + // normal pub output shown while loading the environment.
|
| + if (log.verbosity == log.Verbosity.NORMAL) {
|
| + log.verbosity = log.Verbosity.WARNING;
|
| + }
|
| +
|
| + var environment;
|
| + return AssetEnvironment.create(entrypoint, BarbackMode.RELEASE,
|
| + WatcherType.NONE, useDart2JS: false)
|
| + .then((_environment) {
|
| + environment = _environment;
|
| +
|
| + // Show in-progress errors, but not results. Those get handled
|
| + // implicitly by getAllAssets().
|
| + environment.barback.errors.listen((error) {
|
| + log.error(log.red("Build error:\n$error"));
|
| + });
|
| +
|
| + return environment.serveDirectory("bin");
|
| + }).then((server) {
|
| + var script = commandOptions.rest[0];
|
| + var args = commandOptions.rest.skip(1).toList();
|
| +
|
| + // TODO(rnystrom): Support scripts in other directories.
|
| + var scriptPath = "bin/$script.dart";
|
| +
|
| + // Try to make sure the entrypoint script exists (or is generated) before
|
| + // we spawn the process to run it.
|
| + return environment.barback.getAssetById(
|
| + new AssetId(entrypoint.root.name, scriptPath)).then((_) {
|
| + return environment.getUrlsForAssetPath(scriptPath).then((urls) {
|
| + // Should only be bound to one port.
|
| + assert(urls.length == 1);
|
| +
|
| + // Run in checked mode.
|
| + // TODO(rnystrom): Make this configurable.
|
| + args.insert(0, "--checked");
|
| +
|
| + // The URL to the Dart entrypoint comes before the script arguments.
|
| + args.insert(1, urls[0].toString());
|
| + return Process.start(Platform.executable, args);
|
| + }).then((process) {
|
| + // Note: we're not using process.std___.pipe(std___) here because
|
| + // that prevents pub from also writing to the output streams.
|
| + process.stderr.listen(stderr.add);
|
| + process.stdout.listen(stdout.add);
|
| + stdin.listen(process.stdin.add);
|
| +
|
| + return process.exitCode;
|
| + }).then(flushThenExit);
|
| + }).catchError((error, stackTrace) {
|
| + if (error is! AssetNotFoundException) throw error;
|
| +
|
| + log.error("Could not find $scriptPath.");
|
| + log.fine(new Chain.forTrace(stackTrace));
|
| + return flushThenExit(exit_codes.NO_INPUT);
|
| + });
|
| + });
|
| + }
|
| +}
|
|
|