tano_native/

lib.rs

mod agent;
mod assets;
#[cfg(desktop)]
mod assistant;
#[cfg(desktop)]
mod assistant_cli;
mod assistant_files;
pub mod identity_manifest;
#[cfg(desktop)]
mod import_connections;
#[cfg(desktop)]
mod import_oauth;
mod mobile_storage;
#[cfg(test)]
mod performance;
mod personal_plans;
#[cfg(desktop)]
mod plan_connections;
#[cfg(desktop)]
mod plugin_connection_http;
#[cfg(desktop)]
mod plugin_connection_types;
#[cfg(desktop)]
mod plugin_connection_vault;
#[cfg(desktop)]
mod plugin_connections;
#[cfg(desktop)]
mod plugin_native;
#[cfg(desktop)]
mod plugin_oauth;
#[cfg(desktop)]
mod plugin_oauth_loopback;
#[cfg(desktop)]
mod plugin_oauth_types;
mod search;
mod session_storage;
pub mod storage;
mod updates;
#[cfg(desktop)]
mod workspace_git;
mod workspace_identity;
mod workspace_lock;
#[cfg(test)]
mod workspace_responsiveness_tests;
#[cfg(desktop)]
mod workspace_sync;

use notify::{RecursiveMode, Watcher};
use std::{
    path::{Path, PathBuf},
    sync::Mutex,
};
use tauri::{Emitter, Manager, State};

pub struct Session {
    pub root: PathBuf,
    pub id: String,
    root_key: String,
    _watcher: notify::RecommendedWatcher,
    _lock: std::fs::File,
}

#[derive(Default)]
pub struct AppState {
    session: Mutex<Option<Session>>,
}

fn workspace_switch_blocked(app: &tauri::AppHandle) -> bool {
    // Settings are prewarmed and follow the main window's workspace snapshot. Only
    // independent content windows must be closed before replacing the shared session.
    app.webview_windows().keys().any(|label| {
        label != "main" && !label.starts_with("settings-") && !label.starts_with("file-")
    })
}

fn workspace_lock_directory(app: &tauri::AppHandle) -> Result<PathBuf, String> {
    #[cfg(desktop)]
    {
        Ok(workspace_lock::shared_directory(
            &app.path().data_dir().map_err(|e| e.to_string())?,
        ))
    }
    #[cfg(mobile)]
    {
        Ok(app_data(app)?.join("locks"))
    }
}

fn should_notify_workspace_change(relative: &Path) -> bool {
    relative.components().enumerate().all(|(index, component)| {
        let name = component.as_os_str().to_string_lossy();
        (index == 0 && name == ".tano") || !storage::ignored_workspace_name(&name)
    })
}

#[cfg(test)]
mod watcher_path_tests {
    use super::should_notify_workspace_change;
    use std::path::Path;

    #[test]
    fn refreshes_for_identity_metadata_but_ignores_old_hidden_data() {
        for path in [
            ".tano",
            ".tano/config.json",
            ".tano/identities.json",
            "note.md",
        ] {
            assert!(should_notify_workspace_change(Path::new(path)), "{path}");
        }
        for path in [
            ".workspace/objects/old.tano.json",
            ".git/HEAD",
            "node_modules/package/index.js",
            "nested/target/debug/app.exe",
            "dist/index.html",
            ".tano/.tano-temporary",
            "notes/.draft.md",
        ] {
            assert!(!should_notify_workspace_change(Path::new(path)), "{path}");
        }
    }
}

fn with_session<T>(
    state: State<AppState>,
    f: impl FnOnce(&Session) -> Result<T, String>,
) -> Result<T, String> {
    // Every command using this lock must dispatch off the window thread. Opening
    // a workspace holds it during scanning; a synchronous IPC/asset callback
    // waiting here would stall the WebView and all window events.
    let guard = state.session.lock().map_err(|e| e.to_string())?;
    let session = guard.as_ref().ok_or("请先打开一个工作空间")?;
    if !session.root_key.is_empty() && storage::native_key(&session.root) != session.root_key {
        return Err("工作区根目录已替换，请重新打开工作区".into());
    }
    identity_manifest::require(&session.root, &session.id)?;
    f(session)
}

fn with_session_for_journal<T>(
    state: State<AppState>,
    f: impl FnOnce(&Session) -> Result<T, String>,
) -> Result<T, String> {
    let guard = state.session.lock().map_err(|e| e.to_string())?;
    f(guard.as_ref().ok_or("请先打开一个工作空间")?)
}

pub fn cache_path(app: &tauri::AppHandle) -> Result<PathBuf, String> {
    let dir = app.path().app_data_dir().map_err(|e| e.to_string())?;
    std::fs::create_dir_all(&dir).map_err(|e| e.to_string())?;
    Ok(dir.join("index.sqlite"))
}

#[tauri::command]
async fn open_workspace(path: String, app: tauri::AppHandle) -> Result<storage::Workspace, String> {
    tauri::async_runtime::spawn_blocking(move || {
        let state = app.state::<AppState>();
        open_workspace_blocking(path, app.clone(), state)
    })
    .await
    .map_err(|e| format!("打开工作空间任务失败：{e}"))?
}

