headless_host.rs

  1use std::{path::PathBuf, sync::Arc};
  2
  3use anyhow::{Context as _, Result};
  4use client::{TypedEnvelope, proto};
  5use collections::{HashMap, HashSet};
  6use extension::{
  7    Extension, ExtensionDebugAdapterProviderProxy, ExtensionHostProxy, ExtensionLanguageProxy,
  8    ExtensionLanguageServerProxy, ExtensionManifest,
  9};
 10use fs::{Fs, RemoveOptions, RenameOptions};
 11use gpui::{App, AppContext as _, AsyncApp, Context, Entity, Task, WeakEntity};
 12use http_client::HttpClient;
 13use language::{LanguageConfig, LanguageName, LanguageQueries, LoadedLanguage};
 14use lsp::LanguageServerName;
 15use node_runtime::NodeRuntime;
 16
 17use crate::wasm_host::{WasmExtension, WasmHost};
 18
 19#[derive(Clone, Debug)]
 20pub struct ExtensionVersion {
 21    pub id: String,
 22    pub version: String,
 23    pub dev: bool,
 24}
 25
 26pub struct HeadlessExtensionStore {
 27    pub fs: Arc<dyn Fs>,
 28    pub extension_dir: PathBuf,
 29    pub proxy: Arc<ExtensionHostProxy>,
 30    pub wasm_host: Arc<WasmHost>,
 31    pub loaded_extensions: HashMap<Arc<str>, Arc<str>>,
 32    pub loaded_languages: HashMap<Arc<str>, Vec<LanguageName>>,
 33    pub loaded_language_servers: HashMap<Arc<str>, Vec<(LanguageServerName, LanguageName)>>,
 34}
 35
 36impl HeadlessExtensionStore {
 37    pub fn new(
 38        fs: Arc<dyn Fs>,
 39        http_client: Arc<dyn HttpClient>,
 40        extension_dir: PathBuf,
 41        extension_host_proxy: Arc<ExtensionHostProxy>,
 42        node_runtime: NodeRuntime,
 43        cx: &mut App,
 44    ) -> Entity<Self> {
 45        cx.new(|cx| Self {
 46            fs: fs.clone(),
 47            wasm_host: WasmHost::new(
 48                fs.clone(),
 49                http_client.clone(),
 50                node_runtime,
 51                extension_host_proxy.clone(),
 52                extension_dir.join("work"),
 53                cx,
 54            ),
 55            extension_dir,
 56            proxy: extension_host_proxy,
 57            loaded_extensions: Default::default(),
 58            loaded_languages: Default::default(),
 59            loaded_language_servers: Default::default(),
 60        })
 61    }
 62
 63    pub fn sync_extensions(
 64        &mut self,
 65        extensions: Vec<ExtensionVersion>,
 66        cx: &Context<Self>,
 67    ) -> Task<Result<Vec<ExtensionVersion>>> {
 68        let on_client = HashSet::from_iter(extensions.iter().map(|e| e.id.as_str()));
 69        let to_remove: Vec<Arc<str>> = self
 70            .loaded_extensions
 71            .keys()
 72            .filter(|id| !on_client.contains(id.as_ref()))
 73            .cloned()
 74            .collect();
 75        let to_load: Vec<ExtensionVersion> = extensions
 76            .into_iter()
 77            .filter(|e| {
 78                if e.dev {
 79                    return true;
 80                }
 81                self.loaded_extensions
 82                    .get(e.id.as_str())
 83                    .is_none_or(|loaded| loaded.as_ref() != e.version.as_str())
 84            })
 85            .collect();
 86
 87        cx.spawn(async move |this, cx| {
 88            let mut missing = Vec::new();
 89
 90            for extension_id in to_remove {
 91                log::info!("removing extension: {}", extension_id);
 92                this.update(cx, |this, cx| this.uninstall_extension(&extension_id, cx))?
 93                    .await?;
 94            }
 95
 96            for extension in to_load {
 97                if let Err(e) = Self::load_extension(this.clone(), extension.clone(), cx).await {
 98                    log::info!("failed to load extension: {}, {:?}", extension.id, e);
 99                    missing.push(extension)
100                } else if extension.dev {
101                    missing.push(extension)
102                }
103            }
104
105            Ok(missing)
106        })
107    }
108
109    pub async fn load_extension(
110        this: WeakEntity<Self>,
111        extension: ExtensionVersion,
112        cx: &mut AsyncApp,
113    ) -> Result<()> {
114        let (fs, wasm_host, extension_dir) = this.update(cx, |this, _cx| {
115            this.loaded_extensions.insert(
116                extension.id.clone().into(),
117                extension.version.clone().into(),
118            );
119            (
120                this.fs.clone(),
121                this.wasm_host.clone(),
122                this.extension_dir.join(&extension.id),
123            )
124        })?;
125
126        let manifest = Arc::new(ExtensionManifest::load(fs.clone(), &extension_dir).await?);
127
128        debug_assert!(!manifest.languages.is_empty() || !manifest.language_servers.is_empty());
129
130        if manifest.version.as_ref() != extension.version.as_str() {
131            anyhow::bail!(
132                "mismatched versions: ({}) != ({})",
133                manifest.version,
134                extension.version
135            )
136        }
137
138        for language_path in &manifest.languages {
139            let language_path = extension_dir.join(language_path);
140            let config = fs.load(&language_path.join("config.toml")).await?;
141            let mut config = ::toml::from_str::<LanguageConfig>(&config)?;
142
143            this.update(cx, |this, _cx| {
144                this.loaded_languages
145                    .entry(manifest.id.clone())
146                    .or_default()
147                    .push(config.name.clone());
148
149                config.grammar = None;
150
151                this.proxy.register_language(
152                    config.name.clone(),
153                    None,
154                    config.matcher.clone(),
155                    config.hidden,
156                    Arc::new(move || {
157                        Ok(LoadedLanguage {
158                            config: config.clone(),
159                            queries: LanguageQueries::default(),
160                            context_provider: None,
161                            toolchain_provider: None,
162                        })
163                    }),
164                );
165            })?;
166        }
167
168        if manifest.language_servers.is_empty() {
169            return Ok(());
170        }
171
172        let wasm_extension: Arc<dyn Extension> = Arc::new(
173            WasmExtension::load(extension_dir.clone(), &manifest, wasm_host.clone(), &cx).await?,
174        );
175
176        for (language_server_id, language_server_config) in &manifest.language_servers {
177            for language in language_server_config.languages() {
178                this.update(cx, |this, _cx| {
179                    this.loaded_language_servers
180                        .entry(manifest.id.clone())
181                        .or_default()
182                        .push((language_server_id.clone(), language.clone()));
183                    this.proxy.register_language_server(
184                        wasm_extension.clone(),
185                        language_server_id.clone(),
186                        language.clone(),
187                    );
188                })?;
189            }
190            for (debug_adapter, meta) in &manifest.debug_adapters {
191                let schema_path = extension::build_debug_adapter_schema_path(debug_adapter, meta);
192
193                this.update(cx, |this, _cx| {
194                    this.proxy.register_debug_adapter(
195                        wasm_extension.clone(),
196                        debug_adapter.clone(),
197                        &extension_dir.join(schema_path),
198                    );
199                })?;
200            }
201
202            for debug_adapter in manifest.debug_locators.keys() {
203                this.update(cx, |this, _cx| {
204                    this.proxy
205                        .register_debug_locator(wasm_extension.clone(), debug_adapter.clone());
206                })?;
207            }
208        }
209
210        Ok(())
211    }
212
213    fn uninstall_extension(
214        &mut self,
215        extension_id: &Arc<str>,
216        cx: &mut Context<Self>,
217    ) -> Task<Result<()>> {
218        self.loaded_extensions.remove(extension_id);
219
220        let languages_to_remove = self
221            .loaded_languages
222            .remove(extension_id)
223            .unwrap_or_default();
224        self.proxy.remove_languages(&languages_to_remove, &[]);
225
226        for (language_server_name, language) in self
227            .loaded_language_servers
228            .remove(extension_id)
229            .unwrap_or_default()
230        {
231            self.proxy
232                .remove_language_server(&language, &language_server_name);
233        }
234
235        let path = self.extension_dir.join(&extension_id.to_string());
236        let fs = self.fs.clone();
237        cx.spawn(async move |_, _| {
238            fs.remove_dir(
239                &path,
240                RemoveOptions {
241                    recursive: true,
242                    ignore_if_not_exists: true,
243                },
244            )
245            .await
246        })
247    }
248
249    pub fn install_extension(
250        &mut self,
251        extension: ExtensionVersion,
252        tmp_path: PathBuf,
253        cx: &mut Context<Self>,
254    ) -> Task<Result<()>> {
255        let path = self.extension_dir.join(&extension.id);
256        let fs = self.fs.clone();
257
258        cx.spawn(async move |this, cx| {
259            if fs.is_dir(&path).await {
260                this.update(cx, |this, cx| {
261                    this.uninstall_extension(&extension.id.clone().into(), cx)
262                })?
263                .await?;
264            }
265
266            fs.rename(&tmp_path, &path, RenameOptions::default())
267                .await?;
268
269            Self::load_extension(this, extension, cx).await
270        })
271    }
272
273    pub async fn handle_sync_extensions(
274        extension_store: Entity<HeadlessExtensionStore>,
275        envelope: TypedEnvelope<proto::SyncExtensions>,
276        mut cx: AsyncApp,
277    ) -> Result<proto::SyncExtensionsResponse> {
278        let requested_extensions =
279            envelope
280                .payload
281                .extensions
282                .into_iter()
283                .map(|p| ExtensionVersion {
284                    id: p.id,
285                    version: p.version,
286                    dev: p.dev,
287                });
288        let missing_extensions = extension_store
289            .update(&mut cx, |extension_store, cx| {
290                extension_store.sync_extensions(requested_extensions.collect(), cx)
291            })?
292            .await?;
293
294        Ok(proto::SyncExtensionsResponse {
295            missing_extensions: missing_extensions
296                .into_iter()
297                .map(|e| proto::Extension {
298                    id: e.id,
299                    version: e.version,
300                    dev: e.dev,
301                })
302                .collect(),
303            tmp_dir: paths::remote_extensions_uploads_dir()
304                .to_string_lossy()
305                .to_string(),
306        })
307    }
308
309    pub async fn handle_install_extension(
310        extensions: Entity<HeadlessExtensionStore>,
311        envelope: TypedEnvelope<proto::InstallExtension>,
312        mut cx: AsyncApp,
313    ) -> Result<proto::Ack> {
314        let extension = envelope
315            .payload
316            .extension
317            .context("Invalid InstallExtension request")?;
318
319        extensions
320            .update(&mut cx, |extensions, cx| {
321                extensions.install_extension(
322                    ExtensionVersion {
323                        id: extension.id,
324                        version: extension.version,
325                        dev: extension.dev,
326                    },
327                    PathBuf::from(envelope.payload.tmp_dir),
328                    cx,
329                )
330            })?
331            .await?;
332
333        Ok(proto::Ack {})
334    }
335}