Module 517381

function(e,t,n){"use strict";n.d(t,{A:()=>T}),n(321073);var i=n(17928),r=n(228366),a=n(913122),s=n(320095),l=n(815807),o=n(280450),d=n(994500);class c{isIndexing=!1;isHistoricalIndexing=!1;isFetching=!1;analyticsId=null;error=null;messages=null;documentsIndexed=0;totalResults=null;messageIds=new Set;isInitialFetchComplete=!1;cursor=null;handleSearchStart(){this.isFetching=!0,this.isIndexing=!1,this.analyticsId=null,this.error=null}handleSearchIndexing(){this.isInitialFetchComplete=!0,this.isIndexing=!0,this.isHistoricalIndexing=!0,this.isFetching=!1,this.error=null}handleSearchFailure(e){this.isFetching=!1,this.isIndexing=!1,this.isInitialFetchComplete=!0,this.isHistoricalIndexing=!1,this.error=new a.LG(e),this.analyticsId=null,this.documentsIndexed=0}handleSearchSuccess(e,t){let{analyticsId:n,cursor:i,totalResults:r,doingHistoricalIndex:a,documentsIndexed:s}=e;this.analyticsId=n,this.isFetching=!1,this.isIndexing=!1,this.isInitialFetchComplete=!0,this.isHistoricalIndexing=a,this.error=null,this.documentsIndexed=s,this.cursor=i;let l=[...this.messages??[]],o=[];return t.forEach(e=>{this.messageIds.has(e.id)||(this.messageIds.add(e.id),l.push(e),o.push(e))}),this.messages=l,this.totalResults=r,o}}let u=new Map,_=new Map,E=new Map;function A(e){return u.get(e)??new c}function h(e){let t=A(e);return u.set(e,t),t}function I(e,t){let n=_.get(e);if(null==n)return!1;let i=t(n);return _.set(e,i),!0}function f(e){let{type:t,messageId:n,userId:i,emoji:r}=e;if(!(0,l.vp)(e))return!1;let a=o.default.getId()===i;return I(n,n=>{let{reactionType:i}=e;return"MESSAGE_REACTION_ADD"===t?n.addReaction(r,a,e.colors,i):n.removeReaction(r,a,i)})}class p extends i.Ay.Store{static displayName="SearchMessageStore";initialize(){this.waitFor(o.default,d.A)}getMessage(e){return _.get(e)}getTotalCount(e){return A(e).totalResults}getIsInitialFetchComplete(e){return A(e).isInitialFetchComplete}getIsIndexing(e){return A(e).isIndexing}getIsHistoricalIndexing(e){return A(e).isHistoricalIndexing}getDocumentsIndexed(e){return A(e).documentsIndexed}getIsFetching(e){return A(e).isFetching}getError(e){return A(e).error}getMessages(e){return A(e).messages}getCursor(e){return A(e).cursor}getAnalyticsId(e){return A(e).analyticsId}hasSearchState(e){return u.has(e)}}let T=new p(r.h,{SEARCH_MESSAGES_START:function(e){e.ids.forEach(e=>{h(e).handleSearchStart()})},SEARCH_MESSAGES_SUCCESS:function(e){e.data.forEach(e=>{let t=h(e.id),n=e.messages.map(e=>{let[t]=e;return(0,s.rh)(t)});t.handleSearchSuccess(e,n).forEach(e=>{_.set(e.id,e);let t=E.get(e.id)??0;E.set(e.id,t+1)})})},SEARCH_MESSAGES_INDEXING:function(e){e.ids.forEach(e=>{h(e).handleSearchIndexing()})},SEARCH_MESSAGES_FAILURE:function(e){e.ids.forEach(t=>{h(t).handleSearchFailure(e.error)})},SEARCH_MESSAGES_CLEAR:function(e){let t=u.get(e.id);if(null==t)return!1;t.messageIds.forEach(e=>{let t=E.get(e)??0;t<=1?(_.delete(e),E.delete(e)):E.set(e,t-1)}),u.delete(e.id)},SEARCH_MESSAGES_CLEAR_ALL:function(e){u=new Map,_=new Map,E=new Map},MESSAGE_UPDATE:function(e){let t=e.message.id;if(null==t)return!1;let n=_.get(t);if(null==n)return!1;let i=(0,s.IU)(n,e.message);_.set(t,i)},MESSAGE_REACTION_ADD:f,MESSAGE_REACTION_ADD_MANY:function(e){let{messageId:t,reactions:n}=e,i=o.default.getId();return I(t,e=>e.addReactionBatch(n,i))},MESSAGE_REACTION_REMOVE:f,MESSAGE_REACTION_REMOVE_ALL:function(e){let{messageId:t}=e;return I(t,e=>e.set("reactions",[]))},MESSAGE_REACTION_REMOVE_EMOJI:function(e){let{messageId:t,emoji:n}=e;return I(t,e=>e.removeReactionsForEmoji(n))},CONNECTION_OPEN:function(){u=new Map,_=new Map,E=new Map}})}