test/runner/browser/phantom_js_test.dart - test - Git at Google

 // 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.

 @TestOn("vm")

 import 'dart:async';
 import 'dart:io';

 import 'package:test/test.dart';
 import 'package:test/src/runner/browser/phantom_js.dart';
 import 'package:test/src/util/io.dart';
 import 'package:shelf/shelf.dart' as shelf;
 import 'package:shelf/shelf_io.dart' as shelf_io;
 import 'package:shelf_web_socket/shelf_web_socket.dart';

 import '../../utils.dart';

 void main() {
   group("running JavaScript", () {
     // The JavaScript to serve in the server. We use actual JavaScript here to
     // avoid the pain of compiling to JS in a test
     var javaScript;

     var servePage = (request) {
       var path = request.url.path;

       // We support both shelf 0.5.x and 0.6.x. The former has a leading "/"
       // here, the latter does not.
       if (path.startsWith("/")) path = path.substring(1);

       if (path.isEmpty) {
         return new shelf.Response.ok("""
 <!doctype html>
 <html>
 <head>
   <script src="index.js"></script>
 </head>
 </html>
 """, headers: {'content-type': 'text/html'});
       } else if (path == "index.js") {
         return new shelf.Response.ok(javaScript,
             headers: {'content-type': 'application/javascript'});
       } else {
         return new shelf.Response.notFound(null);
       }
     };

     var server;
     var webSockets;
     setUp(() {
       var webSocketsController = new StreamController();
       webSockets = webSocketsController.stream;

       return shelf_io.serve(
           new shelf.Cascade()
               .add(webSocketHandler(webSocketsController.add))
               .add(servePage).handler,
           'localhost', 0).then((server_) {
         server = server_;
       });
     });

     tearDown(() {
       if (server != null) server.close();

       javaScript = null;
       server = null;
       webSockets = null;
     });

     test("starts PhantomJs with the given URL", () {
       javaScript = '''
 var webSocket = new WebSocket(window.location.href.replace("http://", "ws://"));
 webSocket.addEventListener("open", function() {
   webSocket.send("loaded!");
 });
 ''';
       var phantomJS = new PhantomJS(
           baseUrlForAddress(server.address, server.port));

       return webSockets.first.then((webSocket) {
         return webSocket.first.then(
             (message) => expect(message, equals("loaded!")));
       }).whenComplete(phantomJS.close);
     });

     test("doesn't preserve state across runs", () {
       javaScript = '''
 localStorage.setItem("data", "value");

 var webSocket = new WebSocket(window.location.href.replace("http://", "ws://"));
 webSocket.addEventListener("open", function() {
   webSocket.send("done");
 });
 ''';
       var phantomJS = new PhantomJS(
           baseUrlForAddress(server.address, server.port));

       var first = true;
       webSockets.listen(expectAsync((webSocket) {
         if (first) {
           // The first request will set local storage data. We can't kill the
           // old PhantomJS and start a new one until we're sure that that has
           // finished.
           webSocket.first.then((_) {
             phantomJS.close();

             javaScript = '''
 var webSocket = new WebSocket(window.location.href.replace("http://", "ws://"));
 webSocket.addEventListener("open", function() {
   webSocket.send(localStorage.getItem("data"));
 });
 ''';
             phantomJS = new PhantomJS(
                 baseUrlForAddress(server.address, server.port));
             first = false;
           });
         } else {
           // The second request will return the local storage data. This should
           // be null, indicating that no data was saved between runs.
           expect(
               webSocket.first
                   .then((message) => expect(message, equals('null')))
                   .whenComplete(phantomJS.close),
               completes);
         }
       }, count: 2));
     });
   });

   test("a process can be killed synchronously after it's started", () {
     return shelf_io.serve(expectAsync((_) {}, count: 0), 'localhost', 0)
         .then((server) {
       var phantomJS = new PhantomJS(
           baseUrlForAddress(server.address, server.port));
       return phantomJS.close().whenComplete(server.close);
     });
   });

   test("reports an error in onExit", () {
     var phantomJS = new PhantomJS("http://dart-lang.org",
         executable: "_does_not_exist");
     expect(phantomJS.onExit, throwsA(isApplicationException(startsWith(
         "Failed to start PhantomJS: No such file or directory"))));
   });
 }
	// 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.

	@TestOn("vm")

	import 'dart:async';
	import 'dart:io';

	import 'package:test/test.dart';
	import 'package:test/src/runner/browser/phantom_js.dart';
	import 'package:test/src/util/io.dart';
	import 'package:shelf/shelf.dart' as shelf;
	import 'package:shelf/shelf_io.dart' as shelf_io;
	import 'package:shelf_web_socket/shelf_web_socket.dart';

	import '../../utils.dart';

	void main() {
	group("running JavaScript", () {
	// The JavaScript to serve in the server. We use actual JavaScript here to
	// avoid the pain of compiling to JS in a test
	var javaScript;

	var servePage = (request) {
	var path = request.url.path;

	// We support both shelf 0.5.x and 0.6.x. The former has a leading "/"
	// here, the latter does not.
	if (path.startsWith("/")) path = path.substring(1);

	if (path.isEmpty) {
	return new shelf.Response.ok("""
	<!doctype html>
	<html>
	<head>
	<script src="index.js"></script>
	</head>
	</html>
	""", headers: {'content-type': 'text/html'});
	} else if (path == "index.js") {
	return new shelf.Response.ok(javaScript,
	headers: {'content-type': 'application/javascript'});
	} else {
	return new shelf.Response.notFound(null);
	}
	};

	var server;
	var webSockets;
	setUp(() {
	var webSocketsController = new StreamController();
	webSockets = webSocketsController.stream;

	return shelf_io.serve(
	new shelf.Cascade()
	.add(webSocketHandler(webSocketsController.add))
	.add(servePage).handler,
	'localhost', 0).then((server_) {
	server = server_;
	});
	});

	tearDown(() {
	if (server != null) server.close();

	javaScript = null;
	server = null;
	webSockets = null;
	});

	test("starts PhantomJs with the given URL", () {
	javaScript = '''
	var webSocket = new WebSocket(window.location.href.replace("http://", "ws://"));
	webSocket.addEventListener("open", function() {
	webSocket.send("loaded!");
	});
	''';
	var phantomJS = new PhantomJS(
	baseUrlForAddress(server.address, server.port));

	return webSockets.first.then((webSocket) {
	return webSocket.first.then(
	(message) => expect(message, equals("loaded!")));
	}).whenComplete(phantomJS.close);
	});

	test("doesn't preserve state across runs", () {
	javaScript = '''
	localStorage.setItem("data", "value");

	var webSocket = new WebSocket(window.location.href.replace("http://", "ws://"));
	webSocket.addEventListener("open", function() {
	webSocket.send("done");
	});
	''';
	var phantomJS = new PhantomJS(
	baseUrlForAddress(server.address, server.port));

	var first = true;
	webSockets.listen(expectAsync((webSocket) {
	if (first) {
	// The first request will set local storage data. We can't kill the
	// old PhantomJS and start a new one until we're sure that that has
	// finished.
	webSocket.first.then((_) {
	phantomJS.close();

	javaScript = '''
	var webSocket = new WebSocket(window.location.href.replace("http://", "ws://"));
	webSocket.addEventListener("open", function() {
	webSocket.send(localStorage.getItem("data"));
	});
	''';
	phantomJS = new PhantomJS(
	baseUrlForAddress(server.address, server.port));
	first = false;
	});
	} else {
	// The second request will return the local storage data. This should
	// be null, indicating that no data was saved between runs.
	expect(
	webSocket.first
	.then((message) => expect(message, equals('null')))
	.whenComplete(phantomJS.close),
	completes);
	}
	}, count: 2));
	});
	});

	test("a process can be killed synchronously after it's started", () {
	return shelf_io.serve(expectAsync((_) {}, count: 0), 'localhost', 0)
	.then((server) {
	var phantomJS = new PhantomJS(
	baseUrlForAddress(server.address, server.port));
	return phantomJS.close().whenComplete(server.close);
	});
	});

	test("reports an error in onExit", () {
	var phantomJS = new PhantomJS("http://dart-lang.org",
	executable: "_does_not_exist");
	expect(phantomJS.onExit, throwsA(isApplicationException(startsWith(
	"Failed to start PhantomJS: No such file or directory"))));
	});
	}