Name	Size	Mode	Actions
cache.cpython-37.pyc	20000	0644	editdlrm
container.cpython-37.pyc	24087	0644	editdlrm
converters.cpython-37.pyc	888	0644	editdlrm
cookie.cpython-37.pyc	1779	0644	editdlrm
exceptions.cpython-37.pyc	1298	0644	editdlrm
middleware.cpython-37.pyc	5649	0644	editdlrm
session.cpython-37.pyc	26973	0644	editdlrm
synchronization.cpython-37.pyc	10631	0644	editdlrm
util.cpython-37.pyc	16783	0644	editdlrm
_compat.cpython-37.pyc	4217	0644	editdlrm
__init__.cpython-37.pyc	173	0644	editdlrm

B ��[�B�@sdZd
dl
Z
d
dlZd
dlZddlmZmZmZmZm Z m Z mZmZm Z mZ
yd
dlZWnek rt


d
dlZYnXd
dlmZmZ
d
dlZd
dlZd
dlZd
dlZd
dlZd
dlZd
dlZd
dlZd
dlZd
dlZd
dlm Z
d
dl!m"Z"
d
dlm#Z$
d Z%d ddd dddgZ&dd�Z'dAdd�
Z(dd�Z)dd�Z*dd�Z+dBdd�
Z,dd�Z-Gdd �d e.�Z/Gd d�de.�Z0Gd!d�de0�Z1da2dCd$d �
Z3d%d&�Z4d'd(�Z5d)d*�Z6d+d,�Z7d-d.�Z8d/d0�Z9dDd1d2�
Z:d3d4�Z;d5d6�Zd;d�Z?d�ZAd?d@�ZBdS)EzBeaker utilities�N�
) �PY2�string_type�unicode_text�NoneType�dictkeyslist�im_class�im_func�pickle�func_signature�default_im_func)�datetime� timedelta)
�asbool)
� exceptions)
�local���ThreadLocal�WeakValuedRegistry�SyncDict�encoded_path�verify_directory� serialize�deserializecCs |
|_|S)
z�Return a function with a given __name__. Will assign to __name__ and return the original function if possible on the Python implementation, otherwise a new function will be constructed. )
�__name__)�fn�name�r�.decorate..maybe)rr)rr')r r%r&)rr$r�decorate7s
zskip_if..decorate)r�noser )r%r&r(r)r r%r&r�skip_if1s r*cOs<y|
||�

d
}Wn|k r*


d}YnX|s8td�
�
dS)zGAssert the given exception is raised by the given function + arguments.FTz#Callable did not raise an exceptionN)
�AssertionError)Z except_clsZ callable_r!r"�successrrr� assert_raisesEs



r-c
CsJd
}
x@t�
|tj�sDy|
d7}
t�|�

Wq


|
dkr<�YqXqWdS)zcverifies and creates a directory. tries to ignore collisions with other threads and processes.r
r�N)�os�access�F_OK�makedirs)�dirZtriesrrrrRs






