diff --git a/server/plugins/websocket.js b/server/plugins/websocket.js index f8cf7c6..9304054 100644 --- a/server/plugins/websocket.js +++ b/server/plugins/websocket.js @@ -43,16 +43,6 @@ export function removeSessionConnection(sessionId, ws) { } } -export function broadcastToSession(sessionId, message) { - const conns = getSessionConnections(sessionId) - const data = JSON.stringify(message) - for (const ws of conns) { - if (ws.readyState === 1) { // OPEN - ws.send(data) - } - } -} - export default defineNitroPlugin((nitroApp) => { nitroApp.hooks.hook('ready', async () => { const server = nitroApp.h3App.server || nitroApp.h3App.nodeServer