;/*FB_PKG_DELIM*/

__d("ZenonMWThriftSendMessageMutation_facebookRelayOperation",[],(function(a,b,c,d,e,f){e.exports="6963032207064158"}),null);
__d("ZenonMWThriftSendMessageMutation.graphql",["ZenonMWThriftSendMessageMutation_facebookRelayOperation"],(function(a,b,c,d,e,f){"use strict";a=function(){var a=[{defaultValue:null,kind:"LocalArgument",name:"input"}],c=[{alias:null,args:[{kind:"Variable",name:"data",variableName:"input"}],concreteType:"RtcWebSendMultiwayThriftSignalingMessageResponsePayload",kind:"LinkedField",name:"rtc_web_send_multiway_thrift_signaling_message",plural:!1,selections:[{alias:null,args:null,kind:"ScalarField",name:"response",storageKey:null}],storageKey:null}];return{fragment:{argumentDefinitions:a,kind:"Fragment",metadata:null,name:"ZenonMWThriftSendMessageMutation",selections:c,type:"Mutation",abstractKey:null},kind:"Request",operation:{argumentDefinitions:a,kind:"Operation",name:"ZenonMWThriftSendMessageMutation",selections:c},params:{id:b("ZenonMWThriftSendMessageMutation_facebookRelayOperation"),metadata:{},name:"ZenonMWThriftSendMessageMutation",operationKind:"mutation",text:null}}}();e.exports=a}),null);
__d("ZenonMWThriftMessageLogger",["MultiwayCommonTypes","ZenonLoggingEventTypes"],(function(a,b,c,d,e,f,g){"use strict";var h=new Set(),i=new Set();function a(a,b){var c=a.messageHeader;a=a.messageBody;if(h.has(c.transactionId)||c.type==null)return;switch(c.type){case d("MultiwayCommonTypes").MessageType.JOIN:a.joinRequest&&j(a.joinRequest,b);break;case d("MultiwayCommonTypes").MessageType.ICE_CANDIDATE:a.iceCandidateRequest&&l(a.iceCandidateRequest,b,d("ZenonLoggingEventTypes").ZenonUpdateIceInfoDirection.Send);break;case d("MultiwayCommonTypes").MessageType.CLIENT_MEDIA_UPDATE:a.clientMediaUpdateRequest&&m(a.clientMediaUpdateRequest,b);break;case d("MultiwayCommonTypes").MessageType.SERVER_MEDIA_UPDATE:a.serverMediaUpdateResponse&&p(a.serverMediaUpdateResponse,b);break;default:break}h.add(c.transactionId)}function b(a,b){var c=a.messageHeader;a=a.messageBody;if(i.has(c.transactionId)||c.type==null)return;switch(c.type){case d("MultiwayCommonTypes").MessageType.JOIN:a.joinResponse&&k(a.joinResponse,b);break;case d("MultiwayCommonTypes").MessageType.ICE_CANDIDATE:a.iceCandidateRequest&&l(a.iceCandidateRequest,b,d("ZenonLoggingEventTypes").ZenonUpdateIceInfoDirection.Receive);break;case d("MultiwayCommonTypes").MessageType.CLIENT_MEDIA_UPDATE:a.clientMediaUpdateResponse&&n(a.clientMediaUpdateResponse,b);break;case d("MultiwayCommonTypes").MessageType.SERVER_MEDIA_UPDATE:a.serverMediaUpdateRequest&&o(a.serverMediaUpdateRequest,b);break;default:break}i.add(c.transactionId)}function j(a,b){var c=a.answer;a=a.offer;b({name:"inviteSent"});q(a,b,d("ZenonLoggingEventTypes").ZenonUpdateIceInfoDirection.Send);c&&q(c,b,d("ZenonLoggingEventTypes").ZenonUpdateIceInfoDirection.Send)}function k(a,b){a=a.answer;a&&q(a,b,d("ZenonLoggingEventTypes").ZenonUpdateIceInfoDirection.Receive)}function l(a,b,c){a=a.iceCandidateSdps;a.forEach(function(a){a.candidateSdpString!=null&&b({direction:c,name:"updateIceInfo",sdpString:a.candidateSdpString})})}function m(a,b){a=a.offer;a&&q(a,b,d("ZenonLoggingEventTypes").ZenonUpdateIceInfoDirection.Send)}function n(a,b){a=a.answer;a&&q(a,b,d("ZenonLoggingEventTypes").ZenonUpdateIceInfoDirection.Receive)}function o(a,b){var c=a.answer;a=a.offer;a&&q(a,b,d("ZenonLoggingEventTypes").ZenonUpdateIceInfoDirection.Receive);c&&q(c,b,d("ZenonLoggingEventTypes").ZenonUpdateIceInfoDirection.Receive)}function p(a,b){a=a.answer;a&&q(a,b,d("ZenonLoggingEventTypes").ZenonUpdateIceInfoDirection.Send)}function q(a,b,c){a.sdpString!=null&&b({direction:c,name:"updateIceInfo",sdpString:a.sdpString})}g.logSentMessage=a;g.logReceivedMessage=b}),98);
__d("ZenonValidateMWThriftMessage",["FBLogger","MultiwayCommonTypes","ZenonInfraActionsLogger","ZenonMWThriftMessageMap"],(function(a,b,c,d,e,f,g){"use strict";function a(a){var b=a.messageHeader.type,e=d("ZenonMWThriftMessageMap").messageTypeToString(b);if(a.messageHeader.serverInfoData==null&&b!=null&&b!==d("MultiwayCommonTypes").MessageType.JOIN){c("ZenonInfraActionsLogger").logCheckpoint({checkpoint:"[ZP][DROP] No remoteSignalingID in message: "+e});c("FBLogger")("rtc_www").warn("[ZP][DROP] No remoteSignalingID in message: "+e);return!1}return!0}g["default"]=a}),98);
__d("ZenonMWThriftSendMessageMutation",["CometRelayErrorHandling","Promise","ZenonDataUtils","ZenonMWThriftMessageSerializer","ZenonMWThriftSendMessageMutation.graphql","asyncToGeneratorRuntime","cr:1012418","gkx"],(function(a,b,c,d,e,f,g){"use strict";var h,i;function j(a,e,f){return new(i||(i=b("Promise")))(function(g,i){b("cr:1012418").commitMutation(f,{mutation:h!==void 0?h:h=b("ZenonMWThriftSendMessageMutation.graphql"),onCompleted:function(a){return g(a)},onError:function(a){c("gkx")("708253")&&d("CometRelayErrorHandling").markErrorAsHandled(a);return i(a)},variables:{input:{endpoint:JSON.stringify(a),message:d("ZenonDataUtils").uint8ArrayToBase64(d("ZenonMWThriftMessageSerializer").serializeMWThriftMessage(e,!0))}}})})}function k(a){a=a.rtc_web_send_multiway_thrift_signaling_message;if(a!=null&&a.response!=null){a=d("ZenonDataUtils").base64ToUint8Array(a.response);a=d("ZenonMWThriftMessageSerializer").deserializeMWThriftMessage(a,!0);var b=a.messageBody;a=a.messageHeader;return{body:b,header:a}}return{body:null,header:null}}function a(a,b,c){return l.apply(this,arguments)}function l(){l=b("asyncToGeneratorRuntime").asyncToGenerator(function*(a,b,c){a=(yield j(a,b,c));return k(a)});return l.apply(this,arguments)}g.sendMessage=a}),98);
__d("ZenonGraphQLMWThriftMessageSender",["ChannelClientID","MultiwayCommonTypes","Promise","RpZenonBinaryThriftSignalingSitevarConfig","ZenonActorHooks","ZenonInfraActionsLogger","ZenonMWThriftMessageDebugLogger","ZenonMWThriftMessageLogger","ZenonMWThriftMessageMap","ZenonMWThriftMessageReliabilityLogger","ZenonMWThriftMessageTranslator","ZenonMWThriftSendMessageMutation","ZenonMWTranslatorUtils","ZenonValidateMWThriftMessage","asyncToGeneratorRuntime","err","filterNulls","unrecoverableViolation"],(function(a,b,c,d,e,f,g){"use strict";var h;a=function(){function a(a){this.$3=a;a=c("RpZenonBinaryThriftSignalingSitevarConfig").supported_message_types_mqtt.map(function(a){return d("ZenonMWThriftMessageMap").messageTypeFromString(a)});this.$4=new Set(c("filterNulls")(a))}var e=a.prototype;e.handleResponse=function(a){var b=this.$1;if(b==null)throw c("unrecoverableViolation")("Should never have null message receiver","rtc_www");var e=a.header||null;a=a.body||null;if(e!=null&&a!=null){a={messageBody:a,messageHeader:e};c("ZenonMWThriftMessageDebugLogger").logMWThriftMessage("RECEIVED","GraphQL Thrift",a);d("ZenonMWThriftMessageReliabilityLogger").logReceivedMessage(a);this.$2&&this.$2({mwThriftMessage:a,name:"mwThriftMessageRecv"});e=d("ZenonMWThriftMessageTranslator").toSignalingMessage(a);if(e==null)return;b(e);d("ZenonMWThriftMessageReliabilityLogger").logProcessingMessage(a)}};e.$5=function(){var a=b("asyncToGeneratorRuntime").asyncToGenerator(function*(a,b){d("ZenonMWThriftMessageReliabilityLogger").logSendingMessage(b);c("ZenonMWThriftMessageDebugLogger").logMWThriftMessage("SENDING","GraphQL Thrift",b);this.$2&&d("ZenonMWThriftMessageLogger").logSentMessage(b,this.$2);try{a=(yield d("ZenonMWThriftSendMessageMutation").sendMessage(a,b,this.$3));d("ZenonMWThriftMessageReliabilityLogger").logSentMessage(b);this.$2&&this.$2({mwThriftMessage:b,name:"mwThriftMessageSent"});this.handleResponse(a)}catch(e){a=e!=null?e.toString():"Message Send Error";d("ZenonMWThriftMessageReliabilityLogger").logSendMessageFailed(b,"[GraphQL Thrift] "+a);b=d("ZenonMWThriftMessageMap").messageTypeToString(b.messageHeader.type);c("ZenonMWThriftMessageDebugLogger").logSendMultiwayThriftMessageFailure(a,b);e!=null&&c("ZenonInfraActionsLogger").logCheckpoint({checkpoint:"Failed to send MW Thrift message of type "+b+". Stack Trace: "+e.stack+"."})}});function e(b,c){return a.apply(this,arguments)}return e}();e.sendMessage=function(a){var e=d("ZenonMWThriftMessageTranslator").toMWThriftMessage(a);if(!e||!c("ZenonValidateMWThriftMessage")(e))return(h||(h=b("Promise"))).reject(c("err")("Invalid MW Thrift message"));if(e.messageHeader.type!=null&&!this.$4.has(e.messageHeader.type))return(h||(h=b("Promise"))).resolve();var f=e.messageHeader.type;a={appId:d("ZenonMWTranslatorUtils").getMWAppID(),deviceId:c("ChannelClientID").getID(),userId:a.getHeader().userInfo.userID};return a.userId!==d("ZenonActorHooks").ZenonActor.getAccountID()||f!==d("MultiwayCommonTypes").MessageType.DATA_MESSAGE?this.$5(a,e):(h||(h=b("Promise"))).reject(c("err")("GraphQL only sends DATA_MESSAGE for Page users"))};e.setMessageReceiver=function(a){this.$1=a};e.setLoggingEventHandler=function(a){this.$2=a};return a}();g["default"]=a}),98);
__d("ZenonMqttMWThriftMessageSender",["Promise","RpZenonBinaryThriftSignalingSitevarConfig","ZenonActorHooks","ZenonMWThriftMessageDebugLogger","ZenonMWThriftMessageLogger","ZenonMWThriftMessageMap","ZenonMWThriftMessageReliabilityLogger","ZenonMWThriftMessageSerializer","ZenonMWThriftMessageTranslator","ZenonSignalingConstants","ZenonUserActionLogger","ZenonValidateMWThriftMessage","asyncToGeneratorRuntime","err","filterNulls","getZenonMqttChannel","waitForZenonMqttConnected"],(function(a,b,c,d,e,f,g){"use strict";var h;a=function(){function a(){var a=c("RpZenonBinaryThriftSignalingSitevarConfig").supported_message_types_mqtt.map(function(a){return d("ZenonMWThriftMessageMap").messageTypeFromString(a)});this.$3=new Set(c("filterNulls")(a))}var e=a.prototype;e.$4=function(){var a=b("asyncToGeneratorRuntime").asyncToGenerator(function*(a){var b=this,e=!0;yield c("waitForZenonMqttConnected")()["catch"](function(a){c("ZenonUserActionLogger").logCheckpoint({checkpoint:"Not sending MWS Thrift message through MQTT because MQTT could not connect. Error: "+a}),e=!1});if(!e)return;d("ZenonMWThriftMessageReliabilityLogger").logSendingMessage(a);c("ZenonMWThriftMessageDebugLogger").logMWThriftMessage("SENDING","MQTT Thrift",a);this.$2&&d("ZenonMWThriftMessageLogger").logSentMessage(a,this.$2);var f=c("getZenonMqttChannel")();try{yield f.publishBinary(d("ZenonSignalingConstants").T_RTC_MULTI_MQTT_TOPIC,d("ZenonMWThriftMessageSerializer").serializeMWThriftMessage(a)).then(function(){d("ZenonMWThriftMessageReliabilityLogger").logSentMessage(a),b.$2&&b.$2({mwThriftMessage:a,name:"mwThriftMessageSent"})},function(c){b.$5(a,c.toString())})}catch(b){this.$5(a,b.toString())}});function e(b){return a.apply(this,arguments)}return e}();e.$5=function(a,b){b=b!=null?b:"MQTT Thrift Message Send Error";d("ZenonMWThriftMessageReliabilityLogger").logSendMessageFailed(a,"[MQTT Thrift] "+b);c("ZenonMWThriftMessageDebugLogger").logSendMultiwayThriftMessageFailure(b,d("ZenonMWThriftMessageMap").messageTypeToString(a.messageHeader.type))};e.sendMessage=function(a){var e=d("ZenonMWThriftMessageTranslator").toMWThriftMessage(a);if(!e||!c("ZenonValidateMWThriftMessage")(e))return(h||(h=b("Promise"))).reject(c("err")("Invalid MW Thrift message"));if(e.messageHeader.type!=null&&!this.$3.has(e.messageHeader.type))return(h||(h=b("Promise"))).resolve();return a.getHeader().userInfo.userID!==d("ZenonActorHooks").ZenonActor.getAccountID()&&!d("ZenonActorHooks").ZenonActor.isInstagramUser()&&!d("ZenonActorHooks").ZenonActor.isOculusUser()?(h||(h=b("Promise"))).reject(c("err")("MQTT doesn't work with Page users yet")):this.$4(e)};e.setMessageReceiver=function(a){this.$1=a};e.setLoggingEventHandler=function(a){this.$2=a};return a}();g["default"]=a}),98);