Index: lib/src/runner/browser/phantom_js.dart |
diff --git a/lib/src/runner/browser/phantom_js.dart b/lib/src/runner/browser/phantom_js.dart |
new file mode 100644 |
index 0000000000000000000000000000000000000000..b4e2f4a40e44ce8326e3be1f6f7a5ffb08d53e9d |
--- /dev/null |
+++ b/lib/src/runner/browser/phantom_js.dart |
@@ -0,0 +1,87 @@ |
+// 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 test.runner.browser.phantom_js; |
+ |
+import 'dart:async'; |
+import 'dart:io'; |
+ |
+import 'package:path/path.dart' as p; |
+ |
+import '../../util/io.dart'; |
+import 'browser.dart'; |
+ |
+/// The PhantomJS script that opens the host page. |
+final _script = """ |
+var system = require('system'); |
+var page = require('webpage').create(); |
+ |
+// Pipe browser messages to the process's stdout. This isn't used by default, |
+// but it can be useful for debugging. |
+page.onConsoleMessage = function(message) { |
+ console.log(message); |
+} |
+ |
+page.open(system.args[1], function(status) { |
+ if (status !== "success") phantom.exit(1); |
+}); |
+"""; |
+ |
+/// A class for running an instance of PhantomJS. |
+/// |
+/// Any errors starting or running the process are reported through [onExit]. |
+class PhantomJS implements Browser { |
+ /// The underlying process. |
+ Process _process; |
+ |
+ Future get onExit => _onExitCompleter.future; |
+ final _onExitCompleter = new Completer(); |
+ |
+ /// A future that completes when the browser process has started. |
+ /// |
+ /// This is used to ensure that [close] works regardless of when it's called. |
+ Future get _onProcessStarted => _onProcessStartedCompleter.future; |
+ final _onProcessStartedCompleter = new Completer(); |
+ |
+ /// Starts a new instance of PhantomJS open to the given [url], which may be a |
+ /// [Uri] or a [String]. |
+ /// |
+ /// If [executable] is passed, it's used as the PhantomJS executable. |
+ /// Otherwise the default executable name for the current OS will be used. |
+ PhantomJS(url, {String executable}) { |
+ if (executable == null) { |
+ executable = Platform.isWindows ? "phantomjs.exe" : "phantomjs"; |
+ } |
+ |
+ // Don't return a Future here because there's no need for the caller to wait |
+ // for the process to actually start. They should just wait for the HTTP |
+ // request instead. |
+ withTempDir((dir) { |
+ var script = p.join(dir, "script.js"); |
+ new File(script).writeAsStringSync(_script); |
+ |
+ return Process.start(executable, [script, url.toString()]) |
+ .then((process) { |
+ // PhantomJS synchronously emits standard output, which means that if we |
+ // don't drain its stdout stream it can deadlock. |
+ process.stdout.listen((_) {}); |
+ |
+ _process = process; |
+ _onProcessStartedCompleter.complete(); |
+ |
+ return _process.exitCode; |
+ }); |
+ }).then((exitCode) { |
+ if (exitCode != 0) throw "PhantomJS failed with exit code $exitCode."; |
+ }).then(_onExitCompleter.complete) |
+ .catchError(_onExitCompleter.completeError); |
+ } |
+ |
+ Future close() { |
+ _onProcessStarted.then((_) => _process.kill()); |
+ |
+ // Swallow exceptions. The user should explicitly use [onExit] for these. |
+ return onExit.catchError((_) {}); |
+ } |
+} |