Module 568598

function(e,t,n){"use strict";n.d(t,{Ay:()=>R,KU:()=>N,Qt:()=>v,r4:()=>C}),n(321073);var r=n(735438),i=n(713402),s=n(717558),a=n(933958),o=n(259464),l=n(652896),u=n(616356),c=n(961350),d=n(470710),_=n(734057),f=n(430452),p=n(485296),h=n(287809),m=n(803301),E=n(977997),g=n(562153),A=n(90575),I=n(806931),T=n(652215),S=n(731854);let y="__EMBEDDED_ACTIVITIES__";function v(e){let{applicationId:t,instanceId:n}=e;return null!=n?`activity-${t}-${n}`:`activity-${t}`}function N(e){switch(e.type){case I.lp.ACTIVITY:return`\x01${e.sortKey}`;case I.lp.HIDDEN_STREAM:case I.lp.STREAM:return`${e.userVideo?"\x02":"\x03"}${(0,A.A)(e.userNick,e.user)}\x03`;case I.lp.USER:let t="\x05";return e.voiceState?.selfVideo?t="\x03":e.voiceState?.selfStream&&(t="\x04"),`${t}${(0,A.A)(e.userNick,e.user)}`}}var C=function(e){return e.VIDEO="VIDEO",e.STREAM="STREAM",e.FILTERED="FILTERED",e.SPEAKING="SPEAKING",e.ACTIVITY="ACTIVITY",e.NOT_POPPED_OUT="NOT_POPPED_OUT",e}({});class R{channelId;call;participants={};lastSpoke={};guildRingingUsers=new Set;poppedOutParticipants=new Set;participantByIndex=new i.J(e=>{let t=[];return e.type===I.lp.USER&&e.speaking&&t.push("SPEAKING"),e.type===I.lp.USER&&e.voiceState?.selfVideo?(t.push("VIDEO"),e.localVideoDisabled||e.isPoppedOut||t.push("FILTERED")):(0,I.Ay)(e)&&(t.push("STREAM"),e.type===I.lp.HIDDEN_STREAM||null==e.streamId||e.isPoppedOut||t.push("FILTERED")),e.type===I.lp.ACTIVITY&&t.push("ACTIVITY"),"isPoppedOut"in e&&e.isPoppedOut||t.push("NOT_POPPED_OUT"),t},N);constructor(e){this.channelId=e}get version(){return this.participantByIndex.version}size(e){return this.participantByIndex.size(e)}toArray(e){return this.participantByIndex.values(e,!0)}rebuild(){let e=_.A.getChannel(this.channelId);if(null==e||e.type===T.rbe.GUILD_TEXT||(this.call=d.A.getCall(this.channelId),e.isPrivate()&&(null==this.call||this.call.unavailable)))return!1;let t=new Set(e.isGuildVocalOrThread()?Object.keys(E.A.getVoiceStatesForChannel(e.id)):e.recipients);return t.add(c.default.getId()),this.guildRingingUsers.size>0&&(t=new Set([...t,...this.guildRingingUsers])),u.A.getAllActiveStreamsForChannel(this.channelId).forEach(e=>{let{ownerId:n}=e;return t.add(n)}),this.participantByIndex.clear(),this.participants={},t.forEach(e=>this.updateParticipant(e)),this.updateEmbeddedActivities(),!0}getParticipant(e){return this.participantByIndex.get(e)??null}updateEmbeddedActivities(){return this.updateParticipant(y)}hasEmbeddedActivity(){return this.size("ACTIVITY")>0}updateParticipant(e){let t=this.participants[e],n=e===y?this._getParticipantsForEmbeddedActivities():this._getParticipantsForUser(e);return(null!=t||0!==n.length)&&(t?.forEach(e=>{this.participantByIndex.delete(e.id)}),n.forEach(e=>{this.participantByIndex.set(e.id,e)}),this.participants[e]=n,!0)}updateParticipantSpeaking(e){return this.participants[e]?.reduce((t,n)=>{if(n.type===I.lp.USER){let r=(0,s.R)({userId:e,checkIsMuted:!0}),i=p.A.isSoundSharing(e),a=this.participantByIndex.get(n.id);return a?.type===I.lp.USER&&a.speaking===r&&a.soundsharing===i?t:(r&&(this.lastSpoke[e]=Date.now()),this.participantByIndex.set(n.id,{...n,speaking:r,lastSpoke:this.lastSpoke[e],soundsharing:i}),!0)}return t},!1)??!1}updateParticipantQuality(e,t,n){return this.participants[e]?.reduce((e,r)=>r.type===I.lp.STREAM?(this.participantByIndex.set(r.id,{...r,maxResolution:t,maxFrameRate:n}),!0):e,!1)??!1}updateGuildRingingUsers(e,t){t?this.guildRingingUsers.add(e):this.guildRingingUsers.delete(e)}updateParticipantPoppedOut(e,t){t?this.poppedOutParticipants.add(e):this.poppedOutParticipants.delete(e)}_getEmbeddedActivities(){let e=a.Ay.getEmbeddedActivitiesForChannel(this.channelId),t=a.Ay.getSelfEmbeddedActivityForChannel(this.channelId);return null==t?e:(0,r.uniqBy)([...e,t],e=>e.compositeInstanceId)}_getParticipantsForEmbeddedActivities(){return this._getEmbeddedActivities().map((e,t)=>({type:I.lp.ACTIVITY,id:v({applicationId:e.applicationId,instanceId:e.compositeInstanceId}),applicationId:e.applicationId,activityType:T.$pd.PLAYING,activityUrl:e.url,participants:[...e.participants??[]],guildId:_.A.getChannel(this.channelId)?.getGuildId()??null,sortKey:t.toString()}))}_getParticipantsForUser(e){let t,n,r=[],i=h.default.getUser(e);if(null==i)return r;let a=E.A.getVoiceStateForChannel(this.channelId,e),d=E.A.getVoicePlatformForChannel(this.channelId,e),A=_.A.getChannel(this.channelId),T=A?.getGuildId(),y=(this.call?.ringing?.includes(e)||this.guildRingingUsers.has(e))??!1;(null!=a||y)&&(t={type:I.lp.USER,...m.A.getUserStreamData(e,T),user:i,id:i.id,voiceState:a,voicePlatform:d,speaking:(0,s.R)({userId:e,checkIsMuted:!0}),lastSpoke:this.lastSpoke[e]??0,soundsharing:p.A.isSoundSharing(e),ringing:y,userNick:g.Ay.getName(T,this.channelId,i),userAvatarDecoration:(0,o.U)(i,T),localVideoDisabled:f.Ay.isLocalVideoDisabled(i.id),isPoppedOut:this.poppedOutParticipants.has(i.id)},r.push(t));let v=u.A.getStreamForUser(e,T)??u.A.getActiveStreamForUser(e,T);if(null!=v&&v.channelId===this.channelId){let t=(0,l._z)(v),s=this.getParticipant(t),o=v.ownerId===c.default.getId()&&u.A.isSelfStreamHidden(this.channelId),d=s?.type===I.lp.STREAM?{maxResolution:null!=s.maxResolution?{...s.maxResolution}:void 0,maxFrameRate:s.maxFrameRate}:null;n={...m.A.getUserStreamData(e,T,S.x.STREAM),...d,type:o?I.lp.HIDDEN_STREAM:I.lp.STREAM,id:t,userVideo:a?.selfVideo??!1,user:i,userNick:g.Ay.getName(T,this.channelId,i),stream:v,isPoppedOut:this.poppedOutParticipants.has(t)},r.push(n)}return r}}}