o tBhM@sddlZddlZddlZddlZddlZddlZddlZddlmZddl Z ddl Z zddl Z Wn e y;dZ Ynwe eZGdddZGdddeZGdddeZGd d d eZd d Zd dZdS)N)contextmanagerc@s eZdZdZddZddZdS)Basez Base class for caching backends.cCtNNotImplementedErrorselfurlcontentr a/var/www/html/riverr-enterprise-integrations-main/venv/lib/python3.10/site-packages/zeep/cache.pyaddzBase.addcCrrr)r r r r r getrzBase.getN)__name__ __module__ __qualname____doc__rrr r r r rs rc@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_stringr datar r r _encode_data's  zVersionedCacheBase._encode_datacCs(||jrt|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|dddus Jdd|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)getattrr bytesencode)r prefixr 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)r timeoutr r r __init__Ks zInMemoryCache.__init__cCsFtd|t|ttfstdt|jt j |f|j |<dS)NCaching contents of %sz'a bytes-like object is required, not {}) loggerdebug isinstancestrr# TypeErrorformattyperdatetimeutcnow_cacherr r r rNs zInMemoryCache.addcCsRz |j|\}}Wn tyYnwt||js!td||Std|dS)NCache HIT for %sCache MISS for %s)r6KeyError _is_expiredr)r-r.)r r createdr r r r rVs    zInMemoryCache.getN)r()rrrrr6r+rrr 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(cCstdurtd|dkrtdt|_||_|r|nt|_| }| }| d| WddS1s=wYdS)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)r pathr*connrGr r r r+hs    "zSqliteCache.__init__ccsN|jtj|jtjd}|V|WddS1s wYdS)N) detect_types)rCr>connectrEPARSE_DECLTYPESclose)r connectionr r r rFs "zSqliteCache.db_connectioncCsztd|||}|$}|}|d|f|dtj||f|WddS1s6wYdS)Nr,z!DELETE FROM request WHERE url = ?z ImportError getLoggerrr-rrr'r<r:rDr r r r s,     ! D