chore: refactor file collect command

cli/Cargo.toml

@@ -19,8 +19,4 @@ exporter = { git = "https://github.com/trustification/trustification.git" }
 
 [[bin]]
 name = "guac"
-path = "src/main.rs"
-
-[[bin]]
-name = "collector"
-path = "src/collector.rs"
+path = "src/main.rs"

cli/src/collect.rs

@@ -6,24 +6,50 @@ use guac::collector::{
     emitter::NatsEmitter,
 };
 
-#[derive(clap::Subcommand, Debug)]
+use clap::Subcommand;
+
+#[derive(Subcommand, Debug)]
 pub enum CollectCommand {
-    File { path: String },
-    S3 {},
+    File(FileCommand),
 }
 
 impl CollectCommand {
     pub async fn run(self) -> anyhow::Result<ExitCode> {
-        println!("Collecting ...");
+        match self {
+            Self::File(command) => command.run().await,
+        }
+    }
+}
+
+#[derive(Clone, Debug, clap::Parser)]
+#[command(rename_all_env = "SCREAMING_SNAKE_CASE")]
+pub struct FileConfig {
+    #[arg(short = 'n', long = "nats", default_value = "127.0.0.1:4222")]
+    pub(crate) nats_url: String,
+
+    path: String,
+}
 
-        let emitter = NatsEmitter::new("127.0.0.1:4222").await?;
+#[derive(clap::Args, Debug)]
+#[command(
+    about = "Run the file collector",
+    args_conflicts_with_subcommands = true
+)]
+pub struct FileCommand {
+    #[command(flatten)]
+    pub(crate) config: FileConfig,
+}
+
+impl FileCommand {
+    pub async fn run(self) -> anyhow::Result<ExitCode> {
+        println!("Collecting file {:?}", self.config.path);
+        let emitter = NatsEmitter::new(&self.config.nats_url).await?;
 
         let collector = FileCollector {
-            path: "example/seedwing-java-example.bom".to_string(),
+            path: self.config.path,
         };
 
         collector.run(emitter).await?;
-
         Ok(ExitCode::SUCCESS)
     }
 }