wip: refactor to local server

Signed-off-by: Victor Adossi <vadossi@cosmonic.com>

Author: vados-cosmonic

package-lock.json

@@ -1,34 +1,39 @@
 import { strictEqual, ok } from 'node:assert';
+import { getRandomPort } from "../util"; 
 
-const FETCH_URL = 'https://httpbin.org/anything';
+const FETCH_URL = 'http://localhost';
 
-export const source = `
+export const source = (port) => {
+  let port = port ? ':' + port : '';
+  return `
   export async function run () {
-    const res = await fetch('${FETCH_URL}');
+    const res = await fetch('${FETCH_URL}${port}');
     const source = await res.json();
     console.log(source.url);
   }
   export function ready () {
     return true;
   }
 `;
+};
 
 export const enableFeatures = ['http'];
 
 export async function test(run) {
-  let retries = 3;
-  let stdout, stderr;
-  while (retries > 0) {
-    try {
-      const result = await run();
-      stdout = result.stdout;
-      stderr = result.stderr;
-      break;
-    } catch (err) {
-      console.error('failed to fetch URL', err);
-    }
-    retries -= 1;
-  }
+  const port = await getRandomPort();
+
+  // Run a local server on some port
+  const server = createServer(async (req, res) => {
+    res.writeHead(200, { "Content-Type": "application/json; charset=utf-8" });
+    res.write(JSON.stringify({
+      status: "ok",
+    }));
+    res.end();
+  }).listen(port);
+
+  const { stdout, stderr } = await run({
+    sourceFnArgs: [ port ],
+  });
   strictEqual(stderr, '');
   strictEqual(stdout.trim(), FETCH_URL);
 }

test/builtins/fetch.js

@@ -31,6 +31,12 @@ suite('Builtins', () => {
         enableFeatures,
       } = await import(`./builtins/${filename}`);
 
+      // If the source was 
+      // TODO: need the args here
+      if (typeof source === 'function') {
+        source(config.sourceArgs);
+      }
+
       const { component } = await componentize(
         source,
         `
@@ -80,7 +86,7 @@ suite('Builtins', () => {
       );
 
       try {
-        await runTest(async function run() {
+        await runTest(async function run(options) {
           let stdout = '',
             stderr = '',
             timeout;