righter 0.1.0

A lightweight, memory-safe code editor built in Rust for Rust developers. Language support: Rust only.
Documentation 
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

use anyhow::{Result, bail};
use serde_json::Value;
use tokio::io::{AsyncBufReadExt, AsyncReadExt, AsyncWriteExt, BufReader};
use tokio::process::{ChildStdin, ChildStdout};

/// Read a JSON-RPC message from the LSP server's stdout.
pub async fn read_message(reader: &mut BufReader<ChildStdout>) -> Result<Value> {
    let mut content_length: usize = 0;

    // Read headers
    loop {
        let mut line = String::new();
        let n = reader.read_line(&mut line).await?;
        if n == 0 {
            bail!("LSP server closed stdout");
        }
        let trimmed = line.trim();
        if trimmed.is_empty() {
            break;
        }
        if let Some(len_str) = trimmed.strip_prefix("Content-Length: ") {
            content_length = len_str.parse()?;
        }
    }

    if content_length == 0 {
        bail!("Missing Content-Length header");
    }

    // Read body
    let mut buf = vec![0u8; content_length];
    reader.read_exact(&mut buf).await?;

    let msg: Value = serde_json::from_slice(&buf)?;
    Ok(msg)
}

/// Write a JSON-RPC message to the LSP server's stdin.
pub async fn write_message(
    writer: &mut tokio::io::BufWriter<ChildStdin>,
    msg: &Value,
) -> Result<()> {
    let body = serde_json::to_string(msg)?;
    let header = format!("Content-Length: {}\r\n\r\n", body.len());
    writer.write_all(header.as_bytes()).await?;
    writer.write_all(body.as_bytes()).await?;
    writer.flush().await?;
    Ok(())
}