fix(postgrest): bubble up fetch error causes and codes

Author: mandarini

packages/core/postgrest-js/src/PostgrestBuilder.ts

@@ -209,18 +209,40 @@ export default abstract class PostgrestBuilder<
       return postgrestResponse
     })
     if (!this.shouldThrowOnError) {
-      res = res.catch((fetchError) => ({
-        error: {
-          message: `${fetchError?.name ?? 'FetchError'}: ${fetchError?.message}`,
-          details: `${fetchError?.stack ?? ''}`,
-          hint: '',
-          code: `${fetchError?.code ?? ''}`,
-        },
-        data: null,
-        count: null,
-        status: 0,
-        statusText: '',
-      }))
+      res = res.catch((fetchError) => {
+        // Extract cause information if available (e.g., DNS errors, network failures)
+        const cause = fetchError?.cause
+        const causeCode = cause?.code ?? ''
+        const causeMessage = cause?.message ?? ''
+
+        // Prefer the underlying cause code (e.g., ENOTFOUND) over the wrapper error code
+        const errorCode = causeCode || fetchError?.code || ''
+
+        // Build a detailed error message that includes cause information
+        let errorDetails = fetchError?.stack ?? ''
+        if (cause) {
+          errorDetails += `\n\nCaused by: ${cause?.name ?? 'Error'}: ${causeMessage}`
+          if (cause?.stack) {
+            errorDetails += `\n${cause.stack}`
+          }
+          if (causeCode) {
+            errorDetails += `\nError code: ${causeCode}`
+          }
+        }
+
+        return {
+          error: {
+            message: `${fetchError?.name ?? 'FetchError'}: ${fetchError?.message}`,
+            details: errorDetails,
+            hint: causeMessage ? `Underlying cause: ${causeMessage}` : '',
+            code: errorCode,
+          },
+          data: null,
+          count: null,
+          status: 0,
+          statusText: '',
+        }
+      })
     }
 
     return res.then(onfulfilled, onrejected)

packages/core/postgrest-js/test/fetch-errors.test.ts

