Method start_server

src/crates/services/services-core/src/lsp/manager.rs:123–187

Starts an LSP server. workspace_root: Workspace root path, provided by the caller (WorkspaceLspManager). crash_callback: Callback invoked when the process crashes. progress_callback: Indexing progress callback. token_create_callback: Token creation callback. diagnostics_callback: Diagnostics callback.

(
        &self,
        language: &str,
        workspace_root: Option<PathBuf>,
        crash_callback: Option<CrashCallback>,
        progress_callback: Option<ProgressCallback>,
        token_crea

    /// token_create_callback: Token creation callback.
    /// diagnostics_callback: Diagnostics callback.
    pub async fn start_server(
        &self,
        language: &str,
        workspace_root: Option<PathBuf>,
        crash_callback: Option<CrashCallback>,
        progress_callback: Option<ProgressCallback>,
        token_create_callback: Option<TokenCreateCallback>,
        diagnostics_callback: Option<DiagnosticsCallback>,
    ) -> Result<()> {
        let plugin = {
            let registry = self.registry.read().await;
            match registry.find_by_language(language).cloned() {
                Some(plugin) => plugin,
                None => {
                    let err = anyhow!("No LSP plugin found for language: {}", language);
                    warn!("{} (this is expected for plaintext)", err);
                    return Err(err);
                }
            }
        };

        let plugin_id = plugin.id.clone();

        {
            let processes = self.processes.read().await;
            if processes.contains_key(language) {
                return Ok(());
            }
        }

        let server_path = self.plugin_loader.get_server_path(&plugin).map_err(|e| {
            error!("Failed to get server path: {}", e);
            e
        })?;

        let process = LspServerProcess::spawn(
            plugin_id.clone(),
            server_path.clone(),
            &plugin.server,
            crash_callback,
            progress_callback,
            token_create_callback,
            diagnostics_callback,
        )
        .await
        .map_err(|e| {
            error!("Failed to spawn process: {}", e);
            e
        })?;

        let root_uri = workspace_root.and_then(|p| p.to_str().map(|s| s.to_string()));

        process.initialize(root_uri.clone()).await.map_err(|e| {
            error!("Failed to initialize LSP connection: {}", e);
            e
        })?;

        {