c
Cs*tt
|�
j�
}
|
r"|
d
dkr"dSdSdS)z8Return True if the given function has a 'self' argument.r
)�self�clsTFN)�listr� parameters)�funcr!rrr�has_self_arg`s

r9�cCs0t|t
�rtj|tj|
d
�
ntj||
d
�
dS)zIssue a warning.)
� stacklevelN)� isinstancer�warnings�warnrZ BeakerWarning)r#r;rrrr>is
r>c
s�f
d
d�}
|
S)Nc
s*��
fd
d�}
�j|
_d�
�j
f|
_
|
S)Ncst�
�
td
�
�||
�
S)N�)r=r>�DeprecationWarning)r!Zkargs)r�messagerr�deprecated_methodss

z6deprecated..wrapper..deprecated_methodz%s %s)r�__doc__)rrB)
rA)
rr�wrapperrs


zdeprecated..wrapperr)rArDr)
rAr� deprecatedqs
rEc@s>eZ
dZd
ZdZdd�Zdd�Zdd�Zdd d�
Zdd �Z d S)rz$stores a value on a per-thread basis�_tlocalc

Cst�|_dS)
N)
rF)
r4rrr�__init__�s
zThreadLocal.__init__cCs|
|j_
dS)
N)rF�value)r4rHrrr�put�s
zThreadLocal.putc

Cst|j
d
�S)NrH)�hasattrrF)
r4rrr�has�s
zThreadLocal.hasNcCst|j
d
|
�S)NrH)�getattrrF)r4�defaultrrr�get�s
zThreadLocal.getc


Cs |j`
dS)
N)rFrH)
r4rrr�remove�s
zThreadLocal.remove)
N) r� __module__�__qualname__rC� __slots__rGrIrKrNrOrrrrr}s
 c@s`eZ
dZd
Zdd�Zdd�Zdd�Zdd �Zd d�Zdd �Z dd�Z dd�Zdd�Zdd�Z dS)ra�
An efficient/threadsafe singleton map algorithm, a.k.a. "get a value based on this key, and create if not found or not valid" paradigm: exists && isvalid ? get : create Designed to work with weakref dictionaries to expect items to asynchronously disappear from the dictionary. Use python 2.3.3 or greater ! a major bug was just fixed in Nov. 2003 that was driving me nuts with garbage collection/weakrefs in this section. c

Cst�
�|_i|_dS)
N)� _threading�Lock�mutex�dict)
r4rrrrG�s

zSyncDict.__init__cOsVy,|
|jkr|j|
S|j
|
|f|�|�
SWn$tk rP


|j
|
|f|�|�
SXdS)
N)rV�sync_get�KeyError)r4�key� createfuncr!�kwargsrrrrN�s




zSyncDict.getcOsr|j�
�
zVy,|
|jkr"|j|
S|j|
|f|�|�
SWn$tk r\


|j|
|f|�|�
SXWd|j��
XdS)
N)rU�acquirerV�_createrX�release)r4rYrZr!r[rrrrW�s






zSyncDict.sync_getcOs|||�
||
<}|S)
Nr)r4rYrZr!r[�objrrrr]�s

zSyncDict._createcCs |
|jkS)
N)
rV)r4rYrrr�has_key�s
zSyncDict.has_keycCs|j�
|
�
S)
N)rV�__contains__)r4rYrrrra�s
zSyncDict.__contains__cCs|j�
|
�
S)
N)rV�__getitem__)r4rYrrrrb�s
zSyncDict.__getitem__cCs|j�
|
|�
dS)
N)rV�__setitem__)r4rYrHrrrrc�s
zSyncDict.__setitem__cCs|j�
|
�
S)
N)rV�__delitem__)r4rYrrrrd�s
zSyncDict.__delitem__c

Cs|j�
�
dS)
N)rV�clear)
r4rrrre�s
zSyncDict.clearN)rrPrQrCrGrNrWr]r`rarbrcrdrerrrrr�s
  c@seZ
dZd
d�ZdS)rc

Cst�
�|_t��|_dS)
N)rS�RLockrU�weakref�WeakValueDictionaryrV)
r4rrrrG�s

zWeakValuedRegistry.__init__N)rrPrQrGrrrrr�s
�.encTc Cs�d
�|
�
}t
dkrddlm
a

|rLt|t�r@t
|�d�
�
��}nt
|�
��}tj� |�
}g}x$t d|�D]}|�|d|��

qhWtjj|f
|��}t|�

tj�|||�S)zsGenerate a unique file-accessible path from the given list of identifiers starting at the given root directory.�
_Nr
)
�sha1zutf-8r) �joinrkZ beaker.cryptor<r�encode� hexdigestr/�path�basename�range�appendr) �rootZidentifiers� extension�depthZdigest_filenames�ident�tokens�
dr3rrrr�s 





c

Cs8t|t
�r|St|t�r,t�d
|�r,t
|�
Std�
�
dS)Nz^\d+$zThis is not a proper int)r<�intr�re�match� Exception)
r_rrr�asint�s



r}cCs�t||
�s�t|
t
�s|
f
}
d
}x�|
D]�}yn|tt
fkrLdd�|�d�
D�
}nD|tkrZt}n.|tkrht}n |tt fkr�t||�s�t d|��
||�
}d}Wn


YnX|r$Pq$W|s�t |�
�
nt|t�r�|��s�t d|�
�
|S)NFc
Ssg|]}
|
���qSr)
�strip)�.0�
xrrr�
sz"verify_options..�
,z%s requires a timedelta typeTz!Empty strings are invalid for: %s) r<�tupler6�split�boolrryr}rr r|�strr~)�opt�types�errorZcoerced�typrrr�verify_options

s4
























r�cCs4x.|
D]&\}}}||krt||||�||<qW|S)
N)
r�)�paramsZrulesetrYr�rArrr�verify_rules
s



