aboutsummaryrefslogtreecommitdiff
path: root/src/imap/mailbox_view.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/imap/mailbox_view.rs')
-rw-r--r--src/imap/mailbox_view.rs28
1 files changed, 5 insertions, 23 deletions
diff --git a/src/imap/mailbox_view.rs b/src/imap/mailbox_view.rs
index 93d3b4d..f293bfa 100644
--- a/src/imap/mailbox_view.rs
+++ b/src/imap/mailbox_view.rs
@@ -169,29 +169,7 @@ impl MailboxView {
self.mailbox.del_flags(*uuid, &flags[..]).await?;
}
StoreType::Replace => {
- let old_flags = &self
- .known_state
- .table
- .get(uuid)
- .ok_or(anyhow!(
- "Missing message: {} (UID {}, UUID {})",
- i,
- uid,
- uuid
- ))?
- .1;
- let to_remove = old_flags
- .iter()
- .filter(|x| !flags.contains(&x))
- .cloned()
- .collect::<Vec<_>>();
- let to_add = flags
- .iter()
- .filter(|x| !old_flags.contains(&x))
- .cloned()
- .collect::<Vec<_>>();
- self.mailbox.add_flags(*uuid, &to_add[..]).await?;
- self.mailbox.del_flags(*uuid, &to_remove[..]).await?;
+ self.mailbox.set_flags(*uuid, &flags[..]).await?;
}
}
}
@@ -199,6 +177,10 @@ impl MailboxView {
self.update().await
}
+ pub async fn expunge(&mut self) -> Result<Vec<Body>> {
+ unimplemented!()
+ }
+
/// Looks up state changes in the mailbox and produces a set of IMAP
/// responses describing the new state.
pub async fn fetch(