implemented an in memory storage

2 files changed, 7 insertions, 2 deletions

diff --git a/src/mail/incoming.rs b/src/mail/incoming.rs
index f6b831d..2a6c947 100644
--- a/src/mail/incoming.rs
+++ b/src/mail/incoming.rs
@@ -386,7 +386,7 @@ async fn k2v_lock_loop_internal(
         _ => None,
     };
     if let Some(ct) = release {
-        match storage.row_rm(&storage::Selector::Single(&ct)).await {
+        match storage.row_rm_single(&ct).await {
             Err(e) => warn!("Unable to release lock {:?}: {}", ct, e),
             Ok(_) => (),
         };
diff --git a/src/mail/mailbox.rs b/src/mail/mailbox.rs
index b4afd5e..65f44b1 100644
--- a/src/mail/mailbox.rs
+++ b/src/mail/mailbox.rs
@@ -361,7 +361,12 @@ impl MailboxInternal {
             async {
                 // Delete mail meta from K2V
                 let sk = ident.to_string();
-                self.storage.row_rm(&Selector::Single(&RowRef::new(&self.mail_path, &sk))).await?;
+                let res = self.storage
+                    .row_fetch(&storage::Selector::Single(&RowRef::new(&self.mail_path, &sk)))
+                    .await?;
+                if let Some(row_val) = res.into_iter().next() {
+                    self.storage.row_rm_single(&row_val.row_ref).await?;
+                }
                 Ok::<_, anyhow::Error>(())
             }
         )?;