pkg/unittest: Add a server for serving test assets to browsers.

lib/src/runner/loader.dart

 // Copyright (c) 2015, 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 unittest.runner.loader;
 
 import 'dart:async';
 import 'dart:io';
 import 'dart:isolate';
 
 import 'package:path/path.dart' as p;
 
 import '../backend/suite.dart';
 import '../util/dart.dart';
 import '../util/io.dart';

[kevmoo, 2015/03/04 23:41:04]

unused import

[nweiz, 2015/03/05 01:08:02]

This is needed for [packageRootFor].

 import '../util/remote_exception.dart';
 import 'vm/isolate_test.dart';
 import 'load_exception.dart';
 
 /// A class for finding test files and loading them into a runnable form.
 class Loader {
   /// The package root to use for loading tests, or `null` to use the automatic
   /// root.
   final String _packageRoot;
 
@@ skipping 22 matching lines @@
       // isolates failing to load without stopping the rest.
       return loadFile(entry.path);
     })).then((suites) => suites.toSet()..remove(null));
   }
 
   /// Loads a test suite from the file at [path].
   ///
   /// This will throw a [LoadException] if the file fails to load.
   Future<Suite> loadFile(String path) {
     // TODO(nweiz): Support browser tests.
-    var packageRoot = _packageRoot == null
-        ? p.join(p.dirname(path), 'packages')
-        : _packageRoot;
-
-    if (!new Directory(packageRoot).existsSync()) {
-      throw new LoadException(path, "Directory $packageRoot does not exist.");
-    }
-
+    var packageRoot = packageRootFor(path, _packageRoot);
     var receivePort = new ReceivePort();
     return runInIsolate('''
 import "package:unittest/src/runner/vm/isolate_listener.dart";
 
 import "${p.toUri(p.absolute(path))}" as test;
 
 void main(_, Map message) {
   var sendPort = message['reply'];
   IsolateListener.start(sendPort, () => test.main);
 }
 ''', {
       'reply': receivePort.sendPort
-    }, packageRoot: packageRoot).catchError((error, stackTrace) {
+    }, packageRoot: packageRoot)
+        .catchError((error, stackTrace) {
       receivePort.close();
       return new Future.error(new LoadException(path, error), stackTrace);
     }).then((isolate) {
       _isolates.add(isolate);
       return receivePort.first;
     }).then((response) {
       if (response["type"] == "loadException") {
         return new Future.error(new LoadException(path, response["message"]));
       } else if (response["type"] == "error") {
         var asyncError = RemoteException.deserialize(response["error"]);
@@ skipping 10 matching lines @@
 
   /// Closes the loader and releases all resources allocated by it.
   Future close() {
     for (var isolate in _isolates) {
       isolate.kill();
     }
     _isolates.clear();
     return new Future.value();
   }
 }