\jzdZddlZddlmZddlZddlmZmZ ddlm Z Gdde Z y#e $r ddl m Z YwxYw)a Dictionary with auto-expiring values for caching purposes. Expiration happens on any access, object is locked during cleanup from expired values. Can not store more than max_len elements - the oldest will be deleted. >>> ExpiringDict(max_len=100, max_age_seconds=10) The values stored in the following way: { key1: (value1, created_time1), key2: (value2, created_time2) } NOTE: iteration over dict and also keys() do not remove expired values! N)RLock)AnyUnion) OrderedDictceZdZddZdZddZddZddZdZddZ d Z d Z d Z d Z d ZdZdZdZdZdZdZedZedZedZedZedZdZdZdZy) ExpiringDictNcj|sj||tj|_|_t _tjdk\r fd_ nj_ |vj|rj|||yj|rj|yj|rj!|yt#dy)N)c6tjSN)listkeysselfs?/root/env/lib/python3.12/site-packages/expiringdict/__init__.pyz'ExpiringDict.__init__..+sd499;&7zcan not unpack items)+_ExpiringDict__is_instance_of_expiring_dict_ExpiringDict__assertionsr__init__max_lenmax_agerlocksys version_info _safe_keysr!_ExpiringDict__copy_expiring_dict"_ExpiringDict__is_instance_of_dict_ExpiringDict__copy_dict _ExpiringDict__is_reduced_result"_ExpiringDict__copy_reduced_result ValueError)rrmax_age_secondsitemss` rrzExpiringDict.__init__s2259   g 7T" & G   v %7DO"iiDO  2259))'?EJ++E2  '))%0**51!!788 rc |j5tj||}tj|dz |jkr dddy||= dddy#1swYyxYw#t $rYywxYw)z7 Return True if the dict has a key, else return False. NTFrr __getitem__timerKeyError)rkeyitems r __contains__zExpiringDict.__contains__:s  ""..tS999;a(4<<7 " " S  " "   s: A/?A# A/A#A/#A,(A/,A// A;:A;c|j5tj||}tj|dz }||jkr |r|d|fcdddS|dcdddS||=t |#1swYyxYw)z[ Return the item of the dict. Raises a KeyError if key is not in the map. r'rNr()rr,with_ager-item_ages rr)zExpiringDict.__getitem__Gs YY $**45Dyy{T!W,H$,,&7H, $ $ 7 $ $Ism# $ $sAA;A;-A;;Bc(|j5t||jk(r||vr||=n |jd|t j }t j||||fdddy#t$rYCwxYw#1swYyxYw)z Set d[key] to value. F)lastN)rlenrpopitemr+r*r __setitem__)rr,valueset_times rr6zExpiringDict.__setitem__Xs YY B4yDLL($;S  % 099;  # #D#x/@ A B B$ B Bs.!BA9/B9 BBBBBc|j5 tj||}||=|dcdddS#t$r|cYcdddSwxYw#1swYyxYw)z{ Get item from the dict and remove it. Return default if expired or does not exist. Never raise KeyError. rN)rrr)r+)rr,defaultr-s rpopzExpiringDict.popgsj YY  "..tS9IAw             s&A6 A A A  AAc`|j|d\}}|r|j|z }|dkDr|Sy)zg Return TTL of the `key` (in seconds). Returns None for non-existent or expired keys. T)r0rN)getr)rr, key_valuekey_agekey_ttls rttlzExpiringDict.ttlts; "XXcDX9 7 llW,G{rcZ |j||S#t$r |r|dfcYS|cYSwxYw)zE Return the value for key if key is in the dictionary, else default. N)r)r+)rr,r:r0s rr=zExpiringDict.gets; ##C2 2 }$  s***cg}|jD]} |j|||f|S#t$rY)wxYw)z? Return a copy of the dictionary's list of (key, value) pairs. rappendr+rrr,s rr%zExpiringDict.itemssR ??$ C #tCy)*    s 1 ==cg}|jD]*} |j|tj||f,|S#t$rY:wxYw)zL Return a copy of the dictionary's list of (key, value, timestamp) triples. )rrErr)r+rFs ritems_with_timestampz!ExpiringDict.items_with_timestamps[ ??$ C #{66tSABC    s'A A Ac|g}|jD]} |j|||S#t$rY'wxYw)zZ Return a copy of the dictionary's list of values. See the note for dict.items(). rDrFs rvalueszExpiringDict.valuessO ??$ C c#    s / ;;ct)zE Create a new dictionary with keys from seq and values set to value. NotImplementedErrorrs rfromkeyszExpiringDict.fromkeys !##rct)z> Return an iterator over the dictionary's (key, value) pairs. rMrs r iteritemszExpiringDict.iteritemsrPrct)z2 Return an iterator over the dictionary's values. rMrs r itervalueszExpiringDict.itervaluesrPrct)zC Return a new view of the dictionary's items ((key, value) pairs). rMrs r viewitemszExpiringDict.viewitemsrPrct)z- Return a new view of the dictionary's keys. rMrs rviewkeyszExpiringDict.viewkeysrPrct)z/ Return a new view of the dictionary's values. rMrs r viewvalueszExpiringDict.viewvaluesrPrcp|j|j|jd|jfff}|S)N reduce_result) __class__rrrI)rreduceds r __reduce__zExpiringDict.__reduce__s3..4<<QUQjQjQl?m"nnrcH|j||j|yr )_ExpiringDict__assert_max_len%_ExpiringDict__assert_max_age_seconds)rrr$s r __assertionszExpiringDict.__assertionss g& %%o6rc|dk\sJyNr')rs r__assert_max_lenzExpiringDict.__assert_max_lens!||rc|dk\sJy)Nrrf)r$s r__assert_max_age_secondsz%ExpiringDict.__assert_max_age_secondss!###rc2t|dk(r |ddk(ryy)Nrr\TF)r4r%s r__is_reduced_resultz ExpiringDict.__is_reduced_results u:?uQx?:rc*|t|tryyNTF) isinstancerrls r__is_instance_of_expiring_dictz+ExpiringDict.__is_instance_of_expiring_dicts  %.rc&t|tryyro)rpdictrls r__is_instance_of_dictz"ExpiringDict.__is_instance_of_dicts eT "rc 4||j|||_n|j|_||j|||_n|j|_|j Dcgc]\}\}}|j |||c}}}ycc}}}wr )rarrbrrIr6)rrr$r%r,r7r8s r__copy_expiring_dictz!ExpiringDict.__copy_expiring_dicts    ! !' *"DL ==DL  &  ) )/ :*DL ==DLNSNhNhNjkk4JC9J%  #uh /kks- Bcv|jDcgc]\}}|j||c}}ycc}}wr )r%r6)rr%r,r7s r __copy_dictzExpiringDict.__copy_dicts*8= F*#u  #u %FFs5c n|dDcgc]\}\}}|j|||c}}}ycc}}}wre)r6)rr%r,r7r8s r__copy_reduced_resultz"ExpiringDict.__copy_reduced_results4NSTUhWW4JC9J%  #uh /WWs 0r )F)NF)__name__ __module__ __qualname__rr.r)r6r;rAr=r%rIrKrOrRrTrVrXrZr_r staticmethodrarbr!rrrr r"rfrrrrs96 $" B   $$$$$$7$$   l GXrr) __doc__r* threadingrrtypingrr collectionsr ImportError ordereddictrrfrrrsD"  (' [X;[X ('(s , ::