github/plivo-node
2
0
Fork 0
mirror of https://github.com/donl/plivo-node.git synced 2026-06-30 06:12:08 -06:00
Code Issues Projects Packages Wiki Activity Actions

Node SDK retry - under development

Browse source
This commit is contained in:
Koushik-Ayila 2020-07-14 11:43:36 +05:30
parent 06980d58b4
commit 6596465713
1 changed files with 68 additions and 26 deletions
Download patch file Download diff file Expand all files Collapse all files

94
lib/rest/request.js
View file

@ -67,13 +67,79 @@ export function Request(config) {
options.timeout = config.timeout;
}
function voiceRequestFunc() {
return new Promise((resolve, reject) => {
request(options, (error, response, body) => {
if (error) {
reject(error);
return;
}
const exceptionClass = {
400: Exceptions.InvalidRequestError,
401: Exceptions.AuthenticationError,
404: Exceptions.ResourceNotFoundError,
405: Exceptions.InvalidRequestError,
500: Exceptions.ServerError,
} [response.statusCode] || Error;
// if (response.statusCode >= 200 && isVoiceReq === true){
// voiceRetryCount++;
// if (voiceRetryCount === 1){
// options.url = apiVoiceUris[1] + config.authId + '/' + action;
// console.log(voiceRetryCount,options.url)
// }
// else if (voiceRetryCount === 2){
// options.url = apiVoiceUris[2] + config.authId + '/' + action;
// console.log(voiceRetryCount,options.url)
// }
// else if (voiceRetryCount > 2){
// resolve({
// response: response,
// body: body
// });
// }
// isVoiceReq = true;
// request(options);
// }
if (!_.inRange(response.statusCode, 200, 300)) {
body = body || response.body;
// voiceRetryCount = 0;
if (typeof body === 'object') {
reject(new exceptionClass(JSON.stringify(body)));
} else {
reject(new exceptionClass(body));
}
}
else {
let body = response.body;
let isObj = typeof _body === 'object' && _body !== null && !(_body instanceof Array) && !(_body instanceof Date)
if (isObj) {
_body['statusCode'] = response.statusCode;
}
// voiceRetryCount = 0;
resolve({
response: response,
body: body
});
}
});
});
}
if (isVoiceReq === true){
var req = voiceRequestFunc();
if (req.status >= 200){
console.log(1)
}
}
else {
return new Promise((resolve, reject) => {
request(options, (error, response, body) => {
if (error) {
reject(error);
return;
}
console.log(3)
const exceptionClass = {
400: Exceptions.InvalidRequestError,
401: Exceptions.AuthenticationError,
@ -81,31 +147,8 @@ export function Request(config) {
405: Exceptions.InvalidRequestError,
500: Exceptions.ServerError,
} [response.statusCode] || Error;
if (response.statusCode >= 200 && isVoiceReq === true){
voiceRetryCount++;
if (voiceRetryCount === 1){
options.url = apiVoiceUris[1] + config.authId + '/' + action;
console.log(voiceRetryCount,options.url)
}
else if (voiceRetryCount === 2){
options.url = apiVoiceUris[2] + config.authId + '/' + action;
console.log(voiceRetryCount,options.url)
}
else if (voiceRetryCount > 2){
resolve({
response: response,
body: body
});
}
isVoiceReq = true;
request(options);
}
if (!_.inRange(response.statusCode, 200, 300)) {
console.log(5)
body = body || response.body;
voiceRetryCount = 0;
if (typeof body === 'object') {
reject(new exceptionClass(JSON.stringify(body)));
} else {
@ -113,13 +156,11 @@ export function Request(config) {
}
}
else {
console.log(4)
let body = response.body;
let isObj = typeof _body === 'object' && _body !== null && !(_body instanceof Array) && !(_body instanceof Date)
if (isObj) {
_body['statusCode'] = response.statusCode;
}
voiceRetryCount = 0;
resolve({
response: response,
body: body
@ -127,5 +168,6 @@ export function Request(config) {
}
});
});
}
};
}