Function dispatch

src/apps/server/src/rpc_dispatcher.rs:27–634

Dispatch a WebSocket RPC method call to the appropriate handler. The `method` string matches the Tauri command name exactly (e.g. `"open_workspace"`, `"terminal_create"`), so the frontend's `api.invoke(name, args)` works identically over both Tauri IPC and WebSocket.

(
    method: &str,
    params: serde_json::Value,
    state: &Arc<ServerAppState>,
)

/// `api.invoke(name, args)` works identically over both Tauri IPC and
/// WebSocket.
pub async fn dispatch(
    method: &str,
    params: serde_json::Value,
    state: &Arc<ServerAppState>,
) -> Result<serde_json::Value> {
    match method {
        // ── Ping ──────────────────────────────────────────────
        "ping" => Ok(serde_json::json!({
            "pong": true,
            "timestamp": chrono::Utc::now().timestamp(),
        })),

        // ── Health / Status ──────────────────────────────────
        "get_health_status" => {
            let uptime = state.start_time.elapsed().as_secs();
            Ok(serde_json::json!({
                "status": "healthy",
                "message": "All services are running normally",
                "services": {
                    "workspace_service": true,
                    "config_service": true,
                    "filesystem_service": true,
                },
                "uptime_seconds": uptime,
            }))
        }

        // ── Workspace ────────────────────────────────────────
        "open_workspace" => {
            let request = extract_request(&params)?;
            let path: String = serde_json::from_value(
                request
                    .get("path")
                    .cloned()
                    .ok_or_else(|| anyhow!("Missing path"))?,
            )?;
            let info = state
                .workspace_service
                .open_workspace(path.into())
                .await
                .map_err(|e| anyhow!("{}", e))?;
            *state.workspace_path.write().await = Some(info.root_path.clone());
            Ok(serde_json::to_value(&info).unwrap_or_default())
        }
        "get_current_workspace" => {
            let ws = state.workspace_service.get_current_workspace().await;
            Ok(serde_json::to_value(&ws).unwrap_or(serde_json::Value::Null))
        }
        "get_recent_workspaces" => {
            let list = state.workspace_service.get_recent_workspaces().await;
            Ok(serde_json::to_value(&list).unwrap_or_default())
        }
        "remove_recent_workspace" => {
            let request = extract_request(&params)?;
            let workspace_id = get_string(request, "workspaceId")?;
            state
                .workspace_service
                .remove_workspace_from_recent(&workspace_id)