|
@@ -61,7 +61,7 @@ export class MetaGateway
|
|
|
trace_id: '',
|
|
|
user_id: '',
|
|
|
};
|
|
|
- if (this.gameChanel.isOpen) {
|
|
|
+ if (this.gameChanel.isOpen()) {
|
|
|
const heartPack = new DataView(new ArrayBuffer(4));
|
|
|
heartPack.setUint32(0, 2009889916);
|
|
|
this.gameChanel.sendMessageBinary(Buffer.from(heartPack.buffer));
|
|
@@ -143,7 +143,7 @@ export class MetaGateway
|
|
|
});
|
|
|
}
|
|
|
i++;
|
|
|
- }, 2000);
|
|
|
+ }, 10);
|
|
|
});
|
|
|
this.gameChanel.onClosed(() => {
|
|
|
console.log('gameChanel close');
|
|
@@ -159,8 +159,10 @@ export class MetaGateway
|
|
|
const heartPack = new DataView(new ArrayBuffer(4));
|
|
|
heartPack.setUint32(0, 2009889916);
|
|
|
this._webrtcInterval = setInterval(() => {
|
|
|
- channel.sendMessageBinary(Buffer.from(heartPack.buffer));
|
|
|
- }, 100);
|
|
|
+ if (channel.isOpen()) {
|
|
|
+ channel.sendMessageBinary(Buffer.from(heartPack.buffer));
|
|
|
+ }
|
|
|
+ }, 1e3);
|
|
|
}
|
|
|
|
|
|
stopSendWertcHeartPack(): void {
|
|
@@ -186,7 +188,7 @@ export class MetaGateway
|
|
|
|
|
|
@SubscribeMessage('start')
|
|
|
handlerWebrtcStart(client: any, payload: any) {
|
|
|
- console.log('start', payload)
|
|
|
+ console.log('start', payload);
|
|
|
|
|
|
}
|
|
|
|
|
@@ -195,7 +197,7 @@ export class MetaGateway
|
|
|
}
|
|
|
|
|
|
handleConnection(client: WebSocket, ...args: any[]) {
|
|
|
- this.logger.log(`Client connected: ${client.id}`);
|
|
|
+ this.logger.log(`Client connected: ${args}`);
|
|
|
const connected = {
|
|
|
channel_id: '',
|
|
|
client_os: '',
|