From 292227c83753564cde90de7a4f43d9ef4660bd4c Mon Sep 17 00:00:00 2001 From: 魏曹先生 <1992414357@qq.com> Date: Tue, 25 Nov 2025 15:10:53 +0800 Subject: Improve documentation for system action and config file crates --- crates/system_action/src/action.rs | 56 +++++++++++++++++++++++++++++++++ crates/system_action/src/action_pool.rs | 20 +++++++++++- 2 files changed, 75 insertions(+), 1 deletion(-) (limited to 'crates/system_action/src') diff --git a/crates/system_action/src/action.rs b/crates/system_action/src/action.rs index ef1bf11..62425ff 100644 --- a/crates/system_action/src/action.rs +++ b/crates/system_action/src/action.rs @@ -5,6 +5,40 @@ use std::sync::Arc; use tcp_connection::{error::TcpTargetError, instance::ConnectionInstance}; use tokio::{net::TcpStream, sync::Mutex}; +/// # Trait - Action +/// +/// A trait used to describe the interaction pattern between client and server +/// +/// ## Generics +/// +/// Args: Represents the parameter type required for this action +/// +/// Return: Represents the return type of this action +/// +/// The above generics must implement serde's Serialize and DeserializeOwned traits, +/// and must be sendable between threads +/// +/// ## Implementation +/// +/// ```ignore +/// pub trait Action +/// where +/// Args: Serialize + DeserializeOwned + Send, +/// Return: Serialize + DeserializeOwned + Send, +/// { +/// /// Name, used to inform the server which action to execute +/// fn action_name() -> &'static str; +/// +/// /// Whether it's a local Action, used to inform the system if it only runs locally +/// fn is_remote_action() -> bool; +/// +/// /// Action processing logic +/// fn process( +/// context: ActionContext, +/// args: Args, +/// ) -> impl std::future::Future> + Send; +/// } +/// ``` pub trait Action where Args: Serialize + DeserializeOwned + Send, @@ -20,6 +54,28 @@ where ) -> impl std::future::Future> + Send; } +/// # Struct - ActionContext +/// +/// Used to inform the Action about the current execution environment +/// +/// ## Creation +/// +/// Create ActionContext using the following methods: +/// +/// ```ignore +/// +/// // The instance here is the connection instance passed from external sources for communicating with the server +/// // For specific usage, please refer to the `/crates/utils/tcp_connection` section +/// +/// fn init_local_action_ctx(instance: ConnectionInstance) { +/// // Create context and specify execution on local +/// let mut ctx = ActionContext::local(); +/// } +/// +/// fn init_remote_action_ctx(instance: ConnectionInstance) { +/// // Create context and specify execution on remote +/// let mut ctx = ActionContext::remote(); +/// } #[derive(Default)] pub struct ActionContext { /// Whether the action is executed locally or remotely diff --git a/crates/system_action/src/action_pool.rs b/crates/system_action/src/action_pool.rs index c3ad4a1..019fa6d 100644 --- a/crates/system_action/src/action_pool.rs +++ b/crates/system_action/src/action_pool.rs @@ -15,7 +15,25 @@ type ProcEndCallback = fn() -> ProcEndFuture; type ProcBeginFuture<'a> = Pin> + Send + 'a>>; type ProcEndFuture = Pin> + Send>>; -/// A pool of registered actions that can be processed by name +/// # Struct - ActionPool +/// +/// This struct is used to register and record all accessible and executable actions +/// +/// It also registers `on_proc_begin` and `on_proc_end` callback functions +/// used for action initialization +/// +/// ## Creating and registering actions +/// ```ignore +/// fn init_action_pool() { +/// let mut pool = Action::new(); +/// +/// // Register action +/// pool.register(); +/// +/// // If the action is implemented with `#[action_gen]`, you can also do +/// register_your_action(&mut pool); +/// } +/// ``` pub struct ActionPool { /// HashMap storing action name to action implementation mapping actions: std::collections::HashMap<&'static str, Box>, -- cgit