First pass at getting git and tar.gz working on Windows.

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:uri');
+
 #import('utils.dart');
 
+bool _isGitInstalledCache;
+
+/// The cached Git command.
+String _gitCommandCache;
+
 /** 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 238 matching lines @@
 
   var command = 'ln';
   var args = ['-s', from, to];
 
   if (Platform.operatingSystem == 'windows') {
     // Call mklink on Windows to create an NTFS junction point. Only works on
     // Vista or later. (Junction points are available earlier, but the "mklink"
     // command is not.) I'm using a junction point (/j) here instead of a soft
     // link (/d) because the latter requires some privilege shenanigans that
     // I'm not sure how to specify from the command line.
-    command = 'cmd';
-    args = ['/c', 'mklink', '/j', to, from];
+    command = 'mklink';
+    args = ['/j', to, from];
   }
 
   return runProcess(command, args).transform((result) {
     // TODO(rnystrom): Check exit code and output?
     return new File(to);
   });
 }
 
 /**
  * Creates a new symlink that creates an alias from the package [from] to [to],
@@ skipping 73 matching lines @@
 
   var completer = new Completer<InputStream>();
   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.osError.errorCode == -2 ||
-         e.osError.errorCode == -5)) {
+         e.osError.errorCode == -5 ||
+         e.osError.errorCode == 11004)) {
       e = 'Could not resolve URL "${uri.origin}".';
     }
 
     client.shutdown();
     completer.completeException(e);
   };
 
   connection.onResponse = (response) {
     if (response.statusCode >= 400) {
       client.shutdown();
@@ skipping 53 matching lines @@
  *
  * 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, Map<String, String> environment, bool pipeStdout = false,
     bool pipeStderr = false]) {
   int exitCode;
 
+  // TODO(rnystrom): Should dart:io just handle this?
+  // Spawning a process on Windows will not look for the executable in the
+  // system path. So, if executable looks like it needs that (i.e. it doesn't
+  // have any path separators in it), then spawn it through a shell.
+  if ((Platform.operatingSystem == "windows") &&
+      (executable.indexOf('\\') == -1)) {
+    args = flatten(["/c", executable, args]);
+    executable = "cmd";
+  }
+
   final options = new ProcessOptions();
   if (workingDir != null) {
     options.workingDirectory = _getDirectory(workingDir).path;
   }
   options.environment = environment;
 
   final process = Process.start(executable, args, options);
 
   final outStream = new StringInputStream(process.stdout);
   final processStdout = <String>[];
@@ skipping 61 matching lines @@
     return true;
   });
   input.then((value) {
     if (completer.future.isComplete) return;
     timer.cancel();
     completer.complete(value);
   });
   return completer.future;
 }
 
-/// The cached Git command.
-String _gitCommandCache;
+/// Tests whether or not the git command-line app is available for use.
+Future<bool> get isGitInstalled {
+  if (_isGitInstalledCache != null) {
+    // TODO(rnystrom): The sleep is to pump the message queue. Can use
+    // Future.immediate() when #3356 is fixed.
+    return sleep(0).transform((_) => _isGitInstalledCache);
 
-/// Tests whether or not the git command-line app is available for use.
-Future<bool> get isGitInstalled => _gitCommand.transform((git) => git != null);
+    return _gitCommand.transform((git) => git != null);
+  }
+}
 
 /// Run a git process with [args] from [workingDir].
 Future<PubProcessResult> runGit(List<String> args, [String workingDir]) =>
-  _gitCommand.chain((git) => runProcess(git, args, workingDir));
+    _gitCommand.chain((git) => runProcess(git, args, workingDir));
 
 /// Returns the name of the git command-line app, or null if Git could not be
 /// found on the user's PATH.
 Future<String> get _gitCommand {
   // TODO(nweiz): Just use Future.immediate once issue 3356 is fixed.
   if (_gitCommandCache != null) {
     return sleep(0).transform((_) => _gitCommandCache);
   }
 
   return _tryGitCommand("git").chain((success) {
@@ skipping 30 matching lines @@
   });
 
   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) {
+  destination = _getPath(destination);
+
+  if (Platform.operatingSystem == "windows") {
+    return _extractTarGzWindows(stream, destination);
+  }
+
   var process = Process.start("tar",
-      ["--extract", "--gunzip", "--directory", _getPath(destination)]);
+      ["--extract", "--gunzip", "--directory", destination]);
   var completer = new Completer<int>();
 
   // Wait for the process to be fully started before writing to its
   // stdin stream.
   process.onStart = () {
     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);
 }
 
+Future<bool> _extractTarGzWindows(InputStream stream, String destination) {
+  // Find 7zip.
+  var scriptDir = new Path(new Options().script).directoryPath;
+
+  // Note: This line of code gets munged by create_sdk.py to be the correct
+  // relative path to 7zip in the SDK.
+  var pathTo7zip = '../../third_party/7zip/7za.exe';
+
+  var command = scriptDir.append(pathTo7zip).canonicalize().toNativePath();
+
+  // 7zip can't unarchive from gzip -> tar -> destination all in one step so
+  // we spawn it twice and pipe them together.
+  var completer = new Completer<int>();
+  var gzipProcess = Process.start(command, ["e", "-si", "-tgzip", '-so']);
+  var tarProcess = Process.start(command,
+      ["e", "-si", "-ttar", '-o"$destination"']);
+
+  stream.pipe(gzipProcess.stdin);
+  gzipProcess.stdout.pipe(tarProcess.stdin);
+
+  tarProcess.onExit = completer.complete;
+  gzipProcess.onError = completer.completeException;
+  gzipProcess.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);
 }
 
@@ skipping 40 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);
 }