#iT(%SrSSKJr SSKrSSKrSSKrSSKJr SSKJ r SSK J r \ "\ 5r 0rS\S'\R "5rSS jrSSS jjrSS jrSS jrSqS \S'SqS\S'SSjrSqS\S'SSjrSSjrSSSjjrSSjrSSjrg) zSimple cache wrapper with Redis primary and in-memory dict fallback. Tries Redis first. Falls back to an in-memory dict with TTL if Redis is unavailable or disabled. Uses JSON serialization for values. ) annotationsN)Any) get_logger) get_settingsz#dict[str, tuple[float | None, str]] _memory_storec\[ [RU5nUc SSS5 gUup#Ub*[R"5U:a[U SSS5 g[ R "U5sSSS5 $![ Ra SSS5 gf=f!,(df  g=f)z%Get a value from the in-memory store.N)_lockrgettime monotonicjsonloadsJSONDecodeError)keyentry expires_at json_values ?/root/tipsharks/tipsharks-elo-api/packages/core/common/cache.py _memory_getrs !!#& = "'  !dnn&6&Cc"  ::j) ##    s.B(BA;;BBBB B+rcUb[R"5U-OSn[ U[R"U[ S94[ U'SSS5 g!,(df  g=f)z?Set a value in the in-memory store with optional TTL (seconds).Ndefault)r r r r dumpsstrr)rvaluettlrs r _memory_setr-s@-0_$.."S($J ($**UC*HI c s #A Acp[ [RUS5 SSS5 g!,(df  g=f)z&Delete a key from the in-memory store.N)r rpop)rs r_memory_deleter 4s #t$ s' 5cl[ [R5 SSS5 g!,(df  g=f)z+Clear all entries from the in-memory store.N)r rclearr _memory_clearr%:s  s% 3 _redis_clientz bool | None_redis_availablec[SLag[b[$[5nURR(d[ R S5 SqgSSKnURURRSSSS9q[R5 [ R SS URR0S 9 Sq[$![a+n[ RS S [U50S 9 SqSnAgSnAff=f) z@Return the global Redis client, or None if unavailable/disabled.FNz@Redis caching is disabled via settings, using in-memory fallbackrT)decode_responsessocket_connect_timeoutsocket_timeoutzRedis cache backend activeurlextraz2Redis unavailable, falling back to in-memory cacheerror) r'r&rredisenabledloggerinfofrom_urlr-ping Exceptionwarningr)settings_redisexcs r_get_redis_clientr<Hs5  ~H >> ! ! VW  NN  !#$ (  ((..,,-     @CH%  ! sA/C C;!C66C;z str | None_backendcp[c*[5bSqOSq[RSS[0S9 [$)zBReturn the name of the active cache backend ('redis' or 'memory').r1memoryzCache backend resolvedbackendr.)r=r<r3r4r#r$r get_cacherAxs8   *HH ,Y4I J Or$c [5nUb,URU5nUcg[R"U5$[U5$![a4n[ R SS[U50S9 [U5sSnA$SnAff=f)zwRetrieve a value from cache. Args: key: Cache key. Returns: Deserialized value or None if missing / expired. Nz$Redis cache_get failed, falling backr0r.) r<r r rr7r3r8rr)rclientrawr;s r cache_getrEs F  $**S/C{::c? " s   $ NN6wC>Q  s# #  $s"AA B)A>8B>Bc :Uc[5RRn[5nUb+UR X[ R "U[S95 g[XU5 g![a)n[RSS[U50S9 SnAN;SnAff=f)zStore a value in cache. Args: key: Cache key. value: Value to store (must be JSON-serializable). ttl: Time-to-live in seconds. Uses ``settings.redis.ttl_seconds`` when *ttl* is ``None`` and Redis is the active backend. Nrz$Redis cache_set failed, falling backr0r.) rr1 ttl_secondsr<setexr rrr7r3r8r)rrrrCr;s r cache_setrIs {n""..  F   LL4::eS#A B  C   NN6wC>Q   s)A'' B1BBcz[5nUbURU5 g[U5 g![a Nf=f)zRemove a single key from cache.N)r<deleter7r )rrCs r cache_deleterLsB  F   MM#  3   s - ::ct[5nUbUR5 [5 g![a Nf=f)z4Flush the entire cache (both backends if available).N)r<flushdbr7r%)rCs r cache_clearrOs:  F   NN O   s * 77)rrreturn Any | None)N)rrrrrz int | NonerPNone)rrrPrR)rPrR)rPrQ)rPr)__doc__ __future__rr threadingr typingrpackages.core.common.loggingrpackages.core.common.settingsr__name__r3r__annotations__Lockr rrr r%r&r'r<r=rArErIrLrOr#r$rr\s #  36 H 2   J%  s $+$&Z* 2!2 r$