Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-05-16 13:26:38 +03:00
Code Issues Packages Projects Releases Wiki Activity

refactor: use SQL transaction in MsgId.delete_from_db()

Browse Source
This commit is contained in:
link2xt
2023-07-23 11:59:03 +00:00
parent 8ed6d4d709
commit 8eee389c09
1 changed files with 7 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/message.rs
View File

@@ -114,23 +114,15 @@ WHERE id=?;
/// Deletes a message, corresponding MDNs and unsent SMTP messages from the database. /// Deletes a message, corresponding MDNs and unsent SMTP messages from the database.
pub(crate) async fn delete_from_db(self, context: &Context) -> Result<()> { pub(crate) async fn delete_from_db(self, context: &Context) -> Result<()> {
// We don't use transactions yet, so remove MDNs first to make
// sure they are not left while the message is deleted.
context context
.sql .sql
.execute("DELETE FROM smtp WHERE msg_id=?", (self,)) .transaction(move |transaction| {
.await?; transaction.execute("DELETE FROM smtp WHERE msg_id=?", (self,))?;
context transaction.execute("DELETE FROM msgs_mdns WHERE msg_id=?", (self,))?;
.sql transaction.execute("DELETE FROM msgs_status_updates WHERE msg_id=?", (self,))?;
.execute("DELETE FROM msgs_mdns WHERE msg_id=?;", (self,)) transaction.execute("DELETE FROM msgs WHERE id=?", (self,))?;
.await?; Ok(())
context })
.sql
.execute("DELETE FROM msgs_status_updates WHERE msg_id=?;", (self,))
.await?;
context
.sql
.execute("DELETE FROM msgs WHERE id=?;", (self,))
.await?; .await?;
Ok(()) Ok(())
} }