Add progress for DHT update

iroh/src/run.rs

@@ -1,5 +1,6 @@
 use std::collections::HashMap;
 use std::path::{Path, PathBuf};
+use std::time::Duration;
 
 use anyhow::{Context, Result};
 use clap::{Parser, Subcommand};
@@ -162,7 +163,7 @@ async fn add(api: &impl Api, path: &Path, no_wrap: bool, recursive: bool) -> Res
             path.display()
         );
     }
-    println!("{} Calculating size...", style("[1/2]").bold().dim());
+    println!("{} Calculating size...", style("[1/3]").bold().dim());
 
     let pb = ProgressBar::new_spinner();
     let mut total_size: u64 = 0;
@@ -184,7 +185,7 @@ async fn add(api: &impl Api, path: &Path, no_wrap: bool, recursive: bool) -> Res
 
     println!(
         "{} Importing content {}...",
-        style("[2/2]").bold().dim(),
+        style("[2/3]").bold().dim(),
         human::format_bytes(total_size)
     );
 
@@ -209,9 +210,24 @@ async fn add(api: &impl Api, path: &Path, no_wrap: bool, recursive: bool) -> Res
         }
     }
     pb.finish_and_clear();
+
+    let pb = ProgressBar::new(100);
     let root = root.context("File processing failed")?;
     println!("/ipfs/{}", root);
-    api.provide(root).await?;
+    let cids = vec![root];
+    println!(
+        "{} Providing {} records to DHT ...",
+        style("[3/3]").bold().dim(),
+        cids.len(),
+    );
+    pb.set_style(ProgressStyle::with_template("[{elapsed_precise}]").unwrap());
+    pb.inc(0);
+    tokio::time::sleep(Duration::from_secs(1)).await;
+    for cid in cids {
+        api.provide(cid).await?;
+        pb.inc(1);
+    }
+    pb.finish_and_clear();
 
     Ok(())
 }