feat: add support for websocket handler

atinux · Jan 22, 2025 · a22fbd6 · a22fbd6
1 parent 44b06c6
commit a22fbd6
Show file tree

Hide file tree

Showing 9 changed files with 124 additions and 82 deletions.
diff --git a/package.json b/package.json
@@ -38,7 +38,7 @@
     "@adonisjs/hash": "^9.0.5",
     "@nuxt/kit": "^3.15.2",
     "defu": "^6.1.4",
-    "h3": "^1.13.1",
+    "h3": "^1.14.0",
     "hookable": "^5.5.3",
     "ofetch": "^1.4.1",
     "ohash": "^1.1.4",

diff --git a/playground/app.vue b/playground/app.vue
@@ -201,6 +201,13 @@ const providers = computed(() =>
     external: true,
   })),
 )
+
+onMounted(() => {
+  const ws = new WebSocket('/ws')
+  ws.addEventListener('message', (event) => {
+    console.log('message', event.data)
+  })
+})
 </script>
 
 <template>

diff --git a/playground/nuxt.config.ts b/playground/nuxt.config.ts
@@ -20,6 +20,7 @@ export default defineNuxtConfig({
   nitro: {
     experimental: {
       database: true,
+      websocket: true,
     },
   },
   auth: {

diff --git a/playground/package.json b/playground/package.json
@@ -18,5 +18,8 @@
   },
   "devDependencies": {
     "better-sqlite3": "^11.8.1"
+  },
+  "resolutions": {
+    "h3": "^1.14.0"
   }
 }
diff --git a/playground/server/routes/ws/index.ts b/playground/server/routes/ws/index.ts
@@ -0,0 +1,15 @@
+export default defineWebSocketHandler({
+  // async upgrade(request) {
+  //   const session = await getUserSession(request)
+  //   console.log(`[upgrade] Session id: ${session.id}`)
+  //   return {}
+  // },
+  async open(peer) {
+    // const session = await getUserSession(peer.request)
+    // console.log(`[open] Session:`, session)
+    // peer.send(`Hello, ${session.id}!`)
+  },
+  message(peer, message) {
+    // console.log('message', message)
+  },
+})