| <!doctype html> |
| <html> |
| <head> |
| <meta charset="utf-8"> |
| <script src="/resources/testharness.js"></script> |
| <script src="/resources/testharnessreport.js"></script> |
| </head> |
| <body> |
| <script src="/service-workers/service-worker/resources/test-helpers.sub.js"></script> |
| <script> |
| async function createConnections(test, firstConnectionCallback, secondConnectionCallback) |
| { |
| const pc1 = new RTCPeerConnection(); |
| const pc2 = new RTCPeerConnection(); |
| |
| test.add_cleanup(() => pc1.close()); |
| test.add_cleanup(() => pc2.close()); |
| |
| pc1.onicecandidate = (e) => pc2.addIceCandidate(e.candidate); |
| pc2.onicecandidate = (e) => pc1.addIceCandidate(e.candidate); |
| |
| firstConnectionCallback(pc1); |
| |
| const offer = await pc1.createOffer(); |
| await pc1.setLocalDescription(offer); |
| await pc2.setRemoteDescription(offer); |
| |
| secondConnectionCallback(pc2); |
| |
| const answer = await pc2.createAnswer(); |
| await pc2.setLocalDescription(answer); |
| await pc1.setRemoteDescription(answer); |
| } |
| |
| function waitForMessage(receiver, data) |
| { |
| return new Promise(async (resolve, reject) => { |
| setTimeout(() => reject("waitForMessage for " + data + " timed out"), 5000); |
| while (true) { |
| const received = await new Promise(resolve => receiver.onmessage = (event) => resolve(event.data)); |
| if (data === received) { |
| resolve(); |
| return; |
| } |
| } |
| }); |
| } |
| |
| promise_test(async (test) => { |
| let frame; |
| const scope = 'resources/'; |
| const script = 'transfer-datachannel-service-worker.js'; |
| |
| await service_worker_unregister(test, scope); |
| const registration = await navigator.serviceWorker.register(script, {scope}); |
| test.add_cleanup(async () => { |
| return service_worker_unregister(test, scope); |
| }); |
| const worker = registration.installing; |
| |
| const messageChannel = new MessageChannel(); |
| |
| let localChannel; |
| let remoteChannel; |
| |
| await new Promise((resolve, reject) => { |
| createConnections(test, (firstConnection) => { |
| localChannel = firstConnection.createDataChannel('sendDataChannel'); |
| worker.postMessage({channel: localChannel, port: messageChannel.port2}, [localChannel, messageChannel.port2]); |
| }, (secondConnection) => { |
| secondConnection.ondatachannel = (event) => { |
| remoteChannel = event.channel; |
| remoteChannel.onopen = resolve; |
| }; |
| }); |
| setTimeout(() => reject("createConnections timed out"), 5000); |
| }); |
| |
| const promise = waitForMessage(messageChannel.port1, "OK"); |
| remoteChannel.send("OK"); |
| await promise; |
| }, "offerer data channel in service worker"); |
| </script> |
| </body> |
| </html> |
