<!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>