1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
|
<!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);
}
async function waitForMessage(receiver, data)
{
while (true) {
const received = await new Promise(resolve => receiver.onmessage = (event) => resolve(event.data));
if (data === received)
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;
};
});
});
const promise = waitForMessage(messageChannel.port1, "OK");
remoteChannel.send("OK");
await promise;
const data = new Promise(resolve => remoteChannel.onmessage = (event) => resolve(event.data));
messageChannel.port1.postMessage({message: "OK2"});
assert_equals(await data, "OK2");
}, "offerer data channel in service worker");
</script>
</body>
</html>
|
