lspf 1.0.3

A Rust framework for building extensible LSP language servers
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
50
51
52

//! Example journeys use the same public transport seam as downstream handlers.
use bytes::Bytes;
use lspf::testing::ServerJourney;
use lspf::{RawMessage, RequestId, Server};
use serde_json::{Value, json};

pub(crate) const URI: &str = "file:///example.txt";

pub(crate) async fn opened<S: Send + Sync + 'static>(
    server: Server<S>,
    text: &str,
) -> ServerJourney {
    // Omitted position encodings negotiate UTF-16.
    let mut journey = ServerJourney::start(server).await.unwrap();
    journey
        .peer()
        .send(RawMessage::Notification {
            method: "textDocument/didOpen".into(),
            params: Bytes::from(
                serde_json::to_vec(&json!({"textDocument": {
                    "uri":URI,"languageId":"text","version":1,"text":text,
                }}))
                .unwrap(),
            ),
        })
        .unwrap();
    journey
}

pub(crate) async fn request(
    journey: &mut ServerJourney,
    method: &'static str,
    params: Value,
) -> Value {
    journey
        .peer()
        .send(RawMessage::Request {
            id: RequestId::Number(10),
            method: method.into(),
            params: Bytes::from(serde_json::to_vec(&params).unwrap()),
        })
        .unwrap();
    let response = tokio::time::timeout(std::time::Duration::from_secs(5), journey.peer().recv())
        .await
        .unwrap()
        .unwrap();
    let RawMessage::Response { id, result } = response else {
        panic!("unexpected response: {response:?}")
    };
    assert_eq!(id, RequestId::Number(10));
    serde_json::from_slice(&result.unwrap()).unwrap()
}