Add logging system to pub and sprinkle some logging in.

utils/pub/command_lish.dart

 // Copyright (c) 2012, 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 command_lish;
 
 import 'dart:io';
 import 'dart:json';
 import 'dart:uri';
 
 import '../../pkg/args/lib/args.dart';
 import '../../pkg/http/lib/http.dart' as http;
+import 'git.dart' as git;
+import 'io.dart';
+import 'log.dart' as log;
+import 'oauth2.dart' as oauth2;
 import 'pub.dart';
-import 'io.dart';
-import 'git.dart' as git;
-import 'oauth2.dart' as oauth2;
 import 'validator.dart';
 
 // TODO(nweiz): Make "publish" the primary name for this command. See issue
 // 6949.
 /// Handles the `lish` and `publish` pub commands.
 class LishCommand extends PubCommand {
   final description = "publish the current package to pub.dartlang.org";
   final usage = "pub publish [options]";
   final aliases = const ["lish", "lush"];
 
   ArgParser get commandParser {
     var parser = new ArgParser();
     parser.addOption('server', defaultsTo: 'https://pub.dartlang.org',
         help: 'The package server to which to upload this package');
     return parser;
   }
 
   /// The URL of the server to which to upload the package.
   Uri get server => new Uri.fromString(commandOptions['server']);
 
   Future onRun() {
     var cloudStorageUrl;
     return oauth2.withClient(cache, (client) {
       // TODO(nweiz): Cloud Storage can provide an XML-formatted error. We
       // should report that error and exit.
       return Futures.wait([
         client.get(server.resolve("/packages/versions/new.json")),
         _filesToPublish.transform((files) {
+          log.fine('Archiving and publishing ${entrypoint.root}.');
           return createTarGz(files, baseDir: entrypoint.root.dir);
         }).chain(consumeInputStream),
         _validate()
       ]).chain((results) {
         var response = results[0];
         var packageBytes = results[1];
         var parameters = _parseJson(response);
 
         var url = _expectField(parameters, 'url', response);
         if (url is! String) _invalidServerResponse(response);
@@ skipping 15 matching lines @@
         var location = response.headers['location'];
         if (location == null) throw new PubHttpException(response);
         return location;
       }).chain((location) => client.get(location)).transform((response) {
         var parsed = _parseJson(response);
         if (parsed['success'] is! Map ||
             !parsed['success'].containsKey('message') ||
             parsed['success']['message'] is! String) {
           _invalidServerResponse(response);
         }
-        print(parsed['success']['message']);
+        log.message(parsed['success']['message']);
       });
     }).transformException((e) {
       if (e is PubHttpException) {
         var url = e.response.request.url;
         if (url.toString() == cloudStorageUrl.toString()) {
           // TODO(nweiz): the response may have XML-formatted information about
           // the error. Try to parse that out once we have an easily-accessible
           // XML parser.
           throw 'Failed to upload the package.';
         } else if (url.origin == server.origin) {
           var errorMap = _parseJson(e.response);
           if (errorMap['error'] is! Map ||
               !errorMap['error'].containsKey('message') ||
               errorMap['error']['message'] is! String) {
             _invalidServerResponse(e.response);
           }
           throw errorMap['error']['message'];
         }
       } else if (e is oauth2.ExpirationException) {
-        printError("Pub's authorization to upload packages has expired and "
+        log.error("Pub's authorization to upload packages has expired and "
             "can't be automatically refreshed.");
         return onRun();
       } else if (e is oauth2.AuthorizationException) {
         var message = "OAuth2 authorization failed";
         if (e.description != null) message = "$message (${e.description})";
-        printError("$message.");
+        log.error("$message.");
         return oauth2.clearCredentials(cache).chain((_) => onRun());
       } else {
         throw e;
       }
+
+      if (e is! oauth2.ExpirationException) throw e;
+
+      log.error("Pub's authorization to upload packages has expired and can't "
+          "be automatically refreshed.");
+      return onRun();
     });
   }
 
   /// The basenames of files that are automatically excluded from archives.
   final _BLACKLISTED_FILES = const ['pubspec.lock'];
 
   /// The basenames of directories that are automatically excluded from
   /// archives.
   final _BLACKLISTED_DIRECTORIES = const ['packages'];
 
@@ skipping 64 matching lines @@
       var s = warnings.length == 1 ? '' : 's';
       stdout.writeString("Package has ${warnings.length} warning$s. Upload "
           "anyway (y/n)? ");
       return readLine().transform((line) {
         if (new RegExp(r"^[yY]").hasMatch(line)) return;
         throw "Package upload canceled.";
       });
     });
   }
 }