-
-
Notifications
You must be signed in to change notification settings - Fork 2.5k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
don't resolve lsp with compltion resolve requests
- Loading branch information
1 parent
cbd69a7
commit a4dc696
Showing
6 changed files
with
197 additions
and
120 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,154 @@ | ||
| use std::sync::Arc; | ||
|
|
||
| use helix_lsp::lsp; | ||
| use tokio::sync::mpsc::Sender; | ||
| use tokio::time::{Duration, Instant}; | ||
|
|
||
| use helix_event::{send_blocking, AsyncHook, CancelRx}; | ||
| use helix_view::Editor; | ||
|
|
||
| use crate::handlers::completion::CompletionItem; | ||
| use crate::job; | ||
|
|
||
| /// A hook for resolving incomplete completion items. | ||
| /// | ||
| /// From the [LSP spec](https://microsoft.github.io/language-server-protocol/specifications/lsp/3.17/specification/#textDocument_completion): | ||
| /// | ||
| /// > If computing full completion items is expensive, servers can additionally provide a | ||
| /// > handler for the completion item resolve request. ... | ||
| /// > A typical use case is for example: the `textDocument/completion` request doesn't fill | ||
| /// > in the `documentation` property for returned completion items since it is expensive | ||
| /// > to compute. When the item is selected in the user interface then a | ||
| /// > 'completionItem/resolve' request is sent with the selected completion item as a parameter. | ||
| /// > The returned completion item should have the documentation property filled in. | ||
| pub struct ResolveHandler { | ||
| last_request: Option<Arc<CompletionItem>>, | ||
| resolver: Sender<ResolveRequest>, | ||
| } | ||
|
|
||
| impl ResolveHandler { | ||
| pub fn new() -> ResolveHandler { | ||
| ResolveHandler { | ||
| last_request: None, | ||
| resolver: ResolveTimeout { | ||
| next_request: None, | ||
| in_flight: None, | ||
| } | ||
| .spawn(), | ||
| } | ||
| } | ||
|
|
||
| pub fn ensure_item_resolved(&mut self, editor: &mut Editor, item: &mut CompletionItem) { | ||
| if item.resolved { | ||
| return; | ||
| } | ||
| let needs_resolve = item.item.documentation.is_none() | ||
| || item.item.detail.is_none() | ||
| || item.item.additional_text_edits.is_none(); | ||
| if !needs_resolve { | ||
| item.resolved = true; | ||
| return; | ||
| } | ||
| if self.last_request.as_deref().is_some_and(|it| it == item) { | ||
| return; | ||
| } | ||
| let Some(ls) = editor.language_servers.get_by_id(item.provider).cloned() else { | ||
| item.resolved = true; | ||
| return; | ||
| }; | ||
| if matches!( | ||
| ls.capabilities().completion_provider, | ||
| Some(lsp::CompletionOptions { | ||
| resolve_provider: Some(true), | ||
| .. | ||
| }) | ||
| ) { | ||
| let item = Arc::new(item.clone()); | ||
| self.last_request = Some(item.clone()); | ||
| send_blocking(&self.resolver, ResolveRequest { item, ls }) | ||
| } else { | ||
| item.resolved = true; | ||
| } | ||
| } | ||
| } | ||
|
|
||
| struct ResolveRequest { | ||
| item: Arc<CompletionItem>, | ||
| ls: Arc<helix_lsp::Client>, | ||
| } | ||
|
|
||
| #[derive(Default)] | ||
| struct ResolveTimeout { | ||
| next_request: Option<ResolveRequest>, | ||
| in_flight: Option<(helix_event::CancelTx, Arc<CompletionItem>)>, | ||
| } | ||
|
|
||
| impl AsyncHook for ResolveTimeout { | ||
| type Event = ResolveRequest; | ||
|
|
||
| fn handle_event( | ||
| &mut self, | ||
| request: Self::Event, | ||
| timeout: Option<tokio::time::Instant>, | ||
| ) -> Option<tokio::time::Instant> { | ||
| if self | ||
| .next_request | ||
| .as_ref() | ||
| .is_some_and(|old_request| old_request.item == request.item) | ||
| { | ||
| timeout | ||
| } else if self | ||
| .in_flight | ||
| .as_ref() | ||
| .is_some_and(|(_, old_request)| old_request.item == request.item.item) | ||
| { | ||
| self.next_request = None; | ||
| None | ||
| } else { | ||
| self.next_request = Some(request); | ||
| self.next_request = None; | ||
| Some(Instant::now() + Duration::from_millis(150)) | ||
| } | ||
| } | ||
|
|
||
| fn finish_debounce(&mut self) { | ||
| let Some(request) = self.next_request.take() else { return }; | ||
| let (tx, rx) = helix_event::cancelation(); | ||
| self.in_flight = Some((tx, request.item.clone())); | ||
| tokio::spawn(request.execute(rx)); | ||
| } | ||
| } | ||
|
|
||
| impl ResolveRequest { | ||
| async fn execute(self, cancel: CancelRx) { | ||
| let future = self.ls.resolve_completion_item(&self.item.item); | ||
| let Some(resolved_item) = helix_event::cancelable_future(future, cancel).await else { | ||
| return; | ||
| }; | ||
| job::dispatch(move |_, compositor| { | ||
| if let Some(completion) = &mut compositor | ||
| .find::<crate::ui::EditorView>() | ||
| .unwrap() | ||
| .completion | ||
| { | ||
| let resolved_item = match resolved_item { | ||
| Ok(item) => CompletionItem { | ||
| item, | ||
| resolved: true, | ||
| ..*self.item | ||
| }, | ||
| Err(err) => { | ||
| log::error!("completion resolve request failed: {err}"); | ||
| // set item to resolved so we don't request it again | ||
| // we could also remove it but that oculd be odd ui | ||
| let mut item = (*self.item).clone(); | ||
| item.resolved = true; | ||
| item | ||
| } | ||
| }; | ||
| completion.replace_item(&self.item, resolved_item); | ||
| }; | ||
| }) | ||
| .await | ||
| } | ||
| } |
Oops, something went wrong.