Module 779185

function(e,t,n){"use strict";n.d(t,{AZ:()=>C,Ay:()=>v,Qn:()=>R,cR:()=>L}),n(321073);var i,r=n(284009),a=n.n(r),s=n(636537),l=n(155718),o=n(95561),d=n(626584),c=n(865116),u=n(409481),_=n(322683),E=n(607399),A=n(652215);function h(){if(E.Fr)return null;let{default:e}=n(773371),{default:t}=n(184809),{DEV_PID:i,getPID:r}=n(9302),a=e.isFocusedPidOutOfProcess()||e.isCurrentPidOutOfProcess(),s=t.isPinned(A.uss.TEXT);switch(!0){case __OVERLAY__&&t.isInstanceLocked():return A.Xmn.OVERLAY_LOCKED_ACTIVATED;case __OVERLAY__&&s:return A.Xmn.OVERLAY_UNLOCKED_PINNED;case __OVERLAY__&&!t.isInstanceLocked():return A.Xmn.OVERLAY_UNLOCKED;case a&&e.isFocusedPidInputLocked():return A.Xmn.OVERLAY_LOCKED_ACTIVATED;case a&&!e.isFocusedPidInputLocked():return A.Xmn.OVERLAY_UNLOCKED;default:return null}}var I=n(280450),f=n(544180),p=n(927813),T=n(453771),m=n(513391),g=n(292348),S=n(280889),N=n(381941),C=((i={})[i.SEND=0]="SEND",i[i.EDIT=1]="EDIT",i[i.COMMAND=2]="COMMAND",i[i.SEND_ANNOUNCEMENT=3]="SEND_ANNOUNCEMENT",i);function O(e){return 0===e.type||3===e.type}function R(e){return 1===e.type}function L(e){return O(e)?e.message.nonce:R(e)?e.message.messageId:e.message.data.id}let y=[+p.A.Millis.MINUTE,5*p.A.Millis.MINUTE];class D extends m.A{maxSize;requests=new Map;analyticsTimeouts=new Map;constructor(e=5){super(new d.A("MessageQueue")),this.maxSize=e}isFull(){return this.queue.length>=this.maxSize}drain(e,t){switch(this.logger.log("Draining Message Queue with: ",e.type),e.type){case 0:this.handleSend(e.message,t);break;case 3:this.handleSendAnnouncement(e.message,t);break;case 1:this.handleEdit(e.message,t);break;case 2:this.handleCommand(e.message,t)}}cancelRequest(e){this.logger.log("Cancel message send: ",e),this.requests.get(e)?.abort(),this.requests.delete(e),this.cancelQueueMetricTimers(e),this.remove(t=>(O(t)||2===t.type)&&t.message.nonce===e)}cancelPendingSendRequests(e){let t=[],n=[];for(;this.queue.length>0;){let i=this.queue.shift(),{message:r}=i;0===r.type&&r.message.channelId===e?t.push(r.message):n.push(i)}return this.queue.push(...n),this.logger.log("Cancel pending send requests",t.length),t}clear(){this.requests.forEach(e=>e.abort()),this.requests.clear(),this.analyticsTimeouts.forEach((e,t)=>this.cancelQueueMetricTimers(t)),super.clear()}startQueueMetricTimers(e){let t=y.map(e=>setTimeout(()=>{(0,o.zV)(A.HAw.SEND_MESSAGE_QUEUED,{queued_duration_ms:e})},e));this.analyticsTimeouts.set(e,t)}cancelQueueMetricTimers(e){this.analyticsTimeouts.get(e)?.forEach(clearTimeout),this.analyticsTimeouts.delete(e)}createResponseHandler(e,t){return n=>{if(null!=e&&(this.requests.delete(e),this.cancelQueueMetricTimers(e)),n.hasErr)return t(null,n);if(null!=n.body&&(n.body.code===A.t02.SLOWMODE_RATE_LIMITED||n.body.code===A.t02.CHANNEL_FOLLOWING_EDIT_RATE_LIMITED))t(null,n);else if(429===n.status){let e=parseInt(n.headers["retry-after"]);isNaN(e)?t(null,n):t({retryAfter:e*p.A.Millis.SECOND})}else t(null,n)}}handleSend(e,t){let{channelId:n,analyticsLocation:i,...r}=e,a=h()??i,l=(0,_.O)(),o={mobile_network_type:f.A.getType(),...r,...null!=l&&{signal_strength:l}};if(c.Ay.get("send_fail_100")){this.logger.log("Skipping message send because send_fail_100 is enabled"),t(null,{ok:!1,hasErr:!1,status:500,headers:{},body:"{}",text:"Simulated failure"});return}let d=this.createResponseHandler(e.nonce,t),u=new AbortController;null!=e.nonce&&this.requests.set(e.nonce,u),this.startQueueMetricTimers(e.nonce),s.Bo.post({url:A.Rsh.MESSAGES(n),body:o,context:null!=a?{location:a}:void 0,oldFormErrors:!0,...N.ZG,signal:u.signal,rejectWithError:!0},d)}handleSendAnnouncement(e,t){let{channelId:n,analyticsLocation:i,...r}=e,a=h()??i,l=(0,_.O)(),o={mobile_network_type:f.A.getType(),...r,...null!=l&&{signal_strength:l}};if(c.Ay.get("send_fail_100")){this.logger.log("Skipping message send because send_fail_100 is enabled"),t(null,{ok:!1,hasErr:!1,status:500,headers:{},body:"{}",text:"Simulated failure"});return}let d=this.createResponseHandler(e.nonce,t),u=new AbortController;null!=e.nonce&&this.requests.set(e.nonce,u),this.startQueueMetricTimers(e.nonce),s.Bo.post({url:A.Rsh.MESSAGES_ANNOUNCEMENT(n),body:o,context:null!=a?{location:a}:void 0,oldFormErrors:!0,...N.ZG,signal:u.signal,rejectWithError:!0},d)}handleEdit=(e,t)=>{let{channelId:n,messageId:i,isCrossposted:r,...a}=e,l=new AbortController,o=this.createResponseHandler(i,t),d={url:A.Rsh.MESSAGE(n,i),body:a,retries:1,oldFormErrors:!0,signal:l.signal,rejectWithError:!0,onRequestCreated:()=>{this.requests.set(i,l)}};r&&(d.failImmediatelyWhenRateLimited=!0),s.Bo.patch(d,o)};handleCommand(e,t){let{applicationId:n,guildId:i,channelId:r,data:o,nonce:d,attachments:c,maxSizeCallback:_,analytics_location:E,sectionName:h,source:f}=e,p={type:l.G4.APPLICATION_COMMAND,application_id:n,guild_id:i,channel_id:r,session_id:I.default.getSessionId(),data:o,nonce:d,analytics_location:E,section_name:h,source:f};null!=c&&(p.data.attachments=c.map((e,t)=>(a()(e.status===S.jP.COMPLETED,"Uploads must be staged before trying to send a message"),(0,g.OW)(e,t))));let m=new AbortController;this.requests.set(d,m),s.Bo.post({url:A.Rsh.INTERACTIONS,body:p,signal:m.signal,rejectWithError:!0,onRequestCreated:e=>{e.on("progress",e=>{let{total:t}=e,n=(0,u.C)((0,T.o2)(i));null!=t&&t>n&&(this.cancelRequest(d),_?.(n))})}},this.createResponseHandler(d,t))}}let v=new D}