meli
/
wasm-demo
4
Fork 0
Code Issues Pull Requests Releases Wiki Activity

imap_saync: fix max_uid invariant violation

master
Manos Pitsidianakis 2020-06-29 17:56:23 +03:00
parent adb9061adc
commit 6553d8ec44
Signed by: Manos Pitsidianakis
GPG Key ID: 73627C2F690DF710
1 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
melib/src/backends/imap_async.rs
View File

@ -702,7 +702,8 @@ impl MailBackend for ImapType {
sender: RefreshEventConsumer, sender: RefreshEventConsumer,
work_context: WorkContext, work_context: WorkContext,
) -> Result<std::thread::ThreadId> { ) -> Result<std::thread::ThreadId> {
Err(MeliError::new("Unimplemented.")) Ok(std::thread::current().id())
//Err(MeliError::new("Unimplemented."))
//unimplemented!() //unimplemented!()
/* /*
let conn = ImapConnection::new_connection(&self.server_conf, self.uid_store.clone()); let conn = ImapConnection::new_connection(&self.server_conf, self.uid_store.clone());
@ -1807,9 +1808,13 @@ async fn get_hlpr(
.insert_existing_set(envelopes.iter().map(|(_, env)| env.hash()).collect::<_>()); .insert_existing_set(envelopes.iter().map(|(_, env)| env.hash()).collect::<_>());
payload.extend(envelopes.into_iter().map(|(_, env)| env)); payload.extend(envelopes.into_iter().map(|(_, env)| env));
} }
*max_uid = Some(std::cmp::max( *max_uid = if max_uid_left == 1 {
Some(0)
} else {
Some(std::cmp::max(
std::cmp::max(max_uid_left.saturating_sub(chunk_size), 1), std::cmp::max(max_uid_left.saturating_sub(chunk_size), 1),
1, 1,
)); ))
};
Ok(payload) Ok(payload)
} }