
    Ջg                     z    d dl Z d dlZd dlmZ d dlmZ  e j                  d      j                  Z G d de      Z	y)    N)time)	BaseCachez[^\x00-\x21\xff]{1,250}$c            
       x   e Zd ZdZ	 	 	 ddej
                  dedej                  e   fdZ	dedefd	Z
d
ej                  e   defdZdedej
                  fdZdedej                  eej
                  f   fdZddedej
                  d
ej                  e   defdZ	 ddedej
                  d
ej                  e   dej                  e   fdZdedej$                  ej
                     fdZ	 ddej                  eej
                  f   d
ej                  e   dej$                  ej
                     fdZdedefdZdedej$                  ej
                     fdZdedefdZdefdZddededej                  e   fdZddededej                  e   fdZdej
                  dej
                  fdZy) MemcachedCachea  A cache that uses memcached as backend.

    The first argument can either be an object that resembles the API of a
    :class:`memcache.Client` or a tuple/list of server addresses. In the
    event that a tuple/list is passed, Werkzeug tries to import the best
    available memcache library.

    This cache looks into the following packages/modules to find bindings for
    memcached:

        - ``pylibmc``
        - ``google.appengine.api.memcached``
        - ``memcached``
        - ``libmc``

    Implementation notes:  This cache backend works around some limitations in
    memcached to simplify the interface.  For example unicode keys are encoded
    to utf-8 on the fly.  Methods such as :meth:`~BaseCache.get_dict` return
    the keys in the same format as passed.  Furthermore all get methods
    silently ignore key errors to not cause problems when untrusted user data
    is passed to the get methods which is often the case in web applications.

    :param servers: a list or tuple of server addresses or alternatively
                    a :class:`memcache.Client` or a compatible client.
    :param default_timeout: the default timeout that is used if no timeout is
                            specified on :meth:`~BaseCache.set`. A timeout of
                            0 indicates that the cache never expires.
    :param key_prefix: a prefix that is added before all keys.  This makes it
                       possible to use the same memcached server for different
                       applications.  Keep in mind that
                       :meth:`~BaseCache.clear` will also clear keys with a
                       different prefix.
    Nserversdefault_timeout
key_prefixc                     t        j                  | |       |t        |t        t        f      r2|dg}| j                  |      | _        | j                  t        d      || _        || _        y )Nz127.0.0.1:11211zno memcache module found)	r   __init__
isinstancelisttupleimport_preferred_memcache_lib_clientRuntimeErrorr	   )selfr   r   r	   s       E/var/www/html/venv/lib/python3.12/site-packages/cachelib/memcached.pyr   zMemcachedCache.__init__.   sk     	41?j4-@,-==gFDL||#"#=>> #DL$    keyreturnc                 <    | j                   r| j                   |z   }|S N)r	   r   r   s     r   _normalize_keyzMemcachedCache._normalize_keyB   s    ??//C'C
r   timeoutc                 h    t        j                  | |      }|dkD  rt        t                     |z   }|S Nr   )r   _normalize_timeoutintr   )r   r   s     r   r   z!MemcachedCache._normalize_timeoutG   s0    ..tW=Q;$&kG+Gr   c                 r    | j                  |      }t        |      r| j                  j                  |      S y r   )r   _test_memcached_keyr   getr   s     r   r"   zMemcachedCache.getM   s6    !!#& s#<<##C(( $r   keysc                 X   i }|D ]$  }| j                  |      }t        |      s |||<   & t        |      }| j                  j	                  |      x}}| j
                  r"i }|j                         D ]  \  }}||||   <    t        |      t        |      k  r|D ]  }||vsd ||<    |S r   )r   r!   r   r   	get_multir	   itemslen)	r   r#   key_mappingr   encoded_key_keysdrvvalues	            r   get_dictzMemcachedCache.get_dictU   s     	/C--c2K"3'+.K(	/ [!''..B??Bggi -
