wip feat: provide only root, and only at the end of add

We are still waiting for the add to complete

iroh-api/src/api.rs

@@ -7,6 +7,7 @@ use crate::p2p::MockP2p;
 use crate::p2p::{ClientP2p, P2p};
 use crate::{AddEvent, IpfsPath};
 use anyhow::Result;
+use cid::Cid;
 use futures::future::{BoxFuture, LocalBoxFuture};
 use futures::stream::LocalBoxStream;
 use futures::FutureExt;
@@ -40,6 +41,8 @@ pub trait Api {
 
     fn p2p(&self) -> Result<Self::P>;
 
+    fn provide(&self, cid: Cid) -> LocalBoxFuture<'_, Result<()>>;
+
     /// Produces a asynchronous stream of file descriptions
     /// Each description is a tuple of a relative path, and either a `Directory` or a `Reader`
     /// with the file contents.
@@ -100,6 +103,10 @@ impl Iroh {
 impl Api for Iroh {
     type P = ClientP2p;
 
+    fn provide(&self, cid: Cid) -> LocalBoxFuture<'_, Result<()>> {
+        async move { self.client.try_p2p()?.start_providing(&cid).await }.boxed_local()
+    }
+
     fn p2p(&self) -> Result<ClientP2p> {
         let p2p_client = self.client.try_p2p()?;
         Ok(ClientP2p::new(p2p_client))

iroh-resolver/src/unixfs_builder.rs

@@ -521,8 +521,9 @@ impl Store for StoreAndProvideClient {
     }
 
     async fn put(&self, cid: Cid, blob: Bytes, links: Vec<Cid>) -> Result<()> {
-        self.client.try_store()?.put(cid, blob, links).await?;
-        self.client.try_p2p()?.start_providing(&cid).await
+        self.client.try_store()?.put(cid, blob, links).await
+        // we provide after insertion is finished
+        // self.client.try_p2p()?.start_providing(&cid).await
     }
 }
 

iroh/src/run.rs

@@ -1,7 +1,7 @@
 use std::collections::HashMap;
 use std::path::{Path, PathBuf};
 
-use anyhow::{ensure, Result};
+use anyhow::{Context, Result};
 use clap::{Parser, Subcommand};
 use console::style;
 use futures::StreamExt;
@@ -209,8 +209,9 @@ async fn add(api: &impl Api, path: &Path, no_wrap: bool, recursive: bool) -> Res
         }
     }
     pb.finish_and_clear();
-    ensure!(root.is_some(), "File processing failed");
-    println!("/ipfs/{}", root.unwrap());
+    let root = root.context("File processing failed")?;
+    println!("/ipfs/{}", root);
+    api.provide(root).await?;
 
     Ok(())
 }