@@ -309,21 +309,27 @@ impl WalletDatabase for CashuKvDatabase {
309309 let mint_key = Self :: generate_mint_key ( & mint_url) ;
310310
311311 // Remove mint URL by writing empty data
312- KVStore :: remove ( self . store . as_ref ( ) , CASHU_PRIMARY_KEY , MINTS_KEY , & mint_key)
312+ KVStore :: remove ( self . store . as_ref ( ) , CASHU_PRIMARY_KEY , MINTS_KEY , & mint_key, false )
313313 . await
314314 . map_err ( DatabaseError :: Io ) ?;
315315
316316 // Remove mint info
317317 let info_key = Self :: generate_mint_info_key ( & mint_url) ;
318- KVStore :: remove ( self . store . as_ref ( ) , CASHU_PRIMARY_KEY , MINTS_KEY , & info_key)
318+ KVStore :: remove ( self . store . as_ref ( ) , CASHU_PRIMARY_KEY , MINTS_KEY , & info_key, false )
319319 . await
320320 . map_err ( DatabaseError :: Io ) ?;
321321
322322 // Remove mint keysets
323323 let keysets_key = Self :: generate_mint_keysets_key ( & mint_url) ;
324- KVStore :: remove ( self . store . as_ref ( ) , CASHU_PRIMARY_KEY , MINT_KEYSETS_KEY , & keysets_key)
325- . await
326- . map_err ( DatabaseError :: Io ) ?;
324+ KVStore :: remove (
325+ self . store . as_ref ( ) ,
326+ CASHU_PRIMARY_KEY ,
327+ MINT_KEYSETS_KEY ,
328+ & keysets_key,
329+ false ,
330+ )
331+ . await
332+ . map_err ( DatabaseError :: Io ) ?;
327333
328334 // Update cache
329335 {
@@ -580,7 +586,7 @@ impl WalletDatabase for CashuKvDatabase {
580586
581587 async fn remove_mint_quote ( & self , quote_id : & str ) -> Result < ( ) , Self :: Err > {
582588 // Mark as removed by writing empty data
583- KVStore :: remove ( self . store . as_ref ( ) , CASHU_PRIMARY_KEY , MINT_QUOTES_KEY , quote_id)
589+ KVStore :: remove ( self . store . as_ref ( ) , CASHU_PRIMARY_KEY , MINT_QUOTES_KEY , quote_id, false )
584590 . await
585591 . map_err ( DatabaseError :: Io ) ?;
586592
@@ -637,7 +643,7 @@ impl WalletDatabase for CashuKvDatabase {
637643 }
638644
639645 async fn remove_melt_quote ( & self , quote_id : & str ) -> Result < ( ) , Self :: Err > {
640- KVStore :: remove ( self . store . as_ref ( ) , CASHU_PRIMARY_KEY , MELT_QUOTES_KEY , quote_id)
646+ KVStore :: remove ( self . store . as_ref ( ) , CASHU_PRIMARY_KEY , MELT_QUOTES_KEY , quote_id, false )
641647 . await
642648 . map_err ( DatabaseError :: Io ) ?;
643649
@@ -682,7 +688,7 @@ impl WalletDatabase for CashuKvDatabase {
682688 async fn remove_keys ( & self , id : & Id ) -> Result < ( ) , Self :: Err > {
683689 let key = id. to_string ( ) ;
684690
685- KVStore :: remove ( self . store . as_ref ( ) , CASHU_PRIMARY_KEY , KEYS_KEY , & key)
691+ KVStore :: remove ( self . store . as_ref ( ) , CASHU_PRIMARY_KEY , KEYS_KEY , & key, false )
686692 . await
687693 . map_err ( DatabaseError :: Io ) ?;
688694
@@ -707,7 +713,7 @@ impl WalletDatabase for CashuKvDatabase {
707713 for y in & removed_ys {
708714 let key = format ! ( "proof_{}" , hex:: encode( y. serialize( ) ) ) ;
709715
710- KVStore :: remove ( self . store . as_ref ( ) , CASHU_PRIMARY_KEY , PROOFS_KEY , & key)
716+ KVStore :: remove ( self . store . as_ref ( ) , CASHU_PRIMARY_KEY , PROOFS_KEY , & key, false )
711717 . await
712718 . map_err ( DatabaseError :: Io ) ?;
713719 }
@@ -913,7 +919,7 @@ impl WalletDatabase for CashuKvDatabase {
913919 async fn remove_transaction ( & self , transaction_id : TransactionId ) -> Result < ( ) , Self :: Err > {
914920 let key = transaction_id. to_string ( ) ;
915921
916- KVStore :: remove ( self . store . as_ref ( ) , CASHU_PRIMARY_KEY , TRANSACTIONS_KEY , & key)
922+ KVStore :: remove ( self . store . as_ref ( ) , CASHU_PRIMARY_KEY , TRANSACTIONS_KEY , & key, false )
917923 . await
918924 . map_err ( DatabaseError :: Io ) ?;
919925
0 commit comments