{"version":3,"sources":["webrtc-interface.ts"],"sourcesContent":["import { logger } from \"../../datex_all.ts\";\nimport { Pointer } from \"../../runtime/pointers.ts\";\nimport { Endpoint } from \"../../types/addressing.ts\";\nimport { PermissionError } from \"../../types/errors.ts\";\nimport { communicationHub } from \"../communication-hub.ts\";\nimport { CommunicationInterface, CommunicationInterfaceSocket, InterfaceDirection, InterfaceProperties } from \"../communication-interface.ts\";\n\n@endpoint class WebRTCSignaling {\n\n /**\n * signaling: offer|accept\n */\n @property static negotiation(data: RTCSessionDescriptionInit) {\n if (!datex.meta.signed) throw new PermissionError(\"unauthorized\");\n if (data.type == \"offer\") WebRTCInterface.handleOffer(datex.meta.caller, data);\n else if (data.type == \"answer\") WebRTCInterface.handleAnswer(datex.meta.caller, data);\n else throw new Error(\"Unsupported session description type: \" + data.type);\n }\n\n /**\n * signaling: candidate\n */\n @property static candidate(data: RTCIceCandidateInit) {\n if (!datex.meta.signed) throw new PermissionError(\"unauthorized\");\n WebRTCInterface.handleCandidate(datex.meta.caller, data);\n }\n\n /**\n * request a specfic media stream - only works once a webrtc connection is established\n */\n @property static requestMediaStream(ptrId: string) {\n if (!datex.meta.signed) throw new PermissionError(\"unauthorized\");\n return WebRTCInterface.requestMediaStream(datex.meta.caller, ptrId);\n }\n}\n\nexport class WebRTCInterfaceSocket extends CommunicationInterfaceSocket {\n\n constructor(public inChannel: RTCDataChannel, public outChannel: RTCDataChannel) {\n super()\n }\n\n handleReceive = (event: MessageEvent) => {\n if (event.data instanceof ArrayBuffer) {\n this.receive(event.data)\n }\n }\n\n open() {\n this.inChannel.addEventListener(\"message\", this.handleReceive);\n }\n\n close() {\n this.inChannel.removeEventListener('message', this.handleReceive);\n }\n\n send(dxb: ArrayBuffer) {\n try {\n this.outChannel.send(dxb)\n return true;\n }\n catch {\n return false;\n }\n }\n}\n\n/**\n * Creates a direct DATEX communication channel between two WebRTC clients\n */\nexport class WebRTCInterface extends CommunicationInterface {\n \n public properties: InterfaceProperties = {\n type: \"webrtc\",\n direction: InterfaceDirection.IN_OUT,\n\t\tlatency: 20,\n bandwidth: 50_000\n }\n\n #socket?: WebRTCInterfaceSocket;\n #sessionInit?: RTCSessionDescriptionInit\n #endpoint: Endpoint;\n #connection?: RTCPeerConnection;\n\n #stunServers: RTCIceServer[]\n #turnServers: RTCIceServer[]\n\n #resolveTrackReceivedPromise!: (track: MediaStreamTrack) => void;\n #trackReceivedPromise!: Promise\n\n\n constructor(endpoint: Endpoint, sesionInit?: RTCSessionDescriptionInit, stunServers?: RTCIceServer[], turnServers?: RTCIceServer[]) {\n if (WebRTCInterface.connectedInterfaces.has(endpoint)) throw new Error(\"A WebRTCInterface for \" + endpoint + \" already exists\");\n super()\n\n this.generateTrackReceivedPromise();\n this.#endpoint = endpoint;\n this.#sessionInit = sesionInit;\n this.properties.name = this.#endpoint.toString();\n this.#stunServers = stunServers ?? [{urls: 'stun:195.201.173.190:3478'}];\n this.#turnServers = turnServers ?? [{urls: 'turn:195.201.173.190:3478', username: '1525325424', credential: 'YuzkH/Th9BBaRj4ivR03PiCfr+E='}]; // TODO: get turn server credentials from server\n }\n\n connect() {\n\n WebRTCInterface.connectingInterfaces.set(this.#endpoint, this);\n\n const {promise, resolve} = Promise.withResolvers()\n\n // try to establish a WebRTC connection, exchange keys first\n this.#connection = new RTCPeerConnection({\n iceServers: [...this.#stunServers, ...this.#turnServers]\n });\n\n const dataChannelOut = this.#connection.createDataChannel(\"datex\", {protocol: \"datex\"});\n\n // listeners\n\n this.#connection.onicecandidate = (e) => {\n if (e.candidate) WebRTCSignaling.candidate.to(this.#endpoint)(e.candidate.toJSON())\n };\n\n // connected\n this.#connection.onconnectionstatechange = _ => {\n switch(this.#connection?.connectionState) {\n case \"disconnected\":\n case \"closed\":\n case \"failed\": {\n if (this.#socket) this.removeSocket(this.#socket);\n resolve(false);\n }\n \n } \n };\n\n // received data channel \n this.#connection.ondatachannel = (event) => {\n this.logger.debug(\"received WebRTC data channel\");\n const dataChannelIn = event.channel\n\n this.#socket = new WebRTCInterfaceSocket(dataChannelIn, dataChannelOut);\n this.#socket.endpoint = this.#endpoint;\n this.addSocket(this.#socket);\n \n if (WebRTCInterface.connectingInterfaces.has(this.#endpoint)) {\n WebRTCInterface.connectingInterfaces.delete(this.#endpoint);\n WebRTCInterface.connectedInterfaces.set(this.#endpoint, this);\n }\n resolve(true);\n };\n \n // received track\n this.#connection.ontrack = (event) => {\n this.#resolveTrackReceivedPromise(event.track);\n this.generateTrackReceivedPromise()\n }\n\n this.#connection.onnegotiationneeded = async () => {\n try {\n await this.#connection!.setLocalDescription();\n WebRTCSignaling.negotiation.to(this.#endpoint)(this.#connection!.localDescription!.toJSON())\n }\n catch (e) {\n console.error(e)\n }\n }\n\n // handle initial offer\n if (this.#sessionInit) {\n this.handleOffer(this.#sessionInit);\n }\n\n return promise;\n }\n\n generateTrackReceivedPromise() {\n const {promise, resolve} = Promise.withResolvers();\n this.#trackReceivedPromise = promise;\n this.#resolveTrackReceivedPromise = resolve;\n }\n\n async collectMediaStreamTracks(count: number) {\n if (!this.#connection) throw new Error(\"No WebRTC connection found to collect media stream tracks\");\n\n let tracks: MediaStreamTrack[];\n let previousCount = -1;\n while ((tracks = this.#connection.getReceivers().map(receiver => receiver.track)).length < count) {\n // throw if no new track was added (would lead to infinite loop)\n if (previousCount == tracks.length) throw new Error(\"Track promise was resolved, but no new track added to connection\");\n previousCount = tracks.length;\n await this.#trackReceivedPromise\n }\n const mediaStream = new MediaStream();\n for (const track of tracks) {\n mediaStream.addTrack(track);\n }\n return mediaStream;\n }\n\n\n async handleOffer(data: RTCSessionDescriptionInit) {\n await this.#connection!.setRemoteDescription(data);\n const answer = await this.#connection!.createAnswer();\n await this.#connection!.setLocalDescription(answer);\n WebRTCSignaling.negotiation.to(this.#endpoint)(this.#connection!.localDescription!.toJSON())\n }\n\n\n disconnect() {\n this.#connection?.close();\n WebRTCInterface.connectedInterfaces.delete(this.#endpoint);\n }\n\n override removeSocket(socket: WebRTCInterfaceSocket) {\n super.removeSocket(socket);\n WebRTCInterface.connectedInterfaces.delete(this.#endpoint);\n WebRTCInterface.connectingInterfaces.delete(this.#endpoint);\n }\n \n cloneSocket(socket: WebRTCInterfaceSocket) {\n return new WebRTCInterfaceSocket(socket.inChannel, socket.outChannel);\n }\n\n /**\n * MediaStream handling\n */\n\n attachMediaStream(mediaStream: MediaStream) {\n if (!this.#connection) throw new Error(\"No WebRTC connection found to attach media stream\");\n for (const track of mediaStream.getTracks()) {\n this.#connection.addTrack(track, mediaStream);\n }\n }\n\n static async getMediaStream(ptrId: string) {\n const pointerOrigin = Pointer.getOriginFromPointerId(ptrId);\n console.debug(\"requesting mediastream $\" + ptrId + \", origin \" + pointerOrigin)\n if (!this.connectedInterfaces.has(pointerOrigin)) await communicationHub.addInterface(new WebRTCInterface(pointerOrigin));\n const interf = this.connectedInterfaces.get(pointerOrigin)!;\n if (!interf.#connection) throw new Error(\"No WebRTC connection could be established to get media stream\");\n\n const tracksCount = await WebRTCSignaling.requestMediaStream.to(pointerOrigin)(ptrId);\n const mediaStream = await interf.collectMediaStreamTracks(tracksCount);\n console.debug(\"received mediastream\",mediaStream)\n return mediaStream;\n }\n\n /**\n * Register a media stream to be used by the WebRTC interface\n * @param mediaStream \n */\n static registerMediaStream(mediaStream: MediaStream) {\n mediaStream = Pointer.proxifyValue(mediaStream) // make sure the media stream is bound to a pointer\n this.registeredMediaStreams.set(Pointer.getId(mediaStream)!, new WeakRef(mediaStream));\n }\n\n\n static registeredMediaStreams = new Map>(); // TODO: garbage collect weakrefs\n static connectingInterfaces = new Map();\n static connectedInterfaces = new Map();\n\n static getInterfaceForEndpoint(endpoint: Endpoint, findConnecting = true, findConnected = true) {\n return (\n (findConnecting ? this.connectingInterfaces.get(endpoint) : undefined) ??\n (findConnected ? this.connectedInterfaces.get(endpoint) : undefined)\n )\n }\n\n static getInterfaceConnection(endpoint: Endpoint, findConnecting = true, findConnected = true) {\n if (!findConnecting && !findConnected) throw new Error(\"Cannot find WebRTC connection: both findConnecting and findConnected are false\");\n\n let interf = this.getInterfaceForEndpoint(endpoint, findConnecting, findConnected)\n\n // try with main instance\n if (!interf) {\n interf = this.getInterfaceForEndpoint(endpoint.main, findConnecting, findConnected);\n if (interf) interf.#endpoint = endpoint; // specify received endpoint instance\n }\n\n if (!interf) {\n console.warn(\"No WebRTC interface found for endpoint \" + endpoint);\n return null;\n }\n else if (!interf.#connection) {\n console.warn(\"No WebRTC connection found for endpoint \" + endpoint);\n return null;\n }\n else return interf.#connection\n }\n\n static handleAnswer(endpoint: Endpoint, data: RTCSessionDescriptionInit) {\n const connection = this.getInterfaceConnection(endpoint, true, true);\n if (connection) connection.setRemoteDescription(data);\n }\n\n static async handleOffer(endpoint: Endpoint, data: RTCSessionDescriptionInit) {\n const interf = this.getInterfaceForEndpoint(endpoint, true, true);\n // offer for existing interface\n if (interf) {\n await interf.handleOffer(data);\n }\n // create new interface\n else {\n logger.info(\"Received WebRTC offer from \" + endpoint + \", creating new interface...\")\n await communicationHub.addInterface(new WebRTCInterface(endpoint, data));\n }\n }\n\n\n static handleCandidate(endpoint: Endpoint, data: RTCIceCandidateInit) {\n const connection = this.getInterfaceConnection(endpoint, true, true);\n if (connection) connection.addIceCandidate(data);\n }\n\n static requestMediaStream(endpoint: Endpoint, ptrId: string) {\n const connection = this.getInterfaceConnection(endpoint, false, true);\n if (!connection) throw new Error(\"Cannot request MediaStream $\" + ptrId + \": no WebRTC connection available\");\n \n const mediaStream = this.registeredMediaStreams.get(ptrId)?.deref();\n if (!mediaStream) throw new Error(\"MediaStream $\" + ptrId + \" not found\");\n \n console.debug(endpoint + \" requested mediastream $\" + ptrId)\n const tracks = mediaStream.getTracks();\n for (const track of tracks) {\n connection.addTrack(track, mediaStream);\n }\n return tracks.length\n }\n\n}"],"names":["logger","Pointer","PermissionError","communicationHub","CommunicationInterface","CommunicationInterfaceSocket","InterfaceDirection","WebRTCSignaling","property","negotiation","candidate","requestMediaStream","endpoint","data","datex","meta","signed","type","WebRTCInterface","handleOffer","caller","handleAnswer","Error","handleCandidate","ptrId","WebRTCInterfaceSocket","constructor","inChannel","outChannel","handleReceive","event","ArrayBuffer","receive","open","addEventListener","close","removeEventListener","send","dxb","properties","direction","IN_OUT","latency","bandwidth","sesionInit","stunServers","turnServers","connectedInterfaces","has","generateTrackReceivedPromise","name","toString","urls","username","credential","connect","connectingInterfaces","set","promise","resolve","Promise","withResolvers","RTCPeerConnection","iceServers","dataChannelOut","createDataChannel","protocol","onicecandidate","e","to","toJSON","onconnectionstatechange","_","connectionState","removeSocket","ondatachannel","debug","dataChannelIn","channel","addSocket","delete","ontrack","track","onnegotiationneeded","setLocalDescription","localDescription","console","error","collectMediaStreamTracks","count","tracks","previousCount","getReceivers","map","receiver","length","mediaStream","MediaStream","addTrack","setRemoteDescription","answer","createAnswer","disconnect","socket","cloneSocket","attachMediaStream","getTracks","getMediaStream","pointerOrigin","getOriginFromPointerId","addInterface","interf","get","tracksCount","registerMediaStream","proxifyValue","registeredMediaStreams","getId","WeakRef","Map","getInterfaceForEndpoint","findConnecting","findConnected","undefined","getInterfaceConnection","main","warn","connection","info","addIceCandidate","deref"],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,SAASA,MAAM,QAAQ,qBAAqB;AAC5C,SAASC,OAAO,QAAQ,4BAA4B;AAEpD,SAASC,eAAe,QAAQ,wBAAwB;AACxD,SAASC,gBAAgB,QAAQ,0BAA0B;AAC3D,SAASC,sBAAsB,EAAEC,4BAA4B,EAAEC,kBAAkB,QAA6B,gCAAgC;;;cAE9HC;;;YAAAA,wBAAAA;;;;wBAKXC;;wBAAgBC;;;wBAUhBD;;wBAAgBE;;;wBAQhBF;;wBAAgBG;;;oBAvBpBC;;;YAKG,OAAiBH,YAAYI,IAA+B,EAAE;gBAC1D,IAAI,CAACC,MAAMC,IAAI,CAACC,MAAM,EAAE,MAAM,IAAId,gBAAgB;gBAClD,IAAIW,AAAa,WAAbA,KAAKI,IAAI,EAAaC,gBAAgBC,WAAW,CAACL,MAAMC,IAAI,CAACK,MAAM,EAAEP;qBACpE,IAAIA,AAAa,YAAbA,KAAKI,IAAI,EAAcC,gBAAgBG,YAAY,CAACP,MAAMC,IAAI,CAACK,MAAM,EAAEP;qBAC3E,MAAM,AAAIS,MAAM,2CAA2CT,KAAKI,IAAI;YAC7E;YAKA,OAAiBP,UAAUG,IAAyB,EAAE;gBAClD,IAAI,CAACC,MAAMC,IAAI,CAACC,MAAM,EAAE,MAAM,IAAId,gBAAgB;gBAClDgB,gBAAgBK,eAAe,CAACT,MAAMC,IAAI,CAACK,MAAM,EAAEP;YACvD;YAKA,OAAiBF,mBAAmBa,KAAa,EAAE;gBAC/C,IAAI,CAACV,MAAMC,IAAI,CAACC,MAAM,EAAE,MAAM,IAAId,gBAAgB;gBAClD,OAAOgB,gBAAgBP,kBAAkB,CAACG,MAAMC,IAAI,CAACK,MAAM,EAAEI;YACjE;;;;AAGJ,OAAO,MAAMC,8BAA8BpB;;;IAEvCqB,YAAY,AAAOC,SAAyB,EAAE,AAAOC,UAA0B,CAAE;QAC7E,KAAK,SADUD,YAAAA,gBAAkCC,aAAAA,iBAIrDC,gBAAgB,CAACC;YACTA,MAAMjB,IAAI,YAAYkB,eACtB,IAAI,CAACC,OAAO,CAACF,MAAMjB,IAAI;QAE/B;IANA;IAEAgB,cAIC;IAEDI,OAAO;QACH,IAAI,CAACN,SAAS,CAACO,gBAAgB,CAAC,WAAW,IAAI,CAACL,aAAa;IACjE;IAEAM,QAAQ;QACJ,IAAI,CAACR,SAAS,CAACS,mBAAmB,CAAC,WAAW,IAAI,CAACP,aAAa;IACpE;IAEAQ,KAAKC,GAAgB,EAAE;QACnB,IAAI;YAEA,OADA,IAAI,CAACV,UAAU,CAACS,IAAI,CAACC,MACd,CAAA;QACX,EACA,OAAM;YACF,OAAO,CAAA;QACX;IACJ;AACJ;AAKA,OAAO,MAAMpB,wBAAwBd;IAE1BmC,aAAkC;QACrCtB,MAAM;QACNuB,WAAWlC,mBAAmBmC,MAAM;QAC1CC,SAAS;QACHC,WAAW;IACf,EAAC;IAED,CAAA,MAAO,CAAyB;IAChC,CAAA,WAAY,CAA4B;IACxC,CAAA,QAAS,CAAW;IACpB,CAAA,UAAW,CAAqB;IAEhC,CAAA,WAAY,CAAgB;IAC5B,CAAA,WAAY,CAAgB;IAE5B,CAAA,2BAA4B,CAAqC;IACjE,CAAA,oBAAqB,CAA4B;IAGjDjB,YAAYd,SAAkB,EAAEgC,UAAsC,EAAEC,WAA4B,EAAEC,WAA4B,CAAE;QAChI,IAAI5B,gBAAgB6B,mBAAmB,CAACC,GAAG,CAACpC,YAAW,MAAM,AAAIU,MAAM,2BAA2BV,YAAW;QAC7G,KAAK,IAEL,IAAI,CAACqC,4BAA4B,IACjC,IAAI,CAAC,CAAA,QAAS,GAAGrC,WACjB,IAAI,CAAC,CAAA,WAAY,GAAGgC,YACpB,IAAI,CAACL,UAAU,CAACW,IAAI,GAAG,IAAI,CAAC,CAAA,QAAS,CAACC,QAAQ,IAC9C,IAAI,CAAC,CAAA,WAAY,GAAGN,eAAe;YAAC;gBAACO,MAAM;YAA2B;SAAE,EACxE,IAAI,CAAC,CAAA,WAAY,GAAGN,eAAe;YAAC;gBAACM,MAAM;gBAA6BC,UAAU;gBAAcC,YAAY;YAA8B;SAAE;IAChJ;IAEAC,UAAU;QAENrC,gBAAgBsC,oBAAoB,CAACC,GAAG,CAAC,IAAI,CAAC,CAAA,QAAS,EAAE,IAAI;QAE7D,IAAM,EAACC,OAAO,EAAEC,OAAO,EAAC,GAAGC,QAAQC,aAAa;QAGhD,IAAI,CAAC,CAAA,UAAW,GAAG,IAAIC,kBAAkB;YACrCC,YAAY;mBAAI,IAAI,CAAC,CAAA,WAAY;mBAAK,IAAI,CAAC,CAAA,WAAY;aAAC;QAC5D;QAEA,IAAMC,iBAAiB,IAAI,CAAC,CAAA,UAAW,CAACC,iBAAiB,CAAC,SAAS;YAACC,UAAU;QAAO;QA0DrF,OAtDA,IAAI,CAAC,CAAA,UAAW,CAACC,cAAc,GAAG,CAACC;YAC3BA,EAAE1D,SAAS,IAAEH,iBAAgBG,SAAS,CAAC2D,EAAE,CAAC,IAAI,CAAC,CAAA,QAAS,EAAED,EAAE1D,SAAS,CAAC4D,MAAM;QACpF,GAGA,IAAI,CAAC,CAAA,UAAW,CAACC,uBAAuB,GAAGC,CAAAA;YACvC,OAAO,IAAI,CAAC,CAAA,UAAW,EAAEC;gBACrB,KAAK;gBACL,KAAK;gBACL,KAAK;oBACG,IAAI,CAAC,CAAA,MAAO,IAAE,IAAI,CAACC,YAAY,CAAC,IAAI,CAAC,CAAA,MAAO,GAChDf,QAAQ,CAAA;YAGhB;QACJ,GAGA,IAAI,CAAC,CAAA,UAAW,CAACgB,aAAa,GAAG,CAAC7C;YAC9B,IAAI,CAAC9B,MAAM,CAAC4E,KAAK,CAAC;YAClB,IAAMC,gBAAgB/C,MAAMgD,OAAO;YAEnC,IAAI,CAAC,CAAA,MAAO,GAAG,IAAIrD,sBAAsBoD,eAAeb,iBACxD,IAAI,CAAC,CAAA,MAAO,CAACpD,QAAQ,GAAG,IAAI,CAAC,CAAA,QAAS,EACtC,IAAI,CAACmE,SAAS,CAAC,IAAI,CAAC,CAAA,MAAO,GAEvB7D,gBAAgBsC,oBAAoB,CAACR,GAAG,CAAC,IAAI,CAAC,CAAA,QAAS,MACvD9B,gBAAgBsC,oBAAoB,CAACwB,MAAM,CAAC,IAAI,CAAC,CAAA,QAAS,GAC1D9D,gBAAgB6B,mBAAmB,CAACU,GAAG,CAAC,IAAI,CAAC,CAAA,QAAS,EAAE,IAAI,IAEhEE,QAAQ,CAAA;QACZ,GAGA,IAAI,CAAC,CAAA,UAAW,CAACsB,OAAO,GAAG,CAACnD;YACxB,IAAI,CAAC,CAAA,2BAA4B,CAACA,MAAMoD,KAAK,GAC7C,IAAI,CAACjC,4BAA4B;QACrC,GAEA,IAAI,CAAC,CAAA,UAAW,CAACkC,mBAAmB,GAAG;YACnC,IAAI;gBACA,MAAM,IAAI,CAAC,CAAA,UAAW,CAAEC,mBAAmB,IAC3C7E,iBAAgBE,WAAW,CAAC4D,EAAE,CAAC,IAAI,CAAC,CAAA,QAAS,EAAE,IAAI,CAAC,CAAA,UAAW,CAAEgB,gBAAgB,CAAEf,MAAM;YAC7F,EACA,OAAOF,GAAG;gBACNkB,QAAQC,KAAK,CAACnB;YAClB;QACJ,GAGI,IAAI,CAAC,CAAA,WAAY,IACjB,IAAI,CAACjD,WAAW,CAAC,IAAI,CAAC,CAAA,WAAY,GAG/BuC;IACX;IAEAT,+BAA+B;QAC3B,IAAM,EAACS,OAAO,EAAEC,OAAO,EAAC,GAAGC,QAAQC,aAAa;QAChD,IAAI,CAAC,CAAA,oBAAqB,GAAGH,SAC7B,IAAI,CAAC,CAAA,2BAA4B,GAAGC;IACxC;IAEA,MAAM6B,yBAAyBC,KAAa,EAAE;YAGtCC;QAFJ,IAAI,CAAC,IAAI,CAAC,CAAA,UAAW,EAAE,MAAM,AAAIpE,MAAM;QAGvC,IAAIqE,gBAAgB;QACpB,MAAO,AAACD,CAAAA,SAAS,IAAI,CAAC,CAAA,UAAW,CAACE,YAAY,GAAGC,GAAG,CAACC,CAAAA,WAAYA,SAASZ,KAAK,CAAA,EAAGa,MAAM,GAAGN,OAAO;YAE9F,IAAIE,iBAAiBD,OAAOK,MAAM,EAAE,MAAM,AAAIzE,MAAM;YACpDqE,gBAAgBD,OAAOK,MAAM,EAC7B,MAAM,IAAI,CAAC,CAAA,oBAAqB;QACpC;QACA,IAAMC,cAAc,IAAIC;QACxB,KAAK,IAAMf,SAASQ,OAChBM,YAAYE,QAAQ,CAAChB;QAEzB,OAAOc;IACX;IAGA,MAAM7E,YAAYN,IAA+B,EAAE;QAC/C,MAAM,IAAI,CAAC,CAAA,UAAW,CAAEsF,oBAAoB,CAACtF;QAC7C,IAAMuF,SAAS,MAAM,IAAI,CAAC,CAAA,UAAW,CAAEC,YAAY;QACnD,MAAM,IAAI,CAAC,CAAA,UAAW,CAAEjB,mBAAmB,CAACgB,SAC5C7F,iBAAgBE,WAAW,CAAC4D,EAAE,CAAC,IAAI,CAAC,CAAA,QAAS,EAAE,IAAI,CAAC,CAAA,UAAW,CAAEgB,gBAAgB,CAAEf,MAAM;IAC7F;IAGAgC,aAAa;QACT,IAAI,CAAC,CAAA,UAAW,EAAEnE,SAClBjB,gBAAgB6B,mBAAmB,CAACiC,MAAM,CAAC,IAAI,CAAC,CAAA,QAAS;IAC7D;IAESN,aAAa6B,MAA6B,EAAE;QACjD,KAAK,CAAC7B,aAAa6B,SACnBrF,gBAAgB6B,mBAAmB,CAACiC,MAAM,CAAC,IAAI,CAAC,CAAA,QAAS,GACzD9D,gBAAgBsC,oBAAoB,CAACwB,MAAM,CAAC,IAAI,CAAC,CAAA,QAAS;IAC9D;IAEAwB,YAAYD,MAA6B,EAAE;QACvC,OAAO,IAAI9E,sBAAsB8E,OAAO5E,SAAS,EAAE4E,OAAO3E,UAAU;IACxE;IAMA6E,kBAAkBT,WAAwB,EAAE;QACxC,IAAI,CAAC,IAAI,CAAC,CAAA,UAAW,EAAE,MAAM,AAAI1E,MAAM;QACvC,KAAK,IAAM4D,SAASc,YAAYU,SAAS,GACrC,IAAI,CAAC,CAAA,UAAW,CAACR,QAAQ,CAAChB,OAAOc;IAEzC;IAEA,aAAaW,eAAenF,KAAa,EAAE;QACvC,IAAMoF,gBAAgB3G,QAAQ4G,sBAAsB,CAACrF;QACrD8D,QAAQV,KAAK,CAAC,6BAA6BpD,QAAQ,cAAcoF,gBAC5D,IAAI,CAAC7D,mBAAmB,CAACC,GAAG,CAAC4D,kBAAgB,MAAMzG,iBAAiB2G,YAAY,CAAC,IAAI5F,gBAAgB0F;QAC1G,IAAMG,SAAS,IAAI,CAAChE,mBAAmB,CAACiE,GAAG,CAACJ;QAC5C,IAAI,CAACG,OAAO,CAAA,UAAW,EAAE,MAAM,AAAIzF,MAAM;QAEzC,IAAM2F,cAAc,MAAM1G,iBAAgBI,kBAAkB,CAAC0D,EAAE,CAACuC,eAAepF,QACzEwE,cAAc,MAAMe,OAAOvB,wBAAwB,CAACyB;QAE1D,OADA3B,QAAQV,KAAK,CAAC,wBAAuBoB,cAC9BA;IACX;IAMA,OAAOkB,oBAAoBlB,WAAwB,EAAE;QACjDA,cAAc/F,QAAQkH,YAAY,CAACnB,cACnC,IAAI,CAACoB,sBAAsB,CAAC3D,GAAG,CAACxD,QAAQoH,KAAK,CAACrB,cAAe,IAAIsB,QAAQtB;IAC7E;IAGA,OAAOoB,yBAAyB,IAAIG,MAAoC;IACxE,OAAO/D,uBAAuB,IAAI+D,MAAiC;IACnE,OAAOxE,sBAAsB,IAAIwE,MAAiC;IAElE,OAAOC,wBAAwB5G,SAAkB,EAAE6G,iBAAiB,CAAA,CAAI,EAAEC,gBAAgB,CAAA,CAAI,EAAE;QAC5F,OACI,AAACD,CAAAA,iBAAiB,IAAI,CAACjE,oBAAoB,CAACwD,GAAG,CAACpG,aAAY+G,KAAAA,CAAQ,KACnED,CAAAA,gBAAgB,IAAI,CAAC3E,mBAAmB,CAACiE,GAAG,CAACpG,aAAY+G,KAAAA,CAAQ;IAE1E;IAEA,OAAOC,uBAAuBhH,SAAkB,EAAE6G,iBAAiB,CAAA,CAAI,EAAEC,gBAAgB,CAAA,CAAI,EAAE;QAC3F,IAAI,CAACD,kBAAkB,CAACC,eAAe,MAAM,AAAIpG,MAAM;QAEvD,IAAIyF,SAAS,IAAI,CAACS,uBAAuB,CAAC5G,WAAU6G,gBAAgBC;eAQpE,CALI,CAACX,UACDA,CAAAA,SAAS,IAAI,CAACS,uBAAuB,CAAC5G,UAASiH,IAAI,EAAEJ,gBAAgBC,cAAa,KACtEX,CAAAA,OAAO,CAAA,QAAS,GAAGnG,SAAO,GAGrCmG,UAIKA,OAAO,CAAA,UAAW,GAIhBA,OAAO,CAAA,UAAW,IAH1BzB,QAAQwC,IAAI,CAAC,6CAA6ClH,YACnD,SALP0E,QAAQwC,IAAI,CAAC,4CAA4ClH,YAClD;IAOf;IAEA,OAAOS,aAAaT,SAAkB,EAAEC,IAA+B,EAAE;QACrE,IAAMkH,aAAa,IAAI,CAACH,sBAAsB,CAAChH,WAAU,CAAA,GAAM,CAAA;QAC3DmH,cAAYA,WAAW5B,oBAAoB,CAACtF;IACpD;IAEA,aAAaM,YAAYP,SAAkB,EAAEC,IAA+B,EAAE;QAC1E,IAAMkG,SAAS,IAAI,CAACS,uBAAuB,CAAC5G,WAAU,CAAA,GAAM,CAAA;QAExDmG,SACA,MAAMA,OAAO5F,WAAW,CAACN,SAIzBb,OAAOgI,IAAI,CAAC,gCAAgCpH,YAAW,gCACvD,MAAMT,iBAAiB2G,YAAY,CAAC,IAAI5F,gBAAgBN,WAAUC;IAE1E;IAGA,OAAOU,gBAAgBX,SAAkB,EAAEC,IAAyB,EAAE;QAClE,IAAMkH,aAAa,IAAI,CAACH,sBAAsB,CAAChH,WAAU,CAAA,GAAM,CAAA;QAC3DmH,cAAYA,WAAWE,eAAe,CAACpH;IAC/C;IAEA,OAAOF,mBAAmBC,SAAkB,EAAEY,KAAa,EAAE;QACzD,IAAMuG,aAAa,IAAI,CAACH,sBAAsB,CAAChH,WAAU,CAAA,GAAO,CAAA;QAChE,IAAI,CAACmH,YAAY,MAAM,AAAIzG,MAAM,iCAAiCE,QAAQ;QAE1E,IAAMwE,cAAc,IAAI,CAACoB,sBAAsB,CAACJ,GAAG,CAACxF,QAAQ0G;QAC5D,IAAI,CAAClC,aAAa,MAAM,AAAI1E,MAAM,kBAAkBE,QAAQ;QAE5D8D,QAAQV,KAAK,CAAChE,YAAW,6BAA6BY;QACtD,IAAMkE,SAASM,YAAYU,SAAS;QACpC,KAAK,IAAMxB,SAASQ,OAChBqC,WAAW7B,QAAQ,CAAChB,OAAOc;QAE/B,OAAON,OAAOK,MAAM;IACxB;AAEJ","sourceRoot":"/lib/datex-core-js-legacy-0.3.15/network/communication-interfaces/","file":"webrtc-interface.ts"}