blob: a86e7944f510457f9552b5efd2fc8bdac45f5415 [file] [log] [blame]
// Copyright (c) 2018, the Dart project authors. Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.
import 'dart:async';
import 'dart:convert';
import 'dart:io';
import 'package:analysis_server/lsp_protocol/protocol_generated.dart';
import 'package:analysis_server/lsp_protocol/protocol_special.dart';
import 'package:analysis_server/src/lsp/channel/lsp_channel.dart';
import 'package:analysis_server/src/lsp/json_parsing.dart';
import 'package:analysis_server/src/lsp/lsp_packet_transformer.dart';
import 'package:analyzer/instrumentation/instrumentation.dart';
/// Instances of the class [LspByteStreamServerChannel] implement an
/// [LspServerCommunicationChannel] that uses a stream and a sink (typically,
/// standard input and standard output) to communicate with clients.
class LspByteStreamServerChannel implements LspServerCommunicationChannel {
final Stream _input;
final IOSink _output;
final InstrumentationService _instrumentationService;
/// Completer that will be signalled when the input stream is closed.
final Completer _closed = Completer();
/// True if [close] has been called.
bool _closeRequested = false;
this._input, this._output, this._instrumentationService);
/// Future that will be completed when the input stream is closed.
Future get closed {
return _closed.future;
void close() {
if (!_closeRequested) {
_closeRequested = true;
void listen(void Function(Message message) onMessage,
{Function? onError, void Function()? onDone}) {
(String data) => _readMessage(data, onMessage),
onError: onError,
onDone: () {
if (onDone != null) {
void sendNotification(NotificationMessage notification) =>
void sendRequest(RequestMessage request) => _sendLsp(request.toJson());
void sendResponse(ResponseMessage response) => _sendLsp(response.toJson());
/// Read a request from the given [data] and use the given function to handle
/// the message.
void _readMessage(String data, void Function(Message request) onMessage) {
// Ignore any further requests after the communication channel is closed.
if (_closed.isCompleted) {
final json = jsonDecode(data) as Map<String, Object?>;
if (RequestMessage.canParse(json, nullLspJsonReporter)) {
} else if (NotificationMessage.canParse(json, nullLspJsonReporter)) {
} else if (ResponseMessage.canParse(json, nullLspJsonReporter)) {
} else {
/// Sends a message prefixed with the required LSP headers.
void _sendLsp(Map<String, dynamic> json) {
// Don't send any further responses after the communication channel is
// closed.
if (_closeRequested) {
final jsonEncodedBody = jsonEncode(json);
final utf8EncodedBody = utf8.encode(jsonEncodedBody);
final header = 'Content-Length: ${utf8EncodedBody.length}\r\n'
'Content-Type: application/vscode-jsonrpc; charset=utf-8\r\n\r\n';
final asciiEncodedHeader = ascii.encode(header);
// Header is always ascii, body is always utf8!
void _sendParseError() {
final error = ResponseMessage(
error: ResponseError(
code: ErrorCodes.ParseError, message: 'Unable to parse message'),
jsonrpc: jsonRpcVersion);
/// Send [bytes] to [_output].
void _write(List<int> bytes) {
() => _output.add(bytes),
(e, s) => close(),