Temp fix for add_counter on InMem store

Kuadrant · Mar 14, 2024 · d00d91f · d00d91f
1 parent 98d6b4f
commit d00d91f
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/limitador/src/storage/redis/redis_lenient.rs b/limitador/src/storage/redis/redis_lenient.rs
@@ -62,6 +62,7 @@ impl AsyncCounterStorage for RedisLenient {
         counter_access: CounterAccess<'a>,
     ) -> Result<Authorization, StorageErr> {
         if self.is_partitioned() {
+            let _ = self.fallback.add_counter(counters[0].limit()).unwrap();
             self.fallback
                 .check_and_update(counters, delta, load_counters)
         } else {
@@ -71,6 +72,7 @@ impl AsyncCounterStorage for RedisLenient {
                 .or_else(|err| {
                     if err.is_transient() {
                         self.partitioned(true);
+                        let _ = self.fallback.add_counter(counters[0].limit()).unwrap();
                         self.fallback
                             .check_and_update(counters, delta, load_counters)
                     } else {
@@ -147,6 +149,7 @@ impl RedisLenient {
                 interval.tick().await;
                 if self.is_partitioned() {
                     let partitioned = !self.redis.is_alive().await;
+                    println!("Partitioned! Testing… Fine? {}", !partitioned);
                     self.partitioned(partitioned);
                 }
             }