diff --git a/cli/Cargo.toml b/cli/Cargo.toml index 2d32a80..5a799fd 100644 --- a/cli/Cargo.toml +++ b/cli/Cargo.toml @@ -23,7 +23,7 @@ tonic = "0.14.1" tonic-reflection = "0.14.1" prost-types = "0.14.1" prost = "0.14.1" -cortexflow_agent_api = "0.1.1-beta.0" +cortexflow_agent_api = "0.1.1-beta.1" [[bin]] name = "cfcli" diff --git a/cli/src/monitoring.rs b/cli/src/monitoring.rs index ad96966..56578e8 100644 --- a/cli/src/monitoring.rs +++ b/cli/src/monitoring.rs @@ -96,7 +96,22 @@ pub async fn monitor_identity_events() -> Result<(), Error> { println!("{} {}", "=====>".blue().bold(), "Connected to CortexFlow Client".green()); match send_active_connection_request(client).await { Ok(response) => { - println!("{:?}", response.into_inner().events); + let resp = response.into_inner(); + if resp.events.is_empty() { + println!("{} No events found", "=====>".blue().bold()); + } else { + println!("{} Found {} events", "=====>".blue().bold(), resp.events.len()); + for (i, ev) in resp.events.iter().enumerate() { + println!( + "{} Event[{}] id: {} src: {} dst: {}", + "=====>".blue().bold(), + i, + ev.event_id, + ev.src_ip_port, + ev.dst_ip_port + ); + } + } } Err(e) => { println!( diff --git a/core/api/Cargo.toml b/core/api/Cargo.toml index 211dd89..ee7eed4 100644 --- a/core/api/Cargo.toml +++ b/core/api/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "cortexflow_agent_api" -version = "0.1.1-beta.0" +version = "0.1.1-beta.1" edition = "2021" description = "CortexFlow agent API" authors = ["Lorenzo Tettamanti", "Pranav Verma", "Lorenzo Bradanini","Siddharth Sutar","Andrea Bozzo"]