_Bastler/partey_workadventure
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Connect and Disconnect event.

Browse Source
This commit is contained in:
gparant 2020-05-03 16:28:18 +02:00
parent 8357f9b8c2
commit 372f938bbb
1 changed files with 63 additions and 59 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

104
back/src/Controller/IoSocketController.ts
View File

@ -22,14 +22,15 @@ enum SockerIoEvent {
MESSAGE_ERROR = "message-error", MESSAGE_ERROR = "message-error",
} }
export class IoSocketController{ export class IoSocketController {
Io: socketIO.Server; Io: socketIO.Server;
World: World; World: World;
constructor(server : http.Server) {
constructor(server: http.Server) {
this.Io = socketIO(server); this.Io = socketIO(server);
// Authentication with token. it will be decoded and stored in the socket. // Authentication with token. it will be decoded and stored in the socket.
this.Io.use( (socket: Socket, next) => { this.Io.use((socket: Socket, next) => {
if (!socket.handshake.query || !socket.handshake.query.token) { if (!socket.handshake.query || !socket.handshake.query.token) {
return next(new Error('Authentication error')); return next(new Error('Authentication error'));
} }
@ -46,9 +47,9 @@ export class IoSocketController{
this.shareUsersPosition(); this.shareUsersPosition();
//don't send only function because the context will be not this //don't send only function because the context will be not this
this.World = new World((user1 : string, user2 : string, group: Group) => { this.World = new World((user1: string, user2: string, group: Group) => {
this.connectedUser(user1, user2, group); this.connectedUser(user1, user2, group);
}, (user1 : string, user2 : string, group: Group) => { }, (user1: string, user2: string, group: Group) => {
this.disConnectedUser(user1, user2, group); this.disConnectedUser(user1, user2, group);
}); });
} }
@ -63,9 +64,9 @@ export class IoSocketController{
x: user x position on map x: user x position on map
y: user y position on map y: user y position on map
*/ */
socket.on(SockerIoEvent.JOIN_ROOM, (message : string) => { socket.on(SockerIoEvent.JOIN_ROOM, (message: string) => {
let messageUserPosition = this.hydrateMessageReceive(message); let messageUserPosition = this.hydrateMessageReceive(message);
if(messageUserPosition instanceof Error){ if (messageUserPosition instanceof Error) {
return socket.emit(SockerIoEvent.MESSAGE_ERROR, JSON.stringify({message: messageUserPosition.message})) return socket.emit(SockerIoEvent.MESSAGE_ERROR, JSON.stringify({message: messageUserPosition.message}))
} }
@ -84,7 +85,7 @@ export class IoSocketController{
socket.to(messageUserPosition.roomId).emit(SockerIoEvent.JOIN_ROOM, messageUserPosition.toString()); socket.to(messageUserPosition.roomId).emit(SockerIoEvent.JOIN_ROOM, messageUserPosition.toString());
}); });
socket.on(SockerIoEvent.USER_POSITION, (message : string) => { socket.on(SockerIoEvent.USER_POSITION, (message: string) => {
let messageUserPosition = this.hydrateMessageReceive(message); let messageUserPosition = this.hydrateMessageReceive(message);
if (messageUserPosition instanceof Error) { if (messageUserPosition instanceof Error) {
return socket.emit(SockerIoEvent.MESSAGE_ERROR, JSON.stringify({message: messageUserPosition.message})); return socket.emit(SockerIoEvent.MESSAGE_ERROR, JSON.stringify({message: messageUserPosition.message}));
@ -100,23 +101,23 @@ export class IoSocketController{
this.refreshUserPosition(); this.refreshUserPosition();
}); });
socket.on(SockerIoEvent.WEBRTC_SIGNAL, (message : string) => { socket.on(SockerIoEvent.WEBRTC_SIGNAL, (message: string) => {
let data : any = JSON.parse(message); let data: any = JSON.parse(message);
//send only at user //send only at user
let client = this.searchClientById(data.receiverId); let client = this.searchClientById(data.receiverId);
if(!client){ if (!client) {
console.error("client doesn't exist for ", data.receiverId); console.error("client doesn't exist for ", data.receiverId);
return; return;
} }
return client.emit(SockerIoEvent.WEBRTC_SIGNAL, message); return client.emit(SockerIoEvent.WEBRTC_SIGNAL, message);
}); });
socket.on(SockerIoEvent.WEBRTC_OFFER, (message : string) => { socket.on(SockerIoEvent.WEBRTC_OFFER, (message: string) => {
let data : any = JSON.parse(message); let data: any = JSON.parse(message);
//send only at user //send only at user
let client = this.searchClientById(data.receiverId); let client = this.searchClientById(data.receiverId);
if(!client){ if (!client) {
console.error("client doesn't exist for ", data.receiverId); console.error("client doesn't exist for ", data.receiverId);
return; return;
} }
@ -125,9 +126,7 @@ export class IoSocketController{
socket.on(SockerIoEvent.DISCONNECT, () => { socket.on(SockerIoEvent.DISCONNECT, () => {
let Client = (socket as ExSocketInterface); let Client = (socket as ExSocketInterface);
socket.broadcast.emit(SockerIoEvent.WEBRTC_DISCONNECT, JSON.stringify({ this.sendDisconnectedEvent(Client);
userId: Client.userId
}));
//refresh position of all user in all rooms in real time //refresh position of all user in all rooms in real time
this.refreshUserPosition(); this.refreshUserPosition();
@ -153,24 +152,35 @@ export class IoSocketController{
* *
* @param userId * @param userId
*/ */
searchClientById(userId : string) : ExSocketInterface | null{ searchClientById(userId: string): ExSocketInterface | null {
let clients: Array<any> = Object.values(this.Io.sockets.sockets); let clients: Array<any> = Object.values(this.Io.sockets.sockets);
for(let i = 0; i < clients.length; i++){ for (let i = 0; i < clients.length; i++) {
let client : ExSocketInterface = clients[i]; let client: ExSocketInterface = clients[i];
if(client.userId !== userId){ if (client.userId !== userId) {
continue continue
} }
return client; return client;
} }
return null; return null;
} }
/**
*
* @param Client: ExSocketInterface
*/
sendDisconnectedEvent(Client: ExSocketInterface) {
Client.broadcast.emit(SockerIoEvent.WEBRTC_DISCONNECT, JSON.stringify({
userId: Client.userId
}));
}
/** /**
* *
* @param socket * @param socket
* @param roomId * @param roomId
*/ */
joinWebRtcRoom(socket : ExSocketInterface, roomId : string) { joinWebRtcRoom(socket: ExSocketInterface, roomId: string) {
if(socket.webRtcRoomId === roomId){ if (socket.webRtcRoomId === roomId) {
return; return;
} }
socket.join(roomId); socket.join(roomId);
@ -201,26 +211,26 @@ export class IoSocketController{
} }
//permit to save user position in socket //permit to save user position in socket
saveUserInformation(socket : ExSocketInterface, message : MessageUserPosition){ saveUserInformation(socket: ExSocketInterface, message: MessageUserPosition) {
socket.position = message.position; socket.position = message.position;
socket.roomId = message.roomId; socket.roomId = message.roomId;
socket.userId = message.userId; socket.userId = message.userId;
} }
refreshUserPosition(){ refreshUserPosition() {
//refresh position of all user in all rooms in real time //refresh position of all user in all rooms in real time
let rooms = (this.Io.sockets.adapter.rooms as ExtRoomsInterface); let rooms = (this.Io.sockets.adapter.rooms as ExtRoomsInterface);
if(!rooms.refreshUserPosition){ if (!rooms.refreshUserPosition) {
rooms.refreshUserPosition = RefreshUserPositionFunction; rooms.refreshUserPosition = RefreshUserPositionFunction;
} }
rooms.refreshUserPosition(rooms, this.Io); rooms.refreshUserPosition(rooms, this.Io);
} }
//Hydrate and manage error //Hydrate and manage error
hydrateMessageReceive(message : string) : MessageUserPosition | Error{ hydrateMessageReceive(message: string): MessageUserPosition | Error {
try { try {
return new MessageUserPosition(JSON.parse(message)); return new MessageUserPosition(JSON.parse(message));
}catch (err) { } catch (err) {
//TODO log error //TODO log error
return new Error(err); return new Error(err);
} }
@ -242,20 +252,21 @@ export class IoSocketController{
... ...
] ]
**/ **/
seTimeOutInProgress : any = null; seTimeOutInProgress: any = null;
shareUsersPosition(){
if(this.seTimeOutInProgress){ shareUsersPosition() {
if (this.seTimeOutInProgress) {
clearTimeout(this.seTimeOutInProgress); clearTimeout(this.seTimeOutInProgress);
} }
//send for each room, all data of position user //send for each room, all data of position user
let arrayMap = (this.Io.sockets.adapter.rooms as ExtRooms).userPositionMapByRoom; let arrayMap = (this.Io.sockets.adapter.rooms as ExtRooms).userPositionMapByRoom;
if(!arrayMap){ if (!arrayMap) {
this.seTimeOutInProgress = setTimeout(() => { this.seTimeOutInProgress = setTimeout(() => {
this.shareUsersPosition(); this.shareUsersPosition();
}, 10); }, 10);
return; return;
} }
arrayMap.forEach((value : any) => { arrayMap.forEach((value: any) => {
let roomId = value[0]; let roomId = value[0];
this.Io.in(roomId).emit(SockerIoEvent.USER_POSITION, JSON.stringify(arrayMap)); this.Io.in(roomId).emit(SockerIoEvent.USER_POSITION, JSON.stringify(arrayMap));
}); });
@ -265,27 +276,20 @@ export class IoSocketController{
} }
//connected user //connected user
connectedUser(user1 : string, user2 : string, group : Group) { connectedUser(userId: string, group: Group) {
if(!group){ let Client = this.searchClientById(userId);
if (!Client) {
return; return;
} }
/* TODO manager room and group user to enter and leave */ this.joinWebRtcRoom(Client, group.getId());
let clients: Array<any> = Object.values(this.Io.sockets.sockets);
let User1 = clients.find((user: ExSocketInterface) => user.userId === user1);
let User2 = clients.find((user: ExSocketInterface) => user.userId === user2);
if (User1) {
this.joinWebRtcRoom(User1, group.getId());
}
if (User2) {
this.joinWebRtcRoom(User2, group.getId());
}
} }
//connected user //connected user
disConnectedUser(user1 : string, user2 : string, group : Group){ disConnectedUser(userId: string, group: Group) {
console.log("disConnectedUser => user1", user1); let Client = this.searchClientById(userId);
console.log("disConnectedUser => user2", user2); if (!Client) {
console.log("group", group); return;
}
this.sendDisconnectedEvent(Client)
} }
} }