artin/OBP-API
1
0
Fork 0
mirror of https://github.com/OpenBankProject/OBP-API.git synced 2026-02-06 09:26:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

interpreting redis result

Browse Source
This commit is contained in:
simonredfern 2025-12-24 02:13:27 +01:00
parent 5d8ba8b98e
commit c96539a789
1 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
obp-api/src/main/scala/code/api/util/RateLimitingUtil.scala
View File

@ -229,7 +229,25 @@ object RateLimitingUtil extends MdcLoggable {
// get value (assuming string storage)
val valueOpt: Option[Long] = Redis.use(JedisMethod.GET, key).map(_.toLong)
((valueOpt, ttlOpt), period)
// TTL meanings:
// -2: Key does not exist
// -1: Key exists with no expiry (shouldn't happen in our rate limiting)
// >0: Seconds until key expires
val calls = ttlOpt match {
case Some(-2) => Some(0L) // Key doesn't exist -> 0 calls
case Some(ttl) if ttl <= 0 => Some(0L) // Expired or invalid -> 0 calls
case Some(_) => valueOpt.orElse(Some(0L)) // Active key -> return value or 0
case None => Some(0L) // Redis unavailable -> 0 calls
}
val normalizedTtl = ttlOpt match {
case Some(-2) => Some(0L) // Key doesn't exist -> 0 TTL
case Some(ttl) if ttl <= 0 => Some(0L) // Expired -> 0 TTL
case Some(ttl) => Some(ttl) // Active -> actual TTL
case None => Some(0L) // Redis unavailable -> 0 TTL
}
((calls, normalizedTtl), period)
}
getCallCounterForPeriod(consumerKey, RateLimitingPeriod.PER_SECOND) ::