SNOW-859635: Retry Strategy

lib/connection/connection_config.js

@@ -51,6 +51,7 @@ const DEFAULT_PARAMS =
   'forceStageBindError',
   'includeRetryReason',
   'disableQueryContextCache',
+  'loginTimeout',
 ];
 
 function consolidateHostAndAccount(options)
@@ -483,6 +484,14 @@ function ConnectionConfig(options, validateCredentials, qaMode, clientInfo)
     disableQueryContextCache = options.disableQueryContextCache;
   }
 
+  let loginTimeout = 300;
+  if (Util.exists(options.loginTimeout)) {
+    Errors.checkArgumentValid(Util.isNumber(options.loginTimeout),
+    ErrorCodes.ERR_CONN_CREATE_INVALID_MAX_LOGIN_TIMEOUT);
+
+    loginTimeout = options.loginTimeout > 300 ? options.loginTimeout : 300;
+  }
+
   if (validateDefaultParameters)
   {
     for (const [key] of Object.entries(options))
@@ -793,6 +802,15 @@ function ConnectionConfig(options, validateCredentials, qaMode, clientInfo)
     return clientConfigFile;
   };
 
+  /**
+   * Returns the max login timeout
+   *
+   * @returns {Number}
+   */
+  this.getLoginTimeout = function () {
+    return loginTimeout;
+  }
+
   // save config options
   this.username = options.username;
   this.password = options.password;
@@ -948,7 +966,7 @@ function createParameters()
     },
     {
       name: PARAM_RETRY_SF_MAX_LOGIN_RETRIES,
-      defaultValue: 5,
+      defaultValue: 7,
       external: true,
       validate: isNonNegativeInteger
     },
@@ -959,12 +977,12 @@ function createParameters()
     },
     {
       name: PARAM_RETRY_SF_STARTING_SLEEP_TIME,
-      defaultValue: 0.25,
+      defaultValue: 4,
       validate: isNonNegativeNumber
     },
     {
       name: PARAM_RETRY_SF_MAX_SLEEP_TIME,
-      defaultValue: 16,
+      defaultValue: 108,
       validate: isNonNegativeNumber
     }
   ];

lib/constants/error_messages.js

@@ -68,6 +68,7 @@ exports[404040] = 'Invalid browser timeout value. The specified value must be a
 exports[404041] = 'Invalid disablQueryContextCache. The specified value must be a boolean.';
 exports[404042] = 'Invalid includeRetryReason. The specified value must be a boolean.'
 exports[404043] = 'Invalid clientConfigFile value. The specified value must be a string.';
+exports[404044] = 'Invalid loginTimeout value. The specified value must be a number.';
 
 // 405001
 exports[405001] = 'Invalid callback. The specified value must be a function.';

lib/errors.js

@@ -73,6 +73,7 @@ codes.ERR_CONN_CREATE_INVALID_BROWSER_TIMEOUT = 404040;
 codes.ERR_CONN_CREATE_INVALID_DISABLED_QUERY_CONTEXT_CACHE = 404041
 codes.ERR_CONN_CREATE_INVALID_INCLUDE_RETRY_REASON =404042
 codes.ERR_CONN_CREATE_INVALID_CLIENT_CONFIG_FILE = 404043;
+codes.ERR_CONN_CREATE_INVALID_LOGIN_TIMEOUT = 404044;
 
 // 405001
 codes.ERR_CONN_CONNECT_INVALID_CALLBACK = 405001;

lib/services/sf.js

@@ -782,6 +782,13 @@ function StateAbstract(options)
     requestOptions.headers =
       Util.apply(this.getDefaultReqHeaders(), requestOptions.headers || {});
 
+    if (Util.isLoginRequest(requestOptions.url)) {
+      Util.apply(requestOptions.headers, {
+        "CLIENT_APP_VERSION": requestOptions.json.data.CLIENT_APP_VERSION,
+        "CLIENT_APP_ID": requestOptions.json.data.CLIENT_APP_ID,
+      })
+    }
+
     // augment the options with the absolute url
     requestOptions.absoluteUrl = this.buildFullUrl(requestOptions.url);
   };
@@ -1172,7 +1179,9 @@ StateConnecting.prototype.continue = function ()
   const startTime = connectionConfig.accessUrl.startsWith('https://') ?
     Date.now() : 'FIXEDTIMESTAMP';
   const maxLoginRetries = connectionConfig.getRetrySfMaxLoginRetries();
+  const maxLoginTimeout = connectionConfig.getLoginTimeout();
   let sleep = connectionConfig.getRetrySfStartingSleepTime();
