fix(functions): failing test

Author: mandarini

package-lock.json

@@ -116,8 +116,18 @@ export async function runRelay(
         await new Promise((resolve) => setTimeout(resolve, 1000))
         return new Relay(startedRelay, id, execCache, execRun)
       }
-    } catch {
-      /* we actually don't care about errors here */
+    } catch (error) {
+      // Native fetch throws an error when it encounters HTTP 101 (WebSocket upgrade)
+      // If we get a network error that indicates the server responded (even with 101),
+      // we consider the function ready to serve
+      if (error instanceof TypeError && error.message.includes('fetch')) {
+        // This likely means we got a 101 response that native fetch couldn't handle
+        // The server is responding, so consider it ready
+        log(`function started to serve (detected via 101 error): ${slug + '-' + id}`)
+        await new Promise((resolve) => setTimeout(resolve, 1000))
+        return new Relay(startedRelay, id, execCache, execRun)
+      }
+      // For other errors (connection refused, etc.), continue retrying
     }
     await new Promise((resolve) => setTimeout(resolve, 500))
   }

packages/core/functions-js/test/relay/container.ts

@@ -116,7 +116,7 @@ The `wrapper.mjs` file simply re-exports the CommonJS build, allowing the packag
 
 ```bash
 # Run all tests (from monorepo root)
-npx nx test postgrest-js
+npx nx test:ci:postgrest postgrest-js
 ```
 
 This single command automatically:
@@ -196,4 +196,4 @@ For major changes or if you're unsure about something, please open an issue firs
 
 ## License
 
-This repo is licensed under MIT License.
+This repo is licensed under MIT License.

packages/core/postgrest-js/README.md

@@ -2076,72 +2076,29 @@ test('custom fetch function', async () => {
   )
 })
 
-test('handles undefined global fetch', async () => {
-  // Store original fetch
-  const originalFetch = globalThis.fetch
-  // Delete global fetch to simulate environments where it's undefined
-  delete (globalThis as any).fetch
+test('uses native fetch when no custom fetch provided', async () => {
+  // Spy on the global fetch to verify it's being called
+  const fetchSpy = jest.spyOn(globalThis, 'fetch')
 
-  try {
-    const postgrestClient = new PostgrestClient<Database>(REST_URL)
-    const result = await postgrestClient.from('users').select()
-    expect(result).toMatchInlineSnapshot(`
-      {
-        "count": null,
-        "data": [
-          {
-            "age_range": "[1,2)",
-            "catchphrase": "'cat' 'fat'",
-            "data": null,
-            "status": "ONLINE",
-            "username": "supabot",
-          },
-          {
-            "age_range": "[25,35)",
-            "catchphrase": "'bat' 'cat'",
-            "data": null,
-            "status": "OFFLINE",
-            "username": "kiwicopple",
-          },
-          {
-            "age_range": "[25,35)",
-            "catchphrase": "'bat' 'rat'",
-            "data": null,
-            "status": "ONLINE",
-            "username": "awailas",
-          },
-          {
-            "age_range": "[20,30)",
-            "catchphrase": "'json' 'test'",
-            "data": {
-              "foo": {
-                "bar": {
-                  "nested": "value",
-                },
-                "baz": "string value",
-              },
-            },
-            "status": "ONLINE",
-            "username": "jsonuser",
-          },
-          {
-            "age_range": "[20,30)",
-            "catchphrase": "'fat' 'rat'",
-            "data": null,
-            "status": "ONLINE",
-            "username": "dragarcia",
-          },
-        ],
-        "error": null,
-        "status": 200,
-        "statusText": "OK",
-      }
-    `)
-    // Test passes if we reach here without errors, as it means native fetch was used
-  } finally {
-    // Restore original fetch
-    globalThis.fetch = originalFetch
-  }
+  const postgrestClient = new PostgrestClient<Database>(REST_URL)
+  const result = await postgrestClient.from('users').select()
+
+  // Verify native fetch was called
+  expect(fetchSpy).toHaveBeenCalledWith(
+    expect.stringContaining(REST_URL),
+    expect.objectContaining({
+      method: 'GET',
+      headers: expect.any(Headers),
+    })
+  )
+
+  // Verify the query succeeded
+  expect(result.error).toBeNull()
+  expect(result.data).toBeDefined()
+  expect(Array.isArray(result.data)).toBe(true)
+  expect(result.status).toBe(200)
+
+  fetchSpy.mockRestore()
 })
 
 test('handles array error with 404 status', async () => {