U H4fL@sddlZddlZddlZddlZddlZddlZddlZddlmZddl Z ddl Z z ddl Z Wne k rxdZ YnXe eZGdddZGdddeZGdddeZGd d d eZd d Zd dZdS)N)contextmanagerc@s eZdZdZddZddZdS)Basez Base class for caching backends.cCs tdSNNotImplementedErrorselfurlcontentr ./tmp/pip-unpacked-wheel-04z2hmy8/zeep/cache.pyaddszBase.addcCs tdSrr)rr r r r getszBase.getN)__name__ __module__ __qualname____doc__r rr r r r rsrc@s,eZdZdZddZddZeddZdS) VersionedCacheBasezuVersioned base class for caching backends. Note when subclassing a version class attribute must be provided. cCst|}|j|S)zHelper function for encoding cacheable content as base64. :param data: Content to be encoded. :rtype: bytes )base64 b64encode_version_stringrdatar r r _encode_data's zVersionedCacheBase._encode_datacCs(||jr$t|t|jdSdS)z~Helper function for decoding base64 cached content. :param data: Content to be decoded. :rtype: bytes N) startswithrr b64decodelenrr r r _decode_data/s zVersionedCacheBase._decode_datacCs0t|dddk stdd|j}t|dS)z]Expose the version prefix to be used in content serialization. :rtype: bytes _versionNzJA version must be provided in order to use the VersionedCacheBase backend.z $ZEEP:%s$ascii)getattrAssertionErrorrbytesencode)rprefixr r r r7s  z"VersionedCacheBase._version_stringN)rrrrrrpropertyrr r r r r"s rc@s.eZdZdZiZd ddZddZddZd S) InMemoryCachezDSimple in-memory caching using dict lookup with support for timeoutscCs ||_dSr)_timeout)rtimeoutr r r __init__KszInMemoryCache.__init__cCsFtd|t|ttfs.tdt|jt j |f|j |<dS)NCaching contents of %sz'a bytes-like object is required, not {}) loggerdebug isinstancestrr" TypeErrorformattyperdatetimeutcnow_cacherr r r r Ns  zInMemoryCache.addcCsTz|j|\}}Wntk r&YnXt||jsDtd||Std|dS)NCache HIT for %sCache MISS for %s)r5KeyError _is_expiredr(r,r-)rr createdr r r r rVs   zInMemoryCache.getN)r')rrrrr5r*r rr r r r r&Cs  r&c@s:eZdZdZdZd ddZeddZd d Zd d Z dS) SqliteCachez7Cache contents via a sqlite database on the filesystem.1Nr'c Csrtdkrtd|dkr tdt|_||_|r8|nt|_| }| }| d| W5QRXdS)Nz.sqlite3 module is required for the SqliteCachez:memory:zkThe SqliteCache doesn't support :memory: since it is not thread-safe. Please use zeep.cache.InMemoryCache()z CREATE TABLE IF NOT EXISTS request (created timestamp, url text, content text) ) sqlite3 RuntimeError ValueError threadingRLock_lockr(_get_default_cache_path_db_path db_connectioncursorexecutecommit)rpathr)connrFr r r r*hs  zSqliteCache.__init__c cs6|j&tj|jtjd}|V|W5QRXdS)N)Z detect_types)rBr=connectrDZPARSE_DECLTYPESclose)r connectionr r r rEszSqliteCache.db_connectionc Csdtd|||}|<}|}|d|f|dtj||f|W5QRXdS)Nr+z!DELETE FROM request WHERE url = ?ztk rX}z |jtjkrFtj|rFnW5d}~XYnXtj |dS)NZzeepFzcache.db) platformdirsuser_cache_dirosmakedirsOSErrorerrnoEEXISTrIisdirjoin)rIexcr r r rCs rC)rr3r[loggingrXr@typing contextlibrrVrQr= ImportError getLoggerrr,rrr&r;r9rCr r r r s(     ! D