Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(231)

Unified Diff: sdk/lib/_internal/pub_generated/lib/src/command_runner.dart

Issue 896623005: Use native async/await support in pub. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Code review changes Created 5 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: sdk/lib/_internal/pub_generated/lib/src/command_runner.dart
diff --git a/sdk/lib/_internal/pub_generated/lib/src/command_runner.dart b/sdk/lib/_internal/pub_generated/lib/src/command_runner.dart
deleted file mode 100644
index 6bb615311c09ed097eeaf64745a00014e6c20fe7..0000000000000000000000000000000000000000
--- a/sdk/lib/_internal/pub_generated/lib/src/command_runner.dart
+++ /dev/null
@@ -1,339 +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.command_runner;
-
-import 'dart:async';
-import 'dart:io';
-
-import 'package:args/args.dart';
-import 'package:args/command_runner.dart';
-import 'package:http/http.dart' as http;
-import 'package:stack_trace/stack_trace.dart';
-
-import 'command/build.dart';
-import 'command/cache.dart';
-import 'command/deps.dart';
-import 'command/downgrade.dart';
-import 'command/get.dart';
-import 'command/global.dart';
-import 'command/lish.dart';
-import 'command/list_package_dirs.dart';
-import 'command/run.dart';
-import 'command/serve.dart';
-import 'command/upgrade.dart';
-import 'command/uploader.dart';
-import 'command/version.dart';
-import 'exceptions.dart';
-import 'exit_codes.dart' as exit_codes;
-import 'http.dart';
-import 'io.dart';
-import 'log.dart' as log;
-import 'sdk.dart' as sdk;
-import 'solver/version_solver.dart';
-import 'utils.dart';
-
-class PubCommandRunner extends CommandRunner {
- String get usageFooter =>
- "See http://dartlang.org/tools/pub for detailed " "documentation.";
-
- PubCommandRunner()
- : super("pub", "Pub is a package manager for Dart.") {
- argParser.addFlag('version', negatable: false, help: 'Print pub version.');
- argParser.addFlag(
- 'trace',
- help: 'Print debugging information when an error occurs.');
- argParser.addOption(
- 'verbosity',
- help: 'Control output verbosity.',
- allowed: ['normal', 'io', 'solver', 'all'],
- allowedHelp: {
- 'normal': 'Show errors, warnings, and user messages.',
- 'io': 'Also show IO operations.',
- 'solver': 'Show steps during version resolution.',
- 'all': 'Show all output including internal tracing messages.'
- });
- argParser.addFlag(
- 'verbose',
- abbr: 'v',
- negatable: false,
- help: 'Shortcut for "--verbosity=all".');
- argParser.addFlag(
- 'with-prejudice',
- hide: !isAprilFools,
- negatable: false,
- help: 'Execute commands with prejudice.');
- argParser.addFlag(
- 'package-symlinks',
- hide: true,
- negatable: true,
- defaultsTo: true);
-
- addCommand(new BuildCommand());
- addCommand(new CacheCommand());
- addCommand(new DepsCommand());
- addCommand(new DowngradeCommand());
- addCommand(new GlobalCommand());
- addCommand(new GetCommand());
- addCommand(new ListPackageDirsCommand());
- addCommand(new LishCommand());
- addCommand(new RunCommand());
- addCommand(new ServeCommand());
- addCommand(new UpgradeCommand());
- addCommand(new UploaderCommand());
- addCommand(new VersionCommand());
- }
-
- Future run(List<String> arguments) {
- final completer0 = new Completer();
- scheduleMicrotask(() {
- try {
- var options;
- join0() {
- new Future.value(runCommand(options)).then((x0) {
- try {
- x0;
- completer0.complete();
- } catch (e0, s0) {
- completer0.completeError(e0, s0);
- }
- }, onError: completer0.completeError);
- }
- catch0(error, s1) {
- try {
- if (error is UsageException) {
- log.error(error.message);
- new Future.value(flushThenExit(exit_codes.USAGE)).then((x1) {
- try {
- x1;
- join0();
- } catch (e1, s2) {
- completer0.completeError(e1, s2);
- }
- }, onError: completer0.completeError);
- } else {
- throw error;
- }
- } catch (error, s1) {
- completer0.completeError(error, s1);
- }
- }
- try {
- options = super.parse(arguments);
- join0();
- } catch (e2, s3) {
- catch0(e2, s3);
- }
- } catch (e, s) {
- completer0.completeError(e, s);
- }
- });
- return completer0.future;
- }
-
- Future runCommand(ArgResults options) {
- final completer0 = new Completer();
- scheduleMicrotask(() {
- try {
- log.withPrejudice = options['with-prejudice'];
- join0() {
- join1() {
- break0() {
- log.fine('Pub ${sdk.version}');
- new Future.value(_validatePlatform()).then((x0) {
- try {
- x0;
- var captureStackChains =
- options['trace'] ||
- options['verbose'] ||
- options['verbosity'] == 'all';
- join2() {
- completer0.complete();
- }
- catch0(error, chain) {
- try {
- log.exception(error, chain);
- join3() {
- new Future.value(
- flushThenExit(_chooseExitCode(error))).then((x1) {
- try {
- x1;
- join2();
- } catch (e0, s0) {
- completer0.completeError(e0, s0);
- }
- }, onError: completer0.completeError);
- }
- if (options['trace']) {
- log.dumpTranscript();
- join3();
- } else {
- join4() {
- join3();
- }
- if (!isUserFacingException(error)) {
- log.error("""
-This is an unexpected error. Please run
-
- pub --trace ${options.arguments.map(((arg) {
- return "'$arg'";
- })).join(' ')}
-
-and include the results in a bug report on http://dartbug.com/new.
-""");
- join4();
- } else {
- join4();
- }
- }
- } catch (error, chain) {
- completer0.completeError(error, chain);
- }
- }
- try {
- new Future.value(captureErrors((() {
- return super.runCommand(options);
- }), captureStackChains: captureStackChains)).then((x2) {
- try {
- x2;
- new Future.value(
- flushThenExit(exit_codes.SUCCESS)).then((x3) {
- try {
- x3;
- join2();
- } catch (e1, s1) {
- catch0(e1, s1);
- }
- }, onError: catch0);
- } catch (e2, s2) {
- catch0(e2, s2);
- }
- }, onError: catch0);
- } catch (e3, s3) {
- catch0(e3, s3);
- }
- } catch (e4, s4) {
- completer0.completeError(e4, s4);
- }
- }, onError: completer0.completeError);
- }
- switch (options['verbosity']) {
- case 'normal':
- log.verbosity = log.Verbosity.NORMAL;
- break0();
- break;
- case 'io':
- log.verbosity = log.Verbosity.IO;
- break0();
- break;
- case 'solver':
- log.verbosity = log.Verbosity.SOLVER;
- break0();
- break;
- case 'all':
- log.verbosity = log.Verbosity.ALL;
- break0();
- break;
- default:
- join5() {
- break0();
- }
- if (options['verbose']) {
- log.verbosity = log.Verbosity.ALL;
- join5();
- } else {
- join5();
- }
- break;
- }
- }
- if (options['trace']) {
- log.recordTranscript();
- join1();
- } else {
- join1();
- }
- }
- if (options['version']) {
- log.message('Pub ${sdk.version}');
- completer0.complete(null);
- } else {
- join0();
- }
- } catch (e, s) {
- completer0.completeError(e, s);
- }
- });
- return completer0.future;
- }
-
- void printUsage() {
- log.message(usage);
- }
-
- /// Returns the appropriate exit code for [exception], falling back on 1 if no
- /// appropriate exit code could be found.
- int _chooseExitCode(exception) {
- while (exception is WrappedException) exception = exception.innerError;
-
- if (exception is HttpException ||
- exception is http.ClientException ||
- exception is SocketException ||
- exception is PubHttpException ||
- exception is DependencyNotFoundException) {
- return exit_codes.UNAVAILABLE;
- } else if (exception is FormatException || exception is DataException) {
- return exit_codes.DATA;
- } else if (exception is UsageException) {
- return exit_codes.USAGE;
- } else {
- return 1;
- }
- }
-
- /// Checks that pub is running on a supported platform.
- ///
- /// If it isn't, it prints an error message and exits. Completes when the
- /// validation is done.
- Future _validatePlatform() {
- final completer0 = new Completer();
- scheduleMicrotask(() {
- try {
- join0() {
- new Future.value(runProcess('ver', [])).then((x0) {
- try {
- var result = x0;
- join1() {
- completer0.complete();
- }
- if (result.stdout.join('\n').contains('XP')) {
- log.error('Sorry, but pub is not supported on Windows XP.');
- new Future.value(flushThenExit(exit_codes.USAGE)).then((x1) {
- try {
- x1;
- join1();
- } catch (e0, s0) {
- completer0.completeError(e0, s0);
- }
- }, onError: completer0.completeError);
- } else {
- join1();
- }
- } catch (e1, s1) {
- completer0.completeError(e1, s1);
- }
- }, onError: completer0.completeError);
- }
- if (Platform.operatingSystem != 'windows') {
- completer0.complete(null);
- } else {
- join0();
- }
- } catch (e, s) {
- completer0.completeError(e, s);
- }
- });
- return completer0.future;
- }
-}
« no previous file with comments | « sdk/lib/_internal/pub_generated/lib/src/command/version.dart ('k') | sdk/lib/_internal/pub_generated/lib/src/dart.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698