#[tauri::command(async)]
fn close_workspace(
    workspace_id: String,
    state: State<AppState>,
    app: tauri::AppHandle,
) -> Result<(), String> {
    let mut guard = state.session.lock().map_err(|e| e.to_string())?;
    if guard
        .as_ref()
        .is_some_and(|session| session.id == workspace_id)
    {
        if workspace_switch_blocked(&app) {
            return Err("请先关闭此工作区的独立窗口，再退出工作区".into());
        }
        stop_workspace_plugin_calls(&app);
        guard.take();
    }
    Ok(())
}

#[tauri::command(async)]
fn unregister_workspace(
    workspace_id: String,
    state: State<AppState>,
    app: tauri::AppHandle,
) -> Result<(), String> {
    let mut guard = state.session.lock().map_err(|e| e.to_string())?;
    let session = guard.as_ref().ok_or("请先打开一个工作空间")?;
    if session.id != workspace_id {
        return Err("工作区已切换，请重新确认删除注册".into());
    }
    // The settings window is part of this flow; only detached editors block unregistering.
    if app
        .webview_windows()
        .keys()
        .any(|label| label.starts_with("detached-"))
    {
        return Err("请先关闭此工作区的独立文档窗口，再删除注册".into());
    }
    session_storage::unregister(
        &cache_path(&app)?,
        &app_data(&app)?,
        &session.root,
        &session.id,
    )?;
    stop_workspace_plugin_calls(&app);
    guard.take();
    Ok(())
}

fn stop_workspace_plugin_calls(_app: &tauri::AppHandle) {
    // Cancel at the transition itself, so switching away and back between polling
    // ticks cannot revive a previous workspace's request or account login.
    #[cfg(desktop)]
    if let Some(state) = _app.try_state::<plugin_native::PluginNativeState>() {
        state.stop_workspace();
    }
}

fn open_workspace_blocking(
    path: String,
    app: tauri::AppHandle,
    state: State<AppState>,
) -> Result<storage::Workspace, String> {
    let mut guard = state.session.lock().map_err(|e| e.to_string())?;
    let root = std::fs::canonicalize(&path)
        .map_err(|e| format!("无法打开工作文件夹，请确认目录仍然存在：{e}"))?;
    #[cfg(mobile)]
    let root = mobile_storage::validate(&app_data(&app)?, &root)?;
    if !root.is_dir() {
        return Err("请选择一个文件夹".into());
    }
    let newly_created = storage::existing_workspace_identity(&root)?.is_none();
    if let Some(session) = guard.as_ref() {
        if session.root == root && !newly_created {
            identity_manifest::require(&root, &session.id)?;
            return storage::scan(&root, &session.id, &cache_path(&app)?);
        }
        if workspace_switch_blocked(&app) {
            return Err("请先关闭此工作区的独立窗口，再切换工作区".into());
        }
    }
    let data = app_data(&app)?;
    let registered = workspace_identity::registered_identity(&data, &root)?;
    let recent_id = if registered.is_none() {
        guard
            .as_ref()
            .filter(|session| session.root == root)
            .map(|session| session.id.clone())
            .or(session_storage::known_identity(&cache_path(&app)?, &root)?)
    } else {
        None
    };
    let reinitialized = newly_created && (registered.is_some() || recent_id.is_some());
    let id = workspace_identity::identity_for_open(
        &data,
        &root,
        recent_id.as_deref(),
        &cache_path(&app)?,
    )?;
    let reuse_lock = guard.as_ref().is_some_and(|session| session.id == id);
    let lock = if reuse_lock {
        None
    } else {
        Some(workspace_lock::acquire(
            &workspace_lock_directory(&app)?,
            &id,
        )?)
    };
    storage::assert_workspace_identity(&root, &id)?;
    let mut workspace = storage::scan(&root, &id, &cache_path(&app)?)?;
    workspace.newly_created = newly_created.then_some(true);
    workspace.reinitialized = reinitialized.then_some(true);
    let handle = app.clone();
    let watch_root = root.clone();
    let mut watcher = notify::recommended_watcher(
        move |event: Result<notify::Event, notify::Error>| match event {
            Ok(event) => {
                if matches!(event.kind, notify::EventKind::Access(_)) {
                    return;
                }
                if event.paths.iter().any(|path| {
                    path.strip_prefix(&watch_root)
                        .is_ok_and(should_notify_workspace_change)
                }) {
                    let _ = handle.emit("workspace-changed", ());
                }
            }
            Err(error) => {
                let _ = handle.emit("workspace-watch-error", error.to_string());
            }
        },
    )
    .map_err(|e| e.to_string())?;
    watcher
        .watch(&root, RecursiveMode::Recursive)
        .map_err(|e| e.to_string())?;
    session_storage::record(&cache_path(&app)?, &workspace)?;
    workspace_identity::register_identity(&data, &root, &id)?;
    let lock = match lock {
        Some(lock) => lock,
        None => guard.take().ok_or("工作区会话已关闭")?._lock,
    };
    stop_workspace_plugin_calls(&app);
    *guard = Some(Session {
        root_key: storage::native_key(&root),
        root,
        id,
        _watcher: watcher,
        _lock: lock,
    });
    Ok(workspace)
}

