Update analysis server and integration tests to match new ChangeContentOverlay.

pkg/analysis_server/lib/src/analysis_server.dart

 // Copyright (c) 2014, 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.
 
 library analysis.server;
 
 import 'dart:async';
 import 'dart:collection';
 
 import 'package:analyzer/file_system/file_system.dart';
 import 'package:analysis_server/src/analysis_logger.dart';
 import 'package:analysis_server/src/channel.dart';
 import 'package:analysis_server/src/constants.dart';
 import 'package:analysis_server/src/context_manager.dart';
 import 'package:analysis_server/src/domain_analysis.dart';
 import 'package:analysis_server/src/operation/operation_analysis.dart';
 import 'package:analysis_server/src/operation/operation.dart';
 import 'package:analysis_server/src/operation/operation_queue.dart';
 import 'package:analysis_server/src/package_map_provider.dart';
 import 'package:analysis_server/src/protocol.dart';
 import 'package:analyzer/source/package_map_resolver.dart';
 import 'package:analyzer/src/generated/ast.dart';
 import 'package:analyzer/src/generated/engine.dart';
 import 'package:analyzer/src/generated/source.dart';
 import 'package:analyzer/src/generated/sdk.dart';
 import 'package:analyzer/src/generated/source_io.dart';
 import 'package:analyzer/src/generated/java_engine.dart';
 import 'package:analysis_services/constants.dart';
+import 'package:analysis_services/correction/change.dart';
 import 'package:analysis_services/index/index.dart';
 import 'package:analysis_services/search/search_engine.dart';
 import 'package:analyzer/src/generated/element.dart';
 
 
 class ServerContextManager extends ContextManager {
   final AnalysisServer analysisServer;
 
   /**
    * The default options used to create new analysis contexts.
@@ skipping 438 matching lines @@
    */
   void updateContent(Map<String, ContentChange> changes) {
     changes.forEach((file, change) {
       AnalysisContext analysisContext = getAnalysisContext(file);
       // TODO(paulberry): handle the case where a file is referred to by more
       // than one context (e.g package A depends on package B using a local
       // path, user has both packages open for editing in separate contexts,
       // and user modifies a file in package B).
       if (analysisContext != null) {
         Source source = getSource(file);
-        if (change.offset == null) {
-          analysisContext.setContents(source, change.contentOrReplacement);
-        } else {
-          // TODO(paulberry): an error should be generated if source is not
-          // currently in the content cache.
-          TimestampedData<String> oldContents = analysisContext.getContents(
-              source);
-          int offsetEnd = change.offset + change.length;
-          String newContents = oldContents.data.substring(0, change.offset) +
-              change.contentOrReplacement + oldContents.data.substring(offsetEnd);
-          analysisContext.setChangedContents(source, newContents, change.offset,
-              change.length, change.contentOrReplacement.length);
+        switch (change.type) {
+          case ADD:
+            analysisContext.setContents(source, change.content);
+            break;
+          case CHANGE:
+            // TODO(paulberry): an error should be generated if source is not
+            // currently in the content cache.
+            TimestampedData<String> oldContents = analysisContext.getContents(
+                source);
+            String newContents = Edit.applySequence(oldContents.data, change.changes);
+            // TODO(paulberry): to aid in incremental processing it would be
+            // better to use setChangedContents.
+            analysisContext.setContents(source, newContents);
+            break;
+          case REMOVE:
+            analysisContext.setContents(source, null);
+            break;
         }
         schedulePerformAnalysisOperation(analysisContext);
       }
     });
   }
 
   /**
    * Implementation for `analysis.setSubscriptions`.
    */
   void setAnalysisSubscriptions(Map<AnalysisService, Set<String>> subscriptions) {
@@ skipping 317 matching lines @@
 /**
  * An enumeration of the services provided by the server domain.
  */
 class ServerService extends Enum2<ServerService> {
   static const ServerService STATUS = const ServerService('STATUS', 0);
 
   static const List<ServerService> VALUES = const [STATUS];
 
   const ServerService(String name, int ordinal) : super(name, ordinal);
 }