| 149 | } |
| 150 | |
| 151 | function writeWebsocket(request, sendResponse) { |
| 152 | const ws = websockets.get(request.data.wsId); |
| 153 | if (!ws) { |
| 154 | sendResponse({ status: "error", err: "WebSocket not found", wsId: request.data.wsId, metaData: request.metaData }); |
| 155 | return; |
| 156 | } |
| 157 | if (ws.readyState !== WebSocket.OPEN) { |
| 158 | sendResponse({ status: "error", err: "WebSocket is not open", wsId: request.data.wsId, metaData: request.metaData }); |
| 159 | return; |
| 160 | } |
| 161 | try { |
| 162 | ws.send(request.data.message); |
| 163 | sendResponse({ status: "success", wsId: request.data.wsId, metaData: request.metaData }); |
| 164 | } catch (err) { |
| 165 | sendResponse({ status: "error", err: err.message, wsId: request.data.wsId, metaData: request.metaData }); |
| 166 | } |
| 167 | } |
| 168 | |
| 169 | function disconnectWebsocket(request, sendResponse) { |
| 170 | const ws = websockets.get(request.wsId); |