IcyNetwork/irclib
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ws test

Browse Source
This commit is contained in:
Evert Prants 2022-09-25 11:02:15 +03:00
parent bd82c52fcd
commit 64ca53b494
Signed by: evert
GPG Key ID: 1688DA83D222D0B5
1 changed files with 7 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/connector/websocket.connector.ts
View File

@ -50,26 +50,20 @@ export class IRCWebSocketConnector
} }
write(format: string, ...args: any[]): void { write(format: string, ...args: any[]): void {
this.socket?.send(formatstr(format, ...args) + '\r\n'); this.socket?.send(formatstr(format, ...args));
} }
private handle() { private handle() {
let buffer: string = '';
this.socket?.addEventListener('message', (event) => { this.socket?.addEventListener('message', (event) => {
const chunk = event.data.toString(); const line = event.data.toString();
buffer += chunk;
const data = buffer.split('\r\n');
buffer = data.pop() || '';
data.forEach((line: string) => {
if (line.indexOf('PING') === 0 && !this.connOpts?.skipPings) { if (line.indexOf('PING') === 0 && !this.connOpts?.skipPings) {
this.socket?.send('PONG' + line.substring(4) + '\r\n'); this.socket?.send('PONG' + line.substring(4));
return; return;
} }
this.emit('data', line); this.emit('data', line);
}); });
});
this.socket?.addEventListener('error', (err) => this.emit('error', err)); this.socket?.addEventListener('error', (err) => this.emit('error', err));
this.socket?.addEventListener('close', (err) => { this.socket?.addEventListener('close', (err) => {