Module 185522

function(e,t,n){"use strict";n.d(t,{A:()=>f});var i=n(158390),r=n(439372),s=n(734057),a=n(568548),o=n(309010),l=n(935208),u=n(828488),c=n(775632),d=n(958720),_=n(575279);class h extends r.A{visibleTopMessageId=null;backoffStateByChannel=new Map;actions={CHANNEL_SELECT:()=>{this.visibleTopMessageId=null},UPDATE_VISIBLE_MESSAGES:e=>{let{topVisibleMessage:t}=e,n=o.A.getChannelId();if(null==n)return;let i=s.A.getChannel(n)?.guild_id;if(null==i||!(0,u.Lc)(i,"visible_messages"))return;let r=this.visibleTopMessageId!==t;this.visibleTopMessageId=t??null,this.isBackoffPending(n)||(r||null==t&&this.hasMoreConversations(n,"after"))&&this.fetchForViewport(n,i,r)},CONVERSATIONS_FETCH_SUCCESS:e=>{let{channelId:t}=e;this.clearBackoff(t)},CONVERSATIONS_FETCH_FAILURE:e=>{let{channelId:t}=e;this.armBackoff(t)},CHANNEL_DELETE:e=>{let{channel:t}=e;this.clearBackoff(t.id)},LOGOUT:()=>this.reset()};fetchForViewport(e,t,n){let i=d.A.getChannelConversations(e),r=this.hasMoreConversations(e,"before"),s=this.hasMoreConversations(e,"after");if(null==i||0===i.length&&s)return void(0,c.WF)({channelId:e,guildId:t,direction:null==this.visibleTopMessageId?"before":"around",anchor:this.visibleTopMessageId,limit:25,isJump:!0});let o=this.visibleTopMessageId??a.Ay.lastMessageId(e);if(null==o||null==i||0===i.length)return;let l=null==this.visibleTopMessageId;if(this.isAnchorOutsideBuffer(i,o)&&(!l||n))return void(0,c.WF)({channelId:e,guildId:t,direction:"around",anchor:o,limit:25,isJump:!0});if(l){s&&(0,c.WF)({channelId:e,guildId:t,direction:"after",anchor:i[i.length-1].id,limit:25});return}let{above:u,below:_}=this.countBuffer(e,o);u<10&&_<10&&r&&s?(0,c.WF)({channelId:e,guildId:t,direction:"around",anchor:o,limit:25}):u<10&&r?(0,c.WF)({channelId:e,guildId:t,direction:"before",anchor:i[0].id,limit:25}):_<10&&s&&(0,c.WF)({channelId:e,guildId:t,direction:"after",anchor:i[i.length-1].id,limit:25})}hasMoreConversations(e,t){let n=d.A.getEdgeMarker(e,t);return"before"===t?null==n:null==n||Date.now()-n>_.sE}isBackoffPending(e){return this.backoffStateByChannel.get(e)?.backoff.pending??!1}getOrCreateBackoffState(e){let t=this.backoffStateByChannel.get(e);return null==t&&(t={backoff:new i.A(2e3,18e4),retry:()=>this.retryAfterBackoff(e)},this.backoffStateByChannel.set(e,t)),t}armBackoff(e){let{backoff:t,retry:n}=this.getOrCreateBackoffState(e);t.fail(n)}clearBackoff(e){this.backoffStateByChannel.get(e)?.backoff.cancel(),this.backoffStateByChannel.delete(e)}retryAfterBackoff(e){if(o.A.getChannelId()!==e)return;let t=s.A.getChannel(e)?.guild_id;null!=t&&(0,u.Lc)(t,"backoff_retry")&&this.fetchForViewport(e,t,!0)}reset(){for(let{backoff:e}of(this.visibleTopMessageId=null,this.backoffStateByChannel.values()))e.cancel();this.backoffStateByChannel.clear()}isAnchorOutsideBuffer(e,t){let n=e[0],i=e[e.length-1];return 0>l.default.compare(t,n.startMessageId)||l.default.compare(t,i.endMessageId)>0}countBuffer(e,t){let n=d.A.getChannelConversations(e);if(null==n)return{above:0,below:0};let i=0,r=0;for(let e of n){let n=l.default.compare(e.startMessageId,t);n<0?i++:n>0&&r++}return{above:i,below:r}}}let f=new h}