RTCPeerConnection-legacy-stream-events.https.html

<!doctype html>
<meta charset=utf-8>
<script src="../../resources/testharness.js"></script>
<script src="../../resources/testharnessreport.js"></script>
<script>
'use strict';

promise_test(async t => {
  console.log('onaddstream fires for new remote streams.');
  const pc1 = new RTCPeerConnection();
  t.add_cleanup(() => { pc1.close(); });
  const pc2 = new RTCPeerConnection();
  t.add_cleanup(() => { pc2.close(); });

  const localStream = await navigator.mediaDevices.getUserMedia({audio:true});
  const [localTrack] = localStream.getTracks();
  pc1.addTrack(localTrack, localStream);

  const streamWatcher = new EventWatcher(t, pc2, ['addstream']);
  const addstreamEvent = streamWatcher.wait_for('addstream');
  await performOfferAnswer(pc1, pc2);
  const remoteStream = (await addstreamEvent).stream;
  assert_equals(remoteStream.getTracks().length, 1,
                'The stream should contain a track.');
}, 'onaddstream fires for new remote streams.');

promise_test(async t => {
  console.log('onremovestream for removed remote streams.');
  const pc1 = new RTCPeerConnection();
  t.add_cleanup(() => { pc1.close(); });
  const pc2 = new RTCPeerConnection();
  t.add_cleanup(() => { pc2.close(); });

  const localStream = await navigator.mediaDevices.getUserMedia({audio:true});
  const [localTrack] = localStream.getTracks();
  const sender = pc1.addTrack(localTrack, localStream);

  const streamWatcher = new EventWatcher(t, pc2, ['addstream',
                                                  'removestream']);
  const addstreamEvent = streamWatcher.wait_for('addstream');
  await performOfferAnswer(pc1, pc2);
  const remoteStream = (await addstreamEvent).stream;
  const removestreamEvent = streamWatcher.wait_for('removestream');

  pc1.removeTrack(sender);
  await performOfferAnswer(pc1, pc2);
  const removedRemoteStream = (await removestreamEvent).stream;
  assert_equals(removedRemoteStream, remoteStream);
}, 'onremovestream for removed remote streams.');

promise_test(async t => {
  console.log('onaddstream for a re-added remote stream.');
  const pc1 = new RTCPeerConnection();
  t.add_cleanup(() => { pc1.close(); });
  const pc2 = new RTCPeerConnection();
  t.add_cleanup(() => { pc2.close(); });

  const localStream = await navigator.mediaDevices.getUserMedia({audio:true});
  const [localTrack] = localStream.getTracks();
  const sender = pc1.addTrack(localTrack, localStream);

  const streamWatcher = new EventWatcher(t, pc2, ['addstream']);
  let addstreamEvent = streamWatcher.wait_for('addstream');
  await performOfferAnswer(pc1, pc2);
  const remoteStream = (await addstreamEvent).stream;

  pc1.removeTrack(sender);
  await performOfferAnswer(pc1, pc2);

  pc1.addTrack(localTrack, localStream);
  addstreamEvent = streamWatcher.wait_for('addstream');
  await performOfferAnswer(pc1, pc2);
  const readdedRemoteStream = (await addstreamEvent).stream;
  assert_equals(readdedRemoteStream.id, remoteStream.id);
}, 'onaddstream for a re-added remote stream.');

async function performOfferAnswer(pc1, pc2) {
  const offer = await pc1.createOffer();
  await pc1.setLocalDescription(offer);
  await pc2.setRemoteDescription(offer);
  const answer = await pc2.createAnswer();
  await pc2.setLocalDescription(answer);
  await pc1.setRemoteDescription(answer);
}
</script>
chromium/third_party/blink/web_tests/fast/peerconnection/RTCPeerConnection-legacy-stream-events.https.html
