Build 533169stable
Module 383501
6,799 characters · in no known chunkDependencies
Required by (128)
1193134331714332294331353316434135379624158044718465335029950400581496458582038820578394287203880659555099072108713110618136523142120143991158160162605198229204459206018237496237774241847244920249477251519256667259374264140271195295102305928308494311849315206316541320165327866334086335022338821341383350701358832362442366251366598376151383952384059399925430452446347447010458664480890485296489683494566512835513752519057520165530804542675582095584569585250596854599466601900614170615658616356636153639823648230650338651649665691677698680724684339690953703552707890709747732755742984748319755588767065786840806964810412811917814278815706827343828904845211854492857341861638878163889806915872916768927421935101941673944775965162970812972937986880
Lazily required by (0)none
Lazily requires (1)
Source Raw
function(e,t,n){"use strict";let r,i;n.d(t,{A:()=>$});var s=n(311907),a=n(73153),o=n(507821),l=n(859159),u=n(643501),c=n(75076),d=n(961350),_=n(607567),f=n(652215),p=n(731854);let h=[],m=null,E=null,g=null,A=null,I=!1,T=!1,S=null,y=!1,v=null;function N(e,t){if(null==i)throw Error("Creating RTCConnection without session.");let r=d.default.getId(),s=new(n(767065)).A({userId:r,sessionId:i,guildId:e,channelId:t,joinVoiceId:v});return s.on(o.q.State,(e,t,n)=>{a.h.wait(()=>a.h.dispatch({type:"RTC_CONNECTION_STATE",state:e,...t,...n}))}),s.on(o.q.Video,(e,t,n,r,i)=>{a.h.wait(()=>a.h.dispatch({type:"RTC_CONNECTION_VIDEO",guildId:e,channelId:t,userId:n,streamId:r,rtcServerId:i,context:p.x.DEFAULT,mediaEngineConnectionId:s.getMediaEngineConnectionId()}))}),s.on(o.q.Ping,(e,t)=>{a.h.wait(()=>a.h.dispatch({type:"RTC_CONNECTION_PING",pings:e,quality:t}))}),s.on(o.q.OutboundLossRate,e=>{a.h.wait(()=>a.h.dispatch({type:"RTC_CONNECTION_LOSS_RATE",lossRate:e}))}),s.on(o.q.Speaking,(e,t)=>{A?.setSpeaking(e,t)}),s.on(o.q.Flags,(e,t)=>{a.h.wait(()=>{a.h.dispatch({type:"RTC_CONNECTION_FLAGS",flags:t,userId:e,guildId:s.guildId,channelId:s.channelId,context:s.context})})}),s.on(o.q.UsersMerged,(e,t)=>{a.h.dispatch({type:"RTC_CONNECTION_USERS_MERGED",userIds:e,context:t})}),s.on(o.q.ClientConnect,e=>{a.h.wait(()=>{a.h.dispatch({type:"RTC_CONNECTION_CLIENT_CONNECT",userIds:e,guildId:s.guildId,channelId:s.channelId,context:s.context})})}),s.on(o.q.ClientDisconnect,e=>{a.h.wait(()=>{a.h.dispatch({type:"RTC_CONNECTION_CLIENT_DISCONNECT",userId:e,guildId:s.guildId,channelId:s.channelId,context:s.context})})}),s.on(o.q.Platform,(e,t,n)=>{a.h.wait(()=>{a.h.dispatch({type:"RTC_CONNECTION_PLATFORM",platform:t,userId:e,channelId:n})})}),s.on(o.q.SecureFramesUpdate,()=>{a.h.wait(()=>{a.h.dispatch({type:"RTC_CONNECTION_SECURE_FRAMES_UPDATE"})})}),s.on(o.q.RosterMapUpdate,e=>{a.h.wait(()=>{a.h.dispatch({type:"RTC_CONNECTION_ROSTER_MAP_UPDATE",userIds:e})})}),A=new l.A(d.default.getId(),t),E=null,I=!1,T=!1,s}function C(){if(null==r)return!1;E={duration:r.getDuration(),mediaSessionId:r.getMediaSessionId()??null,rtcConnectionId:r.getRTCConnectionId(),wasEverMultiParticipant:I,wasEverRtcConnected:T,voiceStateAnalytics:A,channelId:r.channelId},a.h.dispatch({type:"MEDIA_ENGINE_CONNECTION_STATS_HISTORY_RESET",mediaEngineConnectionId:r.getMediaEngineConnectionId()}),r.destroy(),r=null,A=null,y=!1}function R(e){return i=e.sessionId,m=null,g=null,C(),!1}function O(){i=null,m=null,g=null,C()}function b(e){let{voiceStates:t}=e;return t.reduce((e,t)=>{if(A?.updateVoiceStates(t.userId,t.channelId),I=I||(A?.getStats().max_voice_state_count??0)>1,d.default.getId()!==t.userId)return e;if(null!=r)t.sessionId===i?null!=t.guildId&&t.guildId===r.guildId||null==t.guildId&&t.channelId===r.channelId?null==t.channelId?C():(r.setNextChannelId(t.channelId),y=!0,v=null,r.clearJoinVoiceId()):(t.guildId!==r.guildId&&null==t.channelId||C(),null!=t.channelId&&(m=null,g=null,r=N(t.guildId,t.channelId),I=(A?.getStats().max_voice_state_count??0)>1)):t.guildId===r.guildId&&((null==u.default.getAwaitingRemoteSessionInfo()||null==u.default.getRemoteSessionId())&&(m=r.channelId),C());else{if(t.sessionId!==i||null==t.channelId)return e;m=null,g=null,r=N(t.guildId,t.channelId),I=(A?.getStats().max_voice_state_count??0)>1}return!0},!1)}function D(e){if(null==r||null!=e.guildId&&e.guildId!==r.guildId||null!=e.channelId&&e.channelId!==r.getNextChannelId())return!1;r.connect(e.endpoint,e.token)}function L(){m=null}function w(){g=null}function M(e){let{guild:t}=e;if(null==r||r.guildId!==t.id)return!1;C()}function P(e){let{channelId:t}=e;if(null==r||r.channelId!==t)return!1;C()}function x(e){let{channel:t}=e;if(null==r||r.channelId!==t.id)return!1;C()}function k(e){let{channelId:t,joinVoiceId:n}=e;null!=r&&(null==t||r.channelId!==t)&&C(),v=n}function U(e){return e.state===f.g6G.ACTIVE&&null!=r&&r.resetBackoff("App state is active"),!1}function G(e){return e.state===f.S7L.RTC_CONNECTED&&(T=!0),!0}function F(e){r?.setNoiseCancellationEnabled(e.enabled)}function V(){return!0}function B(e){let{context:t,wants:n}=e;if(t!==p.x.DEFAULT||!Object.entries(n).some(e=>{let[t,n]=e;return"any"!==t&&0!==n}))return!1;S=performance.now()}function H(e){return e.connection===r}function j(e){let{userId:t,context:n,quality:i}=e;r?.setSimulcastDebugOverride(t,n,i)}function Y(e){let{streamId:t,dimensions:n,zoom:i}=e;r?.setVideoSize(t,n,i)}class W extends s.Ay.Store{static displayName="RTCConnectionStore";initialize(){this.waitFor(d.default,u.default,_.Ay),(0,c.I)(this.getRTCConnectionId,this.getMediaSessionId)}getRTCConnection(){return r}getState(){return null!=r?r.state:f.S7L.DISCONNECTED}isConnected(){return this.getState()===f.S7L.RTC_CONNECTED}isDisconnected(){return this.getState()===f.S7L.DISCONNECTED}getRemoteDisconnectVoiceChannelId(){return m}getLastSessionVoiceChannelId(){return g}setLastSessionVoiceChannelId(e){g=e}getGuildId(){return r?.guildId}getChannelId(){return r?.channelId}getHostname(){return null!=r?r.hostname:""}getQuality(){return null!=r?r.quality:f.bFR.UNKNOWN}getPings(){return null!=r?r.getPings():h}getAveragePing(){return null!=r?r?.getAveragePing():0}getLastPing(){return r?.getLastPing()}getOutboundLossRate(){return r?.getOutboundLossRate()}getMediaSessionId(){return r?.getMediaSessionId()}getRTCConnectionId(){return r?.getRTCConnectionId()}getDuration(){return r?.getDuration()??E?.duration}getLastRTCConnectionState(){return E}getPacketStats(){return r?.getPacketStats()}getVoiceStateStats(){return A?.getStats()}getUserVoiceSettingsStats(e){return A?.getUserVoiceSettingsStats(e)}getWasEverMultiParticipant(){return I}getWasEverRtcConnected(){return T}getUserIds(){return r?.getUserIds()}getJoinVoiceId(){return v}isUserConnected(e){return r?.getIsUserConnected(e)}getSecureFramesState(){return r?.getSecureFramesState()}getSecureFramesRosterMapEntry(e){let t=r?.getSecureFramesRosterMap();return t?.get(e)}getLastNonZeroRemoteVideoSinkWantsTime(){return S}getWasMoved(){return y}}let K=new W(a.h,__OVERLAY__?{}:{CONNECTION_OPEN:R,CONNECTION_CLOSED:O,RTC_CONNECTION_STATE:G,RTC_CONNECTION_PING:V,RTC_CONNECTION_LOSS_RATE:V,RTC_CONNECTION_UPDATE_ID:H,RTC_CONNECTION_SECURE_FRAMES_UPDATE:V,RTC_CONNECTION_CLIENT_CONNECT:V,RTC_CONNECTION_CLIENT_DISCONNECT:V,RTC_CONNECTION_REMOTE_VIDEO_SINK_WANTS:B,VIDEO_SIZE_UPDATE:Y,VOICE_STATE_UPDATES:b,VOICE_CHANNEL_SELECT:k,AUDIO_SET_NOISE_CANCELLATION:F,VOICE_SERVER_UPDATE:D,CLEAR_REMOTE_DISCONNECT_VOICE_CHANNEL_ID:L,REMOTE_SESSION_CONNECT:L,CLEAR_LAST_SESSION_VOICE_CHANNEL_ID:w,GUILD_DELETE:M,CHANNEL_DELETE:x,THREAD_DELETE:x,CALL_DELETE:P,APP_STATE_UPDATE:U,RTC_DEBUG_SET_SIMULCAST_OVERRIDE:j});Promise.resolve().then(n.bind(n,954571)).then(e=>{let{addExtraAnalyticsDecorator:t}=e;t(e=>{e.client_rtc_state=K.getState()})});let $=K}