{"version":3,"sources":["jsdelivr-header.js","/npm/ion-sfu-nodejs@0.0.9/lib/index.js"],"names":[],"mappings":"AAAA;AACA;AACA;AACA;AACA;AACA;AACA,ACNA,aACA,IAAI,gBAAmB,MAAQ,KAAK,iBAAoB,SAAU,GAC9D,OAAQ,GAAO,EAAI,WAAc,EAAM,CAAE,QAAW,EACxD,EACA,OAAO,eAAe,QAAS,aAAc,CAAE,OAAO,IACtD,MAAM,YAAc,QAAQ,aACtB,SAAW,QAAQ,UACnB,OAAS,gBAAgB,QAAQ,WACjC,SAAW,QAAQ,kBACzB,MAAM,eAAe,SAAS,aAC1B,WAAA,GACI,QACA,KAAK,KAAO,CAAC,EAAK,EAAI,KAClB,MAAM,EAAU,IAAI,SAAS,cACvB,EAAO,IAAI,SAAS,YAC1B,IAAI,EAAY,YAAY,OAAO,OAAO,GAE1C,EAAQ,MAAM,GACd,EAAK,OAAO,GACZ,EAAK,eAAe,GAEpB,EAAQ,QAAQ,GAGhB,KAAK,KAAK,MAAM,EAAQ,EAE5B,KAAK,YAAe,IAChB,MAAM,EAAU,IAAI,SAAS,cAC7B,IAAI,EAAa,YAAY,OAAO,OAAO,GAC3C,EAAQ,eAAe,GACvB,KAAK,KAAK,MAAM,EAAQ,EAE5B,KAAK,QAAU,CAAC,EAAQ,KACL,IAAI,SAAS,cAA5B,MACM,EAAU,IAAI,SAAS,QAC7B,EAAQ,UAAU,GAClB,EAAQ,QAAQ,EAAI,EAExB,KAAK,MAAQ,IAAI,SAAS,aAC1B,KAAK,KAAO,OAAO,QAAQ,SAC3B,KAAK,KAAK,GAAG,QAAS,IAGlB,OADY,EAAY,kBAEpB,KAAK,SAAS,YAAY,YAAY,KAClC,KAAK,MAAM,KAAK,SAAU,EAAY,QAAS,YAAY,OAAO,OAAO,EAAY,UAAU,yBAE/F,MACJ,KAAK,SAAS,YAAY,YAAY,YAClC,KAAK,MAAM,KAAK,gBAAiB,YAAY,OAAO,OAAO,EAAY,yBAEvE,MACJ,KAAK,SAAS,YAAY,YAAY,QAClC,KAAK,MAAM,KAAK,YAAa,EAAY,aAAa,YAAa,EAAY,aAAa,WAG5F,MACJ,KAAK,SAAS,YAAY,YAAY,mBAClC,KAAK,MAAM,KAAK,uBAAwB,EAAY,yBAExD,KAAK,SAAS,YAAY,YAAY,MAClC,KAAK,MAAM,KAAK,UAAW,EAAY,YAK/C,GAER,EAEJ,QAAQ,QAAU","file":"/npm/ion-sfu-nodejs@0.0.9/lib/index.js","sourceRoot":"","sourcesContent":["/**\n * Minified by jsDelivr using Terser v5.39.0.\n * Original file: /npm/ion-sfu-nodejs@0.0.9/lib/index.js\n *\n * Do NOT use SRI with dynamically generated files! More information: https://www.jsdelivr.com/using-sri-with-dynamic-files\n */\n","\"use strict\";\nvar __importDefault = (this && this.__importDefault) || function (mod) {\n    return (mod && mod.__esModule) ? mod : { \"default\": mod };\n};\nObject.defineProperty(exports, \"__esModule\", { value: true });\nconst js_base64_1 = require(\"js-base64\");\nconst events_1 = require(\"events\");\nconst conn_1 = __importDefault(require(\"./conn\"));\nconst sfu_pb_1 = require(\"./proto/sfu_pb\");\nclass ionSfu extends events_1.EventEmitter {\n    constructor() {\n        super();\n        this.Join = (obj, id, sid) => {\n            const request = new sfu_pb_1.SignalRequest();\n            const join = new sfu_pb_1.JoinRequest();\n            let dataoffer = js_base64_1.Base64.encode(obj);\n            // console.log(\"object a\", objJsonB64);\n            request.setId(id);\n            join.setSid(sid);\n            join.setDescription(dataoffer);\n            //  console.log(join)\n            request.setJoin(join);\n            // console.log(request);\n            // const bufferedData = Buffer.from(JSON.stringify(request));\n            this.Call.write(request);\n        };\n        this.Description = (obj) => {\n            const request = new sfu_pb_1.SignalRequest();\n            let dataanswer = js_base64_1.Base64.encode(obj);\n            request.setDescription(dataanswer);\n            this.Call.write(request);\n        };\n        this.Trickle = (target, obj) => {\n            const requst = new sfu_pb_1.SignalRequest();\n            const trickle = new sfu_pb_1.Trickle();\n            trickle.setTarget(target);\n            trickle.setInit(obj);\n        };\n        this.event = new events_1.EventEmitter();\n        this.Call = conn_1.default.signal();\n        this.Call.on(\"data\", (signalreply) => {\n            // console.log(\"incoming\", signalreply)\n            const res = signalreply.getPayloadCase();\n            switch (res) {\n                case sfu_pb_1.SignalReply.PayloadCase.JOIN:\n                    this.event.emit(\"onJoin\", signalreply.getId(), js_base64_1.Base64.decode(signalreply.getJoin().getDescription_asB64()));\n                    // console.log(\"onjoin\", signalreply.getId(), Base64.decode(signalreply.getJoin().getDescription_asB64()));\n                    break;\n                case sfu_pb_1.SignalReply.PayloadCase.DESCRIPTION:\n                    this.event.emit(\"onDescription\", js_base64_1.Base64.decode(signalreply.getDescription_asB64()));\n                    // console.log(\"onDescription\", Base64.decode(signalreply.getDescription_asB64()))\n                    break;\n                case sfu_pb_1.SignalReply.PayloadCase.TRICKLE:\n                    this.event.emit(\"onTrickle\", signalreply.getTrickle().getTarget(), signalreply.getTrickle().getInit());\n                    //console.log(\"onCadadidate\", signalreply.getTrickle().getTarget());\n                    // console.log(\"oncan\", signalreply.getTrickle().getInit());\n                    break;\n                case sfu_pb_1.SignalReply.PayloadCase.ICECONNECTIONSTATE:\n                    this.event.emit(\"onIceconnectionstate\", signalreply.getIceconnectionstate());\n                // console.log(\"icestatechanged: \", signalreply.getIceconnectionstate());\n                case sfu_pb_1.SignalReply.PayloadCase.ERROR:\n                    this.event.emit(\"onError\", signalreply.getError());\n                    //console.log(\"on Error\");\n                    break;\n                default:\n                    break;\n            }\n        });\n    }\n}\nexports.default = ionSfu;\n"]}