Update QuicFactory for QUIC SDK API change.

Author: jianjunz

source/agent/addons/quic/QuicFactory.cc

@@ -15,7 +15,7 @@ std::once_flag getQuicFactoryOnce;
 std::shared_ptr<QuicFactory> QuicFactory::s_quicFactory = nullptr;
 
 QuicFactory::QuicFactory()
-    : m_quicTransportFactory(std::make_shared<owt::quic::QuicTransportFactory>())
+    : m_quicTransportFactory(std::shared_ptr<owt::quic::QuicTransportFactory>(owt::quic::QuicTransportFactory::Create()))
 {
     ELOG_DEBUG("QuicFactory ctor.");
 }

source/agent/addons/quic/QuicTransportConnection.h

@@ -43,6 +43,7 @@ class QuicTransportConnection : public Nan::ObjectWrap, public owt::quic::QuicTr
 protected:
     // Overrides owt::quic::QuicTransportSessionInterface::Visitor.
     void OnIncomingStream(owt::quic::QuicTransportStreamInterface*) override;
+    void OnCanCreateNewOutgoingStream(bool unidirectional) override { }
 
     // Overrides QuicTransportStream::Visitor.
     void onEnded() override;

source/agent/addons/quic/QuicTransportStream.cc

@@ -56,6 +56,11 @@ void QuicTransportStream::OnCanWrite()
     ELOG_DEBUG("On can write.");
 }
 
+void QuicTransportStream::OnFinRead()
+{
+    ELOG_DEBUG("On FIN read.");
+}
+
 NAN_MODULE_INIT(QuicTransportStream::init)
 {
     Local<FunctionTemplate> tpl = Nan::New<FunctionTemplate>(newInstance);

source/agent/addons/quic/QuicTransportStream.h

@@ -50,6 +50,7 @@ class QuicTransportStream : public owt_base::FrameSource, public owt_base::Frame
     // Overrides owt::quic::QuicTransportStreamInterface::Visitor.
     void OnCanRead() override;
     void OnCanWrite() override;
+    void OnFinRead() override;
 
 private:
     // Try to read content session ID from data buffered.

source/agent/quic/webtransport/quicTransportServer.js

@@ -38,14 +38,16 @@ module.exports = class QuicTransportServer extends EventEmitter {
         if (!connection.transportId) {
           connection.close();
         }
-      }, authenticationTimeout * 1000);
+      }, authenticationTimeout * 100000);
       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.');
           } else if (!connection.transportId) {
             log.error(
                 'Stream ' + streamId +
@@ -60,6 +62,7 @@ module.exports = class QuicTransportServer extends EventEmitter {
         stream.ondata = (data) => {
           if (stream.contentSessionId === zeroUuid) {
             const transportId = data.toString('utf8');
+            log.info('Received new transport ID: '+transportId);
             if (!this._assignedTransportIds.includes(transportId)) {
               log.info(JSON.stringify(connection));
               connection.close();