diff --git a/services/commtest/tests/backup_performance_test.rs b/services/commtest/tests/backup_performance_test.rs --- a/services/commtest/tests/backup_performance_test.rs +++ b/services/commtest/tests/backup_performance_test.rs @@ -175,7 +175,39 @@ } } - // ADD ATTACHMENTS + // ADD ATTACHMENTS - LOGS + rt.block_on(async { + println!("performing ADD ATTACHMENTS - LOGS operations"); + let mut handlers = vec![]; + for (_, backup_item) in backup_data.iter().enumerate() { + let backup_item_cloned = backup_item.clone(); + for (log_index, _) in backup_item_cloned.log_items.iter().enumerate() { + let backup_item_recloned = backup_item_cloned.clone(); + let mut client_cloned = client.clone(); + handlers.push(tokio::spawn(async move { + if backup_item_recloned + .backup_item + .attachments_holders + .is_empty() + { + return (); + } + add_attachments::run( + &mut client_cloned, + &backup_item_recloned, + Some(log_index), + ) + .await + .unwrap(); + })); + } + } + + for handler in handlers { + handler.await.unwrap(); + } + }); + // PULL BACKUP }) .await