3 lines
5.6 KiB
JavaScript
3 lines
5.6 KiB
JavaScript
(()=>{class e{autoPair=!1;connected=!1;constructor(e){this.endpoint=new URL(e.endpoint),this.autoPair=e.autoPair||!1}connect(){this.ws=new WebSocket(this.endpoint.href),this.addWSEvents()}disconnect(){this.ws.close()}addWSEvents(){this.ws.addEventListener("open",(()=>this.eventOpen())),this.ws.addEventListener("close",(()=>this.eventClose())),this.ws.addEventListener("error",(()=>this.eventError())),this.ws.addEventListener("message",(({data:e})=>this.eventMessage(e)))}eventOpen(){this.connected=!0;for(const e of this.activeConnectionEvent)e(void 0)}eventClose(){this.connected=!1}eventError(){this.connected=!1}recaivePackEvent=[];onRecaivePack(e){this.recaivePackEvent.push(e)}activeConnectionEvent=[];onActive(e){this.connected?e():this.activeConnectionEvent.push(e)}eventMessage(e){if("string"==typeof e){let t=JSON.parse(e);for(const e of this.recaivePackEvent)e(t)}}tranferToServer(e){this.connected&&this.ws.send(JSON.stringify(e))}}class t{events=new Map;signals=new Map;count=0;constructor(e){this.wsts=e}request(e){return new Promise(((t,s)=>{let i=++this.count;this.wsts.WSTSProtocol.SendRequest(e,i),this.events.set(i,[e=>{t(e)},e=>{s(e)}])}))}stream(e,t){let s=++this.count;this.wsts.WSTSProtocol.StartStream(e,s),this.events.set(s,[e=>{t(e)},()=>{}])}signal(e,t){let s=this.signals.get(e);s?s.push(t):this.signals.set(e,[t])}}class s{events={};emit(e,...t){if(this.events[e])for(const s of this.events[e])s(...t)}on(e,t){this.events[e]?this.events[e].push(t):this.events[e]=[t]}activeScope=!1;scope(e){this.activeScope?e():this.on("scope",e)}}class i extends s{selfSocket=!1;active=!1;constructor(e){super(),this.mwse=e}setPeerOptions(e){"string"==typeof e?this.setSocketId(e):this.options=e}setSocketId(e){this.socketId=e}async metadata(){if("me"==this.socketId){let e=await this.mwse.EventPooling.request({type:"my/socketid"});return this.selfSocket=!0,this.active||=!0,this.socketId=e,this.emit("scope"),this.activeScope=!0,e}}async isReachable(){return await this.mwse.EventPooling.request({type:"is/reachable",to:this.socketId})}async enablePairAuth(){await this.mwse.EventPooling.request({type:"auth/pair-system",value:"everybody"})}async disablePairAuth(){await this.mwse.EventPooling.request({type:"auth/pair-system",value:"disable"})}async send(e){await this.mwse.EventPooling.request({type:"pack/to",pack:e,to:this.socketId})}}class o extends s{ifexistsJoin=!1;constructor(e){super(),this.mwse=e}setRoomOptions(e){if("string"==typeof e)this.roomId=e;else{let t={joinType:"free",ifexistsJoin:!0,accessType:"private",notifyActionInvite:!0,notifyActionJoined:!0,notifyActionEjected:!0};Object.assign(t,e),this.options=t}}setRoomId(e){this.roomId=e}async createRoom(e){let t=this.options||e,s=await this.mwse.EventPooling.request({type:"create-room",...t});if("fail"==s.status){if("ALREADY-EXISTS"==s.message&&this.ifexistsJoin)return this.join();throw new Error(s.message||s.messages)}this.options={...this.options,...s.room},this.roomId=s.room.id}async join(){let e=await this.mwse.EventPooling.request({type:"joinroom",name:this.options.name,credential:this.options.credential});if("fail"==e.status)throw new Error(e.message);this.options={...this.options,...e.room},this.roomId=e.room.id}async send(e,t=!1){await this.mwse.EventPooling.request({type:"pack/room",pack:e,to:this.roomId,wom:t})}async fetchAllPeers(){let{type:e,peers:t}=await this.mwse.EventPooling.request({type:"room-peers",roomId:this.roomId});if("fail"==e)throw new Error("Cant using peers on room");if("success"==e)for(const e of t)this.mwse.peer(e)}}class n{constructor(e){this.mwse=e,this.addListener()}addListener(){this.mwse.server?.onRecaivePack((e=>{this.PackAnalyze(e)}))}SendRaw(e){this.mwse.server.tranferToServer(e)}SendOnly(e){this.mwse.server.tranferToServer([e,"R"])}SendRequest(e,t){this.mwse.server.tranferToServer([e,t,"R"])}StartStream(e,t){this.mwse.server.tranferToServer([e,t,"S"])}PackAnalyze(e){let[t,s,i]=e;if("number"==typeof s){let e=this.mwse.EventPooling.events.get(s);if(e){if(e[0](t,i),"E"===i)this.mwse.EventPooling.events.delete(s)}else console.warn("Missing event sended from server")}else{let e=this.mwse.EventPooling.signals.get(s);if(e)for(const s of e)s(t);else console.warn("Missing event sended from server")}}}window.MWSE=class extends s{rooms=new Map;pairs=new Map;peers=new Map;constructor(s){super(),this.server=new e(s),this.server.connect(),this.WSTSProtocol=new n(this),this.EventPooling=new t(this),this.me=new i(this),this.me.scope((()=>{this.peers.set("me",this.me),this.peers.set(this.me.socketId,this.me)})),this.server.onActive((async()=>{this.me.setSocketId("me"),await this.me.metadata(),this.emit("scope"),this.activeScope=!0})),this.packMessagingSystem()}packMessagingSystem(){this.EventPooling.signal("pack",(e=>{let{to:t,pack:s}=e;this.peer(t).emit("message",s)})),this.EventPooling.signal("pack/room",(e=>{let{to:t,pack:s}=e;this.room(t).emit("message",s)})),this.EventPooling.signal("room/joined",(e=>{let{id:t,roomid:s}=e,i=this.room(s),o=this.peer(t);i.emit("join",o)})),this.EventPooling.signal("room/ejected",(e=>{let{id:t,roomid:s}=e,i=this.room(s),o=this.peer(t);i.emit("eject",o)})),this.EventPooling.signal("room/closed",(e=>{let{roomid:t}=e;this.room(t).emit("close"),this.rooms.delete(t)}))}room(e){if("string"==typeof e&&this.rooms.has(e))return this.rooms.get(e);let t=new o(this);return t.setRoomOptions(e),this.rooms.set(t.roomId,t),this.emit("room"),t}peer(e){if("string"==typeof e){if(this.peers.has(e))return this.peers.get(e);if(this.pairs.has(e))return this.pairs.get(e)}let t=new i(this);return t.setPeerOptions(e),this.peers.set(t.socketId,t),this.emit("peer",t),t}}})();
|
|
//# sourceMappingURL=index.js.map
|