|
19 | 19 | */ |
20 | 20 | package org.sonarsource.sonarlint.core.rpc.impl; |
21 | 21 |
|
| 22 | +import java.util.List; |
22 | 23 | import java.util.Map; |
23 | 24 | import java.util.Set; |
| 25 | +import java.util.concurrent.CancellationException; |
24 | 26 | import java.util.concurrent.CompletableFuture; |
| 27 | +import java.util.concurrent.CompletionException; |
25 | 28 | import org.eclipse.lsp4j.jsonrpc.ResponseErrorException; |
26 | 29 | import org.eclipse.lsp4j.jsonrpc.messages.ResponseError; |
| 30 | +import org.eclipse.lsp4j.jsonrpc.messages.ResponseErrorCode; |
27 | 31 | import org.sonarsource.sonarlint.core.analysis.AnalysisResult; |
28 | 32 | import org.sonarsource.sonarlint.core.analysis.AnalysisService; |
29 | 33 | import org.sonarsource.sonarlint.core.analysis.NodeJsService; |
@@ -141,7 +145,18 @@ public CompletableFuture<AnalyzeFilesResponse> analyzeFilesAndTrack(AnalyzeFiles |
141 | 145 | return requestFutureAsync(cancelChecker -> getBean(AnalysisService.class) |
142 | 146 | .scheduleAnalysis(params.getConfigurationScopeId(), params.getAnalysisId(), Set.copyOf(params.getFilesToAnalyze()), |
143 | 147 | params.getExtraProperties(), params.isShouldFetchServerIssues(), TriggerType.FORCED_WITH_EXCLUSIONS, cancelChecker) |
144 | | - .thenApply(AnalysisRpcServiceDelegate::generateAnalyzeFilesResponse), configurationScopeId); |
| 148 | + .exceptionally(exception -> { |
| 149 | + if (exception instanceof CompletionException || exception instanceof CancellationException) { |
| 150 | + throw new ResponseErrorException(new ResponseError(ResponseErrorCode.RequestCancelled, "Analysis was cancelled", null)); |
| 151 | + } |
| 152 | + return null; |
| 153 | + }) |
| 154 | + .thenApply(analysisResults -> { |
| 155 | + if (analysisResults == null) { |
| 156 | + throw new ResponseErrorException(new ResponseError(ResponseErrorCode.RequestCancelled, "Analysis was cancelled", null)); |
| 157 | + } |
| 158 | + return generateAnalyzeFilesResponse(analysisResults); |
| 159 | + }), configurationScopeId); |
145 | 160 | } |
146 | 161 |
|
147 | 162 | @Override |
|
0 commit comments