5j"SSKJr SSKrSSKrSSKrSSKJrJr SSKJ r SSK r SSK J r JrJrJr "SS5r"SS \\ \\5rg) ) annotationsN)Counter defaultdict)floor)MovingWindowSupportSlidingWindowCounterSupportStorageTimestampedSlidingWindowc\rSrSrSSjrSrg)Entryc`[R"5UlURU-UlgN)timeatimeexpiry)selfrs T/root/lseg-credit/backend/venv/lib/python3.13/site-packages/limits/storage/memory.py__init__Entry.__init__sYY[ jj6) )rrN)rfloatreturnNone)__name__ __module__ __qualname____firstlineno__r__static_attributes__rrr r s*rr c@^\rSrSrSrS/rSSU4SjjjrSSjrSSjrSSjr SSjr \ SS j5r SSS jjr SS S jjrS!S jrS"S jrSS#SjjrS$SjrS%SjrSS#SjjrS&SjrS'SjrS(SjrS)SjrS*SjrSrU=r$)+ MemoryStoragez rate limit storage using :class:`collections.Counter` as an in memory storage for fixed and sliding window strategies, and a simple list to implement moving window strategy. memoryc ">[5Ul[[R5Ul0Ul0Ul[R"SUR5Ul URR5 [TU]4"U4SU0UD6 g)N{Gz?wrap_exceptions)rstorager threadingRLocklocks expirationseventsTimer_MemoryStorage__expire_eventstimerstartsuperr)rurir'_ __class__s rrMemoryStorage.__init__$sj3:9 8CIOO8T -/.0 &/oodD/MemoryStorage.__expire_events..>s  rkey) listr-keysr+getbisect bisect_leftrpopr,r()rrIr-oldests r__expire_eventsMemoryStorage.__expire_events9s. ((*+CC![[__S"5565#// 2MF(,{{3'7'@DKK${{sD11JJNN3-!,((--/0C$ 3   d+  $$S$/ sD) 1!s B+F F$ cURR5(dA[R"SUR5UlURR 5 ggr?)r0is_aliver)r.r/r1rs r__schedule_expiryMemoryStorage.__schedule_expiryIsBzz""$$"t/C/CDDJ JJ   %rc[$r) ValueErrorrUs rbase_exceptionsMemoryStorage.base_exceptionsNs rclURU5 UR5 URU URU==U- ss'URUU:Xa%[R"5U-UR U'SSS5 URRUS5$!,(df  N*=f)z increments the counter for a given rate limit key :param key: the key to increment :param expiry: amount in seconds for the key to expire in :param amount: the number to increment by Nr)rL_MemoryStorage__schedule_expiryr+r(rr,)rrIramounts rincrMemoryStorage.incrTs    ZZ_ LL  ' ||C F*(, f(<  %||Q'' _s AB%% B3c URU5 UR5 URU [URUU- S5URU'SSS5 URRUS5$!,(df  N*=f)z decrements the counter for a given rate limit key :param key: the key to decrement :param amount: the number to decrement by rN)rLr]r+maxr()rrIr^s rdecrMemoryStorage.decrdso    ZZ_ #DLL$5$> BDLL ||Q''_s *A?? B cHURRUS5[R"5::aTURR US5 URR US5 UR R US5 URRUS5$)z2 :param key: the key to get the counter value for rN)r,rLrr(rOr+rrIs rrLMemoryStorage.getrsx     Q '499; 6 LL  S$ '    d + JJNN3 %||Q''rcURRUS5 URRUS5 URRUS5 URRUS5 g)z. :param key: the key to clear rate limits for N)r(rOr,r-r+rfs rclearMemoryStorage.clear~sR d# S$' T" sD!rcXB:agUR5 URU URRU/5 [R"5nURUX$- nU(aUR XS- :a SSS5 g[U5/U-URUSS&SSS5 g![ a SnNZf=f!,(df  g=f)z :param key: rate limit key to acquire an entry in :param limit: amount of entries allowed :param expiry: expiry of the entry :param amount: the number of entries to acquire FNrT)r]r+r- setdefaultr IndexErrorrr )rrIlimitrr^ timestampentrys r acquire_entryMemoryStorage.acquire_entrys >  ZZ_ KK " "3 + I  C(8 (::_).f '? C !$_    _s52C B9-C  C 9 CC CC  Cc`URRU[R"55$)z+ :param key: the key to get the expiry for )r,rLrrfs r get_expiryMemoryStorage.get_expirys# ##C55rc[R"5nURRU/5=n(a-[R"XTU- *SS9nXVS- R U4$US4$)z returns the starting point and the number of entries in the moving window :param key: rate limit key :param expiry: expiry of entry :return: (start of window, number of acquired entries) cUR*$r)r)rps rrF1MemoryStorage.get_moving_window..s %++rrHr)rr-rLrMrNr)rrIrnrror-rPs rget_moving_windowMemoryStorage.get_moving_windowskIIK [[__S"- -6 -''f,-3MF1*%++V3 3!|rcHXB:ag[R"5nURXU5upgURXgX55unn n n X-U- U -n [U 5U-U:agUR USU-US9n X-U- U -n [U 5U:aUR Xt5 gg)NF)r^T)rsliding_window_keys_get_sliding_window_inforr_rc) rrIrnrr^now previous_key current_keyprevious_count previous_ttl current_countr4weighted_counts racquire_sliding_window_entry*MemoryStorage.acquire_sliding_window_entrys >iik$($<$?6ILS\Q./69FB ]GGrcx[R"5nURXU5upEURXEX#5$r)rr~rrrIrrrrs rget_sliding_window MemoryStorage.get_sliding_windows7iik$($<$rsF"  ,** k "=?Wkr