@@ -0,0 +1,160 @@
+import { PostgrestClient } from '../src/index'
+import { Database } from './types.override'
+
+describe('Fetch error handling', () => {
+  test('should bubble up DNS error code (ENOTFOUND) from fetch cause', async () => {
+    // Create a client with an invalid domain that will trigger DNS resolution error
+    const postgrest = new PostgrestClient<Database>(
+      'https://invalid-domain-that-does-not-exist.local'
+    )
+
+    const res = await postgrest.from('users').select()
+
+    expect(res.error).toBeTruthy()
+    expect(res.data).toBeNull()
+    expect(res.status).toBe(0)
+    expect(res.statusText).toBe('')
+
+    // The error code should be ENOTFOUND from the cause
+    expect(res.error!.code).toBe('ENOTFOUND')
+
+    // The message should still contain the fetch error
+    expect(res.error!.message).toContain('fetch failed')
+
+    // The details should contain cause information
+    expect(res.error!.details).toContain('Caused by:')
+    expect(res.error!.details).toContain('ENOTFOUND')
+
+    // The hint should contain the underlying cause message
+    expect(res.error!.hint).toContain('getaddrinfo ENOTFOUND')
+  })
+
+  test('should handle network errors with custom fetch implementation', async () => {
+    // Simulate a network error with a cause
+    const mockFetch = jest.fn().mockRejectedValue(
+      Object.assign(new TypeError('fetch failed'), {
+        cause: Object.assign(new Error('getaddrinfo ENOTFOUND example.com'), {
+          code: 'ENOTFOUND',
+          errno: -3008,
+          syscall: 'getaddrinfo',
+          hostname: 'example.com',
+        }),
+      })
+    )
+
+    const postgrest = new PostgrestClient<Database>('https://example.com', {
+      fetch: mockFetch as any,
+    })
+
+    const res = await postgrest.from('users').select()
+
+    expect(res.error).toBeTruthy()
+    expect(res.error!.code).toBe('ENOTFOUND')
+    expect(res.error!.message).toBe('TypeError: fetch failed')
+    expect(res.error!.details).toContain('Caused by:')
+    expect(res.error!.details).toContain('getaddrinfo ENOTFOUND example.com')
+    expect(res.error!.details).toContain('Error code: ENOTFOUND')
+    expect(res.error!.hint).toContain('getaddrinfo ENOTFOUND example.com')
+  })
+
+  test('should handle connection refused errors', async () => {
+    // Simulate a connection refused error
+    const mockFetch = jest.fn().mockRejectedValue(
+      Object.assign(new TypeError('fetch failed'), {
+        cause: Object.assign(new Error('connect ECONNREFUSED 127.0.0.1:9999'), {
+          code: 'ECONNREFUSED',
+          errno: -61,
+          syscall: 'connect',
+          address: '127.0.0.1',
+          port: 9999,
+        }),
+      })
+    )
+
+    const postgrest = new PostgrestClient<Database>('http://localhost:9999', {
+      fetch: mockFetch as any,
+    })
+
+    const res = await postgrest.from('users').select()
+
+    expect(res.error).toBeTruthy()
+    expect(res.error!.code).toBe('ECONNREFUSED')
+    expect(res.error!.details).toContain('connect ECONNREFUSED')
+    expect(res.error!.hint).toContain('connect ECONNREFUSED')
+  })
+
+  test('should handle timeout errors', async () => {
+    // Simulate a timeout error
+    const mockFetch = jest.fn().mockRejectedValue(
+      Object.assign(new TypeError('fetch failed'), {
+        cause: Object.assign(new Error('request timeout'), {
+          code: 'ETIMEDOUT',
+          errno: -60,
+          syscall: 'connect',
+        }),
+      })
+    )
+
+    const postgrest = new PostgrestClient<Database>('https://example.com', {
+      fetch: mockFetch as any,
+    })
+
+    const res = await postgrest.from('users').select()
+
+    expect(res.error).toBeTruthy()
+    expect(res.error!.code).toBe('ETIMEDOUT')
+    expect(res.error!.details).toContain('request timeout')
+  })
+
+  test('should handle fetch errors without cause gracefully', async () => {
+    // Simulate a fetch error without cause
+    const mockFetch = jest.fn().mockRejectedValue(
+      Object.assign(new TypeError('fetch failed'), {
+        code: 'FETCH_ERROR',
+      })
+    )
+
+    const postgrest = new PostgrestClient<Database>('https://example.com', {
+      fetch: mockFetch as any,
+    })
+
+    const res = await postgrest.from('users').select()
+
+    expect(res.error).toBeTruthy()
+    expect(res.error!.code).toBe('FETCH_ERROR')
+    expect(res.error!.message).toBe('TypeError: fetch failed')
+    expect(res.error!.hint).toBe('')
+  })
+
+  test('should handle generic errors without code', async () => {
+    // Simulate a generic error
+    const mockFetch = jest.fn().mockRejectedValue(new Error('Something went wrong'))
+
+    const postgrest = new PostgrestClient<Database>('https://example.com', {
+      fetch: mockFetch as any,
+    })
+
+    const res = await postgrest.from('users').select()
+
+    expect(res.error).toBeTruthy()
+    expect(res.error!.code).toBe('')
+    expect(res.error!.message).toBe('Error: Something went wrong')
+  })
+
+  test('should throw error when using throwOnError with fetch failure', async () => {
+    const mockFetch = jest.fn().mockRejectedValue(
+      Object.assign(new TypeError('fetch failed'), {
+        cause: Object.assign(new Error('getaddrinfo ENOTFOUND example.com'), {
+          code: 'ENOTFOUND',
+        }),
+      })
+    )
+
+    const postgrest = new PostgrestClient<Database>('https://example.com', {
+      fetch: mockFetch as any,
+    })
+
+    // When throwOnError is used, the error should be thrown instead of returned
+    await expect(postgrest.from('users').select().throwOnError()).rejects.toThrow('fetch failed')
+  })
+})