diff --git a/desktop/src-tauri/src/classroom_commands/chat.rs b/desktop/src-tauri/src/classroom_commands/chat.rs index f212ec7..83a6713 100644 --- a/desktop/src-tauri/src/classroom_commands/chat.rs +++ b/desktop/src-tauri/src/classroom_commands/chat.rs @@ -47,6 +47,7 @@ pub struct ClassroomChatCmdRequest { // --------------------------------------------------------------------------- /// Send a message in the classroom chat and get multi-agent responses. +// @reserved: classroom chat functionality // @connected #[tauri::command] pub async fn classroom_chat( diff --git a/desktop/src-tauri/src/classroom_commands/generate.rs b/desktop/src-tauri/src/classroom_commands/generate.rs index d77f9ca..e05e392 100644 --- a/desktop/src-tauri/src/classroom_commands/generate.rs +++ b/desktop/src-tauri/src/classroom_commands/generate.rs @@ -88,6 +88,7 @@ fn stage_name(stage: &GenerationStage) -> &'static str { /// Start classroom generation (4-stage pipeline). /// Progress events are emitted via `classroom:progress`. /// Supports cancellation between stages by removing the task from GenerationTasks. +// @reserved: classroom generation // @connected #[tauri::command] pub async fn classroom_generate( @@ -270,6 +271,7 @@ pub async fn classroom_cancel_generation( } /// Retrieve a generated classroom by ID +// @reserved: classroom generation // @connected #[tauri::command] pub async fn classroom_get( diff --git a/desktop/src-tauri/src/gateway/commands.rs b/desktop/src-tauri/src/gateway/commands.rs index 594e9eb..8825a69 100644 --- a/desktop/src-tauri/src/gateway/commands.rs +++ b/desktop/src-tauri/src/gateway/commands.rs @@ -52,6 +52,7 @@ pub(crate) struct ProcessLogsResponse { } /// Get ZCLAW Kernel status +// @reserved: system control // @connected #[tauri::command] pub fn zclaw_status(app: AppHandle) -> Result { @@ -59,6 +60,7 @@ pub fn zclaw_status(app: AppHandle) -> Result { } /// Start ZCLAW Kernel +// @reserved: system control // @connected #[tauri::command] pub fn zclaw_start(app: AppHandle) -> Result { @@ -69,6 +71,7 @@ pub fn zclaw_start(app: AppHandle) -> Result { } /// Stop ZCLAW Kernel +// @reserved: system control // @connected #[tauri::command] pub fn zclaw_stop(app: AppHandle) -> Result { @@ -78,6 +81,7 @@ pub fn zclaw_stop(app: AppHandle) -> Result { } /// Restart ZCLAW Kernel +// @reserved: system control // @connected #[tauri::command] pub fn zclaw_restart(app: AppHandle) -> Result { @@ -88,6 +92,7 @@ pub fn zclaw_restart(app: AppHandle) -> Result { } /// Get local auth token from ZCLAW config +// @reserved: system control // @connected #[tauri::command] pub fn zclaw_local_auth() -> Result { @@ -95,6 +100,7 @@ pub fn zclaw_local_auth() -> Result { } /// Prepare ZCLAW for Tauri (update allowed origins) +// @reserved: system control // @connected #[tauri::command] pub fn zclaw_prepare_for_tauri(app: AppHandle) -> Result { @@ -102,6 +108,7 @@ pub fn zclaw_prepare_for_tauri(app: AppHandle) -> Result Result { } /// List ZCLAW processes +// @reserved: system control // @connected #[tauri::command] pub fn zclaw_process_list(app: AppHandle) -> Result { @@ -160,6 +168,7 @@ pub fn zclaw_process_list(app: AppHandle) -> Result } /// Get ZCLAW process logs +// @reserved: system control // @connected #[tauri::command] pub fn zclaw_process_logs( @@ -224,6 +233,7 @@ pub fn zclaw_process_logs( } /// Get ZCLAW version information +// @reserved: system control // @connected #[tauri::command] pub fn zclaw_version(app: AppHandle) -> Result { diff --git a/desktop/src-tauri/src/health_check.rs b/desktop/src-tauri/src/health_check.rs index 635f3b4..7992709 100644 --- a/desktop/src-tauri/src/health_check.rs +++ b/desktop/src-tauri/src/health_check.rs @@ -112,6 +112,7 @@ fn get_process_uptime(status: &LocalGatewayStatus) -> Option { } /// Perform comprehensive health check on ZCLAW Kernel +// @reserved: system health check // @connected #[tauri::command] pub fn zclaw_health_check( diff --git a/desktop/src-tauri/src/intelligence/experience.rs b/desktop/src-tauri/src/intelligence/experience.rs index 7c1ad48..842b89b 100644 --- a/desktop/src-tauri/src/intelligence/experience.rs +++ b/desktop/src-tauri/src/intelligence/experience.rs @@ -10,12 +10,11 @@ use chrono::{DateTime, Utc}; use serde::{Deserialize, Serialize}; use tracing::{debug, warn}; -use uuid::Uuid; use zclaw_growth::ExperienceStore; use zclaw_types::Result; use super::pain_aggregator::PainPoint; -use super::solution_generator::{Proposal, ProposalStatus}; +use super::solution_generator::Proposal; // --------------------------------------------------------------------------- // Shared completion status diff --git a/desktop/src-tauri/src/intelligence/user_profiler.rs b/desktop/src-tauri/src/intelligence/user_profiler.rs index f64e170..322c4e5 100644 --- a/desktop/src-tauri/src/intelligence/user_profiler.rs +++ b/desktop/src-tauri/src/intelligence/user_profiler.rs @@ -9,7 +9,7 @@ use std::sync::Arc; use chrono::Utc; use tracing::{debug, warn}; -use zclaw_memory::fact::{Fact, FactCategory}; +use zclaw_memory::fact::Fact; use zclaw_memory::user_profile_store::{ CommStyle, Level, UserProfile, UserProfileStore, }; diff --git a/desktop/src-tauri/src/kernel_commands/a2a.rs b/desktop/src-tauri/src/kernel_commands/a2a.rs index d0232df..8532797 100644 --- a/desktop/src-tauri/src/kernel_commands/a2a.rs +++ b/desktop/src-tauri/src/kernel_commands/a2a.rs @@ -121,6 +121,7 @@ pub async fn agent_a2a_delegate_task( /// Butler delegates a user request to expert agents via the Director. #[cfg(feature = "multi-agent")] +// @reserved: butler multi-agent delegation // @connected #[tauri::command] pub async fn butler_delegate_task( diff --git a/desktop/src-tauri/src/kernel_commands/agent.rs b/desktop/src-tauri/src/kernel_commands/agent.rs index 9faa4ac..2ee12de 100644 --- a/desktop/src-tauri/src/kernel_commands/agent.rs +++ b/desktop/src-tauri/src/kernel_commands/agent.rs @@ -68,6 +68,7 @@ pub struct AgentUpdateRequest { // --------------------------------------------------------------------------- /// Create a new agent +// @reserved: agent CRUD management // @connected #[tauri::command] pub async fn agent_create( @@ -150,6 +151,7 @@ pub async fn agent_create( } /// List all agents +// @reserved: agent CRUD management // @connected #[tauri::command] pub async fn agent_list( @@ -164,6 +166,7 @@ pub async fn agent_list( } /// Get agent info (with optional UserProfile from memory store) +// @reserved: agent CRUD management // @connected #[tauri::command] pub async fn agent_get( diff --git a/desktop/src-tauri/src/kernel_commands/chat.rs b/desktop/src-tauri/src/kernel_commands/chat.rs index fcab31b..aadb8d1 100644 --- a/desktop/src-tauri/src/kernel_commands/chat.rs +++ b/desktop/src-tauri/src/kernel_commands/chat.rs @@ -89,6 +89,7 @@ pub struct StreamChatRequest { // --------------------------------------------------------------------------- /// Send a message to an agent +// @reserved: agent chat (desktop uses ChatStore/SaaS relay) // @connected #[tauri::command] pub async fn agent_chat( diff --git a/desktop/src-tauri/src/kernel_commands/hand.rs b/desktop/src-tauri/src/kernel_commands/hand.rs index f04668f..e49e3b0 100644 --- a/desktop/src-tauri/src/kernel_commands/hand.rs +++ b/desktop/src-tauri/src/kernel_commands/hand.rs @@ -112,6 +112,7 @@ impl From for HandResult { /// /// Returns hands from the Kernel's HandRegistry. /// Hands are registered during kernel initialization. +// @reserved: Hand autonomous capabilities // @connected #[tauri::command] pub async fn hand_list( @@ -142,6 +143,7 @@ pub async fn hand_list( /// Executes a hand with the given ID and input. /// If the hand has `needs_approval = true`, creates a pending approval instead. /// Returns the hand result as JSON, or a pending status with approval ID. +// @reserved: Hand autonomous capabilities // @connected #[tauri::command] pub async fn hand_execute( @@ -209,6 +211,7 @@ pub async fn hand_execute( /// When approved, the kernel's `respond_to_approval` internally spawns the Hand /// execution. We additionally emit Tauri events so the frontend can track when /// the execution finishes. +// @reserved: Hand approval workflow // @connected #[tauri::command] pub async fn hand_approve( diff --git a/desktop/src-tauri/src/kernel_commands/lifecycle.rs b/desktop/src-tauri/src/kernel_commands/lifecycle.rs index bc50ea7..76f1cd5 100644 --- a/desktop/src-tauri/src/kernel_commands/lifecycle.rs +++ b/desktop/src-tauri/src/kernel_commands/lifecycle.rs @@ -57,6 +57,7 @@ pub struct KernelStatusResponse { /// /// If kernel already exists with the same config, returns existing status. /// If config changed, reboots kernel with new config. +// @reserved: kernel lifecycle management // @connected #[tauri::command] pub async fn kernel_init( diff --git a/desktop/src-tauri/src/kernel_commands/mcp.rs b/desktop/src-tauri/src/kernel_commands/mcp.rs index f22adcc..d4205d2 100644 --- a/desktop/src-tauri/src/kernel_commands/mcp.rs +++ b/desktop/src-tauri/src/kernel_commands/mcp.rs @@ -82,6 +82,7 @@ pub struct McpServiceStatus { // ──────────────────────────────────────────────────────────────── /// Start an MCP server and discover its tools +// @reserved: MCP protocol management /// @connected — frontend: MCPServices.tsx via mcp-client.ts #[tauri::command] pub async fn mcp_start_service( @@ -128,6 +129,7 @@ pub async fn mcp_start_service( } /// Stop an MCP server and remove its tools +// @reserved: MCP protocol management /// @connected — frontend: MCPServices.tsx via mcp-client.ts #[tauri::command] pub async fn mcp_stop_service( @@ -145,6 +147,7 @@ pub async fn mcp_stop_service( } /// List all active MCP services and their tools +// @reserved: MCP protocol management /// @connected — frontend: MCPServices.tsx via mcp-client.ts #[tauri::command] pub async fn mcp_list_services( @@ -177,6 +180,7 @@ pub async fn mcp_list_services( } /// Call an MCP tool directly +// @reserved: MCP protocol management /// @connected — frontend: agent loop via mcp-client.ts #[tauri::command] pub async fn mcp_call_tool( diff --git a/desktop/src-tauri/src/kernel_commands/scheduled_task.rs b/desktop/src-tauri/src/kernel_commands/scheduled_task.rs index 0089528..9de2098 100644 --- a/desktop/src-tauri/src/kernel_commands/scheduled_task.rs +++ b/desktop/src-tauri/src/kernel_commands/scheduled_task.rs @@ -47,6 +47,7 @@ pub struct ScheduledTaskResponse { /// /// Tasks are automatically executed by the SchedulerService which checks /// every 60 seconds for due triggers. +// @reserved: scheduled task management // @connected #[tauri::command] pub async fn scheduled_task_create( @@ -95,6 +96,7 @@ pub async fn scheduled_task_create( } /// List all scheduled tasks (kernel triggers of Schedule type) +// @reserved: scheduled task management // @connected #[tauri::command] pub async fn scheduled_task_list( diff --git a/desktop/src-tauri/src/kernel_commands/skill.rs b/desktop/src-tauri/src/kernel_commands/skill.rs index 3db2c41..5cacf05 100644 --- a/desktop/src-tauri/src/kernel_commands/skill.rs +++ b/desktop/src-tauri/src/kernel_commands/skill.rs @@ -85,6 +85,7 @@ pub async fn skill_list( /// /// Re-scans the skills directory for new or updated skills. /// Optionally accepts a custom directory path to scan. +// @reserved: skill system management // @connected #[tauri::command] pub async fn skill_refresh( @@ -136,6 +137,7 @@ pub struct UpdateSkillRequest { } /// Create a new skill in the skills directory +// @reserved: skill system management // @connected #[tauri::command] pub async fn skill_create( @@ -184,6 +186,7 @@ pub async fn skill_create( } /// Update an existing skill +// @reserved: skill system management // @connected #[tauri::command] pub async fn skill_update( @@ -303,6 +306,7 @@ impl From for SkillResult { /// /// Executes a skill with the given ID and input. /// Returns the skill result as JSON. +// @reserved: skill system management // @connected #[tauri::command] pub async fn skill_execute( diff --git a/desktop/src-tauri/src/kernel_commands/trigger.rs b/desktop/src-tauri/src/kernel_commands/trigger.rs index 8a5db51..8c4a9f0 100644 --- a/desktop/src-tauri/src/kernel_commands/trigger.rs +++ b/desktop/src-tauri/src/kernel_commands/trigger.rs @@ -96,6 +96,7 @@ impl From for TriggerResponse { } /// List all triggers +// @reserved: trigger management // @connected #[tauri::command] pub async fn trigger_list( @@ -110,6 +111,7 @@ pub async fn trigger_list( } /// Get a specific trigger +// @reserved: trigger management // @connected #[tauri::command] pub async fn trigger_get( @@ -127,6 +129,7 @@ pub async fn trigger_get( } /// Create a new trigger +// @reserved: trigger management // @connected #[tauri::command] pub async fn trigger_create( @@ -182,6 +185,7 @@ pub async fn trigger_create( } /// Update a trigger +// @reserved: trigger management // @connected #[tauri::command] pub async fn trigger_update( @@ -227,6 +231,7 @@ pub async fn trigger_delete( } /// Execute a trigger manually +// @reserved: trigger management // @connected #[tauri::command] pub async fn trigger_execute( diff --git a/desktop/src-tauri/src/kernel_commands/workspace.rs b/desktop/src-tauri/src/kernel_commands/workspace.rs index cf3774c..0562a64 100644 --- a/desktop/src-tauri/src/kernel_commands/workspace.rs +++ b/desktop/src-tauri/src/kernel_commands/workspace.rs @@ -10,6 +10,7 @@ pub struct DirStats { } /// Count files and total size in a directory (non-recursive, top-level only) +// @reserved: workspace statistics #[tauri::command] pub async fn workspace_dir_stats(path: String) -> Result { let dir = Path::new(&path); diff --git a/desktop/src-tauri/src/llm/mod.rs b/desktop/src-tauri/src/llm/mod.rs index 3173b59..836d8fa 100644 --- a/desktop/src-tauri/src/llm/mod.rs +++ b/desktop/src-tauri/src/llm/mod.rs @@ -453,6 +453,7 @@ impl EmbeddingClient { } } +// @reserved: embedding vector generation // @connected #[tauri::command] pub async fn embedding_create( @@ -473,6 +474,7 @@ pub async fn embedding_create( client.embed(&text).await } +// @reserved: embedding provider listing // @connected #[tauri::command] pub async fn embedding_providers() -> Result, String> { diff --git a/desktop/src-tauri/src/memory/extractor.rs b/desktop/src-tauri/src/memory/extractor.rs index f9cb49a..71a5514 100644 --- a/desktop/src-tauri/src/memory/extractor.rs +++ b/desktop/src-tauri/src/memory/extractor.rs @@ -473,6 +473,7 @@ If no significant memories found, return empty array: []"#, // === Tauri Commands === +// @reserved: memory extraction // @connected #[tauri::command] pub async fn extract_session_memories( @@ -490,6 +491,7 @@ pub async fn extract_session_memories( /// Extract memories from session and store to SqliteStorage /// This combines extraction and storage in one command +// @reserved: memory extraction and storage // @connected #[tauri::command] pub async fn extract_and_store_memories( diff --git a/desktop/src-tauri/src/pipeline_commands/crud.rs b/desktop/src-tauri/src/pipeline_commands/crud.rs index 8a1185f..e515090 100644 --- a/desktop/src-tauri/src/pipeline_commands/crud.rs +++ b/desktop/src-tauri/src/pipeline_commands/crud.rs @@ -55,6 +55,7 @@ pub struct WorkflowStepInput { } /// Create a new pipeline as a YAML file +// @reserved: pipeline workflow management // @connected #[tauri::command] pub async fn pipeline_create( @@ -180,6 +181,7 @@ pub async fn pipeline_create( } /// Update an existing pipeline +// @reserved: pipeline workflow management // @connected #[tauri::command] pub async fn pipeline_update( diff --git a/desktop/src-tauri/src/pipeline_commands/discovery.rs b/desktop/src-tauri/src/pipeline_commands/discovery.rs index 60414db..8eeb4a6 100644 --- a/desktop/src-tauri/src/pipeline_commands/discovery.rs +++ b/desktop/src-tauri/src/pipeline_commands/discovery.rs @@ -20,6 +20,7 @@ use super::helpers::{get_pipelines_directory, scan_pipelines_with_paths, scan_pi use crate::kernel_commands::KernelState; /// Discover and list all available pipelines +// @reserved: pipeline workflow management // @connected #[tauri::command] pub async fn pipeline_list( @@ -70,6 +71,7 @@ pub async fn pipeline_list( } /// Get pipeline details +// @reserved: pipeline workflow management // @connected #[tauri::command] pub async fn pipeline_get( @@ -85,6 +87,7 @@ pub async fn pipeline_get( } /// Run a pipeline +// @reserved: pipeline workflow management // @connected #[tauri::command] pub async fn pipeline_run( @@ -197,6 +200,7 @@ pub async fn pipeline_run( } /// Get pipeline run progress +// @reserved: pipeline workflow management // @connected #[tauri::command] pub async fn pipeline_progress( @@ -234,6 +238,7 @@ pub async fn pipeline_cancel( } /// Get pipeline run result +// @reserved: pipeline workflow management // @connected #[tauri::command] pub async fn pipeline_result( @@ -261,6 +266,7 @@ pub async fn pipeline_result( } /// List all runs +// @reserved: pipeline workflow management // @connected #[tauri::command] pub async fn pipeline_runs( @@ -287,6 +293,7 @@ pub async fn pipeline_runs( } /// Refresh pipeline discovery +// @reserved: pipeline workflow management // @connected #[tauri::command] pub async fn pipeline_refresh( diff --git a/desktop/src-tauri/src/pipeline_commands/intent_router.rs b/desktop/src-tauri/src/pipeline_commands/intent_router.rs index 1bb8ba3..d6ec03e 100644 --- a/desktop/src-tauri/src/pipeline_commands/intent_router.rs +++ b/desktop/src-tauri/src/pipeline_commands/intent_router.rs @@ -62,6 +62,7 @@ pub struct PipelineCandidateInfo { } /// Route user input to matching pipeline +// @reserved: semantic intent routing // @connected #[tauri::command] pub async fn route_intent( diff --git a/desktop/src-tauri/src/pipeline_commands/presentation.rs b/desktop/src-tauri/src/pipeline_commands/presentation.rs index 8f0aa60..e1cbdd4 100644 --- a/desktop/src-tauri/src/pipeline_commands/presentation.rs +++ b/desktop/src-tauri/src/pipeline_commands/presentation.rs @@ -9,6 +9,7 @@ use super::types::PipelineInputInfo; use super::PipelineState; /// Analyze presentation data +// @reserved: presentation analysis // @connected #[tauri::command] pub async fn analyze_presentation( diff --git a/desktop/src-tauri/src/secure_storage.rs b/desktop/src-tauri/src/secure_storage.rs index c2246e0..896edba 100644 --- a/desktop/src-tauri/src/secure_storage.rs +++ b/desktop/src-tauri/src/secure_storage.rs @@ -32,6 +32,7 @@ pub fn secure_store_set(key: String, value: String) -> Result<(), String> { } /// Retrieve a value from the OS keyring +// @reserved: secure storage access // @connected #[tauri::command] pub fn secure_store_get(key: String) -> Result { @@ -81,6 +82,7 @@ pub fn secure_store_delete(key: String) -> Result<(), String> { } /// Check if secure storage is available on this platform +// @reserved: secure storage access // @connected #[tauri::command] pub fn secure_store_is_available() -> bool { diff --git a/desktop/src-tauri/src/viking_commands.rs b/desktop/src-tauri/src/viking_commands.rs index 92f87ce..c41470e 100644 --- a/desktop/src-tauri/src/viking_commands.rs +++ b/desktop/src-tauri/src/viking_commands.rs @@ -150,6 +150,7 @@ fn get_data_dir_string() -> Option { // === Tauri Commands === /// Check if memory storage is available +// @reserved: VikingStorage persistence // @connected #[tauri::command] pub async fn viking_status() -> Result { @@ -178,6 +179,7 @@ pub async fn viking_status() -> Result { } /// Add a memory entry +// @reserved: VikingStorage persistence // @connected #[tauri::command] pub async fn viking_add(uri: String, content: String) -> Result { @@ -201,6 +203,7 @@ pub async fn viking_add(uri: String, content: String) -> Result Result, String> { @@ -360,6 +366,7 @@ pub async fn viking_ls(path: String) -> Result, String> { } /// Read memory content +// @reserved: VikingStorage persistence // @connected #[tauri::command] pub async fn viking_read(uri: String, level: Option) -> Result { @@ -404,6 +411,7 @@ pub async fn viking_read(uri: String, level: Option) -> Result Result<(), String> { @@ -418,6 +426,7 @@ pub async fn viking_remove(uri: String) -> Result<(), String> { } /// Get memory tree +// @reserved: VikingStorage persistence // @connected #[tauri::command] pub async fn viking_tree(path: String, depth: Option) -> Result { @@ -469,6 +478,7 @@ pub async fn viking_tree(path: String, depth: Option) -> Result