fix(functions): failing test

Author: mandarini

package-lock.json

@@ -1,6 +1,22 @@
 import { serve } from 'https://deno.land/[email protected]/http/server.ts'
 
 serve((req) => {
+  // Decode JWT to check if this is a health check
+  const authHeader = req.headers.get('authorization')
+  if (authHeader) {
+    try {
+      const token = authHeader.replace('Bearer ', '')
+      const payload = JSON.parse(atob(token.split('.')[1]))
+      // Health check uses { name: 'check' }
+      if (payload.name === 'check') {
+        return new Response('OK', { status: 200 })
+      }
+    } catch (e) {
+      // If JWT decode fails, continue to upgrade attempt
+    }
+  }
+
+  // For actual test invocations, attempt WebSocket upgrade
   const p = Deno.upgradeHttp(req)
 
   // Run this async IIFE concurrently, first packet won't arrive

packages/core/functions-js/test/functions/hijack/index.ts

@@ -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 TypeError (which fetch throws for protocol errors like 101),
+      // we consider the function ready to serve
+      if (error instanceof TypeError) {
+        // 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 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.