RTCDataChannel-iceRestart.html

Enable keyboard shortcuts

This WPT test may be referenced by the following Test IDs:
- /webrtc/RTCDataChannel-iceRestart.html - WPT Dashboard Interop Dashboard

<!doctype html>

<meta charset=utf-8>

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

<title>RTCDataChannel interactions with ICE restart</title>

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

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

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

<script>

'use strict';

async function checkCanPassData(channel1, channel2) {

  channel1.send('hello');

  const message = await awaitMessage(channel2);

  assert_equals(message, 'hello');

async function pingPongData(channel1, channel2, size=1) {

  channel1.send('hello');

  const request = await awaitMessage(channel2);

  assert_equals(request, 'hello');

  const response = 'x'.repeat(size);

  channel2.send(response);

  const responseReceived = await awaitMessage(channel1);

  assert_equals(response, responseReceived);

promise_test(async t => {

  const pc1 = new RTCPeerConnection();

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

  const pc2 = new RTCPeerConnection();

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

  const [channel1, channel2] = await createDataChannelPair(t, {}, pc1, pc2);

  channel2.addEventListener('error', t.unreached_func());

  channel2.addEventListener('error', t.unreached_func());

  await checkCanPassData(channel1, channel2);

  await checkCanPassData(channel2, channel1);

  pc1.restartIce();

  await exchangeOfferAnswer(pc1, pc2);

  await checkCanPassData(channel1, channel2);

  await checkCanPassData(channel2, channel1);

  channel1.close();

  channel2.close();

}, `Data channel remains usable after ICE restart`);

promise_test(async t => {

  const pc1 = new RTCPeerConnection();

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

  const pc2 = new RTCPeerConnection();

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

  const [channel1, channel2] = await createDataChannelPair(t, {}, pc1, pc2);

  channel2.addEventListener('error', t.unreached_func());

  channel2.addEventListener('error', t.unreached_func());

  await pingPongData(channel1, channel2);

  pc1.restartIce();

  await pc1.setLocalDescription();

  await pingPongData(channel1, channel2);

  await pc2.setRemoteDescription(pc1.localDescription);

  await pingPongData(channel1, channel2);

  await pc2.setLocalDescription(await pc2.createAnswer());

  await pingPongData(channel1, channel2);

  await pc1.setRemoteDescription(pc2.localDescription);

  await pingPongData(channel1, channel2);

  channel1.close();

  channel2.close();

}, `Data channel remains usable at each step of an ICE restart`);

</script>