RollbackEvents.https.html

<!doctype html>

<meta charset=utf-8>

<script src="/resources/testharness.js"></script>

<script src="/resources/testharnessreport.js"></script>

<script>

'use strict';

['audio', 'video'].forEach((kind) => {

  // Make sure "ontrack" fires if a prevuously rolled back track is added back.

  promise_test(async t => {

    const constraints = {};

    constraints[kind] = true;

    const stream = await navigator.mediaDevices.getUserMedia(constraints);

    const [track] = stream.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, stream);

    pc2.addTrack(track, stream);

    const [pc1Transceiver] = pc1.getTransceivers();

    const [pc2Transceiver] = pc2.getTransceivers();

    let remoteStreamViaOnTrackPromise = getRemoteStreamViaOnTrackPromise(pc2);

    // Apply remote offer, but don't complete the entire exchange.

    await pc1.setLocalDescription();

    await pc2.setRemoteDescription(pc1.localDescription);

    // The addTrack-transceiver gets associated, no need for a second

    // transceiver.

    assert_equals(pc2.getTransceivers().length, 1);

    const remoteStream = await remoteStreamViaOnTrackPromise;

    assert_equals(remoteStream.id, stream.id);

    const onRemoveTrackPromise = new Promise(r => {

      remoteStream.onremovetrack = () => { r(); };

});

    // Cause track removal due to rollback.

    await pc2.setRemoteDescription({type:'rollback'});

    // The track was removed.

    await onRemoveTrackPromise;

    // Sanity check that ontrack still fires if we add it back again by applying

    // the same remote offer.

    remoteStreamViaOnTrackPromise = getRemoteStreamViaOnTrackPromise(pc2);

    await pc2.setRemoteDescription(pc1.localDescription);

    const revivedRemoteStream = await remoteStreamViaOnTrackPromise;

    // This test only expects IDs to be the same. The same stream object should

    // also be used, but this should be covered by separate tests.

    // TODO(https://crbug.com/1321738): Add MediaStream identity tests.

    assert_equals(remoteStream.id, revivedRemoteStream.id);

    // No cheating, the same transciever should be used as before.

    assert_equals(pc2.getTransceivers().length, 1);

  }, `[${kind}] Track with stream: removal due to disassociation in rollback and then add it back again`);

  // This is the same test as above, but this time without any remote streams.

  // This test could fail if [[FiredDirection]] was not reset in a rollback but

  // the above version of the test might still pass due to the track being

  // re-added to its stream.

  promise_test(async t => {

    const constraints = {};

    constraints[kind] = true;

    const stream = await navigator.mediaDevices.getUserMedia(constraints);

    const [track] = stream.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);

    pc2.addTrack(track);

    const [pc1Transceiver] = pc1.getTransceivers();

    const [pc2Transceiver] = pc2.getTransceivers();

    let remoteTrackPromise = getTrackViaOnTrackPromise(pc2);

    // Apply remote offer, but don't complete the entire exchange.

    await pc1.setLocalDescription();

    await pc2.setRemoteDescription(pc1.localDescription);

    // The addTrack-transceiver gets associated, no need for a second

    // transceiver.

    assert_equals(pc2.getTransceivers().length, 1);

    const remoteTrack = await remoteTrackPromise;

    assert_not_equals(remoteTrack, null);

    // Cause track removal due to rollback.

    await pc2.setRemoteDescription({type:'rollback'});

    // There's nothing equivalent to stream.onremovetrack when you don't have a

    // stream, but the track should become muted (if it isn't already).

    if (!remoteTrack.muted) {

      await new Promise(r => remoteTrack.onmute = () => { r(); });

    assert_equals(remoteTrack.muted, true);

    // Sanity check that ontrack still fires if we add it back again by applying

    // the same remote offer.

    remoteTrackPromise = getTrackViaOnTrackPromise(pc2);

    await pc2.setRemoteDescription(pc1.localDescription);

    const revivedRemoteTrack = await remoteTrackPromise;

    // We can be sure the same track is used, because the same transceiver is

    // used (and transciever.receiver.track has same lifetime as transceiver).

    assert_equals(pc2.getTransceivers().length, 1);

    assert_equals(remoteTrack, revivedRemoteTrack);

  }, `[${kind}] Track without stream: removal due to disassociation in rollback and then add it back`);

  // Make sure "ontrack" can fire in a rollback (undo making it inactive).

  promise_test(async t => {

    const constraints = {};

    constraints[kind] = true;

    const stream = await navigator.mediaDevices.getUserMedia(constraints);

    const [track] = stream.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, stream);

    const [pc1Transceiver] = pc1.getTransceivers();

    let remoteStreamViaOnTrackPromise = getRemoteStreamViaOnTrackPromise(pc2);

    // Complete O/A exchange such that the transceiver gets associated.

    await pc1.setLocalDescription();

    await pc2.setRemoteDescription(pc1.localDescription);

    await pc2.setLocalDescription();

    await pc1.setRemoteDescription(pc2.localDescription);

    const [pc2Transceiver] = pc2.getTransceivers();

    assert_equals(pc2Transceiver.direction, 'recvonly');

    assert_equals(pc2Transceiver.currentDirection, 'recvonly');

    const remoteStream = await remoteStreamViaOnTrackPromise;

    assert_equals(remoteStream.id, stream.id);

    const onRemoveTrackPromise = new Promise(r => {

      remoteStream.onremovetrack = () => { r(); };

});

    // Cause track removal.

    pc1Transceiver.direction = 'inactive';

    await pc1.setLocalDescription();

    await pc2.setRemoteDescription(pc1.localDescription);

    // The track was removed.

    await onRemoveTrackPromise;

    // Rolling back the offer revives the track, causing ontrack to fire again.

    remoteStreamViaOnTrackPromise = getRemoteStreamViaOnTrackPromise(pc2);

    await pc2.setRemoteDescription({type:'rollback'});

    const revivedRemoteStream = await remoteStreamViaOnTrackPromise;

    // This test only expects IDs to be the same. The same stream object should

    // also be used, but this should be covered by separate tests.

    // TODO(https://crbug.com/1321738): Add MediaStream identity tests.

    assert_equals(remoteStream.id, revivedRemoteStream.id);

  }, `[${kind}] Track with stream: removal due to direction changing and then add back using rollback`);

  // Same test as above but without remote streams.

  promise_test(async t => {

    const constraints = {};

    constraints[kind] = true;

    const stream = await navigator.mediaDevices.getUserMedia(constraints);

    const [track] = stream.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);

    const [pc1Transceiver] = pc1.getTransceivers();

    let remoteTrackPromise = getTrackViaOnTrackPromise(pc2);

    // Complete O/A exchange such that the transceiver gets associated.

    await pc1.setLocalDescription();

    await pc2.setRemoteDescription(pc1.localDescription);

    await pc2.setLocalDescription();

    await pc1.setRemoteDescription(pc2.localDescription);

    const [pc2Transceiver] = pc2.getTransceivers();

    assert_equals(pc2Transceiver.direction, 'recvonly');

    assert_equals(pc2Transceiver.currentDirection, 'recvonly');

    const remoteTrack = await remoteTrackPromise;

    // Cause track removal.

    pc1Transceiver.direction = 'inactive';

    await pc1.setLocalDescription();

    await pc2.setRemoteDescription(pc1.localDescription);

    // There's nothing equivalent to stream.onremovetrack when you don't have a

    // stream, but the track should become muted (if it isn't already).

    if (!remoteTrack.muted) {

      await new Promise(r => remoteTrack.onmute = () => { r(); });

    assert_equals(remoteTrack.muted, true);

    // Rolling back the offer revives the track, causing ontrack to fire again.

    remoteTrackPromise = getTrackViaOnTrackPromise(pc2);

    await pc2.setRemoteDescription({type:'rollback'});

    const revivedRemoteTrack = await remoteTrackPromise;

    // We can be sure the same track is used, because the same transceiver is

    // used (and transciever.receiver.track has same lifetime as transceiver).

    assert_equals(pc2.getTransceivers().length, 1);

    assert_equals(remoteTrack, revivedRemoteTrack);

  }, `[${kind}] Track without stream: removal due to direction changing and then add back using rollback`);

});

function getTrackViaOnTrackPromise(pc) {

  return new Promise(r => {

    pc.ontrack = e => {

      pc.ontrack = null;

      r(e.track);

};

});

function getRemoteStreamViaOnTrackPromise(pc) {

  return new Promise(r => {

    pc.ontrack = e => {

      pc.ontrack = null;

      r(e.streams[0]);

};

});

</script>

Source code

Revision control

Copy as Markdown

Other Tools

Test Info: