if (self.CavalryLogger) { CavalryLogger.start_js(["bSVii"]); } __d("RTISubscriptionData",["ChannelConstants","areEqual"],(function(a,b,c,d,e,f){"use strict";__p&&__p();var g=b("ChannelConstants").SUBSCRIPTION_STATE;a=function(){__p&&__p();function a(a,b,c,d,e,f,h){this.$1=a,this.$2=b,this.$7=!0,this.$8=!1,this.$9=g.SUBSCRIBE,this.$10=null,this.$11=Date.now(),this.$3=d,this.$4=e?e:null,this.$5=f?f:null,this.$6=h?h:null,this.$12=c}var c=a.prototype;c.matchesContext=function(a){return b("areEqual")(this.$3,a)};c.getCreatedTime=function(){return this.$11};c.getTopic=function(){return this.$1};c.getViewId=function(){return this.$12};c.getSubscribeCallback=function(){return this.$4};c.setSubscribeCallback=function(a){this.$4=a};c.getUnsubscribeCallback=function(){return this.$6};c.setUnsubscribeCallback=function(a){this.$6=a};c.getUnsubscribeHook=function(){return this.$5};c.setUnsubscribeHook=function(a){this.$5=a};c.getMessageListener=function(){return this.$2};c.setMessageListener=function(a){this.$2=a};c.getArbiterToken=function(){return this.$10};c.setArbiterToken=function(a){this.$10=a};c.isAlive=function(){return this.$9!=g.UNSUBSCRIBE};c.isMutatingContext=function(){return this.$9==g.MUTATE_CONTEXT};c.isDirty=function(){return this.$7};c.setDirty=function(a){this.$7=a};c.getState=function(){return this.$9};c.setState=function(a){this.$9=a};c.getContext=function(){return this.$3};c.isSent=function(){return this.$8};c.setSent=function(a){this.$8=a};c.prepareMutateContext=function(a){this.setState(g.MUTATE_CONTEXT),this.setDirty(!0),this.setSent(!1),this.$3=a};c.prepareUnsubscribe=function(){this.setState(g.UNSUBSCRIBE),this.setDirty(!0),this.setSent(!1),this.$2=null};return a}();e.exports=a}),null); __d("RTISubscriptionStore",["Arbiter","BanzaiODS","ChannelConstants","ErrorUtils","RTISubscriptionData","SkywalkerUtils"],(function(a,b,c,d,e,f){"use strict";__p&&__p();var g=b("ChannelConstants").SUBSCRIPTION_STATE;a=function(){__p&&__p();function a(){this.$1={},this.$2=1}var c=a.prototype;c.subscribe=function(a,c,d,e,f,h){__p&&__p();d=b("SkywalkerUtils").patchContext(d||{});var i=this.$3(a,d);if(i){var j=i.getState()==g.UNSUBSCRIBE&&i.isDirty()&&!i.isSent();i.isAlive()?b("BanzaiODS").bumpEntityKey(2966,"RTISubscriptionStore","duplicate_subscription_alive"):j?b("BanzaiODS").bumpEntityKey(2966,"RTISubscriptionStore","duplicate_subscription_unflushed_unsubscribe"):b("BanzaiODS").bumpEntityKey(2966,"RTISubscriptionStore","duplicate_subscription_unknown");if(i.isAlive()||j){i.setMessageListener(c);i.setSubscribeCallback(e);i.setUnsubscribeHook(f);i.setUnsubscribeCallback(h);if(j){i.setDirty(!1);i.setSent(!0);i.setState(g.SUBSCRIBE);j=b("ChannelConstants").getRTISkywalkerArbiterType(i.getTopic(),i.getViewId());i.setArbiterToken(this.$4(j,i.getTopic(),i))}return i}}j=this.$2;this.$2+=1;i=new(b("RTISubscriptionData"))(a,c,j,d,e,f,h);c=b("ChannelConstants").getRTISkywalkerArbiterType(a,j);i.setArbiterToken(this.$4(c,a,i));a in this.$1||(this.$1[a]=new Set());this.$1[a].add(i);return i};c.unsubscribe=function(a){if(!this.isSubscribed(a))return;a.prepareUnsubscribe();var c=a.getArbiterToken();c&&(b("Arbiter").unsubscribe(c),a.setArbiterToken(null))};c.mutateContext=function(a,b){if(!this.isSubscribed(a))return;a.prepareMutateContext(b)};c.isSubscribed=function(a){return a.getTopic()in this.$1&&this.$1[a.getTopic()].has(a)&&a.isAlive()};c.clearSubscriptions=function(){this.$1={}};c.deleteSubscriptions=function(a){var b=this,c=[];this.forEachSubscription(function(d){a.call(b,d)&&c.push(d)});c.forEach(function(a){if(a.getTopic()in b.$1){var c=b.$1[a.getTopic()];c["delete"](a)}})};c.forEachSubscription=function(a){__p&&__p();for(var b in this.$1){var c=this.$1[b];for(var c=c,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;if(a.call(this,f))return}}};c.$3=function(a,b){__p&&__p();a=this.$1[a];if(!a)return null;for(var a=a,c=Array.isArray(a),d=0,a=c?a:a[typeof Symbol==="function"?Symbol.iterator:"@@iterator"]();;){var e;if(c){if(d>=a.length)break;e=a[d++]}else{d=a.next();if(d.done)break;e=d.value}e=e;if(e.matchesContext(b))return e}return null};c.$4=function(a,c,d){var e=this;return b("Arbiter").subscribe(a,function(a,f){b("BanzaiODS").bumpEntityKey(2966,"RTISubscriptionStore","skywalker_subscription_delivery"),f.obj.forEach(function(a){a={topic:c,payload:a};var f=d.getMessageListener();f&&b("ErrorUtils").applyWithGuard(f,e,[a])})})};return a}();e.exports=a}),null); __d("StreamStateMachine",["StreamStateMachineConstants"],(function(a,b,c,d,e,f){"use strict";__p&&__p();var g=b("StreamStateMachineConstants").events,h=b("StreamStateMachineConstants").states,i=babelHelpers["extends"]({},g,{GQLS_STATE_TRANSIT_ON_REFRESH:"onRefresh"});a=function(){__p&&__p();function a(a,b){a===void 0&&(a=!1),b===void 0&&(b=1e4),this.$1=b,this.$2=null,this.$3=null,this.$5=a,this.$4=null}var b=a.prototype;b.start=function(){this.$6(i.GQLS_STATE_TRANSIT_ON_CREATE),this.$5||this.$6(i.GQLS_STATE_TRANSIT_ON_ACTIVE)};b.ping=function(){switch(this.$4){case h.GQLS_STATE_ACTIVE:this.$6(i.GQLS_STATE_TRANSIT_ON_REFRESH);break;case h.GQLS_STATE_PAUSED:this.$6(i.GQLS_STATE_TRANSIT_ON_RESUME);break;case h.GQLS_STATE_CREATED:this.$6(i.GQLS_STATE_TRANSIT_ON_ACTIVE);break;case h.GQLS_STATE_TERMINATED:break}};b.kill=function(){this.$6(i.GQLS_STATE_TRANSIT_ON_TERMINATE)};b.setLifecycleHandler=function(a){this.$3=a};b.getState=function(){return this.$4};b.$6=function(a){__p&&__p();switch(a){case i.GQLS_STATE_TRANSIT_ON_CREATE:this.$7();break;case i.GQLS_STATE_TRANSIT_ON_ACTIVE:this.$8();break;case i.GQLS_STATE_TRANSIT_ON_REFRESH:this.$9();break;case i.GQLS_STATE_TRANSIT_ON_PAUSE:this.$10();break;case i.GQLS_STATE_TRANSIT_ON_RESUME:this.$11();break;case i.GQLS_STATE_TRANSIT_ON_TERMINATE:this.$12();break}};b.$7=function(){this.$4=h.GQLS_STATE_CREATED,this.$3&&this.$3(g.GQLS_STATE_TRANSIT_ON_CREATE)};b.$8=function(){this.$4=h.GQLS_STATE_ACTIVE,this.$3&&this.$3(g.GQLS_STATE_TRANSIT_ON_ACTIVE),this.$13()};b.$9=function(){clearTimeout(this.$2),this.$13()};b.$10=function(){this.$4=h.GQLS_STATE_PAUSED,this.$3&&this.$3(g.GQLS_STATE_TRANSIT_ON_PAUSE)};b.$11=function(){this.$4=h.GQLS_STATE_ACTIVE,this.$3&&this.$3(g.GQLS_STATE_TRANSIT_ON_RESUME),this.$13()};b.$12=function(){clearTimeout(this.$2),this.$4=h.GQLS_STATE_TERMINATED};b.$13=function(){var a=this;this.$5&&(this.$2=setTimeout(function(){a.$6(g.GQLS_STATE_TRANSIT_ON_PAUSE)},this.$1))};return a}();e.exports=a}),null); __d("RTISubscriptionToken",["StreamStateMachine","gkx"],(function(a,b,c,d,e,f){__p&&__p();a=function(){"use strict";__p&&__p();function a(a,c,d,e,f){__p&&__p();this.$1=a;this.$2=c;this.$4=d;this.$5=e;this.$3=f;this.$6=null;if(b("gkx")("676931")){a=this.getContext();c=this.hasHeartbeatOption(a);this.$7=new(b("StreamStateMachine"))(c);this.$7.start()}}var c=a.prototype;c.setFriendFanoutToken=function(a){this.$6=a};c.getFriendFanoutToken=function(){return this.$6};c.getSubscriptionData=function(){return this.$1};c.isSubscribed=function(){return this.$3(this.$1)};c.getContext=function(){return this.$1.getContext()};c.mutateContext=function(a){this.$4(this.$1,a)};c.unsubscribe=function(){var a=this.$1.getUnsubscribeHook();a&&a();this.$2(this.$1);this.$6&&this.$6.unsubscribe();b("gkx")("676931")&&(this.$7&&this.$7.kill())};c.fastUnsubscribe=function(){this.unsubscribe(),this.$5()};c.hasHeartbeatOption=function(a){if(a&&a.transformContext){a=JSON.parse(a.transformContext);if(a.serializedQueryParameters){a=JSON.parse(a.serializedQueryParameters);if(a&&a["%options"]&&a["%options"].heartbeat)return!0}}return!1};c.ping=function(){b("gkx")("676931")&&(this.$7&&this.$7.ping())};c.handleLifecycles=function(a){b("gkx")("676931")&&(this.$7&&this.$7.setLifecycleHandler(a))};return a}();e.exports=a}),null); __d("SkywalkerWebClientTypedLogger",["Banzai","GeneratedLoggerUtils","nullthrows"],(function(a,b,c,d,e,f){"use strict";__p&&__p();a=function(){__p&&__p();function a(){this.$1={}}var c=a.prototype;c.log=function(){b("GeneratedLoggerUtils").log("logger:SkywalkerWebClientLoggerConfig",this.$1,b("Banzai").BASIC)};c.logVital=function(){b("GeneratedLoggerUtils").log("logger:SkywalkerWebClientLoggerConfig",this.$1,b("Banzai").VITAL)};c.logImmediately=function(){b("GeneratedLoggerUtils").log("logger:SkywalkerWebClientLoggerConfig",this.$1,{signal:!0})};c.clear=function(){this.$1={};return this};c.getData=function(){return babelHelpers["extends"]({},this.$1)};c.updateData=function(a){this.$1=babelHelpers["extends"]({},this.$1,a);return this};c.setClientSessionUuid=function(a){this.$1.client_session_uuid=a;return this};c.setClientTime=function(a){this.$1.client_time=a;return this};c.setEventName=function(a){this.$1.event_name=a;return this};c.setGateway=function(a){this.$1.gateway=a;return this};c.setMessage=function(a){this.$1.message=a;return this};c.setTime=function(a){this.$1.time=a;return this};c.setTopic=function(a){this.$1.topic=a;return this};c.setVC=function(a){this.$1.vc=a;return this};c.setWeight=function(a){this.$1.weight=a;return this};return a}();c={client_session_uuid:!0,client_time:!0,event_name:!0,gateway:!0,message:!0,time:!0,topic:!0,vc:!0,weight:!0};e.exports=a}),null); __d("SkywalkerLogger",["BanzaiODS","FBLogger","LogHistory","SkywalkerWebClientTypedLogger","nullthrows","uuid"],(function(a,b,c,d,e,f){__p&&__p();var g="skywalker_web_client",h=b("LogHistory").getInstance(g);a=function(){"use strict";__p&&__p();function a(a){a===void 0&&(a={}),this.$1=a,this.$1.client_session_uuid==null&&(this.$1.client_session_uuid=b("uuid")())}var c=a.prototype;c.log=function(a){a=this.$2(a);var c=b("nullthrows")(a.event_name);h.log(c,a);this.$3(a)};c.warn=function(a){a=this.$2(a);var c=b("nullthrows")(a.event_name);h.warn(c,a);b("FBLogger")(g).warn(c);this.$3(a)};c.error=function(a){a=this.$2(a);var c=b("nullthrows")(a.event_name);h.error(c,a);b("FBLogger")(g).mustfix(c);this.$3(a)};c.bump=function(a){b("BanzaiODS").bumpEntityKey(2966,g,a)};c.$2=function(a){a=babelHelpers["extends"]({},this.$1,a);a.client_time==null&&(a.client_time=Date.now());return a};c.$3=function(a){var c=new(b("SkywalkerWebClientTypedLogger"))();c.updateData(a);c.log()};return a}();e.exports=a}),null); __d("RTISubscriptionManager",["Arbiter","ChannelConstants","CurrentUser","ErrorUtils","RTIFriendFanoutConfig","RTISubscriptionManagerConfig","RTISubscriptionStore","RTISubscriptionToken","Run","SkywalkerLogger","SystemEvents","gkx","setTimeoutAcrossTransitions"],(function(a,b,c,d,e,f){"use strict";__p&&__p();var g=b("ChannelConstants").SUBSCRIPTION_STATE;a=function(){__p&&__p();function a(){__p&&__p();var a=this;this.PULL_HINT_DELAY_MILLIS=1e4;this.$1=new(b("RTISubscriptionStore"))();this.$2=new(b("SkywalkerLogger"))({gateway:"chatproxy"});this.$3=!1;this.$4=!1;this.$5=!1;this.$6=!1;this.$7=!1;this.$8=!0;this.$9=0;this.$10=document.readyState==="complete";b("Run").onAfterLoad(function(){a.$10=!0,a.flush()});this.$11=null;b("Arbiter").subscribe(b("ChannelConstants").ON_ENTER_STATE,function(c,d){if(!a.$11)return;c=/pull/.test(d.state);!a.$3&&c?(a.$4=!0,a.$5||(a.$5=!0,b("setTimeoutAcrossTransitions")(function(){a.$3=a.$4,a.$5=!1,a.$3&&a.flush()},a.PULL_HINT_DELAY_MILLIS))):!c?(a.$4=!1,a.$3=!1):c&&(a.$3=!0,a.flush())});b("SystemEvents").subscribe(b("SystemEvents").ONLINE,function(b,c){c||(a.$3=!1,a.$4=!1)});b("SystemEvents").subscribe(b("SystemEvents").USER,function(b,c){a.$3=!1,a.$4=!1,a.$1.clearSubscriptions()});b("Arbiter").subscribe(b("ChannelConstants").RTI_SESSION,function(b,c){!a.$11&&c&&a.deleteSubscriptions(function(a){return a.getState()===g.UNSUBSCRIBE}),a.$11=c,a.$11&&(a.$3=!0,a.flush())});b("Arbiter").subscribe(b("ChannelConstants").ON_INVALID_HISTORY,function(){a.$3=!0,a.forEachSubscription(function(a){return a.setDirty(!0)}),a.getCurrentSession()});this.getCurrentSession();b("Arbiter").subscribe(b("ChannelConstants").SKYWALKER,function(c,d){c=d.obj.topic;var e=d.obj.view_id,f={};c!=null?a.$2.log({event_name:"payload_received",topic:c}):a.$2.error({event_name:"payload_parse_error",message:"Missing Skywalker topic field in payload"});d.obj.payloads===void 0?f.obj=[d.obj.payload]:f.obj=d.obj.payloads;d=b("ChannelConstants").getRTISkywalkerArbiterType(c,e);b("Arbiter").inform(d,f)})}var c=a.prototype;c.subscribe=function(a,c,d,e,f,g){__p&&__p();var h=this;e=this.$1.subscribe(a,function(d){if(!b("gkx")("676931")){c(d);return}h.isHeartbeat(d.payload)?h.$2.log({event_name:"heartbeat_received",topic:a}):c(d);i.ping()},d,e,f,g);var i=this.$12(e);f=a.substr(0,a.lastIndexOf("/"));if(b("RTIFriendFanoutConfig").passFriendFanoutSubscribeGK&&b("RTIFriendFanoutConfig").topicPrefixes.indexOf(f)>=0){g=a+"_user_id_"+b("CurrentUser").getID();f=this.$1.subscribe(g,c,d);g=this.$12(f);i.setFriendFanoutToken(g)}e.isDirty()&&this.flush();return i};c.mutateContext=function(a,b){this.$1.isSubscribed(a)&&(this.$1.mutateContext(a,b),this.flush())};c.isHeartbeat=function(a){try{a=JSON.parse(a);if(a.heartbeat)return!0}catch(a){}return!1};c.unsubscribe=function(a){this.$1.unsubscribe(a)};c.unsubscribeAll=function(a){if(!this.isReady()||this.$11==null)return;var b=this.$11;this.$2.bump("unsubscribe_all");var c={reset:"t"};a=a!=null?a:function(a){};b.issueRequest("/sub",c,{},a)};c.activePing=function(){if(!this.isReady()||this.$11==null)return;var a={state:"active"};this.$11.issueRequest("/active_ping",a,{},function(a){})};c.flush=function(){__p&&__p();var a=this;if(!this.isReady()||this.$11==null||this.$6){this.$7=!0;this.$11==null&&this.getCurrentSession();return}var c=this.$11;this.$6=!0;this.$7=!1;var d=this.getMaxConsecutiveFlushFailures();if(this.$9>=d){this.$2.warn({event_name:"reset_state"});this.$9=0;this.$1.clearSubscriptions();this.unsubscribeAll(function(){a.$6=!1});return}var e=[],f={};d=!0;var i=0,j=function(b){__p&&__p();if(i>=a.getMaxFlushBatchSize()){a.$7=!0;return!0}if(b.isDirty()){b.getState()===g.MUTATE_CONTEXT&&(d=!1);var c="subscriptions",h=f[c];h||(h=[],f[c]=h);e.push(b);b.setDirty(!1);b.setSent(!1);c={topic:b.getTopic(),state:b.getState(),context:b.getContext(),viewId:b.getViewId()};i+=1;h.push(c)}else d=!1;return!1};this.forEachSubscription(j);if(d&&f.subscriptions&&f.subscriptions.length>0){j=[];for(var k=0;k