Add a pub command for managing uploaders for packages.

utils/pub/io.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.
 
 /**
  * Helper functionality to make working with IO easier.
  */
 library io;
 
 import 'dart:io';
 import 'dart:isolate';
+import 'dart:json';
 import 'dart:uri';
 
 // TODO(nweiz): Make this import better.
 import '../../pkg/http/lib/http.dart' as http;
 import 'curl_client.dart';
 import 'log.dart' as log;
 import 'path.dart' as path;
 import 'utils.dart';
 
 bool _isGitInstalledCache;
@@ skipping 536 matching lines @@
       throw e;
     }), HTTP_TIMEOUT, 'fetching URL "${request.url}"');
   }
 }
 
 /// The HTTP client to use for all HTTP requests.
 final httpClient = new PubHttpClient();
 
 final curlClient = new PubHttpClient(new CurlClient());
 
+/// Handles a successful JSON-formatted response from pub.dartlang.org.

[Bob Nystrom, 2012/12/17 18:41:58]

io.dart is becoming a bit of a dumping ground. How about moving these to a new
library? Maybe "http.dart" or "web.dart"?

[nweiz, 2012/12/17 21:18:48]

Done.

+///
+/// These responses are expected to be of the form `{"success": {"message":
+/// "some message"}}`. If the format is correct, the message will be printed;
+/// otherwise an error will be raised.
+void handleJsonSuccess(http.Response response) {
+  var parsed = parseJsonResponse(response);
+  if (parsed['success'] is! Map ||
+      !parsed['success'].containsKey('message') ||
+      parsed['success']['message'] is! String) {
+    invalidServerResponse(response);
+  }
+  log.message(parsed['success']['message']);
+}
+
+/// Handles an unsuccessful JSON-formatted response from pub.dartlang.org.
+///
+/// These responses are expected to be of the form `{"error": {"message": "some
+/// message"}}`. If the format is correct, the message will be raised as an
+/// error; otherwise an [invalidServerResponse] error will be raised.
+void handleJsonError(http.Response response) {
+  var errorMap = parseJsonResponse(response);
+  if (errorMap['error'] is! Map ||
+      !errorMap['error'].containsKey('message') ||
+      errorMap['error']['message'] is! String) {
+    invalidServerResponse(response);
+  }
+  throw errorMap['error']['message'];
+}
+
+/// Parses a response body, assuming it's JSON-formatted. Throws a user-friendly
+/// error if the response body is invalid JSON, or if it's not a map.
+Map parseJsonResponse(http.Response response) {
+  var value;
+  try {
+    value = JSON.parse(response.body);
+  } catch (e) {
+    // TODO(nweiz): narrow this catch clause once issue 6775 is fixed.
+    invalidServerResponse(response);
+  }
+  if (value is! Map) invalidServerResponse(response);
+  return value;
+}
+
+/// Throws an error describing an invalid response from the server.
+void invalidServerResponse(http.Response response) {
+  throw 'Invalid server response:\n${response.body}';
+}
+
 /**
  * Takes all input from [source] and writes it to [sink].
  *
  * Returns a future that completes when [source] is closed.
  */
 Future pipeInputToInput(InputStream source, ListInputStream sink) {
   var completer = new Completer();
   source.onClosed = () {
     sink.markEndOfStream();
     completer.complete(null);
@@ skipping 492 matching lines @@
   return new Directory(entry);
 }
 
 /**
  * Gets a [Uri] for [uri], which can either already be one, or be a [String].
  */
 Uri _getUri(uri) {
   if (uri is Uri) return uri;
   return new Uri.fromString(uri);
 }