use std::collections::HashMap;
use std::path::{Path, PathBuf};
use std::process::Stdio;
use serde_json::{Value, json};
use tokio::io::{AsyncBufReadExt, AsyncReadExt, AsyncWriteExt, BufReader};
use tokio::process::{Child, ChildStdin, ChildStdout, Command};
use crate::lsp::{Caller, LspError, RefSite, Symbol};
pub struct LspClient {
_child: Child,
stdin: ChildStdin,
stdout: BufReader<ChildStdout>,
next_id: i64,
root: PathBuf,
open_docs: HashMap<PathBuf, i64>,
}
impl LspClient {
pub async fn spawn(bin: &str, argv: &[&str], root: &Path) -> Result<Self, LspError> {
let mut child = Command::new(bin)
.args(argv)
.current_dir(root)
.stdin(Stdio::piped())
.stdout(Stdio::piped())
.stderr(Stdio::null())
.kill_on_drop(true)
.spawn()
.map_err(|err| LspError::Spawn(bin.to_owned(), err.to_string()))?;
let root = canonical_root(root);
let stdin = child.stdin.take().ok_or(LspError::Io("no stdin"))?;
let stdout = BufReader::new(child.stdout.take().ok_or(LspError::Io("no stdout"))?);
let mut client = Self {
_child: child,
stdin,
stdout,
next_id: 0,
root,
open_docs: HashMap::new(),
};
let root_uri = uri(&client.root);
client
.request(
"initialize",
json!({
"processId": std::process::id(),
"rootUri": root_uri,
"workspaceFolders": [{"uri": root_uri, "name": "root"}],
"capabilities": {
"textDocument": {
"documentSymbol": {"hierarchicalDocumentSymbolSupport": true},
"references": {},
"callHierarchy": {}
}
}
}),
)
.await?;
client.notify("initialized", json!({})).await?;
Ok(client)
}
pub async fn sync_document(&mut self, path: &Path, text: &str) -> Result<(), LspError> {
let abs = self.root.join(path);
match self.open_docs.get_mut(&abs) {
None => {
self.open_docs.insert(abs.clone(), 1);
self.notify(
"textDocument/didOpen",
json!({"textDocument": {
"uri": uri(&abs),
"languageId": crate::lsp::registry::language_id(path),
"version": 1,
"text": text,
}}),
)
.await
}
Some(version) => {
*version += 1;
let version = *version;
self.notify(
"textDocument/didChange",
json!({
"textDocument": {"uri": uri(&abs), "version": version},
"contentChanges": [{"text": text}],
}),
)
.await
}
}
}
pub async fn document_symbols(&mut self, path: &Path) -> Result<Vec<Symbol>, LspError> {
let abs = self.root.join(path);
let result = self
.request(
"textDocument/documentSymbol",
json!({"textDocument": {"uri": uri(&abs)}}),
)
.await?;
let mut out = Vec::new();
collect_symbols(result.as_array().unwrap_or(&Vec::new()), &mut out);
Ok(out)
}
pub async fn references(
&mut self,
path: &Path,
line: u32,
character: u32,
) -> Result<Vec<RefSite>, LspError> {
let abs = self.root.join(path);
let result = self
.request(
"textDocument/references",
json!({
"textDocument": {"uri": uri(&abs)},
"position": {"line": line, "character": character},
"context": {"includeDeclaration": false},
}),
)
.await?;
Ok(result
.as_array()
.unwrap_or(&Vec::new())
.iter()
.filter_map(|loc| {
let target = loc.get("uri")?.as_str()?;
let line = loc.pointer("/range/start/line")?.as_u64()? as u32;
let path = rel_path(&self.root, target)?;
Some(RefSite { path, line })
})
.collect())
}
pub async fn incoming_calls(
&mut self,
path: &Path,
line: u32,
character: u32,
) -> Result<Vec<Caller>, LspError> {
let abs = self.root.join(path);
let items = self
.request(
"textDocument/prepareCallHierarchy",
json!({
"textDocument": {"uri": uri(&abs)},
"position": {"line": line, "character": character},
}),
)
.await?;
let Some(item) = items.as_array().and_then(|a| a.first()).cloned() else {
return Ok(Vec::new());
};
let calls = self
.request("callHierarchy/incomingCalls", json!({"item": item}))
.await?;
Ok(calls
.as_array()
.unwrap_or(&Vec::new())
.iter()
.filter_map(|call| {
let from = call.get("from")?;
let name = from.get("name")?.as_str()?.to_owned();
let target = from.get("uri")?.as_str()?;
let path = rel_path(&self.root, target)?;
let at = |ptr: &str| from.pointer(ptr).and_then(Value::as_u64).map(|v| v as u32);
Some(Caller {
name,
path,
line: at("/range/start/line")?,
select_line: at("/selectionRange/start/line")?,
select_character: at("/selectionRange/start/character")?,
})
})
.collect())
}
async fn request(&mut self, method: &str, params: Value) -> Result<Value, LspError> {
self.next_id += 1;
let id = self.next_id;
self.send(&json!({"jsonrpc": "2.0", "id": id, "method": method, "params": params}))
.await?;
tokio::time::timeout(REQUEST_TIMEOUT, self.await_response(id, method))
.await
.map_err(|_| LspError::Io("timeout"))?
}
async fn await_response(&mut self, id: i64, method: &str) -> Result<Value, LspError> {
loop {
let message = self.read_message().await?;
if message.get("id").and_then(Value::as_i64) == Some(id)
&& message.get("method").is_none()
{
if let Some(error) = message.get("error") {
return Err(LspError::Server(method.to_owned(), error.to_string()));
}
return Ok(message.get("result").cloned().unwrap_or(Value::Null));
}
if let Some(request_id) = message
.get("method")
.and(message.get("id"))
.and_then(Value::as_i64)
{
let result = server_request_result(&message);
self.send(&json!({"jsonrpc": "2.0", "id": request_id, "result": result}))
.await?;
}
}
}
async fn notify(&mut self, method: &str, params: Value) -> Result<(), LspError> {
self.send(&json!({"jsonrpc": "2.0", "method": method, "params": params}))
.await
}
async fn send(&mut self, message: &Value) -> Result<(), LspError> {
let body = message.to_string();
let framed = format!("Content-Length: {}\r\n\r\n{body}", body.len());
self.stdin
.write_all(framed.as_bytes())
.await
.map_err(|_| LspError::Io("write"))?;
self.stdin.flush().await.map_err(|_| LspError::Io("flush"))
}
async fn read_message(&mut self) -> Result<Value, LspError> {
let mut length: usize = 0;
loop {
let mut header = String::new();
let read = self
.stdout
.read_line(&mut header)
.await
.map_err(|_| LspError::Io("read header"))?;
if read == 0 {
return Err(LspError::Io("server closed"));
}
let header = header.trim_end();
if header.is_empty() {
break;
}
if let Some(value) = header.strip_prefix("Content-Length: ") {
length = value.parse().map_err(|_| LspError::Io("bad length"))?;
}
}
let mut body = vec![0u8; length];
self.stdout
.read_exact(&mut body)
.await
.map_err(|_| LspError::Io("read body"))?;
serde_json::from_slice(&body).map_err(|_| LspError::Io("bad json"))
}
}
const REQUEST_TIMEOUT: std::time::Duration = std::time::Duration::from_secs(30);
fn server_request_result(message: &Value) -> Value {
if message.get("method").and_then(Value::as_str) == Some("workspace/configuration") {
let items = message
.pointer("/params/items")
.and_then(Value::as_array)
.map_or(0, Vec::len);
return Value::Array(vec![Value::Null; items]);
}
Value::Null
}
fn canonical_root(root: &Path) -> PathBuf {
let canonical = root.canonicalize().unwrap_or_else(|_| root.to_path_buf());
let text = canonical.to_string_lossy();
match text.strip_prefix(r"\\?\") {
Some(stripped) => PathBuf::from(stripped),
None => canonical,
}
}
fn uri(path: &Path) -> String {
url::Url::from_file_path(path).map_or_else(
|()| format!("file://{}", path.display()),
|url| url.to_string(),
)
}
fn rel_path(root: &Path, uri: &str) -> Option<String> {
let path = url::Url::parse(uri).ok()?.to_file_path().ok()?;
let rel = path.strip_prefix(root).ok()?;
Some(rel.to_string_lossy().into_owned())
}
const FUNCTION_KINDS: &[u64] = &[6, 9, 12];
fn collect_symbols(nodes: &[Value], out: &mut Vec<Symbol>) {
for node in nodes {
if let Some(children) = node.get("children").and_then(Value::as_array) {
collect_symbols(children, out);
}
let kind = node.get("kind").and_then(Value::as_u64).unwrap_or(0);
if !FUNCTION_KINDS.contains(&kind) {
continue;
}
let Some(name) = node.get("name").and_then(Value::as_str) else {
continue;
};
let range = |ptr: &str| node.pointer(ptr).and_then(Value::as_u64).map(|v| v as u32);
let (Some(start), Some(end)) = (range("/range/start/line"), range("/range/end/line"))
else {
continue;
};
out.push(Symbol {
name: name.to_owned(),
start_line: start,
end_line: end,
select_line: range("/selectionRange/start/line").unwrap_or(start),
select_character: range("/selectionRange/start/character").unwrap_or(0),
});
}
}
#[cfg(test)]
mod tests {
use super::*;
#[cfg(unix)]
#[test]
fn uri_and_rel_path_round_trip_spaces() {
let root = Path::new("/repo dir");
let uri = uri(&root.join("src/a file.rs"));
assert_eq!(uri, "file:///repo%20dir/src/a%20file.rs");
assert_eq!(rel_path(root, &uri).as_deref(), Some("src/a file.rs"));
}
#[test]
fn rel_path_rejects_locations_outside_the_root() {
assert_eq!(rel_path(Path::new("/repo"), "file:///elsewhere/x.rs"), None);
assert_eq!(rel_path(Path::new("/repo"), "not a uri"), None);
}
#[test]
fn configuration_requests_get_one_null_per_item() {
let msg = serde_json::json!({
"method": "workspace/configuration",
"params": {"items": [{}, {}]},
});
assert_eq!(
server_request_result(&msg),
Value::Array(vec![Value::Null, Value::Null])
);
assert_eq!(
server_request_result(&serde_json::json!({"method": "x"})),
Value::Null
);
}
}