| <!DOCTYPE html> |
| <title>Tests that postMessage works during and after terminating a service worker</title> |
| <script src="/resources/testharness.js"></script> |
| <script src="/resources/testharnessreport.js"></script> |
| <script src="resources/test-helpers.js"></script> |
| <script> |
| function send_ping(worker) { |
| return new Promise(function(resolve) { |
| var channel = new MessageChannel(); |
| channel.port1.onmessage = function(message) { |
| resolve(message.data); |
| }; |
| worker.postMessage({port: channel.port2}, [channel.port2]); |
| }); |
| } |
| |
| function delay(ms) { |
| return new Promise(function(resolve) { |
| window.setTimeout(resolve, ms); |
| }); |
| } |
| |
| promise_test(function(test) { |
| var worker = 'resources/ping-worker.js'; |
| var scope = 'resources/blank.html'; |
| var sw; |
| return service_worker_unregister_and_register(test, worker, scope) |
| .then(function(registration) { |
| sw = registration.installing; |
| return send_ping(sw); |
| }) |
| .then(function(reply) { |
| assert_equals(reply, 0); |
| return internals.terminateServiceWorker(sw); |
| }) |
| .then(function() { |
| return send_ping(sw); |
| }) |
| .then(function(reply) { |
| assert_equals(reply, 0); |
| return send_ping(sw); |
| }) |
| .then(function(reply) { |
| assert_equals(reply, 1); |
| return service_worker_unregister_and_done(test, scope); |
| }); |
| }, 'postMessage to a terminated service worker.'); |
| |
| async_test(function(t) { |
| var worker_script = 'resources/postmessage-worker.js'; |
| var scope = 'resources/postmessage-worker-scope'; |
| var worker; |
| var registration; |
| var port; |
| |
| service_worker_unregister_and_register( |
| t, worker_script, scope) |
| .then(function(r) { |
| registration = r; |
| return wait_for_state(t, r.installing, 'activated'); |
| }) |
| .then(function() { |
| worker = registration.active; |
| return internals.terminateServiceWorker(worker); |
| }) |
| .then(function() { |
| var messageChannel = new MessageChannel(); |
| port = messageChannel.port1; |
| port.onmessage = t.step_func(on_message); |
| port.postMessage({value: 0}); |
| worker.postMessage({port: messageChannel.port2}, |
| [messageChannel.port2]); |
| port.postMessage({value: 1}); |
| // Asynchronously sending more messages gives chrome a chance to be in |
| // a slightly different state, so wait a minimal amount of time. |
| return delay(1); |
| }) |
| .then(function() { |
| port.postMessage({value: 2}); |
| port.postMessage({done: true}); |
| }) |
| .catch(unreached_rejection(t)); |
| |
| var result = []; |
| var expected = [ |
| 'Acking value: 0', |
| 'Acking value: 1', |
| 'Acking value: 2', |
| ]; |
| |
| function on_message(e) { |
| var message = e.data; |
| if (message === 'quit') { |
| assert_array_equals(result, expected, |
| 'Worker should post back expected values.'); |
| service_worker_unregister_and_done(t, scope); |
| } else { |
| result.push(message); |
| } |
| } |
| }, 'postMessage on a port that was sent to a terminated service worker'); |
| |
| async_test(function(t) { |
| var worker_script = 'resources/postmessage-port-worker.js'; |
| var scope = 'resources/postmessage-port-worker-scope'; |
| var worker; |
| var registration; |
| var port; |
| |
| service_worker_unregister_and_register( |
| t, worker_script, scope) |
| .then(function(r) { |
| registration = r; |
| return wait_for_state(t, r.installing, 'activated'); |
| }) |
| .then(function() { |
| worker = registration.active; |
| return internals.terminateServiceWorker(worker); |
| }) |
| .then(function() { |
| var innerChannel = new MessageChannel(); |
| var outerChannel = new MessageChannel(); |
| port = innerChannel.port1; |
| port.onmessage = t.step_func(on_message); |
| port.postMessage({value: 0}); |
| outerChannel.port1.postMessage({port: innerChannel.port2}, |
| [innerChannel.port2]); |
| worker.postMessage({port: outerChannel.port2}, [outerChannel.port2]); |
| port.postMessage({value: 1}); |
| // Asynchronously sending more messages gives chrome a chance to be in |
| // a slightly different state, so wait a minimal amount of time. |
| return delay(1); |
| }) |
| .then(function() { |
| port.postMessage({value: 2}); |
| port.postMessage({done: true}); |
| }) |
| .catch(unreached_rejection(t)); |
| |
| var result = []; |
| var expected = [ |
| 'Acking value: 0', |
| 'Acking value: 1', |
| 'Acking value: 2', |
| ]; |
| |
| function on_message(e) { |
| var message = e.data; |
| if (message === 'quit') { |
| assert_array_equals(result, expected, |
| 'Worker should post back expected values.'); |
| service_worker_unregister_and_done(t, scope); |
| } else { |
| result.push(message); |
| } |
| } |
| }, 'postMessage on a port that was sent on a port that was sent to a terminated service worker'); |
| </script> |