typedrequest/ts/typedrequest.classes.typedrequest.ts

45 lines
1.4 KiB
TypeScript
Raw Normal View History

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> {
2020-06-25 23:53:05 +00:00
public webrequest = new plugins.webrequest.WebRequest();
2019-08-23 16:01:37 +00:00
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']> {
2020-06-25 23:53:05 +00:00
const response = await this.webrequest.postJson(this.urlEndPoint, {
method: this.method,
request: fireArg,
response: null
2019-08-23 16:01:37 +00:00
});
2020-06-25 23:53:05 +00:00
const responseBody: T = response;
2019-09-01 13:39:08 +00:00
if (responseBody.error) {
2020-06-25 23:53:05 +00:00
console.error(
`Got an error ${responseBody.error.text} with data ${JSON.stringify(
responseBody.error.data
)}`
);
2020-06-16 22:00:38 +00:00
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
}
}