feat: v0.1.5

Author: eastspire

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "hyperlane-cli"
-version = "0.1.3"
+version = "0.1.5"
 readme = "README.md"
 edition = "2024"
 authors = ["root@ltpp.vip"]
@@ -12,7 +12,8 @@ categories = ["command-line-interface", "development-tools", "visualization"]
 exclude = ["target", "Cargo.lock", "sh", ".github"]
 
 [dependencies]
-tokio = { version = "1", features = ["process", "rt-multi-thread", "macros"] }
+toml = "0.9.8"
+tokio = { version = "1.49.0", features = ["full"] }
 
 [profile.dev]
 incremental = false

src/command/enum.rs

@@ -7,6 +7,8 @@ pub(crate) enum CommandType {
     Watch,
     /// Bump version in Cargo.toml
     Bump,
+    /// Publish packages in monorepo
+    Publish,
     /// Show help
     Help,
     /// Show version

src/config/fn.rs

@@ -11,6 +11,7 @@ pub(crate) fn parse_args() -> Args {
     let mut check: bool = false;
     let mut manifest_path: Option<String> = None;
     let mut bump_type: Option<BumpVersionType> = None;
+    let mut max_retries: u32 = 3;
     let mut i: usize = 1;
     while i < raw_args.len() {
         let arg: &str = raw_args[i].as_str();
@@ -36,6 +37,11 @@ pub(crate) fn parse_args() -> Args {
                     command = CommandType::Bump;
                 }
             }
+            "publish" => {
+                if command == CommandType::Help || command == CommandType::Version {
+                    command = CommandType::Publish;
+                }
+            }
             "--patch" => {
                 bump_type = Some(BumpVersionType::Patch);
             }
@@ -66,6 +72,14 @@ pub(crate) fn parse_args() -> Args {
                     manifest_path = Some(raw_args[i].clone());
                 }
             }
+            "--max-retries" => {
+                i += 1;
+                if i < raw_args.len() {
+                    if let Ok(n) = raw_args[i].parse::<u32>() {
+                        max_retries = n;
+                    }
+                }
+            }
             _ => {}
         }
         i += 1;
@@ -75,5 +89,6 @@ pub(crate) fn parse_args() -> Args {
         check,
         manifest_path,
         bump_type,
+        max_retries,
     }
 }

src/config/struct.rs

@@ -7,8 +7,10 @@ pub struct Args {
     pub command: CommandType,
     /// Check mode for fmt
     pub check: bool,
-    /// Manifest path for fmt and bump
+    /// Manifest path for fmt, bump and publish
     pub manifest_path: Option<String>,
     /// Bump type for bump command
     pub bump_type: Option<BumpVersionType>,
+    /// Maximum retry attempts for publish command
+    pub max_retries: u32,
 }

src/help/fn.rs

@@ -6,6 +6,7 @@ pub(crate) fn print_help() {
     println!("  bump      Bump version in Cargo.toml");
     println!("  fmt       Format Rust code using cargo fmt");
     println!("  watch     Watch files and run cargo run using cargo-watch");
+    println!("  publish   Publish packages in monorepo with topological ordering");
     println!("  -h, --help      Print this help message");
     println!("  -v, --version   Print version information");
     println!();
@@ -28,4 +29,8 @@ pub(crate) fn print_help() {
     println!("Fmt Options:");
     println!("  --check         Check formatting without making changes");
     println!("  --manifest-path <PATH>  Path to Cargo.toml");
+    println!();
+    println!("Publish Options:");
+    println!("  --manifest-path <PATH>  Path to workspace Cargo.toml [default: Cargo.toml]");
+    println!("  --max-retries <N>       Maximum retry attempts per package [default: 3]");
 }

src/main.rs

@@ -7,15 +7,19 @@ mod command;
 mod config;
 mod fmt;
 mod help;
+mod publish;
 mod version;
 mod watch;
 
-pub(crate) use {bump::*, command::*, config::*, fmt::*, help::*, version::*, watch::*};
+pub(crate) use {
+    bump::*, command::*, config::*, fmt::*, help::*, publish::*, version::*, watch::*,
+};
 
 pub(crate) use std::{
+    collections::{HashMap, VecDeque},
     env::args,
     fs::{read_to_string, write},
-    path::Path,
+    path::{Path, PathBuf},
     process::{ExitStatus, Stdio, exit},
 };
 
@@ -52,6 +56,30 @@ async fn main() {
                 }
             }
         }
+        CommandType::Publish => {
+            let manifest_path: String = args
+                .manifest_path
+                .unwrap_or_else(|| "Cargo.toml".to_string());
+            let max_retries: u32 = args.max_retries;
+            match execute_publish(&manifest_path, max_retries).await {
+                Ok(results) => {
+                    let failed_count: usize = results
+                        .iter()
+                        .filter(|r: &&PublishResult| !r.success)
+                        .count();
+                    if failed_count > 0 {
+                        eprintln!("Publish completed with {failed_count} failures");
+                        exit(1);
+                    } else {
+                        println!("All packages published successfully");
+                    }
+                }
+                Err(error) => {
+                    eprintln!("publish failed: {error}");
+                    exit(1);
+                }
+            }
+        }
         CommandType::Help => print_help(),
         CommandType::Version => print_version(),
     }

src/publish/enum.rs

@@ -0,0 +1,10 @@
+/// Error types for publish operation
+#[derive(Clone, Debug, Eq, PartialEq)]
+pub(crate) enum PublishError {
+    /// Failed to parse Cargo.toml
+    ManifestParseError,
+    /// Circular dependency detected
+    CircularDependency,
+    /// IO error
+    IoError,
+}