mecha10_cli/services/process/
mod.rs

1#![allow(dead_code)]
2
3//! Process service for managing child processes
4//!
5//! This service provides process lifecycle management for CLI commands,
6//! particularly for the `dev` and `run` commands that need to manage
7//! multiple node processes.
8//!
9//! This is a thin wrapper around mecha10-runtime's ProcessManager,
10//! delegating core process management to the runtime layer.
11//!
12//! The implementation is split across a few focused submodules, all of
13//! which add `impl ProcessService` blocks for the struct defined here:
14//!
15//! - [`resolve`]: binary path resolution (framework dev mode, global installs, node-runner)
16//! - [`spawn`]: plain process spawning primitives (inherited/piped output, env, working dir)
17//! - [`spawn_node`]: node-oriented spawning (node-runner, standalone/direct)
18//! - [`control`]: status, stop/restart, and cleanup of tracked processes
19//! - [`build`]: cargo build helpers used before spawning nodes
20
21mod build;
22mod control;
23mod resolve;
24mod spawn;
25mod spawn_node;
26
27use mecha10_runtime::ProcessManager;
28
29/// Process service for managing child processes
30///
31/// This is a thin wrapper around the runtime's ProcessManager,
32/// adding CLI-specific conveniences and delegating core functionality
33/// to the runtime layer.
34///
35/// # Examples
36///
37/// ```rust,ignore
38/// use mecha10_cli::services::ProcessService;
39///
40/// # async fn example() -> anyhow::Result<()> {
41/// let mut service = ProcessService::new();
42///
43/// // Spawn a node process
44/// service.spawn_node("camera_driver", "target/debug/camera_driver", &[])?;
45///
46/// // Check status
47/// let status = service.get_status();
48/// println!("Running processes: {:?}", status);
49///
50/// // Stop a specific process
51/// service.stop("camera_driver")?;
52///
53/// // Cleanup all processes
54/// service.cleanup();
55/// # Ok(())
56/// # }
57/// ```
58pub struct ProcessService {
59    /// Runtime's process manager (handles core lifecycle)
60    manager: ProcessManager,
61}
62
63impl ProcessService {
64    /// Create a new process service
65    pub fn new() -> Self {
66        Self {
67            manager: ProcessManager::new(),
68        }
69    }
70
71    /// Track dependency relationship for a node
72    ///
73    /// # Arguments
74    ///
75    /// * `node` - Name of the node
76    /// * `dependencies` - List of nodes this node depends on
77    pub fn track_dependency(&mut self, node: &str, dependencies: Vec<String>) {
78        for dep in dependencies {
79            self.manager.add_dependency(node.to_string(), dep);
80        }
81    }
82
83    /// Get shutdown order (reverse dependency order)
84    ///
85    /// Returns nodes in order they should be stopped:
86    /// - Nodes with dependents first (high-level nodes)
87    /// - Then their dependencies (low-level nodes)
88    ///
89    /// This ensures we don't stop a node while other nodes depend on it.
90    ///
91    /// Delegates to the runtime's ProcessManager.
92    pub fn get_shutdown_order(&self) -> Vec<String> {
93        self.manager.shutdown_order()
94    }
95
96    /// Get the number of tracked processes
97    pub fn count(&self) -> usize {
98        self.manager.len()
99    }
100
101    /// Check if any processes are being tracked
102    pub fn is_empty(&self) -> bool {
103        self.manager.is_empty()
104    }
105
106    /// Get access to the underlying ProcessManager
107    ///
108    /// Useful for advanced operations or when migrating existing code.
109    /// Provides direct access to the runtime's ProcessManager.
110    pub fn manager(&mut self) -> &mut ProcessManager {
111        &mut self.manager
112    }
113}
114
115impl Default for ProcessService {
116    fn default() -> Self {
117        Self::new()
118    }
119}
120
121impl Drop for ProcessService {
122    fn drop(&mut self) {
123        // ProcessManager's Drop will handle graceful shutdown
124    }
125}
mecha10_cli/services/process/mod.rs

mecha10_cli/services/process/
mod.rs
