diff --git a/crates/languages/src/json.rs b/crates/languages/src/json.rs index 5bdeda8bb9..4012624e5a 100644 --- a/crates/languages/src/json.rs +++ b/crates/languages/src/json.rs @@ -1,25 +1,32 @@ -use anyhow::{anyhow, Result}; +use anyhow::{anyhow, bail, Context, Result}; +use async_compression::futures::bufread::GzipDecoder; +use async_tar::Archive; use async_trait::async_trait; use collections::HashMap; use feature_flags::FeatureFlagAppExt; use futures::StreamExt; use gpui::{AppContext, AsyncAppContext}; +use http::github::{latest_github_release, GitHubLspBinaryVersion}; use language::{LanguageRegistry, LanguageServerName, LspAdapter, LspAdapterDelegate}; use lsp::LanguageServerBinary; use node_runtime::NodeRuntime; use project::ContextProviderWithTasks; use serde_json::{json, Value}; use settings::{KeymapFile, SettingsJsonSchemaParams, SettingsStore}; -use smol::fs; +use smol::{ + fs::{self}, + io::BufReader, +}; use std::{ any::Any, + env::consts, ffi::OsString, path::{Path, PathBuf}, str::FromStr, sync::{Arc, OnceLock}, }; use task::{TaskTemplate, TaskTemplates, VariableName}; -use util::{maybe, ResultExt}; +use util::{fs::remove_matching, maybe, ResultExt}; const SERVER_PATH: &str = "node_modules/vscode-langservers-extracted/bin/vscode-json-language-server"; @@ -251,3 +258,137 @@ fn schema_file_match(path: &Path) -> String { .to_string() .replace('\\', "/") } + +pub(super) struct NodeVersionAdapter; + +#[async_trait(?Send)] +impl LspAdapter for NodeVersionAdapter { + fn name(&self) -> LanguageServerName { + LanguageServerName("package-version-server".into()) + } + + async fn fetch_latest_server_version( + &self, + delegate: &dyn LspAdapterDelegate, + ) -> Result> { + let release = latest_github_release( + "zed-industries/package-version-server", + true, + false, + delegate.http_client(), + ) + .await?; + let os = match consts::OS { + "macos" => "apple-darwin", + "linux" => "unknown-linux-gnu", + "windows" => "pc-windows-msvc", + other => bail!("Running on unsupported os: {other}"), + }; + let suffix = if consts::OS == "windows" { + ".zip" + } else { + ".tar.gz" + }; + let asset_name = format!("package-version-server-{}-{os}{suffix}", consts::ARCH); + let asset = release + .assets + .iter() + .find(|asset| asset.name == asset_name) + .with_context(|| format!("no asset found matching `{asset_name:?}`"))?; + Ok(Box::new(GitHubLspBinaryVersion { + name: release.tag_name, + url: asset.browser_download_url.clone(), + })) + } + + async fn fetch_server_binary( + &self, + latest_version: Box, + container_dir: PathBuf, + delegate: &dyn LspAdapterDelegate, + ) -> Result { + let version = latest_version.downcast::().unwrap(); + let destination_path = + container_dir.join(format!("package-version-server-{}", version.name)); + let destination_container_path = + container_dir.join(format!("package-version-server-{}-tmp", version.name)); + if fs::metadata(&destination_path).await.is_err() { + let mut response = delegate + .http_client() + .get(&version.url, Default::default(), true) + .await + .map_err(|err| anyhow!("error downloading release: {}", err))?; + if version.url.ends_with(".zip") { + node_runtime::extract_zip( + &destination_container_path, + BufReader::new(response.body_mut()), + ) + .await?; + } else if version.url.ends_with(".tar.gz") { + let decompressed_bytes = GzipDecoder::new(BufReader::new(response.body_mut())); + let archive = Archive::new(decompressed_bytes); + archive.unpack(&destination_container_path).await?; + } + + fs::copy( + destination_container_path.join("package-version-server"), + &destination_path, + ) + .await?; + // todo("windows") + #[cfg(not(windows))] + { + fs::set_permissions( + &destination_path, + ::from_mode(0o755), + ) + .await?; + } + remove_matching(&container_dir, |entry| entry != destination_path).await; + } + + Ok(LanguageServerBinary { + path: destination_path.join("package-version-server"), + env: None, + arguments: Default::default(), + }) + } + + async fn cached_server_binary( + &self, + container_dir: PathBuf, + _delegate: &dyn LspAdapterDelegate, + ) -> Option { + get_cached_version_server_binary(container_dir).await + } + + async fn installation_test_binary( + &self, + container_dir: PathBuf, + ) -> Option { + get_cached_version_server_binary(container_dir) + .await + .map(|mut binary| { + binary.arguments = vec!["--version".into()]; + binary + }) + } +} + +async fn get_cached_version_server_binary(container_dir: PathBuf) -> Option { + maybe!(async { + let mut last = None; + let mut entries = fs::read_dir(&container_dir).await?; + while let Some(entry) = entries.next().await { + last = Some(entry?.path()); + } + + anyhow::Ok(LanguageServerBinary { + path: last.ok_or_else(|| anyhow!("no cached binary"))?, + env: None, + arguments: Default::default(), + }) + }) + .await + .log_err() +} diff --git a/crates/languages/src/lib.rs b/crates/languages/src/lib.rs index 9ca727f46e..205644fbba 100644 --- a/crates/languages/src/lib.rs +++ b/crates/languages/src/lib.rs @@ -117,10 +117,13 @@ pub fn init( language!( "json", - vec![Arc::new(json::JsonLspAdapter::new( - node_runtime.clone(), - languages.clone(), - ))], + vec![ + Arc::new(json::JsonLspAdapter::new( + node_runtime.clone(), + languages.clone(), + )), + Arc::new(json::NodeVersionAdapter) + ], json_task_context() ); language!("markdown"); diff --git a/crates/node_runtime/src/node_runtime.rs b/crates/node_runtime/src/node_runtime.rs index 6ec7f95f4a..5f482de22a 100644 --- a/crates/node_runtime/src/node_runtime.rs +++ b/crates/node_runtime/src/node_runtime.rs @@ -1,6 +1,7 @@ mod archive; use anyhow::{anyhow, bail, Context, Result}; +pub use archive::extract_zip; use async_compression::futures::bufread::GzipDecoder; use async_tar::Archive; use futures::AsyncReadExt;