Deuxfleurs/aerogramme
15
0
Fork 1
Code Issues 33 Pull requests 1 Projects 11 Releases 5 Wiki Activity

better name and cleanup

Browse source
This commit is contained in:
Alex 2022-07-15 17:55:04 +02:00
parent 24c6607304
commit 1f336cad2b
Signed by: lx
GPG key ID: 0E496D15096376BE
2 changed files with 10 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
src/imap/mailbox_view.rs
View file

@ -13,7 +13,7 @@ use imap_codec::types::core::{Atom, IString, NString};
use imap_codec::types::datetime::MyDateTime; use imap_codec::types::datetime::MyDateTime;
use imap_codec::types::envelope::Envelope; use imap_codec::types::envelope::Envelope;
use imap_codec::types::fetch_attributes::{ use imap_codec::types::fetch_attributes::{
FetchAttribute, MacroOrFetchAttributes, Part as FetchPart, Section as FetchSection, FetchAttribute, MacroOrFetchAttributes, Section as FetchSection,
}; };
use imap_codec::types::flag::{Flag, StoreResponse, StoreType}; use imap_codec::types::flag::{Flag, StoreResponse, StoreType};
use imap_codec::types::response::{Code, Data, MessageAttribute, Status}; use imap_codec::types::response::{Code, Data, MessageAttribute, Status};
@ -982,7 +982,7 @@ fn get_message_section<'a>(
))? ))?
.into()), .into()),
Some(FetchSection::Text(Some(part))) => { Some(FetchSection::Text(Some(part))) => {
subpart_msg_fn(parsed, part.0.as_slice(), |part_msg| { map_subpart_msg(parsed, part.0.as_slice(), |part_msg| {
Ok(part_msg Ok(part_msg
.raw_message .raw_message
.get(part_msg.offset_body..parsed.offset_end) .get(part_msg.offset_body..parsed.offset_end)
@ -993,7 +993,7 @@ fn get_message_section<'a>(
.into()) .into())
}) })
} }
Some(FetchSection::Header(part)) => subpart_msg_fn( Some(FetchSection::Header(part)) => map_subpart_msg(
parsed, parsed,
part.as_ref().map(|p| p.0.as_slice()).unwrap_or(&[]), part.as_ref().map(|p| p.0.as_slice()).unwrap_or(&[]),
|part_msg| { |part_msg| {
@ -1007,7 +1007,7 @@ fn get_message_section<'a>(
.into()) .into())
}, },
), ),
Some(FetchSection::Part(part)) => subpart_fn(parsed, part.0.as_slice(), |_msg, part| { Some(FetchSection::Part(part)) => map_subpart(parsed, part.0.as_slice(), |_msg, part| {
let bytes = match part { let bytes = match part {
MessagePart::Text(p) | MessagePart::Html(p) => p.body.as_bytes().to_vec(), MessagePart::Text(p) | MessagePart::Html(p) => p.body.as_bytes().to_vec(),
MessagePart::Binary(p) | MessagePart::InlineBinary(p) => p.body.to_vec(), MessagePart::Binary(p) | MessagePart::InlineBinary(p) => p.body.to_vec(),
@ -1023,7 +1023,7 @@ fn get_message_section<'a>(
}; };
Ok(bytes.into()) Ok(bytes.into())
}), }),
Some(FetchSection::Mime(part)) => subpart_fn(parsed, part.0.as_slice(), |msg, part| { Some(FetchSection::Mime(part)) => map_subpart(parsed, part.0.as_slice(), |msg, part| {
let raw_headers = match part { let raw_headers = match part {
MessagePart::Text(p) | MessagePart::Html(p) => &p.headers_raw, MessagePart::Text(p) | MessagePart::Html(p) => &p.headers_raw,
MessagePart::Binary(p) | MessagePart::InlineBinary(p) => &p.headers_raw, MessagePart::Binary(p) | MessagePart::InlineBinary(p) => &p.headers_raw,
@ -1044,7 +1044,7 @@ fn get_message_section<'a>(
} }
} }
fn subpart_msg_fn<'a, F, R>(msg: &Message<'a>, path: &[NonZeroU32], f: F) -> Result<R> fn map_subpart_msg<'a, F, R>(msg: &Message<'a>, path: &[NonZeroU32], f: F) -> Result<R>
where where
F: FnOnce(&Message<'_>) -> Result<R>, F: FnOnce(&Message<'_>) -> Result<R>,
{ {
@ -1059,14 +1059,14 @@ where
let part_msg = part let part_msg = part
.parse_message() .parse_message()
.ok_or(anyhow!("Cannot parse subpart: {}", path[0]))?; .ok_or(anyhow!("Cannot parse subpart: {}", path[0]))?;
subpart_msg_fn(&part_msg, &path[1..], f) map_subpart_msg(&part_msg, &path[1..], f)
} else { } else {
bail!("Subpart is not a message: {}", path[0]); bail!("Subpart is not a message: {}", path[0]);
} }
} }
} }
fn subpart_fn<'a, F, R>(msg: &Message<'a>, path: &[NonZeroU32], f: F) -> Result<R> fn map_subpart<'a, F, R>(msg: &Message<'a>, path: &[NonZeroU32], f: F) -> Result<R>
where where
F: FnOnce(&Message<'_>, &MessagePart<'_>) -> Result<R>, F: FnOnce(&Message<'_>, &MessagePart<'_>) -> Result<R>,
{ {
@ -1084,7 +1084,7 @@ where
let part_msg = part let part_msg = part
.parse_message() .parse_message()
.ok_or(anyhow!("Cannot parse subpart: {}", path[0]))?; .ok_or(anyhow!("Cannot parse subpart: {}", path[0]))?;
subpart_fn(&part_msg, &path[1..], f) map_subpart(&part_msg, &path[1..], f)
} else { } else {
bail!("Subpart is not a message: {}", path[0]); bail!("Subpart is not a message: {}", path[0]);
} }

2
src/mail/incoming.rs
View file

@ -390,7 +390,7 @@ async fn k2v_lock_loop_internal(
} }
.boxed(); .boxed();
let res = futures::try_join!(watch_lock_loop, lock_notify_loop, take_lock_loop); let _ = futures::try_join!(watch_lock_loop, lock_notify_loop, take_lock_loop);
info!("lock loop exited, releasing"); info!("lock loop exited, releasing");