This commit is contained in:
Abdussamed ULUTAŞ 2022-12-29 00:02:18 +03:00
parent b5e26b9888
commit 10e7d01bce
3 changed files with 8 additions and 0 deletions

View File

@ -80,4 +80,8 @@ export default class Peer extends EventTarget
to: this.socketId
});
}
async forget(){
this.mwse.peers.delete(this.socketId as string);
this.mwse.pairs.delete(this.socketId as string);
}
}

View File

@ -99,6 +99,7 @@ export default class Room extends EventTarget
type:'ejectroom',
roomId: this.roomId
});
this.peers.clear();
if(type == 'success')
{
this.mwse.rooms.delete(this.roomId as string);

View File

@ -75,17 +75,20 @@ export default class MWSE extends EventTarget {
let {id,roomid} = payload;
let room = this.room(roomid);
let peer = this.peer(id, true);
room.peers.set(peer.socketId as string, peer);
room.emit('join', peer);
})
this.EventPooling.signal('room/ejected',(payload : {id:string,roomid:any,ownerid:string}) => {
let {id,roomid} = payload;
let room = this.room(roomid);
let peer = this.peer(id);
room.peers.delete(peer.socketId as string);
room.emit('eject', peer);
})
this.EventPooling.signal('room/closed',(payload : {roomid:any}) => {
let {roomid} = payload;
let room = this.room(roomid);
room.peers.clear();
room.emit('close');
this.rooms.delete(roomid);
})