Module 343969

function(e,t,n){"use strict";n.d(t,{Ay:()=>Y,Ms:()=>B,Wl:()=>H});var r=n(812729),i=n.n(r),s=n(735438),a=n(353640),o=n(121894),l=n(499979),u=n(439372),c=n(626584),d=n(403362),_=n(661191),f=n(233693),p=n(859126),h=n(70738),m=n(902822),E=n(266047);let g=-1,A=new c.A("MemberSafetySearchManager");function I(e){return`guild_${e}`}function T(e){return{requestState:e,abortController:null,lastUpdated:Date.now(),query:null,cursor:null,previousPagination:null,sort:null,elasticSearchCursor:null}}let S=(0,a.v)(e=>({}));function y(e,t){let n=S.getState()[e];return null==n&&(n=T(1)),n={...n,...t},(0,o.r)(()=>{S.setState(t=>({...t,[e]:n}))}),n}function v(e){return S.getState()[e]}function N(e){let t=v(e);return null==t&&y(e,t=T(1)),t}function C(e){(0,o.r)(()=>{S.setState(t=>{let n={...t};return delete n[e],n})})}function R(e,t,n,r,i){let s=v(e);return s?.requestState===2&&s.abortController?.abort(),y(e,{requestState:2,abortController:new AbortController,lastUpdated:Date.now(),query:t,cursor:n,previousPagination:r,sort:i})}function O(e){null!=v(e)&&y(e,{requestState:0,abortController:null,lastUpdated:Date.now()})}async function b(e){await (0,l.yy)(200),null!=v(e)&&y(e,{requestState:3,abortController:null,lastUpdated:Date.now()})}function D(e){y(e,{requestState:4,abortController:null,lastUpdated:Date.now()})}function L(e){C(I(e))}function w(e){return null!=e&&e.length>1}function M(e){let t={},n={},{query:r}=e;if(w(r)){let[e,n]=(0,p.H)(r);e.length>0&&(t.usernames={or_query:e}),n.length>0&&(t.user_id={or_query:n})}let{requireUnusualDmActivity:i,requireCommunicationDisabled:s,requireUnusualAccountActivity:a,requireUsernameQuarantined:o}=e,l={};i&&(l.unusual_dm_activity_until={range:{gte:Date.now()-h.tX}}),s&&(l.communication_disabled_until={range:{gte:Date.now()}}),a&&(l.unusual_account_activity=a),o&&(l.automod_quarantined_username=o),Object.keys(l).length>0&&(n.safety_signals=l);let{selectedRoleIds:u}=e;u.size>0&&(t.role_ids={and_query:Array.from(u)});let{selectedJoinDateOption:c}=e;null!=c.afterDate&&(t.guild_joined_at={range:{gte:c.afterDate,lte:c.beforeDate??void 0}});let{selectedAccountAgeOption:d}=e;if(null!=d.afterDate){let e=t.user_id;t.user_id={...e,range:{gte:_.default.fromTimestamp(d.afterDate),lte:null!=d.beforeDate?_.default.fromTimestamp(d.beforeDate):void 0}}}let{selectedSourceInviteCode:f}=e;null!=f&&(t.source_invite_code={or_query:[f]});let{selectedJoinSourceType:m}=e;null!=m&&(t.join_source_type={or_query:[m]});let E={or_query:n,and_query:t},{selectedSort:g}=e;return null!=g&&(E.sort=g),E}function P(e,t){return null==t?e:{...e,...t}}function x(e,t){return Math.floor(Math.max(e-1,0)/t)}function k(e){let t=(0,f.n4)(e),n=e.pageSize*(e.currentPage-1),r=e.pageSize*e.currentPage,i=e.pageSize*(e.currentPage+1);return{previousPageChunkNumber:x(n,t),currentPageChunkNumber:x(r,t),nextPageChunkNumber:x(i,t)}}function U(e,t){let{currentPageChunkNumber:n,previousPageChunkNumber:r,nextPageChunkNumber:i}=k(t),{previousPagination:s}=N(I(e)),a=t.currentPage,o=s?.currentPage??0,l=E.A.getElasticSearchPaginationByGuildId(e);switch(!0){case null==l:case n===i&&0===n:return 0;case n===i&&n===r:return 1;case o<a&&n<i:return 2;case o>a&&n>=r:if(0<n)return 3;return 0;default:return 1}}function G(e,t,n){let r=U(e,n),i=E.A.getElasticSearchPaginationByGuildId(e),s=(0,f.n4)(n);switch(r){case 0:return[null,{limit:s}];case 1:return[t.cursor??null,{limit:s,after:t.cursor??void 0}];case 2:return[i?.after??null,{limit:s,after:i?.after??void 0}];case 3:return[i?.before??null,{limit:s,before:i?.before??void 0}];default:(0,d.xb)(r)}}function F(e,t){let n=N(e);return i()(n.query,t)}async function V(e){let t=E.A.getSearchStateByGuildId(e),n=E.A.getPaginationStateByGuildId(e),r=I(e),i=N(r),[a,o]=G(e,i,n),l=P(M(t),o),u=t.selectedSort??h.mF.ORDER_BY_GUILD_JOINED_AT_DESC;if(F(r,l)&&(0,s.isEqual)(a,i.cursor))return;let c=R(r,l,a,n,u);try{if(A.info("Making member search request",{query:c.query,guildId:e}),null==c.query)throw Error("Query is null");await (0,m.N)(e,c.query,{signal:c.abortController?.signal??void 0})}catch(e){if(g===e.code)return;O(r);return}await b(r)}function B(e){return S(t=>{let n=I(e);return t[n]?.requestState===2})}function H(e){return S(t=>{let n=I(e);return t[n]?.requestState===4})}class j extends u.A{actions={INITIALIZE_MEMBER_SAFETY_STORE:e=>this.handleInitialize(e),GUILD_DELETE:e=>this.handleGuildDelete(e),MEMBER_SAFETY_SEARCH_STATE_UPDATE:e=>this.handleSearchStateUpdate(e),MEMBER_SAFETY_PAGINATION_UPDATE:e=>this.handlePaginationUpdate(e),MEMBER_SAFETY_GUILD_MEMBER_SEARCH_SUCCESS:e=>this.handleGuildMemberSearchSuccess(e),MEMBER_SAFETY_GUILD_MEMBER_SEARCH_STILL_INDEXING:e=>this.handleGuildMemberSearchStillIndexing(e),MEMBER_SAFETY_NEW_MEMBER_TIMESTAMP_REFRESH:e=>this.handleNewMemberTimestampRefresh(e)};handleInitialize(e){let{guildId:t}=e;return L(t),V(t)}handleGuildDelete(e){let{guild:t}=e;return L(t.id)}handleSearchStateUpdate(e){let{guildId:t}=e;return V(t)}handlePaginationUpdate(e){let{guildId:t}=e;return V(t)}handleGuildMemberSearchSuccess(e){let{guildId:t}=e;return b(I(t))}handleGuildMemberSearchStillIndexing(e){let{guildId:t}=e;return D(I(t))}handleNewMemberTimestampRefresh(e){let{guildId:t}=e;return V(t)}}let Y=new j}