Code: Select all
class WSS {
constructor(){
const WebSocket = require('ws');
this.wss = new WebSocket.Server({ port: 3001});
this.activeWs = null;
this.wss.on('connection', function connection(ws) {
console.log("Client Connected");
if (this.activeWs != null) {
this.activeWs.close(1000, "Server initiated close");
console.log("Closed old session")
}
this.activeWs = ws;
})
this.sendCommand = (data) => {
console.log(this.activeWs)
if (this.activeWs == null) {
return;
}
console.log(data);
}
}
}
class WS {
constructor(clientId, onmessage) {
this.clientId = clientId;
const WebSocket = require('ws');
this.ws = new WebSocket('localhost:8080');
this.ws.onmessage = (event) => { onmessage(event)};
}
}
serverWSS = new WSS();
listener = new WS("000", forwardMessage)
function forwardMessage(event) {
serverWSS.sendCommand(event.data);
}