add diagnostic interval config

Author: CppCXY

crates/emmylua_ls/src/context/file_diagnostic.rs

@@ -30,7 +30,7 @@ impl FileDiagnostic {
     }
 
     #[allow(unused)]
-    pub async fn add_diagnostic_task(&self, file_id: FileId) {
+    pub async fn add_diagnostic_task(&self, file_id: FileId, interval: u64) {
         let mut tokens = self.diagnostic_tokens.lock().await;
 
         if let Some(token) = tokens.get(&file_id) {
@@ -44,8 +44,6 @@ impl FileDiagnostic {
         drop(tokens); // free the lock
 
         let analysis = self.analysis.clone();
-        let emmyrc = analysis.read().await.get_emmyrc();
-        let interval = emmyrc.diagnostics.diagnostic_interval.unwrap_or(500);
         let client = self.client.clone();
         let diagnostic_tokens = self.diagnostic_tokens.clone();
         let file_id_clone = file_id.clone();
@@ -80,9 +78,9 @@ impl FileDiagnostic {
     }
 
     // todo add message show
-    pub async fn add_files_diagnostic_task(&self, file_ids: Vec<FileId>) {
+    pub async fn add_files_diagnostic_task(&self, file_ids: Vec<FileId>, interval: u64) {
         for file_id in file_ids {
-            self.add_diagnostic_task(file_id).await;
+            self.add_diagnostic_task(file_id, interval).await;
         }
     }
 

crates/emmylua_ls/src/handlers/text_document/text_document_handler.rs

@@ -1,4 +1,7 @@
-use lsp_types::{DidChangeTextDocumentParams, DidCloseTextDocumentParams, DidOpenTextDocumentParams, DidSaveTextDocumentParams};
+use lsp_types::{
+    DidChangeTextDocumentParams, DidCloseTextDocumentParams, DidOpenTextDocumentParams,
+    DidSaveTextDocumentParams,
+};
 
 use crate::context::ServerContextSnapshot;
 
@@ -10,8 +13,13 @@ pub async fn on_did_open_text_document(
     let uri = params.text_document.uri;
     let text = params.text_document.text;
     let file_id = analysis.update_file_by_uri(&uri, Some(text));
+    let emmyrc = analysis.get_emmyrc();
+    let interval = emmyrc.diagnostics.diagnostic_interval.unwrap_or(500);
     if let Some(file_id) = file_id {
-        context.file_diagnostic.add_diagnostic_task(file_id).await;
+        context
+            .file_diagnostic
+            .add_diagnostic_task(file_id, interval)
+            .await;
     }
 
     Some(())
@@ -24,8 +32,13 @@ pub async fn on_did_save_text_document(
     let analysis = context.analysis.read().await;
     let uri = params.text_document.uri;
     let file_id = analysis.get_file_id(&uri);
+    let emmyrc = analysis.get_emmyrc();
+    let interval = emmyrc.diagnostics.diagnostic_interval.unwrap_or(500);
     if let Some(file_id) = file_id {
-        context.file_diagnostic.add_diagnostic_task(file_id).await;
+        context
+            .file_diagnostic
+            .add_diagnostic_task(file_id, interval)
+            .await;
     }
 
     Some(())
@@ -39,9 +52,14 @@ pub async fn on_did_change_text_document(
     let uri = params.text_document.uri;
     let text = params.content_changes.first()?.text.clone();
     let file_id = analysis.update_file_by_uri(&uri, Some(text));
+    let emmyrc = analysis.get_emmyrc();
+    let interval = emmyrc.diagnostics.diagnostic_interval.unwrap_or(500);
     drop(analysis);
     if let Some(file_id) = file_id {
-        context.file_diagnostic.add_diagnostic_task(file_id).await;
+        context
+            .file_diagnostic
+            .add_diagnostic_task(file_id, interval)
+            .await;
     }
 
     Some(())
@@ -51,6 +69,5 @@ pub async fn on_did_close_document(
     _: ServerContextSnapshot,
     _: DidCloseTextDocumentParams,
 ) -> Option<()> {
-
     Some(())
-}
+}

crates/emmylua_ls/src/handlers/text_document/watched_file_handler.rs

@@ -10,6 +10,7 @@ pub async fn on_did_change_watched_files(
     let mut analysis = context.analysis.write().await;
     let emmyrc = analysis.get_emmyrc();
     let encoding = &emmyrc.workspace.encoding;
+    let interval = emmyrc.diagnostics.diagnostic_interval.unwrap_or(500);
     let mut watched_lua_files: Vec<(Uri, Option<String>)> = Vec::new();
     // let
     for file_event in params.changes.into_iter() {
@@ -54,7 +55,7 @@ pub async fn on_did_change_watched_files(
     let file_ids = analysis.update_files_by_uri(watched_lua_files);
     context
         .file_diagnostic
-        .add_files_diagnostic_task(file_ids)
+        .add_files_diagnostic_task(file_ids, interval)
         .await;
 
     Some(())

crates/emmylua_ls/src/main.rs

@@ -19,7 +19,6 @@ const CRATE_VERSION: &str = env!("CARGO_PKG_VERSION");
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn Error + Sync + Send>> {
-    env::set_var("RUST_BACKTRACE", "full");
     let cmd_args = CmdArgs::from_args();
     let (connection, threads) = match cmd_args.communication {
         cmd_args::Communication::Stdio => Connection::stdio(),