r�c
CsP
d
tt
fdfdtt
fdfdtt
fdfdttttfdfd tt
fd fdtt
fdfd tf
dfdtf
dfdtt
fdfdtt
fdfdtt
fdfdtt
fdfdtt
fdfdtt
fdfdtt
fdfdtt
fd fd!tt
fd"fd#tt
fd$fd%tf
d&fg}
t||
�}|�d�
}|�
r&t|t��
r&t|t��
s&t|d'�
|d<|�d�
dk �
rL|�dd(��
sLt d)�
�
|S)*N�data_dirz3data_dir must be a string referring to a directory.�lock_dirz3lock_dir must be a string referring to a directory.�typezSession type must be a string.�cookie_expireszGCookie expires was not a boolean, datetime, int, or timedelta instance.Z cookie_domainzCookie domain must be a string.Zcookie_pathzCookie path must be a string.�idzSession id must be a string.rYzSession key must be a string.Zsecretz Session secret must be a string.Zvalidate_keyz%Session encrypt_key must be a string.Zencrypt_keyz&Session validate_key must be a string.Zencrypt_nonce_bitsz+Session encrypt_nonce_bits must be a numberZsecurez!Session secure must be a boolean.Zhttponlyz#Session httponly must be a boolean.�timeoutz#Session timeout must be an integer.Zsave_accessed_timez@Session save_accessed_time must be a boolean (defaults to true).�autozSession is created if accessed.Zwebtest_varnamez!Session varname must be a string.Zdata_serializerz!data_serializer must be a string.)
�secondsTz.save_accessed_time must be true to use timeout) r�rr�r rryr�rNr<r|)r��rules�optsr�rrr�coerce_session_params&
s:
























r�c
 Csbd
tt
fdfdtt
fdfdtf
dfdtt
fdfd tt
fd fdttt
fdfd tt
fdfg}
t||
�S)Nr�z3data_dir must be a string referring to a directory.r�z3lock_dir must be a string referring to a directory.r�zCache type must be a string.�enabledz&enabled must be true/false if present.�expirezNexpire must be an integer representing how many seconds the cache is valid for�regionsz7Regions must be a comma separated list of valid regions� key_lengthzUkey_length must be an integer which indicates the longest a key can be before hashing)r�rr�ryr6r�r�)r�r�rrr�coerce_cache_paramsJ
s








r�c
Cs>
d
tt
fdfdtt
fdfdt
f
dfdt
f
dfd tf
d fdt
f
dfd tt
fdfdt
f
dfdtt
fdfdt
f
dfdtt
fdfdtt
fdfdt
tfdfdtt
fdfdtt
fdfdt
f
d fd!tt
fd"fd#t
f
d$fd%t
f
d&fd't
f
d(fd)tt
fd*fd+t
f
d,fd-t
f
d.fd/tf
d0fd1t
f
d2fd3tf
d4fd5tt
fd6fd7t
f
d8fg}
t||
�S)9NZcasz#cas must be a boolean or an integerZno_blockz(no_block must be a boolean or an integerZreceive_timeoutz"receive_timeout must be an integerZsend_timeoutzsend_timeout must be an integerZketama_hashzHketama_hash must be a string designating a valid hashing strategy optionZ _poll_timeoutz _poll_timeout must be an integerZ auto_ejectzauto_eject must be an integerZ retry_timeoutz retry_timeout must be an integerZ_sort_hostsz_sort_hosts must be an integerZ_io_msg_watermarkz$_io_msg_watermark must be an integerZketamaz&ketama must be a boolean or an integerZketama_weightedz/ketama_weighted must be a boolean or an integerZ_io_key_prefetchz0_io_key_prefetch must be a boolean or an integerZ_hash_with_prefix_keyz5_hash_with_prefix_key must be a boolean or an integerZtcp_nodelayz+tcp_nodelay must be a boolean or an integerZ failure_limitz failure_limit must be an integerZbuffer_requestsz/buffer_requests must be a boolean or an integerZ_socket_send_sizez$_socket_send_size must be an integerZnum_replicasznum_replicas must be an integerZ remove_failedz remove_failed must be an integerZ_noreplyz(_noreply must be a boolean or an integerZ_io_bytes_watermarkz&_io_bytes_watermark must be an integerZ_socket_recv_sizez$_socket_recv_size must be an integer�distributionzEdistribution must be a string designating a valid distribution optionZconnect_timeoutz"connect_timeout must be an integer�hashz8hash must be a string designating a valid hashing optionZverify_keysz+verify_keys must be a boolean or an integerZdead_timeoutzdead_timeout must be an integer)r�ryr�r�)� behaviorsr�rrr�coerce_memcached_behaviorsZ
s@





























r�cCs@
|
rtd
dddd�}ni}xH|�
�D]<\}}|�d�
rF|||dd�<|�d�
r$|||dd�<q$Wt|�

d|kr�|
r�d |d<|�d d�}|�
rrE�objectrrrrkrr}r�r�r�r�r�r�r�r�r�r�rrr�r�rrrr�
sl

0
















   A
 $% .