lingshu-lsp 0.10.0

LSP client tools for Lingshu: code navigation, diagnostics, and workspace edits via language servers
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116

use lingshu_tools::path_utils::jail_read_path;
use lingshu_tools::registry::ToolContext;
use lingshu_tools::tools::checkpoint::ensure_checkpoint;
use lsp_types::{DocumentChangeOperation, DocumentChanges, OneOf, TextEdit, Uri, WorkspaceEdit};
use serde_json::json;

use crate::error::{LspError, uri_to_path};
use crate::position::PositionEncoder;

pub fn apply_text_edits(original: &str, edits: &[TextEdit]) -> Result<String, LspError> {
    let mut ordered = edits.to_vec();
    ordered.sort_by(|a, b| {
        b.range
            .start
            .line
            .cmp(&a.range.start.line)
            .then(b.range.start.character.cmp(&a.range.start.character))
            .then(b.range.end.line.cmp(&a.range.end.line))
            .then(b.range.end.character.cmp(&a.range.end.character))
    });

    let mut text = original.to_string();
    for edit in ordered {
        let range = PositionEncoder::to_byte_range(&text, edit.range)
            .ok_or_else(|| LspError::Protocol("invalid text edit range".into()))?;
        text.replace_range(range, &edit.new_text);
    }
    Ok(text)
}

#[allow(clippy::result_large_err)]
fn apply_file_edits(
    ctx: &ToolContext,
    file_url: &Uri,
    edits: &[TextEdit],
) -> Result<serde_json::Value, LspError> {
    let path = uri_to_path(file_url)?;
    let rel = path.strip_prefix(&ctx.cwd).unwrap_or(&path);
    let rel_str = rel.to_string_lossy().to_string();
    let policy = ctx.config.file_path_policy(&ctx.cwd);
    let read_path = jail_read_path(&rel_str, &policy)
        .or_else(|_| jail_read_path(&path.to_string_lossy(), &policy))
        .map_err(|err| LspError::Other(err.to_string()))?;
    // LSP workspace edits always modify existing files.  Re-running the path
    // through jail_write_path on the already-resolved absolute read_path causes
    // the virtual-tmp-root mapping to fire a second time, producing a remapped
    // path whose parent directory may not exist (observed on Linux CI).  Writing
    // back to read_path is safe: jail_read_path already validated it is within
    // the workspace (or an explicitly allowed root).
    let original = std::fs::read_to_string(&read_path)?;
    let updated = apply_text_edits(&original, edits)?;
    std::fs::write(&read_path, &updated)?;
    Ok(json!({
        "file": read_path.display().to_string(),
        "changed": original != updated,
        "diff": similar::TextDiff::from_lines(&original, &updated).unified_diff().context_radius(2).to_string(),
    }))
}

pub fn apply_workspace_edit(
    ctx: &ToolContext,
    edit: &WorkspaceEdit,
) -> Result<Vec<serde_json::Value>, LspError> {
    ensure_checkpoint(ctx, "before lsp workspace edit");

    let mut changed = Vec::new();

    if let Some(changes) = &edit.changes {
        let mut ordered: Vec<_> = changes.iter().collect();
        ordered.sort_by(|(left_uri, _), (right_uri, _)| left_uri.as_str().cmp(right_uri.as_str()));
        for (url, edits) in ordered {
            changed.push(apply_file_edits(ctx, url, edits)?);
        }
    }

    if let Some(document_changes) = &edit.document_changes {
        match document_changes {
            DocumentChanges::Edits(edits) => {
                for change in edits {
                    changed.push(apply_file_edits(
                        ctx,
                        &change.text_document.uri,
                        &change
                            .edits
                            .iter()
                            .filter_map(|edit| match edit {
                                OneOf::Left(text_edit) => Some(text_edit.clone()),
                                OneOf::Right(_) => None,
                            })
                            .collect::<Vec<_>>(),
                    )?);
                }
            }
            DocumentChanges::Operations(ops) => {
                for op in ops {
                    if let DocumentChangeOperation::Edit(edit) = op {
                        changed.push(apply_file_edits(
                            ctx,
                            &edit.text_document.uri,
                            &edit
                                .edits
                                .iter()
                                .filter_map(|text_edit| match text_edit {
                                    OneOf::Left(text_edit) => Some(text_edit.clone()),
                                    OneOf::Right(_) => None,
                                })
                                .collect::<Vec<_>>(),
                        )?);
                    }
                }
            }
        }
    }

    Ok(changed)
}