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
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
|
<!doctype html>
<meta charset=utf-8>
<meta name="timeout" content="long">
<title>RTCPeerConnection BUNDLE</title>
<script src="/resources/testharness.js"></script>
<script src="/resources/testharnessreport.js"></script>
<script src="../RTCPeerConnection-helper.js"></script>
<script>
'use strict';
promise_test(async t => {
const caller = new RTCPeerConnection();
t.add_cleanup(() => caller.close());
const callee = new RTCPeerConnection();
t.add_cleanup(() => callee.close());
const stream = await getNoiseStream({audio: true, video: true});
t.add_cleanup(() => stream.getTracks().forEach(track => track.stop()));
stream.getTracks().forEach(track => caller.addTrack(track, stream));
exchangeIceCandidates(caller, callee);
const offer = await caller.createOffer();
// remove the a=group:BUNDLE from the SDP when signaling.
const sdp = offer.sdp.replace(/a=group:BUNDLE (.*)\r\n/, '');
const ontrack = new Promise(r => callee.ontrack = r);
await callee.setRemoteDescription({type: 'offer', sdp});
await caller.setLocalDescription(offer);
const answer = await callee.createAnswer();
await caller.setRemoteDescription(answer);
await callee.setLocalDescription(answer);
const {streams: [recvStream]} = await ontrack;
assert_equals(recvStream.getTracks().length, 2, "Tracks should be added to the stream before sRD resolves.");
const v = document.createElement('video');
v.autoplay = true;
v.srcObject = recvStream;
v.id = recvStream.id;
await new Promise(r => v.onloadedmetadata = r);
const senders = caller.getSenders();
const dtlsTransports = senders.map(s => s.transport);
assert_equals(dtlsTransports.length, 2);
assert_not_equals(dtlsTransports[0], dtlsTransports[1]);
const iceTransports = dtlsTransports.map(t => t.iceTransport);
assert_equals(iceTransports.length, 2);
assert_not_equals(iceTransports[0], iceTransports[1]);
}, 'not negotiating BUNDLE creates two separate ice and dtls transports');
promise_test(async t => {
const caller = new RTCPeerConnection();
t.add_cleanup(() => caller.close());
const callee = new RTCPeerConnection();
t.add_cleanup(() => callee.close());
const stream = await getNoiseStream({audio: true, video: true});
t.add_cleanup(() => stream.getTracks().forEach(track => track.stop()));
stream.getTracks().forEach(track => caller.addTrack(track, stream));
exchangeIceCandidates(caller, callee);
const offer = await caller.createOffer();
const ontrack = new Promise(r => callee.ontrack = r);
await callee.setRemoteDescription(offer);
await caller.setLocalDescription(offer);
const secondTransport = caller.getSenders()[1].transport; // Save a reference to this transport.
const answer = await callee.createAnswer();
await caller.setRemoteDescription(answer);
await callee.setLocalDescription(answer);
const {streams: [recvStream]} = await ontrack;
assert_equals(recvStream.getTracks().length, 2, "Tracks should be added to the stream before sRD resolves.");
const v = document.createElement('video');
v.autoplay = true;
v.srcObject = recvStream;
v.id = recvStream.id;
await new Promise(r => v.onloadedmetadata = r);
const senders = caller.getSenders();
const dtlsTransports = senders.map(s => s.transport);
assert_equals(dtlsTransports.length, 2);
assert_equals(dtlsTransports[0], dtlsTransports[1]);
assert_not_equals(dtlsTransports[1], secondTransport);
assert_equals(secondTransport.state, 'closed');
}, 'bundles on the first transport and closes the second');
promise_test(async t => {
const sdp = `v=0
o=- 0 3 IN IP4 127.0.0.1
s=-
t=0 0
a=fingerprint:sha-256 A7:24:72:CA:6E:02:55:39:BA:66:DF:6E:CC:4C:D8:B0:1A:BF:1A:56:65:7D:F4:03:AD:7E:77:43:2A:29:EC:93
a=ice-ufrag:ETEn
a=ice-pwd:OtSK0WpNtpUjkY4+86js7Z/l
m=audio 9 UDP/TLS/RTP/SAVPF 111
c=IN IP4 0.0.0.0
a=rtcp-mux
a=sendonly
a=mid:audio
a=rtpmap:111 opus/48000/2
a=setup:actpass
m=video 9 UDP/TLS/RTP/SAVPF 100
c=IN IP4 0.0.0.0
a=rtcp-mux
a=sendonly
a=mid:video
a=rtpmap:100 VP8/90000
a=fmtp:100 max-fr=30;max-fs=3600
a=setup:actpass
`;
const pc = new RTCPeerConnection({ bundlePolicy: 'max-bundle' });
t.add_cleanup(() => pc.close());
await pc.setRemoteDescription({ type: 'offer', sdp });
await pc.setLocalDescription();
const transceivers = pc.getTransceivers();
assert_equals(transceivers.length, 2);
assert_false(transceivers[0].stopped);
assert_true(transceivers[1].stopped);
}, 'max-bundle with an offer without bundle only negotiates the first m-line');
promise_test(async t => {
const sdp = `v=0
o=- 0 3 IN IP4 127.0.0.1
s=-
t=0 0
a=group:BUNDLE audio video
m=audio 9 UDP/TLS/RTP/SAVPF 111
c=IN IP4 0.0.0.0
a=fingerprint:sha-256 A7:24:72:CA:6E:02:55:39:BA:66:DF:6E:CC:4C:D8:B0:1A:BF:1A:56:65:7D:F4:03:AD:7E:77:43:2A:29:EC:93
a=ice-ufrag:ETEn
a=ice-pwd:OtSK0WpNtpUjkY4+86js7Z/l
a=rtcp-mux
a=sendonly
a=mid:audio
a=rtpmap:111 opus/48000/2
a=setup:actpass
m=video 0 UDP/TLS/RTP/SAVPF 100
c=IN IP4 0.0.0.0
a=bundle-only
a=sendonly
a=mid:video
a=rtpmap:100 VP8/90000
a=fmtp:100 max-fr=30;max-fs=3600
`;
const pc = new RTCPeerConnection();
t.add_cleanup(() => pc.close());
await pc.setRemoteDescription({ type: 'offer', sdp });
}, 'sRD(offer) works with no transport attributes in a bundle-only m-section');
</script>
|
