diff --git a/cvmts/src/User.ts b/cvmts/src/User.ts index 5578b37..cbc2a68 100644 --- a/cvmts/src/User.ts +++ b/cvmts/src/User.ts @@ -78,10 +78,7 @@ export class User { if (!this.socket.isOpen()) return; clearInterval(this.nopSendInterval); this.nopSendInterval = setInterval(() => this.sendNop(), 5000); - this.socket.send(msg) - .catch((err: Error) => { - this.logger.Error(`bandaid fix: ${err.message}`); - }); + this.socket.send(msg); } private onNoMsg() { diff --git a/cvmts/src/WebSocket/WSClient.ts b/cvmts/src/WebSocket/WSClient.ts index 69b6468..cf5e2b0 100644 --- a/cvmts/src/WebSocket/WSClient.ts +++ b/cvmts/src/WebSocket/WSClient.ts @@ -35,6 +35,9 @@ export default class WSClient extends EventEmitter implements NetworkClient { } send(msg: string): Promise { return new Promise((res,rej) => { + if(!this.isOpen()) + res(); + this.socket.send(msg, (err) => { if (err) { rej(err); @@ -49,4 +52,4 @@ export default class WSClient extends EventEmitter implements NetworkClient { this.socket.close(); } -} \ No newline at end of file +}