Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

fix: workaround for LSP dependency resolution #1865

Merged
merged 10 commits into from
Jul 13, 2023
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion crates/fm/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ impl FileManager {
// Unwrap as we ensure that all file_id's map to a corresponding file in the file map
self.file_map.get_file(file_id).unwrap()
}
pub fn path(&mut self, file_id: FileId) -> &Path {
pub fn path(&self, file_id: FileId) -> &Path {
// Unwrap as we ensure that all file_ids are created by the file manager
// So all file_ids will points to a corresponding path
self.id_to_path.get(&file_id).unwrap().0.as_path()
Expand Down
1 change: 1 addition & 0 deletions crates/lsp/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@ noirc_driver.workspace = true
noirc_errors.workspace = true
noirc_frontend.workspace = true
serde_json.workspace = true
toml.workspace = true
tower.workspace = true
async-lsp = { version = "0.0.4", default-features = false, features = ["omni-trait"] }

Expand Down
34 changes: 33 additions & 1 deletion crates/lsp/src/lib.rs
Original file line number Diff line number Diff line change
@@ -1,3 +1,6 @@
mod lib_hacky;
use std::env;

use std::{
future::Future,
ops::{self, ControlFlow},
Expand Down Expand Up @@ -27,7 +30,7 @@ const TEST_COMMAND: &str = "nargo.test";
const TEST_CODELENS_TITLE: &str = "▶\u{fe0e} Run Test";

// State for the LSP gets implemented on this struct and is internal to the implementation
struct LspState {
pub struct LspState {
client: ClientSocket,
}

Expand All @@ -43,6 +46,35 @@ pub struct NargoLspService {

impl NargoLspService {
pub fn new(client: &ClientSocket) -> Self {
// Using conditional running with lib_hacky to prevent non-hacky code from being identified as dead code
// Secondarily, provides a runtime way to stress the non-hacky code.
if env::var("NOIR_LSP_NO_HACK").is_err() {
let state = LspState::new(client);
let mut router = Router::new(state);
router
.request::<request::Initialize, _>(lib_hacky::on_initialize)
.request::<request::Shutdown, _>(lib_hacky::on_shutdown)
.request::<request::CodeLensRequest, _>(lib_hacky::on_code_lens_request)
.notification::<notification::Initialized>(lib_hacky::on_initialized)
.notification::<notification::DidChangeConfiguration>(
lib_hacky::on_did_change_configuration,
)
.notification::<notification::DidOpenTextDocument>(
lib_hacky::on_did_open_text_document,
)
.notification::<notification::DidChangeTextDocument>(
lib_hacky::on_did_change_text_document,
)
.notification::<notification::DidCloseTextDocument>(
lib_hacky::on_did_close_text_document,
)
.notification::<notification::DidSaveTextDocument>(
lib_hacky::on_did_save_text_document,
)
.notification::<notification::Exit>(lib_hacky::on_exit);
return Self { router };
}

let state = LspState::new(client);
let mut router = Router::new(state);
router
Expand Down
318 changes: 318 additions & 0 deletions crates/lsp/src/lib_hacky.rs
Original file line number Diff line number Diff line change
@@ -0,0 +1,318 @@
//! NOTE: This is a temporary module until https://github.com/noir-lang/noir/issues/1838 is fixed.
//! This is sectioned off, and currently the default implementation, unless the environment variable NOIR_LSP_NO_HACKS is set.
//! This is mainly so that non-hacky code is not considered dead.
use std::{
collections::HashMap,
fs,
future::Future,
ops::{self, ControlFlow},
path::{Path, PathBuf},
};

use async_lsp::{LanguageClient, ResponseError};
use codespan_reporting::files;
use lsp_types::{
CodeLens, CodeLensOptions, CodeLensParams, Command, Diagnostic, DiagnosticSeverity,
DidChangeConfigurationParams, DidChangeTextDocumentParams, DidCloseTextDocumentParams,
DidOpenTextDocumentParams, DidSaveTextDocumentParams, InitializeParams, InitializeResult,
InitializedParams, Position, PublishDiagnosticsParams, Range, ServerCapabilities,
TextDocumentSyncOptions,
};
use noirc_driver::{check_crate, create_local_crate, create_non_local_crate, propagate_dep};
use noirc_errors::{DiagnosticKind, FileDiagnostic};
use noirc_frontend::{
graph::{CrateId, CrateName, CrateType},
hir::Context,
};

use crate::LspState;

const TEST_COMMAND: &str = "nargo.test";
const TEST_CODELENS_TITLE: &str = "▶\u{fe0e} Run Test";

// Handlers
// The handlers for `request` are not `async` because it compiles down to lifetimes that can't be added to
// the router. To return a future that fits the trait, it is easiest wrap your implementations in an `async {}`
// block but you can also use `std::future::ready`.
//
// Additionally, the handlers for `notification` aren't async at all.
//
// They are not attached to the `NargoLspService` struct so they can be unit tested with only `LspState`
// and params passed in.

pub fn on_initialize(
_state: &mut LspState,
_params: InitializeParams,
) -> impl Future<Output = Result<InitializeResult, ResponseError>> {
async {
let text_document_sync =
TextDocumentSyncOptions { save: Some(true.into()), ..Default::default() };

let code_lens = CodeLensOptions { resolve_provider: Some(false) };

Ok(InitializeResult {
capabilities: ServerCapabilities {
text_document_sync: Some(text_document_sync.into()),
code_lens_provider: Some(code_lens),
// Add capabilities before this spread when adding support for one
..Default::default()
},
server_info: None,
})
}
}

pub fn on_shutdown(
_state: &mut LspState,
_params: (),
) -> impl Future<Output = Result<(), ResponseError>> {
async { Ok(()) }
}

pub fn on_code_lens_request(
_state: &mut LspState,
params: CodeLensParams,
) -> impl Future<Output = Result<Option<Vec<CodeLens>>, ResponseError>> {
let actual_path = params.text_document.uri.to_file_path().unwrap();
let (mut driver, current_crate_id) = create_context_at_path(actual_path);

// We ignore the warnings and errors produced by compilation for producing codelenses
// because we can still get the test functions even if compilation fails
let _ = check_crate(&mut driver, false, false);

let fm = &driver.file_manager;
let files = fm.as_simple_files();
let tests = driver.get_all_test_functions_in_crate_matching(&current_crate_id, "");

let mut lenses: Vec<CodeLens> = vec![];
for func_id in tests {
let location = driver.function_meta(&func_id).name.location;
let file_id = location.file;
// TODO(#1681): This file_id never be 0 because the "path" where it maps is the directory, not a file
if file_id.as_usize() != 0 {
continue;
}

let func_name = driver.function_name(&func_id);

let range =
byte_span_to_range(files, file_id.as_usize(), location.span.into()).unwrap_or_default();

let command = Command {
title: TEST_CODELENS_TITLE.into(),
command: TEST_COMMAND.into(),
arguments: Some(vec![func_name.into()]),
};

let lens = CodeLens { range, command: command.into(), data: None };

lenses.push(lens);
}

async move {
if lenses.is_empty() {
Ok(None)
} else {
Ok(Some(lenses))
}
}
}

pub fn on_initialized(
_state: &mut LspState,
_params: InitializedParams,
) -> ControlFlow<Result<(), async_lsp::Error>> {
ControlFlow::Continue(())
}

pub fn on_did_change_configuration(
_state: &mut LspState,
_params: DidChangeConfigurationParams,
) -> ControlFlow<Result<(), async_lsp::Error>> {
ControlFlow::Continue(())
}

pub fn on_did_open_text_document(
_state: &mut LspState,
_params: DidOpenTextDocumentParams,
) -> ControlFlow<Result<(), async_lsp::Error>> {
ControlFlow::Continue(())
}

pub fn on_did_change_text_document(
_state: &mut LspState,
_params: DidChangeTextDocumentParams,
) -> ControlFlow<Result<(), async_lsp::Error>> {
ControlFlow::Continue(())
}

pub fn on_did_close_text_document(
_state: &mut LspState,
_params: DidCloseTextDocumentParams,
) -> ControlFlow<Result<(), async_lsp::Error>> {
ControlFlow::Continue(())
}

/// Find the nearest parent file with given names.
fn find_nearest_parent_file(path: &Path, filenames: &[&str]) -> Option<PathBuf> {
let mut current_path = path;

while let Some(parent_path) = current_path.parent() {
for filename in filenames {
let mut possible_file_path = parent_path.to_path_buf();
possible_file_path.push(filename);
if possible_file_path.is_file() {
return Some(possible_file_path);
}
}
current_path = parent_path;
}

None
}

fn read_dependencies(
nargo_toml_path: &Path,
) -> Result<HashMap<String, String>, Box<dyn std::error::Error>> {
let content: String = fs::read_to_string(nargo_toml_path)?;
let value: toml::Value = toml::from_str(&content)?;

let mut dependencies = HashMap::new();

if let Some(toml::Value::Table(table)) = value.get("dependencies") {
for (key, value) in table {
if let toml::Value::Table(inner_table) = value {
if let Some(toml::Value::String(path)) = inner_table.get("path") {
dependencies.insert(key.clone(), path.clone());
}
}
}
}

Ok(dependencies)
}

pub fn on_did_save_text_document(
state: &mut LspState,
params: DidSaveTextDocumentParams,
) -> ControlFlow<Result<(), async_lsp::Error>> {
let actual_path = params.text_document.uri.to_file_path().unwrap();
let (mut context, _) = create_context_at_path(actual_path.clone());

let file_diagnostics = match check_crate(&mut context, false, false) {
Ok(warnings) => warnings,
Err(errors_and_warnings) => errors_and_warnings,
};
let mut diagnostics = Vec::new();

if !file_diagnostics.is_empty() {
let fm = &context.file_manager;
let files = fm.as_simple_files();

for FileDiagnostic { file_id, diagnostic } in file_diagnostics {
// TODO(AD): HACK, undo these total hacks once we have a proper approach
if file_id.as_usize() == 0 {
// main.nr case
if actual_path.file_name().unwrap().to_str() != Some("main.nr")
&& actual_path.file_name().unwrap().to_str() != Some("lib.nr")
{
continue;
}
} else if fm.path(file_id).file_name().unwrap().to_str().unwrap()
!= actual_path.file_name().unwrap().to_str().unwrap().replace(".nr", "")
{
// every other file case
continue; // TODO(AD): HACK, we list all errors, filter by hacky final path component
}

let mut range = Range::default();

// TODO: Should this be the first item in secondaries? Should we bail when we find a range?
for sec in diagnostic.secondaries {
// Not using `unwrap_or_default` here because we don't want to overwrite a valid range with a default range
if let Some(r) = byte_span_to_range(files, file_id.as_usize(), sec.span.into()) {
range = r
}
}
let severity = match diagnostic.kind {
DiagnosticKind::Error => Some(DiagnosticSeverity::ERROR),
DiagnosticKind::Warning => Some(DiagnosticSeverity::WARNING),
};
diagnostics.push(Diagnostic {
range,
severity,
message: diagnostic.message,
..Diagnostic::default()
})
}
}

let _ = state.client.publish_diagnostics(PublishDiagnosticsParams {
uri: params.text_document.uri,
version: None,
diagnostics,
});

ControlFlow::Continue(())
}

fn create_context_at_path(actual_path: PathBuf) -> (Context, CrateId) {
// TODO: Requiring `Language` and `is_opcode_supported` to construct a driver makes for some real stinky code
// The driver should not require knowledge of the backend; instead should be implemented as an independent pass (in nargo?)
let mut context = Context::default();

let mut file_path: PathBuf = actual_path;
// TODO better naming/unhacking
if let Some(new_path) = find_nearest_parent_file(&file_path, &["lib.nr", "main.nr"]) {
file_path = new_path; // TODO unhack
}
let nargo_toml_path = find_nearest_parent_file(&file_path, &["Nargo.toml"]);

let current_crate_id = create_local_crate(&mut context, file_path, CrateType::Binary);

// TODO(AD): undo hacky dependency resolution
if let Some(nargo_toml_path) = nargo_toml_path {
let dependencies = read_dependencies(&nargo_toml_path);
if let Ok(dependencies) = dependencies {
for (crate_name, dependency_path) in dependencies.iter() {
let path_to_lib = nargo_toml_path
.parent()
.unwrap() // TODO
.join(PathBuf::from(&dependency_path).join("src").join("lib.nr"));
let library_crate =
create_non_local_crate(&mut context, path_to_lib, CrateType::Library);
propagate_dep(&mut context, library_crate, &CrateName::new(crate_name).unwrap());
}
}
}
(context, current_crate_id)
}

pub fn on_exit(_state: &mut LspState, _params: ()) -> ControlFlow<Result<(), async_lsp::Error>> {
ControlFlow::Continue(())
}

fn byte_span_to_range<'a, F: files::Files<'a> + ?Sized>(
files: &'a F,
file_id: F::FileId,
span: ops::Range<usize>,
) -> Option<Range> {
// TODO(#1683): Codespan ranges are often (always?) off by some amount of characters
if let Ok(codespan_range) = codespan_lsp::byte_span_to_range(files, file_id, span) {
// We have to manually construct a Range because the codespan_lsp restricts lsp-types to the wrong version range
// TODO: codespan is unmaintained and we should probably subsume it. Ref https://github.com/brendanzab/codespan/issues/345
let range = Range {
start: Position {
line: codespan_range.start.line,
character: codespan_range.start.character,
},
end: Position {
line: codespan_range.end.line,
character: codespan_range.end.character,
},
};
Some(range)
} else {
None
}
}