U ]g@s|ddlZddlZddlmZddlZddlmZmZddlm Z m Z m Z m Z m Z mZGdddejZGdddeeZdS) N)Counter)MovingWindowSupportStorage)DictListOptionalTupleTypeUnioncs$eZdZeddfdd ZZS) LockableEntryN)expiryreturncs$t|_|j||_tdSN)timeatimer super__init__)selfr  __class__9/tmp/pip-unpacked-wheel-kizsipjx/limits/storage/memory.pyr s  zLockableEntry.__init__)__name__ __module__ __qualname__floatr __classcell__rrrrr sr cs*eZdZdZdgZd(eeeedfdd Ze e e e e e e dffd d d Zdd d d Zdd ddZd)eeeeedddZeedddZeddddZd*eeeeedddZeedddZeeeddd Zeeee eefd!d"d#Zed d$d%Zeed d&d'ZZS)+ MemoryStoragez rate limit storage using :class:`collections.Counter` as an in memory storage for fixed and elastic window strategies, and a simple list to implement moving window strategy. ZmemoryNF)uriwrap_exceptions_c sJt|_i|_i|_td|j|_|jt j |fd|i|dS)N{Gz?r) rstorage expirationsevents threadingTimer_MemoryStorage__expire_eventstimerstartrr)rrrr rrrrs  zMemoryStorage.__init__.)r cCstSr) ValueErrorrrrrbase_exceptions%szMemoryStorage.base_exceptionsc Cst|jD]T}t|j|D]@}|2|jtkrV||j|krV|j||W5QRXq qt|jD]2}|j|tkrr|j|d|j|dqrdSr) listr$keysr rremover#r"pop)rkeyeventrrrZ__expire_events+szMemoryStorage.__expire_eventscCs(|js$td|j|_|jdS)Nr!)r(is_aliver%r&r'r)r+rrrZ__schedule_expiry7s zMemoryStorage.__schedule_expiry)r1r elastic_expiryamountr cCsV||||j||7<|s6|j||krHt||j|<|j|dS)aD 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 elastic_expiry: whether to keep extending the rate limit window every hit. :param amount: the number to increment by r)get_MemoryStorage__schedule_expiryr"rr#)rr1r r5r6rrrincr<s zMemoryStorage.incr)r1r cCs@|j|dtkr2|j|d|j|d|j|dS)zB :param key: the key to get the counter value for rN)r#r7rr"r0rr1rrrr7QszMemoryStorage.getcCs.|j|d|j|d|j|ddS)z> :param key: the key to clear rate limits for N)r"r0r#r$r:rrrclear\szMemoryStorage.clear)r1limitr r6r cs||kr dS|j|g|t}z|j|||}Wntk rXd}YnX|rp|j|krpdSfddt|D|j|dd<dSdS)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 FNcsg|] }tqSr)r ).0r r rr ysz/MemoryStorage.acquire_entry..rT)r$ setdefaultr8r IndexErrorrrange)rr1r<r r6 timestampentryrr>r acquire_entryds $zMemoryStorage.acquire_entrycCst|j|tS)z; :param key: the key to get the expiry for )intr#r7rr:rrr get_expiry|szMemoryStorage.get_expiry)r1r r cs6t|j|r2tfdd|j|DSdS)z returns the number of entries already acquired :param key: rate limit key to acquire an entry in :param expiry: expiry of the entry csg|]}|jkr|qSr)r)r=kr rCrrr?sz2MemoryStorage.get_num_acquired..r)rr$r7len)rr1r rrIrget_num_acquireds  zMemoryStorage.get_num_acquired)r1r<r r cCs^t}|||}|j|gdddD]$}|j||kr,t|j|fSq,t||fS)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) N)rrKr$r7rrF)rr1r<r rCZacquireditemrrrget_moving_windows  zMemoryStorage.get_moving_windowcCsdS)z- check if storage is healthy Trr+rrrcheckszMemoryStorage.checkcCs8tt|jt|j}|j|j|j|Sr)maxrJr"r$r;r#)rZ num_itemsrrrresets    zMemoryStorage.reset)NF)Fr4)r4)rrr__doc__ZSTORAGE_SCHEMErstrboolrpropertyr r Exceptionrr,r'r8rFr9r7r;rErGrKrNrOrQrrrrrrs>    r)r%r collectionsrZ limits.typingZlimitsZlimits.storage.baserrrrrrr r _RLockr rrrrrs