|
8 | 8 | * SPDX-License-Identifier: EPL-2.0 |
9 | 9 | * |
10 | 10 | * Contributors: |
11 | | - * Angelo ZERR (Red Hat Inc.) - initial implementation |
| 11 | + * Angelo ZERR (Red Hat Inc.) - initial implementation |
12 | 12 | *******************************************************************************/ |
13 | 13 | package org.eclipse.wildwebdeveloper.ui.preferences; |
14 | 14 |
|
|
18 | 18 | import java.util.HashMap; |
19 | 19 | import java.util.Map; |
20 | 20 | import java.util.Objects; |
| 21 | +import java.util.Set; |
21 | 22 | import java.util.concurrent.CompletableFuture; |
| 23 | +import java.util.concurrent.ConcurrentHashMap; |
22 | 24 |
|
| 25 | +import org.eclipse.core.resources.ResourcesPlugin; |
23 | 26 | import org.eclipse.jface.preference.IPreferenceStore; |
| 27 | +import org.eclipse.jface.text.IDocument; |
24 | 28 | import org.eclipse.jface.util.IPropertyChangeListener; |
25 | 29 | import org.eclipse.jface.util.PropertyChangeEvent; |
| 30 | +import org.eclipse.lsp4e.LSPEclipseUtils; |
26 | 31 | import org.eclipse.lsp4e.LanguageServers; |
27 | 32 | import org.eclipse.lsp4e.LanguageServersRegistry; |
28 | 33 | import org.eclipse.lsp4e.LanguageServersRegistry.LanguageServerDefinition; |
29 | 34 | import org.eclipse.lsp4e.server.ProcessStreamConnectionProvider; |
30 | 35 | import org.eclipse.lsp4j.DidChangeConfigurationParams; |
| 36 | +import org.eclipse.lsp4j.services.LanguageServer; |
31 | 37 | import org.eclipse.lsp4j.services.WorkspaceService; |
| 38 | +import org.eclipse.ui.IEditorPart; |
| 39 | +import org.eclipse.ui.IEditorReference; |
| 40 | +import org.eclipse.ui.IWorkbenchPage; |
| 41 | +import org.eclipse.ui.IWorkbenchWindow; |
| 42 | +import org.eclipse.ui.PlatformUI; |
32 | 43 |
|
33 | 44 | /** |
34 | 45 | * This class extends {@link ProcessStreamConnectionProvider} to manage |
35 | 46 | * {@link IPreferenceStore} and call |
36 | 47 | * {@link WorkspaceService#didChangeConfiguration(DidChangeConfigurationParams)} |
37 | 48 | * when the preference store changes. |
38 | | - * |
| 49 | + * |
39 | 50 | */ |
40 | 51 | public abstract class ProcessStreamConnectionProviderWithPreference extends ProcessStreamConnectionProvider |
41 | 52 | implements IPropertyChangeListener { |
@@ -162,9 +173,54 @@ public void propertyChange(PropertyChangeEvent event) { |
162 | 173 | @SuppressWarnings("rawtypes") |
163 | 174 | DidChangeConfigurationParams params = new DidChangeConfigurationParams(createSettings()); |
164 | 175 |
|
| 176 | + final Set<LanguageServer> notifiedServers = ConcurrentHashMap.newKeySet(); |
| 177 | + |
165 | 178 | LanguageServers.forProject(null).withPreferredServer(languageServerDefinition).excludeInactive() |
166 | | - .collectAll((w, ls) -> CompletableFuture.completedFuture(ls)).thenAccept( |
167 | | - lss -> lss.stream().forEach(ls -> ls.getWorkspaceService().didChangeConfiguration(params))); |
| 179 | + .collectAll((wrapper, server) -> { |
| 180 | + if (languageServerDefinition.equals(wrapper.serverDefinition) && notifiedServers.add(server)) { |
| 181 | + server.getWorkspaceService().didChangeConfiguration(params); |
| 182 | + } |
| 183 | + return CompletableFuture.completedFuture(null); |
| 184 | + }); |
| 185 | + |
| 186 | + // also explicitly check project-scoped LS because `LanguageServers.forProject(null)` does not return LanguageServers |
| 187 | + // that do not support supportsWorkspaceFolderCapability like JSTSLanguageServer. These LS do not pass the |
| 188 | + // `LanguageServerWrapper.canOperate(IProject)` test with null project argument as used by `LanguageServers.forProject(null)` |
| 189 | + for (final var project : ResourcesPlugin.getWorkspace().getRoot().getProjects()) { |
| 190 | + if (!project.isOpen()) |
| 191 | + continue; |
| 192 | + |
| 193 | + LanguageServers.forProject(project).withPreferredServer(languageServerDefinition).excludeInactive() |
| 194 | + .collectAll((wrapper, server) -> { |
| 195 | + if (languageServerDefinition.equals(wrapper.serverDefinition) && notifiedServers.add(server)) { |
| 196 | + server.getWorkspaceService().didChangeConfiguration(params); |
| 197 | + } |
| 198 | + return CompletableFuture.completedFuture(null); |
| 199 | + }); |
| 200 | + } |
| 201 | + |
| 202 | + // check per-doc LS |
| 203 | + for (final IWorkbenchWindow win : PlatformUI.getWorkbench().getWorkbenchWindows()) { |
| 204 | + for (IWorkbenchPage page : win.getPages()) { |
| 205 | + for (IEditorReference ref : page.getEditorReferences()) { |
| 206 | + IEditorPart editor = ref.getEditor(false); // do not restore unopened editors |
| 207 | + if (editor == null) |
| 208 | + continue; |
| 209 | + |
| 210 | + IDocument doc = LSPEclipseUtils.getDocument(editor.getEditorInput()); |
| 211 | + if (doc == null) |
| 212 | + continue; |
| 213 | + |
| 214 | + LanguageServers.forDocument(doc).withPreferredServer(languageServerDefinition) |
| 215 | + .collectAll((wrapper, server) -> { |
| 216 | + if (languageServerDefinition.equals(wrapper.serverDefinition) && notifiedServers.add(server)) { |
| 217 | + server.getWorkspaceService().didChangeConfiguration(params); |
| 218 | + } |
| 219 | + return CompletableFuture.completedFuture(null); |
| 220 | + }); |
| 221 | + } |
| 222 | + } |
| 223 | + } |
168 | 224 | } |
169 | 225 | } |
170 | 226 |
|
|
0 commit comments