NeonJS/library
Archived
0
0
Fork 0
Code Activity

fix(gateway): fix identify not sending (try 3)

Browse source
This commit is contained in:
Daryl Ronningen 2021-07-16 20:23:15 -07:00
parent 3788d1ef08
commit e3d1dc1eed
Signed by: Daryl Ronningen
GPG key ID: FD23F0C934A5EC6B
1 changed files with 3 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/gateway/gatewayClient.ts
View file

@ -8,7 +8,6 @@ import type { GatewayReceiveMessage, GatewaySendMessage } from '../utils/types';
export class GatewayClient { export class GatewayClient {
public client: Client; public client: Client;
public connection: WebSocket | null; public connection: WebSocket | null;
public deflate: zlib.Deflate;
public inflate: zlib.Inflate; public inflate: zlib.Inflate;
private _heartbeatInterval: number; private _heartbeatInterval: number;
@ -20,7 +19,6 @@ export class GatewayClient {
this.client = client; this.client = client;
this.connection = null; this.connection = null;
this.deflate = new zlib.Deflate();
this.inflate = new zlib.Inflate(); this.inflate = new zlib.Inflate();
this._heartbeatInterval = 0; this._heartbeatInterval = 0;
@ -73,7 +71,7 @@ export class GatewayClient {
}, },
}); });
this._sendHeartbeat(); this._heartbeatIntervalTimer = setInterval(() => this._sendHeartbeat(), this._heartbeatInterval * 1000);
break; break;
default: default:
break; break;
@ -84,15 +82,10 @@ export class GatewayClient {
public send(data: GatewaySendMessage): void { public send(data: GatewaySendMessage): void {
if (!this.connection) throw new Error('You are not connected to the Discord WebSocket Gateway!'); if (!this.connection) throw new Error('You are not connected to the Discord WebSocket Gateway!');
let parsedMessage: Buffer | string; this.connection.send(JSON.stringify(data));
if (this.client.options.ws.compression) parsedMessage = this.deflate.process(JSON.stringify(data));
else parsedMessage = JSON.stringify(data);
this.connection.send(parsedMessage);
} }
private _sendHeartbeat(): void { private _sendHeartbeat(): void {
this._heartbeatIntervalTimer = setInterval(() => this.send({ op: 1, d: this._sequence }), this._heartbeatInterval * 1000); this.send({ op: 1, d: this._sequence });
} }
} }