mirror of
https://github.com/chatmail/core.git
synced 2026-05-02 04:46:29 +03:00
more functional
This commit is contained in:
@@ -911,25 +911,24 @@ impl MimeMessage {
|
|||||||
.contains("daemon")
|
.contains("daemon")
|
||||||
&& self.failure_report.is_none()
|
&& self.failure_report.is_none()
|
||||||
{
|
{
|
||||||
for line in self
|
lazy_static! {
|
||||||
|
static ref RE: regex::Regex = regex::Regex::new(r"Message-ID:(.*)").unwrap();
|
||||||
|
}
|
||||||
|
for captures in self
|
||||||
.parts
|
.parts
|
||||||
.iter()
|
.iter()
|
||||||
.filter_map(|p| p.msg_raw.as_ref())
|
.filter_map(|part| part.msg_raw.as_ref())
|
||||||
.flat_map(|p| p.lines())
|
.flat_map(|part| part.lines())
|
||||||
|
.filter_map(|line| RE.captures(line))
|
||||||
{
|
{
|
||||||
lazy_static! {
|
if let Ok(original_message_id) = parse_message_id(&captures[1]) {
|
||||||
static ref RE: regex::Regex = regex::Regex::new(r"Message-ID:(.*)").unwrap();
|
if let Ok(Some(_)) =
|
||||||
}
|
message::rfc724_mid_exists(context, &original_message_id).await
|
||||||
if let Some(c) = RE.captures(line) {
|
{
|
||||||
if let Ok(original_message_id) = parse_message_id(&c[1]) {
|
self.failure_report = Some(FailureReport {
|
||||||
if let Ok(Some(_)) =
|
rfc724_mid: original_message_id,
|
||||||
message::rfc724_mid_exists(context, &original_message_id).await
|
failed_recipient: None,
|
||||||
{
|
})
|
||||||
self.failure_report = Some(FailureReport {
|
|
||||||
rfc724_mid: original_message_id,
|
|
||||||
failed_recipient: None,
|
|
||||||
})
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user