Fix shares information to enter into Webrtc room.

- Refactor share position in world class.
- Update selects a client to send information about connecting WebRtc room.

diff --git a/back/src/Controller/IoSocketController.ts b/back/src/Controller/IoSocketController.ts
index d253cc9efec62b71b50bf3da70915ae0442d893c..bd3f9bc8f8924c42b513fc47d52de112a620d0b3 100644 (file)
--- a/back/src/Controller/IoSocketController.ts
+++ b/back/src/Controller/IoSocketController.ts
@@ -91,9 +91,6 @@ export class IoSocketController {
                     return socket.emit(SockerIoEvent.MESSAGE_ERROR, JSON.stringify({message: messageUserPosition.message}));
                 }
 
-                // update position in the worl
-                this.World.updatePosition(messageUserPosition);
-
                 // sending to all clients in room except sender
                 this.saveUserInformation((socket as ExSocketInterface), messageUserPosition);
 
@@ -192,8 +189,8 @@ export class IoSocketController {
         if (this.Io.sockets.adapter.rooms[roomId].length < 2 || this.Io.sockets.adapter.rooms[roomId].length >= 4) {
             return;
         }
-        let clients: Array<any> = Object.values(this.Io.sockets.sockets);
-
+        let clients: Array<ExSocketInterface> = Object.values(this.Io.sockets.sockets)
+            .filter((client: ExSocketInterface) => client.webRtcRoomId && client.webRtcRoomId === roomId);
         //send start at one client to initialise offer webrtc
         //send all users in room to create PeerConnection in front
         clients.forEach((client: ExSocketInterface, index: number) => {
@@ -228,7 +225,7 @@ export class IoSocketController {
         if (!rooms.refreshUserPosition) {
             rooms.refreshUserPosition = RefreshUserPositionFunction;
         }
-        rooms.refreshUserPosition(rooms, this.Io);
+        rooms.refreshUserPosition(rooms, this.Io, this.World);
     }
 
     //Hydrate and manage error

diff --git a/back/src/Model/Websocket/ExtRoom.ts b/back/src/Model/Websocket/ExtRoom.ts
index a1b2cb6579997ca524bafd7dd676bb643975aef7..5ad812850130a8e46b8cbe2594c4587377c8e7cb 100644 (file)
--- a/back/src/Model/Websocket/ExtRoom.ts
+++ b/back/src/Model/Websocket/ExtRoom.ts
@@ -1,6 +1,8 @@
 import {ExtRoomsInterface} from "./ExtRoomsInterface";
 import socketIO = require('socket.io');
-import {ExSocketInterface} from "_Model/Websocket/ExSocketInterface";
+import {ExSocketInterface} from "./ExSocketInterface";
+import {MessageUserPosition} from "./MessageUserPosition";
+import {World} from "_Model/World";
 
 export class ExtRooms implements ExtRoomsInterface{
     userPositionMapByRoom: any;
@@ -9,7 +11,7 @@ export class ExtRooms implements ExtRoomsInterface{
     [room: string]: SocketIO.Room;
 }
 
-let RefreshUserPositionFunction = function(rooms : ExtRooms, Io: socketIO.Server) {
+let RefreshUserPositionFunction = function(rooms : ExtRooms, Io: socketIO.Server, World : World) {
     let clients = Io.clients();
     let socketsKey = Object.keys(Io.clients().sockets);
 
@@ -35,6 +37,10 @@ let RefreshUserPositionFunction = function(rooms : ExtRooms, Io: socketIO.Server
             dataArray = [data];
         }
         mapPositionUserByRoom.set(data.roomId, dataArray);
+
+        // update position in the worl
+        let messageUserPosition = new MessageUserPosition(data);
+        World.updatePosition(messageUserPosition);
     }
     rooms.userPositionMapByRoom = Array.from(mapPositionUserByRoom);
 }