feat: add websocket support utils, and app handling

package.json

@@ -32,14 +32,16 @@
     "test:types": "vitest typecheck"
   },
   "dependencies": {
+    "@types/ws": "^8.5.5",
     "cookie-es": "^1.0.0",
     "defu": "^6.1.2",
     "destr": "^2.0.1",
     "iron-webcrypto": "^0.10.1",
     "radix3": "^1.1.0",
     "ufo": "^1.3.0",
     "uncrypto": "^0.1.3",
-    "unenv": "^1.7.4"
+    "unenv": "^1.7.4",
+    "ws": "^8.14.2"
   },
   "devDependencies": {
     "0x": "^5.6.0",

playground/app.ts

@@ -1,13 +1,36 @@
-import { createApp, createRouter, eventHandler } from "h3";
-
+import {
+  createApp,
+  eventHandler,
+  upgradeWebSocket,
+  isWebSocketUpgradeRequest,
+  isWebSocketEvent,
+  toWebSocketEvent,
+} from "h3";
 export const app = createApp();
 
-const router = createRouter();
-app.use(router);
-
-router.get(
+app.use(
   "/",
   eventHandler((event) => {
-    return { path: event.path, message: "Hello World!" };
+    if (isWebSocketEvent(event)) {
+      const wsEvent = toWebSocketEvent(event);
+      if (wsEvent.type === "connection") {
+        wsEvent.connection.send("pong");
+      } else if (wsEvent.type === "message") {
+        console.log("got", new TextDecoder().decode(wsEvent.message));
+      }
+    }
+    if (isWebSocketUpgradeRequest(event)) {
+      return upgradeWebSocket(event);
+    }
+
+    return `<h1>Hello World!</h1><script type="module">
+      const ws = new WebSocket("ws://localhost:3000");
+      await new Promise((resolve) => ws.addEventListener("open", resolve));
+      ws.addEventListener("message", (event) => {
+        console.log(event.data);
+        ws.send("ping from client");
+      });
+      ws.send("pong");
+    </script>`;
   }),
 );