pickls 0.6.17

The General Purpose Language Server for Command-Line Linters and Formatters
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

use lsp_types::request::*;

use crate::prelude::*;

pub fn run_server<F, T>(f: F) -> Result<()>
where
    F: FnOnce(Client) -> T,
    T: LanguageServer,
{
    let stdin = std::io::stdin();
    let stdout = Rc::new(RefCell::new(std::io::stdout().lock()));
    let client = Client::new(stdout);
    // let mut read_buf = [0i8; 4096];
    let mut backend = f(client.clone());
    log::info!("Server is running");
    for rpc in parse_json_rpc(stdin.lock()) {
        let rpc = rpc.context("Error parsing JSON")?;
        // log::info!("Received message: {:#?}", rpc);
        // This is a Request.
        let id = rpc.id.clone();
        match rpc.method.as_str() {
            Initialize::METHOD => {
                client.write_response(id, backend.initialize(rpc.take_params()?))?;
            }
            Initialized::METHOD => {
                backend
                    .initialized(rpc.take_params()?)
                    .ok_or_log("Error in initialized");
            }
            SetTrace::METHOD => {
                backend.set_trace(rpc.take_params()?);
            }
            WorkspaceSymbolRequest::METHOD => {
                client.write_response(id, backend.workspace_symbol(rpc.take_params()?))?;
            }
            ExecuteCommand::METHOD => {
                client.write_response(id, backend.execute_command(rpc.take_params()?))?;
            }
            CodeActionRequest::METHOD => {
                client.write_response(id, backend.code_action(rpc.take_params()?))?;
            }
            DidChangeTextDocument::METHOD => {
                backend
                    .did_change(rpc.take_params()?)
                    .ok_or_log("Error in did_change");
            }
            DidChangeConfiguration::METHOD => {
                backend
                    .did_change_configuration(rpc.take_params()?)
                    .ok_or_log("Error in did_change_configuration");
            }
            DidOpenTextDocument::METHOD => {
                backend
                    .did_open(rpc.take_params()?)
                    .ok_or_log("Error in did_open");
            }
            DidCloseTextDocument::METHOD => {
                backend
                    .did_close(rpc.take_params()?)
                    .ok_or_log("Error in did_close");
            }
            WillSaveTextDocument::METHOD => {
                backend
                    .will_save(rpc.take_params()?)
                    .ok_or_log("Error in will_save");
            }
            Formatting::METHOD => {
                client.write_response(id, backend.formatting(rpc.take_params()?))?;
            }
            Shutdown::METHOD => {
                client.write_response(id, backend.shutdown())?;
                log::info!("Shutting down");
                break;
            }
            Cancel::METHOD => { /* ignore */ }
            DocumentDiagnosticRequest::METHOD => { /*ignore*/ }
            WorkspaceDiagnosticRequest::METHOD => { /*ignore*/ }
            DidSaveTextDocument::METHOD => { /*ignore*/ }
            _ => {
                log::warn!("Unhandled method: {}", rpc.method);
            }
        }
    }
    Ok(())
}