From 27f6414ad1ff451feb0044af62f37dc2a6255ffa Mon Sep 17 00:00:00 2001
From: 魏曹先生 <1992414357@qq.com>
Date: Thu, 5 Feb 2026 22:35:05 +0800
Subject: Remove examples and legacy code, update .gitignore

- Delete examples directory and its example action system
- Rename actions/ to legacy_actions/ and data/ to legacy_data/
- Update Cargo.toml license file reference
- Move setup scripts to scripts/dev/ directory
- Add todo.txt patterns to .gitignore
---
 legacy_actions/src/registry/client_registry.rs | 128 +++++++++++++++++++++++++
 1 file changed, 128 insertions(+)
 create mode 100644 legacy_actions/src/registry/client_registry.rs

(limited to 'legacy_actions/src/registry/client_registry.rs')

diff --git a/legacy_actions/src/registry/client_registry.rs b/legacy_actions/src/registry/client_registry.rs
new file mode 100644
index 0000000..db69889
--- /dev/null
+++ b/legacy_actions/src/registry/client_registry.rs
@@ -0,0 +1,128 @@
+use std::sync::Arc;
+
+use action_system::{action::ActionContext, action_pool::ActionPool};
+use cfg_file::config::ConfigFile;
+use tcp_connection::error::TcpTargetError;
+use vcs_data::data::{
+    local::{LocalWorkspace, workspace_config::LocalConfig},
+    user::UserDirectory,
+};
+
+use crate::{
+    connection::protocol::RemoteActionInvoke,
+    remote_actions::{
+        content_manage::track_file::register_track_file_action,
+        edit_right_manage::change_virtual_file_edit_right::register_change_virtual_file_edit_right_action,
+        mapping_manage::{
+            edit_mapping::register_edit_mapping_action,
+            merge_share_mapping::register_merge_share_mapping_action,
+            share_mapping::register_share_mapping_action,
+        },
+        sheet_manage::{
+            drop_sheet::register_drop_sheet_action, make_sheet::register_make_sheet_action,
+        },
+        workspace_manage::{
+            set_upstream_vault::register_set_upstream_vault_action,
+            update_to_latest_info::register_update_to_latest_info_action,
+        },
+    },
+};
+
+fn register_actions(pool: &mut ActionPool) {
+    // Pool register here
+
+    // Local Actions
+    register_set_upstream_vault_action(pool);
+    register_update_to_latest_info_action(pool);
+
+    // Sheet Actions
+    register_make_sheet_action(pool);
+    register_drop_sheet_action(pool);
+    register_edit_mapping_action(pool);
+
+    // Share / Merge Share Actions
+    register_share_mapping_action(pool);
+    register_merge_share_mapping_action(pool);
+
+    // Track Action
+    register_track_file_action(pool);
+
+    // User Actions
+    register_change_virtual_file_edit_right_action(pool);
+}
+
+pub fn client_action_pool() -> ActionPool {
+    // Create pool
+    let mut pool = ActionPool::new();
+
+    // Register actions
+    register_actions(&mut pool);
+
+    // Add process events
+    pool.set_on_proc_begin(|ctx, args| Box::pin(on_proc_begin(ctx, args)));
+
+    // Return
+    pool
+}
+
+async fn on_proc_begin(
+    ctx: &mut ActionContext,
+    _args: &(dyn std::any::Any + Send + Sync),
+) -> Result<(), TcpTargetError> {
+    // Is ctx remote
+    let is_remote = ctx.is_remote_action();
+
+    // Action name and arguments
+    let action_name = ctx.action_name().to_string();
+    let action_args_json = ctx.action_args_json().clone();
+
+    // Insert LocalWorkspace Arc
+    let Ok(local_config) = LocalConfig::read().await else {
+        return Err(TcpTargetError::NotFound(
+            "The current directory does not have a local workspace".to_string(),
+        ));
+    };
+    let local_workspace = match LocalWorkspace::init_current_dir(local_config) {
+        Some(workspace) => workspace,
+        None => {
+            return Err(TcpTargetError::NotFound(
+                "Failed to initialize local workspace.".to_string(),
+            ));
+        }
+    };
+    let local_workspace_arc = Arc::new(local_workspace);
+    ctx.insert_arc_data(local_workspace_arc);
+
+    // Insert UserDirectory Arc
+    let Some(user_directory) = UserDirectory::current_cfg_dir() else {
+        return Err(TcpTargetError::NotFound(
+            "The user directory does not exist.".to_string(),
+        ));
+    };
+
+    let user_directory_arc = Arc::new(user_directory);
+    ctx.insert_arc_data(user_directory_arc);
+
+    // Get instance
+    let Some(instance) = ctx.instance() else {
+        return Err(TcpTargetError::Unsupported(
+            "Missing ConnectionInstance in current context, this ActionPool does not support this call"
+                .to_string()));
+    };
+
+    // If it's remote, invoke action at server
+    if is_remote {
+        // Build protocol message
+        let msg = RemoteActionInvoke {
+            action_name,
+            action_args_json,
+        };
+
+        // Send
+        let mut instance = instance.lock().await;
+        instance.write_msgpack(&msg).await?;
+    }
+
+    // Return OK, wait for client to execute Action locally
+    Ok(())
+}
-- 
cgit