Add a Pub source for pub.dartlang.org.

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:uri');
 
 /** Gets the current working directory. */
 String get workingDir() => new File('.').fullPathSync();
 
 /**
  * Prints the given string to `stderr` on its own line.
  */
 void printError(value) {
   stderr.writeString(value.toString());
   stderr.writeString('\n');
@@ skipping 235 matching lines @@
 }
 
 /**
  * Given [entry] which may be a [String], [File], or [Directory] relative to
  * the current working directory, returns its full canonicalized path.
  */
 // TODO(rnystrom): Should this be async?
 String getFullPath(entry) => new File(_getPath(entry)).fullPathSync();
 
 /**
+ * Opens an input stream for a HTTP GET request to [uri], which may be a
+ * [String] or [Uri].
+ */
+InputStream httpGet(uri) {
+  var resultStream = new ListInputStream();
+  var connection = new HttpClient().getUrl(_getUri(uri));
+
+  // TODO(nweiz): propagate this error to the return value. See issue 3657.
+  connection.onError = (e) { throw e; };
+  connection.onResponse = (response) {
+    if (response.statusCode >= 400) {
+      // TODO(nweiz): propagate this error to the return value. See issue 3657.
+      throw new Exception(
+          "HTTP request for $uri failed with status ${response.statusCode}");
+    }
+
+    pipeInputToInput(response.inputStream, resultStream);
+  };
+
+  return resultStream;
+}
+
+/**
+ * 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();
+  };
+  source.onData = () => sink.write(source.read());
+  // TODO(nweiz): propagate this error to the sink. See issue 3657.
+  source.onError = (e) { throw e; };
+}
+
+/**
+ * Buffers all input from an InputStream and returns it as a future.
+ */
+Future<List<int>> consumeInputStream(InputStream stream) {
+  var completer = new Completer<List<int>>();
+  var buffer = <int>[];
+  stream.onClosed = () => completer.complete(buffer);
+  stream.onData = () => buffer.addAll(stream.read());
+  stream.onError = (e) => completer.completeException(e);
+  return completer.future;
+}
+
+/**
  * Spawns and runs the process located at [executable], passing in [args].
  * Returns a [Future] that will complete the results of the process after it
  * has ended.
  *
  * If [pipeStdout] and/or [pipeStderr] are set, all output from the subprocess's
  * output streams are sent to the parent process's output streams. Output from
  * piped streams won't be available in the result object.
  */
 Future<PubProcessResult> runProcess(String executable, List<String> args,
     [workingDir, bool pipeStdout = false, bool pipeStderr = false]) {
@@ skipping 74 matching lines @@
   future.handleException((err) {
     // If the process failed, they probably don't have it.
     completer.complete(false);
     return true;
   });
 
   return completer.future;
 }
 
 /**
+ * Extracts a `.tar.gz` file from [stream] to [destination], which can be a
+ * directory or a path. Returns whether or not the extraction was successful.
+ */
+Future<bool> extractTarGz(InputStream stream, destination) {
+  var process = Process.start("tar",
+      ["--extract", "--gunzip", "--directory", _getPath(destination)]);
+  var completer = new Completer<int>();
+
+  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);
+}
+
+/**
  * 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 12 matching lines @@
 }
 
 /**
  * Gets a [Directory] for [entry], which can either already be one, or be a
  * [String].
  */
 Directory _getDirectory(entry) {
   if (entry is Directory) return entry;
   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);
+}