KCA/WebsocketServer
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

Bwuh

Browse source
This commit is contained in:
Christopher Cookman 2024-09-04 08:02:09 -06:00
parent 096e69259f
commit e0ce204118
Signed by: ChrisChrome
GPG key ID: A023A26E42C33A42
1 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
index.js
View file

@ -27,7 +27,9 @@ app.put('/api/connect/:jobid', (req, res) => {
ws_[id].message = data; ws_[id].message = data;
}) })
ws_[id].connection.on('close', function() { ws_[id].connection.on('close', function() {
ws_[id].connection.terminate(); if (ws_[id].connection) {
ws_[id].connection.terminate();
}
}) })
ws_[id].open = false; ws_[id].open = false;
setInterval(() => { setInterval(() => {
@ -54,10 +56,10 @@ app.post("/api/send/:jobid/:id/", (req, res) => {
var socket = ws_[id].connection; var socket = ws_[id].connection;
console.log("sent data: " + req.body) console.log("sent data: " + req.body)
if (stats.open == true) { if (stats.open == true) {
socket.send(req.body); socket.send(req.body.data);
} else { } else {
socket.on('open', () => { socket.on('open', () => {
socket.send(req.body); socket.send(req.body.data);
}); });
} }
res.send({ res.send({