starred/rustmailer
1
0
Fork 0
mirror of https://github.com/rustmailer/rustmailer.git synced 2026-09-08 08:01:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix resync issue for empty accounts by skipping full rebuild and going straight to incremental sync

Browse Source
This commit is contained in:
rustmailer
2025-11-12 20:02:37 +08:00
parent 1ca23d30a3
commit 3e63223c81
3 changed files with 40 additions and 43 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/modules/cache/vendor/outlook/sync/rebuild.rs
Vendored
+36 -37
View File
@@ -26,29 +26,29 @@ pub async fn rebuild_cache(
let use_proxy = account.use_proxy;
OutlookFolder::batch_insert(remote_folders).await?;
for folder in remote_folders {
if folder.exists == 0 {
info!(
"Account {}: folder '{}' on the remote server has no emails. Skipping fetch for this folder.",
account.id, &folder.name
);
continue;
}
match fetch_and_save_full_folder(account, folder, folder.exists, true).await {
Ok(inserted) => {
total_inserted += inserted;
}
Err(e) => {
warn!(
if folder.exists > 0 {
match fetch_and_save_full_folder(account, folder, folder.exists, true).await {
Ok(inserted) => {
total_inserted += inserted;
}
Err(e) => {
warn!(
"Account {}: Failed to sync label '{}'. Error: {:#?}. Removing label entry.",
account.id, &folder.name, e
);
if let Err(del_err) = OutlookFolder::delete(folder.id).await {
error!(
"Account {}: Failed to delete label '{}' after sync error: {}",
account.id, &folder.name, del_err
);
if let Err(del_err) = OutlookFolder::delete(folder.id).await {
error!(
"Account {}: Failed to delete label '{}' after sync error: {}",
account.id, &folder.name, del_err
);
}
}
}
} else {
warn!(
"Account {}: folder '{}' on the remote server has no emails. Skipping fetch for this folder.",
account.id, &folder.name
);
}
let delta_link =
@@ -78,30 +78,29 @@ pub async fn rebuild_cache_since_date(
OutlookFolder::batch_insert(remote_folders).await?;
for folder in remote_folders {
if folder.exists == 0 {
info!(
"Account {}: Mailbox '{}' on the remote server has no emails. Skipping fetch for this mailbox.",
account.id, &folder.name
);
continue;
}
match fetch_and_save_since_date(account, date.as_str(), folder, true).await {
Ok(inserted) => {
total_inserted += inserted;
}
Err(e) => {
warn!(
if folder.exists > 0 {
match fetch_and_save_since_date(account, date.as_str(), folder, true).await {
Ok(inserted) => {
total_inserted += inserted;
}
Err(e) => {
warn!(
"Account {}: Failed to sync mailbox '{}'. Error: {}. Removing mailbox entry.",
account.id, &folder.name, e
);
if let Err(del_err) = OutlookFolder::delete(folder.id).await {
error!(
"Account {}: Failed to delete mailbox '{}' after sync error: {}",
account.id, &folder.name, del_err
);
if let Err(del_err) = OutlookFolder::delete(folder.id).await {
error!(
"Account {}: Failed to delete mailbox '{}' after sync error: {}",
account.id, &folder.name, del_err
);
}
}
}
} else {
warn!(
"Account {}: Mailbox '{}' on the remote server has no emails. Skipping fetch for this mailbox.",
account.id, &folder.name
);
}
let delta_link =
OutlookClient::get_delta_link(account_id, use_proxy, &folder.folder_id).await?;