test_peerConnection_callbacks.html

Enable keyboard shortcuts

<!DOCTYPE HTML>

<html>

<head>

  <script type="application/javascript" src="pc.js"></script>

</head>

<body>

<pre id="test">

<script type="application/javascript">

  createHTML({

    title: "PeerConnection using callback functions",

    bug: "1119593",

    visible: true

});

// This still aggressively uses promises, but it is testing that the callback functions

// are properly in place.

// wrapper that turns a callback-based function call into a promise

function pcall(o, f, beforeArg) {

  return new Promise((resolve, reject) => {

    var args = [resolve, reject];

    if (typeof beforeArg !== 'undefined') {

      args.unshift(beforeArg);

    info('Calling ' + f.name);

    f.apply(o, args);

});

var pc1 = new RTCPeerConnection();

var pc2 = new RTCPeerConnection();

var pc2_haveRemoteOffer = new Promise(resolve => {

  pc2.onsignalingstatechange =

    e => (e.target.signalingState == "have-remote-offer") && resolve();

});

var pc1_stable = new Promise(resolve => {

  pc1.onsignalingstatechange =

    e => (e.target.signalingState == "stable") && resolve();

});

pc1.onicecandidate = e => {

  pc2_haveRemoteOffer

    .then(() => !e.candidate || pcall(pc2, pc2.addIceCandidate, e.candidate))

    .catch(generateErrorCallback());

};

pc2.onicecandidate = e => {

  pc1_stable

    .then(() => !e.candidate || pcall(pc1, pc1.addIceCandidate, e.candidate))

    .catch(generateErrorCallback());

};

runNetworkTest(async function() {

  // Tests trigger warnings

  await SpecialPowers.pushPrefEnv({

    set: [['media.peerconnection.treat_warnings_as_errors', false]]

});

  const v1 = createMediaElement('video', 'v1');

  const v2 = createMediaElement('video', 'v2');

  const delivered = new Promise(resolve => {

    pc2.onaddstream = e => {

      v2.srcObject = e.stream;

      resolve(e.stream);

};

});

  var canPlayThrough = new Promise(resolve => v2.canplaythrough = resolve);

  is(v2.currentTime, 0, "v2.currentTime is zero at outset");

  // not testing legacy gUM here

  await navigator.mediaDevices.getUserMedia({ video: true, audio: true })

    .then(stream => pc1.addStream(v1.srcObject = stream))

    .then(() => pcall(pc1, pc1.createOffer))

    .then(offer => pcall(pc1, pc1.setLocalDescription, offer))

    .then(() => pcall(pc2, pc2.setRemoteDescription, pc1.localDescription))

    .then(() => pcall(pc2, pc2.createAnswer))

    .then(answer => pcall(pc2, pc2.setLocalDescription, answer))

    .then(() => pcall(pc1, pc1.setRemoteDescription, pc2.localDescription))

    .then(() => delivered)

  //    .then(() => canPlayThrough)    // why doesn't this fire?

    .then(() => waitUntil(() => v2.currentTime > 0))

    .then(() => ok(v2.currentTime > 0, "v2.currentTime is moving (" + v2.currentTime + ")"))

    .then(() => ok(true, "Connected."))

    .then(() => { v1.pause(); v2.pause(); });

});

</script>

</pre>

</body>

</html>