Tokens have URL for WebTransport connections.

A new property webTransportUrl is added to tokens if a QUIC agent is
running.

Author: jianjunz

source/agent/index.js

@@ -95,6 +95,7 @@ var joinCluster = function (on_ok) {
         joinRetry: config.cluster.worker.join_retry,
         info: {
             ip: config.cluster.worker.ip,
+            port: config[myPurpose] ? config[myPurpose].port : undefined,
             purpose: myPurpose,
             state: 2,
             max_load: config.cluster.worker.load.max,

source/data_access/model/tokenModel.js

@@ -15,7 +15,8 @@ var TokenSchema = new Schema({
   origin: {},
   code: String,
   secure: Boolean,
-  host: String
+  host: String,
+  webTransportUrl: String
 });
 
 module.exports = mongoose.model('Token', TokenSchema);

source/management_api/requestHandler.js

@@ -33,28 +33,37 @@ var log = require('./logger').logger.getLogger('RequestHandler');
 var cluster_name = ((global.config || {}).cluster || {}).name || 'owt-cluster';
 var e = require('./errors');
 
-exports.schedulePortal = function (tokenCode, origin, callback) {
+const scheduleAgent = function(agentName, tokenCode, origin, attempts, callback) {
     var keepTrying = true;
 
-    var tryFetchingPortal = function (attempts) {
+    var tryFetchingAgent = function(attempts) {
         if (attempts <= 0) {
             return callback('timeout');
         }
 
-        rpc.callRpc(cluster_name, 'schedule', ['portal', tokenCode, origin, 60 * 1000], {callback: function (result) {
+        rpc.callRpc(cluster_name, 'schedule', [ agentName, tokenCode, origin, 60 * 1000 ], { callback : function(result) {
             if (result === 'timeout' || result === 'error') {
                 if (keepTrying) {
-                    log.info('Faild in scheduling portal, tokenCode:', tokenCode, ', keep trying.');
-                    setTimeout(function () {tryFetchingPortal(attempts - (result === 'timeout' ? 4 : 1));}, 1000);
+                    log.info('Faild in scheduling ', agentName, ' tokenCode:', tokenCode, ', keep trying.');
+                    setTimeout(function() { tryFetchingAgent(attempts - (result === 'timeout' ? 4 : 1)); }, 1000);
                 }
             } else {
                 callback(result.info);
                 keepTrying = false;
             }
-        }});
+        } });
     };
 
-    tryFetchingPortal(60);
+    tryFetchingAgent(attempts);
+};
+
+exports.schedulePortal = function(tokenCode, origin, callback) {
+    return scheduleAgent('portal', tokenCode, origin, 60, callback);
+};
+
+exports.scheduleQuicAgent = async function(tokenCode, origin, callback) {
+    // QUIC agent may not be enabled in all deployment environment, at least before CI for QUIC SDK is ready. Attempts less times to reduce response time for creating tokens.
+    return scheduleAgent('quic', tokenCode, origin, 5, callback);
 };
 
 const scheduleRoomController = function (roomId) {

source/management_api/resource/v1/tokensResource.js

@@ -39,14 +39,15 @@ var log = logger.getLogger('TokensResource');
 
 var getTokenString = function (id, token) {
     return dataAccess.token.key().then(function(serverKey) {
-        var toSign = id + ',' + token.host,
+        var toSign = id + ',' + token.host + ',' + token.webTransportUrl,
             hex = crypto.createHmac('sha256', serverKey).update(toSign).digest('hex'),
             signed = (new Buffer(hex)).toString('base64'),
 
             tokenJ = {
                 tokenId: id,
                 host: token.host,
                 secure: token.secure,
+                webTransportUrl: token.webTransportUrl,
                 signature: signed
             },
             tokenS = (new Buffer(JSON.stringify(tokenJ))).toString('base64');
@@ -100,7 +101,7 @@ var generateToken = function (currentRoom, authData, origin, callback) {
             return;
         }
 
-	if(ec.via_host !== '') {
+        if(ec.via_host !== '') {
             if(ec.via_host.indexOf('https') == 0) {
                 token.secure = true;
                 token.host = ec.via_host.substr(8);
@@ -120,11 +121,22 @@ var generateToken = function (currentRoom, authData, origin, callback) {
             token.host += ':' + ec.port;
         }
 
-        dataAccess.token.create(token, function(id) {
-            getTokenString(id, token)
-                .then((tokenS) => {
-                    callback(tokenS);
-                });
+        // TODO: Schedule QUIC agent and portal parallelly.
+        requestHandler.scheduleQuicAgent(token.code, origin, info => {
+            if (info !== 'timeout') {
+                let hostname = info.hostname;
+                if (!hostname) {
+                    hostname = info.ip;
+                }
+                // TODO: Rename "echo".
+                token.webTransportUrl = 'quic-transport://' + hostname + ':' + info.port + '/echo';
+            }
+            dataAccess.token.create(token, function(id) {
+                getTokenString(id, token)
+                    .then((tokenS) => {
+                        callback(tokenS);
+                    });
+            });
         });
     });
 };

source/portal/portal.js

@@ -35,7 +35,7 @@ var Portal = function(spec, rpcReq) {
     }
 
     var calculateSignature = function (token) {
-      var toSign = token.tokenId + ',' + token.host,
+      var toSign = token.tokenId + ',' + token.host + ',' + token.webTransportUrl,
         signed = crypto.createHmac('sha256', token_key).update(toSign).digest('hex');
       return (new Buffer(signed)).toString('base64');
     };