#[tauri::command]
async fn refresh_workspace(app: tauri::AppHandle) -> Result<storage::Workspace, String> {
    tauri::async_runtime::spawn_blocking(move || {
        let state = app.state::<AppState>();
        with_session(state, |s| storage::scan(&s.root, &s.id, &cache_path(&app)?))
    })
    .await
    .map_err(|e| format!("刷新工作空间任务失败：{e}"))?
}

#[tauri::command(async)]
fn search_documents(
    workspace_id: String,
    query: String,
    app: tauri::AppHandle,
    state: State<AppState>,
) -> Result<Vec<search::SearchHit>, String> {
    with_workspace_session(&workspace_id, state, |s| {
        search::query(&cache_path(&app)?, &s.id, &query)
    })
}

#[tauri::command(async)]
fn recent_workspaces(
    app: tauri::AppHandle,
) -> Result<Vec<session_storage::RecentWorkspace>, String> {
    let recent = session_storage::recent(&cache_path(&app)?)?;
    #[cfg(mobile)]
    let data = app_data(&app)?;
    #[cfg(mobile)]
    let recent = recent
        .into_iter()
        .filter(|entry| mobile_storage::validate(&data, std::path::Path::new(&entry.path)).is_ok())
        .collect();
    Ok(recent)
}

#[tauri::command]
fn runtime_platform() -> serde_json::Value {
    serde_json::json!({"mobile": cfg!(mobile), "os": std::env::consts::OS})
}

#[cfg(desktop)]
#[tauri::command]
fn open_devtools(window: tauri::WebviewWindow) {
    window.open_devtools();
}

#[tauri::command]
async fn tab_drag_release() -> Result<serde_json::Value, String> {
    #[cfg(windows)]
    {
        tauri::async_runtime::spawn_blocking(|| {
            use windows_sys::Win32::Foundation::POINT;
            use windows_sys::Win32::UI::Input::KeyboardAndMouse::{GetAsyncKeyState, VK_LBUTTON};
            use windows_sys::Win32::UI::WindowsAndMessaging::GetCursorPos;

            // The WebView may not dispatch dragend after an OS drag ends outside its window.
            // Observe the button on a host thread so renderer timer throttling cannot lose it.
            while unsafe { GetAsyncKeyState(VK_LBUTTON.into()) < 0 } {
                std::thread::sleep(std::time::Duration::from_millis(8));
            }
            let mut point = POINT { x: 0, y: 0 };
            if unsafe { GetCursorPos(&mut point) } == 0 {
                return Err(std::io::Error::last_os_error().to_string());
            }
            Ok(serde_json::json!({"x": point.x, "y": point.y}))
        })
        .await
        .map_err(|error| error.to_string())?
    }
    #[cfg(not(windows))]
    {
        Err("Tab drag release observation is only available on Windows".to_owned())
    }
}

#[tauri::command]
async fn open_mobile_workspace(
    name: Option<String>,
    app: tauri::AppHandle,
) -> Result<storage::Workspace, String> {
    if !cfg!(mobile) {
        return Err("仅在移动应用中创建沙箱空间".into());
    }
    let data = app_data(&app)?;
    let path = match name {
        Some(name) => mobile_storage::create(&data, &name)?,
        None => mobile_storage::default_workspace(&data)?,
    };
    open_workspace(path.to_string_lossy().to_string(), app).await
}

#[tauri::command(async)]
fn mobile_recycled(
    workspace_id: String,
    app: tauri::AppHandle,
    state: State<AppState>,
) -> Result<Vec<mobile_storage::RecycledFile>, String> {
    if !cfg!(mobile) {
        return Err("桌面端请使用系统回收站".into());
    }
    with_workspace_session(&workspace_id, state, |s| {
        mobile_storage::recycled(&app_data(&app)?, &s.id)
    })
}

#[tauri::command(async)]
fn mobile_recover(
    workspace_id: String,
    id: String,
    app: tauri::AppHandle,
    state: State<AppState>,
) -> Result<String, String> {
    if !cfg!(mobile) {
        return Err("桌面端请使用系统回收站".into());
    }
    with_workspace_session(&workspace_id, state, |s| {
        mobile_storage::recover(&app_data(&app)?, &s.root, &s.id, &id)
    })
}
#[tauri::command(async)]
fn load_session(
    workspace_id: String,
    app: tauri::AppHandle,
    state: State<AppState>,
) -> Result<Option<session_storage::WorkspaceSession>, String> {
    with_session_for_journal(state, |s| {
        if s.id != workspace_id {
            return Err("会话所属工作区已切换".into());
        }
        session_storage::load(&app_data(&app)?, &s.id)
    })
}
#[tauri::command(async)]
fn save_session(
    workspace_id: String,
    session: session_storage::WorkspaceSession,
    app: tauri::AppHandle,
    state: State<AppState>,
) -> Result<(), String> {
    with_session_for_journal(state, |s| {
        if s.id != workspace_id {
            return Err("会话所属工作区已切换".into());
        }
        session_storage::save(&app_data(&app)?, &s.id, &session)
    })
}

