lbehm/workadventure
1
0
Fork 0
Code Issues Pull requests Releases Activity

Add multi SimplePear connection

Browse source
This commit is contained in:
gparant 2020-04-25 17:14:05 +02:00
parent c28108f6c9
commit 89db8558f6
2 changed files with 30 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
back/src/Controller/IoSocketController.ts
View file

@ -92,9 +92,17 @@ export class IoSocketController{
let clients : Array<any> = Object.values(this.Io.sockets.sockets); let clients : Array<any> = Object.values(this.Io.sockets.sockets);
//send start at one client to initialise offer webrtc //send start at one client to initialise offer webrtc
//send all users in room to create PeerConnection in front
let clientsId = clients.reduce((tabs : Array<any>, client: ExtWebSocket) => {
if(!client.userId){
return tabs;
}
tabs.push(client.userId);
return tabs;
}, []);
clients.forEach((client: ExtWebSocket, index : number) => { clients.forEach((client: ExtWebSocket, index : number) => {
client.emit('webrtc-start', JSON.stringify({ client.emit('webrtc-start', JSON.stringify({
userId: client.userId, usersId: clientsId.filter((userId : any) => userId !== client.userId),
initiator : index === 0 initiator : index === 0
})); }));
}); });

34
front/src/WebRtc/SimplePeer.ts
View file

@ -8,6 +8,7 @@ export class SimplePeer {
RoomId: string; RoomId: string;
PeerConnexion: any; PeerConnexion: any;
PeerConnexionArray: Array<any> = new Array<any>();
constructor(Connexion: ConnexionInterface, roomId: string = "test-webrtc") { constructor(Connexion: ConnexionInterface, roomId: string = "test-webrtc") {
this.Connexion = Connexion; this.Connexion = Connexion;
@ -46,7 +47,7 @@ export class SimplePeer {
let data = JSON.parse(message); let data = JSON.parse(message);
//create pear connexion of user stared //create pear connexion of user stared
this.createPeerConnexion(data.initiator); this.createPeerConnexion(data.usersId, data.initiator);
} }
/** /**
@ -54,16 +55,23 @@ export class SimplePeer {
* @param userId * @param userId
* @param initiator * @param initiator
*/ */
createPeerConnexion(initiator : boolean = false){ createPeerConnexion(usersId : Array<string>, initiator : boolean = false) {
this.PeerConnexion = new Peer({initiator: initiator}); usersId.forEach((userId: any) => {
this.addMedia(); if(this.PeerConnexionArray[userId]){
return;
}
this.PeerConnexion = new Peer({initiator: initiator});
this.PeerConnexion.on('signal', (data: any) => { this.PeerConnexion.on('signal', (data: any) => {
this.sendWebrtcSignal(data); this.sendWebrtcSignal(data);
}); });
this.PeerConnexion.on('stream', (stream: MediaStream) => { this.PeerConnexion.on('stream', (stream: MediaStream) => {
this.stream(stream) this.stream(stream);
});
this.PeerConnexionArray[userId] = this.PeerConnexion;
this.addMedia(userId);
}); });
} }
@ -81,10 +89,10 @@ export class SimplePeer {
*/ */
receiveWebrtcSignal(message: string) { receiveWebrtcSignal(message: string) {
let data = JSON.parse(message); let data = JSON.parse(message);
if(!this.PeerConnexion){ if(!this.PeerConnexionArray[data.userId]){
return; return;
} }
this.PeerConnexion.signal(data.signal); this.PeerConnexionArray[data.userId].signal(data.signal);
} }
/** /**
@ -100,7 +108,7 @@ export class SimplePeer {
* Permit to update stream * Permit to update stream
* @param stream * @param stream
*/ */
addMedia () { addMedia (userId : any) {
this.PeerConnexion.addStream(this.MediaManager.localStream) // <- add streams to peer dynamically this.PeerConnexionArray[userId].addStream(this.MediaManager.localStream) // <- add streams to peer dynamically
} }
} }