fix: timeout parameter being respected

Author: manchuck

packages/vetch/__tests__/vetch.test.ts

@@ -104,10 +104,7 @@ describe('option configuration', () => {
   });
 
   test('should default to application/json', async () => {
-    nock(url)
-      .matchHeader('accept', 'application/json')
-      .get('/')
-      .reply(200, {});
+    nock(url).matchHeader('accept', 'application/json').get('/').reply(200, {});
     const res = await request({ url });
     expect(res.data).toEqual({});
   });
@@ -122,19 +119,25 @@ describe('option configuration', () => {
   test('should allow for our custom user agent', async () => {
     const options = {
       reqheaders: {
-        'user-agent': (val) => {
-          return /^@vonage\/server-sdk\/[\d].[\d].[\d].* node\/.*$/.test(
-            val,
-          );
+        'user-agent': (val: string) => {
+          return /^@vonage\/server-sdk\/[\d].[\d].[\d].* node\/.*$/.test(val);
         },
       },
     };
 
     nock(url, options).get('/').reply(200);
     const inst = new Vetch();
-    const res = await inst.request({ url });
+    await inst.request({ url });
     expect(nock.isDone()).toBeTruthy();
   });
+
+  test('should timeout', async () => {
+    nock(url).get('/').delayConnection(5).reply(200);
+    const inst = new Vetch({ timeout: 1 });
+    await expect(inst.request({ url })).rejects.toThrow(
+      'network timeout at: https://just-testing.com/',
+    );
+  });
 });
 
 describe('data handling', () => {

packages/vetch/lib/vetch.ts

@@ -3,7 +3,6 @@ import { stringify } from 'querystring';
 import merge from 'lodash.merge';
 import http from 'http';
 import https from 'https';
-import URL from 'url';
 import { VetchError } from './types/vetchError';
 import { Headers } from './interfaces/headers';
 import { VetchResponse } from './interfaces/vetchResponse';
@@ -26,9 +25,20 @@ export class Vetch {
   private async _defaultAdapter<T>(
     opts: VetchOptions,
   ): Promise<VetchResponse<T>> {
-    const res = await fetch(opts.url, opts);
-    const data = await this.getResponseData(opts, res);
-    return this.createResponse(opts, res, data);
+    const { timeout } = opts;
+    let timeoutId = null;
+    if (timeout) {
+      const controller = new AbortController();
+      timeoutId = setTimeout(() => controller.abort(), timeout);
+    }
+
+    try {
+      const res = await fetch(opts.url, opts);
+      const data = await this.getResponseData(opts, res);
+      return this.createResponse(opts, res, data);
+    } finally {
+      clearTimeout(timeoutId);
+    }
   }
 
   async request<T>(opts: VetchOptions = {}): Promise<VetchResponse<T>> {
@@ -116,10 +126,10 @@ export class Vetch {
 
     // Allow a custom timeout to be used
     const httpAgent = new http.Agent({
-      timeout: this.defaults.timeout,
+      timeout: opts.timeout,
     });
     const httpsAgent = new https.Agent({
-      timeout: this.defaults.timeout,
+      timeout: opts.timeout,
     });
     opts.agent = (parsedUrl: URL): https.Agent | http.Agent => {
       if (parsedUrl.protocol === 'http:') {