Add a sample for QUIC transport.

jianjunz · jianjunz · commit 302b79b727a7 · 2020-06-23T11:27:35.000+08:00
diff --git a/src/samples/conference/public/quic.html b/src/samples/conference/public/quic.html
@@ -0,0 +1,40 @@
+<!--
+ Copyright (C) <2020> Intel Corporation
+
+ SPDX-License-Identifier: Apache-2.0
+-->
+
+<html>
+<meta charset="utf-8">
+
+<head>
+  <title>Open WebRTC Toolkit QUIC Sample</title>
+  <style>
+    html {
+      font-family: "intel-clear", "tahoma", Helvetica, "helvetica", Arial, sans-serif;
+      font-size: 90%;
+    }
+
+    .operations {
+      padding: 1em 0;
+    }
+  </style>
+</head>
+
+<body>
+  <h1>Open WebRTC Toolkit</h1>
+  <h2>Sample of QuicTransport</h2>
+  <div id="description">
+    <p>This sample works with the latest Chrome.</p>
+  </div>
+  <div class="operations">
+    <button id="start-sending">Start sending</button>
+    <button id="stop-sending">Stop sending</button>
+  </div>
+  <div id="conference-status"></div>
+  <div class="stats">
+  </div>
+  <script src="scripts/quic.js" type="text/javascript"></script>
+</body>
+
+</html>
diff --git a/src/samples/conference/public/scripts/quic.js b/src/samples/conference/public/scripts/quic.js
@@ -0,0 +1,75 @@
+// Copyright (C) <2020> Intel Corporation
+//
+// SPDX-License-Identifier: Apache-2.0
+
+'use strict';
+
+//const conference = new Owt.Conference.ConferenceClient();
+let quicTransport=null;
+let bidirectionalStream = null;
+let writeTask;
+
+function updateConferenceStatus(message) {
+  document.getElementById('conference-status').innerHTML +=
+      ('<p>' + message + '</p>');
+}
+
+
+function joinConference() {
+  const host = 'http://' + document.location.hostname + ':3001';
+  return new Promise((resolve, reject) => {
+    createToken(undefined, 'user', 'presenter', resp => {
+      conference.join(resp).then(() => {
+        updateConferenceStatus('Connected to conference server.');
+        resolve();
+      });
+    }, host);
+  });
+};
+
+function createQuicTransport(){
+  quicTransport= new QuicTransport('quic-transport://jianjunz-nuc-ubuntu.sh.intel.com:7700/echo');
+  quicTransport.onstatechange=()=>{
+    console.log('QuicTransport state changed.');
+  };
+  return quicTransport.ready;
+}
+
+async function createSendChannel() {
+  bidirectionalStream = await quicTransport.createSendStream();
+  updateConferenceStatus('Created send channel.');
+}
+
+async function windowOnLoad() {
+  //await joinConference();
+  await createQuicTransport();
+  await createSendChannel();
+}
+
+async function writeData() {
+  const encoder = new TextEncoder();
+  const encoded = encoder.encode('message', {stream: true});
+  const writer = bidirectionalStream.writable.getWriter();
+  await writer.ready;
+  await writer.write(new ArrayBuffer(90000000));
+  writer.releaseLock();
+  return;
+}
+
+window.addEventListener('load', () => {
+  windowOnLoad();
+});
+
+document.getElementById('start-sending').addEventListener('click', () => {
+  if (!bidirectionalStream) {
+    updateConferenceStatus('Stream is not created.');
+    return;
+  }
+  writeTask = setInterval(writeData, 500);
+  updateConferenceStatus('Started sending.');
+});
+
+document.getElementById('stop-sending').addEventListener('click', () => {
+  clearInterval(writeTask);
+  updateConferenceStatus('Stopped sending.');
+});
