Working ws for crypto

app/pages/app/crypto/[symbol].vue

@@ -24,7 +24,7 @@ let ws: WebSocket | undefined
 
 function connect() {
   const isSecure = location.protocol === 'https:'
-  const url = (isSecure ? 'wss://' : 'ws://') + location.host + '/_ws'
+  const url = `${isSecure ? 'wss' : 'ws'}://${location.host}/api/crypto/ws?symbol=${symbol}`
   if (ws) {
     console.log('ws', 'Closing previous connection before reconnecting...')
     ws.close()

server/api/crypto/ws.ts

@@ -0,0 +1,32 @@
+import type { Peer } from 'crossws'
+import { getQuery } from 'ufo'
+
+let intervalId: NodeJS.Timeout
+
+export default defineWebSocketHandler({
+  open(peer: Peer) {
+    console.log(`[ws] open ${peer}`)
+    const { symbol } = getQuery(peer.url)
+    console.log(`[ws] symbol ${symbol}`)
+
+    peer.subscribe('value')
+
+    const sendRandomNumber = () => {
+      const randomNumber = (Math.floor(Math.random() * 10000)).toFixed(2)
+      peer.send({ number: randomNumber })
+    }
+
+    intervalId = setInterval(sendRandomNumber, 1500)
+  },
+  message(peer, message) {
+    console.log(`[ws] message ${peer} ${message.text()}`)
+
+    if (message.text() === 'ping') {
+      peer.send('pong')
+    }
+  },
+  close(peer) {
+    console.log(`[ws] close ${peer}`)
+    clearInterval(intervalId)
+  }
+})