Add request timeout

src/http-requests.ts

@@ -91,11 +91,13 @@ class HttpRequests {
   url: URL
   requestConfig?: Config['requestConfig']
   httpClient?: Required<Config>['httpClient']
+  timeout?: number
 
   constructor(config: Config) {
     this.headers = createHeaders(config)
     this.requestConfig = config.requestConfig
     this.httpClient = config.httpClient
+    this.timeout = config.timeout
 
     try {
       const host = constructHostURL(config.host)
@@ -140,14 +142,17 @@ class HttpRequests {
     const headers = { ...this.headers, ...config.headers }
 
     try {
-      const fetchFn = this.httpClient ? this.httpClient : fetch
-      const result = fetchFn(constructURL.toString(), {
-        ...config,
-        ...this.requestConfig,
-        method,
-        body,
-        headers,
-      })
+      const result = this.fetchWithTimeout(
+        constructURL.toString(),
+        {
+          ...config,
+          ...this.requestConfig,
+          method,
+          body,
+          headers,
+        },
+        this.timeout
+      )
 
       // When using a custom HTTP client, the response is returned to allow the user to parse/handle it as they see fit
       if (this.httpClient) {
@@ -166,6 +171,43 @@ class HttpRequests {
     }
   }
 
+  async fetchWithTimeout(
+    url: string,
+    options: RequestInit | undefined,
+    timeout: HttpRequests['timeout']
+  ): Promise<Response> {
+    return new Promise((resolve, reject) => {
+      const fetchFn = this.httpClient ? this.httpClient : fetch
+
+      const fetchPromise = fetchFn(url, options)
+
+      const promises: Array<Promise<any>> = [fetchPromise]
+
+      // TimeoutPromise will not run if undefined or zero
+      let timeoutId: ReturnType<typeof setTimeout>
+      if (timeout) {
+        const timeoutPromise = new Promise((_, reject) => {
+          timeoutId = setTimeout(() => {
+            reject(new Error('Error: Request Timed Out'))
+          }, timeout)
+        })
+
+        promises.push(timeoutPromise)
+      }
+
+      Promise.race(promises)
+        .then((response) => {
+          resolve(response)
+        })
+        .catch((error) => {
+          reject(error)
+        })
+        .finally(() => {
+          clearTimeout(timeoutId)
+        })
+    })
+  }
+
   async get(
     url: string,
     params?: { [key: string]: any },

src/types/types.ts

@@ -12,6 +12,7 @@ export type Config = {
   clientAgents?: string[]
   requestConfig?: Partial<Omit<RequestInit, 'body' | 'method'>>
   httpClient?: (input: string, init?: RequestInit) => Promise<any>
+  timeout?: number
 }
 
 ///

tests/search.test.ts

@@ -1059,6 +1059,21 @@ describe.each([
       expect(error).toHaveProperty('message', 'The user aborted a request.')
     })
   })
+
+  test(`${permission} key: search should be aborted when reaching timeout`, async () => {
+    const key = await getKey(permission)
+    const client = new MeiliSearch({
+      ...config,
+      apiKey: key,
+      timeout: 1,
+    })
+    try {
+      await client.health()
+    } catch (e: any) {
+      expect(e.message).toEqual('Error: Request Timed Out')
+      expect(e.name).toEqual('MeiliSearchCommunicationError')
+    }
+  })
 })
 
 describe.each([