#[tauri::command(async)]
fn import_attachment(
    workspace_id: String,
    name: String,
    content: String,
    require_image: bool,
    app: tauri::AppHandle,
    state: State<AppState>,
) -> Result<assets::ImportedAsset, String> {
    use base64::Engine;
    if content.len() > 70 * 1024 * 1024 {
        return Err("附件过大".into());
    }
    let bytes = base64::engine::general_purpose::STANDARD
        .decode(content)
        .map_err(|_| "附件编码无效")?;
    with_workspace_mutating_session(&workspace_id, state, &app, |s| {
        assets::import(
            &s.root,
            &name,
            &bytes,
            require_image,
            Some((&s.id, &cache_path(&app)?)),
        )
    })
}

#[tauri::command(async)]
fn read_attachment(
    workspace_id: String,
    path: String,
    state: State<AppState>,
) -> Result<String, String> {
    use base64::Engine;
    with_workspace_session(&workspace_id, state, |s| {
        let bytes = assets::read(&s.root, &path)?;
        Ok(base64::engine::general_purpose::STANDARD.encode(bytes))
    })
}

#[tauri::command(async)]
fn export_attachment(
    workspace_id: String,
    path: String,
    destination: String,
    app: tauri::AppHandle,
    state: State<AppState>,
) -> Result<(), String> {
    with_workspace_session(&workspace_id, state, |s| {
        let bytes = assets::read(&s.root, &path)?;
        write_export(&app, &destination, &bytes)
    })
}

#[tauri::command(async)]
fn export_document(
    content: String,
    destination: String,
    app: tauri::AppHandle,
) -> Result<(), String> {
    use base64::Engine;
    if content.len() > 70 * 1024 * 1024 {
        return Err("导出文件不能超过 50 MiB".into());
    }
    let bytes = base64::engine::general_purpose::STANDARD
        .decode(content)
        .map_err(|e| format!("无效导出内容：{e}"))?;
    if bytes.len() > 50 * 1024 * 1024 {
        return Err("导出文件不能超过 50 MiB".into());
    }
    write_export(&app, &destination, &bytes)
}

fn write_export(app: &tauri::AppHandle, destination: &str, bytes: &[u8]) -> Result<(), String> {
    #[cfg(mobile)]
    {
        use std::io::Write;
        use tauri_plugin_fs::FsExt;
        let destination: tauri_plugin_fs::FilePath = destination
            .parse()
            .map_err(|e| format!("无效导出位置：{e}"))?;
        #[cfg(target_os = "android")]
        if !matches!(&destination, tauri_plugin_fs::FilePath::Url(url) if url.scheme() == "content")
        {
            return Err("请通过 Android 文件选择器选择导出位置".into());
        }
        #[cfg(target_os = "ios")]
        {
            let target = destination.clone().into_path().map_err(|e| e.to_string())?;
            let parent = std::fs::canonicalize(target.parent().ok_or("导出路径无效")?)
                .map_err(|e| e.to_string())?;
            if parent
                .starts_with(std::fs::canonicalize(app_data(&app)?).map_err(|e| e.to_string())?)
            {
                return Err("请选择工作空间之外的导出位置".into());
            }
        }
        let mut options = tauri_plugin_fs::OpenOptions::new();
        options.write(true).truncate(true).create(true);
        let result = (|| {
            let mut file = app
                .fs()
                .open(destination.clone(), options)
                .map_err(|e| e.to_string())?;
            file.write_all(&bytes).map_err(|e| e.to_string())?;
            file.sync_all().map_err(|e| e.to_string())
        })();
        #[cfg(target_os = "ios")]
        let _ = app
            .fs()
            .stop_accessing_security_scoped_resource(destination);
        result
    }
    #[cfg(desktop)]
    {
        let _ = app;
        let target = PathBuf::from(destination);
        if !target.is_absolute() {
            return Err("请选择完整的保存路径".into());
        }
        storage::create_atomic(&target, bytes)
            .map_err(|e| format!("无法导出；请使用尚未存在的文件名：{e}"))
    }
}

#[tauri::command(async)]
fn open_external_url(url: String, app: tauri::AppHandle) -> Result<(), String> {
    let parsed = validated_external_url(&url)?;
    use tauri_plugin_opener::OpenerExt;
    app.opener()
        .open_url(parsed.as_str(), None::<&str>)
        .map_err(|e| e.to_string())
}

fn validated_external_url(url: &str) -> Result<tauri::Url, String> {
    let parsed = tauri::Url::parse(url).map_err(|_| "链接地址无效")?;
    match parsed.scheme() {
        "http" | "https" if parsed.username().is_empty() && parsed.password().is_none() => {}
        "mailto" => {
            let address = parsed.path();
            let valid_address = address.split_once('@').is_some_and(|(local, domain)| {
                !local.is_empty()
                    && !domain.is_empty()
                    && !domain.contains('@')
                    && address.bytes().all(|byte| {
                        byte.is_ascii_alphanumeric()
                            || matches!(byte, b'@' | b'.' | b'_' | b'+' | b'-')
                    })
            });
            if !valid_address || parsed.query().is_some() || parsed.fragment().is_some() {
                return Err("邮箱链接仅支持单个有效地址".into());
            }
        }
        _ => return Err("外部链接只支持 HTTP、HTTPS 和 mailto 地址".into()),
    }
    Ok(parsed)
}

