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) {}, },