ZeIi)pUdZddlmZddlZddlmZmZddlmZm Z ddl m Z ddl m Z dd lmZdd lmZmZmZdd lmZdd lmZGd deZGddeZGddeZe dGddeZeeeezeezZeeedZded<dS)z Rate limiting strategies ) annotationsN)ABCMetaabstractmethod)floorinf) versionadded)SlidingWindowCounterSupport) RateLimitItem)MovingWindowSupportStorage StorageTypes)cast) WindowStatscreZdZddZeddddZeddddZeddZddZdS) RateLimiterstoragercBt|tsJ||_dSN) isinstancer r)selfrs V/var/www/html/MCyber-Diagnostic/venv/lib/python3.11/site-packages/limits/strategies.py__init__zRateLimiter.__init__s#'7+++++ ' r costitemr identifiersstrrintreturnboolctS Consume the rate limit :param item: The rate limit item :param identifiers: variable list of strings to uniquely identify this instance of the limit :param cost: The cost of this hit, default 1 :return: True if ``cost`` could be deducted from the rate limit without exceeding it NotImplementedErrorrrrrs rhitzRateLimiter.hit "!rct)aT Check the rate limit without consuming from it. :param item: The rate limit item :param identifiers: variable list of strings to uniquely identify this instance of the limit :param cost: The expected cost to be consumed, default 1 :return: True if the rate limit is not depleted r&r(s rtestzRateLimiter.test(r*rrct)  Query the reset time and remaining amount for the limit :param item: The rate limit item :param identifiers: variable list of strings to uniquely identify this instance of the limit :return: (reset time, remaining) r&rrrs rget_window_statszRateLimiter.get_window_stats6s "!rNonecF|j|j|Sr)rclearkey_forr/s rr3zRateLimiter.clearBs!|!!,$, "<===rNrrrr rrrr r!r"rr rrr!rrr rrr!r1) __name__ __module__ __qualname__rrr)r,r0r3rrrrs((((FG " " " " "^ "GH " " " " "^ " " " "^ ">>>>>>rr) metaclasscHeZdZdZdfd ZddddZddddZddZxZS)MovingWindowRateLimiterz4 Reference: :ref:`strategies:moving window` rrct|ds't|dstd|jt|dS)N acquire_entryget_moving_windowz@MovingWindowRateLimiting is not implemented for storage of type hasattrr' __class__superrrrrEs rrz MovingWindowRateLimiter.__init__Ksq G_ - - 18BU1V1V &/",//  !!!!!rr rrr rrrr r!r"ctt|j|j||j||Sr%)amount)rr rrAr4rJ get_expiryr(s rr)zMovingWindowRateLimiter.hitUsM'66DD DL+ & T__5F5FtE   rctt|j|j||j|d|j|z kSaK Check if the rate limit can be consumed :param item: The rate limit item :param identifiers: variable list of strings to uniquely identify this instance of the limit :param cost: The expected cost to be consumed, default 1 :return: True if the rate limit is not depleted r )rr rrBr4rJrKr(s rr,zMovingWindowRateLimiter.testesb $dl 3 3 E E k* !!     {T!  " rrctt|j|j||j|\}}||z}t||j|z S)a returns the number of requests remaining within this limit. :param item: The rate limit item :param identifiers: variable list of strings to uniquely identify this instance of the limit :return: tuple (reset time, remaining) )rr rrBr4rJrKr)rrr window_start window_itemsresets rr0z(MovingWindowRateLimiter.get_window_statszsu&* & &  LDL+6 T__EVEV W W # lt0005$+ "<===rr5r6r7) r9r:r;__doc__rr)r,r0 __classcell__rEs@rr?r?Fs""""""GH      HI      *>>>>>>>>rr?c6eZdZdZdddd Zdddd ZddZdS)FixedWindowRateLimiterz3 Reference: :ref:`strategies:fixed window` r rrr rrrr r!r"c|j|j||||jkSrI)rincrr4rKrJr(s rr)zFixedWindowRateLimiter.hitsK L   k*!!    {   rcd|j|j||j|z dzkSrM)rgetr4rJr(s rr,zFixedWindowRateLimiter.tests5|  k :;;dkD>PST>TTTrrc td|j|j|j|z }|j|j|}t ||S)r.r)maxrJrrZr4rKr)rrr remainingrQs rr0z'FixedWindowRateLimiter.get_window_statssa4;)9)9,$, :T)U)UUVV  ''  k(BCC5),,,rNr6r7)r9r:r;rRr)r,r0r<rrrVrVsGH      *HI U U U U U U - - - - - -rrVz4.1)versioncXeZdZdZdfd Zdd ZddddZddddZddZddZ xZ S)SlidingWindowCounterRateLimiterz= Reference: :ref:`strategies:sliding window counter` rrct|drt|dstd|jt|dS)Nget_sliding_windowacquire_sliding_window_entryzHSlidingWindowCounterRateLimiting is not implemented for storage of type rCrGs rrz(SlidingWindowCounterRateLimiter.__init__svw 455 W 3> >  &/",//  !!!!!rrr previous_countr previous_expires_infloat current_countr!c<||z|z |zS)zu Return the approximated by weighting the previous window count and adding the current window count. )rK)rrrdrergs r_weighted_countz/SlidingWindowCounterRateLimiter._weighted_counts$ 33doo6G6GG-WWrr rrrrr"ctt|j|j||j||Sr$)rr rrcr4rJrKr(s rr)z#SlidingWindowCounterRateLimiter.hitsN '  & & DL+ & K OO       rctt|j|j||\}}}}||||||j|z dzkSrM)rr rrbr4rKrirJ)rrrrrdrerg_s rr,z$SlidingWindowCounterRateLimiter.testsAE 'A A  \T\;79J9J K K >+]A  n&9=  kD 1$ % rrc tt|j|j||\}}}}t d|jt| ||||z }tj }|s|st||S|} tt} } |r|| |z z} |r|| z} t|t| | z|S)a Query the reset time and remaining amount for the limit. :param item: The rate limit item :param identifiers: variable list of strings to uniquely identify this instance of the limit :return: WindowStats(reset time, remaining) r)rr rrbr4rKr\rJrritimerrmin) rrrrdrergcurrent_expires_inr]nowexpiryprevious_reset_incurrent_reset_ins rr0z0SlidingWindowCounterRateLimiter.get_window_statss*RV 'R R  \T\;79J9J K K O+]>SS DL+ &(9(9   rr5) rr rdr rerfrgr r!rfr6r7r8) r9r:r;rRrrir)r,r0r3rSrTs@rr`r`s"""""" X X X XGH      (HI      ,$V$V$V$VL        rr`)zsliding-window-counterz fixed-windowz moving-windowzdict[str, KnownStrategy] STRATEGIES) rR __future__rrnabcrrmathrrdeprecated.sphinxrlimits.storage.baser limitsr rr r rtypingrutilrrr?rVr`type KnownStrategyrw__annotations__r<rrrs#""""" ''''''''******;;;;;;!!!!!!??????????.>.>.>.>.>G.>.>.>.>bB>B>B>B>B>kB>B>B>J4-4-4-4-4-[4-4-4-nen n n n n kn n n d () !"# "#$>*,(( r