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

cargo fmt

Browse Source
This commit is contained in:
holger krekel
2019-09-23 20:38:27 +02:00
parent 4d6b367654
commit 21c9ff6c85
1 changed files with 87 additions and 88 deletions
Download Patch File Download Diff File Expand all files Collapse all files

161
src/job.rs
View File

@@ -215,43 +215,43 @@ impl Job {
return; return;
} }
} }
if let Ok(msg) = Message::load_from_db(context, self.foreign_id) { if let Ok(msg) = Message::load_from_db(context, self.foreign_id) {
if context if context
.sql .sql
.get_config_int(context, "folders_configured") .get_config_int(context, "folders_configured")
.unwrap_or_default() .unwrap_or_default()
< 3 < 3
{ {
inbox.configure_folders(context, 0x1i32); inbox.configure_folders(context, 0x1i32);
} }
let dest_folder = context.sql.get_config(context, "configured_mvbox_folder"); let dest_folder = context.sql.get_config(context, "configured_mvbox_folder");
if let Some(dest_folder) = dest_folder { if let Some(dest_folder) = dest_folder {
let server_folder = msg.server_folder.as_ref().unwrap(); let server_folder = msg.server_folder.as_ref().unwrap();
let mut dest_uid = 0; let mut dest_uid = 0;
match inbox.mv( match inbox.mv(
context, context,
server_folder, server_folder,
msg.server_uid, msg.server_uid,
&dest_folder, &dest_folder,
&mut dest_uid, &mut dest_uid,
) { ) {
ImapResult::RetryLater => { ImapResult::RetryLater => {
self.try_again_later(3i32, None); self.try_again_later(3i32, None);
}
ImapResult::Success => {
message::update_server_uid(
context,
&msg.rfc724_mid,
&dest_folder,
dest_uid,
);
}
ImapResult::Failed | ImapResult::AlreadyDone => {}
} }
ImapResult::Success => {
message::update_server_uid(
context,
&msg.rfc724_mid,
&dest_folder,
dest_uid,
);
}
ImapResult::Failed | ImapResult::AlreadyDone => {}
} }
} }
}
} }
#[allow(non_snake_case)] #[allow(non_snake_case)]
@@ -278,15 +278,14 @@ impl Job {
return; return;
} }
} }
let mid = msg.rfc724_mid; let mid = msg.rfc724_mid;
let server_folder = msg.server_folder.as_ref().unwrap(); let server_folder = msg.server_folder.as_ref().unwrap();
if 0 == inbox.delete_msg(context, &mid, server_folder, &mut msg.server_uid) if 0 == inbox.delete_msg(context, &mid, server_folder, &mut msg.server_uid) {
{ self.try_again_later(-1i32, None);
self.try_again_later(-1i32, None); return;
return; }
}
} }
Message::delete_from_db(context, msg.id); Message::delete_from_db(context, msg.id);
} }
} }
} }
@@ -302,35 +301,35 @@ impl Job {
return; return;
} }
} }
if let Ok(msg) = Message::load_from_db(context, self.foreign_id) { if let Ok(msg) = Message::load_from_db(context, self.foreign_id) {
let server_folder = msg.server_folder.as_ref().unwrap(); let server_folder = msg.server_folder.as_ref().unwrap();
match inbox.set_seen(context, server_folder, msg.server_uid) { match inbox.set_seen(context, server_folder, msg.server_uid) {
ImapResult::Failed => {} ImapResult::Failed => {}
ImapResult::RetryLater => { ImapResult::RetryLater => {
self.try_again_later(3i32, None); self.try_again_later(3i32, None);
} }
_ => { _ => {
if 0 != msg.param.get_int(Param::WantsMdn).unwrap_or_default() if 0 != msg.param.get_int(Param::WantsMdn).unwrap_or_default()
&& 0 != context && 0 != context
.sql .sql
.get_config_int(context, "mdns_enabled") .get_config_int(context, "mdns_enabled")
.unwrap_or_else(|| 1) .unwrap_or_else(|| 1)
{ {
let folder = msg.server_folder.as_ref().unwrap(); let folder = msg.server_folder.as_ref().unwrap();
match inbox.set_mdnsent(context, folder, msg.server_uid) { match inbox.set_mdnsent(context, folder, msg.server_uid) {
ImapResult::RetryLater => { ImapResult::RetryLater => {
self.try_again_later(3i32, None); self.try_again_later(3i32, None);
}
ImapResult::Success => {
send_mdn(context, msg.id);
}
ImapResult::Failed | ImapResult::AlreadyDone => {}
} }
ImapResult::Success => {
send_mdn(context, msg.id);
}
ImapResult::Failed | ImapResult::AlreadyDone => {}
} }
} }
} }
} }
}
} }
#[allow(non_snake_case)] #[allow(non_snake_case)]
@@ -350,28 +349,28 @@ impl Job {
return; return;
} }
} }
if inbox.set_seen(context, &folder, uid) == ImapResult::Failed { if inbox.set_seen(context, &folder, uid) == ImapResult::Failed {
self.try_again_later(3i32, None); self.try_again_later(3i32, None);
}
if 0 != self.param.get_int(Param::AlsoMove).unwrap_or_default() {
if context
.sql
.get_config_int(context, "folders_configured")
.unwrap_or_default()
< 3
{
inbox.configure_folders(context, 0x1i32);
} }
if 0 != self.param.get_int(Param::AlsoMove).unwrap_or_default() { let dest_folder = context.sql.get_config(context, "configured_mvbox_folder");
if context if let Some(dest_folder) = dest_folder {
.sql let mut dest_uid = 0;
.get_config_int(context, "folders_configured") if ImapResult::RetryLater
.unwrap_or_default() == inbox.mv(context, folder, uid, dest_folder, &mut dest_uid)
< 3
{ {
inbox.configure_folders(context, 0x1i32); self.try_again_later(3, None);
}
let dest_folder = context.sql.get_config(context, "configured_mvbox_folder");
if let Some(dest_folder) = dest_folder {
let mut dest_uid = 0;
if ImapResult::RetryLater
== inbox.mv(context, folder, uid, dest_folder, &mut dest_uid)
{
self.try_again_later(3, None);
}
} }
} }
}
} }
} }