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

Side by Side Diff: sdk/lib/_internal/pub_generated/bin/pub.dart

Issue 657673002: Regenerate pub sources. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 6 years, 2 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 unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file
2 // for details. All rights reserved. Use of this source code is governed by a
3 // BSD-style license that can be found in the LICENSE file.
4
1 import 'dart:async'; 5 import 'dart:async';
2 import 'dart:io'; 6 import 'dart:io';
7
3 import 'package:args/args.dart'; 8 import 'package:args/args.dart';
4 import 'package:http/http.dart' as http; 9 import 'package:http/http.dart' as http;
5 import 'package:path/path.dart' as path; 10 import 'package:path/path.dart' as path;
6 import 'package:stack_trace/stack_trace.dart'; 11 import 'package:stack_trace/stack_trace.dart';
12
7 import '../lib/src/command.dart'; 13 import '../lib/src/command.dart';
8 import '../lib/src/exceptions.dart'; 14 import '../lib/src/exceptions.dart';
9 import '../lib/src/exit_codes.dart' as exit_codes; 15 import '../lib/src/exit_codes.dart' as exit_codes;
10 import '../lib/src/http.dart'; 16 import '../lib/src/http.dart';
11 import '../lib/src/io.dart'; 17 import '../lib/src/io.dart';
12 import '../lib/src/log.dart' as log; 18 import '../lib/src/log.dart' as log;
13 import '../lib/src/sdk.dart' as sdk; 19 import '../lib/src/sdk.dart' as sdk;
14 import '../lib/src/solver/version_solver.dart'; 20 import '../lib/src/solver/version_solver.dart';
15 import '../lib/src/utils.dart'; 21 import '../lib/src/utils.dart';
22
16 void main(List<String> arguments) { 23 void main(List<String> arguments) {
17 ArgResults options; 24 ArgResults options;
25
18 try { 26 try {
19 options = PubCommand.pubArgParser.parse(arguments); 27 options = PubCommand.pubArgParser.parse(arguments);
20 } on FormatException catch (e) { 28 } on FormatException catch (e) {
21 log.error(e.message); 29 log.error(e.message);
22 log.error('Run "pub help" to see available options.'); 30 log.error('Run "pub help" to see available options.');
23 flushThenExit(exit_codes.USAGE); 31 flushThenExit(exit_codes.USAGE);
24 return; 32 return;
25 } 33 }
34
26 log.withPrejudice = options['with-prejudice']; 35 log.withPrejudice = options['with-prejudice'];
36
27 if (options['version']) { 37 if (options['version']) {
28 log.message('Pub ${sdk.version}'); 38 log.message('Pub ${sdk.version}');
29 return; 39 return;
30 } 40 }
41
31 if (options['help']) { 42 if (options['help']) {
32 PubCommand.printGlobalUsage(); 43 PubCommand.printGlobalUsage();
33 return; 44 return;
34 } 45 }
46
35 if (options['trace']) { 47 if (options['trace']) {
36 log.recordTranscript(); 48 log.recordTranscript();
37 } 49 }
50
38 switch (options['verbosity']) { 51 switch (options['verbosity']) {
39 case 'normal': 52 case 'normal':
40 log.verbosity = log.Verbosity.NORMAL; 53 log.verbosity = log.Verbosity.NORMAL;
41 break; 54 break;
42 case 'io': 55 case 'io':
43 log.verbosity = log.Verbosity.IO; 56 log.verbosity = log.Verbosity.IO;
44 break; 57 break;
45 case 'solver': 58 case 'solver':
46 log.verbosity = log.Verbosity.SOLVER; 59 log.verbosity = log.Verbosity.SOLVER;
47 break; 60 break;
48 case 'all': 61 case 'all':
49 log.verbosity = log.Verbosity.ALL; 62 log.verbosity = log.Verbosity.ALL;
50 break; 63 break;
51 default: 64 default:
65 // No specific verbosity given, so check for the shortcut.
52 if (options['verbose']) { 66 if (options['verbose']) {
53 log.verbosity = log.Verbosity.ALL; 67 log.verbosity = log.Verbosity.ALL;
54 } 68 }
55 break; 69 break;
56 } 70 }
71
57 log.fine('Pub ${sdk.version}'); 72 log.fine('Pub ${sdk.version}');
73
58 var cacheDir; 74 var cacheDir;
59 if (Platform.environment.containsKey('PUB_CACHE')) { 75 if (Platform.environment.containsKey('PUB_CACHE')) {
60 cacheDir = Platform.environment['PUB_CACHE']; 76 cacheDir = Platform.environment['PUB_CACHE'];
61 } else if (Platform.operatingSystem == 'windows') { 77 } else if (Platform.operatingSystem == 'windows') {
62 var appData = Platform.environment['APPDATA']; 78 var appData = Platform.environment['APPDATA'];
63 cacheDir = path.join(appData, 'Pub', 'Cache'); 79 cacheDir = path.join(appData, 'Pub', 'Cache');
64 } else { 80 } else {
65 cacheDir = '${Platform.environment['HOME']}/.pub-cache'; 81 cacheDir = '${Platform.environment['HOME']}/.pub-cache';
66 } 82 }
83
67 validatePlatform().then((_) => runPub(cacheDir, options, arguments)); 84 validatePlatform().then((_) => runPub(cacheDir, options, arguments));
68 } 85 }
86
87 /// Runs the appropriate pub command whose [arguments] have been parsed to
88 /// [options] using the system cache in [cacheDir].
89 ///
90 /// Handles and correctly reports any errors that occur while running.
69 void runPub(String cacheDir, ArgResults options, List<String> arguments) { 91 void runPub(String cacheDir, ArgResults options, List<String> arguments) {
70 var captureStackChains = 92 var captureStackChains =
71 options['trace'] || 93 options['trace'] ||
72 options['verbose'] || 94 options['verbose'] ||
73 options['verbosity'] == 'all'; 95 options['verbosity'] == 'all';
96
74 captureErrors( 97 captureErrors(
75 () => invokeCommand(cacheDir, options), 98 () => invokeCommand(cacheDir, options),
76 captureStackChains: captureStackChains).catchError((error, Chain chain) { 99 captureStackChains: captureStackChains).catchError((error, Chain chain) {
77 log.exception(error, chain); 100 log.exception(error, chain);
101
78 if (options['trace']) { 102 if (options['trace']) {
79 log.dumpTranscript(); 103 log.dumpTranscript();
80 } else if (!isUserFacingException(error)) { 104 } else if (!isUserFacingException(error)) {
81 log.error(""" 105 log.error("""
82 This is an unexpected error. Please run 106 This is an unexpected error. Please run
83 107
84 pub --trace ${arguments.map((arg) => "'$arg'").join(' ')} 108 pub --trace ${arguments.map((arg) => "'$arg'").join(' ')}
85 109
86 and include the results in a bug report on http://dartbug.com/new. 110 and include the results in a bug report on http://dartbug.com/new.
87 """); 111 """);
88 } 112 }
113
89 return flushThenExit(chooseExitCode(error)); 114 return flushThenExit(chooseExitCode(error));
90 }).then((_) { 115 }).then((_) {
116 // Explicitly exit on success to ensure that any dangling dart:io handles
117 // don't cause the process to never terminate.
91 return flushThenExit(exit_codes.SUCCESS); 118 return flushThenExit(exit_codes.SUCCESS);
92 }); 119 });
93 } 120 }
121
122 /// Returns the appropriate exit code for [exception], falling back on 1 if no
123 /// appropriate exit code could be found.
94 int chooseExitCode(exception) { 124 int chooseExitCode(exception) {
95 while (exception is WrappedException) exception = exception.innerError; 125 while (exception is WrappedException) exception = exception.innerError;
126
96 if (exception is HttpException || 127 if (exception is HttpException ||
97 exception is http.ClientException || 128 exception is http.ClientException ||
98 exception is SocketException || 129 exception is SocketException ||
99 exception is PubHttpException || 130 exception is PubHttpException ||
100 exception is DependencyNotFoundException) { 131 exception is DependencyNotFoundException) {
101 return exit_codes.UNAVAILABLE; 132 return exit_codes.UNAVAILABLE;
102 } else if (exception is FormatException || exception is DataException) { 133 } else if (exception is FormatException || exception is DataException) {
103 return exit_codes.DATA; 134 return exit_codes.DATA;
104 } else if (exception is UsageException) { 135 } else if (exception is UsageException) {
105 return exit_codes.USAGE; 136 return exit_codes.USAGE;
106 } else { 137 } else {
107 return 1; 138 return 1;
108 } 139 }
109 } 140 }
141
142 /// Walks the command tree and runs the selected pub command.
110 Future invokeCommand(String cacheDir, ArgResults mainOptions) { 143 Future invokeCommand(String cacheDir, ArgResults mainOptions) {
111 final completer0 = new Completer(); 144 final completer0 = new Completer();
112 scheduleMicrotask(() { 145 scheduleMicrotask(() {
113 try { 146 try {
114 var commands = PubCommand.mainCommands; 147 var commands = PubCommand.mainCommands;
115 var command; 148 var command;
116 var commandString = "pub"; 149 var commandString = "pub";
117 var options = mainOptions; 150 var options = mainOptions;
118 break0(x2) { 151 break0() {
119 join0() { 152 join0() {
120 join1(x0) { 153 join1() {
121 completer0.complete(null); 154 completer0.complete();
122 } 155 }
123 finally0(cont0, v0) { 156 finally0(cont0) {
124 command.cache.deleteTempDir(); 157 command.cache.deleteTempDir();
125 cont0(v0); 158 cont0();
126 } 159 }
127 catch0(e0) { 160 catch0(e1, s1) {
128 finally0(join1, null); 161 finally0(() => completer0.completeError(e1, s1));
129 } 162 }
130 try { 163 try {
131 finally0((v1) { 164 final v0 = command.run(cacheDir, mainOptions, options);
132 completer0.complete(v1); 165 finally0(() {
133 }, command.run(cacheDir, mainOptions, options)); 166 completer0.complete(v0);
134 } catch (e1) { 167 });
135 catch0(e1); 168 } catch (e2, s2) {
169 catch0(e2, s2);
136 } 170 }
137 } 171 }
138 if (!command.takesArguments && options.rest.isNotEmpty) { 172 if (!command.takesArguments && options.rest.isNotEmpty) {
139 command.usageError( 173 command.usageError(
140 'Command "${options.name}" does not take any arguments.'); 174 'Command "${options.name}" does not take any arguments.');
141 join0(); 175 join0();
142 } else { 176 } else {
143 join0(); 177 join0();
144 } 178 }
145 } 179 }
146 continue0(x3) { 180 var trampoline0;
181 continue0() {
182 trampoline0 = null;
147 if (commands.isNotEmpty) { 183 if (commands.isNotEmpty) {
148 Future.wait([]).then((x1) { 184 join2() {
149 join2() { 185 options = options.command;
150 options = options.command; 186 command = commands[options.name];
151 command = commands[options.name]; 187 commands = command.subcommands;
152 commands = command.subcommands; 188 commandString += " ${options.name}";
153 commandString += " ${options.name}"; 189 join3() {
154 join3() { 190 trampoline0 = continue0;
155 continue0(null); 191 }
192 if (options['help']) {
193 command.printUsage();
194 completer0.complete(new Future.value());
195 } else {
196 join3();
197 }
198 }
199 if (options.command == null) {
200 join4() {
201 join2();
202 }
203 if (options.rest.isEmpty) {
204 join5() {
205 command.usageError(
206 'Missing subcommand for "${commandString}".');
207 join4();
156 } 208 }
157 if (options['help']) { 209 if (command == null) {
158 command.printUsage(); 210 PubCommand.printGlobalUsage();
159 completer0.complete(new Future.value()); 211 completer0.complete(new Future.value());
160 } else { 212 } else {
161 join3(); 213 join5();
214 }
215 } else {
216 join6() {
217 command.usageError(
218 'Could not find a subcommand named '
219 '"${options.rest[0]}" for "${commandString}".');
220 join4();
221 }
222 if (command == null) {
223 PubCommand.usageErrorWithCommands(
224 commands,
225 'Could not find a command named "${options.rest[0]}".');
226 join6();
227 } else {
228 join6();
162 } 229 }
163 } 230 }
164 if (options.command == null) { 231 } else {
165 join4() { 232 join2();
166 join2(); 233 }
167 }
168 if (options.rest.isEmpty) {
169 join5() {
170 command.usageError(
171 'Missing subcommand for "${commandString}".');
172 join4();
173 }
174 if (command == null) {
175 PubCommand.printGlobalUsage();
176 completer0.complete(new Future.value());
177 } else {
178 join5();
179 }
180 } else {
181 join6() {
182 command.usageError(
183 'Could not find a subcommand named '
184 '"${options.rest[0]}" for "${commandString}".');
185 join4();
186 }
187 if (command == null) {
188 PubCommand.usageErrorWithCommands(
189 commands,
190 'Could not find a command named "${options.rest[0]}".');
191 join6();
192 } else {
193 join6();
194 }
195 }
196 } else {
197 join2();
198 }
199 });
200 } else { 234 } else {
201 break0(null); 235 break0();
202 } 236 }
203 } 237 }
204 continue0(null); 238 trampoline0 = continue0;
205 } catch (e2) { 239 do trampoline0(); while (trampoline0 != null);
206 completer0.completeError(e2); 240 } catch (e, s) {
241 completer0.completeError(e, s);
207 } 242 }
208 }); 243 });
209 return completer0.future; 244 return completer0.future;
210 } 245 }
246
247 /// Checks that pub is running on a supported platform.
248 ///
249 /// If it isn't, it prints an error message and exits. Completes when the
250 /// validation is done.
211 Future validatePlatform() { 251 Future validatePlatform() {
212 final completer0 = new Completer(); 252 final completer0 = new Completer();
213 scheduleMicrotask(() { 253 scheduleMicrotask(() {
214 try { 254 try {
215 join0() { 255 join0() {
216 runProcess('ver', []).then((x0) { 256 runProcess('ver', []).then((x0) {
217 try { 257 try {
218 var result = x0; 258 var result = x0;
219 join1() { 259 join1() {
220 completer0.complete(null); 260 completer0.complete();
221 } 261 }
222 if (result.stdout.join('\n').contains('XP')) { 262 if (result.stdout.join('\n').contains('XP')) {
223 log.error('Sorry, but pub is not supported on Windows XP.'); 263 log.error('Sorry, but pub is not supported on Windows XP.');
224 flushThenExit(exit_codes.USAGE).then((x1) { 264 flushThenExit(exit_codes.USAGE).then((x1) {
225 try { 265 try {
226 x1; 266 x1;
227 join1(); 267 join1();
228 } catch (e1) { 268 } catch (e0, s0) {
229 completer0.completeError(e1); 269 completer0.completeError(e0, s0);
230 } 270 }
231 }, onError: (e2) { 271 }, onError: completer0.completeError);
232 completer0.completeError(e2);
233 });
234 } else { 272 } else {
235 join1(); 273 join1();
236 } 274 }
237 } catch (e0) { 275 } catch (e1, s1) {
238 completer0.completeError(e0); 276 completer0.completeError(e1, s1);
239 } 277 }
240 }, onError: (e3) { 278 }, onError: completer0.completeError);
241 completer0.completeError(e3);
242 });
243 } 279 }
244 if (Platform.operatingSystem != 'windows') { 280 if (Platform.operatingSystem != 'windows') {
245 completer0.complete(null); 281 completer0.complete(null);
246 } else { 282 } else {
247 join0(); 283 join0();
248 } 284 }
249 } catch (e4) { 285 } catch (e, s) {
250 completer0.completeError(e4); 286 completer0.completeError(e, s);
251 } 287 }
252 }); 288 });
253 return completer0.future; 289 return completer0.future;
254 } 290 }
OLDNEW
« no previous file with comments | « sdk/lib/_internal/pub_generated/bin/async_compile.dart ('k') | sdk/lib/_internal/pub_generated/lib/src/ascii_tree.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698