draft(oxlnt/lsp): support jsPlugins

Author: Sysix

.vscode/settings.json

@@ -1,4 +1,5 @@
 {
+  "oxc.path.server": "./apps/oxlint/dist/cli.js",
   "oxc.typeAware": true,
   "oxc.configPath": "oxlintrc.json",
   "oxc.unusedDisableDirectives": "deny",

apps/oxlint/src/js_plugins/external_linter.rs

@@ -1,4 +1,4 @@
-use std::sync::{atomic::Ordering, mpsc::channel};
+use std::sync::{Arc, atomic::Ordering, mpsc::channel};
 
 use napi::{
     Status,
@@ -45,7 +45,7 @@ pub fn create_external_linter(
 ///
 /// The returned function will panic if called outside of a Tokio runtime.
 fn wrap_load_plugin(cb: JsLoadPluginCb) -> ExternalLinterLoadPluginCb {
-    Box::new(move |workspace_dir, plugin_url, package_name| {
+    Arc::new(Box::new(move |workspace_dir, plugin_url, package_name| {
         let cb = &cb;
         tokio::task::block_in_place(|| {
             tokio::runtime::Handle::current().block_on(async move {
@@ -58,7 +58,7 @@ fn wrap_load_plugin(cb: JsLoadPluginCb) -> ExternalLinterLoadPluginCb {
                 Ok(plugin_load_result)
             })
         })
-    })
+    }))
 }
 
 /// Result returned by `lintFile` JS callback.
@@ -71,17 +71,17 @@ pub enum LintFileReturnValue {
 /// Wrap `createWorkspace` JS callback as a normal Rust function.
 ///
 fn wrap_create_workspace(cb: JsCreateWorkspaceCb) -> oxc_linter::ExternalLinterCreateWorkspaceCb {
-    Box::new(move |root_dir: String| {
+    Arc::new(Box::new(move |root_dir: String| {
         let _ = cb.call(FnArgs::from((root_dir,)), ThreadsafeFunctionCallMode::Blocking);
-    })
+    }))
 }
 
 fn wrap_destroy_workspace(
     cb: JsDestroyWorkspaceCb,
 ) -> oxc_linter::ExternalLinterDestroyWorkspaceCb {
-    Box::new(move |root_dir: String| {
+    Arc::new(Box::new(move |root_dir: String| {
         let _ = cb.call(FnArgs::from((root_dir,)), ThreadsafeFunctionCallMode::Blocking);
-    })
+    }))
 }
 
 /// Wrap `lintFile` JS callback as a normal Rust function.
@@ -94,7 +94,7 @@ fn wrap_destroy_workspace(
 /// Use an `mpsc::channel` to wait for the result from JS side, and block current thread until `lintFile`
 /// completes execution.
 fn wrap_lint_file(cb: JsLintFileCb) -> ExternalLinterLintFileCb {
-    Box::new(
+    Arc::new(Box::new(
         move |workspace_dir: String,
               file_path: String,
               rule_ids: Vec<u32>,
@@ -148,7 +148,7 @@ fn wrap_lint_file(cb: JsLintFileCb) -> ExternalLinterLintFileCb {
                 Err(err) => panic!("Callback did not respond: {err}"),
             }
         },
-    )
+    ))
 }
 
 /// Get buffer ID of the `Allocator` and, if it hasn't already been sent to JS,

apps/oxlint/src/lsp.rs

@@ -1,4 +1,7 @@
 /// Run the language server
-pub async fn run_lsp() {
-    oxc_language_server::run_server(vec![Box::new(oxc_language_server::ServerLinterBuilder)]).await;
+pub async fn run_lsp(external_linter: Option<oxc_linter::ExternalLinter>) {
+    oxc_language_server::run_server(vec![Box::new(oxc_language_server::ServerLinterBuilder::new(
+        external_linter,
+    ))])
+    .await;
 }

apps/oxlint/src/main.rs

@@ -9,7 +9,7 @@ async fn main() -> CliRunResult {
 
     // If --lsp flag is set, run the language server
     if command.lsp {
-        run_lsp().await;
+        run_lsp(None).await;
         return CliRunResult::LintSucceeded;
     }
 

apps/oxlint/src/run.rs

@@ -133,17 +133,6 @@ async fn lint_impl(
         }
     };
 
-    // If --lsp flag is set, run the language server
-    if command.lsp {
-        crate::lsp::run_lsp().await;
-        return CliRunResult::LintSucceeded;
-    }
-
-    init_tracing();
-    init_miette();
-
-    command.handle_threads();
-
     // JS plugins are only supported on 64-bit little-endian platforms at present
     #[cfg(all(target_pointer_width = "64", target_endian = "little"))]
     let external_linter = Some(super::js_plugins::create_external_linter(
@@ -158,6 +147,17 @@ async fn lint_impl(
         None
     };
 
+    // If --lsp flag is set, run the language server
+    if command.lsp {
+        crate::lsp::run_lsp(external_linter).await;
+        return CliRunResult::LintSucceeded;
+    }
+
+    init_tracing();
+    init_miette();
+
+    command.handle_threads();
+
     // stdio is blocked by LineWriter, use a BufWriter to reduce syscalls.
     // See `https://github.com/rust-lang/rust/issues/60673`.
     let mut stdout = BufWriter::new(std::io::stdout());

crates/oxc_language_server/src/linter/isolated_lint_handler.rs

@@ -10,9 +10,9 @@ use tower_lsp_server::{UriExt, lsp_types::Uri};
 
 use oxc_allocator::Allocator;
 use oxc_linter::{
-    AllowWarnDeny, ConfigStore, DisableDirectives, Fix, FixKind, LINTABLE_EXTENSIONS, LintOptions,
-    LintRunner, LintRunnerBuilder, LintServiceOptions, Linter, Message, PossibleFixes,
-    RuleCommentType, RuntimeFileSystem, read_to_arena_str, read_to_string,
+    AllowWarnDeny, ConfigStore, DisableDirectives, ExternalLinter, Fix, FixKind,
+    LINTABLE_EXTENSIONS, LintOptions, LintRunner, LintRunnerBuilder, LintServiceOptions, Linter,
+    Message, PossibleFixes, RuleCommentType, RuntimeFileSystem, read_to_arena_str, read_to_string,
 };
 
 use super::error_with_position::{
@@ -68,12 +68,13 @@ impl IsolatedLintHandler {
         cwd: &Path,
         lint_options: LintOptions,
         config_store: ConfigStore,
+        external_linter: Option<ExternalLinter>,
         options: &IsolatedLintHandlerOptions,
     ) -> Self {
         let config_store_clone = config_store.clone();
         let cwd = cwd.to_string_lossy().to_string();
 
-        let linter = Linter::new(cwd.clone(), lint_options, config_store, None);
+        let linter = Linter::new(cwd.clone(), lint_options, config_store, external_linter);
         let mut lint_service_options = LintServiceOptions::new(options.root_path.clone())
             .with_cross_module(options.use_cross_module);
 
@@ -123,6 +124,7 @@ impl IsolatedLintHandler {
         debug!("lint {}", path.display());
         let rope = &Rope::from_str(source_text);
 
+        // ToDO: with external linter, we need a new FS (raw) system
         let fs = IsolatedLintHandlerFileSystem::new(path.to_path_buf(), Arc::from(source_text));
 
         let mut messages: Vec<DiagnosticReport> = self