Load web tests using the plugin infrastructure.

lib/src/runner/browser/static/host.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.
 
 import 'dart:async';
 import 'dart:convert';
 import 'dart:html';
 import 'dart:js' as js;
 
 import 'package:stack_trace/stack_trace.dart';
@@ skipping 70 matching lines @@
       } else if (message['command'] == 'displayPause') {
         document.body.classes.add('paused');
       } else if (message['command'] == 'resume') {
         document.body.classes.remove('paused');
       } else {
         assert(message['command'] == 'closeSuite');
         _iframes[message['id']].remove();
       }
     });
 
+    // Send periodic pings to the test runner so it can know when the browser is
+    // paused for debugging.
+    new Timer.periodic(new Duration(seconds: 1),

[kevmoo, 2016/02/17 16:22:48]

const Duration?

+        (_) => serverChannel.sink.add({"command": "ping"}));
+
     var play = document.querySelector("#play");
     play.onClick.listen((_) {
       document.body.classes.remove('paused');
       serverChannel.sink.add({"command": "resume"});
     });
   }, onError: (error, stackTrace) {
     print("$error\n${new Trace.from(stackTrace).terse}");
   });
 }
 
 /// Creates a [MultiChannel] connection to the server, using a [WebSocket] as
 /// the underlying protocol.
 MultiChannel _connectToServer() {
   // The `managerUrl` query parameter contains the WebSocket URL of the remote
   // [BrowserManager] with which this communicates.
   var currentUrl = Uri.parse(window.location.href);
   var webSocket = new WebSocket(currentUrl.queryParameters['managerUrl']);
 
-  var inputController = new StreamController(sync: true);
+  var controller = new StreamChannelController(sync: true);
   webSocket.onMessage.listen((message) {
-    inputController.add(JSON.decode(message.data));
+    controller.local.sink.add(JSON.decode(message.data));
   });
 
-  var outputController = new StreamController(sync: true);
-  outputController.stream.listen(
+  controller.local.stream.listen(
       (message) => webSocket.send(JSON.encode(message)));
 
-  return new MultiChannel(
-      new StreamChannel(inputController.stream, outputController.sink));
+  return new MultiChannel(controller.foreign);
 }
 
 /// Creates an iframe with `src` [url] and establishes a connection to it using
 /// `postMessage`.
 ///
 /// [id] identifies the suite loaded in this iframe.
 StreamChannel _connectToIframe(String url, int id) {
   var iframe = new IFrameElement();
   _iframes[id] = iframe;
   iframe.src = url;
   document.body.children.add(iframe);
 
-  var inputController = new StreamController(sync: true);
-  var outputController = new StreamController(sync: true);
+  var controller = new StreamChannelController(sync: true);
 
   // Use this to avoid sending a message to the iframe before it's sent a
   // message to us. This ensures that no messages get dropped on the floor.
   var readyCompleter = new Completer();
 
   // TODO(nweiz): use MessageChannel once Firefox supports it
   // (http://caniuse.com/#search=MessageChannel).
   window.onMessage.listen((message) {
     // A message on the Window can theoretically come from any website. It's
     // very unlikely that a malicious site would care about hacking someone's
     // unit tests, let alone be able to find the test server while it's
     // running, but it's good practice to check the origin anyway.
     if (message.origin != window.location.origin) return;
 
     // TODO(nweiz): Stop manually checking href here once issue 22554 is
     // fixed.
     if (message.data["href"] != iframe.src) return;
 
     message.stopPropagation();
-    inputController.add(message.data["data"]);
-    if (!readyCompleter.isCompleted) readyCompleter.complete();
+
+    // This message indicates that the iframe is actively listening for events.
+    if (message.data["ready"] == true) {
+      readyCompleter.complete();
+    } else {
+      controller.local.sink.add(message.data["data"]);
+    }
   });
 
-  outputController.stream.listen((message) async {
+  controller.local.stream.listen((message) async {
     await readyCompleter.future;
-    iframe.contentWindow.postMessage(message, window.location.origin);
+
+    // JSON-encode the message to work around sdk#25636, which caused the
+    // structured clone algorithm to be broken with Window.postMessage in
+    // 1.14.{0,1,2}. Once we no longer care about these Dartiums, stop encoding.
+    iframe.contentWindow.postMessage(
+        JSON.encode(message), window.location.origin);
   });
 
-  return new StreamChannel(inputController.stream, outputController.sink);
+  return controller.foreign;
 }