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:uri');
 
+#import('utils.dart');
+
+bool _isGitInstalledCache;
+
 /** 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 98 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 119 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);
   });
 }
 
 /**
  * Given [entry] which may be a [String], [File], or [Directory] relative to
@@ skipping 60 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 36 matching lines @@
 
   process.onError = (error) => completer.completeException(error);
 
   return completer.future;
 }
 
 /**
  * Tests whether or not the git command-line app is available for use.
  */
 Future<bool> get isGitInstalled {
-  // TODO(rnystrom): We could cache this after the first check. We aren't right
-  // now because Future.immediate() will invoke its callback synchronously.
-  // That does bad things in cases where the caller expects futures to always
-  // be async. In particular, withGit() in the pub tests which calls
-  // expectAsync() will fail horribly if the test isn't actually async.
+  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);
+  }
 
   var completer = new Completer<bool>();
 
   // If "git --version" prints something familiar, git is working.
   var future = runProcess("git", ["--version"]);
 
   future.then((results) {
     var regex = new RegExp("^git version");
     completer.complete(results.stdout.length == 1 &&
                        regex.hasMatch(results.stdout[0]));
   });
 
   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) {
+  if (Platform.operatingSystem == "windows") {
+    return _extractTarGzWindows(stream, destination);
+  }
+
+  destination = _getPath(destination);

[nweiz, 2012/09/18 23:07:12]

Why not do this before passing it in to _extractTarGzWindows?

[Bob Nystrom, 2012/09/19 15:57:54]

Done.

+
   var process = Process.start("tar",
-      ["--extract", "--gunzip", "--directory", _getPath(destination)]);
+      ["--extract", "--gunzip", "--directory", 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);
 }
 
+Future<bool> _extractTarGzWindows(InputStream stream, dest) {
+  dest = _getPath(dest);
+
+  // 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"$dest"']);
+
+  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);
+}
+
 /**
  * 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);
 
@@ skipping 21 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);
 }