-
Notifications
You must be signed in to change notification settings - Fork 3.2k
/
Copy pathRTCPeerConnection-onsignalingstatechanged.https.html
71 lines (62 loc) · 2.5 KB
/
RTCPeerConnection-onsignalingstatechanged.https.html
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
<!doctype html>
<meta charset=utf-8>
<title>RTCPeerConnection onsignalingstatechanged</title>
<script src="/resources/testharness.js"></script>
<script src="/resources/testharnessreport.js"></script>
<script src="RTCPeerConnection-helper.js"></script>
<script>
promise_test(async t => {
const [track] = (await getNoiseStream({video: true})).getTracks();
t.add_cleanup(() => track.stop());
const pc1 = new RTCPeerConnection();
t.add_cleanup(() => pc1.close());
const pc2 = new RTCPeerConnection();
t.add_cleanup(() => pc2.close());
pc1.addTrack(track, new MediaStream());
await pc1.setLocalDescription(await pc1.createOffer());
const events = [];
pc2.onsignalingstatechange = t.step_func(e => {
const [transceiver] = pc2.getTransceivers();
assert_equals(transceiver.currentDirection, null);
events.push(pc2.signalingState);
});
await pc2.setRemoteDescription(pc1.localDescription);
assert_equals(events.length, 1, "event fired");
assert_equals(events[0], "have-remote-offer");
pc2.onsignalingstatechange = t.step_func(e => {
const [transceiver] = pc2.getTransceivers();
assert_equals(transceiver.currentDirection, "recvonly");
events.push(pc2.signalingState);
});
await pc2.setLocalDescription(await pc2.createAnswer());
assert_equals(events.length, 2, "event fired");
assert_equals(events[1], "stable");
}, 'Negotiation methods fire signalingstatechange events');
promise_test(async t => {
const pc1 = new RTCPeerConnection();
t.add_cleanup(() => pc1.close());
const pc2 = new RTCPeerConnection();
const stream = await getNoiseStream({ audio: true });
t.add_cleanup(() => stream.getTracks().forEach(track => track.stop()));
stream.getTracks().forEach(track => pc1.addTrack(track, stream));
exchangeIceCandidates(pc1, pc2);
exchangeOfferAnswer(pc1, pc2);
await listenToIceConnected(pc2);
pc2.onsignalingstatechange = t.unreached_func();
pc2.close();
assert_equals(pc2.signalingState, 'closed');
await new Promise(r => t.step_timeout(r, 100));
}, 'Closing a PeerConnection should not fire signalingstatechange event');
promise_test(async t => {
const pc1 = new RTCPeerConnection();
t.add_cleanup(() => pc1.close());
const pc2 = new RTCPeerConnection();
t.add_cleanup(() => pc2.close());
pc2.addTransceiver('video');
pc1.ontrack = t.unreached_func();
pc1.onsignalingstatechange = t.step_func(e => {
pc1.ontrack = null;
});
await pc1.setRemoteDescription(await pc2.createOffer());
}, 'signalingstatechange is the first event to fire');
</script>