<!doctype html>
<html>
<head>
  <title>MediaStreamTrackProcessor</title>
  <link rel="help" href="https://w3c.github.io/mediacapture-insertable-streams">
</head>
<body>
<p class="instructions">When prompted, use the accept button to give permission to use your audio and video devices.</p>
<h1 class="instructions">Description</h1>
<p class="instructions">This test checks that MediaStreamTrackProcessor works as expected on video MediaStreamTracks.</p>
<script src=/resources/testharness.js></script>
<script src=/resources/testharnessreport.js></script>
<script src=/resources/testdriver.js></script>
<script src=/resources/testdriver-vendor.js></script>
<script src='../mediacapture-streams/permission-helper.js'></script>
<script>
promise_test(async t => {
  await setMediaPermission("granted", ["camera"]);
  const stream = await navigator.mediaDevices.getUserMedia({video: true});
  const track = stream.getTracks()[0];
  const processor = new MediaStreamTrackProcessor({track: track});
  const reader = processor.readable.getReader();
  const readResult = await reader.read();
  assert_false(readResult.done)
  assert_true(readResult.value instanceof VideoFrame);
  readResult.value.close();
  track.stop();
  return reader.closed;
}, "Tests that the reader of a video MediaStreamTrackProcessor produces video frames and is closed on track stop");

promise_test(async t => {
  const stream = await navigator.mediaDevices.getUserMedia({video: true});
  const track = stream.getTracks()[0];
  const processor = new MediaStreamTrackProcessor({track: track});
  const worker = new Worker('MediaStreamTrackProcessor-worker.js');
  const promise = new Promise(resolve => {
    worker.onmessage = t.step_func(msg => {
      if (msg.data instanceof VideoFrame) {
        msg.data.close();
        track.stop();
      } else if (msg.data == 'closed') {
        resolve();
      } else {
        assert_unreached();
      }
    })
  });
  worker.postMessage({readable: processor.readable},
                     [processor.readable]);
  return promise;
}, "Tests that the reader of a video MediaStreamTrackProcessor produces VideoFrame objects and is closed on track stop while running on a worker");

function makeVideoFrame(timestamp) {
  const canvas = new OffscreenCanvas(100, 100);
  const ctx = canvas.getContext('2d');
  return new VideoFrame(canvas, {timestamp});
}

promise_test(async t => {
  // The generator will be used as the source for the processor to
  // produce frames in a controlled manner.
  const generator = new MediaStreamTrackGenerator('video');
  t.add_cleanup(() => generator.stop());
  // Use a larger maxBufferSize than the default to ensure no frames
  // will be dropped.
  const processor = new MediaStreamTrackProcessor({track: generator, maxBufferSize:10});
  const reader = processor.readable.getReader();
  const writer = generator.writable.getWriter();

  let numReads = 0;
  let resolve = null;
  const promise = new Promise(r => resolve = r);

  const numOperations = 4;
  // Issue reads without waiting for the frames to arrive.
  for (let i = 0; i < numOperations; i++) {
    reader.read().then(dv=> {
      dv.value.close();
      if (++numReads == numOperations)
        resolve();
    });
  }

  // Write video frames in different tasks to "slowly" settle the pending read
  // requests.
  for (let i = 0; i<numOperations; i++) {
     await writer.write(makeVideoFrame(i));
     await new Promise(r=>setTimeout(r,0));
  }

  return promise;

}, "Tests that multiple read requests are eventually settled");

</script>
</body>
</html>
