Add support for timeouts

myrotvorets · May 22, 2022 · 7740e55 · 7740e55
1 parent c6c038a
commit 7740e55
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 2 deletions.
diff --git a/src/clientbase.ts b/src/clientbase.ts
@@ -12,6 +12,7 @@ export class ClientBase {
     private _transport: IRemoteTransport;
     private readonly _encoder: IFaceXRequestEncoder;
     protected _requestBuilder: IFaceXRequestBuilder;
+    private _timeout = 15000;
 
     public constructor(
         url: string,
@@ -33,6 +34,14 @@ export class ClientBase {
         this._transport = transport;
     }
 
+    public get timeout(): number {
+        return this._timeout;
+    }
+
+    public set timeout(timeout: number) {
+        this._timeout = timeout;
+    }
+
     protected async _sendRequest<R extends Response>(req: FaceXRequest): Promise<R> {
         dbg(req);
         const encoded = await this._encoder.encode(req);
@@ -43,7 +52,7 @@ export class ClientBase {
         };
 
         dbgll('SEND:', encoded);
-        const text = await this._transport.post(this._url, encoded, headers);
+        const text = await this._transport.post(this._url, encoded, headers, this._timeout);
         dbgll('RECV:', text);
 
         let body: RawResponse;

diff --git a/src/interfaces.ts b/src/interfaces.ts
@@ -18,7 +18,7 @@ export interface FaceXRequest {
 }
 
 export interface IRemoteTransport {
-    post(url: URL, data: string, headers: Record<string, string>): Promise<string>;
+    post(url: URL, data: string, headers: Record<string, string>, timeout?: number): Promise<string>;
 }
 
 export interface IFaceXRequestEncoder {