<!doctype html>
<meta charset=utf-8>
<meta name="timeout" content="long">
<title>RTCPeerConnection.prototype.setRemoteDescription - add/remove remote tracks</title>
<script src="/resources/testharness.js"></script>
<script src="/resources/testharnessreport.js"></script>
<script src="RTCPeerConnection-helper.js"></script>
<script>
'use strict';
// The following helper functions are called from RTCPeerConnection-helper.js:
// addEventListenerPromise
// exchangeOffer
// exchangeOfferAnswer
// Resolver
// These tests are concerned with the observable consequences of processing
// the addition or removal of remote tracks, including events firing and the
// states of RTCPeerConnection, MediaStream and MediaStreamTrack.
promise_test(async t => {
const caller = new RTCPeerConnection();
t.add_cleanup(() => caller.close());
const callee = new RTCPeerConnection();
t.add_cleanup(() => callee.close());
const localStream =
await getNoiseStream({audio: true});
t.add_cleanup(() => localStream.getTracks().forEach(track => track.stop()));
caller.addTrack(localStream.getTracks()[0]);
const ontrackPromise = addEventListenerPromise(t, callee, 'track', e => {
assert_equals(e.streams.length, 0, 'No remote stream created.');
});
await exchangeOffer(caller, callee);
await ontrackPromise;
}, 'addTrack() with a track and no stream makes ontrack fire with a track and no stream.');
promise_test(async t => {
const caller = new RTCPeerConnection();
t.add_cleanup(() => caller.close());
const callee = new RTCPeerConnection();
t.add_cleanup(() => callee.close());
const localStream =
await getNoiseStream({audio: true});
t.add_cleanup(() => localStream.getTracks().forEach(track => track.stop()));
caller.addTrack(localStream.getTracks()[0], localStream);
const ontrackPromise = addEventListenerPromise(t, callee, 'track', e => {
assert_equals(e.streams.length, 1, 'Created a single remote stream.');
assert_equals(e.streams[0].id, localStream.id,
'Local and remote stream IDs match.');
assert_array_equals(e.streams[0].getTracks(), [e.track],
'The remote stream contains the remote track.');
});
await exchangeOffer(caller, callee);
await ontrackPromise;
}, 'addTrack() with a track and a stream makes ontrack fire with a track and a stream.');
promise_test(async t => {
const caller = new RTCPeerConnection();
t.add_cleanup(() => caller.close());
const callee = new RTCPeerConnection();
t.add_cleanup(() => callee.close());
let eventSequence = '';
const localStream =
await getNoiseStream({audio: true});
t.add_cleanup(() => localStream.getTracks().forEach(track => track.stop()));
caller.addTrack(localStream.getTracks()[0], localStream);
const ontrackPromise = addEventListenerPromise(t, callee, 'track', e => {
eventSequence += 'ontrack;';
});
await exchangeOffer(caller, callee);
eventSequence += 'setRemoteDescription;';
await ontrackPromise;
assert_equals(eventSequence, 'ontrack;setRemoteDescription;');
}, 'ontrack fires before setRemoteDescription resolves.');
promise_test(async t => {
const caller = new RTCPeerConnection();
t.add_cleanup(() => caller.close());
const callee = new RTCPeerConnection();
t.add_cleanup(() => callee.close());
const localStreams = await Promise.all([
getNoiseStream({audio: true}),
getNoiseStream({audio: true}),
]);
t.add_cleanup(() => localStreams.forEach((stream) =>
stream.getTracks().forEach((track) => track.stop())));
caller.addTrack(localStreams[0].getTracks()[0], localStreams[0]);
caller.addTrack(localStreams[1].getTracks()[0], localStreams[0]);
let ontrackEventsFired = 0;
const ontrackEventResolvers = [ new Resolver(), new Resolver() ];
callee.ontrack = t.step_func(e => {
ontrackEventResolvers[ontrackEventsFired++].resolve(e);
});
await exchangeOffer(caller, callee);
let firstTrackEvent = await ontrackEventResolvers[0];
assert_equals(firstTrackEvent.streams.length, 1,
'First ontrack fires with a single stream.');
assert_equals(firstTrackEvent.streams[0].id,
localStreams[0].id,
'First ontrack\'s stream ID matches local stream.');
let secondTrackEvent = await ontrackEventResolvers[1];
assert_equals(secondTrackEvent.streams.length, 1,
'Second ontrack fires with a single stream.');
assert_equals(secondTrackEvent.streams[0].id,
localStreams[0].id,
'Second ontrack\'s stream ID matches local stream.');
assert_array_equals(firstTrackEvent.streams, secondTrackEvent.streams,
'ontrack was fired with the same streams both times.');
assert_equals(firstTrackEvent.streams[0].getTracks().length, 2, "stream should have two tracks");
assert_true(firstTrackEvent.streams[0].getTracks().includes(firstTrackEvent.track), "remoteStream should have the first track");
assert_true(firstTrackEvent.streams[0].getTracks().includes(secondTrackEvent.track), "remoteStream should have the second track");
assert_equals(ontrackEventsFired, 2, 'Unexpected number of track events.');
assert_equals(ontrackEventsFired, 2, 'Unexpected number of track events.');
}, 'addTrack() with two tracks and one stream makes ontrack fire twice with the tracks and shared stream.');
promise_test(async t => {
const caller = new RTCPeerConnection();
t.add_cleanup(() => caller.close());
const callee = new RTCPeerConnection();
t.add_cleanup(() => callee.close());
let eventSequence = '';
const localStreams = await Promise.all([
getNoiseStream({audio: true}),
getNoiseStream({audio: true}),
]);
t.add_cleanup(() => localStreams.forEach((stream) =>
stream.getTracks().forEach((track) => track.stop())));
caller.addTrack(localStreams[0].getTracks()[0], localStreams[0]);
const remoteStreams = [];
callee.ontrack = e => {
if (!remoteStreams.includes(e.streams[0]))
remoteStreams.push(e.streams[0]);
};
exchangeIceCandidates(caller, callee);
await exchangeOfferAnswer(caller, callee);
assert_equals(remoteStreams.length, 1, 'One remote stream created.');
assert_equals(remoteStreams[0].id, localStreams[0].id,
'First local and remote streams have the same ID.');
const firstRemoteTrack = remoteStreams[0].getTracks()[0];
const onaddtrackPromise = addEventListenerPromise(t, remoteStreams[0], 'addtrack');
caller.addTrack(localStreams[1].getTracks()[0], localStreams[0]);
await exchangeOffer(caller, callee);
const e = await onaddtrackPromise;
assert_equals(remoteStreams[0].getTracks().length, 2, 'stream has two tracks');
assert_not_equals(e.track.id, firstRemoteTrack.id,
'addtrack event has a new track');
assert_equals(remoteStreams.length, 1, 'Still a single remote stream.');
}, 'addTrack() for an existing stream makes stream.onaddtrack fire.');
promise_test(async t => {
const caller = new RTCPeerConnection();
t.add_cleanup(() => caller.close());
const callee = new RTCPeerConnection();
t.add_cleanup(() => callee.close());
let eventSequence = '';
const localStreams = await Promise.all([
getNoiseStream({audio: true}),
getNoiseStream({audio: true}),
]);
t.add_cleanup(() => localStreams.forEach((stream) =>
stream.getTracks().forEach((track) => track.stop())));
caller.addTrack(localStreams[0].getTracks()[0], localStreams[0]);
const remoteStreams = [];
callee.ontrack = e => {
if (!remoteStreams.includes(e.streams[0]))
remoteStreams.push(e.streams[0]);
};
exchangeIceCandidates(caller, callee);
await exchangeOfferAnswer(caller, callee);
assert_equals(remoteStreams.length, 1, 'One remote stream created.');
const onaddtrackPromise =
addEventListenerPromise(t, remoteStreams[0], 'addtrack', e => {
eventSequence += 'stream.onaddtrack;';
});
caller.addTrack(localStreams[1].getTracks()[0], localStreams[0]);
await exchangeOffer(caller, callee);
eventSequence += 'setRemoteDescription;';
await onaddtrackPromise;
assert_equals(remoteStreams.length, 1, 'Still a single remote stream.');
assert_equals(eventSequence, 'stream.onaddtrack;setRemoteDescription;');
}, 'stream.onaddtrack fires before setRemoteDescription resolves.');
promise_test(async t => {
const caller = new RTCPeerConnection();
t.add_cleanup(() => caller.close());
const callee = new RTCPeerConnection();
t.add_cleanup(() => callee.close());
const localStreams = await Promise.all([
getNoiseStream({audio: true}),
getNoiseStream({audio: true}),
]);
t.add_cleanup(() => localStreams.forEach((stream) =>
stream.getTracks().forEach((track) => track.stop())));
caller.addTrack(localStreams[0].getTracks()[0],
localStreams[0], localStreams[1]);
const ontrackPromise = addEventListenerPromise(t, callee, 'track', e => {
assert_equals(e.streams.length, 2, 'Two remote stream created.');
assert_array_equals(e.streams[0].getTracks(), [e.track],
'First remote stream == [remote track].');
assert_array_equals(e.streams[1].getTracks(), [e.track],
'Second remote stream == [remote track].');
assert_equals(e.streams[0].id, localStreams[0].id,
'First local and remote stream IDs match.');
assert_equals(e.streams[1].id, localStreams[1].id,
'Second local and remote stream IDs match.');
});
await exchangeOffer(caller, callee);
await ontrackPromise;
}, 'addTrack() with a track and two streams makes ontrack fire with a track and two streams.');
promise_test(async t => {
const caller = new RTCPeerConnection();
t.add_cleanup(() => caller.close());
const callee = new RTCPeerConnection();
t.add_cleanup(() => callee.close());
const localStream =
await getNoiseStream({audio: true});
t.add_cleanup(() => localStream.getTracks().forEach(track => track.stop()));
caller.addTrack(localStream.getTracks()[0], localStream);
const ontrackPromise = addEventListenerPromise(t, callee, 'track', e => {
assert_array_equals(callee.getReceivers(), [e.receiver],
'getReceivers() == [e.receiver].');
});
await exchangeOffer(caller, callee);
await ontrackPromise;
}, 'ontrack\'s receiver matches getReceivers().');
promise_test(async t => {
const caller = new RTCPeerConnection();
t.add_cleanup(() => caller.close());
const callee = new RTCPeerConnection();
t.add_cleanup(() => callee.close());
const localStream =
await getNoiseStream({audio: true});
t.add_cleanup(() => localStream.getTracks().forEach(track => track.stop()));
const sender = caller.addTrack(localStream.getTracks()[0], localStream);
const ontrackPromise = addEventListenerPromise(t, callee, 'track');
exchangeIceCandidates(caller, callee);
await exchangeOfferAnswer(caller, callee);
await ontrackPromise;
assert_equals(callee.getReceivers().length, 1, 'One receiver created.');
caller.removeTrack(sender);
await exchangeOffer(caller, callee);
assert_equals(callee.getReceivers().length, 1, 'Receiver not removed.');
}, 'removeTrack() does not remove the receiver.');
promise_test(async t => {
const caller = new RTCPeerConnection();
t.add_cleanup(() => caller.close());
const callee = new RTCPeerConnection();
t.add_cleanup(() => callee.close());
const localStream =
await getNoiseStream({audio: true});
t.add_cleanup(() => localStream.getTracks().forEach(track => track.stop()));
const [track] = localStream.getTracks();
const sender = caller.addTrack(track, localStream);
const ontrackPromise = addEventListenerPromise(t, callee, 'track', e => {
assert_equals(e.streams.length, 1);
return e.streams[0];
});
exchangeIceCandidates(caller, callee);
await exchangeOfferAnswer(caller, callee);
const remoteStream = await ontrackPromise;
const remoteTrack = remoteStream.getTracks()[0];
const onremovetrackPromise =
addEventListenerPromise(t, remoteStream, 'removetrack', e => {
assert_equals(e.track, remoteTrack);
assert_equals(remoteStream.getTracks().length, 0,
'Remote stream emptied of tracks.');
});
caller.removeTrack(sender);
await exchangeOffer(caller, callee);
await onremovetrackPromise;
}, 'removeTrack() makes stream.onremovetrack fire and the track to be removed from the stream.');
promise_test(async t => {
const caller = new RTCPeerConnection();
t.add_cleanup(() => caller.close());
const callee = new RTCPeerConnection();
t.add_cleanup(() => callee.close());
let eventSequence = '';
const localStream =
await getNoiseStream({audio: true});
t.add_cleanup(() => localStream.getTracks().forEach(track => track.stop()));
const sender = caller.addTrack(localStream.getTracks()[0], localStream);
const ontrackPromise = addEventListenerPromise(t, callee, 'track', e => {
assert_equals(e.streams.length, 1);
return e.streams[0];
});
exchangeIceCandidates(caller, callee);
await exchangeOfferAnswer(caller, callee);
const remoteStream = await ontrackPromise;
const remoteTrack = remoteStream.getTracks()[0];
const onremovetrackPromise =
addEventListenerPromise(t, remoteStream, 'removetrack', e => {
eventSequence += 'stream.onremovetrack;';
});
caller.removeTrack(sender);
await exchangeOffer(caller, callee);
eventSequence += 'setRemoteDescription;';
await onremovetrackPromise;
assert_equals(eventSequence, 'stream.onremovetrack;setRemoteDescription;');
}, 'stream.onremovetrack fires before setRemoteDescription resolves.');
promise_test(async t => {
const caller = new RTCPeerConnection();
t.add_cleanup(() => caller.close());
const callee = new RTCPeerConnection();
t.add_cleanup(() => callee.close());
const localStream =
await getNoiseStream({audio: true});
t.add_cleanup(() => localStream.getTracks().forEach(track => track.stop()));
const sender = caller.addTrack(localStream.getTracks()[0], localStream);
exchangeIceCandidates(caller, callee);
const e = await exchangeOfferAndListenToOntrack(t, caller, callee);
const remoteTrack = e.track;
// Need to wait for unmute, otherwise there's no event for the transition
// back to muted.
const onunmutePromise =
addEventListenerPromise(t, remoteTrack, 'unmute', () => {
assert_false(remoteTrack.muted);
});
await exchangeAnswer(caller, callee);
await onunmutePromise;
const onmutePromise =
addEventListenerPromise(t, remoteTrack, 'mute', () => {
assert_true(remoteTrack.muted);
});
caller.removeTrack(sender);
await exchangeOffer(caller, callee);
await onmutePromise;
}, 'removeTrack() makes track.onmute fire and the track to be muted.');
promise_test(async t => {
const caller = new RTCPeerConnection();
t.add_cleanup(() => caller.close());
const callee = new RTCPeerConnection();
t.add_cleanup(() => callee.close());
let eventSequence = '';
const localStream =
await getNoiseStream({audio: true});
t.add_cleanup(() => localStream.getTracks().forEach(track => track.stop()));
const sender = caller.addTrack(localStream.getTracks()[0], localStream);
const ontrackPromise = addEventListenerPromise(t, callee, 'track', e => {
assert_equals(e.streams.length, 1);
return e.streams[0];
});
exchangeIceCandidates(caller, callee);
const e = await exchangeOfferAndListenToOntrack(t, caller, callee);
const remoteTrack = e.track;
// Need to wait for unmute, otherwise there's no event for the transition
// back to muted.
const onunmutePromise =
addEventListenerPromise(t, remoteTrack, 'unmute', () => {
assert_false(remoteTrack.muted);
});
await exchangeAnswer(caller, callee);
await onunmutePromise;
const onmutePromise =
addEventListenerPromise(t, remoteTrack, 'mute', () => {
eventSequence += 'track.onmute;';
});
caller.removeTrack(sender);
await exchangeOffer(caller, callee);
eventSequence += 'setRemoteDescription;';
await onmutePromise;
assert_equals(eventSequence, 'track.onmute;setRemoteDescription;');
}, 'track.onmute fires before setRemoteDescription resolves.');
promise_test(async t => {
const pc = new RTCPeerConnection();
t.add_cleanup(() => pc.close());
const stream = await getNoiseStream({audio: true});
t.add_cleanup(() => stream.getTracks().forEach(track => track.stop()));
const sender = pc.addTrack(stream.getTracks()[0]);
pc.removeTrack(sender);
pc.removeTrack(sender);
}, 'removeTrack() twice is safe.');
</script>
Codebase Browser
chromium