chore: concurrently fetch picture and banner

Satellite-im · Dec 12, 2024 · c76b33a · c76b33a
1 parent 6e29389
commit c76b33a
Showing 1 changed file with 10 additions and 6 deletions.
diff --git a/extensions/warp-ipfs/src/store/document.rs b/extensions/warp-ipfs/src/store/document.rs
@@ -442,7 +442,7 @@ impl RootDocument {
     }
 }
 
-async fn resolve_to_img_doc(ipfs: &Ipfs, cid: Cid) -> Result<(), Error> {
+async fn resolve_to_img_doc(ipfs: Ipfs, cid: Cid) -> Result<(), Error> {
     let dag: ImageDag = ipfs.get_dag(cid).deserialized().await?;
     if dag.size > MAX_IMAGE_SIZE as _ {
         return Err(Error::InvalidLength {
@@ -469,19 +469,23 @@ async fn resolve_verify_image(ipfs: &Ipfs, identity_document: &IdentityDocument)
             .profile_picture
             .ok_or(Error::Other),
     )
-    .and_then(|cid| async move { resolve_to_img_doc(ipfs, cid).await })
-    .await;
+    .and_then(|cid| {
+        let ipfs = ipfs.clone();
+        async move { resolve_to_img_doc(ipfs, cid).await }
+    });
 
     let _fut_banner = futures::future::ready(
         identity_document
             .metadata
             .profile_banner
             .ok_or(Error::Other),
     )
-    .and_then(|cid| async move { resolve_to_img_doc(ipfs, cid).await })
-    .await;
+    .and_then(|cid| {
+        let ipfs = ipfs.clone();
+        async move { resolve_to_img_doc(ipfs, cid).await }
+    });
 
-    // _ = tokio::join!(fut_picture, fut_banner);
+    _ = tokio::join!(_fut_picture, _fut_banner);
 }
 
 #[derive(Clone, Debug, Deserialize, Serialize, PartialEq, Eq)]