RTCPeerConnection-addIceCandidate-connectionSetup.html

Enable keyboard shortcuts

This WPT test may be referenced by the following Test IDs:
- /webrtc/RTCPeerConnection-addIceCandidate-connectionSetup.html - WPT Dashboard Interop Dashboard

<!doctype html>

<meta name="timeout" content="long">

<title>Test RTCPeerConnection.prototype.addIceCandidate</title>

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

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

<script src="RTCPeerConnection-helper.js"></script>

<script>

  'use strict';

// This test may be flaky, so it's in its own file.

// The test belongs in RTCPeerConnection-addIceCandidate.

promise_test(async t => {

  const pc1 = new RTCPeerConnection();

  const pc2 = new RTCPeerConnection();

  t.add_cleanup(() => pc1.close());

  t.add_cleanup(() => pc2.close());

  const transceiver = pc1.addTransceiver('video');

  exchangeIceCandidates(pc1, pc2);

  await exchangeOffer(pc1, pc2);

  const answer = await pc2.createAnswer();

  // Note that sequence of the following two calls is critical

  // for test stability.

  await pc1.setRemoteDescription(answer);

  await pc2.setLocalDescription(answer);

  await waitForState(transceiver.sender.transport, 'connected');

}, 'Candidates are added dynamically; connection should work');

promise_test(async t => {

  const pc1 = new RTCPeerConnection();

  const pc2 = new RTCPeerConnection();

  t.add_cleanup(() => pc1.close());

  t.add_cleanup(() => pc2.close());

  const transceiver = pc1.addTransceiver('video');

  let candidates1to2 = [];

  let candidates2to1 = [];

  pc1.onicecandidate = e => candidates1to2.push(e.candidate);

  pc2.onicecandidate = e => candidates2to1.push(e.candidate);

  const pc2GatheredCandidates = new Promise((resolve) => {

    pc2.addEventListener('icegatheringstatechange', () => {

      if (pc2.iceGatheringState == 'complete') {

        resolve();

});

});

  await exchangeOffer(pc1, pc2);

  let answer = await pc2.createAnswer();

  await pc1.setRemoteDescription(answer);

  await pc2.setLocalDescription(answer);

  await pc2GatheredCandidates;

  // Add candidates to pc1, ensuring that it goes to "connecting" state before "connected".

  // We do not iterate/await because repeatedly awaiting while we serially add

  // the candidates opens the opportunity to miss the 'connecting' transition.

  const addCandidatesDone = Promise.all(candidates2to1.map(c => pc1.addIceCandidate(c)));

  await waitForState(transceiver.sender.transport, 'connecting');

  await addCandidatesDone;

  await waitForState(transceiver.sender.transport, 'connected');

}, 'Candidates are added at PC1; connection should work');

promise_test(async t => {

  const pc1 = new RTCPeerConnection();

  const pc2 = new RTCPeerConnection();

  t.add_cleanup(() => pc1.close());

  t.add_cleanup(() => pc2.close());

  const transceiver = pc1.addTransceiver('video');

  let candidates1to2 = [];

  let candidates2to1 = [];

  pc1.onicecandidate = e => candidates1to2.push(e.candidate);

  pc2.onicecandidate = e => candidates2to1.push(e.candidate);

  const pc1GatheredCandidates = new Promise((resolve) => {

    pc1.addEventListener('icegatheringstatechange', () => {

      if (pc1.iceGatheringState == 'complete') {

        resolve();

});

});

  await exchangeOffer(pc1, pc2);

  let answer = await pc2.createAnswer();

  await pc1.setRemoteDescription(answer);

  await pc2.setLocalDescription(answer);

  await pc1GatheredCandidates;

  // Add candidates to pc2

  // We do not iterate/await because repeatedly awaiting while we serially add

  // the candidates opens the opportunity to miss the ICE state transitions.

  await Promise.all(candidates1to2.map(c => pc2.addIceCandidate(c)));

  await waitForState(transceiver.sender.transport, 'connected');

}, 'Candidates are added at PC2; connection should work');

</script>