Index: test/current_isolate_info_test.dart |
diff --git a/test/current_isolate_info_test.dart b/test/current_isolate_info_test.dart |
new file mode 100644 |
index 0000000000000000000000000000000000000000..bb6f4f7d93389eaa3d5c5387817449cc66e8f152 |
--- /dev/null |
+++ b/test/current_isolate_info_test.dart |
@@ -0,0 +1,233 @@ |
+// 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 file. |
+ |
+import 'dart:async'; |
+import 'dart:convert'; |
+import 'dart:io'; |
+import 'dart:isolate'; |
+ |
+import 'package:path/path.dart' as p; |
+import 'package:stack_trace/stack_trace.dart'; |
+import 'package:test/test.dart'; |
+ |
+import 'package:package_resolver/package_resolver.dart'; |
+ |
+void main() { |
+ // It's important to test these, because they use PackageConfig.current and |
+ // they're used to verify the output of the inner isolate's |
+ // PackageConfig.current. |
+ test("_packageResolverLibUri is correct", () async { |
+ var libPath = p.fromUri(await _packageResolverLibUri); |
+ expect(new File(p.join(libPath, 'package_resolver.dart')).exists(), |
+ completion(isTrue)); |
+ }); |
+ |
+ test("_pathLibUri is correct", () async { |
+ var libPath = p.fromUri(await _pathLibUri); |
+ expect(new File(p.join(libPath, 'path.dart')).exists(), completion(isTrue)); |
+ }); |
+ |
+ group("with a package config", () { |
+ var resolver; |
+ setUp(() async { |
+ var map; |
+ var currentIsolateMap = await PackageResolver.current.packageConfigMap; |
+ if (currentIsolateMap != null) { |
+ map = new Map.from(currentIsolateMap); |
+ } else { |
+ // If the isolate running this test isn't using package config, create |
+ // one from scratch with the same resolution semantics. |
+ var map = {}; |
+ var root = p.fromUri(await PackageResolver.current.packageRoot); |
+ await for (var link in new Directory(root).list(followLinks: false)) { |
+ assert(link is Link); |
+ map[p.basename(link.path)] = |
+ p.toUri(await link.resolveSymbolicLinks()); |
+ } |
+ } |
+ |
+ // Ensure that we have at least one URI that ends with "/" and one that |
+ // doesn't. Both of these cases need to be tested. |
+ expect(map["package_resolver"].path, endsWith("/")); |
+ map["path"] = Uri.parse(p.url.normalize(map["path"].toString())); |
+ expect(map["path"].path, isNot(endsWith("/"))); |
+ |
+ resolver = new PackageResolver.config(map); |
+ }); |
+ |
+ test("exposes the config map", () async { |
+ expect(await _spawn("""() async { |
+ var serializable = {}; |
+ (await PackageResolver.current.packageConfigMap) |
+ .forEach((package, uri) { |
+ serializable[package] = uri.toString(); |
+ }); |
+ return serializable; |
+ }()""", resolver), |
+ containsPair("package_resolver", await _packageResolverLibUri)); |
+ }); |
+ |
+ test("exposes the config URI", () async { |
+ expect( |
+ await _spawn( |
+ "(await PackageResolver.current.packageConfigUri).toString()", |
+ resolver), |
+ equals((await resolver.packageConfigUri).toString())); |
+ }); |
+ |
+ test("exposes a null package root", () async { |
+ expect( |
+ // Use "== null" because if it *is* a URI, it'll crash the isolate |
+ // when we try to send it over the port. |
+ await _spawn( |
+ "(await PackageResolver.current.packageRoot) == null", resolver), |
+ isTrue); |
+ }); |
+ |
+ test("processArgument uses --packages", () async { |
+ expect( |
+ await _spawn("PackageResolver.current.processArgument", resolver), |
+ equals(await resolver.processArgument)); |
+ }); |
+ |
+ group("resolveUri", () { |
+ test("with a matching package", () async { |
+ expect(await _spawn("""() async { |
+ var uri = await PackageResolver.current.resolveUri( |
+ 'package:package_resolver/foo/bar.dart'); |
+ return uri.toString(); |
+ }()""", resolver), |
+ equals(p.url.join(await _packageResolverLibUri, "foo/bar.dart"))); |
+ |
+ expect(await _spawn("""() async { |
+ var uri = await PackageResolver.current.resolveUri( |
+ 'package:path/foo/bar.dart'); |
+ return uri.toString(); |
+ }()""", resolver), |
+ equals(p.url.join(await _pathLibUri, "foo/bar.dart"))); |
+ }); |
+ |
+ test("with a matching package with no path", () async { |
+ expect(await _spawn("""() async { |
+ var uri = await PackageResolver.current.resolveUri( |
+ 'package:package_resolver'); |
+ return uri == null; |
+ }()""", resolver), isTrue); |
+ |
+ expect(await _spawn("""() async { |
+ var uri = await PackageResolver.current.resolveUri('package:path'); |
+ return uri == null; |
+ }()""", resolver), isTrue); |
+ }); |
+ |
+ test("with a matching package with an empty path", |
+ () async { |
+ expect(await _spawn("""() async { |
+ var uri = await PackageResolver.current.resolveUri( |
+ 'package:package_resolver/'); |
+ return uri.toString(); |
+ }()""", resolver), (await _packageResolverLibUri).toString()); |
+ |
+ expect(await _spawn("""() async { |
+ var uri = await PackageResolver.current.resolveUri('package:path/'); |
+ return uri.toString(); |
+ }()""", resolver), (await _pathLibUri).toString()); |
+ }); |
+ |
+ test("with a URI object", () async { |
+ expect(await _spawn("""() async { |
+ var uri = await PackageResolver.current.resolveUri( |
+ Uri.parse('package:package_resolver/foo/bar.dart')); |
+ return uri.toString(); |
+ }()""", resolver), |
+ equals(p.url.join(await _packageResolverLibUri, 'foo/bar.dart'))); |
+ }); |
+ |
+ test("with a non-matching package", () async { |
+ expect(await _spawn("""() async { |
+ var uri = await PackageResolver.current.resolveUri( |
+ Uri.parse('package:not-a-package/foo/bar.dart')); |
+ return uri == null; |
+ }()""", resolver), isTrue); |
+ }); |
+ |
+ test("with an invalid argument type", () async { |
+ expect(await _spawn("""() async { |
+ try { |
+ await PackageResolver.current.resolveUri(12); |
+ return false; |
+ } on ArgumentError catch (_) { |
+ return true; |
+ } |
+ }()""", resolver), isTrue); |
+ }); |
+ |
+ test("with a non-package URI", () async { |
+ expect(await _spawn("""() async { |
+ try { |
+ await PackageResolver.current.resolveUri('file:///zip/zap'); |
+ return false; |
+ } on FormatException catch (_) { |
+ return true; |
+ } |
+ }()""", resolver), isTrue); |
+ }); |
+ |
+ test("with an invalid package URI", () async { |
+ expect(await _spawn("""() async { |
+ try { |
+ await PackageResolver.current.resolveUri("package:"); |
+ return false; |
+ } on FormatException catch (_) { |
+ return true; |
+ } |
+ }()""", resolver), isTrue); |
+ }); |
+ }); |
+ }); |
+} |
+ |
+Future<String> get _packageResolverLibUri async => |
+ (await PackageResolver.current.urlFor("package_resolver")).toString(); |
+ |
+Future<String> get _pathLibUri async => |
+ (await PackageResolver.current.urlFor("path")).toString(); |
+ |
+Future _spawn(String expression, PackageResolver packageResolver) async { |
+ var data = new UriData.fromString(""" |
+ import 'dart:convert'; |
+ import 'dart:isolate'; |
+ |
+ import 'package:package_resolver/package_resolver.dart'; |
+ |
+ main(_, SendPort message) async { |
+ message.send(await ($expression)); |
+ } |
+ """, mimeType: "application/dart", parameters: {"charset": "utf-8"}); |
+ |
+ var receivePort = new ReceivePort(); |
+ var errorPort = new ReceivePort(); |
+ try { |
+ var isolate = await Isolate.spawnUri(data.uri, [], receivePort.sendPort, |
+ packageRoot: await packageResolver.packageRoot, |
+ packageConfig: await packageResolver.packageConfigUri, |
+ paused: true); |
+ |
+ isolate.addErrorListener(errorPort.sendPort); |
+ errorPort.listen((message) { |
+ registerException(message[0], |
+ message[1] == null ? null : new Trace.parse(message[1])); |
+ errorPort.close(); |
+ receivePort.close(); |
+ }); |
+ isolate.resume(isolate.pauseCapability); |
+ |
+ var value = await receivePort.first; |
+ isolate.kill(); |
+ return value; |
+ } finally { |
+ errorPort.close(); |
+ receivePort.close(); |
+ } |
+} |