refactor(iroh-cli)!: Use gossip cli from iroh-gossip crate

Cargo.toml

@@ -55,6 +55,6 @@ iroh-metrics = { path = "./iroh-metrics" }
 iroh-test = { path = "./iroh-test" }
 iroh-router = { path = "./iroh-router" }
 
-iroh-gossip = { git = "https://github.com/n0-computer/iroh-gossip", branch = "main" }
-iroh-docs = { git = "https://github.com/n0-computer/iroh-docs", branch = "main" }
-iroh-blobs = { git = "https://github.com/n0-computer/iroh-blobs", branch = "main" }
+iroh-gossip = { git = "https://github.com/n0-computer/iroh-gossip", branch = "cli" }
+iroh-docs = { git = "https://github.com/n0-computer/iroh-docs", branch = "cli" }
+iroh-blobs = { git = "https://github.com/n0-computer/iroh-blobs", branch = "cli" }

iroh-cli/Cargo.toml

@@ -42,8 +42,9 @@ human-time = "0.1.6"
 indicatif = { version = "0.17", features = ["tokio"] }
 iroh = { version = "0.28.1", path = "../iroh", features = ["metrics"] }
 iroh-gossip = "0.28.1"
-iroh-docs = { version = "0.28.0", features = ["rpc"]}
+iroh-docs = { version = "0.28.0", features = ["rpc", "cli"]}
 iroh-metrics = { version = "0.28.0" }
+iroh-blobs = { version = "0.28.1", features = ["cli"] }
 parking_lot = "0.12.1"
 pkarr = { version = "2.2.0", default-features = false }
 portable-atomic = "1"

iroh-cli/src/commands.rs

@@ -6,24 +6,20 @@ use std::{
 use anyhow::{ensure, Context, Result};
 use clap::Parser;
 use iroh::client::Iroh;
+use iroh_blobs::cli::{BlobAddOptions, BlobSource};
+use iroh_docs::cli::ConsoleEnv;
 
-use self::{
-    blobs::{BlobAddOptions, BlobSource},
-    rpc::RpcCommands,
-    start::RunType,
-};
-use crate::config::{ConsoleEnv, NodeConfig};
+use self::{rpc::RpcCommands, start::RunType};
+use crate::config::NodeConfig;
 
-pub(crate) mod authors;
-pub(crate) mod blobs;
 pub(crate) mod console;
-pub(crate) mod docs;
 pub(crate) mod doctor;
-pub(crate) mod gossip;
 pub(crate) mod net;
 pub(crate) mod rpc;
 pub(crate) mod start;
-pub(crate) mod tags;
+pub use iroh_blobs::{cli as blobs, cli::tags};
+pub use iroh_docs::{cli as docs, cli::authors};
+pub use iroh_gossip::cli as gossip;
 
 /// iroh is a tool for building distributed apps.
 ///
@@ -125,7 +121,8 @@ impl Cli {
                         self.rpc_addr,
                         RunType::SingleCommandNoAbort,
                         |iroh| async move {
-                            let env = ConsoleEnv::for_console(data_dir_owned, &iroh).await?;
+                            let env =
+                                ConsoleEnv::for_console(data_dir_owned, &iroh.authors()).await?;
                             console::run(&iroh, &env).await
                         },
                     )
@@ -137,7 +134,7 @@ impl Cli {
                     } else {
                         Iroh::connect_path(data_dir).await.context("rpc connect")?
                     };
-                    let env = ConsoleEnv::for_console(data_dir_owned, &iroh).await?;
+                    let env = ConsoleEnv::for_console(data_dir_owned, &iroh.authors()).await?;
                     console::run(&iroh, &env).await
                 }
             }
@@ -151,7 +148,7 @@ impl Cli {
                         self.rpc_addr,
                         RunType::SingleCommandAbortable,
                         move |iroh| async move {
-                            let env = ConsoleEnv::for_cli(data_dir_owned, &iroh).await?;
+                            let env = ConsoleEnv::for_cli(data_dir_owned, &iroh.authors()).await?;
                             command.run(&iroh, &env).await
                         },
                     )
@@ -163,7 +160,7 @@ impl Cli {
                     } else {
                         Iroh::connect_path(data_dir).await.context("rpc connect")?
                     };
-                    let env = ConsoleEnv::for_cli(data_dir_owned, &iroh).await?;
+                    let env = ConsoleEnv::for_cli(data_dir_owned, &iroh.authors()).await?;
                     command.run(&iroh, &env).await
                 }
             }
@@ -191,7 +188,10 @@ impl Cli {
                     |client| async move {
                         match add_command {
                             None => Ok(()),
-                            Some(command) => command.run(&client).await,
+                            Some(command) => {
+                                let node_addr = client.net().node_addr().await?;
+                                command.run(&client.blobs(), node_addr).await
+                            }
                         }
                     },
                 )