Module 734057

function(e,t,n){"use strict";n.d(t,{A:()=>el,D:()=>B}),n(205816);var i=n(735438),r=n.n(i),s=n(61090),a=n(17928),o=n(228366),l=n(723176),u=n(154049),c=n(531743),d=n(453001),_=n(736400),h=n(311016),f=n(626584),p=n(181079),E=n(95701),m=n(403362),g=n(935208),A=n(495544),I=n(71393),T=n(287809),S=n(652215);let y=new f.A("ChannelStore"),C={},N={},v={},R={},O=null,b={},D={},L={},w=0,M={},P={},x=new Set,k={},U=0,G={},F=0,V=0;class B{static loadAllMissingChannels(){let e=I.A.getGuildIds().filter(e=>!x.has(e));return this.loadGuildIds(e)}static loadGuildFromChannelId(e){return null==e?null:B.loadGuildIds([W(e)?.guild_id])}static loadGuildIds(e){let t=e.filter(m.Vq);if(0===t.length)return null;let n=l.A.database();if(null==n||!t.some(e=>!x.has(e)))return null;let i=U;return(0,u.ES)("loadChannels",async()=>{let e=t.map(e=>{if(x.has(e))return null;if(null!=k[e])return y.fileOnly(`Skipping loading ${e} because a load is pending`),null;let t=c.A.getAsync(n,e).then(t=>(y.fileOnly(`Lazy loaded channels for ${e} #:${t.length}`),{guildId:e,channels:t}));return k[e]=t,{guildId:e,promise:t}}).filter(m.Vq),r=e.map(e=>e.promise);try{let t=await Promise.all(r);if(U!==i)return y.fileOnly("lastResetTime has changed, skipping loads for "+e.map(e=>e.guildId)),null;let n=t.filter(e=>!x.has(e.guildId));await o.h.dispatch({type:"LOAD_CHANNELS",channels:n})}catch(t){for(let n of(y.error("Failed to load channels from disk for "+e.map(e=>e.guildId),t),e))delete k[n.guildId];throw t}return null})}}function j(e,t,n){if(null==e||"null"===e||x.has(e)||0===t&&d.A.hasGuild(e))return;let i=l.A.database();if(null==i)return;y.verbose(`hydrating guild (guild: ${e}, trace: ${n})`);let r=(0,u.Ek)(`ensureGuildLoaded(${e})`,()=>c.A.getSync(i,e),"ensureGuildLoaded");if(null==r){x.add(e),d.A.restored(e),y.log(`load returned null; early returning (guild: ${e}, database: ${i})`);return}let[a,o]=r;for(let n of((0,_.Ay)(a),0!==t&&(V+=1),x.add(e),d.A.restored(e),s.A.mark("\u2757",`loaded guild channels (guild: ${e})`,o),a))Object.hasOwn(N,n.id)||Z((0,E.oh)(n));y.verbose(`hydration complete (guild: ${e}, channels: ${a.length}, guilds_loaded: ${V})`)}function H(e,t,n){if(!Object.hasOwn(N,e)&&!Object.hasOwn(R,e)&&!Object.hasOwn(b,e)&&!Object.hasOwn(P,e)&&1===t){let i=d.A.getBasicChannel(e);i?.guild_id!=null&&j(i.guild_id,t,n)}}function Y(e){if(y.fileOnly(`Deleting guild channels for ${e}`),null!=v[e]){for(let t of g.default.keys(v[e]))delete N[t];delete v[e]}null!=D[e]&&delete D[e]}function W(e){return H(e,0,"getBasicChannel"),N[e]??R[e]??b[e]??P[e]??d.A.getBasicChannel(e)}function K(e){return H(e,1,"getChannel"),N[e]??R[e]??b[e]??P[e]??G[e]}function $(e){e.isPrivate()?(delete G[e.id],z(e)):e.isThread()?q(e):E.uL.has(e.type)&&Z(e)}function z(e){if(null!=e.recipients.find(e=>(0,h.A)(e)))return!1;R[e.id]=e,e.type===S.rbe.DM&&(L[e.getRecipientId()]=e.id),w+=1}function q(e){let t=N[e.parent_id];b[e.id]=e.merge({nsfw:t?.nsfw===!0,parentChannelThreadType:t?.type}),e.isScheduledForDeletion()&&o.h.dispatch({type:"THREAD_DELETE",channel:e})}function Z(e){let{id:t,guild_id:n}=e;N[t]=e,v[n]=v[n]??{},v[n][t]=e,M[n]=(M[n]??0)+1,null!=e.linkedLobby?(D[n]=D[n]??{},D[n][t]=e):delete D[n]?.[t]}function X(e){let{id:t,channels:n,threads:i}=e;switch(n.op){case"full_sync":for(let e of(y.fileOnly(`ConnectionOpen contained full channels for ${t} #:${n.items.length}`),Y(t),x.add(t),d.A.restored(t),n.items))Z(e);break;case"update":for(let e of((n.writes.length>0||n.deletes.length>0)&&d.A.invalidate(t),n.deletes))ee(N[e]);for(let e of n.writes)Z(e)}if(null!=i)for(let e of i)q(e)}function Q(e){if(!E.A_.has(e.channel.type))return!1;let t=K(e.channel.id);$(t=null==t?e.channel:t.merge({...e.channel.toJS(),bitrate:e.channel.bitrate??t.bitrate}))}function J(e){let{threads:t}=e;t.forEach(e=>{E.A_.has(e.type)&&$((0,E.UE)(e))})}function ee(e){if(null==e)return;let t=e.guild_id;e.id in R&&delete R[e.id],e.id in N&&delete N[e.id],e.id in b&&delete b[e.id],null!=t&&(null!=v[t]&&e.id in v[t]&&delete v[t][e.id],null!=D[t]&&e.id in D[t]&&delete D[t][e.id]),null==e.guild_id||E.Le.has(e.type)?(0,E.Gw)(e.type)&&(w+=1):M[e.guild_id]=(M[e.guild_id]??0)+1}function et(e){let{channel:t}=e,n=N[t.id]??R[t.id]??b[t.id];if(null==n)return!1;ee(n),function(e){if("basicPermissions"in e||e.type!==S.rbe.DM)return;let t=e.getRecipientId();L[t]===e.id&&delete L[t]}(n)}function en(e){let{messages:t}=e;for(let e of t)null!=e.thread&&!(e.thread.id in b)&&E.A_.has(e.thread.type)&&q((0,E.UE)(e.thread))}function ei(e){let{data:t}=e;t.forEach(e=>{let{messages:t,threads:n,channels:i}=e;t.forEach(e=>{e.forEach(e=>{er(e.thread)})}),n.forEach(er),i.forEach(e=>{let t=(0,E.UE)(e),n=null!=K(e.id),i=null!=G[e.id];t.isPrivate()&&(!n||i)?G[t.id]=t:n||$(t)})})}function er(e){null!=e&&!(e.id in b)&&E.A_.has(e.type)&&q((0,E.UE)(e))}function es(){for(let e in P={},p.A.getFavoriteChannels()){let t=p.A.getCategoryRecord(e);null!=t&&(P[e]=t)}}class ea extends a.Ay.Store{static displayName="ChannelStore";initialize(){this.waitFor(A.default,d.A,p.A,I.A,T.default),this.syncWith([p.A],es)}hasChannel(e){return null!=W(e)}getBasicChannel(e){if(null!=e)return W(e)}getChannel(e){if(null!=e)return K(e)}loadAllGuildAndPrivateChannelsFromDisk(){for(let e of I.A.getGuildIds())j(e,1,"loadAllGuildAndPrivateChannelsFromDisk");return{...N,...R}}getChannelIds(e){return(j(e,0,"getChannelIds"),null==e)?g.default.keys(R):g.default.keys(d.A.getGuildBasicChannels(e)??v[e]??C)}getMutablePrivateChannels(){return R}getMutableBasicGuildChannelsForGuild(e){return j(e,0,"getMutableBasicGuildChannelsForGuild"),d.A.getGuildBasicChannels(e)??v[e]??C}getMutableGuildChannelsForGuild(e){return j(e,1,"getMutableGuildChannelsForGuild"),v[e]??C}getSortedLinkedChannelsForGuild(e){return r().values(D[e]??C).sort((e,t)=>g.default.compare(e.id,t.id))}getSortedPrivateChannels(){return r()(R).values().sort((e,t)=>g.default.compare(e.lastMessageId,t.lastMessageId)).reverse().value()}getDMFromUserId(e){if(null!=e)return L[e]}getDMChannelFromUserId(e){if(null!=e)return this.getChannel(L[e])}getMutableDMsByUserIds(){return L}getDMUserIds(){return g.default.keys(L)}getPrivateChannelsVersion(){return w}getGuildChannelsVersion(e){return M[e]??0}getAllThreadsForParent(e){return r().values(b).filter(t=>t.parent_id===e)}getAllThreadsForGuild(e){return r().values(b).filter(t=>t.guild_id===e)}getInitialOverlayState(){return{...N,...R,...b}}getDebugInfo(){return{loadedGuildIds:Array.from(x).sort(g.default.compare),pendingGuildLoads:Object.keys(k).sort(g.default.compare),guildSizes:Object.keys(v).sort(g.default.compare).map(e=>`${e}: ${eo(e)}`)}}}function eo(e){return null==v[e]?null:Object.keys(v[e]).length}let el=new ea(o.h,{BACKGROUND_SYNC:function(e){let{guilds:t}=e,n=v;N={},v={},M={},D={},t.forEach(e=>{if("unavailable"===e.data_mode)y.fileOnly(`Restoring guild channels b/c unavailable in bg sync, for ${e.id} #:${eo(e.id)}`),r().forEach(n[e.id],Z);else if("partial"===e.data_mode){y.fileOnly(`Restoring guild channels b/c partial in bg sync, for ${e.id} #:${eo(e.id)}`),r().forEach(n[e.id],Z);let t=e.partial_updates.deleted_channel_ids??[];t.length>0&&(j(e.id,1,"handleBackgroundSync"),t.forEach(e=>ee(N[e]))),e.partial_updates.channels?.forEach(t=>Z((0,E.UE)(t,e.id)))}else y.fileOnly(`BG sync contained full channels for ${e.id} #:${e.channels.length}`),Y(e.id),x.add(e.id),d.A.restored(e.id),e.channels.forEach(t=>Z((0,E.UE)(t,e.id)))})},CACHE_LOADED_LAZY:function(e){for(let[t,n]of(F=Math.max(F,e.guilds.length),e.guildChannels))for(let e of(y.fileOnly(`Lazy cache contained full guild channels for ${t} #:${n.length}`),x.add(t),n))$((0,E.oh)(e))},CACHE_LOADED:function(e){F=Math.max(F,e.guilds.length);let{privateChannels:t,initialGuildChannels:n}=e;for(let e of[t,n])for(let t of e)$((0,_.n2)((0,E.oh)(t)));let i=n[0]?.guild_id;null!=i&&(y.fileOnly(`Early cache contained full guild channels for ${i}`),x.add(i))},CHANNEL_CREATE:function(e){$(e.channel)},CHANNEL_DELETE:et,CHANNEL_RECIPIENT_ADD:function(e){let t=K(e.channelId),n=A.default.getId();return!!t?.isPrivate()&&($(t.addRecipient(e.user.id,e.nick,n)),!0)},CHANNEL_RECIPIENT_REMOVE:function(e){let t=K(e.channelId);return!!t?.isPrivate()&&($(t.removeRecipient(e.user.id)),!0)},CHANNEL_UPDATES:function(e){let t=e.channels.some(e=>{let t=K(e.id);return e.nsfw!==t?.nsfw||e.type!==t?.type});for(let t of e.channels)$(t);t&&Object.values(b).forEach(e=>$(e))},CONNECTION_OPEN_SUPPLEMENTAL:function(e){let{lazyPrivateChannels:t}=e;null!=O&&(R={},O.forEach(z)),t.forEach(z)},CONNECTION_OPEN:function(e){let t=v;for(let n of(L={},N={},v={},D={},b={},M={},G={},k={},U=Date.now(),O=e.initialPrivateChannels,e.initialPrivateChannels.forEach(z),e.guilds))"partial"===n.dataMode&&(r().forEach(t[n.id],Z),y.fileOnly(`Restoring guild channels for ${n.id} #:${eo(n.id)}`)),X(n);es()},CHANNEL_PERMISSIONS_PUT_OVERWRITE_SUCCESS:function(e){let{channelId:t,overwrite:n}=e,i=K(t);if(null==i)return!1;$(i.set("permissionOverwrites",{...i.permissionOverwrites,[n.id]:n}))},CHANNEL_PERMISSIONS_DELETE_OVERWRITE_SUCCESS:function(e){let{channelId:t,overwriteId:n}=e,i=K(t);if(null==i)return!1;let r={...i.permissionOverwrites};delete r[n],$(i.set("permissionOverwrites",r))},GUILD_CREATE:function(e){X(e.guild)},GUILD_DELETE:function(e){y.fileOnly(`GuildDelete of ${e.guild.id}`),Y(e.guild.id),x.delete(e.guild.id),d.A.invalidate(e.guild.id)},LOAD_ARCHIVED_THREADS_SUCCESS:J,LOAD_CHANNELS:function(e){for(let{guildId:t,channels:n}of e.channels)for(let e of(y.fileOnly(`Lazy loaded guild channels for ${t}`),(0,_.Ay)(n),x.add(t),d.A.restored(t),n))Object.hasOwn(N,e.id)||Z((0,E.oh)(e));return!1},LOAD_MESSAGES_AROUND_SUCCESS:en,LOAD_MESSAGES_SUCCESS:en,LOAD_THREADS_SUCCESS:J,LOGOUT:function(){y.fileOnly("initializeClear()"),L={},N={},v={},M={},D={},R={},G={},b={},x=new Set,k={},U=Date.now()},OVERLAY_INITIALIZE:function(e){for(let t of e.channels)$((0,_.n2)((0,E.oh)(t)))},SEARCH_MESSAGES_SUCCESS:ei,MOD_VIEW_SEARCH_MESSAGES_SUCCESS:ei,THREAD_CREATE:Q,THREAD_DELETE:et,THREAD_LIST_SYNC:function(e){let{threads:t}=e;t.forEach(e=>{E.A_.has(e.type)&&$(e)})},THREAD_UPDATE:Q})}