From 17edf50e2c8ce92a6f056e311d68000d64838873 Mon Sep 17 00:00:00 2001 From: Aleksey Kladov Date: Fri, 10 Jul 2020 00:28:12 +0200 Subject: Avoid accidently stumping over config values --- crates/rust-analyzer/src/bin/main.rs | 4 +- crates/rust-analyzer/src/config.rs | 293 +++++++++++++++++++--------------- crates/rust-analyzer/src/main_loop.rs | 6 +- 3 files changed, 169 insertions(+), 134 deletions(-) diff --git a/crates/rust-analyzer/src/bin/main.rs b/crates/rust-analyzer/src/bin/main.rs index 047772d0c..65f1a6d15 100644 --- a/crates/rust-analyzer/src/bin/main.rs +++ b/crates/rust-analyzer/src/bin/main.rs @@ -120,8 +120,8 @@ fn run_server() -> Result<()> { }; let mut config = Config::new(root_path); - if let Some(value) = &initialize_params.initialization_options { - config.update(value); + if let Some(json) = initialize_params.initialization_options { + config.update(json); } config.update_caps(&initialize_params.capabilities); diff --git a/crates/rust-analyzer/src/config.rs b/crates/rust-analyzer/src/config.rs index 9e7de0243..9dd81b4fc 100644 --- a/crates/rust-analyzer/src/config.rs +++ b/crates/rust-analyzer/src/config.rs @@ -111,14 +111,8 @@ pub struct NotificationsConfig { #[derive(Debug, Clone)] pub enum RustfmtConfig { - Rustfmt { - extra_args: Vec, - }, - #[allow(unused)] - CustomCommand { - command: String, - args: Vec, - }, + Rustfmt { extra_args: Vec }, + CustomCommand { command: String, args: Vec }, } #[derive(Debug, Clone, Default)] @@ -178,146 +172,110 @@ impl Config { } } - #[rustfmt::skip] - pub fn update(&mut self, value: &serde_json::Value) { - log::info!("Config::update({:#})", value); - - let client_caps = self.client_caps.clone(); - let linked_projects = self.linked_projects.clone(); - *self = Config::new(self.root_path.clone()); - self.client_caps = client_caps; - self.linked_projects = linked_projects; - - set(value, "/withSysroot", &mut self.with_sysroot); - set(value, "/diagnostics/enable", &mut self.publish_diagnostics); - set(value, "/diagnostics/warningsAsInfo", &mut self.diagnostics.warnings_as_info); - set(value, "/diagnostics/warningsAsHint", &mut self.diagnostics.warnings_as_hint); - set(value, "/lruCapacity", &mut self.lru_capacity); - self.files.watcher = match get(value, "/files/watcher") { - Some("client") => FilesWatcher::Client, - Some("notify") | _ => FilesWatcher::Notify + pub fn update(&mut self, json: serde_json::Value) { + log::info!("Config::update({:#})", json); + let data = ConfigData::from_json(json); + + self.with_sysroot = data.withSysroot; + self.publish_diagnostics = data.diagnostics_enable; + self.diagnostics = DiagnosticsConfig { + warnings_as_info: data.diagnostics_warningsAsInfo, + warnings_as_hint: data.diagnostics_warningsAsHint, + }; + self.lru_capacity = data.lruCapacity; + self.files.watcher = match data.files_watcher.as_str() { + "notify" => FilesWatcher::Notify, + "client" | _ => FilesWatcher::Client, + }; + self.notifications = + NotificationsConfig { cargo_toml_not_found: data.notifications_cargoTomlNotFound }; + self.cargo = CargoConfig { + no_default_features: data.cargo_noDefaultFeatures, + all_features: data.cargo_allFeatures, + features: data.cargo_features.clone(), + load_out_dirs_from_check: data.cargo_loadOutDirsFromCheck, + target: data.cargo_target, }; - set(value, "/notifications/cargoTomlNotFound", &mut self.notifications.cargo_toml_not_found); - - set(value, "/cargo/noDefaultFeatures", &mut self.cargo.no_default_features); - set(value, "/cargo/allFeatures", &mut self.cargo.all_features); - set(value, "/cargo/features", &mut self.cargo.features); - set(value, "/cargo/loadOutDirsFromCheck", &mut self.cargo.load_out_dirs_from_check); - set(value, "/cargo/target", &mut self.cargo.target); - - match get(value, "/procMacro/enable") { - Some(true) => { - if let Ok(path) = std::env::current_exe() { - self.proc_macro_srv = Some((path, vec!["proc-macro".into()])); - } - } - _ => self.proc_macro_srv = None, - } - match get::>(value, "/rustfmt/overrideCommand") { + self.proc_macro_srv = if data.procMacro_enable { + std::env::current_exe().ok().map(|path| (path, vec!["proc-macro".into()])) + } else { + None + }; + + self.rustfmt = match data.rustfmt_overrideCommand { Some(mut args) if !args.is_empty() => { let command = args.remove(0); - self.rustfmt = RustfmtConfig::CustomCommand { - command, - args, - } - } - _ => { - if let RustfmtConfig::Rustfmt { extra_args } = &mut self.rustfmt { - set(value, "/rustfmt/extraArgs", extra_args); - } + RustfmtConfig::CustomCommand { command, args } } + Some(_) | None => RustfmtConfig::Rustfmt { extra_args: data.rustfmt_extraArgs }, }; - if let Some(false) = get(value, "/checkOnSave/enable") { - // check is disabled - self.flycheck = None; - } else { - // check is enabled - match get::>(value, "/checkOnSave/overrideCommand") { - // first see if the user has completely overridden the command + self.flycheck = if data.checkOnSave_enable { + let flycheck_config = match data.checkOnSave_overrideCommand { Some(mut args) if !args.is_empty() => { let command = args.remove(0); - self.flycheck = Some(FlycheckConfig::CustomCommand { - command, - args, - }); - } - // otherwise configure command customizations - _ => { - if let Some(FlycheckConfig::CargoCommand { command, extra_args, all_targets, all_features, features }) - = &mut self.flycheck - { - set(value, "/checkOnSave/extraArgs", extra_args); - set(value, "/checkOnSave/command", command); - set(value, "/checkOnSave/allTargets", all_targets); - *all_features = get(value, "/checkOnSave/allFeatures").unwrap_or(self.cargo.all_features); - *features = get(value, "/checkOnSave/features").unwrap_or(self.cargo.features.clone()); - } + FlycheckConfig::CustomCommand { command, args } } + Some(_) | None => FlycheckConfig::CargoCommand { + command: data.checkOnSave_command, + all_targets: data.checkOnSave_allTargets, + all_features: data.checkOnSave_allFeatures.unwrap_or(data.cargo_allFeatures), + features: data.checkOnSave_features.unwrap_or(data.cargo_features), + extra_args: data.checkOnSave_extraArgs, + }, }; - } - - set(value, "/inlayHints/typeHints", &mut self.inlay_hints.type_hints); - set(value, "/inlayHints/parameterHints", &mut self.inlay_hints.parameter_hints); - set(value, "/inlayHints/chainingHints", &mut self.inlay_hints.chaining_hints); - set(value, "/inlayHints/maxLength", &mut self.inlay_hints.max_length); - set(value, "/completion/postfix/enable", &mut self.completion.enable_postfix_completions); - set(value, "/completion/addCallParenthesis", &mut self.completion.add_call_parenthesis); - set(value, "/completion/addCallArgumentSnippets", &mut self.completion.add_call_argument_snippets); - set(value, "/callInfo/full", &mut self.call_info_full); - - let mut lens_enabled = true; - set(value, "/lens/enable", &mut lens_enabled); - if lens_enabled { - set(value, "/lens/run", &mut self.lens.run); - set(value, "/lens/debug", &mut self.lens.debug); - set(value, "/lens/implementations", &mut self.lens.implementations); + Some(flycheck_config) } else { - self.lens = LensConfig::NO_LENS; - } + None + }; - if let Some(linked_projects) = get::>(value, "/linkedProjects") { - if !linked_projects.is_empty() { - self.linked_projects.clear(); - for linked_project in linked_projects { - let linked_project = match linked_project { - ManifestOrProjectJson::Manifest(it) => { - let path = self.root_path.join(it); - match ProjectManifest::from_manifest_file(path) { - Ok(it) => it.into(), - Err(_) => continue, - } - } - ManifestOrProjectJson::ProjectJson(it) => ProjectJson::new(&self.root_path, it).into(), - }; - self.linked_projects.push(linked_project); - } - } - } + self.inlay_hints = InlayHintsConfig { + type_hints: data.inlayHints_typeHints, + parameter_hints: data.inlayHints_parameterHints, + chaining_hints: data.inlayHints_chainingHints, + max_length: data.inlayHints_maxLength, + }; - let mut use_hover_actions = false; - set(value, "/hoverActions/enable", &mut use_hover_actions); - if use_hover_actions { - set(value, "/hoverActions/implementations", &mut self.hover.implementations); - set(value, "/hoverActions/run", &mut self.hover.run); - set(value, "/hoverActions/debug", &mut self.hover.debug); - set(value, "/hoverActions/gotoTypeDef", &mut self.hover.goto_type_def); - } else { - self.hover = HoverConfig::NO_ACTIONS; - } + self.completion.enable_postfix_completions = data.completion_postfix_enable; + self.completion.add_call_parenthesis = data.completion_addCallParenthesis; + self.completion.add_call_argument_snippets = data.completion_addCallArgumentSnippets; - log::info!("Config::update() = {:#?}", self); + self.call_info_full = data.callInfo_full; - fn get<'a, T: Deserialize<'a>>(value: &'a serde_json::Value, pointer: &str) -> Option { - value.pointer(pointer).and_then(|it| T::deserialize(it).ok()) - } + self.lens = LensConfig { + run: data.lens_enable && data.lens_run, + debug: data.lens_enable && data.lens_debug, + implementations: data.lens_enable && data.lens_implementations, + }; - fn set<'a, T: Deserialize<'a>>(value: &'a serde_json::Value, pointer: &str, slot: &mut T) { - if let Some(new_value) = get(value, pointer) { - *slot = new_value + if !data.linkedProjects.is_empty() { + self.linked_projects.clear(); + for linked_project in data.linkedProjects { + let linked_project = match linked_project { + ManifestOrProjectJson::Manifest(it) => { + let path = self.root_path.join(it); + match ProjectManifest::from_manifest_file(path) { + Ok(it) => it.into(), + Err(_) => continue, + } + } + ManifestOrProjectJson::ProjectJson(it) => { + ProjectJson::new(&self.root_path, it).into() + } + }; + self.linked_projects.push(linked_project); } } + + self.hover = HoverConfig { + implementations: data.hoverActions_enable && data.hoverActions_implementations, + run: data.hoverActions_enable && data.hoverActions_run, + debug: data.hoverActions_enable && data.hoverActions_debug, + goto_type_def: data.hoverActions_enable && data.hoverActions_gotoTypeDef, + }; + + log::info!("Config::update() = {:#?}", self); } pub fn update_caps(&mut self, caps: &ClientCapabilities) { @@ -380,3 +338,80 @@ enum ManifestOrProjectJson { Manifest(PathBuf), ProjectJson(ProjectJsonData), } + +macro_rules! config_data { + (struct $name:ident { $($field:ident: $ty:ty = $default:expr,)*}) => { + #[allow(non_snake_case)] + struct $name { $($field: $ty,)* } + impl $name { + fn from_json(mut json: serde_json::Value) -> $name { + $name {$( + $field: { + let pointer = stringify!($field).replace('_', "/"); + let pointer = format!("/{}", pointer); + json.pointer_mut(&pointer) + .and_then(|it| serde_json::from_value(it.take()).ok()) + .unwrap_or($default) + }, + )*} + } + } + + }; +} + +config_data! { + struct ConfigData { + callInfo_full: bool = true, + + cargo_allFeatures: bool = false, + cargo_features: Vec = Vec::new(), + cargo_loadOutDirsFromCheck: bool = false, + cargo_noDefaultFeatures: bool = false, + cargo_target: Option = None, + + checkOnSave_allFeatures: Option = None, + checkOnSave_allTargets: bool = true, + checkOnSave_command: String = "check".into(), + checkOnSave_enable: bool = false, + checkOnSave_extraArgs: Vec = Vec::new(), + checkOnSave_features: Option> = None, + checkOnSave_overrideCommand: Option> = None, + + completion_addCallArgumentSnippets: bool = true, + completion_addCallParenthesis: bool = true, + completion_postfix_enable: bool = true, + + diagnostics_enable: bool = true, + diagnostics_warningsAsHint: Vec = Vec::new(), + diagnostics_warningsAsInfo: Vec = Vec::new(), + + files_watcher: String = "client".into(), + + hoverActions_debug: bool = true, + hoverActions_enable: bool = true, + hoverActions_gotoTypeDef: bool = true, + hoverActions_implementations: bool = true, + hoverActions_run: bool = true, + + inlayHints_chainingHints: bool = true, + inlayHints_maxLength: Option = None, + inlayHints_parameterHints: bool = true, + inlayHints_typeHints: bool = true, + + lens_debug: bool = true, + lens_enable: bool = true, + lens_implementations: bool = true, + lens_run: bool = true, + + linkedProjects: Vec = Vec::new(), + lruCapacity: Option = None, + notifications_cargoTomlNotFound: bool = true, + procMacro_enable: bool = false, + + rustfmt_extraArgs: Vec = Vec::new(), + rustfmt_overrideCommand: Option> = None, + + withSysroot: bool = true, + } +} diff --git a/crates/rust-analyzer/src/main_loop.rs b/crates/rust-analyzer/src/main_loop.rs index 4e556bd50..b48239058 100644 --- a/crates/rust-analyzer/src/main_loop.rs +++ b/crates/rust-analyzer/src/main_loop.rs @@ -467,10 +467,10 @@ impl GlobalState { (Some(err), _) => { log::error!("failed to fetch the server settings: {:?}", err) } - (None, Some(configs)) => { - if let Some(new_config) = configs.get(0) { + (None, Some(mut configs)) => { + if let Some(json) = configs.get_mut(0) { let mut config = this.config.clone(); - config.update(&new_config); + config.update(json.take()); this.update_configuration(config); } } -- cgit v1.2.3