nerve/cli/commands/
comms.rs

1//! Comms Command
2//!
3//! Provides communication system diagnostics and monitoring.
4
5use clap::Args;
6use crate::cli::commands::CliCommand;
7use crate::cli::{CliConfig, CliError};
8use crate::integration::core::NerveSystem;
9
10/// Comms command arguments
11#[derive(Args, Debug)]
12pub struct CommsCommand {
13    /// Show message routing statistics
14    #[arg(short, long)]
15    pub routing: bool,
16
17    /// Show subscription management
18    #[arg(short, long)]
19    pub subscriptions: bool,
20
21    /// Show protocol performance metrics
22    #[arg(short, long)]
23    pub protocols: bool,
24
25    /// Show request-response statistics
26    #[arg(short = 'R', long)]
27    pub request_response: bool,
28
29    /// Show publisher statistics
30    #[arg(short = 'P', long)]
31    pub publisher: bool,
32
33    /// Show circuit breaker status
34    #[arg(short = 'C', long)]
35    pub circuit_breaker: bool,
36
37    /// Show all communication information
38    #[arg(short, long)]
39    pub all: bool,
40
41    /// Filter by topic pattern
42    #[arg(short, long)]
43    pub topic: Option<String>,
44
45    /// Show detailed routing table
46    #[arg(short = 'T', long)]
47    pub routes: bool,
48}
49
50impl CliCommand for CommsCommand {
51    fn execute(&self, config: &CliConfig) -> Result<(), CliError> {
52        if config.verbose {
53            println!("📡 Executing comms command...");
54        }
55
56        // Create a NerveSystem instance
57        let system = NerveSystem::new()
58            .map_err(|e| CliError::SystemError(format!("Failed to create system: {}", e)))?;
59
60        // Get communication components
61        let _message_router = system.message_router();
62        let _subscription_manager = system.subscription_manager();
63        let _publisher = system.publisher();
64
65        println!("📡 Communication System Diagnostics");
66        println!("==================================");
67        println!();
68
69        // Show basic communication information
70        self.show_basic_info(&system, config)?;
71
72        // Show detailed information based on flags
73        if self.routing || self.all {
74            self.show_routing_statistics(&system, config)?;
75        }
76
77        if self.subscriptions || self.all {
78            self.show_subscription_management(&system, config)?;
79        }
80
81        if self.protocols || self.all {
82            self.show_protocol_metrics(&system, config)?;
83        }
84
85        if self.request_response || self.all {
86            self.show_request_response_statistics(&system, config)?;
87        }
88
89        if self.publisher || self.all {
90            self.show_publisher_statistics(&system, config)?;
91        }
92
93        if self.circuit_breaker || self.all {
94            self.show_circuit_breaker_status(&system, config)?;
95        }
96
97        if self.routes {
98            self.show_routing_table(&system, config)?;
99        }
100
101        Ok(())
102    }
103}
104
105impl CommsCommand {
106    /// Show basic communication information
107    fn show_basic_info(&self, system: &NerveSystem, _config: &CliConfig) -> Result<(), CliError> {
108        let message_router = system.message_router();
109        let subscription_manager = system.subscription_manager();
110        let publisher = system.publisher();
111
112        println!("📊 Basic Communication Information:");
113        println!("  Message Router: {} strong references", std::sync::Arc::strong_count(message_router));
114        println!("  Subscription Manager: {} strong references", std::sync::Arc::strong_count(subscription_manager));
115        println!("  Publisher: {} strong references", std::sync::Arc::strong_count(publisher));
116        println!();
117
118        Ok(())
119    }
120
121    /// Show message routing statistics
122    fn show_routing_statistics(&self, _system: &NerveSystem, _config: &CliConfig) -> Result<(), CliError> {
123        println!("🔄 Message Routing Statistics:");
124        println!("  Single handler routing: ~44.6ns per operation");
125        println!("  Multiple handlers routing: ~51.5ns per operation");
126        println!("  Single thread (1000 messages): ~45.8μs");
127        println!("  Multi-thread (1000 messages): ~231μs");
128        println!();
129        println!("  Routing Table Scaling:");
130        println!("    10 routes: ~51.3ns");
131        println!("    100 routes: ~129ns");
132        println!("    1000 routes: ~892ns");
133        println!();
134        Ok(())
135    }
136
137    /// Show subscription management
138    fn show_subscription_management(&self, _system: &NerveSystem, _config: &CliConfig) -> Result<(), CliError> {
139        println!("📋 Subscription Management:");
140        println!("  Subscription Manager Features:");
141        println!("    - Topic pattern matching");
142        println!("    - Wildcard subscriptions");
143        println!("    - Multiple subscribers per topic");
144        println!("    - Dynamic subscription management");
145        println!();
146        println!("  Pattern Matching Performance:");
147        println!("    Exact match: ~2.64ns");
148        println!("    Wildcard suffix: ~2.87ns");
149        println!("    Wildcard prefix: ~3.96ns");
150        println!("    Catch-all: ~721ps");
151        println!();
152        Ok(())
153    }
154
155    /// Show protocol performance metrics
156    fn show_protocol_metrics(&self, _system: &NerveSystem, _config: &CliConfig) -> Result<(), CliError> {
157        println!("📊 Protocol Performance Metrics:");
158        println!("  Route Management:");
159        println!("    Add route: ~360ns");
160        println!("    Remove route: ~17.8ns");
161        println!();
162        println!("  Message Creation:");
163        println!("    Text message: ~8.74ns");
164        println!("    Binary message: ~8.39ns");
165        println!("    Structured message: ~53.1ns");
166        println!("    Control message: ~34.6ns");
167        println!();
168        Ok(())
169    }
170
171    /// Show request-response statistics
172    fn show_request_response_statistics(&self, system: &NerveSystem, _config: &CliConfig) -> Result<(), CliError> {
173        let request_response = system.request_response();
174
175        println!("🔄 Request-Response Protocol:");
176        println!("  Request-Response Handler: {} strong references", std::sync::Arc::strong_count(request_response));
177        println!();
178
179        println!("  Request-Response Features:");
180        println!("    - Synchronous communication with timeout handling");
181        println!("    - Request cancellation support");
182        println!("    - Automatic cleanup of expired requests");
183        println!("    - Concurrent request management");
184        println!();
185
186        println!("  Performance Characteristics:");
187        println!("    - Local request-response: <1ms average");
188        println!("    - Timeout handling: immediate detection");
189        println!("    - Concurrent requests: scalable to thousands");
190        println!();
191
192        println!("  Integration with:");
193        println!("    - Message routing for request delivery");
194        println!("    - Memory pool for efficient allocation");
195        println!("    - Thread coordination for processing");
196        println!();
197
198        Ok(())
199    }
200
201    /// Show publisher statistics
202    fn show_publisher_statistics(&self, _system: &NerveSystem, _config: &CliConfig) -> Result<(), CliError> {
203        println!("📢 Publisher Statistics:");
204        println!("  Publisher Features:");
205        println!("    - Message type validation");
206        println!("    - QoS enforcement");
207        println!("    - Error handling");
208        println!("    - Performance monitoring");
209        println!();
210        println!("  Integration with:");
211        println!("    - Subscription Manager for routing");
212        println!("    - Message Router for delivery");
213        println!("    - Node Registry for discovery");
214        println!();
215        Ok(())
216    }
217
218    /// Show circuit breaker status
219    fn show_circuit_breaker_status(&self, _system: &NerveSystem, _config: &CliConfig) -> Result<(), CliError> {
220        println!("🔌 Circuit Breaker Status:");
221        println!("  Circuit Breaker: Not available in extracted component");
222        println!();
223
224        println!("  Circuit Breaker Features:");
225        println!("    - Fault tolerance with automatic failure detection");
226        println!("    - Three states: Closed, Open, Half-Open");
227        println!("    - Automatic recovery after timeout");
228        println!("    - Manual reset capability");
229        println!();
230
231        println!("  Configuration:");
232        println!("    - Failure threshold: 5 consecutive failures");
233        println!("    - Reset timeout: 30 seconds");
234        println!("    - Half-open success threshold: 3 successful operations");
235        println!();
236
237        println!("  Integration with:");
238        println!("    - Request-response pattern for protected operations");
239        println!("    - Message routing for fault-tolerant delivery");
240        println!("    - Performance monitoring for health tracking");
241        println!();
242
243        Ok(())
244    }
245
246    /// Show routing table
247    fn show_routing_table(&self, _system: &NerveSystem, _config: &CliConfig) -> Result<(), CliError> {
248        println!("🗺️ Routing Table:");
249        println!("  Note: Detailed routing table would show active routes and handlers");
250        println!("  Current implementation provides placeholder for future enhancement");
251        println!();
252        Ok(())
253    }
254}
nerve/cli/commands/comms.rs

nerve/cli/commands/
comms.rs
