Fix loop when fetching pending messages

Exclude lower band from redis range
mozilla-services · Dec 22, 2024 · 837ee58 · 837ee58
1 parent 30e497a
commit 837ee58
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/autopush-common/src/db/redis/redis_client/mod.rs b/autopush-common/src/db/redis/redis_client/mod.rs
@@ -459,10 +459,11 @@ impl DbClient for RedisClientImpl {
         trace!("🐰 Fecthing {} messages since {:?}", limit, timestamp);
         let mut con = self.connection().await?;
         let msg_list_key = self.message_list_key(&uaid);
+        // ZRANGE Key (x +inf LIMIT 0 limit
         let (messages_id, mut scores): (Vec<String>, Vec<u64>) = con
-            .zrangebyscore_limit_withscores::<&str, u64, &str, Vec<(String, u64)>>(
+            .zrangebyscore_limit_withscores::<&str, &str, &str, Vec<(String, u64)>>(
                 &msg_list_key,
-                timestamp.unwrap_or(0),
+                &format!("({}", timestamp.unwrap_or(0)),
                 "+inf",
                 0,
                 limit as isize,