From 14290be9239b8f67b7b37bcb06b85f1ae1dea8e3 Mon Sep 17 00:00:00 2001 From: sky Date: Mon, 23 Jun 2025 16:10:09 -0400 Subject: [PATCH] add hook into user - server websocket --- index.js | 19 ++++++++++--------- 1 file changed, 10 insertions(+), 9 deletions(-) diff --git a/index.js b/index.js index 04b4d53..5e8720b 100644 --- a/index.js +++ b/index.js @@ -7,14 +7,14 @@ const server = Bun.serve({ }, websocket: { message(ws, message) { - // console.log(serverSockets[ws.data.uuid]); + // console.log(serverSockets[ws.data.uuid]["remote"]); // console.log(message); - if(serverSockets[ws.data.uuid].readyState != 1) { - serverSockets[ws.data.uuid].addEventListener("open", ()=>{ - serverSockets[ws.data.uuid].send(message); + if(serverSockets[ws.data.uuid]["remote"].readyState != 1) { + serverSockets[ws.data.uuid]["remote"].addEventListener("open", ()=>{ + serverSockets[ws.data.uuid]["remote"].send(message); }) } else { - serverSockets[ws.data.uuid].send(message); + serverSockets[ws.data.uuid]["remote"].send(message); } }, open(ws) { @@ -25,13 +25,14 @@ const server = Bun.serve({ }); socket.addEventListener("close", event => { ws.close(); - delete serverSockets[ws.data.uuid]; + delete serverSockets[ws.data.uuid]["remote"]; }); - serverSockets[ws.data.uuid] = socket; + serverSockets[ws.data.uuid]["remote"] = socket; + serverSockets[ws.data.uuid]["local"] = ws; }, close(ws, code, message) { - serverSockets[ws.data.uuid].close(); - delete serverSockets[ws.data.uuid]; + serverSockets[ws.data.uuid]["remote"].close(); + delete serverSockets[ws.data.uuid]["remote"]; }, drain(ws) {}, },