saqut
/
MWSE
1
1
Fork 0
Code Issues 10 Pull Requests Packages Projects 2 Releases 1 Wiki Activity

Stage 247

This commit is contained in:
Abdussamed ULUTAŞ 2022-12-23 00:45:11 +03:00
parent 0098eb9e72
commit 4930af2c4b
3 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
frontend/index.ts
View File

@ -53,7 +53,7 @@ export default class MWSE extends EventTarget {
{ {
this.EventPooling.signal('pack',(payload : {to:string,pack:any}) => { this.EventPooling.signal('pack',(payload : {to:string,pack:any}) => {
let {to,pack} = payload; let {to,pack} = payload;
this.peer(to).emit('message', pack); this.peer(to, true).emit('message', pack);
}) })
this.EventPooling.signal('request',(payload : {from:string,pack:any,id:number}) => { this.EventPooling.signal('request',(payload : {from:string,pack:any,id:number}) => {
let {from,pack, id} = payload; let {from,pack, id} = payload;
@ -71,7 +71,7 @@ export default class MWSE extends EventTarget {
this.EventPooling.signal('room/joined',(payload : {id:string,roomid:any,ownerid:string}) => { this.EventPooling.signal('room/joined',(payload : {id:string,roomid:any,ownerid:string}) => {
let {id,roomid} = payload; let {id,roomid} = payload;
let room = this.room(roomid); let room = this.room(roomid);
let peer = this.peer(id); let peer = this.peer(id, true);
room.emit('join', peer); room.emit('join', peer);
}) })
this.EventPooling.signal('room/ejected',(payload : {id:string,roomid:any,ownerid:string}) => { this.EventPooling.signal('room/ejected',(payload : {id:string,roomid:any,ownerid:string}) => {
@ -102,7 +102,7 @@ export default class MWSE extends EventTarget {
this.emit('room'); this.emit('room');
return room; return room;
} }
public peer(options: string | IRoomOptions) : Peer public peer(options: string | IRoomOptions, isActive = false) : Peer
{ {
if(typeof options == "string") if(typeof options == "string")
{ {
@ -117,6 +117,7 @@ export default class MWSE extends EventTarget {
} }
let peer = new Peer(this); let peer = new Peer(this);
peer.setPeerOptions(options); peer.setPeerOptions(options);
peer.active = isActive;
this.peers.set(peer.socketId as string, peer); this.peers.set(peer.socketId as string, peer);
this.emit('peer', peer); this.emit('peer', peer);
return peer; return peer;

2
script/index.js
View File

File diff suppressed because one or more lines are too long

2
script/index.js.map
View File

File diff suppressed because one or more lines are too long