Initial implementation of stashed message ports, layout tests

LayoutTests/http/tests/serviceworker/resources/stashed-ports-worker.js

+importScripts('worker-testharness.js');
+
+// Helper method that waits for a reply on a port, and resolves a promise with
+// the reply.
+function wait_for_reply(test, port) {

[scheib, 2015/05/06 22:36:18]

wait_for_reply, wait_for_message, very similar names, work differently, how
about:

wait_for_message_on_port
wait_for_message_from_source

[Marijn Kruisselbrink, 2015/05/13 02:46:02]

Done.

+  return new Promise(function(resolve) {
+    var resolved = false;
+    port.onmessage = test.step_func(function(event) {
+      assert_false(resolved);
+      resolved = true;
+      resolve(event.data);
+    });
+  });
+}
+
+test(function(test) {
+    var channel = new MessageChannel();
+    var name = 'somename';
+    var stashed_port = self.ports.add(name, channel.port1);
+    assert_equals(stashed_port.name, name);
+  }, 'Name set when adding port is set correctly.');
+
+promise_test(function(test) {
+    var channel = new MessageChannel();
+    var stashed_port = self.ports.add('', channel.port1);
+    stashed_port.postMessage('pingy ping');
+    return wait_for_reply(test, channel.port2)
+      .then(test.step_func(function(reply) {
+          assert_equals(reply, 'pingy ping');
+      }));
+  }, 'Messages posted into stashed port arrive on other side.');
+
+function wait_for_message(test, name) {
+  return new Promise(function(resolve) {
+    var event_handler = function(e) {
+      if (e.source.name === name) {
+        self.ports.removeEventListener('message', event_handler);
+        resolve(e);
+      }
+    };
+    self.ports.addEventListener('message', event_handler);
+  });
+}
+
+promise_test(function(test) {
+    var channel = new MessageChannel();
+    var name = 'test_events';
+    var stashed_port = self.ports.add(name, channel.port1);
+    channel.port2.postMessage('ping blah');
+    return wait_for_message(test, name)
+      .then(test.step_func(function(reply) {
+          assert_equals(reply.data, 'ping blah');
+          assert_equals(reply.source, stashed_port);
+      }));
+  }, 'Messages send to stashed port arrive as global events.');

[scheib, 2015/05/06 22:36:18]

send -> sent

[Marijn Kruisselbrink, 2015/05/13 02:46:02]

Done.