feat: lsp file watcher. Actively monitor file system changes. These c…

…hanges will not be notified through lsp, e.g., execute `kcl mod add xxx`, `kcl fmt xxx`

Signed-off-by: he1pa <[email protected]>

kclvm/driver/Cargo.toml

@@ -7,7 +7,6 @@ edition = "2021"
 
 [dependencies]
 serde_json = "1.0.86"
-notify = "6.1.1"
 
 kclvm-config ={ path = "../config"}
 kclvm-runtime ={ path = "../runtime"}

kclvm/sema/src/resolver/import.rs

@@ -42,6 +42,7 @@ impl<'ctx> Resolver<'ctx> {
                         let real_path =
                             Path::new(&self.program.root).join(pkgpath.replace('.', "/"));
                         if !self.program.pkgs.contains_key(pkgpath) {
+                            self.ctx.invalid_pkg_scope.insert(pkgpath.to_string());
                             if real_path.exists() {
                                 self.handler.add_error(
                                     ErrorKind::CannotFindModule,

kclvm/sema/src/resolver/mod.rs

@@ -19,7 +19,7 @@ mod var;
 #[cfg(test)]
 mod tests;
 
-use indexmap::IndexMap;
+use indexmap::{IndexMap, IndexSet};
 use kclvm_error::diagnostic::Range;
 use std::sync::Arc;
 use std::{cell::RefCell, rc::Rc};
@@ -99,8 +99,12 @@ impl<'ctx> Resolver<'ctx> {
 
     pub(crate) fn check_and_lint(&mut self, pkgpath: &str) -> ProgramScope {
         self.check(pkgpath);
+        let mut scope_map = self.scope_map.clone();
+        for invalid_pkg_scope in &self.ctx.invalid_pkg_scope {
+            scope_map.remove(invalid_pkg_scope);
+        }
         let mut scope = ProgramScope {
-            scope_map: self.scope_map.clone(),
+            scope_map,
             import_names: self.ctx.import_names.clone(),
             node_ty_map: self.node_ty_map.clone(),
             handler: self.handler.clone(),
@@ -145,6 +149,8 @@ pub struct Context {
     pub ty_ctx: TypeContext,
     /// Type alias mapping
     pub type_alias_mapping: IndexMap<String, IndexMap<String, String>>,
+    /// invalid pkg scope, remove when after resolve
+    pub invalid_pkg_scope: IndexSet<String>,
 }
 
 /// Resolve options.

kclvm/tools/src/LSP/Cargo.toml

@@ -37,13 +37,14 @@ anyhow = { version = "1.0", default-features = false, features = ["std"] }
 crossbeam-channel = { version = "0.5.7", default-features = false }
 ra_ap_vfs = "0.0.149"
 ra_ap_vfs-notify = "0.0.149"
-lsp-types = { version = "0.93.0", features = ["proposed"]}
+lsp-types = { version = "0.93.0", features = ["proposed"] }
 threadpool = { version = "1.8.1", default-features = false }
 salsa = { version = "0.16.1", default-features = false }
 serde_json = { version = "1.0", default-features = false }
 parking_lot = { version = "0.12.0", default-features = false }
 rustc-hash = { version = "1.1.0", default-features = false }
 proc_macro_crate = { path = "../../benches/proc_macro_crate" }
+notify = "7.0.0"
 
 [target.'cfg(not(target_arch = "wasm32"))'.dependencies]
 tokio = { version = "1.37.0", features = ["full"] }

kclvm/tools/src/LSP/src/notification.rs

@@ -1,13 +1,8 @@
-use kclvm_config::{
-    modfile::{KCL_MOD_FILE, KCL_WORK_FILE},
-    settings::DEFAULT_SETTING_FILE,
-};
-use kclvm_driver::lookup_compile_workspaces;
 use lsp_types::notification::{
     Cancel, DidChangeTextDocument, DidChangeWatchedFiles, DidCloseTextDocument,
     DidOpenTextDocument, DidSaveTextDocument,
 };
-use std::{collections::HashSet, sync::Arc};
+use std::collections::HashSet;
 
 use crate::util::apply_document_changes;
 use crate::{
@@ -137,27 +132,8 @@ impl LanguageServerState {
         for change in params.changes {
             let path = from_lsp::abs_path(&change.uri)?;
             self.loader.handle.invalidate(path.clone());
-            if KCL_CONFIG_FILE.contains(&path.file_name().unwrap().to_str().unwrap()) {
-                self.entry_cache.write().clear();
-                let parent_path = path.parent().unwrap();
-                let path = parent_path.as_os_str().to_str().unwrap().to_string();
-                let tool = Arc::clone(&self.tool);
-                let (workspaces, failed) = lookup_compile_workspaces(&*tool.read(), &path, true);
-
-                if let Some(failed) = failed {
-                    for (key, err) in failed {
-                        self.log_message(format!("parse kcl.work failed: {}: {}", key, err));
-                    }
-                }
-
-                for (workspace, opts) in workspaces {
-                    self.async_compile(workspace, opts, None, false);
-                }
-            }
         }
 
         Ok(())
     }
 }
-
-const KCL_CONFIG_FILE: [&str; 3] = [DEFAULT_SETTING_FILE, KCL_MOD_FILE, KCL_WORK_FILE];

kclvm/tools/src/LSP/src/request.rs

@@ -1,6 +1,7 @@
 use anyhow::anyhow;
 use crossbeam_channel::Sender;
 
+use kclvm_driver::WorkSpaceKind;
 use kclvm_sema::info::is_valid_kcl_name;
 use lsp_types::{Location, SemanticTokensResult, TextEdit};
 use ra_ap_vfs::VfsPath;
@@ -97,7 +98,7 @@ impl LanguageServerSnapshot {
     ) -> anyhow::Result<Option<Arc<AnalysisDatabase>>> {
         match self.try_get_db_state(path) {
             Ok(db) => match db {
-                Some(db) => match db {
+                Some((_, db)) => match db {
                     DBState::Ready(db) => Ok(Some(db.clone())),
                     DBState::Compiling(_) | DBState::Init => {
                         log_message(
@@ -124,7 +125,10 @@ impl LanguageServerSnapshot {
     /// return Ok(Some(db)) -> Compile completed
     /// return Ok(None) -> RWlock, retry to unlock
     /// return Err(_) ->  Compile failed
-    pub(crate) fn try_get_db_state(&self, path: &VfsPath) -> anyhow::Result<Option<DBState>> {
+    pub(crate) fn try_get_db_state(
+        &self,
+        path: &VfsPath,
+    ) -> anyhow::Result<Option<(WorkSpaceKind, DBState)>> {
         match self.vfs.try_read() {
             Some(vfs) => match vfs.file_id(path) {
                 Some(file_id) => {
@@ -134,7 +138,7 @@ impl LanguageServerSnapshot {
                         Some(option_workspace) => match option_workspace {
                             Some(work_space) => match self.workspaces.try_read() {
                                 Some(workspaces) => match workspaces.get(work_space) {
-                                    Some(db) => Ok(Some(db.clone())),
+                                    Some(db) => Ok(Some((work_space.clone(), db.clone()))),
                                     None => Err(anyhow::anyhow!(
                                         LSPError::AnalysisDatabaseNotFound(path.clone())
                                     )),
@@ -154,7 +158,7 @@ impl LanguageServerSnapshot {
                             let work_space = file_info.workspaces.iter().next().unwrap();
                             match self.workspaces.try_read() {
                                 Some(workspaces) => match workspaces.get(work_space) {
-                                    Some(db) => Ok(Some(db.clone())),
+                                    Some(db) => Ok(Some((work_space.clone(), db.clone()))),
                                     None => Err(anyhow::anyhow!(
                                         LSPError::AnalysisDatabaseNotFound(path.clone())
                                     )),
@@ -310,7 +314,7 @@ pub(crate) fn handle_completion(
         return Ok(None);
     }
 
-    let db_state = match snapshot.try_get_db_state(&path) {
+    let (workspace, db_state) = match snapshot.try_get_db_state(&path) {
         Ok(option_state) => match option_state {
             Some(db) => db,
             None => return Err(anyhow!(LSPError::Retry)),
@@ -341,10 +345,10 @@ pub(crate) fn handle_completion(
     let kcl_pos = kcl_pos(&file, params.text_document_position.position);
 
     let metadata = snapshot
-        .entry_cache
+        .workspace_config_cache
         .read()
-        .get(&file)
-        .and_then(|metadata| metadata.0 .2.clone());
+        .get(&workspace)
+        .and_then(|opt| opt.2.clone());
 
     let res = completion(
         completion_trigger_character,