2019-08-23 16:01:37 +00:00
|
|
|
import * as plugins from './typedrequest.plugins';
|
2020-06-16 22:00:38 +00:00
|
|
|
import { TypedResponseError } from './typedrequest.classes.typedresponseerror';
|
2019-08-23 16:01:37 +00:00
|
|
|
|
|
|
|
export class TypedRequest<T extends plugins.typedRequestInterfaces.ITypedRequest> {
|
|
|
|
public urlEndPoint: string;
|
|
|
|
public method: string;
|
|
|
|
|
|
|
|
// STATIC
|
|
|
|
constructor(urlEndPointArg: string, methodArg: T['method']) {
|
|
|
|
this.urlEndPoint = urlEndPointArg;
|
|
|
|
this.method = methodArg;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* firest the request
|
|
|
|
*/
|
|
|
|
public async fire(fireArg: T['request']): Promise<T['response']> {
|
2019-09-01 11:17:21 +00:00
|
|
|
const response = await plugins.smartrequest.postJson(this.urlEndPoint, {
|
|
|
|
requestBody: {
|
2019-08-23 16:01:37 +00:00
|
|
|
method: this.method,
|
|
|
|
request: fireArg,
|
|
|
|
response: null
|
2019-09-01 11:17:21 +00:00
|
|
|
}
|
2019-08-23 16:01:37 +00:00
|
|
|
});
|
2019-09-01 13:39:08 +00:00
|
|
|
const responseBody: T = response.body;
|
|
|
|
if (responseBody.error) {
|
2020-06-16 22:00:38 +00:00
|
|
|
console.error(`Got an error ${responseBody.error.text} with data ${JSON.stringify(responseBody.error.data)}`);
|
|
|
|
if (!responseBody.retry) {
|
|
|
|
throw new TypedResponseError(responseBody.error.text, responseBody.error.data);
|
|
|
|
}
|
2020-02-11 18:55:07 +00:00
|
|
|
return null;
|
2019-09-01 13:39:08 +00:00
|
|
|
}
|
2020-02-11 18:55:07 +00:00
|
|
|
if (responseBody.retry) {
|
2020-02-12 08:29:43 +00:00
|
|
|
console.log(`server requested retry for the following reason: ${responseBody.retry.reason}`);
|
|
|
|
await plugins.smartdelay.delayFor(responseBody.retry.waitForMs);
|
|
|
|
// tslint:disable-next-line: no-return-await
|
|
|
|
return await this.fire(fireArg);
|
|
|
|
}
|
2020-02-11 18:55:07 +00:00
|
|
|
return responseBody.response;
|
2019-08-23 16:01:37 +00:00
|
|
|
}
|
|
|
|
}
|