Move package:testing to SDK.

pkg/testing/lib/src/discover.dart

Index: pkg/testing/lib/src/discover.dart
diff --git a/pkg/testing/lib/src/discover.dart b/pkg/testing/lib/src/discover.dart
new file mode 100644
index 0000000000000000000000000000000000000000..219594771b24d36d3db8a1b2cbe10661925776f9
--- /dev/null
+++ b/pkg/testing/lib/src/discover.dart
@@ -0,0 +1,95 @@
+// Copyright (c) 2016, 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.md file.
+
+library testing.discover;
+
+import 'dart:io' show
+    Directory,
+    FileSystemEntity,
+    Platform,
+    Process;
+
+import 'dart:async' show
+    Future,
+    Stream,
+    StreamController,
+    StreamSubscription;
+
+import '../testing.dart' show
+  TestDescription;
+
+final Uri packageConfig = computePackageConfig();
+
+final Uri dartSdk = computeDartSdk();
+
+/// Common arguments when running a dart program. Returns a copy that can
+/// safely be modified by caller.
+List<String> get dartArguments => <String>["-c", "--packages=$packageConfig"];
+
+Stream<TestDescription> listTests(List<Uri> testRoots, {Pattern pattern}) {
+  StreamController<TestDescription> controller =
+      new StreamController<TestDescription>();
+  Map<Uri, StreamSubscription> subscriptions = <Uri, StreamSubscription>{};
+  for (Uri testRootUri in testRoots) {
+    subscriptions[testRootUri] = null;
+    Directory testRoot = new Directory.fromUri(testRootUri);
+    testRoot.exists().then((bool exists) {
+      if (exists) {
+        Stream<FileSystemEntity> stream =
+            testRoot.list(recursive: true, followLinks: false);
+        var subscription = stream.listen((FileSystemEntity entity) {
+          TestDescription description =
+              TestDescription.from(testRootUri, entity, pattern: pattern);
+          if (description != null) {
+            controller.add(description);
+          }
+        }, onError: (error, StackTrace trace) {
+          controller.addError(error, trace);
+        }, onDone: () {
+          subscriptions.remove(testRootUri);
+          if (subscriptions.isEmpty) {
+            controller.close(); // TODO(ahe): catchError???
+          }
+        });
+        subscriptions[testRootUri] = subscription;
+      } else {
+        controller.addError("$testRootUri isn't a directory");
+        subscriptions.remove(testRootUri);
+      }
+      if (subscriptions.isEmpty) {
+        controller.close(); // TODO(ahe): catchError???
+      }
+    });
+  }
+  return controller.stream;
+}
+
+Uri computePackageConfig() {
+  String path = Platform.packageConfig;
+  if (path != null) return Uri.base.resolve(path);
+  return Uri.base.resolve(".packages");
+}
+
+Uri computeDartSdk() {
+  String dartSdkPath = Platform.environment["DART_SDK"]
+      ?? const String.fromEnvironment("DART_SDK");
+  if (dartSdkPath != null) {
+    return Uri.base.resolveUri(new Uri.file(dartSdkPath));
+  } else {
+    return Uri.base.resolve(Platform.resolvedExecutable).resolve("../");
+  }
+}
+
+Future<Process> startDart(
+    Uri program,
+    [List<String> arguments,
+     List<String> vmArguments]) {
+  List<String> allArguments = <String>[];
+  allArguments.addAll(vmArguments ?? dartArguments);
+  allArguments.add(program.toFilePath());
+  if (arguments != null) {
+    allArguments.addAll(arguments);
+  }
+  return Process.start(Platform.resolvedExecutable, allArguments);
+}