Add a 30s timeout for all HTTP requests in Pub.

utils/pub/hosted_source.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('hosted_source');
 
 #import('dart:json');
 #import('dart:uri');
 #import('io.dart');
 #import('package.dart');
@@ skipping 38 matching lines @@
   }
 
   /**
    * Downloads and parses the pubspec for a specific version of a package that
    * is available from the site.
    */
   Future<Pubspec> describe(PackageId id) {
     var parsed = _parseDescription(id.description);
     var fullUrl = "${parsed.last}/packages/${parsed.first}/versions/"
       "${id.version}.yaml";
-    return consumeInputStream(httpGet(fullUrl)).transform((data) {
-      return new Pubspec.parse(
-          new String.fromCharCodes(data), systemCache.sources);
+    return httpGetString(fullUrl).transform((yaml) {
+      return new Pubspec.parse(yaml, systemCache.sources);
     });
   }
 
   /**
    * Downloads a package from the site and unpacks it.
    */
   Future<bool> install(PackageId id, String destPath) {
     var parsedDescription = _parseDescription(id.description);
     var name = parsedDescription.first;
     var url = parsedDescription.last;
 
-    return ensureDir(destPath).chain((destDir) {
-      var fullUrl = "$url/packages/$name/versions/${id.version}.tar.gz";
-      return extractTarGz(httpGet(fullUrl), destDir);
+    var fullUrl = "$url/packages/$name/versions/${id.version}.tar.gz";
+    return Futures.wait([httpGet(fullUrl), ensureDir(destPath)]).chain((args) {
+      return future(extractTarGz(args[0], args[1]), HTTP_TIMEOUT,
+          'Timed out while fetching URL "$fullUrl".');
     });
   }
 
   /**
    * The system cache directory for the hosted source contains subdirectories
    * for each separate repository URL that's used on the system. Each of these
    * subdirectories then contains a subdirectory for each package installed
    * from that site.
    */
   String systemCacheDirectory(PackageId id) {
@@ skipping 44 matching lines @@
 
     var name = description["name"];
     if (name is! String) {
       throw new FormatException("The 'name' key must have a string value.");
     }
 
     var url = description.containsKey("url") ? description["url"] : defaultUrl;
     return new Pair<String, String>(name, url);
   }
 }