Implement close for QUIC stream. (#882)

This change also closes unauthenticated connections in expected time and
avoid duplicated signaling streams.

Author: jianjunz

source/agent/addons/quic/QuicTransportStream.cc

@@ -104,6 +104,12 @@ NAN_METHOD(QuicTransportStream::write)
     info.GetReturnValue().Set(Nan::New(static_cast<int>(written)));
 }
 
+NAN_METHOD(QuicTransportStream::close)
+{
+    QuicTransportStream* obj = Nan::ObjectWrap::Unwrap<QuicTransportStream>(info.Holder());
+    obj->m_stream->Close();
+}
+
 NAN_METHOD(QuicTransportStream::addDestination)
 {
     QuicTransportStream* obj = Nan::ObjectWrap::Unwrap<QuicTransportStream>(info.Holder());

source/agent/addons/quic/QuicTransportStream.h

@@ -32,6 +32,7 @@ class QuicTransportStream : public owt_base::FrameSource, public owt_base::Frame
     static NAN_MODULE_INIT(init);
     static NAN_METHOD(newInstance);
     static NAN_METHOD(write);
+    static NAN_METHOD(close);
     static NAN_METHOD(addDestination);
     static NAN_METHOD(removeDestination);
     static NAUV_WORK_CB(onContentSessionId);

source/agent/quic/webtransport/quicTransportServer.js

@@ -38,20 +38,25 @@ module.exports = class QuicTransportServer extends EventEmitter {
         if (!connection.transportId) {
           connection.close();
         }
-      }, authenticationTimeout * 1000000);
+      }, authenticationTimeout * 1000);
       connection.onincomingstream = (stream) => {
         log.info('New incoming stream.');
         stream.oncontentsessionid = (id) => {
           const streamId = this._uuidBytesToString(new Uint8Array(id))
           stream.contentSessionId = streamId;
           stream.transportId = connection.transportId;
           if (streamId === zeroUuid) {
-            // Signaling stream. Waiting for transport ID.
-            log.info('Zero content session ID.');
+            if (connection.transportId) {
+              log.error(
+                  'Received a new signaling stream on an authenticated connection. Close connection.')
+              connection.close();
+            }
+            // Signaling stream. Waiting for transport ID then.
           } else if (!connection.transportId) {
             log.error(
                 'Stream ' + streamId +
-                ' added on unauthroized transport. Close connection.');
+                ' added on unauthenticated transport. Close connection.');
+            connection.close();
           } else {
             log.debug(
                 'A new stream ' + streamId + ' is created on transport ' +

source/agent/quic/webtransport/quicTransportStreamPipeline.js

@@ -51,7 +51,6 @@ module.exports = class QuicTransportStreamPipeline {
     };
 
     this.close = function(){
-      return;
       this._quicStream.close();
     }
   }