diff options
author | Quentin Dufour <quentin@deuxfleurs.fr> | 2023-12-19 19:02:22 +0100 |
---|---|---|
committer | Quentin Dufour <quentin@deuxfleurs.fr> | 2023-12-19 19:02:22 +0100 |
commit | c75f2d91ff969dd791cb476031ee80870c6ad61a (patch) | |
tree | b8da577a6a932d82a28d29b7ab98f9cc696d4ff5 /src/mail/mailbox.rs | |
parent | 3d41f40dc8cd6bdfa7a9279ab1959564d06eefaf (diff) | |
download | aerogramme-c75f2d91ff969dd791cb476031ee80870c6ad61a.tar.gz aerogramme-c75f2d91ff969dd791cb476031ee80870c6ad61a.zip |
implemented an in memory storage
Diffstat (limited to 'src/mail/mailbox.rs')
-rw-r--r-- | src/mail/mailbox.rs | 7 |
1 files changed, 6 insertions, 1 deletions
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>(()) } )?; |