#[cfg(test)]
mod external_url_tests {
    use super::validated_external_url;

    #[test]
    fn accepts_web_and_email_links() {
        assert!(validated_external_url("https://example.com/path").is_ok());
        assert!(validated_external_url("mailto:test+tag@example.com").is_ok());
    }

    #[test]
    fn rejects_unsafe_or_ambiguous_external_links() {
        for url in [
            "javascript:alert(1)",
            "https://user:secret@example.com",
            "mailto:test@example.com?subject=hello",
            "mailto:test%0a@example.com",
            "mailto:test@example.com,other@example.com",
        ] {
            assert!(validated_external_url(url).is_err(), "{url}");
        }
    }
}

#[tauri::command(async)]
fn read_document(path: String, state: State<AppState>) -> Result<storage::Snapshot, String> {
    with_session(state, |s| {
        storage::read(&storage::resolve_storage(&s.root, &path, true)?)
    })
}

#[tauri::command(async)]
fn write_document(
    path: String,
    content: String,
    expected_hash: String,
    state: State<AppState>,
) -> Result<storage::WriteResult, String> {
    with_session(state, |s| {
        let target = storage::resolve_storage(&s.root, &path, false)?;
        storage::write(&target, &content, &expected_hash)
    })
}

#[tauri::command(async)]
fn create_agent_record(
    path: String,
    content: String,
    app: tauri::AppHandle,
    state: State<AppState>,
) -> Result<(), String> {
    let object: serde_json::Value = serde_json::from_str(&content).map_err(|_| "对象 JSON 无效")?;
    let id = object
        .get("id")
        .and_then(serde_json::Value::as_str)
        .ok_or("对象身份缺失")?;
    if !storage::is_short_id(id)
        || !(path == format!(".tano/objects/{id}.tano.json")
            || (!path.starts_with('.') && path.ends_with(".table.json")))
    {
        return Err("对象路径无效".into());
    }
    with_session(state, |s| {
        let target = storage::ensure_file_parent(&s.root, &path)?;
        if target.exists() {
            return Err("对象路径已存在".into());
        }
        identity_manifest::claim_external(&s.root, &s.id, &cache_path(&app)?, id)?;
        // Failed publication deliberately keeps the ID reserved; never reuse an identity.
        storage::create_atomic(&target, content.as_bytes())
    })
}

#[tauri::command(async)]
fn reserve_reference_id(
    app: tauri::AppHandle,
    occupied: Vec<String>,
    state: State<AppState>,
) -> Result<String, String> {
    with_session(state, |s| {
        identity_manifest::reserve(&s.root, &s.id, &cache_path(&app)?, &occupied)
    })
}

#[tauri::command(async)]
fn create_document(
    path: String,
    content: String,
    app: tauri::AppHandle,
    state: State<AppState>,
) -> Result<(), String> {
    with_session(state, |s| {
        let target = if storage::is_workspace_data_path(&path) {
            storage::ensure_file_parent(&s.root, &path)?
        } else {
            storage::resolve(&s.root, &path, false)?
        };
        let cache = cache_path(&app)?;
        identity_manifest::begin_create(&s.root, &s.id, &cache, &path, content.as_bytes())?;
        if let Err(error) = storage::create(&target, &content) {
            let _ = identity_manifest::recover_mutation(&s.root, &s.id, &cache);
            return Err(error);
        }
        identity_manifest::recover_mutation(&s.root, &s.id, &cache)
    })
}

#[tauri::command(async)]
fn create_folder(path: String, state: State<AppState>) -> Result<(), String> {
    with_session(state, |s| {
        std::fs::create_dir(storage::resolve(&s.root, &path, false)?).map_err(|e| e.to_string())
    })
}

#[tauri::command(async)]
fn rename_document(
    from: String,
    to: String,
    app: tauri::AppHandle,
    state: State<AppState>,
) -> Result<(), String> {
    with_session(state, |s| {
        storage::rename(&s.root, &s.id, &from, &to, &cache_path(&app)?)
    })
}

#[tauri::command(async)]
fn move_entry(
    from: String,
    to: String,
    app: tauri::AppHandle,
    state: State<AppState>,
) -> Result<(), String> {
    with_session(state, |s| {
        storage::move_entry(&s.root, &s.id, &from, &to, &cache_path(&app)?)
    })
}

#[tauri::command(async)]
fn remove_document(
    path: String,
    app: tauri::AppHandle,
    state: State<AppState>,
) -> Result<(), String> {
    with_session(state, |s| {
        let target = storage::resolve_storage(&s.root, &path, true)?;
        #[cfg(mobile)]
        if !target.is_file() {
            return Err("手机回收站暂不支持文件夹".into());
        }
        let cache = cache_path(&app)?;
        identity_manifest::begin_delete(&s.root, &s.id, &cache, &path)?;
        #[cfg(desktop)]
        {
            if let Err(error) = trash::delete(target) {
                let _ = identity_manifest::recover_mutation(&s.root, &s.id, &cache);
                return Err(error.to_string());
            }
        }
        #[cfg(mobile)]
        {
            if let Err(error) = mobile_storage::recycle(&app_data(&app)?, &s.root, &s.id, &path) {
                let _ = identity_manifest::recover_mutation(&s.root, &s.id, &cache);
                return Err(error);
            }
        }
        identity_manifest::recover_mutation(&s.root, &s.id, &cache)
    })
}

