pbm double message join fixed
This commit is contained in:
@@ -34,12 +34,12 @@ implements OnGatewayConnection, OnGatewayDisconnect
|
|||||||
async joinRoom(@ConnectedSocket() socket: socketDto, @MessageBody() room_name: string): Promise<void>
|
async joinRoom(@ConnectedSocket() socket: socketDto, @MessageBody() room_name: string): Promise<void>
|
||||||
{
|
{
|
||||||
console.log('- in joinRoom gateway');
|
console.log('- in joinRoom gateway');
|
||||||
socket.leave(socket.room);
|
|
||||||
socket.join(room_name);
|
await this.chatService.socketJoinRoom(socket, room_name)
|
||||||
socket.room = room_name;
|
let message = `${socket.username} joined the room`;
|
||||||
let message = `${socket.username} has join the room`;
|
|
||||||
await socket.to(socket.room).emit('message', "SERVER", message);
|
|
||||||
await this.chatService.addMessageToRoom(room_name, "SERVER", message);
|
await this.chatService.addMessageToRoom(room_name, "SERVER", message);
|
||||||
|
|
||||||
|
console.log('- out joinRoom gateway');
|
||||||
}
|
}
|
||||||
|
|
||||||
@SubscribeMessage('change')
|
@SubscribeMessage('change')
|
||||||
@@ -47,6 +47,7 @@ implements OnGatewayConnection, OnGatewayDisconnect
|
|||||||
{
|
{
|
||||||
console.log('- in changeRoom gateway');
|
console.log('- in changeRoom gateway');
|
||||||
await this.chatService.socketChangeRoom(socket, room_name);
|
await this.chatService.socketChangeRoom(socket, room_name);
|
||||||
|
console.log('- out changeRoom gateway');
|
||||||
}
|
}
|
||||||
|
|
||||||
@SubscribeMessage('message')
|
@SubscribeMessage('message')
|
||||||
@@ -54,6 +55,7 @@ implements OnGatewayConnection, OnGatewayDisconnect
|
|||||||
{
|
{
|
||||||
console.log('- in handleMessage gateway');
|
console.log('- in handleMessage gateway');
|
||||||
await this.chatService.socketIncommingMessage(socket, message);
|
await this.chatService.socketIncommingMessage(socket, message);
|
||||||
|
console.log('- out handleMessage gateway');
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -379,7 +379,6 @@ export class ChatService {
|
|||||||
socket.room = room_name;
|
socket.room = room_name;
|
||||||
let message = `${socket.username} joined the room`;
|
let message = `${socket.username} joined the room`;
|
||||||
await socket.to(socket.room).emit('message', "SERVER", message);
|
await socket.to(socket.room).emit('message', "SERVER", message);
|
||||||
await this.addMessageToRoom(room_name, "SERVER", message);
|
|
||||||
|
|
||||||
console.log('- out socketJoinRoom service');
|
console.log('- out socketJoinRoom service');
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user