use anyhow::Result;
use log::info;
use lsp_server::Connection;
use lsp_types::{
CodeActionKind, CodeActionOptions, CodeActionProviderCapability, CompletionOptions,
DiagnosticOptions, DiagnosticServerCapabilities, FoldingRangeProviderCapability,
HoverProviderCapability, InitializeParams, OneOf, SelectionRangeProviderCapability,
ServerCapabilities, TextDocumentSyncCapability, TextDocumentSyncKind, WorkDoneProgressOptions,
};
use crate::global_state::GlobalState;
pub fn run() -> Result<()> {
info!("Starting Squawk LSP server");
let (connection, io_threads) = Connection::stdio();
let server_capabilities = serde_json::to_value(&ServerCapabilities {
text_document_sync: Some(TextDocumentSyncCapability::Kind(
TextDocumentSyncKind::INCREMENTAL,
)),
code_action_provider: Some(CodeActionProviderCapability::Options(CodeActionOptions {
code_action_kinds: Some(vec![
CodeActionKind::QUICKFIX,
CodeActionKind::REFACTOR_REWRITE,
]),
work_done_progress_options: WorkDoneProgressOptions {
work_done_progress: None,
},
resolve_provider: None,
})),
selection_range_provider: Some(SelectionRangeProviderCapability::Simple(true)),
references_provider: Some(OneOf::Left(true)),
definition_provider: Some(OneOf::Left(true)),
hover_provider: Some(HoverProviderCapability::Simple(true)),
inlay_hint_provider: Some(OneOf::Left(true)),
diagnostic_provider: Some(DiagnosticServerCapabilities::Options(DiagnosticOptions {
identifier: None,
inter_file_dependencies: false,
workspace_diagnostics: false,
work_done_progress_options: WorkDoneProgressOptions {
work_done_progress: None,
},
})),
document_symbol_provider: Some(OneOf::Left(true)),
folding_range_provider: Some(FoldingRangeProviderCapability::Simple(true)),
completion_provider: Some(CompletionOptions {
resolve_provider: Some(false),
trigger_characters: Some(vec![".".to_owned()]),
all_commit_characters: None,
work_done_progress_options: WorkDoneProgressOptions {
work_done_progress: None,
},
completion_item: None,
}),
..Default::default()
})
.unwrap();
info!("LSP server initializing connection...");
let initialization_params = connection.initialize(server_capabilities)?;
info!("LSP server initialized, entering main loop");
main_loop(connection, initialization_params)?;
info!("LSP server shutting down");
io_threads.join()?;
Ok(())
}
fn main_loop(connection: Connection, params: serde_json::Value) -> Result<()> {
info!("Server main loop");
let init_params: InitializeParams = serde_json::from_value(params).unwrap_or_default();
info!("Client process ID: {:?}", init_params.process_id);
let client_name = init_params.client_info.map(|x| x.name);
info!("Client name: {client_name:?}");
GlobalState::new(connection.sender).run(connection.receiver)
}