#[tauri::command(async)]
fn change_assistant_file(
    request: assistant_files::FileChangeRequest,
    app: tauri::AppHandle,
    state: State<AppState>,
) -> Result<storage::WriteResult, String> {
    with_session(state, |s| {
        assistant_files::change(&s.root, &s.id, &cache_path(&app)?, &request, |target| {
            #[cfg(desktop)]
            {
                trash::delete(target).map_err(|error| error.to_string())
            }
            #[cfg(mobile)]
            {
                let _ = target;
                mobile_storage::recycle(&app_data(&app)?, &s.root, &s.id, &request.path)
            }
        })
    })
}

#[tauri::command(async)]
fn delete_workspace_object(
    request: assistant_files::FileChangeRequest,
    app: tauri::AppHandle,
    state: State<AppState>,
) -> Result<storage::WriteResult, String> {
    with_session(state, |s| {
        assistant_files::delete_object(&s.root, &s.id, &cache_path(&app)?, &request, |target| {
            #[cfg(desktop)]
            {
                trash::delete(target).map_err(|error| error.to_string())
            }
            #[cfg(mobile)]
            {
                let _ = target;
                mobile_storage::recycle(&app_data(&app)?, &s.root, &s.id, &request.path)
            }
        })
    })
}

#[tauri::command(async)]
fn reveal_workspace(state: State<AppState>) -> Result<(), String> {
    #[cfg(mobile)]
    {
        let _ = state;
        return Err("手机空间保存在应用沙箱中".into());
    }
    #[cfg(desktop)]
    with_session(state, |s| {
        #[cfg(windows)]
        let command = "explorer";
        #[cfg(target_os = "macos")]
        let command = "open";
        #[cfg(all(unix, not(target_os = "macos")))]
        let command = "xdg-open";
        std::process::Command::new(command)
            .arg(&s.root)
            .spawn()
            .map_err(|e| e.to_string())?;
        Ok(())
    })
}

#[tauri::command(async)]
fn open_workspace_entry(
    workspace_id: String,
    path: String,
    reveal: bool,
    state: State<AppState>,
) -> Result<(), String> {
    #[cfg(mobile)]
    {
        let _ = (workspace_id, path, reveal, state);
        return Err("请在桌面端打开工作区文件".into());
    }
    #[cfg(desktop)]
    with_workspace_session(&workspace_id, state, |s| {
        let target = storage::resolve(&s.root, &path, true)?;
        if reveal {
            tauri_plugin_opener::reveal_item_in_dir(&target)
        } else {
            tauri_plugin_opener::open_path(&target, None::<&str>)
        }
        .map_err(|e| e.to_string())
    })
}

#[tauri::command(async)]
fn workspace_entry_path(
    workspace_id: String,
    path: String,
    state: State<AppState>,
) -> Result<String, String> {
    #[cfg(mobile)]
    {
        let _ = (workspace_id, path, state);
        return Err("请在桌面端复制工作区文件路径".into());
    }
    #[cfg(desktop)]
    with_workspace_session(&workspace_id, state, |s| {
        storage::resolve(&s.root, &path, true)?
            .into_os_string()
            .into_string()
            .map_err(|_| "文件路径包含无法复制的字符".into())
    })
}

#[tauri::command(async)]
fn duplicate_workspace_entry(
    workspace_id: String,
    path: String,
    app: tauri::AppHandle,
    state: State<AppState>,
) -> Result<String, String> {
    with_workspace_mutating_session(&workspace_id, state, &app, |s| {
        let duplicate = storage::duplicate_entry(&s.root, &path)?;
        storage::scan(&s.root, &s.id, &cache_path(&app)?)?;
        Ok(duplicate)
    })
}

#[tauri::command(async)]
fn open_workspace_terminal(workspace_id: String, state: State<AppState>) -> Result<(), String> {
    if cfg!(mobile) {
        return Err("请在电脑端打开工作区终端".into());
    }
    with_workspace_session(&workspace_id, state, |s| agent::terminal(&s.root))
}

#[tauri::command(async)]
fn agent_setup(
    workspace_id: String,
    app: tauri::AppHandle,
    state: State<AppState>,
) -> Result<serde_json::Value, String> {
    if cfg!(mobile) {
        return Err("本机 MCP 仅在桌面提供，请在电脑端使用".into());
    }
    with_workspace_session(&workspace_id, state, |s| {
        let bundled = app
            .path()
            .resource_dir()
            .map_err(|e| e.to_string())?
            .join("mcp/tano-mcp.cjs");
        let development =
            PathBuf::from(env!("CARGO_MANIFEST_DIR")).join("../../apps/mcp/dist/tano-mcp.cjs");
        let script = if bundled.is_file() {
            bundled
        } else {
            development
        };
        let exists = script.is_file();
        let script = if exists {
            std::fs::canonicalize(script).map_err(|e| e.to_string())?
        } else {
            script
        };
        #[cfg(target_os = "linux")]
        let script = if exists {
            agent::persistent_mcp_script(&script, &app_data(&app)?)?
        } else {
            script
        };
        let plain = |p: &std::path::Path| {
            p.display()
                .to_string()
                .trim_start_matches("\\\\?\\")
                .to_string()
        };
        Ok(
            serde_json::json!({"bundled": exists, "config": {"mcpServers": {"tano": {
                "command": "node", "args": [plain(&script), "--workspace", plain(&s.root), "--data-dir", plain(&app_data(&app)?)]
            }}}}),
        )
    })
}

