Files

1 line
34 KiB
JavaScript
Raw Permalink Normal View History

2026-02-02 19:13:26 +03:00
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([[3],{"/Dgr":function(e,t){function n(){throw new TypeError("Invalid attempt to spread non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method.")}e.exports=n,e.exports.__esModule=!0,e.exports["default"]=e.exports},"0F7Y":function(e,t,n){"use strict";var r=n("kZYY");Object.defineProperty(t,"__esModule",{value:!0}),t.default=f;var o=r(n("E3WA")),a=r(n("fydt")),u=r(n("Z0cm")),c=n("GnQf"),i=r(n("aNwR")),s=r(n("JXcE")),l=n("Vfns");function f(e,t,n){return d.apply(this,arguments)}function d(){return d=(0,a.default)(o.default.mark((function e(t,n,r){var a,f,d,p,v,h,b,m,g,w,y,k,x,_,T=arguments;return o.default.wrap((function(e){while(1)switch(e.prev=e.next){case 0:return a=T.length>3&&void 0!==T[3]&&T[3],s.default.log("[ws] try to fetch token from: ".concat(t)),e.next=4,(0,l.getTokenCache)({uid:r,sessionPrivate:a});case 4:if(f=e.sent,!f){e.next=9;break}if(d=f||{},p=d.token,v=d.instanceServers,!p||!v){e.next=9;break}return e.abrupt("return",{token:p,instanceServers:v});case 9:h=!0,b=null,m=[],g=200,w=0;case 14:if(!(h&&w<10)){e.next=43;break}return e.prev=15,e.next=18,(0,c.post)(t,{protocol:"socket.io",source:n});case 18:if(y=e.sent,k=y.data,b=k.token,m=k.instanceServers,(0,u.default)(m)&&m.length){e.next=24;break}throw new Error("Invalid Servers List, fetch data: ".concat(JSON.stringify(k)));case 24:h=!1,(0,l.setTokenCache)({uid:r,sessionPrivate:a,token:b,instanceServers:m}),e.next=41;break;case 28:if(e.prev=28,e.t0=e["catch"](15),s.default.log(e.t0),x=e.t0||{},_=x.code,!_||"401"!==_){e.next=36;break}return g=401,h=!1,e.abrupt("break",43);case 36:return h=!0,w+=1,e.next=40,(0,i.default)(5e3);case 40:s.default.log("[ws] retry to fetch token");case 41:e.next=14;break;case 43:return e.abrupt("return",{token:b,instanceServers:m,code:g});case 44:case"end":return e.stop()}}),e,this,[[15,28]])}))),d.apply(this,arguments)}e.exports=t.default},"157+":function(e,t){function n(e){if("undefined"!==typeof Symbol&&null!=e[Symbol.iterator]||null!=e["@@iterator"])return Array.from(e)}e.exports=n,e.exports.__esModule=!0,e.exports["default"]=e.exports},"7a2K":function(e,t,n){"use strict";var r=n("kZYY");Object.defineProperty(t,"__esModule",{value:!0}),t.messageHandler=t.unSubscribeHandler=t.subscribeHandler=t.errorHandler=t.serverDisconnectHandler=t.reconnectHandler=t.connectHandler=t.eventHandler=void 0;var o=r(n("yfwS")),a=r(n("jIJb")),u=r(n("JXcE")),c=r(n("Up5r")),i=n("r7jK"),s=n("Vfns"),l="_event_",f="".concat(l,"_first_ack"),d=(0,c.default)("ack");function p(e){var t=e||"ev",n=Math.random().toString(36).substr(2,9),r=(new Date).getTime();return"".concat(l,"_").concat(t,"_").concat(n,"_").concat(r)}var v=function(e){u.default.log(e)},h=new o.default;t.eventHandler=h;var b=function(e,t){return new Promise((function(n){e.on("connect",(function(){var e;(0,a.default)(h),u.default.log("[ws] event emitter all off on connect");var r=function(){e&&clearTimeout(e),u.default.log("[ws] connect ack recieved"),t.emit("connect"),n()};e=setTimeout((function(){u.default.log("[ws] connect timeout"),h.off(f,r),n("ACK TIMEOUT"),t.emit("disconnect")}),1e4),h.once(f,r)}))}))};t.connectHandler=b;var m=function(e,t){return new Promise((function(n){e.on("reconnect",(function(){var e,r=function(){e&&clearTimeout(e),u.default.log("[ws] reconnect ack recieved"),t.emit("reconnect"),n()};e=setTimeout((function(){u.default.log("[ws] reconnect timeout"),h.off(f,r),n("ACK TIMEOUT"),t.emit("disconnect")}),1e4),h.once(f,r)}))}))};t.reconnectHandler=m;var g=function(e,t){return new Promise((function(n){e.on("disconnect",(function(e){t.emit("disconnect"),"io server disconnect"!==e&&"transport close"!==e||n(e)}))}))};t.serverDisconnectHandler=g;var w=function(e,t){return new Promise((function(n){e.on("error",(function(e){t.emit("error"),n(e)})),e.on("reconnect_failed",(function(){t.emit("disconnect"),n(new Error("Reconnect Failed"))}))}))};t.errorHandler=w;var y=function(e,t,n){return new Promise((function(r){var o="subscribe",a=p(o);h.once(a,(function(e){u.default.log("[ws