Generate constants in server as we do in plugin

pkg/analysis_server/benchmark/integration/input_converter.dart

 // Copyright (c) 2015, 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/protocol/protocol.dart';
+import 'package:analysis_server/protocol/protocol_constants.dart';
 import 'package:analysis_server/protocol/protocol_generated.dart';
-import 'package:analysis_server/src/constants.dart';
 import 'package:analyzer_plugin/protocol/protocol_common.dart';
 import 'package:logging/logging.dart';
 import 'package:path/path.dart' as path;
 
 import 'instrumentation_input_converter.dart';
 import 'log_file_input_converter.dart';
 import 'operation.dart';
 
 /**
  * Common input converter superclass for sharing implementation.
@@ skipping 50 matching lines @@
 
   CommonInputConverter(this.tmpSrcDirPath, this.srcPathMap);
 
   Map<String, dynamic> asMap(dynamic value) => value as Map<String, dynamic>;
 
   /**
    * Return an operation for the notification or `null` if none.
    */
   Operation convertNotification(Map<String, dynamic> json) {
     String event = json['event'];
-    if (event == SERVER_STATUS) {
+    if (event == SERVER_NOTIFICATION_STATUS) {
       // {"event":"server.status","params":{"analysis":{"isAnalyzing":false}}}
       Map<String, dynamic> params = asMap(json['params']);
       if (params != null) {
         Map<String, dynamic> analysis = asMap(params['analysis']);
         if (analysis != null && analysis['isAnalyzing'] == false) {
           return new WaitForAnalysisCompleteOperation();
         }
       }
     }
-    if (event == SERVER_CONNECTED) {
+    if (event == SERVER_NOTIFICATION_CONNECTED) {
       // {"event":"server.connected","params":{"version":"1.7.0"}}
       return new StartServerOperation();
     }
     if (eventsSeen.add(event)) {
       logger.log(Level.INFO, 'Ignored notification: $event\n  $json');
     }
     return null;
   }
 
   /**
    * Return an operation for the request or `null` if none.
    */
   Operation convertRequest(Map<String, dynamic> origJson) {
     Map<String, dynamic> json = asMap(translateSrcPaths(origJson));
     requestMap[json['id']] = json;
     String method = json['method'];
     // Sanity check operations that modify source
     // to ensure that the operation is on source in temp space
-    if (method == ANALYSIS_UPDATE_CONTENT) {
+    if (method == ANALYSIS_REQUEST_UPDATE_CONTENT) {
       // Track overlays in parallel with the analysis server
       // so that when an overlay is removed, the file can be updated on disk
       Request request = new Request.fromJson(json);
       var params = new AnalysisUpdateContentParams.fromRequest(request);
       params.files.forEach((String filePath, change) {
         if (change is AddContentOverlay) {
           String content = change.content;
           if (content == null) {
             throw 'expected new overlay content\n$json';
           }
@@ skipping 13 matching lines @@
             throw 'found path referencing source outside temp space\n$filePath\n$json';
           }
           new File(filePath).writeAsStringSync(content);
         } else {
           throw 'unknown overlay change $change\n$json';
         }
       });
       return new RequestOperation(this, json);
     }
     // Track performance for completion notifications
-    if (method == COMPLETION_GET_SUGGESTIONS) {
+    if (method == COMPLETION_REQUEST_GET_SUGGESTIONS) {
       return new CompletionRequestOperation(this, json);
     }
     // TODO(danrubel) replace this with code
     // that just forwards the translated request
-    if (method == ANALYSIS_GET_HOVER ||
-        method == ANALYSIS_SET_ANALYSIS_ROOTS ||
-        method == ANALYSIS_SET_PRIORITY_FILES ||
-        method == ANALYSIS_SET_SUBSCRIPTIONS ||
-        method == ANALYSIS_UPDATE_OPTIONS ||
-        method == EDIT_GET_ASSISTS ||
-        method == EDIT_GET_AVAILABLE_REFACTORINGS ||
-        method == EDIT_GET_FIXES ||
-        method == EDIT_GET_REFACTORING ||
-        method == EDIT_SORT_MEMBERS ||
-        method == EXECUTION_CREATE_CONTEXT ||
-        method == EXECUTION_DELETE_CONTEXT ||
-        method == EXECUTION_MAP_URI ||
-        method == EXECUTION_SET_SUBSCRIPTIONS ||
-        method == SEARCH_FIND_ELEMENT_REFERENCES ||
-        method == SEARCH_FIND_MEMBER_DECLARATIONS ||
-        method == SERVER_GET_VERSION ||
-        method == SERVER_SET_SUBSCRIPTIONS) {
+    if (method == ANALYSIS_REQUEST_GET_HOVER ||
+        method == ANALYSIS_REQUEST_SET_ANALYSIS_ROOTS ||
+        method == ANALYSIS_REQUEST_SET_PRIORITY_FILES ||
+        method == ANALYSIS_REQUEST_SET_SUBSCRIPTIONS ||
+        method == ANALYSIS_REQUEST_UPDATE_OPTIONS ||
+        method == EDIT_REQUEST_GET_ASSISTS ||
+        method == EDIT_REQUEST_GET_AVAILABLE_REFACTORINGS ||
+        method == EDIT_REQUEST_GET_FIXES ||
+        method == EDIT_REQUEST_GET_REFACTORING ||
+        method == EDIT_REQUEST_SORT_MEMBERS ||
+        method == EXECUTION_REQUEST_CREATE_CONTEXT ||
+        method == EXECUTION_REQUEST_DELETE_CONTEXT ||
+        method == EXECUTION_REQUEST_MAP_URI ||
+        method == EXECUTION_REQUEST_SET_SUBSCRIPTIONS ||
+        method == SEARCH_REQUEST_FIND_ELEMENT_REFERENCES ||
+        method == SEARCH_REQUEST_FIND_MEMBER_DECLARATIONS ||
+        method == SERVER_REQUEST_GET_VERSION ||
+        method == SERVER_REQUEST_SET_SUBSCRIPTIONS) {
       return new RequestOperation(this, json);
     }
     throw 'unknown request: $method\n  $json';
   }
 
   /**
    * Return an operation for the recorded/expected response.
    */
   Operation convertResponse(Map<String, dynamic> json) {
     return new ResponseOperation(this, asMap(requestMap.remove(json['id'])),
@@ skipping 212 matching lines @@
     if (op != null) {
       outSink.add(op);
     }
   }
 
   @override
   void close() {
     outSink.close();
   }
 }