U',;s#$-r7SY #b="BsG# 	r   r-   c                     | j                  |      }| j                  |      }t        | j                  j	                  |||            S r   )r   r   boolr   addr   r   r-   r   s       r   r1   zMemcachedCache.addg   s@    !!#&))'2DLL$$S%9::r   c                     | j                  |      }| j                  |      }t        | j                  j	                  |||            S r   )r   r   r0   r   setr2   s       r   r4   zMemcachedCache.setl   sB     !!#&))'2DLL$$S%9::r   c                 P     | j                   | }|D cg c]  }||   	 c}S c c}w r   )r.   )r   r#   r+   r   s       r   get_manyzMemcachedCache.get_manys   s*    DMM4 "&'3#'''s   #mappingc                 L   i }|j                         D ]  \  }}| j                  |      }|||<    | j                  |      }| j                  j	                  ||      }t        |j                         |j                               }|D 	cg c]  \  }}	|	|vs| c}	}S c c}	}w r   )r&   r   r   r   	set_multizipr#   )
r   r7   r   new_mappingr   r-   failed_keys	k_normkeyknkeys
             r   set_manyzMemcachedCache.set_manyw   s     !--/ 	%JC%%c*C$K	% ))'2ll,,
 (8(8(:;	!*Fgad+.EFFFs   B B c                     | j                  |      }t        |      r$t        | j                  j	                  |            S y)NF)r   r!   r0   r   deleter   s     r   rB   zMemcachedCache.delete   s7    !!#&s#++C011r   c                     g }|D ]0  }| j                  |      }t        |      s |j                  |       2 | j                  j	                  |       |D cg c]  }| j                  |      r| c}S c c}w r   )r   r!   appendr   delete_multihas)r   r#   new_keysr   r>   s        r   delete_manyzMemcachedCache.delete_many   sl     	%C%%c*C"3'$	% 	!!(+#7a488A;777s   A5.A5c                     | j                  |      }t        |      r%t        | j                  j	                  |d            S y)N F)r   r!   r0   r   rD   r   s     r   rF   zMemcachedCache.has   s9    !!#&s#++C455r   c                 H    t        | j                  j                               S r   )r0   r   	flush_all)r   s    r   clearzMemcachedCache.clear   s    DLL**,--r   deltac                     | j                  |      }| j                  j                  |      xs d|z   }| j                  ||      r|S d S r   r   r   r"   r4   r   r   rN   r-   s       r   inczMemcachedCache.inc   H    !!#&!!#&+!u4e,u6$6r   c                     | j                  |      }| j                  j                  |      xs d|z
  }| j                  ||      r|S d S r   rP   rQ   s       r   deczMemcachedCache.dec   rS   r   c                 ,   	 ddl }|j                  |      S # t        $ r Y nw xY w	 ddlm} |j                         S # t        $ r Y nw xY w	 ddl}|j                  |      S # t        $ r Y nw xY w	 ddl}|j                  |      S # t        $ r Y yw xY w)zAReturns an initialized memcache client.  Used by the constructor.r   N)memcache)pylibmcClientImportErrorgoogle.appengine.apirW   libmc)r   r   rX   rW   r\   s        r   r   z,MemcachedCache.import_preferred_memcache_lib   s    	+ >>'**  		
	%5 ??$$  		
	, ??7++  		
	) <<((  		s?    	##= 	A	A	A" "	A.-A.2B 	BB)Ni,  Nr   )   )__name__
__module____qualname____doc___tAnyr   Optionalstrr   r   r   r"   Dictr.   r0   r1   r4   Listr6   r@   rB   rH   rF   rM   rR   rU   r    r   r   r   r      s;    H "'+	%% % KK$	%(# # 
"++c*: s )s )rvv )c bggc266k&: $;s ;266 ;BKK4D ;PT ; DH;;!vv;02C0@;	T	;(c (bggbffo (
 JNGwwsBFF{+G68kk#6FG	G# $ 8 8 8s t .t .7s 73 7r{{3/? 7
7s 73 7r{{3/? 7
)RVV ) )r   r   )
retypingrb   r   cachelib.baser   compilematchr!   r   rh   r   r   <module>rn      s9    	   # !bjj!<=CC y)Y y)r   