Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-04-17 21:46:35 +03:00
Code Issues Packages Projects Releases Wiki Activity

perf: make get_contacts concurrent

Browse Source 
and `get_contacts_by_ids`.

Based on hand-testing `get_contacts` with a dummy account
with 5000 dummy contacts, this very slightly increased performance.
From 1380ms to 1325ms.
This commit is contained in:
WofWca
2025-02-03 15:42:54 +04:00
parent aa82402151
commit d7a706d95b
1 changed files with 16 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
deltachat-jsonrpc/src/api.rs
View File

@@ -1396,17 +1396,13 @@ impl CommandApi {
) -> Result<Vec<ContactObject>> {
let ctx = self.get_context(account_id).await?;
let contact_ids = Contact::get_all(&ctx, list_flags, query.as_deref()).await?;
let mut contacts: Vec<ContactObject> = Vec::with_capacity(contact_ids.len());
for id in contact_ids {
contacts.push(
ContactObject::try_from_dc_contact(
&ctx,
deltachat::contact::Contact::get_by_id(&ctx, id).await?,
)
.await?,
);
}
Ok(contacts)
let ctx_ref = &ctx;
return futures::future::try_join_all(contact_ids.into_iter().map(|id| async move {
let contact = deltachat::contact::Contact::get_by_id(ctx_ref, id).await?;
let contact_object = ContactObject::try_from_dc_contact(ctx_ref, contact).await?;
Ok(contact_object)
}))
.await;
}
async fn get_contacts_by_ids(
@@ -1416,18 +1412,15 @@ impl CommandApi {
) -> Result<HashMap<u32, ContactObject>> {
let ctx = self.get_context(account_id).await?;
let mut contacts = HashMap::with_capacity(ids.len());
for id in ids {
contacts.insert(
id,
ContactObject::try_from_dc_contact(
&ctx,
deltachat::contact::Contact::get_by_id(&ctx, ContactId::new(id)).await?,
)
.await?,
);
}
Ok(contacts)
let ctx_ref = &ctx;
return futures::future::try_join_all(ids.into_iter().map(|id| async move {
let contact =
deltachat::contact::Contact::get_by_id(ctx_ref, ContactId::new(id)).await?;
let contact_object = ContactObject::try_from_dc_contact(ctx_ref, contact).await?;
Ok((id, contact_object))
}))
.await
.map(|vec| vec.into_iter().collect());
}
async fn delete_contact(&self, account_id: u32, contact_id: u32) -> Result<()> {