#[tauri::command(async)]
fn agent_changes(
    workspace_id: String,
    selected: Option<String>,
    app: tauri::AppHandle,
    state: State<AppState>,
) -> Result<Vec<agent::Change>, String> {
    with_workspace_session(&workspace_id, state, |s| {
        agent::changes(&app_data(&app)?, &s.id, &s.root, selected.as_deref())
    })
}

pub fn with_workspace_session<T>(
    workspace_id: &str,
    state: State<AppState>,
    f: impl FnOnce(&Session) -> Result<T, String>,
) -> Result<T, String> {
    with_session(state, |session| {
        if session.id != workspace_id {
            return Err("所属工作空间已切换，操作已取消".into());
        }
        f(session)
    })
}

pub fn with_workspace_mutating_session<T>(
    workspace_id: &str,
    state: State<AppState>,
    _app: &tauri::AppHandle,
    f: impl FnOnce(&Session) -> Result<T, String>,
) -> Result<T, String> {
    with_workspace_session(workspace_id, state, f)
}

/// Called under the workspace session lock before a cloud adapter applies local files.
pub fn assert_cloud_sync_available(data: &Path, workspace_id: &str) -> Result<(), String> {
    let path = data
        .join("workspace-sync")
        .join(workspace_id)
        .join("state.json");
    let bytes = match std::fs::read(path) {
        Ok(bytes) => bytes,
        Err(error) if error.kind() == std::io::ErrorKind::NotFound => return Ok(()),
        Err(error) => return Err(error.to_string()),
    };
    let state: serde_json::Value =
        serde_json::from_slice(&bytes).map_err(|_| "同步配置损坏，已停止云端写入")?;
    match state.get("backend") {
        Some(serde_json::Value::Null) => Ok(()),
        Some(serde_json::Value::String(backend)) if backend == "cloud" => Ok(()),
        _ => Err("当前工作区由 Git 同步，已阻止云端文件写入".into()),
    }
}

pub fn app_data(app: &tauri::AppHandle) -> Result<PathBuf, String> {
    let directory = app.path().app_data_dir().map_err(|e| e.to_string())?;
    std::fs::create_dir_all(&directory).map_err(|e| e.to_string())?;
    Ok(directory)
}

pub fn configure(builder: tauri::Builder<tauri::Wry>) -> tauri::Builder<tauri::Wry> {
    configure_with_commands(builder, &[], |_| false)
}

