fix: KEYS command did not exclude expired entries

cfanbo · Aug 22, 2024 · 50bffa0 · 50bffa0
1 parent 5ea55c9
commit 50bffa0
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/server.rs b/src/server.rs
@@ -802,7 +802,11 @@ impl Server {
                     for v in store.keys() {
                         let v1 = String::from_utf8(v.to_vec()).unwrap();
                         if util::match_key(&k, &v1) {
-                            result.push(OwnedFrame::BulkString(v.clone()));
+                            if let Ok(entry) = store.get_entry(v.as_slice()) {
+                                if !entry.is_expired() {
+                                    result.push(OwnedFrame::BulkString(v.clone()));
+                                }
+                            }
                         }
                     }
                     Ok(OwnedFrame::Array(result))