Skip to content

GitLab

Merged
Created by Dan Jones@danjonOwner

Resolve "Error handling on send"

Viewing commit b66f89a7
Next
3 files
+ 87
- 15
Show latest version
di‎st‎
adapter‎.esm.js‎ +29 -5
adapt‎er.js‎ +29 -5
src/a‎dapter‎
inde‎x.js‎ +29 -5
  • b66f89a7 
    At the moment if the backbone token secret changes
the adapter can have a token it thinks is valid but
which can no longer be decrypted by the backbone.

On a 403 error this will trigger a new token grant
and resend the request with the new token.
dist/adapter.esm.js
+ 29
- 5
Show all unchanged lines Show 20 lines
* Messages should be passed through encode before sending
* @param {string} topic
* @param {string} body
* @param {boolean} is_retry
* @returns
*/
publish(topic, body) {
publish(topic, body, is_retry=false) {
let adapterConfig = this.config;
return this.getAuthorizationHeader()
.then((headers) => {
Show 20 lines Show all unchanged lines Show 20 lines
return response;
})
.catch((error) => {
return Promise.reject(error);
let retry = false;
switch(error.response.status_code) {
case 403: {
this.credentials = null;
retry = true;
} break;
case 503: {
retry = true;
}
}
if (retry && !is_retry) return this.publish(topic, body, true);
else return Promise.reject(error);
});
}
Show 20 lines Show all unchanged lines Show 20 lines
* quickly in an emergency scenario.
*
* Messages should be passed through encode before sending
* @param {*} body
* @param {string} body
* @param {boolean} is_retry
* @returns
*/
broadcast(body) {
broadcast(body, is_retry=false) {
let adapterConfig = this.config;
return this.getAuthorizationHeader()
.then((headers) => {
Show 20 lines Show all unchanged lines Show 20 lines
return response;
})
.catch((error) => {
return Promise.reject(error);
let retry = false;
switch(error.response.status_code) {
case 403: {
this.credentials = null;
retry = true;
} break;
case 503: {
retry = true;
}
}
if (retry && !is_retry) return this.broadcast(body, true);
else return Promise.reject(error);
});
}
}
Show 20 lines Show all unchanged lines
dist/adapter.js
+ 29
- 5
Show all unchanged lines Show 20 lines
* Messages should be passed through encode before sending
* @param {string} topic
* @param {string} body
* @param {boolean} is_retry
* @returns
*/
publish(topic, body) {
publish(topic, body, is_retry=false) {
let adapterConfig = this.config;
return this.getAuthorizationHeader()
.then((headers) => {
Show 20 lines Show all unchanged lines Show 20 lines
return response;
})
.catch((error) => {
return Promise.reject(error);
let retry = false;
switch(error.response.status_code) {
case 403: {
this.credentials = null;
retry = true;
} break;
case 503: {
retry = true;
}
}
if (retry && !is_retry) return this.publish(topic, body, true);
else return Promise.reject(error);
});
}
Show 20 lines Show all unchanged lines Show 20 lines
* quickly in an emergency scenario.
*
* Messages should be passed through encode before sending
* @param {*} body
* @param {string} body
* @param {boolean} is_retry
* @returns
*/
broadcast(body) {
broadcast(body, is_retry=false) {
let adapterConfig = this.config;
return this.getAuthorizationHeader()
.then((headers) => {
Show 20 lines Show all unchanged lines Show 20 lines
return response;
})
.catch((error) => {
return Promise.reject(error);
let retry = false;
switch(error.response.status_code) {
case 403: {
this.credentials = null;
retry = true;
} break;
case 503: {
retry = true;
}
}
if (retry && !is_retry) return this.broadcast(body, true);
else return Promise.reject(error);
});
}
}
Show 20 lines Show all unchanged lines
src/adapter/index.js
+ 29
- 5
Show all unchanged lines Show 20 lines
* Messages should be passed through encode before sending
* @param {string} topic
* @param {string} body
* @param {boolean} is_retry
* @returns
*/
publish(topic, body) {
publish(topic, body, is_retry=false) {
let adapterConfig = this.config;
return this.getAuthorizationHeader()
.then((headers) => {
Show 20 lines Show all unchanged lines Show 20 lines
return response;
})
.catch((error) => {
return Promise.reject(error);
let retry = false;
switch(error.response.status_code) {
case 403: {
this.credentials = null;
retry = true;
} break;
case 503: {
retry = true;
}
}
if (retry && !is_retry) return this.publish(topic, body, true);
else return Promise.reject(error);
});
}
Show 20 lines Show all unchanged lines Show 20 lines
* quickly in an emergency scenario.
*
* Messages should be passed through encode before sending
* @param {*} body
* @param {string} body
* @param {boolean} is_retry
* @returns
*/
broadcast(body) {
broadcast(body, is_retry=false) {
let adapterConfig = this.config;
return this.getAuthorizationHeader()
.then((headers) => {
Show 20 lines Show all unchanged lines Show 20 lines
return response;
})
.catch((error) => {
return Promise.reject(error);
let retry = false;
switch(error.response.status_code) {
case 403: {
this.credentials = null;
retry = true;
} break;
case 503: {
retry = true;
}
}
if (retry && !is_retry) return this.broadcast(body, true);
else return Promise.reject(error);
});
}
}