| Index: pkg/analyzer_plugin/lib/protocol/protocol.dart
|
| diff --git a/pkg/analyzer_plugin/lib/protocol/protocol.dart b/pkg/analyzer_plugin/lib/protocol/protocol.dart
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..4c2b705bd28696fe72ce8dd82cf19b924d242c57
|
| --- /dev/null
|
| +++ b/pkg/analyzer_plugin/lib/protocol/protocol.dart
|
| @@ -0,0 +1,583 @@
|
| +// Copyright (c) 2017, 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:collection';
|
| +
|
| +import 'package:analyzer_plugin/protocol/generated_protocol.dart';
|
| +import 'package:analyzer_plugin/src/protocol/protocol_internal.dart';
|
| +
|
| +/**
|
| + * An interface for enumerated types in the protocol.
|
| + *
|
| + * Clients may not extend, implement or mix-in this class.
|
| + */
|
| +abstract class Enum {
|
| + /**
|
| + * The name of the enumerated value. This should match the name of the static
|
| + * getter which provides access to this enumerated value.
|
| + */
|
| + String get name;
|
| +}
|
| +
|
| +/**
|
| + * A notification that can be sent to the server about an event that occurred.
|
| + *
|
| + * Clients may not extend, implement or mix-in this class.
|
| + */
|
| +class Notification {
|
| + /**
|
| + * The name of the JSON attribute containing the name of the event that
|
| + * triggered the notification.
|
| + */
|
| + static const String EVENT = 'event';
|
| +
|
| + /**
|
| + * The name of the JSON attribute containing the result values.
|
| + */
|
| + static const String PARAMS = 'params';
|
| +
|
| + /**
|
| + * The name of the event that triggered the notification.
|
| + */
|
| + final String event;
|
| +
|
| + /**
|
| + * A table mapping the names of notification parameters to their values, or
|
| + * `null` if there are no notification parameters.
|
| + */
|
| + Map<String, Object> params;
|
| +
|
| + /**
|
| + * Initialize a newly created [Notification] to have the given [event] name.
|
| + * If [params] is provided, it will be used as the params; otherwise no
|
| + * params will be used.
|
| + */
|
| + Notification(this.event, [this.params]);
|
| +
|
| + /**
|
| + * Initialize a newly created instance based on the given JSON data.
|
| + */
|
| + factory Notification.fromJson(Map json) {
|
| + return new Notification(json[Notification.EVENT],
|
| + json[Notification.PARAMS] as Map<String, Object>);
|
| + }
|
| +
|
| + /**
|
| + * Return a table representing the structure of the Json object that will be
|
| + * sent to the client to represent this response.
|
| + */
|
| + Map<String, Object> toJson() {
|
| + Map<String, Object> jsonObject = {};
|
| + jsonObject[EVENT] = event;
|
| + if (params != null) {
|
| + jsonObject[PARAMS] = params;
|
| + }
|
| + return jsonObject;
|
| + }
|
| +}
|
| +
|
| +/**
|
| + * A request that was received from the server.
|
| + *
|
| + * Clients may not extend, implement or mix-in this class.
|
| + */
|
| +class Request {
|
| + /**
|
| + * The name of the JSON attribute containing the id of the request.
|
| + */
|
| + static const String ID = 'id';
|
| +
|
| + /**
|
| + * The name of the JSON attribute containing the name of the request.
|
| + */
|
| + static const String METHOD = 'method';
|
| +
|
| + /**
|
| + * The name of the JSON attribute containing the request parameters.
|
| + */
|
| + static const String PARAMS = 'params';
|
| +
|
| + /**
|
| + * The name of the optional JSON attribute indicating the time (milliseconds
|
| + * since epoch) at which the server made the request.
|
| + */
|
| + static const String SERVER_REQUEST_TIME = 'serverRequestTime';
|
| +
|
| + /**
|
| + * The unique identifier used to identify this request.
|
| + */
|
| + final String id;
|
| +
|
| + /**
|
| + * The method being requested.
|
| + */
|
| + final String method;
|
| +
|
| + /**
|
| + * A table mapping the names of request parameters to their values.
|
| + */
|
| + final Map<String, Object> params;
|
| +
|
| + /**
|
| + * The time (milliseconds since epoch) at which the server made the request,
|
| + * or `null` if this information is not provided by the server.
|
| + */
|
| + final int serverRequestTime;
|
| +
|
| + /**
|
| + * Initialize a newly created [Request] to have the given [id] and [method]
|
| + * name. If [params] is supplied, it is used as the "params" map for the
|
| + * request. Otherwise an empty "params" map is allocated.
|
| + */
|
| + Request(this.id, this.method,
|
| + [Map<String, Object> params, this.serverRequestTime])
|
| + : params = params ?? <String, Object>{};
|
| +
|
| + /**
|
| + * Return a request parsed from the given json, or `null` if the [data] is
|
| + * not a valid json representation of a request. The [data] is expected to
|
| + * have the following format:
|
| + *
|
| + * {
|
| + * 'clientRequestTime': millisecondsSinceEpoch
|
| + * 'id': String,
|
| + * 'method': methodName,
|
| + * 'params': {
|
| + * paramter_name: value
|
| + * }
|
| + * }
|
| + *
|
| + * where both the parameters and clientRequestTime are optional.
|
| + *
|
| + * The parameters can contain any number of name/value pairs. The
|
| + * clientRequestTime must be an int representing the time at which the client
|
| + * issued the request (milliseconds since epoch).
|
| + */
|
| + factory Request.fromJson(Map<String, Object> result) {
|
| + var id = result[Request.ID];
|
| + var method = result[Request.METHOD];
|
| + if (id is! String || method is! String) {
|
| + return null;
|
| + }
|
| + var time = result[Request.SERVER_REQUEST_TIME];
|
| + if (time != null && time is! int) {
|
| + return null;
|
| + }
|
| + var params = result[Request.PARAMS];
|
| + if (params is Map || params == null) {
|
| + return new Request(id, method, params as Map<String, Object>, time);
|
| + } else {
|
| + return null;
|
| + }
|
| + }
|
| +
|
| + @override
|
| + int get hashCode {
|
| + return id.hashCode;
|
| + }
|
| +
|
| + @override
|
| + bool operator ==(Object other) {
|
| + return other is Request &&
|
| + id == other.id &&
|
| + method == other.method &&
|
| + serverRequestTime == other.serverRequestTime &&
|
| + _equalMaps(params, other.params);
|
| + }
|
| +
|
| + /**
|
| + * Return a table representing the structure of the Json object that will be
|
| + * sent to the server to represent this response.
|
| + */
|
| + Map<String, Object> toJson() {
|
| + Map<String, Object> jsonObject = {};
|
| + jsonObject[ID] = id;
|
| + jsonObject[METHOD] = method;
|
| + if (params.isNotEmpty) {
|
| + jsonObject[PARAMS] = params;
|
| + }
|
| + if (serverRequestTime != null) {
|
| + jsonObject[SERVER_REQUEST_TIME] = serverRequestTime;
|
| + }
|
| + return jsonObject;
|
| + }
|
| +
|
| + bool _equalLists(List first, List second) {
|
| + if (first == null) {
|
| + return second == null;
|
| + }
|
| + if (second == null) {
|
| + return false;
|
| + }
|
| + int length = first.length;
|
| + if (length != second.length) {
|
| + return false;
|
| + }
|
| + for (int i = 0; i < length; i++) {
|
| + if (!_equalObjects(first[i], second[i])) {
|
| + return false;
|
| + }
|
| + }
|
| + return true;
|
| + }
|
| +
|
| + bool _equalMaps(Map first, Map second) {
|
| + if (first == null) {
|
| + return second == null;
|
| + }
|
| + if (second == null) {
|
| + return false;
|
| + }
|
| + if (first.length != second.length) {
|
| + return false;
|
| + }
|
| + for (var key in first.keys) {
|
| + if (!second.containsKey(key)) {
|
| + return false;
|
| + }
|
| + if (!_equalObjects(first[key], second[key])) {
|
| + return false;
|
| + }
|
| + }
|
| + return true;
|
| + }
|
| +
|
| + bool _equalObjects(Object first, Object second) {
|
| + if (first == null) {
|
| + return second == null;
|
| + }
|
| + if (second == null) {
|
| + return false;
|
| + }
|
| + if (first is Map) {
|
| + if (second is Map) {
|
| + return _equalMaps(first, second);
|
| + }
|
| + return false;
|
| + }
|
| + if (first is List) {
|
| + if (second is List) {
|
| + return _equalLists(first, second);
|
| + }
|
| + return false;
|
| + }
|
| + return first == second;
|
| + }
|
| +}
|
| +
|
| +/**
|
| + * A collection of utility methods that create instances of the generated class
|
| + * [RequestError].
|
| + */
|
| +class RequestErrorFactory {
|
| +// /**
|
| +// * Initialize a newly created instance to represent the
|
| +// * GET_ERRORS_INVALID_FILE error condition.
|
| +// */
|
| +// Response.getErrorsInvalidFile(Request request)
|
| +// : this(request.id,
|
| +// error: new RequestError(RequestErrorCode.GET_ERRORS_INVALID_FILE,
|
| +// 'Error during `analysis.getErrors`: invalid file.'));
|
| +//
|
| +// /**
|
| +// * Initialize a newly created instance to represent the
|
| +// * GET_NAVIGATION_INVALID_FILE error condition.
|
| +// */
|
| +// Response.getNavigationInvalidFile(Request request)
|
| +// : this(request.id,
|
| +// error: new RequestError(
|
| +// RequestErrorCode.GET_NAVIGATION_INVALID_FILE,
|
| +// 'Error during `analysis.getNavigation`: invalid file.'));
|
| +//
|
| +// /**
|
| +// * Initialize a newly created instance to represent the
|
| +// * GET_REACHABLE_SOURCES_INVALID_FILE error condition.
|
| +// */
|
| +// Response.getReachableSourcesInvalidFile(Request request)
|
| +// : this(request.id,
|
| +// error: new RequestError(
|
| +// RequestErrorCode.GET_REACHABLE_SOURCES_INVALID_FILE,
|
| +// 'Error during `analysis.getReachableSources`: invalid file.'));
|
| +//
|
| +// /**
|
| +// * Initialize a newly created instance to represent an error condition caused
|
| +// * by an analysis.reanalyze [request] that specifies an analysis root that is
|
| +// * not in the current list of analysis roots.
|
| +// */
|
| +// Response.invalidAnalysisRoot(Request request, String rootPath)
|
| +// : this(request.id,
|
| +// error: new RequestError(RequestErrorCode.INVALID_ANALYSIS_ROOT,
|
| +// "Invalid analysis root: $rootPath"));
|
| +//
|
| +// /**
|
| +// * Initialize a newly created instance to represent an error condition caused
|
| +// * by a [request] that specifies an execution context whose context root does
|
| +// * not exist.
|
| +// */
|
| +// Response.invalidExecutionContext(Request request, String contextId)
|
| +// : this(request.id,
|
| +// error: new RequestError(RequestErrorCode.INVALID_EXECUTION_CONTEXT,
|
| +// "Invalid execution context: $contextId"));
|
| +//
|
| +// /**
|
| +// * Initialize a newly created instance to represent the
|
| +// * INVALID_FILE_PATH_FORMAT error condition.
|
| +// */
|
| +// Response.invalidFilePathFormat(Request request, path)
|
| +// : this(request.id,
|
| +// error: new RequestError(RequestErrorCode.INVALID_FILE_PATH_FORMAT,
|
| +// 'Invalid file path format: $path'));
|
| +
|
| + /**
|
| + * Return a request error representing an error condition caused by a
|
| + * [request] that had invalid parameter. [path] is the path to the
|
| + * invalid parameter, in Javascript notation (e.g. "foo.bar" means that the
|
| + * parameter "foo" contained a key "bar" whose value was the wrong type).
|
| + * [expectation] is a description of the type of data that was expected.
|
| + */
|
| + static RequestError invalidParameter(
|
| + Request request, String path, String expectation) =>
|
| + new RequestError(RequestErrorCode.INVALID_PARAMETER,
|
| + "Invalid parameter '$path'. $expectation.");
|
| +
|
| +// /**
|
| +// * Initialize a newly created instance to represent an error condition caused
|
| +// * by a malformed request.
|
| +// */
|
| +// Response.invalidRequestFormat()
|
| +// : this('',
|
| +// error: new RequestError(
|
| +// RequestErrorCode.INVALID_REQUEST, 'Invalid request'));
|
| +//
|
| +// /**
|
| +// * Initialize a newly created instance to represent an error condition caused
|
| +// * by a request that requires an index, but indexing is disabled.
|
| +// */
|
| +// Response.noIndexGenerated(Request request)
|
| +// : this(request.id,
|
| +// error: new RequestError(
|
| +// RequestErrorCode.NO_INDEX_GENERATED, 'Indexing is disabled'));
|
| +//
|
| +// /**
|
| +// * Initialize a newly created instance to represent the
|
| +// * ORGANIZE_DIRECTIVES_ERROR error condition.
|
| +// */
|
| +// Response.organizeDirectivesError(Request request, String message)
|
| +// : this(request.id,
|
| +// error: new RequestError(
|
| +// RequestErrorCode.ORGANIZE_DIRECTIVES_ERROR, message));
|
| +//
|
| +// /**
|
| +// * Initialize a newly created instance to represent the
|
| +// * REFACTORING_REQUEST_CANCELLED error condition.
|
| +// */
|
| +// Response.refactoringRequestCancelled(Request request)
|
| +// : this(request.id,
|
| +// error: new RequestError(
|
| +// RequestErrorCode.REFACTORING_REQUEST_CANCELLED,
|
| +// 'The `edit.getRefactoring` request was cancelled.'));
|
| +
|
| + /**
|
| + * Return a request error representing an error that occurred in the plugin.
|
| + */
|
| + static RequestError pluginError(Request request, exception, stackTrace) =>
|
| + new RequestError(RequestErrorCode.PLUGIN_ERROR, exception.toString(),
|
| + stackTrace: stackTrace);
|
| +
|
| +// /**
|
| +// * Initialize a newly created instance to represent the
|
| +// * SORT_MEMBERS_INVALID_FILE error condition.
|
| +// */
|
| +// Response.sortMembersInvalidFile(Request request)
|
| +// : this(request.id,
|
| +// error: new RequestError(RequestErrorCode.SORT_MEMBERS_INVALID_FILE,
|
| +// 'Error during `edit.sortMembers`: invalid file.'));
|
| +//
|
| +// /**
|
| +// * Initialize a newly created instance to represent the
|
| +// * SORT_MEMBERS_PARSE_ERRORS error condition.
|
| +// */
|
| +// Response.sortMembersParseErrors(Request request, int numErrors)
|
| +// : this(request.id,
|
| +// error: new RequestError(RequestErrorCode.SORT_MEMBERS_PARSE_ERRORS,
|
| +// 'Error during `edit.sortMembers`: file has $numErrors scan/parse errors.'));
|
| +//
|
| +// /**
|
| +// * Initialize a newly created instance to represent an error condition caused
|
| +// * by a `analysis.setPriorityFiles` [request] that includes one or more files
|
| +// * that are not being analyzed.
|
| +// */
|
| +// Response.unanalyzedPriorityFiles(String requestId, String fileNames)
|
| +// : this(requestId,
|
| +// error: new RequestError(RequestErrorCode.UNANALYZED_PRIORITY_FILES,
|
| +// "Unanalyzed files cannot be a priority: '$fileNames'"));
|
| +
|
| + /**
|
| + * Return a request error representing an error condition caused by a
|
| + * [request] that cannot be handled by any known handlers.
|
| + */
|
| + static RequestError unknownRequest(Request request) =>
|
| + new RequestError(RequestErrorCode.UNKNOWN_REQUEST, 'Unknown request');
|
| +
|
| +// /**
|
| +// * Initialize a newly created instance to represent an error condition caused
|
| +// * by a [request] referencing a source that does not exist.
|
| +// */
|
| +// Response.unknownSource(Request request)
|
| +// : this(request.id,
|
| +// error: new RequestError(
|
| +// RequestErrorCode.UNKNOWN_SOURCE, 'Unknown source'));
|
| +//
|
| +// /**
|
| +// * Initialize a newly created instance to represent an error condition caused
|
| +// * by a [request] for a service that is not supported.
|
| +// */
|
| +// Response.unsupportedFeature(String requestId, String message)
|
| +// : this(requestId,
|
| +// error: new RequestError(
|
| +// RequestErrorCode.UNSUPPORTED_FEATURE, message));
|
| +}
|
| +
|
| +/**
|
| + * An exception that occurred during the handling of a request that requires
|
| + * that an error be returned to the server.
|
| + *
|
| + * Clients may not extend, implement or mix-in this class.
|
| + */
|
| +class RequestFailure implements Exception {
|
| + /**
|
| + * A description of the error that was encountered.
|
| + */
|
| + final RequestError error;
|
| +
|
| + /**
|
| + * Initialize a newly created exception to return a response with the given
|
| + * [error].
|
| + */
|
| + RequestFailure(this.error);
|
| +}
|
| +
|
| +/**
|
| + * A response to the server.
|
| + *
|
| + * Clients may not extend, implement or mix-in this class.
|
| + */
|
| +class Response {
|
| + /**
|
| + * The [Response] instance that is returned when a real [Response] cannot
|
| + * be provided at the moment.
|
| + */
|
| + static final Response DELAYED_RESPONSE = new Response('DELAYED_RESPONSE');
|
| +
|
| + /**
|
| + * The name of the JSON attribute containing the id of the request for which
|
| + * this is a response.
|
| + */
|
| + static const String ID = 'id';
|
| +
|
| + /**
|
| + * The name of the JSON attribute containing the error message.
|
| + */
|
| + static const String ERROR = 'error';
|
| +
|
| + /**
|
| + * The name of the JSON attribute containing the result values.
|
| + */
|
| + static const String RESULT = 'result';
|
| +
|
| + /**
|
| + * The unique identifier used to identify the request that this response is
|
| + * associated with.
|
| + */
|
| + final String id;
|
| +
|
| + /**
|
| + * The error that was caused by attempting to handle the request, or `null` if
|
| + * there was no error.
|
| + */
|
| + final RequestError error;
|
| +
|
| + /**
|
| + * A table mapping the names of result fields to their values. Should be
|
| + * `null` if there is no result to send.
|
| + */
|
| + Map<String, Object> result;
|
| +
|
| + /**
|
| + * Initialize a newly created instance to represent a response to a request
|
| + * with the given [id]. If [_result] is provided, it will be used as the
|
| + * result; otherwise an empty result will be used. If an [error] is provided
|
| + * then the response will represent an error condition.
|
| + */
|
| + Response(this.id, {Map<String, Object> result, this.error}) : result = result;
|
| +
|
| +// /**
|
| +// * Initialize a newly created instance to represent the FILE_NOT_ANALYZED
|
| +// * error condition.
|
| +// */
|
| +// Response.fileNotAnalyzed(Request request, String file)
|
| +// : this(request.id,
|
| +// error: new RequestError(RequestErrorCode.FILE_NOT_ANALYZED,
|
| +// 'File is not analyzed: $file.'));
|
| +//
|
| +// /**
|
| +// * Initialize a newly created instance to represent the FORMAT_INVALID_FILE
|
| +// * error condition.
|
| +// */
|
| +// Response.formatInvalidFile(Request request)
|
| +// : this(request.id,
|
| +// error: new RequestError(RequestErrorCode.FORMAT_INVALID_FILE,
|
| +// 'Error during `edit.format`: invalid file.'));
|
| +//
|
| +// /**
|
| +// * Initialize a newly created instance to represent the FORMAT_WITH_ERROR
|
| +// * error condition.
|
| +// */
|
| +// Response.formatWithErrors(Request request)
|
| +// : this(request.id,
|
| +// error: new RequestError(RequestErrorCode.FORMAT_WITH_ERRORS,
|
| +// 'Error during `edit.format`: source contains syntax errors.'));
|
| +
|
| + /**
|
| + * Initialize a newly created instance based on the given JSON data.
|
| + */
|
| + factory Response.fromJson(Map json) {
|
| + try {
|
| + Object id = json[Response.ID];
|
| + if (id is! String) {
|
| + return null;
|
| + }
|
| + Object error = json[Response.ERROR];
|
| + RequestError decodedError;
|
| + if (error is Map) {
|
| + decodedError = new RequestError.fromJson(
|
| + new ResponseDecoder(null), '.error', error);
|
| + }
|
| + Object result = json[Response.RESULT];
|
| + Map<String, Object> decodedResult;
|
| + if (result is Map) {
|
| + decodedResult = result as Map<String, Object>;
|
| + }
|
| + return new Response(id, error: decodedError, result: decodedResult);
|
| + } catch (exception) {
|
| + return null;
|
| + }
|
| + }
|
| +
|
| + /**
|
| + * Return a table representing the structure of the Json object that will be
|
| + * sent to the client to represent this response.
|
| + */
|
| + Map<String, Object> toJson() {
|
| + Map<String, Object> jsonObject = new HashMap<String, Object>();
|
| + jsonObject[ID] = id;
|
| + if (error != null) {
|
| + jsonObject[ERROR] = error.toJson();
|
| + }
|
| + if (result != null) {
|
| + jsonObject[RESULT] = result;
|
| + }
|
| + return jsonObject;
|
| + }
|
| +}
|
|
|