o ]j0 @sUdZddlmZddlZddlZddlmZmZmZddl m Z ddl m Z m Z ddlmZmZedZed ZGd d d eeZdad ed <eZdaded<eZddddZddddZgdZdS)zxIn-memory TTLCache implementation using cachetools. Provides a thread-safe, TTL-based cache for storing API responses. ) annotationsN)AnyGenericTypeVar)TTLCache)Settings get_settings)DEFAULT_CACHE_TTL_SDEFAULT_EXPIRY_CACHE_TTL_Szindiaopt.cacheTc@sReZdZdZddd d ZdddZdddZd ddZd!ddZe d"ddZ dS)# MemoryCachezThread-safe TTL in-memory cache. Wraps :class:`cachetools.TTLCache` with a thread lock. Args: maxsize: Maximum number of items the cache can hold. ttl: Time-to-live for each item in seconds. N@maxsizeintttlfloatreturnNonecCs"t||d|_t|_||_dS)Nrr)r_cache threadingLock_lockr)selfrrrX/home/dinkstrade/pdmp-scanner/venv/lib/python3.10/site-packages/indiaopt/cache/memory.py__init__#s  zMemoryCache.__init__keystrT | NonecCs6|j|j|WdS1swYdS)zCGet an item from the cache. Returns ``None`` if expired or missing.N)rrgetrrrrrr!(s $zMemoryCache.getvaluer cCs6|j||j|<WddS1swYdS)zSet an item in the cache.N)rr)rrr#rrrset- "zMemoryCache.setcCs:|j|j|dWddS1swYdS)zDelete an item from the cache.N)rrpopr"rrrdelete2s"zMemoryCache.deletecCs6|j|jWddS1swYdS)zClear all items from the cache.N)rrclearrrrrr(7r%zMemoryCache.clearcCs6|jt|jjWdS1swYdS)z%Current number of items in the cache.N)rrrcurrsizer)rrrr*<s $zMemoryCache.currsizeN)r r)rrrrrr)rrrr )rrr#r rr)rrrr)rr)rr) __name__ __module__ __qualname____doc__rr!r$r'r(propertyr*rrrrr s    r zMemoryCache[Any] | None _chain_cachezMemoryCache[list[str]] | None _expiry_cachesettingsSettings | NonerMemoryCache[Any]cCdt&tdur |p t}t|dt}td|daWdtSWdtS1s+wYtS)z)Return the global option-chain TTL cache.N cache_ttlr r)_chain_cache_lockr0rgetattrr r r2srrrrget_chain_cacheK    r;MemoryCache[list[str]]cCr5)z)Return the global expiry-dates TTL cache.Nexpiry_cache_ttlir)_expiry_cache_lockr1rr8r r r9rrrget_expiry_cacheVr<r@)r r;r@)N)r2r3rr4)r2r3rr=)r. __future__rloggingrtypingrrr cachetoolsrindiaopt.config.settingsrrindiaopt.constantsr r getLoggerloggerr r r0__annotations__rr7r1r?r;r@__all__rrrrs$    +