beenull/himalaya
1
0
Fork 0
mirror of https://github.com/soywod/himalaya.git synced 2024-07-05 09:05:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

implement notmuch backend flags methods

Browse source
This commit is contained in:
Clément DOUIN 2022-03-01 14:15:15 +01:00
parent 4093d13765
commit e544536e01
No known key found for this signature in database
GPG key ID: 353E4A18EE0FAB72
1 changed files with 108 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

114
src/backends/notmuch/notmuch_backend.rs
View file

@ -288,15 +288,117 @@ impl<'a> Backend<'a> for NotmuchBackend<'a> {
Ok(())
}
fn add_flags(&mut self, _virt_mbox: &str, _id: &str, _flags: &str) -> Result<()> {
unimplemented!();
fn add_flags(&mut self, virt_mbox: &str, query: &str, tags: &str) -> Result<()> {
info!(">> add notmuch message flags");
debug!("tags: {:?}", tags);
debug!("query: {:?}", query);
let query = self
.account_config
.mailboxes
.get(virt_mbox)
.map(|s| s.as_str())
.unwrap_or(query);
debug!("final query: {:?}", query);
let tags: Vec<_> = tags.split_whitespace().collect();
let query_builder = self
.db
.create_query(query)
.with_context(|| format!("cannot create notmuch query from {:?}", query))?;
let envelopes = query_builder
.search_messages()
.with_context(|| format!("cannot find notmuch envelopes from query {:?}", query))?;
for envelope in envelopes {
for tag in tags.iter() {
envelope.add_tag(*tag).with_context(|| {
format!(
"cannot add tag {:?} to notmuch message {:?}",
tag,
envelope.id()
)
})?
}
}
info!("<< add notmuch message flags");
Ok(())
}
fn set_flags(&mut self, _virt_mbox: &str, _id: &str, _flags: &str) -> Result<()> {
unimplemented!();
fn set_flags(&mut self, virt_mbox: &str, query: &str, tags: &str) -> Result<()> {
info!(">> set notmuch message flags");
debug!("tags: {:?}", tags);
debug!("query: {:?}", query);
let query = self
.account_config
.mailboxes
.get(virt_mbox)
.map(|s| s.as_str())
.unwrap_or(query);
debug!("final query: {:?}", query);
let tags: Vec<_> = tags.split_whitespace().collect();
let query_builder = self
.db
.create_query(query)
.with_context(|| format!("cannot create notmuch query from {:?}", query))?;
let envelopes = query_builder
.search_messages()
.with_context(|| format!("cannot find notmuch envelopes from query {:?}", query))?;
for envelope in envelopes {
envelope.remove_all_tags().with_context(|| {
format!(
"cannot remove all tags from notmuch message {:?}",
envelope.id()
)
})?;
for tag in tags.iter() {
envelope.add_tag(*tag).with_context(|| {
format!(
"cannot add tag {:?} to notmuch message {:?}",
tag,
envelope.id()
)
})?
}
}
info!("<< set notmuch message flags");
Ok(())
}
fn del_flags(&mut self, _virt_mbox: &str, _id: &str, _flags: &str) -> Result<()> {
unimplemented!();
fn del_flags(&mut self, virt_mbox: &str, query: &str, tags: &str) -> Result<()> {
info!(">> delete notmuch message flags");
debug!("tags: {:?}", tags);
debug!("query: {:?}", query);
let query = self
.account_config
.mailboxes
.get(virt_mbox)
.map(|s| s.as_str())
.unwrap_or(query);
debug!("final query: {:?}", query);
let tags: Vec<_> = tags.split_whitespace().collect();
let query_builder = self
.db
.create_query(query)
.with_context(|| format!("cannot create notmuch query from {:?}", query))?;
let envelopes = query_builder
.search_messages()
.with_context(|| format!("cannot find notmuch envelopes from query {:?}", query))?;
for envelope in envelopes {
for tag in tags.iter() {
envelope.remove_tag(*tag).with_context(|| {
format!(
"cannot delete tag {:?} from notmuch message {:?}",
tag,
envelope.id()
)
})?
}
}
info!("<< delete notmuch message flags");
Ok(())
}
}