test: add test for manual incoming handler component

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

Author: vados-cosmonic

test/cases/http-server/source.js

@@ -0,0 +1,27 @@
+import {
+  IncomingRequest,
+  ResponseOutparam,
+  OutgoingBody,
+  OutgoingResponse,
+  Fields,
+} from 'wasi:http/types@0.2.3';
+
+export const incomingHandler = {
+  handle(incomingRequest, responseOutparam) {
+    const outgoingResponse = new OutgoingResponse(new Fields());
+    let outgoingBody = outgoingResponse.body();
+    {
+      let outputStream = outgoingBody.write();
+      outputStream.blockingWriteAndFlush(
+        new Uint8Array(new TextEncoder().encode('Hello world!')),
+      );
+      outputStream[Symbol.dispose]();
+    }
+    outgoingResponse.setStatusCode(200);
+    OutgoingBody.finish(outgoingBody, undefined);
+    ResponseOutparam.set(outgoingResponse, {
+      tag: 'ok',
+      val: outgoingResponse,
+    });
+  },
+};

test/cases/http-server/test.js

@@ -0,0 +1,22 @@
+import { strictEqual } from 'node:assert';
+
+import { HTTPServer } from '@bytecodealliance/preview2-shim/http';
+
+import { getRandomPort } from '../../util.js';
+
+export const enableFeatures = ['http'];
+export const worldName = 'test3';
+
+export async function test(instance) {
+  const server = new HTTPServer(instance.incomingHandler);
+  let port = await getRandomPort();
+  server.listen(port);
+
+  try {
+    const resp = await fetch(`http://localhost:${port}`);
+    const text = await resp.text();
+    strictEqual(text, 'Hello world!');
+  } finally {
+    server.stop();
+  }
+}

test/test.js

@@ -135,44 +135,55 @@ suite('Builtins', () => {
 const bindingsCases = await readdir(new URL('./cases', import.meta.url));
 suite('Bindings', () => {
   for (const name of bindingsCases) {
+    if (name !== 'http-server') {
+      continue;
+    }
+
     test(name, async () => {
       const source = await readFile(
         new URL(`./cases/${name}/source.js`, import.meta.url),
-        'utf8'
+        'utf8',
       );
 
+      const test = await import(`./cases/${name}/test.js`);
+
+      // Determine the relevant WIT world to use
       let witWorld,
         witPath,
         worldName,
         isWasiTarget = false;
-      try {
-        witWorld = await readFile(
-          new URL(`./cases/${name}/world.wit`, import.meta.url),
-          'utf8'
-        );
-      } catch (e) {
-        if (e?.code == 'ENOENT') {
-          try {
-            isWasiTarget = true;
-            witPath = fileURLToPath(
-              new URL(`./cases/${name}/wit`, import.meta.url)
-            );
-            await readdir(witPath);
-          } catch (e) {
-            if (e?.code === 'ENOENT') {
-              witPath = fileURLToPath(new URL('./wit', import.meta.url));
-              worldName = 'test2';
-            } else {
-              throw e;
+      if (test.worldName) {
+        witPath = fileURLToPath(new URL('./wit', import.meta.url));
+        worldName = test.worldName;
+        isWasiTarget = true;
+      } else {
+        try {
+          witWorld = await readFile(
+            new URL(`./cases/${name}/world.wit`, import.meta.url),
+            'utf8',
+          );
+        } catch (e) {
+          if (e?.code == 'ENOENT') {
+            try {
+              isWasiTarget = true;
+              witPath = fileURLToPath(
+                new URL(`./cases/${name}/wit`, import.meta.url),
+              );
+              await readdir(witPath);
+            } catch (e) {
+              if (e?.code === 'ENOENT') {
+                witPath = fileURLToPath(new URL('./wit', import.meta.url));
+                worldName = 'test2';
+              } else {
+                throw e;
+              }
             }
+          } else {
+            throw e;
           }
-        } else {
-          throw e;
         }
       }
 
-      const test = await import(`./cases/${name}/test.js`);
-
       const enableFeatures = test.enableFeatures || ['http'];
       const disableFeatures =
         test.disableFeatures ||
@@ -229,14 +240,19 @@ suite('Bindings', () => {
 
         await writeFile(
           new URL(`./output/${name}.component.wasm`, import.meta.url),
-          component
+          component,
+        );
+
+        await writeFile(
+          new URL(`/tmp/component.wasm`, import.meta.url),
+          component,
         );
 
         for (const file of Object.keys(files)) {
           let source = files[file];
           await writeFile(
             new URL(`./output/${name}/${file}`, import.meta.url),
-            source
+            source,
           );
         }
 

test/util.js

@@ -0,0 +1,13 @@
+import { createServer } from 'node:net';
+
+// Utility function for getting a random port
+export async function getRandomPort() {
+  return await new Promise((resolve) => {
+    const server = createServer();
+    server.listen(0, function () {
+      const port = this.address().port;
+      server.on('close', () => resolve(port));
+      server.close();
+    });
+  });
+}

test/wit/test1.wit

@@ -64,3 +64,10 @@ world test2 {
 
   export get-result: func() -> string;
 }
+
+world test3 {
+  import wasi:cli/environment@0.2.3;
+  import wasi:http/types@0.2.3;
+
+  export wasi:http/incoming-handler@0.2.3;
+}