Temp changes for QUIC.

Author: jianjunz

package-lock.json

@@ -36,7 +36,7 @@ <h2>Sample of QuicTransport</h2>
   </div>
   <script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/2.2.0/socket.io.js" type="text/javascript"></script>
   <script src="scripts/rest-sample.js" type="text/javascript"></script>
-  <script src="../../../../dist/sdk-debug/owt.js" type="text/javascript"></script>
+  <script src="scripts/owt.js" type="text/javascript"></script>
   <script src="scripts/quic.js" type="text/javascript"></script>
 </body>
 

src/samples/conference/public/quic.html

@@ -36,7 +36,6 @@ const runSocketIOSample = function() {
     let myId;
     let subscriptionForMixedStream;
     let myRoom;
-    let bidirectionalStream;
 
     function getParameterByName(name) {
         name = name.replace(/[\[]/, '\\\[').replace(/[\]]/, '\\\]');
@@ -144,9 +143,6 @@ const runSocketIOSample = function() {
             conference.join(token).then(resp => {
                 myId = resp.self.id;
                 myRoom = resp.id;
-                conference.createDataStream().then(stream=>{
-                    window.bidirectionalStream=stream;
-                });
                 if(mediaUrl){
                      startStreamingIn(myRoom, mediaUrl);
                 }
@@ -196,7 +192,6 @@ const runSocketIOSample = function() {
                       if (stream.source.audio === 'mixed' || stream.source.video ===
                         'mixed') {
                         subscribeAndRenderVideo(stream);
-                        return;
                       }
                     } else if (stream.source.audio !== 'mixed') {
                         subscribeAndRenderVideo(stream);

src/samples/conference/public/scripts/index.js

@@ -27,7 +27,7 @@ const SignalingState = {
   CONNECTED: 3,
 };
 
-const protocolVersion = '1.1';
+const protocolVersion = '1.2';
 
 /* eslint-disable valid-jsdoc */
 /**

src/sdk/conference/client.js

@@ -29,7 +29,13 @@ export class QuicConnection extends EventDispatcher {
     this._signaling = signaling;
     this._ended = false;
     this._quicStreams = new Map(); // Key is publication or subscription ID.
-    this._quicTransport = new QuicTransport(url);
+    this._quicTransport = new QuicTransport(url, {
+      serverCertificateFingerprints: [{
+        value:
+            '25:47:DA:10:A0:5B:BF:AE:61:A5:C0:53:BB:2E:9C:2C:80:B5:B9:6A:16:2C:97:0A:F2:A4:86:33:3F:02:FF:6A',
+        algorithm: 'sha-256',
+      }],
+    });
     this._subscribePromises = new Map(); // Key is subscription ID.
     this._transportId = this._token.transportId;
     this._init();
@@ -108,7 +114,8 @@ export class QuicConnection extends EventDispatcher {
 
   async _authenticate(token) {
     await this._quicTransport.ready;
-    const quicStream = await this._quicTransport.createSendStream();
+    const quicStream = await this._quicTransport.createBidirectionalStream();
+    const chunkReader = quicStream.readable.getReader();
     const writer = quicStream.writable.getWriter();
     await writer.ready;
     // 128 bit of zero indicates this is a stream for signaling.
@@ -119,6 +126,9 @@ export class QuicConnection extends EventDispatcher {
     const encodedToken = encoder.encode(token);
     writer.write(Uint32Array.of(encodedToken.length));
     writer.write(encodedToken);
+    // Server returns transport ID as an ack. Ignore it here.
+    await chunkReader.read();
+    Logger.info('Authentication success.');
   }
 
   async createSendStream() {