"j!xddlZddlZddlZddlmZddlmZmZmZm Z eje Z GddZ y)N)util)generate_lock_token lock_stringnormalize_lock_root validate_lockcxeZdZdZdddddfd ZdZd Zd Zd Zd Z d Z dZ dZ dZ dZdZdZdZxZS)LockStorageRediszH A (high performance?) lock manager implementation using redis! z 127.0.0.1irNhostportdbpasswordct|||_||_||_||_d|_|j jd|_|j jd|_ d|_ y)Nz wsgidav-{}zlock:{}z URL2TOKEN:{}) super__init__ _redis_host _redis_port _redis_db_redis_password _redis_prefixformat_redis_lock_prefix_redis_url2token_prefix_redis)selfr r r r __class__s R/srv/dav/.venv/lib/python3.12/site-packages/wsgidav/lock_man/lock_storage_redis.pyrzLockStorageRedis.__init__sn ')"&"4"4";";I"F'+'9'9'@'@'P$ i: i$c.|jjS)N)r__name__rs r__repr__zLockStorageRedis.__repr__(s~~&&&rcy)z$Overloaded by Shelve implementation.Nr!s r_flushzLockStorageRedis._flush.rc|jJtj|j|j|j |j |_y)zUCalled before first use. May be implemented to initialize a storage. Nr )rredisRedisrrrrr!s ropenzLockStorageRedis.open1sF{{"""kk!!!!~~))   rcd|_y)zCalled on shutdown.N)rr!s rclosezLockStorageRedis.close=s  rcy)zPurge expired locks (optional).Nr$r!s rcleanupzLockStorageRedis.cleanupAr&rc|jW|jj|jjd}|D]}|jj |yy)zDelete all entries.N*)rkeysrrdelete)rr1keys rclearzLockStorageRedis.clearDsW ;; ";;##D$6$6$=$=c$BCD ( ""3' ( #rc|jj|jj|}|*tj d||j |ytj|}t|d}d|cxkrtjkr:n|Stj d|dt||j |y|S)a Return a lock dictionary for a token. If the lock does not exist or is expired, None is returned. token: lock token Returns: Lock dictionary or Side effect: if lock is expired, it will be purged and None is returned. NzLock purged dangling: expirerzLock timed-out(): ) rgetrr_loggerdebugr2pickleloadsfloattimer)rtokenlockr6s rr8zLockStorageRedis.getKs{{t66==eDE < MM25': ; KK ||D!tH~&  $ $  MMOF83{47H6IJ K KK  rc|jdJ|jdJd|rd|vsJ|}t|}||d<t|jd}|tj}n(|dks|tj kDrtj }||d<t j |z|d<t|t}||d<|jj|jj|tj|t||j j|}|jj#|s|jj%||n|jj%|||j't(j+d |d t-||S) aCreate a direct lock for a resource path. path: Normalized path (utf8 encoded string, no trailing '/') lock: lock dictionary, without a token entry Returns: New unique lock token.: - lock['timeout'] may be normalized and shorter than requested - lock['token'] is added r?r6zUse timeout instead of expire/roottimeoutrexzLockStorageRedis.set(r7)r8rr=r LOCK_TIME_OUT_DEFAULTLOCK_TIME_OUT_MAXr>rrrsetrrr;dumpsintrexistslpushr%r9r:r)rpathr@org_pathrDr?r3s rcreatezLockStorageRedis.createbsxx (((xx!)J+JJ)t ##"4(V +, ?&<rIrJrKr%)rr?rDr@s rrefreshzLockStorageRedis.refreshs{{!!$"9"9"@"@"GHHH"}! ++ Q;'$4$F$FF&88G||DKKOOD,C,C,J,J5,QRS!Yw.X   # # * *5 16<<3E#g,    rc|jj|jj|}|yt j |}t jdt||jj|jd}|jj|d||jj|jj||jy)zeDelete lock. Returns True on success. False, if token does not exist, or is expired. Fzdelete rCT) rr8rrr;r<r9r:rrlremr2r%)rr?r@r3s rr2zLockStorageRedis.deletes{{t66==eDE <||D!  D 1234**11$((62BC a' 42299%@A rc tj|sJ|r|jdsJ|s|sJ fd}t|}jj |}j j|dd}g |r|||rhtdj j|dzD]<}tj||s|j j|dd> S)auReturn a list of direct locks for . Expired locks are *not* returned (but may be purged). path: Normalized path (utf8 encoded string, no trailing '/') include_root: False: don't add lock (only makes sense, when include_children is True). include_children: True: Also check all sub-paths for existing locks. token_only: True: only a list of token is returned. This may be implemented more efficiently by some providers. Returns: List of valid lock dictionaries (may be empty). rBctd|D]v}jjjj |}|s:t j |}rj|dfj|xy)Nc$|jdSNzutf-8decodexs rzGLockStorageRedis.get_lock_list..__appendLocks..sqxx'8rr?)maprr8rrr;r<append)toklistr?r@lockListr token_onlys r __appendLocksz5LockStorageRedis.get_lock_list..__appendLocksso8'B .{{t'>'>'E'Ee'LM!<<-D! W 6 - .rrrRc$|jdSrZr[r]s rr_z0LockStorageRedis.get_lock_list..s188G#4rz/*) ris_str startswithrrrrlranger`r1 is_child_uri) rrN include_rootinclude_childrenrd_LockStorageRedis__appendLocksr3tokListurcs ` ` @r get_lock_listzLockStorageRedis.get_lock_lists {{4   ,,,/// .#4(**11$7++$$S!R0  ' " 4dkk6F6FsTz6RS @$$S!,!$++"4"4Q2">? @r)r __module__ __qualname____doc__rrGrHr"r%r*r,r.r4r8rPrSr2rp __classcell__)rs@rr r s^ +!d #"' 3  .(.3j6 ,rr )r;r>r(wsgidavrwsgidav.lock_man.lock_managerrrrrget_module_loggerr r9r r$rrrxs=   !$  *YYr