/// Compose host commands with the local command router without replacing it.
pub fn configure_with_commands(
    builder: tauri::Builder<tauri::Wry>,
    commands: &'static [&'static str],
    extra: impl Fn(tauri::ipc::Invoke<tauri::Wry>) -> bool + Send + Sync + 'static,
) -> tauri::Builder<tauri::Wry> {
    #[cfg(desktop)]
    let builder = builder.plugin(tauri_plugin_updater::Builder::new().build());
    #[cfg(desktop)]
    let builder = builder.manage(assistant::AssistantState::default());
    #[cfg(desktop)]
    let builder = builder.manage(plugin_native::PluginNativeState::default());
    #[cfg(desktop)]
    let builder = builder.manage(plugin_oauth::PluginOAuthState::default());
    builder
        .plugin(tauri_plugin_dialog::init())
        .plugin(tauri_plugin_opener::init())
        .plugin(tauri_plugin_fs::init())
        .manage(AppState::default())
        .manage(updates::UpdateState::default())
        .on_window_event(|window, event| {
            #[cfg(desktop)]
            if matches!(event, tauri::WindowEvent::Destroyed) {
                window
                    .state::<assistant::AssistantState>()
                    .stop_window(window.label());
                window
                    .state::<plugin_native::PluginNativeState>()
                    .stop_window(window.label());
            }
        })
        .register_asynchronous_uri_scheme_protocol("tano-asset", |context, request, responder| {
            let app = context.app_handle().clone();
            tauri::async_runtime::spawn_blocking(move || {
                let state = app.state::<AppState>();
                let response = match state.session.lock() {
                    Ok(guard) if guard.is_some() => {
                        let session = guard.as_ref().unwrap();
                        assets::respond(&session.root, &session.id, &request)
                    }
                    _ => tauri::http::Response::builder()
                        .status(404)
                        .body(b"No workspace".to_vec())
                        .expect("static response"),
                };
                responder.respond(response);
            });
        })
        .invoke_handler(move |invoke| {
            #[cfg(desktop)]
            if invoke.message.command() == "workspace_git_query" {
                let handler: fn(tauri::ipc::Invoke<tauri::Wry>) -> bool =
                    tauri::generate_handler![workspace_git::workspace_git_query];
                return handler(invoke);
            }
            #[cfg(desktop)]
            if invoke.message.command() == "workspace_sync" {
                let handler: fn(tauri::ipc::Invoke<tauri::Wry>) -> bool =
                    tauri::generate_handler![workspace_sync::workspace_sync];
                return handler(invoke);
            }

            #[cfg(desktop)]
            if invoke.message.command().starts_with("plugin_connections_") {
                let handler: fn(tauri::ipc::Invoke<tauri::Wry>) -> bool = tauri::generate_handler![
                    plugin_connections::plugin_connections_list,
                    plugin_connections::plugin_connections_save,
                    plugin_connections::plugin_connections_remove,
                    plugin_connections::plugin_connections_request,
                    plugin_oauth::plugin_connections_oauth_providers,
                    plugin_oauth::plugin_connections_oauth_start,
                    plugin_oauth::plugin_connections_oauth_status,
                    plugin_oauth::plugin_connections_oauth_cancel,
                ];
                return handler(invoke);
            }
            #[cfg(desktop)]
            if matches!(
                invoke.message.command(),
                "plugin_native_request" | "plugin_native_cancel"
            ) {
                let handler: fn(tauri::ipc::Invoke<tauri::Wry>) -> bool = tauri::generate_handler![
                    plugin_native::plugin_native_request,
                    plugin_native::plugin_native_cancel,
                ];
                return handler(invoke);
            }
            #[cfg(desktop)]
            if invoke.message.command() == "open_devtools" {
                let handler: fn(tauri::ipc::Invoke<tauri::Wry>) -> bool =
                    tauri::generate_handler![open_devtools];
                return handler(invoke);
            }
            #[cfg(desktop)]
            if invoke.message.command().starts_with("assistant_") {
                let handler: fn(tauri::ipc::Invoke<tauri::Wry>) -> bool = tauri::generate_handler![
                    assistant::assistant_protocol_version,
                    assistant::assistant_connections,
                    assistant::assistant_models,
                    assistant::assistant_connection_save,
                    assistant::assistant_connection_remove,
                    assistant::assistant_request,
                    assistant::assistant_cancel,
                    assistant::assistant_sessions_load,
                    assistant::assistant_session_save,
                    assistant::assistant_session_delete,
                    assistant::assistant_external_sessions,
                    assistant::assistant_external_result,
                ];
                return handler(invoke);
            }
            #[cfg(desktop)]
            if matches!(
                invoke.message.command(),
                "plan_accounts_list"
                    | "plan_account_save"
                    | "plan_account_remove"
                    | "plan_account_oauth"
                    | "plan_remote_request"
                    | "plan_sync_state_read"
                    | "plan_sync_state_write"
            ) {
                let handler: fn(tauri::ipc::Invoke<tauri::Wry>) -> bool = tauri::generate_handler![
                    plan_connections::plan_accounts_list,
                    plan_connections::plan_account_save,
                    plan_connections::plan_account_remove,
                    plan_connections::plan_account_oauth,
                    plan_connections::plan_remote_request,
                    plan_connections::plan_sync_state_read,
                    plan_connections::plan_sync_state_write,
                ];
                return handler(invoke);
            }
            #[cfg(desktop)]
            if matches!(
                invoke.message.command(),
                "import_capabilities"
                    | "import_accounts"
                    | "import_connect"
                    | "import_cancel"
                    | "import_disconnect"
                    | "import_request"
            ) {
                let handler: fn(tauri::ipc::Invoke<tauri::Wry>) -> bool = tauri::generate_handler![
                    import_connections::import_capabilities,
                    import_connections::import_accounts,
                    import_connections::import_connect,
                    import_connections::import_cancel,
                    import_connections::import_disconnect,
                    import_connections::import_request
                ];
                return handler(invoke);
            }
            if commands.contains(&invoke.message.command()) {
                extra(invoke)
            } else {
                let handler: fn(tauri::ipc::Invoke<tauri::Wry>) -> bool = tauri::generate_handler![
                    updates::update_status,
                    updates::update_check,
                    updates::update_download,
                    updates::update_install,
                    open_workspace,
                    close_workspace,
                    unregister_workspace,
                    runtime_platform,
                    tab_drag_release,
                    open_mobile_workspace,
                    mobile_recycled,
                    mobile_recover,
                    search_documents,
                    recent_workspaces,
                    load_session,
                    save_session,
                    import_attachment,
                    read_attachment,
                    export_attachment,
                    export_document,
                    open_external_url,
                    refresh_workspace,
                    reserve_reference_id,
                    create_agent_record,
                    personal_plans::personal_plans_list,
                    personal_plans::personal_plans_read,
                    personal_plans::personal_plans_reserve,
                    personal_plans::personal_plans_create,
                    personal_plans::personal_plans_write,
                    read_document,
                    write_document,
                    create_document,
                    create_folder,
                    rename_document,
                    move_entry,
                    remove_document,
                    change_assistant_file,
                    delete_workspace_object,
                    reveal_workspace,
                    open_workspace_entry,
                    workspace_entry_path,
                    duplicate_workspace_entry,
                    open_workspace_terminal,
                    agent_setup,
                    agent_changes
                ];
                handler(invoke)
            }
        })
}