Merge branch '30-fix-fast-polling-race-condition' into 'dev'

Resolve "Fix fast polling race condition"

Closes #30

See merge request !20

CHANGELOG.md

@@ -7,6 +7,10 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 
 ## [Unreleased]
 
+### Fixed
+
+- Wait for authentication to complete for fast polling rates
+
 ### Changed
 
 - Add hyphen to regex for schema version to enable issue branches

dist/adapter.esm.js

@@ -8,6 +8,7 @@ class Adapter {
     this.protocol = protocol;
     this.config = config;
     this.axios = axios;
+    this.authenticating = false;
   }
 
   /**
@@ -44,6 +45,10 @@ class Adapter {
    * @returns {object}
    */
   getAuthorizationHeader() {
+    if (this.authenticating) {
+      // return an pseudo response with an ignored status
+      return Promise.reject({ response: { status: 405 } });
+    }
     if (!this.tokenValid())
       return this.auth().then((response) => {
         return {
@@ -62,6 +67,7 @@ class Adapter {
    * @returns {object}
    */
   auth() {
+    this.authenticating = true;
     let adapterConfig = this.config;
     return this.axios
       .get(`${adapterConfig.api}/token`, {
@@ -72,9 +78,11 @@ class Adapter {
       })
       .then((response) => {
         this.credentials = response.data;
+        this.authenticating = false;
         return response;
       })
       .catch((error) => {
+        this.authenticating = false;
         return Promise.reject(error);
       });
   }
@@ -116,6 +124,7 @@ class Adapter {
               retry = true;
             }
             break;
+          // ignore 405 from auth in progress
           case 503: {
             retry = true;
           }

dist/adapter.js

@@ -10,6 +10,7 @@ class Adapter {
     this.protocol = protocol;
     this.config = config;
     this.axios = axios;
+    this.authenticating = false;
   }
 
   /**
@@ -46,6 +47,10 @@ class Adapter {
    * @returns {object}
    */
   getAuthorizationHeader() {
+    if (this.authenticating) {
+      // return an pseudo response with an ignored status
+      return Promise.reject({ response: { status: 405 } });
+    }
     if (!this.tokenValid())
       return this.auth().then((response) => {
         return {
@@ -64,6 +69,7 @@ class Adapter {
    * @returns {object}
    */
   auth() {
+    this.authenticating = true;
     let adapterConfig = this.config;
     return this.axios
       .get(`${adapterConfig.api}/token`, {
@@ -74,9 +80,11 @@ class Adapter {
       })
       .then((response) => {
         this.credentials = response.data;
+        this.authenticating = false;
         return response;
       })
       .catch((error) => {
+        this.authenticating = false;
         return Promise.reject(error);
       });
   }
@@ -118,6 +126,7 @@ class Adapter {
               retry = true;
             }
             break;
+          // ignore 405 from auth in progress
           case 503: {
             retry = true;
           }

src/adapter/index.js

@@ -8,6 +8,7 @@ export class Adapter {
     this.protocol = protocol;
     this.config = config;
     this.axios = axios;
+    this.authenticating = false;
   }
 
   /**
@@ -44,6 +45,10 @@ export class Adapter {
    * @returns {object}
    */
   getAuthorizationHeader() {
+    if (this.authenticating) {
+      // return an pseudo response with an ignored status
+      return Promise.reject({ response: { status: 405 } });
+    }
     if (!this.tokenValid())
       return this.auth().then((response) => {
         return {
@@ -62,6 +67,7 @@ export class Adapter {
    * @returns {object}
    */
   auth() {
+    this.authenticating = true;
     let adapterConfig = this.config;
     return this.axios
       .get(`${adapterConfig.api}/token`, {
@@ -72,9 +78,11 @@ export class Adapter {
       })
       .then((response) => {
         this.credentials = response.data;
+        this.authenticating = false;
         return response;
       })
       .catch((error) => {
+        this.authenticating = false;
         return Promise.reject(error);
       });
   }
@@ -116,6 +124,7 @@ export class Adapter {
               retry = true;
             }
             break;
+          // ignore 405 from auth in progress
           case 503: {
             retry = true;
           }