o Wli %@sZdZddlZddlmZddlmZGdddeeZGdddeZGd d d eZdS) z flask_caching.backends.rediscache ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ The redis caching backend. :copyright: (c) 2018 by Peter Justin. :copyright: (c) 2010 by Thadeus Burgess. :license: BSD, see LICENSE for more details. N) RedisCache) BaseCachec@sJeZdZdZ      dddZed d Zd d Zd dZddZ dS)raUses the Redis key-value store as a cache backend. The first argument can be either a string denoting address of the Redis server or an object resembling an instance of a redis.Redis class. Note: Python Redis API already takes care of encoding unicode strings on the fly. :param host: address of the Redis server or an object which API is compatible with the official Python Redis client (redis-py). :param port: port number on which Redis server listens for connections. :param password: password authentication for the Redis server. :param db: db (zero-based numeric index) on Redis Server to connect. :param default_timeout: the default timeout that is used if no timeout is specified on :meth:`~BaseCache.set`. A timeout of 0 indicates that the cache never expires. :param key_prefix: A prefix that should be added to all keys. Any additional keyword arguments will be passed to ``redis.Redis``. localhostNr,c Ks2tj||dtj|f||||||d|dS)N)default_timeout)hostportpassworddbr key_prefix)r__init__CachelibRedisCache)selfrr r r rr kwargsrq/var/www/html/tatsat2dev/dashboard-backend/venv/lib/python3.10/site-packages/flask_caching/backends/rediscache.pyr (s  zRedisCache.__init__c Cszddlm}Wnty}ztd|d}~ww|t|dd|dd|ddd |d }|r;||d <|d }|rF||d <|d} | rY|| |ddd|d<||i|} | S)Nr)from_urlno redis module foundCACHE_REDIS_HOSTrCACHE_REDIS_PORTrCACHE_REDIS_DB)rr r CACHE_REDIS_PASSWORDr CACHE_KEY_PREFIXr CACHE_REDIS_URLr )r r)redisr ImportError RuntimeErrorupdatedictgetpop) clsappconfigargsrredis_from_urler r redis_url new_classrrrfactory>s0       zRedisCache.factorycCst|jtr |jS|S)N) isinstancer strrrrr _get_prefix\szRedisCache._get_prefixcCs,t|}|tkrt|dSdt|S)zDumps an object into a string for redis. By default it serializes integers as regular string and pickle dumps everything else. ascii!)typeintr,encodepickledumps)rvaluetrrr dump_objectaszRedisCache.dump_objectcsV|sdSjrfdd|D}tjdd}|dur%t|r%jj|Sjj|S)z= 3.0.0 and redis > 4, support this operationNcsg|]}j|qSr)r ).0keyr-rr oz%RedisCache.unlink..unlink)r getattr _write_clientcallabler=delete)rkeysr=rr-rr=js  zRedisCache.unlink)rrNrrN) __name__ __module__ __qualname____doc__r classmethodr*r.r8r=rrrrrs   rcs:eZdZdZ      d fdd Zedd ZZS) RedisSentinelCacheaUses the Redis key-value store as a cache backend. The first argument can be either a string denoting address of the Redis server or an object resembling an instance of a redis.Redis class. Note: Python Redis API already takes care of encoding unicode strings on the fly. :param sentinels: A list or a tuple of Redis sentinel addresses. :param master: The name of the master server in a sentinel configuration. :param password: password authentication for the Redis server. :param db: db (zero-based numeric index) on Redis Server to connect. :param default_timeout: the default timeout that is used if no timeout is specified on :meth:`~BaseCache.set`. A timeout of 0 indicates that the cache never expires. :param key_prefix: A prefix that should be added to all keys. Any additional keyword arguments will be passed to ``redis.sentinel.Sentinel``. Nrrc stj||dzddl}Wnty} ztd| d} ~ ww|ddr*td|p.dg}dd|D} d d|D}|jj d |||| d |} | ||_ | ||_ dS) Nr rrrdecode_responses0decode_responses is not supported by RedisCache.z 127.0.0.1i gcSs(i|]\}}|dr|dd|qS) sentinel_ N startswithr9r:r6rrr s  z/RedisSentinelCache.__init__..cSs i|] \}}|ds||qS)rNrPrRrrrrSs ) sentinelsr r sentinel_kwargsr)superr redis.sentinelrrr ValueErroritemssentinelSentinel master_forr? slave_for _read_client) rrTmasterr r rr rrr'rUrZ __class__rrr s4      zRedisSentinelCache.__init__c CsZ|t|ddg|dd|dd|dd|dd|dd d ||i|S) NCACHE_REDIS_SENTINELSrMCACHE_REDIS_SENTINEL_MASTERmymasterrCACHE_REDIS_SENTINEL_PASSWORDrrr)rTr_r sentinel_passwordr r rrr r"r#r$r%rrrrr*s       zRedisSentinelCache.factory)NNNrrrIrCrDrErFr rGr* __classcell__rrr`rrHws+rHcs0eZdZdZ dfdd ZeddZZS) RedisClusterCacheaUses the Redis key-value store as a cache backend. The first argument can be either a string denoting address of the Redis server or an object resembling an instance of a rediscluster.RedisCluster class. Note: Python Redis API already takes care of encoding unicode strings on the fly. :param cluster: The redis cluster nodes address separated by comma. e.g. host1:port1,host2:port2,host3:port3 . :param password: password authentication for the Redis server. :param default_timeout: the default timeout that is used if no timeout is specified on :meth:`~BaseCache.set`. A timeout of 0 indicates that the cache never expires. :param key_prefix: A prefix that should be added to all keys. Any additional keyword arguments will be passed to ``rediscluster.RedisCluster``. rIrc stj||d|ddrtdzddlm}ddlmWnty1}zt d|d}~wwzdd | d D}fd d |D} Wnt yX}ztd |d}~ww| d d} |d| || d|}||_ ||_dS)NrJrKrLr) RedisCluster ClusterNodezno redis.cluster module foundcSsg|]}|dqS):)splitr9noderrrr;r<z.RedisClusterCache.__init__..,cs&g|]}|d|dqS)r)striprqrmrrr;szQPlease give the correct cluster argument e.g. host1:port1,host2:port2,host3:port3skip_full_coverage_checkT) startup_nodesr rvr)rVr r rXrrl redis.clusterrnrrrp IndexErrorr!r?r^) rclusterr rr rrlr'nodesrwrvr`rmrr sB       zRedisClusterCache.__init__c CsD|t|dd|dd|dd|ddd||i|S)NCACHE_REDIS_CLUSTERrIrCACHE_DEFAULT_TIMEOUTrr)rzr rr rgrhrrrr*s    zRedisClusterCache.factory)rIrIrrIrirrr`rrks 'rk) rFr4cachelibrrflask_caching.backends.baserrHrkrrrrs  eR