/**************************************************************************** ** ** Copyright (C) 2018 The Qt Company Ltd. ** Contact: https://www.qt.io/licensing/ ** ** This file is part of Qt Creator. ** ** Commercial License Usage ** Licensees holding valid commercial Qt licenses may use this file in ** accordance with the commercial license agreement provided with the ** Software or, alternatively, in accordance with the terms contained in ** a written agreement between you and The Qt Company. For licensing terms ** and conditions see https://www.qt.io/terms-conditions. For further ** information use the contact form at https://www.qt.io/contact-us. ** ** GNU General Public License Usage ** Alternatively, this file may be used under the terms of the GNU ** General Public License version 3 as published by the Free Software ** Foundation with exceptions as appearing in the file LICENSE.GPL3-EXCEPT ** included in the packaging of this file. Please review the following ** information to ensure the GNU General Public License requirements will ** be met: https://www.gnu.org/licenses/gpl-3.0.html. ** ****************************************************************************/ #include "client.h" #include "languageclientinterface.h" #include "languageclientmanager.h" #include "languageclientutils.h" #include "semantichighlightsupport.h" #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include using namespace LanguageServerProtocol; using namespace Utils; namespace LanguageClient { static Q_LOGGING_CATEGORY(LOGLSPCLIENT, "qtc.languageclient.client", QtWarningMsg); class TextMark : public TextEditor::TextMark { public: TextMark(const Utils::FilePath &fileName, const Diagnostic &diag) : TextEditor::TextMark(fileName, diag.range().start().line() + 1, "lspmark") , m_diagnostic(diag) { using namespace Utils; setLineAnnotation(diag.message()); setToolTip(diag.message()); const bool isError = diag.severity().value_or(DiagnosticSeverity::Hint) == DiagnosticSeverity::Error; setColor(isError ? Theme::CodeModel_Error_TextMarkColor : Theme::CodeModel_Warning_TextMarkColor); setIcon(isError ? Icons::CODEMODEL_ERROR.icon() : Icons::CODEMODEL_WARNING.icon()); } const Diagnostic &diagnostic() const { return m_diagnostic; } private: const Diagnostic m_diagnostic; }; Client::Client(BaseClientInterface *clientInterface) : m_id(Core::Id::fromString(QUuid::createUuid().toString())) , m_completionProvider(this) , m_functionHintProvider(this) , m_quickFixProvider(this) , m_clientInterface(clientInterface) , m_documentSymbolCache(this) , m_hoverHandler(this) { m_contentHandler.insert(JsonRpcMessageHandler::jsonRpcMimeType(), &JsonRpcMessageHandler::parseContent); QTC_ASSERT(clientInterface, return); connect(clientInterface, &BaseClientInterface::messageReceived, this, &Client::handleMessage); connect(clientInterface, &BaseClientInterface::error, this, &Client::setError); connect(clientInterface, &BaseClientInterface::finished, this, &Client::finished); connect(TextEditor::TextEditorSettings::instance(), &TextEditor::TextEditorSettings::fontSettingsChanged, this, &Client::rehighlight); } static void updateEditorToolBar(QList files) { QList editors = Core::DocumentModel::editorsForDocuments( Utils::transform(files, [](Utils::FilePath &file) { return Core::DocumentModel::documentForFilePath(file.toString()); })); for (auto editor : editors) updateEditorToolBar(editor); } Client::~Client() { using namespace TextEditor; // FIXME: instead of replacing the completion provider in the text document store the // completion provider as a prioritised list in the text document for (TextDocument *document : m_resetAssistProvider.keys()) { if (document->completionAssistProvider() == &m_completionProvider) document->setCompletionAssistProvider(m_resetAssistProvider[document]); document->setFunctionHintAssistProvider(nullptr); document->setQuickFixAssistProvider(nullptr); } for (Core::IEditor * editor : Core::DocumentModel::editorsForOpenedDocuments()) { if (auto textEditor = qobject_cast(editor)) { TextEditorWidget *widget = textEditor->editorWidget(); widget->setRefactorMarkers(RefactorMarker::filterOutType(widget->refactorMarkers(), id())); widget->removeHoverHandler(&m_hoverHandler); } } for (const DocumentUri &uri : m_diagnostics.keys()) removeDiagnostics(uri); for (const DocumentUri &uri : m_highlights.keys()) { if (TextDocument *doc = TextDocument::textDocumentForFileName(uri.toFileName())) { if (TextEditor::SyntaxHighlighter *highlighter = doc->syntaxHighlighter()) highlighter->clearAllExtraFormats(); } } updateEditorToolBar(m_openedDocument.keys()); } static ClientCapabilities generateClientCapabilities() { ClientCapabilities capabilities; WorkspaceClientCapabilities workspaceCapabilities; workspaceCapabilities.setWorkspaceFolders(true); workspaceCapabilities.setApplyEdit(true); DynamicRegistrationCapabilities allowDynamicRegistration; allowDynamicRegistration.setDynamicRegistration(true); workspaceCapabilities.setDidChangeConfiguration(allowDynamicRegistration); workspaceCapabilities.setExecuteCommand(allowDynamicRegistration); capabilities.setWorkspace(workspaceCapabilities); TextDocumentClientCapabilities documentCapabilities; TextDocumentClientCapabilities::SynchronizationCapabilities syncCapabilities; syncCapabilities.setDynamicRegistration(true); syncCapabilities.setWillSave(true); syncCapabilities.setWillSaveWaitUntil(false); syncCapabilities.setDidSave(true); documentCapabilities.setSynchronization(syncCapabilities); SymbolCapabilities symbolCapabilities; SymbolCapabilities::SymbolKindCapabilities symbolKindCapabilities; symbolKindCapabilities.setValueSet( {SymbolKind::File, SymbolKind::Module, SymbolKind::Namespace, SymbolKind::Package, SymbolKind::Class, SymbolKind::Method, SymbolKind::Property, SymbolKind::Field, SymbolKind::Constructor, SymbolKind::Enum, SymbolKind::Interface, SymbolKind::Function, SymbolKind::Variable, SymbolKind::Constant, SymbolKind::String, SymbolKind::Number, SymbolKind::Boolean, SymbolKind::Array, SymbolKind::Object, SymbolKind::Key, SymbolKind::Null, SymbolKind::EnumMember, SymbolKind::Struct, SymbolKind::Event, SymbolKind::Operator, SymbolKind::TypeParameter}); symbolCapabilities.setSymbolKind(symbolKindCapabilities); documentCapabilities.setDocumentSymbol(symbolCapabilities); TextDocumentClientCapabilities::SemanticHighlightingCapabilities semanticHighlight; semanticHighlight.setSemanticHighlighting(true); documentCapabilities.setSemanticHighlightingCapabilities(semanticHighlight); TextDocumentClientCapabilities::CompletionCapabilities completionCapabilities; completionCapabilities.setDynamicRegistration(true); TextDocumentClientCapabilities::CompletionCapabilities::CompletionItemKindCapabilities completionItemKindCapabilities; completionItemKindCapabilities.setValueSet( {CompletionItemKind::Text, CompletionItemKind::Method, CompletionItemKind::Function, CompletionItemKind::Constructor, CompletionItemKind::Field, CompletionItemKind::Variable, CompletionItemKind::Class, CompletionItemKind::Interface, CompletionItemKind::Module, CompletionItemKind::Property, CompletionItemKind::Unit, CompletionItemKind::Value, CompletionItemKind::Enum, CompletionItemKind::Keyword, CompletionItemKind::Snippet, CompletionItemKind::Color, CompletionItemKind::File, CompletionItemKind::Reference, CompletionItemKind::Folder, CompletionItemKind::EnumMember, CompletionItemKind::Constant, CompletionItemKind::Struct, CompletionItemKind::Event, CompletionItemKind::Operator, CompletionItemKind::TypeParameter}); completionCapabilities.setCompletionItemKind(completionItemKindCapabilities); TextDocumentClientCapabilities::CompletionCapabilities::CompletionItemCapbilities completionItemCapbilities; completionItemCapbilities.setSnippetSupport(false); completionItemCapbilities.setCommitCharacterSupport(true); completionCapabilities.setCompletionItem(completionItemCapbilities); documentCapabilities.setCompletion(completionCapabilities); TextDocumentClientCapabilities::CodeActionCapabilities codeActionCapabilities; TextDocumentClientCapabilities::CodeActionCapabilities::CodeActionLiteralSupport literalSupport; literalSupport.setCodeActionKind( TextDocumentClientCapabilities::CodeActionCapabilities::CodeActionLiteralSupport:: CodeActionKind(QList{"*"})); codeActionCapabilities.setCodeActionLiteralSupport(literalSupport); documentCapabilities.setCodeAction(codeActionCapabilities); TextDocumentClientCapabilities::HoverCapabilities hover; hover.setContentFormat({MarkupKind::plaintext}); hover.setDynamicRegistration(true); documentCapabilities.setHover(hover); documentCapabilities.setReferences(allowDynamicRegistration); documentCapabilities.setDocumentHighlight(allowDynamicRegistration); documentCapabilities.setDefinition(allowDynamicRegistration); documentCapabilities.setTypeDefinition(allowDynamicRegistration); documentCapabilities.setImplementation(allowDynamicRegistration); capabilities.setTextDocument(documentCapabilities); return capabilities; } void Client::initialize() { using namespace ProjectExplorer; QTC_ASSERT(m_clientInterface, return); QTC_ASSERT(m_state == Uninitialized, return); qCDebug(LOGLSPCLIENT) << "initializing language server " << m_displayName; auto initRequest = new InitializeRequest(); auto params = initRequest->params().value_or(InitializeParams()); params.setCapabilities(generateClientCapabilities()); if (m_project) { params.setRootUri(DocumentUri::fromFileName(m_project->projectDirectory())); params.setWorkSpaceFolders(Utils::transform(SessionManager::projects(), [](Project *pro){ return WorkSpaceFolder(pro->projectDirectory().toString(), pro->displayName()); })); } initRequest->setParams(params); initRequest->setResponseCallback([this](const InitializeRequest::Response &initResponse){ intializeCallback(initResponse); }); // directly send data otherwise the state check would fail; initRequest->registerResponseHandler(&m_responseHandlers); m_clientInterface->sendMessage(initRequest->toBaseMessage()); m_state = InitializeRequested; } void Client::shutdown() { QTC_ASSERT(m_state == Initialized, emit finished(); return); qCDebug(LOGLSPCLIENT) << "shutdown language server " << m_displayName; ShutdownRequest shutdown; shutdown.setResponseCallback([this](const ShutdownRequest::Response &shutdownResponse){ shutDownCallback(shutdownResponse); }); sendContent(shutdown); m_state = ShutdownRequested; } Client::State Client::state() const { return m_state; } bool Client::openDocument(Core::IDocument *document) { using namespace TextEditor; if (!isSupportedDocument(document)) return false; const FilePath &filePath = document->filePath(); const QString method(DidOpenTextDocumentNotification::methodName); if (Utils::optional registered = m_dynamicCapabilities.isRegistered(method)) { if (!registered.value()) return false; const TextDocumentRegistrationOptions option( m_dynamicCapabilities.option(method).toObject()); if (option.isValid(nullptr) && !option.filterApplies(filePath, Utils::mimeTypeForName(document->mimeType()))) { return false; } } else if (Utils::optional _sync = m_serverCapabilities.textDocumentSync()) { if (auto options = Utils::get_if(&_sync.value())) { if (!options->openClose().value_or(true)) return false; } } auto uri = DocumentUri::fromFileName(filePath); showDiagnostics(uri); auto textDocument = qobject_cast(document); TextDocumentItem item; item.setLanguageId(TextDocumentItem::mimeTypeToLanguageId(document->mimeType())); item.setUri(uri); item.setText(QString::fromUtf8(document->contents())); item.setVersion(textDocument ? textDocument->document()->revision() : 0); if (textDocument) { connect(textDocument, &TextEditor::TextDocument::contentsChangedWithPosition, this, [this, textDocument](int position, int charsRemoved, int charsAdded) { documentContentsChanged(textDocument, position, charsRemoved, charsAdded); }); auto *oldCompletionProvider = qobject_cast( textDocument->completionAssistProvider()); if (oldCompletionProvider || !textDocument->completionAssistProvider()) { // only replace the completion assist provider if it is the default one or null m_completionProvider.setTriggerCharacters( m_serverCapabilities.completionProvider() .value_or(ServerCapabilities::CompletionOptions()) .triggerCharacters() .value_or(QList())); textDocument->setCompletionAssistProvider(&m_completionProvider); } m_resetAssistProvider[textDocument] = oldCompletionProvider; m_functionHintProvider.setTriggerCharacters( m_serverCapabilities.signatureHelpProvider() .value_or(ServerCapabilities::SignatureHelpOptions()) .triggerCharacters() .value_or(QList())); textDocument->setCompletionAssistProvider(&m_completionProvider); textDocument->setFunctionHintAssistProvider(&m_functionHintProvider); textDocument->setQuickFixAssistProvider(&m_quickFixProvider); connect(textDocument, &QObject::destroyed, this, [this, textDocument]{ m_resetAssistProvider.remove(textDocument); }); m_openedDocument.insert(document->filePath(), textDocument->plainText()); } else { m_openedDocument.insert(document->filePath(), QString()); } sendContent(DidOpenTextDocumentNotification(DidOpenTextDocumentParams(item))); if (textDocument) requestDocumentSymbols(textDocument); return true; } void Client::sendContent(const IContent &content) { QTC_ASSERT(m_clientInterface, return); QTC_ASSERT(m_state == Initialized, return); content.registerResponseHandler(&m_responseHandlers); QString error; if (!QTC_GUARD(content.isValid(&error))) Core::MessageManager::write(error); m_clientInterface->sendMessage(content.toBaseMessage()); } void Client::sendContent(const DocumentUri &uri, const IContent &content) { if (!m_openedDocument.contains(uri.toFileName())) return; sendContent(content); } void Client::cancelRequest(const MessageId &id) { m_responseHandlers.remove(id); sendContent(CancelRequest(CancelParameter(id))); } void Client::closeDocument(const DidCloseTextDocumentParams ¶ms) { const DocumentUri &uri = params.textDocument().uri(); m_highlights[uri].clear(); sendContent(uri, DidCloseTextDocumentNotification(params)); } bool Client::documentOpen(const Core::IDocument *document) const { return m_openedDocument.contains(document->filePath()); } void Client::documentContentsSaved(Core::IDocument *document) { if (!m_openedDocument.contains(document->filePath())) return; bool sendMessage = true; bool includeText = false; const QString method(DidSaveTextDocumentNotification::methodName); if (Utils::optional registered = m_dynamicCapabilities.isRegistered(method)) { sendMessage = registered.value(); if (sendMessage) { const TextDocumentSaveRegistrationOptions option( m_dynamicCapabilities.option(method).toObject()); if (option.isValid(nullptr)) { sendMessage = option.filterApplies(document->filePath(), Utils::mimeTypeForName(document->mimeType())); includeText = option.includeText().value_or(includeText); } } } else if (Utils::optional _sync = m_serverCapabilities.textDocumentSync()) { if (auto options = Utils::get_if(&_sync.value())) { if (Utils::optional saveOptions = options->save()) includeText = saveOptions.value().includeText().value_or(includeText); } } if (!sendMessage) return; DidSaveTextDocumentParams params( TextDocumentIdentifier(DocumentUri::fromFileName(document->filePath()))); if (includeText) params.setText(QString::fromUtf8(document->contents())); sendContent(DidSaveTextDocumentNotification(params)); } void Client::documentWillSave(Core::IDocument *document) { const FilePath &filePath = document->filePath(); if (!m_openedDocument.contains(filePath)) return; bool sendMessage = true; const QString method(WillSaveTextDocumentNotification::methodName); if (Utils::optional registered = m_dynamicCapabilities.isRegistered(method)) { sendMessage = registered.value(); if (sendMessage) { const TextDocumentRegistrationOptions option(m_dynamicCapabilities.option(method)); if (option.isValid(nullptr)) { sendMessage = option.filterApplies(filePath, Utils::mimeTypeForName(document->mimeType())); } } } else if (Utils::optional _sync = m_serverCapabilities.textDocumentSync()) { if (auto options = Utils::get_if(&_sync.value())) sendMessage = options->willSave().value_or(sendMessage); } if (!sendMessage) return; const WillSaveTextDocumentParams params( TextDocumentIdentifier(DocumentUri::fromFileName(document->filePath()))); sendContent(WillSaveTextDocumentNotification(params)); } void Client::documentContentsChanged(TextEditor::TextDocument *document, int position, int charsRemoved, int charsAdded) { if (!m_openedDocument.contains(document->filePath())) return; const QString method(DidChangeTextDocumentNotification::methodName); TextDocumentSyncKind syncKind = m_serverCapabilities.textDocumentSyncKindHelper(); if (Utils::optional registered = m_dynamicCapabilities.isRegistered(method)) { syncKind = registered.value() ? TextDocumentSyncKind::None : TextDocumentSyncKind::Full; if (syncKind != TextDocumentSyncKind::None) { const TextDocumentChangeRegistrationOptions option( m_dynamicCapabilities.option(method).toObject()); syncKind = option.isValid(nullptr) ? option.syncKind() : syncKind; } } auto textDocument = qobject_cast(document); const auto uri = DocumentUri::fromFileName(document->filePath()); m_highlights[uri].clear(); if (syncKind != TextDocumentSyncKind::None) { VersionedTextDocumentIdentifier docId(uri); docId.setVersion(textDocument ? textDocument->document()->revision() : 0); DidChangeTextDocumentParams params; params.setTextDocument(docId); if (syncKind == TextDocumentSyncKind::Incremental) { DidChangeTextDocumentParams::TextDocumentContentChangeEvent change; QTextDocument oldDoc(m_openedDocument[document->filePath()]); QTextCursor cursor(&oldDoc); cursor.setPosition(position + charsRemoved); cursor.setPosition(position, QTextCursor::KeepAnchor); change.setRange(Range(cursor)); change.setRangeLength(cursor.selectionEnd() - cursor.selectionStart()); change.setText(document->textAt(position, charsAdded)); params.setContentChanges({change}); } else { params.setContentChanges({document->plainText()}); } m_openedDocument[document->filePath()] = document->plainText(); sendContent(DidChangeTextDocumentNotification(params)); } if (textDocument) { using namespace TextEditor; for (BaseTextEditor *editor : BaseTextEditor::textEditorsForDocument(textDocument)) if (TextEditorWidget *widget = editor->editorWidget()) widget->setRefactorMarkers(RefactorMarker::filterOutType(widget->refactorMarkers(), id())); requestDocumentSymbols(textDocument); } } void Client::registerCapabilities(const QList ®istrations) { m_dynamicCapabilities.registerCapability(registrations); } void Client::unregisterCapabilities(const QList &unregistrations) { m_dynamicCapabilities.unregisterCapability(unregistrations); } template static bool sendTextDocumentPositionParamsRequest(Client *client, const Request &request, const DynamicCapabilities &dynamicCapabilities, const optional &serverCapability) { if (!request.isValid(nullptr)) return false; const DocumentUri uri = request.params().value().textDocument().uri(); const bool supportedFile = client->isSupportedUri(uri); bool sendMessage = dynamicCapabilities.isRegistered(Request::methodName).value_or(false); if (sendMessage) { const TextDocumentRegistrationOptions option(dynamicCapabilities.option(Request::methodName)); if (option.isValid(nullptr)) sendMessage = option.filterApplies(FilePath::fromString(QUrl(uri).adjusted(QUrl::PreferLocalFile).toString())); else sendMessage = supportedFile; } else { sendMessage = serverCapability.value_or(sendMessage) && supportedFile; } if (sendMessage) client->sendContent(request); return sendMessage; } bool Client::findLinkAt(GotoDefinitionRequest &request) { return LanguageClient::sendTextDocumentPositionParamsRequest( this, request, m_dynamicCapabilities, m_serverCapabilities.definitionProvider()); } bool Client::findUsages(FindReferencesRequest &request) { return LanguageClient::sendTextDocumentPositionParamsRequest( this, request, m_dynamicCapabilities, m_serverCapabilities.referencesProvider()); } TextEditor::HighlightingResult createHighlightingResult(const SymbolInformation &info) { if (!info.isValid(nullptr)) return {}; const Position &start = info.location().range().start(); return TextEditor::HighlightingResult(unsigned(start.line() + 1), unsigned(start.character() + 1), unsigned(info.name().length()), info.kind()); } void Client::requestDocumentSymbols(TextEditor::TextDocument *document) { // TODO: Do not use this information for highlighting but the overview model return; const FilePath &filePath = document->filePath(); bool sendMessage = m_dynamicCapabilities.isRegistered(DocumentSymbolsRequest::methodName).value_or(false); if (sendMessage) { const TextDocumentRegistrationOptions option(m_dynamicCapabilities.option(DocumentSymbolsRequest::methodName)); if (option.isValid(nullptr)) sendMessage = option.filterApplies(filePath, Utils::mimeTypeForName(document->mimeType())); } else { sendMessage = m_serverCapabilities.documentSymbolProvider().value_or(false); } if (!sendMessage) return; DocumentSymbolsRequest request( DocumentSymbolParams(TextDocumentIdentifier(DocumentUri::fromFileName(filePath)))); request.setResponseCallback( [doc = QPointer(document)] (DocumentSymbolsRequest::Response response){ if (!doc) return; const DocumentSymbolsResult result = response.result().value_or(DocumentSymbolsResult()); if (!holds_alternative>(result)) return; const auto &symbols = get>(result); QFutureInterface future; for (const SymbolInformation &symbol : symbols) future.reportResult(createHighlightingResult(symbol)); const TextEditor::FontSettings &fs = doc->fontSettings(); QHash formatMap; formatMap[static_cast(LanguageServerProtocol::SymbolKind::File )] = fs.toTextCharFormat(TextEditor::C_STRING); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Module )] = fs.toTextCharFormat(TextEditor::C_STRING); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Namespace )] = fs.toTextCharFormat(TextEditor::C_STRING); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Package )] = fs.toTextCharFormat(TextEditor::C_STRING); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Class )] = fs.toTextCharFormat(TextEditor::C_TYPE); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Method )] = fs.toTextCharFormat(TextEditor::C_FUNCTION); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Property )] = fs.toTextCharFormat(TextEditor::C_FIELD); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Field )] = fs.toTextCharFormat(TextEditor::C_FIELD); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Constructor )] = fs.toTextCharFormat(TextEditor::C_FUNCTION); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Enum )] = fs.toTextCharFormat(TextEditor::C_TYPE); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Interface )] = fs.toTextCharFormat(TextEditor::C_TYPE); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Function )] = fs.toTextCharFormat(TextEditor::C_FUNCTION); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Variable )] = fs.toTextCharFormat(TextEditor::C_LOCAL); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Constant )] = fs.toTextCharFormat(TextEditor::C_LOCAL); formatMap[static_cast(LanguageServerProtocol::SymbolKind::String )] = fs.toTextCharFormat(TextEditor::C_STRING); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Number )] = fs.toTextCharFormat(TextEditor::C_NUMBER); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Boolean )] = fs.toTextCharFormat(TextEditor::C_KEYWORD); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Array )] = fs.toTextCharFormat(TextEditor::C_STRING); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Object )] = fs.toTextCharFormat(TextEditor::C_LOCAL); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Key )] = fs.toTextCharFormat(TextEditor::C_LOCAL); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Null )] = fs.toTextCharFormat(TextEditor::C_KEYWORD); formatMap[static_cast(LanguageServerProtocol::SymbolKind::EnumMember )] = fs.toTextCharFormat(TextEditor::C_ENUMERATION); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Struct )] = fs.toTextCharFormat(TextEditor::C_TYPE); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Event )] = fs.toTextCharFormat(TextEditor::C_STRING); formatMap[static_cast(LanguageServerProtocol::SymbolKind::Operator )] = fs.toTextCharFormat(TextEditor::C_OPERATOR); formatMap[static_cast(LanguageServerProtocol::SymbolKind::TypeParameter)] = fs.toTextCharFormat(TextEditor::C_LOCAL); TextEditor::SemanticHighlighter::incrementalApplyExtraAdditionalFormats( doc->syntaxHighlighter(), future.future(), 0, future.resultCount() - 1, formatMap); }); sendContent(request); } void Client::cursorPositionChanged(TextEditor::TextEditorWidget *widget) { const auto uri = DocumentUri::fromFileName(widget->textDocument()->filePath()); if (m_dynamicCapabilities.isRegistered(DocumentHighlightsRequest::methodName).value_or(false)) { TextDocumentRegistrationOptions option( m_dynamicCapabilities.option(DocumentHighlightsRequest::methodName)); if (!option.filterApplies(widget->textDocument()->filePath())) return; } else if (!m_serverCapabilities.documentHighlightProvider().value_or(false)) { return; } auto runningRequest = m_highlightRequests.find(uri); if (runningRequest != m_highlightRequests.end()) cancelRequest(runningRequest.value()); DocumentHighlightsRequest request(TextDocumentPositionParams(uri, widget->textCursor())); request.setResponseCallback( [widget = QPointer(widget), this, uri] (DocumentHighlightsRequest::Response response) { m_highlightRequests.remove(uri); if (!widget) return; QList selections; const DocumentHighlightsResult result = response.result().value_or(DocumentHighlightsResult()); if (!holds_alternative>(result)) { widget->setExtraSelections(TextEditor::TextEditorWidget::CodeSemanticsSelection, selections); return; } const QTextCharFormat &format = widget->textDocument()->fontSettings().toTextCharFormat(TextEditor::C_OCCURRENCES); QTextDocument *document = widget->document(); for (const auto &highlight : get>(result)) { QTextEdit::ExtraSelection selection{widget->textCursor(), format}; const int &start = highlight.range().start().toPositionInDocument(document); const int &end = highlight.range().end().toPositionInDocument(document); if (start < 0 || end < 0) continue; selection.cursor.setPosition(start); selection.cursor.setPosition(end, QTextCursor::KeepAnchor); selections << selection; } widget->setExtraSelections(TextEditor::TextEditorWidget::CodeSemanticsSelection, selections); }); m_highlightRequests[uri] = request.id(); sendContent(request); } void Client::requestCodeActions(const DocumentUri &uri, const QList &diagnostics) { const Utils::FilePath fileName = uri.toFileName(); TextEditor::TextDocument *doc = TextEditor::TextDocument::textDocumentForFileName(fileName); if (!doc) return; CodeActionParams codeActionParams; CodeActionParams::CodeActionContext context; context.setDiagnostics(diagnostics); codeActionParams.setContext(context); codeActionParams.setTextDocument(uri); Position start(0, 0); const QTextBlock &lastBlock = doc->document()->lastBlock(); Position end(lastBlock.blockNumber(), lastBlock.length() - 1); codeActionParams.setRange(Range(start, end)); CodeActionRequest request(codeActionParams); request.setResponseCallback( [uri, self = QPointer(this)](const CodeActionRequest::Response &response) { if (self) self->handleCodeActionResponse(response, uri); }); requestCodeActions(request); } void Client::requestCodeActions(const CodeActionRequest &request) { if (!request.isValid(nullptr)) return; const Utils::FilePath fileName = request.params().value_or(CodeActionParams()).textDocument().uri().toFileName(); const QString method(CodeActionRequest::methodName); if (Utils::optional registered = m_dynamicCapabilities.isRegistered(method)) { if (!registered.value()) return; const TextDocumentRegistrationOptions option( m_dynamicCapabilities.option(method).toObject()); if (option.isValid(nullptr) && !option.filterApplies(fileName)) return; } else { Utils::variant provider = m_serverCapabilities.codeActionProvider().value_or(false); if (!(Utils::holds_alternative(provider) || Utils::get(provider))) return; } sendContent(request); } void Client::handleCodeActionResponse(const CodeActionRequest::Response &response, const DocumentUri &uri) { if (const Utils::optional &error = response.error()) log(*error); if (const Utils::optional &_result = response.result()) { const CodeActionResult &result = _result.value(); if (auto list = Utils::get_if>>(&result)) { for (const Utils::variant &item : *list) { if (auto action = Utils::get_if(&item)) updateCodeActionRefactoringMarker(this, *action, uri); else if (auto command = Utils::get_if(&item)) { Q_UNUSED(command) // todo } } } } } void Client::executeCommand(const Command &command) { using CommandOptions = LanguageServerProtocol::ServerCapabilities::ExecuteCommandOptions; const QString method(ExecuteCommandRequest::methodName); if (Utils::optional registered = m_dynamicCapabilities.isRegistered(method)) { if (!registered.value()) return; const CommandOptions option(m_dynamicCapabilities.option(method).toObject()); if (option.isValid(nullptr) && !option.commands().isEmpty() && !option.commands().contains(command.command())) return; } else if (Utils::optional option = m_serverCapabilities.executeCommandProvider()) { if (option->isValid(nullptr) && !option->commands().isEmpty() && !option->commands().contains(command.command())) return; } else { return; } const ExecuteCommandRequest request((ExecuteCommandParams(command))); sendContent(request); } const ProjectExplorer::Project *Client::project() const { return m_project; } void Client::setCurrentProject(ProjectExplorer::Project *project) { m_project = project; } void Client::projectOpened(ProjectExplorer::Project *project) { if (!sendWorkspceFolderChanges()) return; WorkspaceFoldersChangeEvent event; event.setAdded({WorkSpaceFolder(project->projectDirectory().toString(), project->displayName())}); DidChangeWorkspaceFoldersParams params; params.setEvent(event); DidChangeWorkspaceFoldersNotification change(params); sendContent(change); } void Client::projectClosed(ProjectExplorer::Project *project) { if (project == m_project) { if (m_state == Initialized) { shutdown(); } else { m_state = Shutdown; // otherwise the manager would try to restart this server emit finished(); } } if (!sendWorkspceFolderChanges()) return; WorkspaceFoldersChangeEvent event; event.setRemoved( {WorkSpaceFolder(project->projectDirectory().toString(), project->displayName())}); DidChangeWorkspaceFoldersParams params; params.setEvent(event); DidChangeWorkspaceFoldersNotification change(params); sendContent(change); } void Client::setSupportedLanguage(const LanguageFilter &filter) { m_languagFilter = filter; } bool Client::isSupportedDocument(const Core::IDocument *document) const { QTC_ASSERT(document, return false); return m_languagFilter.isSupported(document); } bool Client::isSupportedFile(const Utils::FilePath &filePath, const QString &mimeType) const { return m_languagFilter.isSupported(filePath, mimeType); } bool Client::isSupportedUri(const DocumentUri &uri) const { return m_languagFilter.isSupported(uri.toFileName(), Utils::mimeTypeForFile(uri.toFileName().fileName()).name()); } bool Client::needsRestart(const BaseSettings *settings) const { QTC_ASSERT(settings, return false); return m_languagFilter.mimeTypes != settings->m_languageFilter.mimeTypes || m_languagFilter.filePattern != settings->m_languageFilter.filePattern; } QList Client::diagnosticsAt(const DocumentUri &uri, const Range &range) const { QList diagnostics; for (const TextMark *mark : m_diagnostics[uri]) { const Diagnostic diagnostic = mark->diagnostic(); if (diagnostic.range().overlaps(range)) diagnostics << diagnostic; } return diagnostics; } bool Client::start() { return m_clientInterface->start(); } bool Client::reset() { if (!m_restartsLeft) return false; --m_restartsLeft; m_state = Uninitialized; m_responseHandlers.clear(); m_clientInterface->resetBuffer(); updateEditorToolBar(m_openedDocument.keys()); m_openedDocument.clear(); m_serverCapabilities = ServerCapabilities(); m_dynamicCapabilities.reset(); m_project = nullptr; for (const DocumentUri &uri : m_diagnostics.keys()) removeDiagnostics(uri); return true; } void Client::setError(const QString &message) { log(message); m_state = Error; } void Client::handleMessage(const BaseMessage &message) { if (auto handler = m_contentHandler[message.mimeType]) { QString parseError; handler(message.content, message.codec, parseError, [this](MessageId id, const QByteArray &content, QTextCodec *codec){ this->handleResponse(id, content, codec); }, [this](const QString &method, MessageId id, const IContent *content){ this->handleMethod(method, id, content); }); if (!parseError.isEmpty()) log(parseError); } else { log(tr("Cannot handle content of type: %1").arg(QLatin1String(message.mimeType))); } } void Client::log(const QString &message, Core::MessageManager::PrintToOutputPaneFlag flag) { Core::MessageManager::write(QString("LanguageClient %1: %2").arg(name(), message), flag); } const ServerCapabilities &Client::capabilities() const { return m_serverCapabilities; } const DynamicCapabilities &Client::dynamicCapabilities() const { return m_dynamicCapabilities; } const BaseClientInterface *Client::clientInterface() const { return m_clientInterface.data(); } DocumentSymbolCache *Client::documentSymbolCache() { return &m_documentSymbolCache; } HoverHandler *Client::hoverHandler() { return &m_hoverHandler; } void Client::log(const ShowMessageParams &message, Core::MessageManager::PrintToOutputPaneFlag flag) { log(message.toString(), flag); } void Client::showMessageBox(const ShowMessageRequestParams &message, const MessageId &id) { auto box = new QMessageBox(); box->setText(message.toString()); box->setAttribute(Qt::WA_DeleteOnClose); switch (message.type()) { case Error: box->setIcon(QMessageBox::Critical); break; case Warning: box->setIcon(QMessageBox::Warning); break; case Info: box->setIcon(QMessageBox::Information); break; case Log: box->setIcon(QMessageBox::NoIcon); break; } QHash itemForButton; if (const Utils::optional> actions = message.actions()) { for (const MessageActionItem &action : actions.value()) itemForButton.insert(box->addButton(action.title(), QMessageBox::InvalidRole), action); } box->setModal(true); connect(box, &QMessageBox::finished, this, [=]{ ShowMessageRequest::Response response(id); const MessageActionItem &item = itemForButton.value(box->clickedButton()); response.setResult(item.isValid(nullptr) ? LanguageClientValue(item) : LanguageClientValue()); sendContent(response); }); box->show(); } void Client::showDiagnostics(const DocumentUri &uri) { if (TextEditor::TextDocument *doc = TextEditor::TextDocument::textDocumentForFileName(uri.toFileName())) { for (TextMark *mark : m_diagnostics.value(uri)) doc->addMark(mark); } } void Client::removeDiagnostics(const DocumentUri &uri) { TextEditor::TextDocument *doc = TextEditor::TextDocument::textDocumentForFileName(uri.toFileName()); for (TextMark *mark : m_diagnostics.take(uri)) { if (doc) doc->removeMark(mark); delete mark; } } void Client::handleResponse(const MessageId &id, const QByteArray &content, QTextCodec *codec) { if (auto handler = m_responseHandlers[id]) handler(content, codec); } void Client::handleMethod(const QString &method, MessageId id, const IContent *content) { QStringList error; bool paramsValid = true; if (method == PublishDiagnosticsNotification::methodName) { auto params = dynamic_cast(content)->params().value_or(PublishDiagnosticsParams()); paramsValid = params.isValid(&error); if (paramsValid) handleDiagnostics(params); } else if (method == LogMessageNotification::methodName) { auto params = dynamic_cast(content)->params().value_or(LogMessageParams()); paramsValid = params.isValid(&error); if (paramsValid) log(params, Core::MessageManager::Flash); } else if (method == SemanticHighlightNotification::methodName) { auto params = dynamic_cast(content)->params().value_or(SemanticHighlightingParams()); paramsValid = params.isValid(&error); if (paramsValid) handleSemanticHighlight(params); } else if (method == ShowMessageNotification::methodName) { auto params = dynamic_cast(content)->params().value_or(ShowMessageParams()); paramsValid = params.isValid(&error); if (paramsValid) log(params); } else if (method == ShowMessageRequest::methodName) { auto request = dynamic_cast(content); auto params = request->params().value_or(ShowMessageRequestParams()); paramsValid = params.isValid(&error); if (paramsValid) { showMessageBox(params, request->id()); } else { ShowMessageRequest::Response response(request->id()); ResponseError error; const QString errorMessage = QString("Could not parse ShowMessageRequest parameter of '%1': \"%2\"") .arg(request->id().toString(), QString::fromUtf8(QJsonDocument(params).toJson())); error.setMessage(errorMessage); response.setError(error); sendContent(response); } } else if (method == RegisterCapabilityRequest::methodName) { auto params = dynamic_cast(content)->params().value_or(RegistrationParams()); paramsValid = params.isValid(&error); if (paramsValid) m_dynamicCapabilities.registerCapability(params.registrations()); } else if (method == UnregisterCapabilityRequest::methodName) { auto params = dynamic_cast(content)->params().value_or(UnregistrationParams()); paramsValid = params.isValid(&error); if (paramsValid) m_dynamicCapabilities.unregisterCapability(params.unregistrations()); } else if (method == ApplyWorkspaceEditRequest::methodName) { auto params = dynamic_cast(content)->params().value_or(ApplyWorkspaceEditParams()); paramsValid = params.isValid(&error); if (paramsValid) applyWorkspaceEdit(params.edit()); } else if (method == WorkSpaceFolderRequest::methodName) { WorkSpaceFolderRequest::Response response(dynamic_cast(content)->id()); const QList projects = ProjectExplorer::SessionManager::projects(); WorkSpaceFolderResult result; if (projects.isEmpty()) { result = nullptr; } else { result = Utils::transform(projects, [](ProjectExplorer::Project *project) { return WorkSpaceFolder(project->projectDirectory().toString(), project->displayName()); }); } response.setResult(result); sendContent(response); } else if (id.isValid(&error)) { Response response(id); ResponseError error; error.setCode(ResponseError::MethodNotFound); response.setError(error); sendContent(response); } std::reverse(error.begin(), error.end()); if (!paramsValid) { log(tr("Invalid parameter in \"%1\": %2").arg(method, error.join("->")), Core::MessageManager::Flash); } delete content; } void Client::handleDiagnostics(const PublishDiagnosticsParams ¶ms) { const DocumentUri &uri = params.uri(); removeDiagnostics(uri); const QList &diagnostics = params.diagnostics(); m_diagnostics[uri] = Utils::transform(diagnostics, [fileName = uri.toFileName()](const Diagnostic &diagnostic) { return new TextMark(fileName, diagnostic); }); showDiagnostics(uri); requestCodeActions(uri, diagnostics); } void Client::handleSemanticHighlight(const SemanticHighlightingParams ¶ms) { const DocumentUri &uri = params.textDocument().uri(); m_highlights[uri].clear(); const LanguageClientValue &version = params.textDocument().version(); TextEditor::TextDocument *doc = TextEditor::TextDocument::textDocumentForFileName( uri.toFileName()); if (!doc || (!version.isNull() && doc->document()->revision() != version.value())) return; const TextEditor::HighlightingResults results = SemanticHighligtingSupport::generateResults( params.lines()); m_highlights[uri] = results; SemanticHighligtingSupport::applyHighlight(doc, results, capabilities()); } void Client::rehighlight() { using namespace TextEditor; for (auto it = m_highlights.begin(), end = m_highlights.end(); it != end; ++it) { if (TextDocument *doc = TextDocument::textDocumentForFileName(it.key().toFileName())) SemanticHighligtingSupport::applyHighlight(doc, it.value(), capabilities()); } } void Client::intializeCallback(const InitializeRequest::Response &initResponse) { QTC_ASSERT(m_state == InitializeRequested, return); if (optional> error = initResponse.error()) { if (error.value().data().has_value() && error.value().data().value().retry().value_or(false)) { const QString title(tr("Language Server \"%1\" Initialize Error").arg(m_displayName)); auto result = QMessageBox::warning(Core::ICore::dialogParent(), title, error.value().message(), QMessageBox::Retry | QMessageBox::Cancel, QMessageBox::Retry); if (result == QMessageBox::Retry) { m_state = Uninitialized; initialize(); return; } } setError(tr("Initialize error: ") + error.value().message()); emit finished(); return; } const optional &_result = initResponse.result(); if (!_result.has_value()) {// continue on ill formed result log(tr("No initialize result.")); } else { const InitializeResult &result = _result.value(); QStringList error; if (!result.isValid(&error)) { // continue on ill formed result std::reverse(error.begin(), error.end()); log(tr("Initialize result is not valid: ") + error.join("->")); } m_serverCapabilities = result.capabilities().value_or(ServerCapabilities()); } qCDebug(LOGLSPCLIENT) << "language server " << m_displayName << " initialized"; m_state = Initialized; sendContent(InitializeNotification()); for (auto openedDocument : Core::DocumentModel::openedDocuments()) { if (openDocument(openedDocument)) { for (Core::IEditor *editor : Core::DocumentModel::editorsForDocument(openedDocument)) updateEditorToolBar(editor); } } for (Core::IEditor *editor : Core::DocumentModel::editorsForOpenedDocuments()) { if (auto textEditor = qobject_cast(editor)) textEditor->editorWidget()->addHoverHandler(&m_hoverHandler); } if (m_dynamicCapabilities.isRegistered(DocumentSymbolsRequest::methodName) .value_or(capabilities().documentSymbolProvider().value_or(false))) { TextEditor::IOutlineWidgetFactory::updateOutline(); } emit initialized(m_serverCapabilities); } void Client::shutDownCallback(const ShutdownRequest::Response &shutdownResponse) { QTC_ASSERT(m_state == ShutdownRequested, return); QTC_ASSERT(m_clientInterface, return); optional errorValue = shutdownResponse.error(); if (errorValue.has_value()) { ShutdownRequest::Response::Error error = errorValue.value(); qDebug() << error; return; } // directly send data otherwise the state check would fail; m_clientInterface->sendMessage(ExitNotification().toBaseMessage()); qCDebug(LOGLSPCLIENT) << "language server " << m_displayName << " shutdown"; m_state = Shutdown; } bool Client::sendWorkspceFolderChanges() const { if (m_dynamicCapabilities.isRegistered( DidChangeWorkspaceFoldersNotification::methodName).value_or(false)) { return true; } if (auto workspace = m_serverCapabilities.workspace()) { if (auto folder = workspace.value().workspaceFolders()) { if (folder.value().supported().value_or(false)) { // holds either the Id for deregistration or whether it is registered auto notification = folder.value().changeNotifications().value_or(false); return holds_alternative(notification) || (holds_alternative(notification) && get(notification)); } } } return false; } } // namespace LanguageClient