fix: resume token should return previous (not 0) when nothing found (#…

…265)
ceramicnetwork · Feb 8, 2024 · 41fa8a8 · 41fa8a8
1 parent 22eab7e
commit 41fa8a8
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/store/src/sqlite/model.rs b/store/src/sqlite/model.rs
@@ -426,7 +426,7 @@ where
         let row_id: i64 = rows
             .first()
             .and_then(|r| r.get("new_highwater_mark"))
-            .unwrap_or(0);
+            .unwrap_or(row_id);
         let rows = rows
             .into_iter()
             .map(|row| {
@@ -1378,7 +1378,11 @@ mod test {
 
         let (hw, res) = store.new_keys_since_value_rowid(hw, 1).await.unwrap();
         assert_eq!(1, res.len());
-        assert_eq!(22, hw); // see comment in prep_highwater_tests
+        assert_eq!(22, hw);
         assert_eq!([key_c], res.as_slice());
+
+        let (hw, res) = store.new_keys_since_value_rowid(hw, 1).await.unwrap();
+        assert_eq!(0, res.len());
+        assert_eq!(22, hw); // previously returned 0
     }
 }