if (self.CavalryLogger) { CavalryLogger.start_js(["3Ua4g"]); } __d("AdsPagerConstants",["keyMirror"],(function(a,b,c,d,e,f){a=b("keyMirror")({ADD_PAGE:null,PAGE_TRANSITION:null,REQUEST_PAGE:null});c=b("keyMirror")({VIEW_ACTION:null,SERVER_ACTION:null});e.exports={ActionTypes:a,PayloadSources:c}}),null); __d("AdsPagerDispatcher",["AdsPagerConstants","Dispatcher_DEPRECATED"],(function(a,b,c,d,e,f){"use strict";c=b("AdsPagerConstants").PayloadSources;function a(a){return function(b){this.dispatch({payloadSource:a,action:b})}}d=Object.assign(new(b("Dispatcher_DEPRECATED"))(),{handleUpdateFromViewAction:a(c.VIEW_ACTION),handleUpdateFromServerAction:a(c.SERVER_ACTION)});e.exports=d}),null); __d("ExternalTrackingTag",["AsyncSignal","Event","TrackingPixel"],(function(a,b,c,d,e,f){var g={listenForElementClick:function(a,c,d,e,f){b("Event").listen(a,"click",function(){g.sendRequest(c,d,e,f)})},sendRequest:function(a,c,d,e){if(!a)return;new(b("AsyncSignal"))("/ads/external_tracking_tag/",{href:a,tracking_tag_id:c,adgroup_id:d,ad_id:e}).send();b("TrackingPixel").loadWithNoReferrer(a)}};e.exports=g}),null); __d("FBLynxWrapper",["URI","isLinkshimURI"],(function(a,b,c,d,e,f){"use strict";a={SUBDOMAIN:"l",SUBDOMAIN_M:"lm",PATH:"/",URL_PARAM:"u",ENC_PARAM:"e",isLynxLink:function(a){if(a.getAttribute("data-lynx-async-dest"))return!0;if(a.getAttribute("data-lynx-uri"))return!0;return b("isLinkshimURI")(new(b("URI"))(a.href))?!0:!1}};e.exports=a}),null); __d("LitestandColumnManager",["Arbiter","BlueBar","Event","NavigationMessage","Run","SubscriptionsHandler","clamp","getScrollPosition"],(function(a,b,c,d,e,f){"use strict";__p&&__p();var g=0,h=null;function i(){if(h)return;h=new(b("SubscriptionsHandler"))();h.addSubscriptions(b("Arbiter").subscribe(b("NavigationMessage").NAVIGATION_BEGIN,function(){l(0),j()}),b("Event").listen(window,"resize",function(){b("BlueBar").hasFixedBlueBar()||(l(0),j())}),b("Event").listen(window,"scroll",function(){k()||j()}));b("Run").onLeave(function(){h&&h.release()})}function j(){h&&h.release(),h=null}function k(){if(g<=0)return!1;l(b("clamp")(b("getScrollPosition")(window).y,0,g));return g>0}function l(a){g=a}a={adjustVerticalWindowPosition:function(a,b){i(),l(b),window.scrollTo(a.x,a.y+g)}};e.exports=a}),null); __d("LitestandStream",["csx","invariant","Arbiter","CSS","EventEmitter","LitestandColumnManager","Run","getScrollPosition","nullthrows"],(function(a,b,c,d,e,f,g,h){__p&&__p();var i,j,k,l,m=new(b("EventEmitter"))(),n={init:function(a,c,d,e){i=d,k=a,j=e,l||(l=b("Arbiter").subscribe("ufi/didUpdate",function(a,c){c.offsetY&&b("LitestandColumnManager").adjustVerticalWindowPosition(b("getScrollPosition")(window),c.offsetY)})),b("Run").onLeave(function(){l&&l.unsubscribe(),l=null,m.removeAllListeners("ready"),k=null}),m.emit("ready")},getStoriesSelector:function(){return"._5jmm"},getStreamRoot:function(){return k},getSectionID:function(){return i},getStoryID:function(){return j},isStory:function(a){return b("CSS").matchesSelector(a,"._5jmm")},getFeedStreamID:function(){return parseInt(b("nullthrows")(k).id.split("feed_stream_")[1],16)%1e8},isReady:function(){return!!k},addReadyListener:function(a){n.isReady()||h(0,1974);return m.once("ready",a)}};e.exports=n}),null); __d("FeedAdsClickLogger",["AdsPagerDispatcher","Arbiter","AsyncRequest","BanzaiODS","DataAttributeUtils","DOM","ExternalTrackingTag","FBLogger","FBLynxWrapper","LitestandMessages","LitestandStream","Parent","SLConfig","TrackingNodes","URI","collectDataAttributes","ge","gkx","isFacebookURI","isLinkshimURI"],(function(a,b,c,d,e,f){"use strict";__p&&__p();var g={},h=!1,i,j=!1,k=function(){__p&&__p();function a(){}var c=a.prototype;c.init=function(a){i=b("SLConfig").gk.sl_replace_s,b("Arbiter").subscribe("ClickRefAction/new",this.onNewUserAction.bind(this)),b("Arbiter").subscribe("ClickRefAction/contextmenu",this.onNewUserAction.bind(this)),b("Arbiter").subscribe("ClickRefAction/middleclick",this.onNewUserAction.bind(this)),j=a.see_more_logging_enabled,a.append_tracking_data_to_links&&(this.appendTrackingDataToLinks(),b("Arbiter").subscribe(b("LitestandMessages").STORIES_INSERTED,this.appendTrackingDataToLinks.bind(this)),b("Arbiter").subscribe("FeedAdsClickLogger/refreshTrackingData",this.appendTrackingDataToLinks.bind(this),"new"))};c.getStories=function(){var a=b("LitestandStream").getStreamRoot();if(a)return b("DOM").scry(a,b("LitestandStream").getStoriesSelector());else{a=b("ge")("home_stream");if(a)return b("DOM").scry(a,".uiStreamStory")}return[]};c.appendTrackingDataToLinks=function(){__p&&__p();var a=this.getStories();for(var c=0;c1e4)&&this.inform(this.TIME_TRAVEL,b)};e.$SystemEvents6=function(){this.$SystemEvents8(),this.$SystemEvents9(),this.$SystemEvents10(),this.$SystemEvents11()};e.$SystemEvents8=function(){var a=this,c=b("TimeSlice").guard(function(){a.$SystemEvents3||(a.$SystemEvents3=!0,a.inform(a.ONLINE,a.$SystemEvents3))},"SystemEvents onOnline"),d=b("TimeSlice").guard(function(){a.$SystemEvents3&&(a.$SystemEvents3=!1,a.inform(a.ONLINE,a.$SystemEvents3))},"SystemEvents onOffline");b("UserAgent_DEPRECATED").ie()?b("UserAgent_DEPRECATED").ie()>=11?(window.addEventListener("online",c,!1),window.addEventListener("offline",d,!1)):b("UserAgent_DEPRECATED").ie()>=8?window.attachEvent("onload",function(){document.body.ononline=c,document.body.onoffline=d}):b("setIntervalAcrossTransitions")(function(){(navigator.onLine?c:d)()},g):window.addEventListener&&(window.addEventListener("online",c,!1),window.addEventListener("offline",d,!1))};e.$SystemEvents13=function(){b("clearTimeout")(this.$SystemEvents5),this.$SystemEvents5=b("setTimeoutAcrossTransitions")(this.$SystemEvents12,g)};e.$SystemEvents9=function(){var a=this;if(self!==top&&b("gkx")("678677"))return;b("gkx")("678678")&&b("UserActivity").subscribe(function(){a.$SystemEvents13()});this.$SystemEvents13()};e.$SystemEvents10=function(){b("setIntervalAcrossTransitions")(this.checkTimeTravel.bind(this),g)};e.$SystemEvents11=function(){b("setIntervalAcrossTransitions")(function(){window.onerror!=b("ErrorPubSub").onerror&&(window.onerror=b("ErrorPubSub").onerror)},g)};e.$SystemEvents7=function(){return b("Cookie").get("c_user")||"0"};return d}(b("mixin")(b("ArbiterMixin")));e.exports=new c()}),3); __d("onViewportChanged",["EventListener","emptyFunction","getViewportDimensions","requestAnimationFrame"],(function(a,b,c,d,e,f){__p&&__p();var g=[],h=!1,i=null,j,k;function l(){var a=b("getViewportDimensions").withoutScrollbars();return{top:0,bottom:a.height,left:0,right:a.width}}function a(a,c){c={transform:c||b("emptyFunction").thatReturnsArgument,callback:a,needsUpdate:!0};g.push(c);s();n();return{remove:m.bind(null,c),scheduleCheck:q.bind(null,c)}}function m(a){a=g.indexOf(a);a!==-1&&(g.splice(a,1),g.length===0&&(o(),i=null))}function n(){k||(k=b("EventListener").capture(window,"scroll",r),j=b("EventListener").capture(window,"resize",p))}function o(){k!==null&&j!==null&&(k.remove(),j.remove(),k=j=null)}function p(){i=null,r()}function q(a){a.needsUpdate=!0,s()}function r(){g.map(function(a){return a.needsUpdate=!0}),s()}function s(){h||(h=!0,b("requestAnimationFrame")(function(){h=!1,u()}))}function t(a){if(a.needsUpdate){a.needsUpdate=!1;return!0}return!1}function u(){i||(i=l());var a=g.filter(t),b=a.map(function(a){return a.transform.call(null,i)});a.forEach(function(a,c){return a.callback.call(null,b[c])})}e.exports=a}),null); __d("FantailLogger",["FantailConfig"],(function(a,b,c,d,e,f){__p&&__p();var g=b("FantailConfig").FantailLogQueue;a={debug:function(a,b){var c;for(var d=arguments.length,e=new Array(d>2?d-2:0),f=2;f2?d-2:0),f=2;f2?d-2:0),f=2;f2?d-2:0),f=2;f=a.length)break;f=a[e++]}else{e=a.next();if(e.done)break;f=e.value}f=f;b(f)&&c.add(f)}return c}e.exports=a}),null); __d("MqttWsClientTypedLoggerLite",["Banzai","generateLiteTypedLogger"],(function(a,b,c,d,e,f){"use strict";e.exports=b("generateLiteTypedLogger")("logger:MqttWsClientLoggerConfig")}),null); __d("InstanceProxy",[],(function(a,b,c,d,e,f){__p&&__p();a=function(){"use strict";function a(a){this.$1=a}var b=a.prototype;b.getInstance=function(){return this.$1};b.setInstance=function(a){this.$1=a};return a}();e.exports=a}),null); __d("SkywalkerUtils",["CurrentLocale","RTISubscriptionManagerConfig"],(function(a,b,c,d,e,f){__p&&__p();a={patchContext:function(a){a=a||{};a.locale=b("CurrentLocale").get();if(b("RTISubscriptionManagerConfig").assimilator){var c=b("RTISubscriptionManagerConfig").assimilator;c.tierType!=null&&(a.tierType=c.tierType);c.sandboxIP!=null&&c.sandboxPort!=null&&c.sandboxHostname!=null&&(a.sandboxIP=c.sandboxIP,a.sandboxPort=c.sandboxPort,a.sandboxHostname=c.sandboxHostname)}return a}};e.exports=a}),null); __d("MqttLongPollingHookCollection",[],(function(a,b,c,d,e,f){"use strict";__p&&__p();a=function(){__p&&__p();function a(){this.$1=new Set()}var b=a.prototype;b.addHook=function(a){this.$1.add(a)};b.removeHook=function(a){this.$1["delete"](a)};b.onPollRequestSent=function(){this.$1.forEach(function(a){a.onPollRequestSent()})};b.onPollRequestSuccess=function(){this.$1.forEach(function(a){a.onPollRequestSuccess()})};b.onPollResponse=function(a){this.$1.forEach(function(b){b.onPollResponse(a)})};b.onPollFinish=function(){this.$1.forEach(function(a){a.onPollFinish()})};b.onPollRequestFailed=function(a){this.$1.forEach(function(b){b.onPollRequestFailed(a)})};return a}();e.exports=a}),null); __d("MqttLogger",["BanzaiODS","ChannelClientID","FantailLogger","FBLogger","Log","LogHistory","MqttEnv","MqttWsClientTypedLoggerLite","MqttUtils","gkx"],(function(a,b,c,d,e,f){"use strict";__p&&__p();var g=b("MqttEnv").Env,h=b("MqttWsClientTypedLoggerLite").log,i="mqtt_client",j="MqttJsClient",k=null,l={CONNECT:"mqtt_client_connect",DISCONNECT:"mqtt_client_disconnect",PUBLISH:"mqtt_client_publish",CLIENT_ERROR:"mqtt_client_error"};a=function(){__p&&__p();a.getInstance=function(){k||(k=new a());return k};function a(){this.$1=b("LogHistory").getInstance(i),this.$2=0,this.$3=b("gkx")("778292"),this.$4=Date.now(),this.$5=b("ChannelClientID").getID()}var c=a.prototype;c.setAppId=function(a){this.$2===0&&(this.$2=a)};c.eventLogConnect=function(a){var c=a.sessionID,d=a.connectionStatus,e=a.duration,f=a.hostname,h=a.attemptNumber;a.failTotal;a.successTotal;var i=a.subscribedTopics,j=a.publishes,k=a.errorCode;a=a.errorMessage;var m=d?"success":"failed";this.bumpCounter(l.CONNECT+"."+m);m={device_id:this.$5,session_id:c,logged_in:g.isUserLoggedInNow(),href:window.location.hostname,connection_status:d,duration:e,hostname:f,feature_availability:b("MqttUtils").getWSAvailability(),attempt_number:h,subscribed_topics:i,publishes:j,error_code:k,error_message:a};this.$6(l.CONNECT,m)};c.eventLogPull=function(a){var b=a.pullEventName,c=a.sessionID,d=a.status,e=a.duration,f=a.hostname;a=a.errorMessage;c={device_id:this.$5,session_id:c,logged_in:g.isUserLoggedInNow(),href:window.location.hostname,connection_status:d,duration:e,hostname:f,error_message:a};this.$6(b,c)};c.eventLogPullFinish=function(a){var b=a.pullEventName,c=a.sessionID,d=a.duration,e=a.errorMessage,f=a.publishReceived;a=a.publishSent;c={device_id:this.$5,session_id:c,logged_in:g.isUserLoggedInNow(),href:window.location.hostname,duration:d,error_message:e,publish_received:f,publish_sent:a};this.$6(b,c)};c.eventLogDisconnect=function(a){var b=a.sessionID,c=a.errorCode,d=a.errorMessage;a=a.duration;this.bumpCounter(l.DISCONNECT);b={device_id:this.$5,session_id:b,href:window.location.hostname,duration:a,error_code:c,error_message:d};this.$6(l.DISCONNECT,b)};c.eventLogPublish=function(a){var b=a.sessionID,c=a.topic,d=a.connectionStatus;a=a.publishStatus;this.bumpCounter(l.PUBLISH+"."+c);b={device_id:this.$5,href:window.location.hostname,session_id:b,topic:c,connection_status:d,publish_status:a};this.$6(l.PUBLISH,b)};c.logError=function(a,c){var d=this;g.scheduleLoggingCallback(function(){try{b("FBLogger")(i).catching(a).mustfix(c),d.$7(b("FantailLogger").error,c)}catch(a){}})};c.eventLogMiscellaneousError=function(a){a=a.errorMessage;a={device_id:this.$5,logged_in:g.isUserLoggedInNow(),href:window.location.hostname,error_message:a,time_passed:Date.now()-this.$4};this.$6(l.CLIENT_ERROR,a)};c.logErrorWarn=function(a,c){var d=this;g.scheduleLoggingCallback(function(){try{b("FBLogger")(i).catching(a).warn(c),d.$7(b("FantailLogger").warn,c)}catch(a){}})};c.logWarn=function(a,c){var d=this;g.scheduleLoggingCallback(function(){try{d.$1.warn(a,c),d.$7(b("FantailLogger").warn,c)}catch(a){}})};c.debugTrace=function(a,c){var d=this;g.scheduleLoggingCallback(function(){try{d.$1.debug(a,c),d.$7(b("FantailLogger").debug,c)}catch(a){}})};c.bumpCounter=function(a){var c=this;g.scheduleLoggingCallback(function(){c.$2!==0&&b("BanzaiODS").bumpEntityKey(2966,"mqtt_ws_client",c.$2+"."+a),b("BanzaiODS").bumpEntityKey(2966,"mqtt_ws_client",a)})};c.$6=function(a,c){var d=this;g.scheduleLoggingCallback(function(){c.event_type=a;c.app_id=d.$2;c.online=d.$8();var e=JSON.stringify(c);d.$1.log(a,e);a!==l.PUBLISH&&a!==l.DISCONNECT&&h(c);d.$7(b("FantailLogger").info,e)})};c.$7=function(a,c){g.scheduleLoggingCallback(function(){b("gkx")("676936")&&a(j,c)})};c.$8=function(){return window.navigator&&window.navigator.onLine!==void 0?window.navigator.onLine:!1};return a}();e.exports=a}),null); __d("MqttEnvInitializer",["CurrentUser","JSScheduler","MqttEnv","MqttLogger","Random","WebStorage","clearTimeout","gkx","setTimeoutAcrossTransitions"],(function(a,b,c,d,e,f){"use strict";__p&&__p();var g=b("MqttEnv").MqttGkNames,h=b("MqttEnv").Env,i="mqtt:",j={genGk:function(a){__p&&__p();switch(a){case g.mqtt_waterfall_log_client_sampling:return b("gkx")("832242");case g.messenger_uses_mqtt_rollout:return b("gkx")("678651");case g.mqtt_ws_polling_enabled:return b("gkx")("865725");case g.mqtt_ws_forced_polling_only:return b("gkx")("865724");case g.mqtt_send_unload_event:return b("gkx")("901339");case g.mqtt_ws_reconnect_reset:return b("gkx")("807517");case g.mqtt_lp_use_fetch:return b("gkx")("945829");case g.mqtt_fast_lp:return b("gkx")("1001007");case g.mqtt_lp_no_delay:return b("gkx")("1066746");case g.mqtt_enable_publish_over_polling:return b("gkx")("968609");default:b("MqttLogger").getInstance().logError(new Error("unknown gk"),"Unknown GK value "+a);return!1}},useJSScheduler:function(a){return b("gkx")("987139")?a:null},initialize:function(){__p&&__p();h.initialize(b("Random").random,b("CurrentUser").isLoggedInNow,b("clearTimeout"),b("setTimeoutAcrossTransitions"),function(){return b("MqttLogger").getInstance()},j.genGk,null,j.useJSScheduler(b("JSScheduler").scheduleNormalPriCallback),j.useJSScheduler(b("JSScheduler").scheduleLoggingPriCallback),function(a,c){var d=b("WebStorage").getLocalStorage();if(d){d=d.getItem(i+a);if(d!=null)return d}return c},function(a,c){var d=b("WebStorage").getLocalStorage();d&&(c==null?d.removeItem(i+a):d.setItem(i+a,c))})}};e.exports=j}),null); __d("FBMqttChannel",["MqttChannel","MqttEnvInitializer","MqttWebConfig"],(function(a,b,c,d,e,f){"use strict";b("MqttEnvInitializer").initialize(),e.exports=new(b("MqttChannel"))({endpoint:b("MqttWebConfig").endpoint,pollingEndpoint:b("MqttWebConfig").pollingEndpoint,userFbid:b("MqttWebConfig").fbid,appId:b("MqttWebConfig").appID,initialSubscribedTopics:b("MqttWebConfig").subscribedTopics,capabilities:b("MqttWebConfig").capabilities,clientCapabilities:b("MqttWebConfig").clientCapabilities,chatVisibility:b("MqttWebConfig").chatVisibility})}),null); __d("PromiseResult",["Promise"],(function(a,b,c,d,e,f){"use strict";__p&&__p();a=function(){__p&&__p();function a(){var a=this;this.promise=new(b("Promise"))(function(b,c){a.$1=b,a.$2=c})}var c=a.prototype;c.resolve=function(a){this.$1(a)};c.reject=function(a){this.$2(a)};return a}();e.exports=a}),null); __d("MqttFetchClient",["Promise","MqttEnv","MqttProtocolCodec","MqttUtils","PromiseResult"],(function(a,b,c,d,e,f){"use strict";__p&&__p();var g=b("MqttEnv").Env,h=b("MqttProtocolCodec").WireMessage,i=b("MqttProtocolCodec").decodeByteMessages,j=b("MqttProtocolCodec").MESSAGE_TYPE,k="fetch_pull",l="fetch_pull_finish",m="fetch_",n=6e4,o="action",p="chunked",q="send",r="true",s=5,t=20,u=4e4,v=10;a=function(){__p&&__p();function a(){this.$1=setInterval(function(){}),this.$2="",this.$3=g.getLoggerInstance(),this.$4=0,this.$5="",this.$7=function(){},this.$8=function(a){},this.$9=function(){},this.$10=function(a){},this.$11=0,this.$12=0,this.$13=0,this.$14=0,this.$15="Ready",this.$16=[],this.$17=!1,this.$18=Date.now(),this.$19=0}a.isSupported=function(){return typeof fetch==="function"};var c=a.prototype;c.run=function(a,c,d,e,f,g,h,i){this.$2=b("MqttUtils").endpointWithSessionId(a,c),this.$4=c,this.$5=d,this.$6=e,this.$7=f,this.$8=g,this.$9=h,this.$10=i,this.$20()};c.isTopicSupported=function(a){return!0};c.publish=function(a,c){__p&&__p();if(this.$15!=="ReceivingData"){this.$3.bumpCounter(m+"publish."+a+".invalidstate");return b("Promise").reject("not connected")}else{this.$3.bumpCounter(m+"publish."+a+".publish");var d=new(b("PromiseResult"))();a={topic:a,payload:c,promiseResult:d};this.$16.push(a);this.$21();return d.promise}};c.abort=function(){this.$7=function(){},this.$8=function(a){},this.$9=function(){},this.$10=function(a){}};c.$22=function(a){var b=this;a.forEach(function(a){b.$3.bumpCounter(m+"publish."+a.topic+".resolved"),a.promiseResult.resolve()});this.$13+=a.length};c.$23=function(a,b){var c=this;a.forEach(function(a){c.$3.bumpCounter(m+"publish."+a.topic+".rejected"),a.promiseResult.reject(b)})};c.$24=function(a,b,c){var d=a.map(function(a){return a.topic}).join(",");this.$3.debugTrace("FetchClient","Fetch publish request failed. Publishes:"+d+", retry:"+b);this.$3.bumpCounter(m+"publish_request_failed");this.$15!="ReceivingData"||b===s?(this.$23(a,c),this.$17=!1,this.$3.bumpCounter(m+"publish_request_failed_final"),this.$21()):this.$25(a,b+1)};c.$26=function(a,b,c){__p&&__p();if(!c.ok){this.$3.bumpCounter(m+"publish_request_failed.http."+c.status);if(c.status===409){this.$19++;if(this.$19>=v){this.$3.bumpCounter(m+"409_reset");this.$27(new Error("Too many 409 errors"));return}}this.$24(a,b,this.$28(c));return}this.$3.bumpCounter(m+"publish_request_success");c=a.map(function(a){return a.topic}).join(",");this.$3.debugTrace("FetchClient","Fetch publish request success. Publishes:"+c+", retry:"+b);this.$22(a);this.$17=!1;this.$21()};c.$21=function(){__p&&__p();if(this.$15!="ReceivingData")return;if(this.$17)return;if(this.$16.length==0)return;this.$17=!0;var a=this.$16.slice(0,t);this.$16=this.$16.slice(t,this.$16.length);this.$25(a,0)};c.$25=function(a,c){__p&&__p();var d=this,e=a.map(function(a){return a.topic}).join(",");this.$3.debugTrace("FetchClient","Fetch publish request sent. Publishes:"+e+", retry:"+c);e=b("MqttUtils").endpointWithExtraParameter(this.$2,o,q);var f=a.map(function(a){return{topic:a.topic,payload:a.payload,qos:0,messageId:g.random()}});f=this.$6.gen(this.$4,[],f);this.$3.bumpCounter(m+"publish_request");b("MqttUtils").promiseDoneWithTimeout(fetch(e,{method:"POST",mode:"cors",cache:"no-cache",credentials:"include",referrer:"no-referrer",body:f,keepalive:!1}),function(b){return d.$26(a,c,b)},function(b){return d.$24(a,c,b)},n)};c.$29=function(a){a=a.message;this.$3.debugTrace("FetchClient","Fetch request failed with error:"+a);this.$10(a);this.$30(!1,a);this.$3.bumpCounter(m+"error");this.$15="Error";clearInterval(this.$1)};c.$31=function(a){__p&&__p();this.$3.debugTrace("FetchClient","Fetch response data received");a=i(new Uint8Array(a));a=a.messages;var b=a.filter(function(a){return a.messageType===j.PINGREQ});a=a.filter(function(a){return a.messageType===j.PUBLISH}).map(function(a){if(a instanceof h.Publish){a=a;return{topic:a.topic,payload:a.payloadMessage.payloadString}}else return{}});for(var c=a,d=Array.isArray(c),e=0,c=d?c:c[typeof Symbol==="function"?Symbol.iterator:"@@iterator"]();;){var f;if(d){if(e>=c.length)break;f=c[e++]}else{e=c.next();if(e.done)break;f=e.value}f=f;this.$3.bumpCounter(m+"response_"+f.topic)}a&&a.length>0&&(this.$14+=a.length,this.$8(a));b&&b.length>0&&this.$32()};c.$32=function(){this.$3.debugTrace("FetchClient","Got server ping request"),this.$3.bumpCounter(m+"ping"),this.$18=Date.now()};c.$27=function(a){this.$3.debugTrace("FetchClient","Fetch request ended"),this.$3.bumpCounter(m+"done"),this.$33(a.message),clearInterval(this.$1),this.$9(),this.$15="Done"};c.$34=function(a,c,d){__p&&__p();var e=this;if(d!==null&&d!==void 0)try{this.$31(d)}catch(a){this.$27(a);this.$3.bumpCounter(m+"dataDecodeException");return}if(c){this.$27(new Error("EOF"));return}b("MqttUtils").promiseDone(a.read(),function(c){var b=c.done;c=c.value;return e.$34(a,b,c)},function(a){return e.$27(a)})};c.$35=function(a){__p&&__p();if(!a.ok){this.$3.bumpCounter(m+"error.http."+a.status);this.$29(this.$28(a));return}a=a.body;if(!a){this.$29(new Error("Empty body"));return}a=a.getReader();var b=this;this.$1=setInterval(function(){var a=Date.now();a=a-b.$18;a>u&&b.$27(new Error("Failed to receive Ping"))},u);this.$7();this.$3.bumpCounter(m+"success");this.$30(!0,null);this.$12=Date.now();this.$15="ReceivingData";this.$3.debugTrace("FetchClient","Fetch request success");this.$34(a,!1,null)};c.$33=function(a){this.$3.eventLogPullFinish({pullEventName:l,sessionID:this.$4,duration:Date.now()-this.$12,errorMessage:a,publishReceived:this.$14,publishSent:this.$13})};c.$30=function(a,b){this.$3.eventLogPull({pullEventName:k,sessionID:this.$4,status:a,duration:Date.now()-this.$11,hostname:this.$2,errorMessage:b})};c.$20=function(){__p&&__p();var a=this;if(this.$15!="Ready")return;this.$3.debugTrace("FetchClient","Sending fetch request");this.$3.bumpCounter(m+"request");this.$11=Date.now();var c=b("MqttUtils").endpointWithExtraParameter(this.$2,p,r);b("MqttUtils").promiseDoneWithTimeout(fetch(c,{method:"POST",mode:"cors",cache:"no-cache",credentials:"include",referrer:"no-referrer",body:this.$5,keepalive:!1}),function(b){return a.$35(b)},function(b){return a.$29(b)},n)};c.$28=function(a){return new Error("Http error, status="+a.status)};return a}();e.exports=a}),null); __d("MqttLongPollingClient",["Promise","MqttEnv","MqttProtocolCodec","XHRRequest","getCrossOriginTransport"],(function(a,b,c,d,e,f){"use strict";__p&&__p();var g=b("MqttEnv").Env,h=b("MqttProtocolCodec").WireMessage,i=b("MqttProtocolCodec").decodeByteMessages,j=120*1e3,k="simple_pull";a=function(){__p&&__p();function a(){this.$3="",this.$4=0,this.$2=g.getLoggerInstance(),this.$1="Ready",this.$5="",this.$7=function(){},this.$8=function(a){},this.$9=function(){},this.$10=function(a){},this.$11=0,this.$12=null,this.$13=new Set(["/t_ms","/messenger_sync_get_diffs","/messenger_sync_create_queue","/webrtc","/rtc_multi"])}var c=a.prototype;c.run=function(a,b,c,d,e,f,g,h){this.$3=a,this.$4=b,this.$5=c,this.$6=d,this.$7=e,this.$8=f,this.$9=g,this.$10=h,this.$14(this.$5)};c.isTopicSupported=function(a){return this.$13.has(a)};c.publish=function(a,c){return b("Promise").reject("not supported")};c.abort=function(){this.$12!=null&&this.$12.abort("Disconnected")};c.$15=function(a,b){if(this.$1===a)return;this.$1=a;a=="Error"&&b!=null&&this.$10(b)};c.$16=function(a){__p&&__p();if(this.$1!="RequestSend")return;if(!a){this.$17("EmptyResponse",null);return}this.$7();this.$18(!0,null);this.$15("ResponseReceived");a=i(new Uint8Array(a));a=a.messages.filter(function(a){return a instanceof h.Publish}).map(function(a){if(a instanceof h.Publish){a=a;return{topic:a.topic,payload:a.payloadMessage.payloadString}}else return{}});this.$8(a);this.$9()};c.$17=function(a,b){b=b!=null?b.message:"null";this.$2.debugTrace("LongPollingClient Error","Poll failed with error:"+a+", errorMsg:"+b);this.$18(!1,a+":"+b);this.$15("Error",a)};c.$18=function(a,b){this.$2.eventLogPull({pullEventName:k,sessionID:this.$4,status:a,duration:Date.now()-this.$11,hostname:this.$3,errorMessage:b})};c.$14=function(a){__p&&__p();var c=this;if(this.$1!="Ready"||this.$12)return;try{this.$11=Date.now(),this.$12=new(b("XHRRequest"))(this.$3).setResponseType("arraybuffer").setRawData(a).setTransportBuilder(b("getCrossOriginTransport").withCredentials).setResponseHandler(function(a){return c.$16(a)}).setNetworkFailureHandler(function(a){c.$17("Network",a)}).setErrorHandler(function(a){c.$17("Error",a)}).setAbortHandler(function(a){c.$17("Abort",null)}).setTimeoutHandler(function(){c.$17("Timeout",null)}).setTimeout(j).send(),this.$15("RequestSend")}catch(a){this.$17("Error",a)}};return a}();e.exports=a}),null); __d("exponentialBackoff",["MqttEnv"],(function(a,b,c,d,e,f){__p&&__p();var g=b("MqttEnv").Env;function a(a,b){__p&&__p();b===void 0&&(b=null);var c=null,d=0;function e(){__p&&__p();for(var e=arguments.length,f=new Array(e),h=0;h=j&&this.$24("LPError")};c.$28=function(){__p&&__p();var a=g.genGk(h.mqtt_lp_no_delay),b=g.genGk(h.mqtt_ws_polling_enabled),c=g.genGk(h.mqtt_fast_lp);this.$5.debugTrace("LongPollingRunner","_shouldPoll? pollNow:"+String(a)+" enabled:"+String(b)+" fastPoll:"+String(c)+" hasWSSupport:"+String(this.$4)+" hasSuccess:"+String(this.$1)+" failureCount:"+this.$2+" wsFatal:"+String(this.$3));if(!b)return!1;if(a){this.$5.bumpCounter(m+".nd");return!0}if(!this.$4){this.$5.bumpCounter(m+".na");return!0}if(this.$3){this.$5.bumpCounter(m+".fatal");return!0}if(this.$1)return!1;if(c){b=Date.now()-this.$20;if(this.$21===o){if(this.$2>=1)return!0;if(b>k){this.$5.bumpCounter(m+".fastdelay");return!0}}else if(b>l){this.$5.bumpCounter(m+".regulardelay");return!0}}if(this.$2>=3){this.$5.bumpCounter(m+".failure");return!0}return!1};c.$29=function(){if(this.$14!=null)return!1;var a=this.$28();!this.$13&&a&&(this.$5.bumpCounter("polling_kickin"),this.$13=!0,this.$24("LPActive"),this.$26());this.$13&&!a&&(this.$5.bumpCounter("polling_stopped"),this.$13=!1,this.$24("LPInactive"),this.$26());return a};c.$30=function(){if(this.$22){this.$5.debugTrace("LongPollingRunner","Creating polling client using Fetch API");return new(b("MqttFetchClient"))()}else{this.$5.debugTrace("LongPollingRunner","Creating regular Polling client");return new(b("MqttLongPollingClient"))()}};c.$31=function(){this.$5.debugTrace("LongPollingRunner","Poll success"),this.$19.onPollRequestSuccess(),this.$18.reset(),this.$24("LPActive"),this.$26(),g.configWrite(n,o),this.$25("ReceivingData")};c.$32=function(a){__p&&__p();var b=a.map(function(a){return a.topic}).join(",");this.$5.debugTrace("LongPollingRunner","Poll response received, message received:"+b);for(var b=a,a=Array.isArray(b),c=0,b=a?b:b[typeof Symbol==="function"?Symbol.iterator:"@@iterator"]();;){var d;if(a){if(c>=b.length)break;d=b[c++]}else{c=b.next();if(c.done)break;d=c.value}d=d;this.$19.onPollResponse(d.topic);this.$8(d.topic,d.payload)}};c.$33=function(){this.$5.debugTrace("LongPollingRunner","Poll finish"),this.$19.onPollFinish(),this.$14&&this.$14.abort(),this.$14=null,this.$23(),this.$25("NotSent")};c.$34=function(a){this.$19.onPollRequestFailed(a),this.$14&&this.$14.abort(),this.$14=null,this.$18(),this.$27(),this.$25("NotSent")};return a}();e.exports=a}),null); __d("SyncProtocolConstants",[],(function(a,b,c,d,e,f){a={IRIS_CURSOR_LIMIT:"IRIS_CURSOR_LIMIT",SNAPSHOT_FAILURE:"SNAPSHOT_FAILURE"};e.exports=a}),null);