o g@sddlZddlZddlZddlZddlZddlZddlmZddlm Z m Z m Z ddl Z ddl Z zddlZWn eyAdZYnweeZGdddZGdddeZGdd d eZGd d d eZd d ZddZdS)N)contextmanager)DictTupleUnionc@s eZdZdZddZddZdS)Basez Base class for caching backends.cCtNNotImplementedErrorselfurlcontentrC/home/ubuntu/webapp/venv/lib/python3.10/site-packages/zeep/cache.pyaddzBase.addcCrrr )r r rrrgetrzBase.getN)__name__ __module__ __qualname____doc__rrrrrrrs 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 datarrr _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 b64decodelenrrrr _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 prefixrrrr7s  z"VersionedCacheBase._version_stringN)rrrrrr"propertyrrrrrr"s rc@sReZdZUdZiZeeeeje e efffe d<d ddZ ddZ dd Zd S) InMemoryCachezDSimple in-memory caching using dict lookup with support for timeouts_cachecCs ||_dSr)_timeout)r timeoutrrr__init__Is zInMemoryCache.__init__cCsLtd|t|ttfstdt|jt j t j j |f|j |<dS)NCaching contents of %sz'a bytes-like object is required, not {})loggerdebug isinstancestrr& TypeErrorformattyperdatetimenowtimezoneutcr+r rrrrLs zInMemoryCache.addcCsRz |j|\}}Wn tyYnwt||js!td||Std|dS)NCache HIT for %sCache MISS for %s)r+KeyError _is_expiredr-r1r2)r r createdrrrrrTs    zInMemoryCache.getN)r,)rrrrr+rr4rr8rr&__annotations__r/rrrrrrr*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.connrMrrrr/fs    "zSqliteCache.__init__ccsVtsJ|jtj|jtjd}|V|WddS1s$wYdS)N) detect_types)rDrIconnectrKPARSE_DECLTYPESclose)r connectionrrrrLs "zSqliteCache.db_connectioncCstd|||}|'}|}|d|f|dtjtjj ||f| WddS1s9wYdS)Nr0z!DELETE FROM request WHERE url = ?zs,     !F