+  let totalTimeout = sleep;
   const cap = connectionConfig.getRetrySfMaxSleepTime();
   Logger.getInstance().debug("Retry Max sleep time = " + cap);
   const parent = this;
@@ -1204,10 +1213,13 @@ StateConnecting.prototype.continue = function ()
       if (Errors.isNetworkError(err) || Errors.isRequestFailedError(err))
       {
         if (numRetries < maxLoginRetries && (
-          isRetryableNetworkError(err) || isRetryableHttpError(err)))
+          isRetryableNetworkError(err) || isRetryableHttpError(err)) &&
+          totalTimeout < maxLoginTimeout) 
         {
           numRetries++;
-          sleep = Util.nextSleepTime(1, cap, sleep);
+          const jitter = Util.jitteredSleepTime(numRetries, sleep, totalTimeout, maxLoginTimeout);
+          sleep = jitter.sleep;
+          totalTimeout = jitter.totalTimeout;
           setTimeout(sendRequest, sleep * 1000);
           return;
         }

lib/util.js

@@ -405,7 +405,7 @@ exports.isNode = function ()
 /**
  * Returns the next sleep time calculated by exponential backoff with
  * decorrelated jitter.
- *  sleep = min(cap, random_between(base, sleep * 3))
+ * sleep = min(cap, random_between(base, sleep * 3))
  * for more details, check out:
  * http://www.awsarchitectureblog.com/2015/03/backoff.html
  * @param base minimum seconds
@@ -420,6 +420,74 @@ exports.nextSleepTime = function (
     Math.min(base, previousSleep * 3));
 };
 
+
+/**
+ * Return next sleep time calculated by the jitter rule.
+ *
+ * @param {Number} numofRetries 
+ * @param {Number} currentSleepTime 
+ * @param {Number} maxSleepTime 
+ * @returns {JSON} return next sleep Time and totalTime.
+ */
+exports.jitteredSleepTime = function (numofRetries, currentSleepTime, totalTimeout, maxLoginTimeout) {
+  const nextSleepTime = Math.min(maxLoginTimeout - totalTimeout, 4 * numofRetries);
+  const sleep = nextSleepTime + getJitter(currentSleepTime);
+  totalTimeout += sleep
+
+  return {sleep, totalTimeout}
+}
+
+/**
+ * Choose one of the number between two numbers.
+ *
+ * @param {Number} firstNumber 
+ * @param {Number} secondNumber 
+ * @returns {Boolean} return a random number between two numbers.
+ */
+function chooseRandom (firstNumber, secondNumber) {
+  let bigNumber;
+  let smallNumber;
+  if (firstNumber > secondNumber) {
+    bigNumber = firstNumber;
+    smallNumber = secondNumber;
+  } 
+  else if (firstNumber === secondNumber) {
+    bigNumber = 1;
+    smallNumber = 0;
+  }
+  else {
+    bigNumber = secondNumber;
+    smallNumber = firstNumber;
+  }
+
+  return (Math.random() * (bigNumber - smallNumber)) + smallNumber;
+} 
+
+exports.chooseRandom = chooseRandom;
+
+/**
+ * Check whether the request is the login-request or not.
+ *
+ * @param {Number} curWaitTime 
+ * @returns {Boolean} return jitter..
+ */
+function getJitter (curWaitTime) {
+  const multiplicationFactor = chooseRandom(1, -1);
+  const jitterAmount = 0.5 * curWaitTime * multiplicationFactor;
+  return jitterAmount;
+}
+
+/**
+ * Check whether the request is the login-request or not.
+ *
+ * @param loginurl HTTP request url
+ * @returns {Boolean} true if it is loginRequest, otherwise false.
+ */
+exports.isLoginRequest = function (loginUrl) {
+  const endPoints = ['/v1/login-request', '/authenticator-request', '/token-request',];
+  return endPoints.some((endPoint) => loginUrl.includes(endPoint));
+}
+
 /**
  * Checks if the HTTP response code is retryable
  *

test/integration/ocsp_mock/testConnectionOcspMock.js

@@ -23,6 +23,8 @@ function cloneConnOption(connOption)
 
 describe('Connection test with OCSP Mock', function ()
 {
+  this.timeout(300000);
+
   const valid = cloneConnOption(connOption.valid);
 
   console.log(connOption.valid);

test/unit/connection/connection_config_test.js

@@ -546,6 +546,16 @@ describe('ConnectionConfig: basic', function ()
         },
         errorCode: ErrorCodes.ERR_CONN_CREATE_INVALID_CLIENT_CONFIG_FILE
       },
+      {
+        name: 'invalid maxLoginTimeout',
+        options: {
+            account: 'account',
+            username: 'username',
+            password: 'password',
+            loginTimeout: 'invalud'
+        },
+        errorCode: ErrorCodes.ERR_CONN_CREATE_INVALID_MAX_LOGIN_TIMEOUT
+      },
     ];
 
   var createNegativeITCallback = function (testCase)
@@ -887,13 +897,13 @@ describe('ConnectionConfig: basic', function ()
           username: 'username',
           password: 'password',
           account: 'account',
-          disableQueryContextCache: true
+          disableQueryContextCache: true,
         },
         options:
         {
           accessUrl: 'https://account.snowflakecomputing.com',
           username: 'username',
-          password: 'password'
+          password: 'password',
         }
       },
       {
@@ -914,6 +924,23 @@ describe('ConnectionConfig: basic', function ()
             clientConfigFile: 'easy_logging_config.json'
           }
       },
+      {
+        name: 'login time out',
+        input:
+          {
+            account: 'account',
+            username: 'username',
+            password: 'password',
+            loginTimeout: 1234,
+          },
+        options:
+          {
+            accessUrl: 'https://account.snowflakecomputing.com',
+            username: 'username',
+            password: 'password',
+            account: 'account',
+          }
+      },
     ];
 
   var createItCallback = function (testCase)

test/unit/mock/mock_http_client.js

@@ -174,7 +174,9 @@ function buildRequestOutputMappings(clientInfo)
           headers:
             {
               'Accept': 'application/json',
-              'Content-Type': 'application/json'
+              'Content-Type': 'application/json',
+              "CLIENT_APP_VERSION": clientInfo.version,
+              "CLIENT_APP_ID": "JavaScript",
             },
           json:
             {
@@ -1158,7 +1160,9 @@ function buildRequestOutputMappings(clientInfo)
           headers:
             {
               'Accept': 'application/json',
-              'Content-Type': 'application/json'
+              'Content-Type': 'application/json',
+              "CLIENT_APP_VERSION": clientInfo.version,
+              "CLIENT_APP_ID": "JavaScript"
             },
           json:
             {
@@ -1373,7 +1377,9 @@ function buildRequestOutputMappings(clientInfo)
           headers:
             {
               'Accept': 'application/json',
-              'Content-Type': 'application/json'
+              'Content-Type': 'application/json',
+              "CLIENT_APP_VERSION": clientInfo.version,
+              "CLIENT_APP_ID": "JavaScript"
             },
           json:
             {
@@ -1478,7 +1484,9 @@ function buildRequestOutputMappings(clientInfo)
           headers:
             {
               'Accept': 'application/json',
-              'Content-Type': 'application/json'
+              'Content-Type': 'application/json',
+              "CLIENT_APP_VERSION": clientInfo.version,
+              "CLIENT_APP_ID": "JavaScript"
             },
           json:
             {
@@ -1583,7 +1591,9 @@ function buildRequestOutputMappings(clientInfo)
           headers:
             {
               'Accept': 'application/json',
-              'Content-Type': 'application/json'
+              'Content-Type': 'application/json',
+              "CLIENT_APP_VERSION": clientInfo.version,
+              "CLIENT_APP_ID": "JavaScript"
             },
           json:
             {
@@ -1670,7 +1680,9 @@ function buildRequestOutputMappings(clientInfo)
           headers:
             {
               'Accept': 'application/json',
-              'Content-Type': 'application/json'
+              'Content-Type': 'application/json',
+              "CLIENT_APP_VERSION": clientInfo.version,
+              "CLIENT_APP_ID": "JavaScript"
             },
           json:
             {
@@ -1706,7 +1718,10 @@ function buildRequestOutputMappings(clientInfo)
           headers:
             {
               'Accept': 'application/json',
-              'Content-Type': 'application/json'
+              'Content-Type': 'application/json',
+              "CLIENT_APP_VERSION": clientInfo.version,
+              "CLIENT_APP_ID": "JavaScript"
+
             },
           json:
             {
@@ -1742,7 +1757,9 @@ function buildRequestOutputMappings(clientInfo)
           headers:
             {
               'Accept': 'application/json',
-              'Content-Type': 'application/json'
+              'Content-Type': 'application/json',
+              "CLIENT_APP_VERSION": clientInfo.version,
+              "CLIENT_APP_ID": "JavaScript"
             },
           json:
             {