Show nicer errors on some server failures.

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');
@@ skipping 110 matching lines @@
     return opened.writeString(contents).chain((ignore) {
         return opened.close().transform((ignore) => file);
     });
   });
 }
 
 /**
  * Asynchronously deletes [file], which can be a [String] or a [File]. Returns a
  * [Future] that completes when the deletion is done.
  */
-Future<Directory> deleteFile(file) {
+Future<File> deleteFile(file) {
   return new File(_getPath(file)).delete();
 }
 
 /**
  * Creates a directory [dir]. Returns a [Future] that completes when the
  * directory is created.
  */
 Future<Directory> createDir(dir) {
   dir = _getDirectory(dir);
   return dir.create();
@@ skipping 161 matching lines @@
           "HTTP request for $uri failed with status ${response.statusCode}");
     }
 
     pipeInputToInput(response.inputStream, resultStream, client.shutdown);
   };
 
   return resultStream;
 }
 
 /**
+ * Opens an input stream for a HTTP GET request to [uri], which may be a
+ * [String] or [Uri]. Completes with the result of the request as a String.
+ */
+Future<String> httpGetString(uri) {
+  // TODO(rnystrom): This code is very similar to httpGet() and
+  // consumeInputStream() (but this one propagates errors). Merge them when
+  // #3657 is fixed.
+  uri = _getUri(uri);
+
+  var completer = new Completer<String>();
+  var client = new HttpClient();
+  var connection = client.getUrl(uri);
+
+  connection.onError = (e) {
+    // Show a friendly error if the URL couldn't be resolved.
+    if (e is SocketIOException && e.osError.errorCode == 8) {
+      e = 'Could not resolve URL "${uri.origin}".';
+    }
+
+    client.shutdown();
+    completer.completeException(e);
+  };
+
+  connection.onResponse = (response) {
+    if (response.statusCode >= 400) {
+      client.shutdown();
+      completer.completeException(
+          new HttpException(response.statusCode, response.reasonPhrase));
+      return;
+    }
+
+    var resultStream = new ListInputStream();
+    var buffer = <int>[];
+
+    response.inputStream.onClosed = () {
+      client.shutdown();
+      completer.complete(new String.fromCharCodes(buffer));
+    };
+
+    response.inputStream.onData = () {
+      buffer.addAll(response.inputStream.read());
+    };
+
+    response.inputStream.onError = (e) {
+      client.shutdown();
+      completer.completeException(e);
+    };
+  };
+
+  return completer.future;
+}
+
+/**
  * Takes all input from [source] and writes it to [sink].
  *
  * [onClosed] is called when [source] is closed.
  */
 void pipeInputToInput(InputStream source, ListInputStream sink,
     [void onClosed()]) {
   source.onClosed = () {
     sink.markEndOfStream();
     if (onClosed != null) onClosed();
   };
@@ skipping 122 matching lines @@
   stream.pipe(process.stdin);
   process.stdout.pipe(stdout, close: false);
   process.stderr.pipe(stderr, close: false);
 
   process.onExit = completer.complete;
   process.onError = completer.completeException;
   return completer.future.transform((exitCode) => exitCode == 0);
 }
 
 /**
+ * Exception thrown when an HTTP operation fails.
+ */
+class HttpException implements Exception {
+  final int statusCode;
+  final String reason;
+
+  const HttpException(this.statusCode, this.reason);
+}
+
+/**
  * Contains the results of invoking a [Process] and waiting for it to complete.
  */
 class PubProcessResult {
   final List<String> stdout;
   final List<String> stderr;
   final int exitCode;
 
   const PubProcessResult(this.stdout, this.stderr, this.exitCode);
 
   bool get success => exitCode == 0;
@@ skipping 20 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);
 }