Remove ability to disable new analysis driver

pkg/analysis_server/lib/src/domain_analysis.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.
 
 import 'dart:async';
 import 'dart:core';
 
 import 'package:analysis_server/plugin/analysis/analysis_domain.dart';
 import 'package:analysis_server/src/analysis_server.dart';
 import 'package:analysis_server/src/computer/computer_hover.dart';
 import 'package:analysis_server/src/constants.dart';
 import 'package:analysis_server/src/context_manager.dart';
 import 'package:analysis_server/src/domain_abstract.dart';
 import 'package:analysis_server/src/domains/analysis/navigation.dart';
 import 'package:analysis_server/src/domains/analysis/navigation_dart.dart';
 import 'package:analysis_server/src/operation/operation_analysis.dart'
     show NavigationOperation, OccurrencesOperation;
 import 'package:analysis_server/src/plugin/plugin_manager.dart';
 import 'package:analysis_server/src/plugin/request_converter.dart';
 import 'package:analysis_server/src/plugin/result_merger.dart';
 import 'package:analysis_server/src/protocol/protocol_internal.dart';
 import 'package:analysis_server/src/protocol_server.dart';
 import 'package:analysis_server/src/services/dependencies/library_dependencies.dart';
-import 'package:analysis_server/src/services/dependencies/reachable_source_collector.dart';
 import 'package:analyzer/dart/ast/ast.dart';
-import 'package:analyzer/dart/element/element.dart';
 import 'package:analyzer/error/error.dart' as engine;
 import 'package:analyzer/exception/exception.dart';
 import 'package:analyzer/file_system/file_system.dart';
 import 'package:analyzer/src/dart/analysis/driver.dart';
 import 'package:analyzer/src/generated/engine.dart' as engine;
 import 'package:analyzer/src/generated/source.dart';
 import 'package:analyzer/task/model.dart' show ResultDescriptor;
 import 'package:analyzer_plugin/protocol/protocol.dart' as plugin;
 import 'package:analyzer_plugin/protocol/protocol_common.dart';
 import 'package:analyzer_plugin/protocol/protocol_constants.dart' as plugin;
@@ skipping 22 matching lines @@
       if (lineInfo == null) {
         server.sendResponse(new Response.getErrorsInvalidFile(request));
       } else {
         List<AnalysisError> protocolErrors =
             doAnalysisError_listFromEngine(analysisOptions, lineInfo, errors);
         server.sendResponse(
             new AnalysisGetErrorsResult(protocolErrors).toResponse(request.id));
       }
     }
 
-    if (server.options.enableNewAnalysisDriver) {
-      var result = await server.getAnalysisResult(file);
+    AnalysisResult result = await server.getAnalysisResult(file);
 
-      if (server.onResultErrorSupplementor != null) {
-        if (result != null) {
-          await server.onResultErrorSupplementor(file, result.errors);
-        } else {
-          server.onNoAnalysisResult(file, send);
-          return;
-        }
+    if (server.onResultErrorSupplementor != null) {
+      if (result != null) {
+        await server.onResultErrorSupplementor(file, result.errors);
+      } else {
+        server.onNoAnalysisResult(file, send);
+        return;
       }
-
-      send(result?.driver?.analysisOptions, result?.lineInfo, result?.errors);
-      return;
     }
 
-    Future<AnalysisDoneReason> completionFuture =
-        server.onFileAnalysisComplete(file);
-    if (completionFuture == null) {
-      server.sendResponse(new Response.getErrorsInvalidFile(request));
-    }
-    completionFuture.then((AnalysisDoneReason reason) async {
-      switch (reason) {
-        case AnalysisDoneReason.COMPLETE:
-          engine.AnalysisErrorInfo errorInfo = server.getErrors(file);
-          if (errorInfo == null) {
-            server.sendResponse(new Response.getErrorsInvalidFile(request));
-          } else {
-            engine.AnalysisContext context = server.getAnalysisContext(file);
-            send(context.analysisOptions, errorInfo.lineInfo, errorInfo.errors);
-          }
-          break;
-        case AnalysisDoneReason.CONTEXT_REMOVED:
-          // The active contexts have changed, so try again.
-          await getErrors(request);
-          break;
-      }
-    });
+    send(result?.driver?.analysisOptions, result?.lineInfo, result?.errors);
   }
 
   /**
    * Implement the `analysis.getHover` request.
    */
   Future<Null> getHover(Request request) async {
     var params = new AnalysisGetHoverParams.fromRequest(request);
 
     // Prepare the resolved units.
-    CompilationUnit unit;
-    if (server.options.enableNewAnalysisDriver) {
-      AnalysisResult result = await server.getAnalysisResult(params.file);
-      unit = result?.unit;
-    } else {
-      unit = await server.getResolvedCompilationUnit(params.file);
-    }
+    AnalysisResult result = await server.getAnalysisResult(params.file);
+    CompilationUnit unit = result?.unit;
 
     // Prepare the hovers.
     List<HoverInformation> hovers = <HoverInformation>[];
     if (unit != null) {
       HoverInformation hoverInformation =
           new DartUnitHoverComputer(unit, params.offset).compute();
       if (hoverInformation != null) {
         hovers.add(hoverInformation);
       }
     }
@@ skipping 23 matching lines @@
 
   /**
    * Implement the `analysis.getNavigation` request.
    */
   Future<Null> getNavigation(Request request) async {
     var params = new AnalysisGetNavigationParams.fromRequest(request);
     String file = params.file;
     int offset = params.offset;
     int length = params.length;
 
-    if (server.options.enableNewAnalysisDriver) {
-      AnalysisDriver driver = server.getAnalysisDriver(file);
-      if (driver == null) {
-        server.sendResponse(new Response.getNavigationInvalidFile(request));
-      } else {
-        //
-        // Allow plugins to start computing navigation data.
-        //
-        plugin.AnalysisGetNavigationParams requestParams =
-            new plugin.AnalysisGetNavigationParams(file, offset, length);
-        Map<PluginInfo, Future<plugin.Response>> pluginFutures = server
-            .pluginManager
-            .broadcastRequest(requestParams, contextRoot: driver.contextRoot);
-        //
-        // Compute navigation data generated by server.
-        //
-        List<AnalysisNavigationParams> allResults =
-            <AnalysisNavigationParams>[];
-        AnalysisResult result = await server.getAnalysisResult(file);
-        CompilationUnit unit = result?.unit;
-        if (unit != null && result.exists) {
-          NavigationCollectorImpl collector = new NavigationCollectorImpl();
-          computeDartNavigation(collector, unit, offset, length);
-          collector.createRegions();
+    AnalysisDriver driver = server.getAnalysisDriver(file);
+    if (driver == null) {
+      server.sendResponse(new Response.getNavigationInvalidFile(request));
+    } else {
+      //
+      // Allow plugins to start computing navigation data.
+      //
+      plugin.AnalysisGetNavigationParams requestParams =
+          new plugin.AnalysisGetNavigationParams(file, offset, length);
+      Map<PluginInfo, Future<plugin.Response>> pluginFutures = server
+          .pluginManager
+          .broadcastRequest(requestParams, contextRoot: driver.contextRoot);
+      //
+      // Compute navigation data generated by server.
+      //
+      List<AnalysisNavigationParams> allResults = <AnalysisNavigationParams>[];
+      AnalysisResult result = await server.getAnalysisResult(file);
+      CompilationUnit unit = result?.unit;
+      if (unit != null && result.exists) {
+        NavigationCollectorImpl collector = new NavigationCollectorImpl();
+        computeDartNavigation(collector, unit, offset, length);
+        collector.createRegions();
+        allResults.add(new AnalysisNavigationParams(
+            file, collector.regions, collector.targets, collector.files));
+      }
+      //
+      // Add the navigation data produced by plugins to the server-generated
+      // navigation data.
+      //
+      if (pluginFutures != null) {
+        List<plugin.Response> responses = await waitForResponses(pluginFutures,
+            requestParameters: requestParams);
+        for (plugin.Response response in responses) {
+          plugin.AnalysisGetNavigationResult result =
+              new plugin.AnalysisGetNavigationResult.fromResponse(response);
           allResults.add(new AnalysisNavigationParams(
-              file, collector.regions, collector.targets, collector.files));
-        }
-        //
-        // Add the navigation data produced by plugins to the server-generated
-        // navigation data.
-        //
-        if (pluginFutures != null) {
-          List<plugin.Response> responses = await waitForResponses(
-              pluginFutures,
-              requestParameters: requestParams);
-          for (plugin.Response response in responses) {
-            plugin.AnalysisGetNavigationResult result =
-                new plugin.AnalysisGetNavigationResult.fromResponse(response);
-            allResults.add(new AnalysisNavigationParams(
-                file, result.regions, result.targets, result.files));
-          }
-        }
-        //
-        // Return the result.
-        //
-        ResultMerger merger = new ResultMerger();
-        AnalysisNavigationParams mergedResults =
-            merger.mergeNavigation(allResults);
-        if (mergedResults == null) {
-          server.sendResponse(new AnalysisGetNavigationResult(
-                  <String>[], <NavigationTarget>[], <NavigationRegion>[])
-              .toResponse(request.id));
-        } else {
-          server.sendResponse(new AnalysisGetNavigationResult(
-                  mergedResults.files,
-                  mergedResults.targets,
-                  mergedResults.regions)
-              .toResponse(request.id));
+              file, result.regions, result.targets, result.files));
         }
       }
-      return;
+      //
+      // Return the result.
+      //
+      ResultMerger merger = new ResultMerger();
+      AnalysisNavigationParams mergedResults =
+          merger.mergeNavigation(allResults);
+      if (mergedResults == null) {
+        server.sendResponse(new AnalysisGetNavigationResult(
+                <String>[], <NavigationTarget>[], <NavigationRegion>[])
+            .toResponse(request.id));
+      } else {
+        server.sendResponse(new AnalysisGetNavigationResult(mergedResults.files,
+                mergedResults.targets, mergedResults.regions)
+            .toResponse(request.id));
+      }
     }
-
-    Future<AnalysisDoneReason> analysisFuture =
-        server.onFileAnalysisComplete(file);
-    if (analysisFuture == null) {
-      server.sendResponse(new Response.getNavigationInvalidFile(request));
-      return;
-    }
-    analysisFuture.then((AnalysisDoneReason reason) async {
-      switch (reason) {
-        case AnalysisDoneReason.COMPLETE:
-          CompilationUnit unit = await server.getResolvedCompilationUnit(file);
-          if (unit == null) {
-            server.sendResponse(new Response.getNavigationInvalidFile(request));
-          } else {
-            CompilationUnitElement unitElement = unit.element;
-            NavigationCollectorImpl collector = computeNavigation(
-                server,
-                unitElement.context,
-                unitElement.source,
-                params.offset,
-                params.length);
-            server.sendResponse(new AnalysisGetNavigationResult(
-                    collector.files, collector.targets, collector.regions)
-                .toResponse(request.id));
-          }
-          break;
-        case AnalysisDoneReason.CONTEXT_REMOVED:
-          // The active contexts have changed, so try again.
-          await getNavigation(request);
-          break;
-      }
-    });
   }
 
   /**
    * Implement the `analysis.getReachableSources` request.
    */
   Response getReachableSources(Request request) {
-    AnalysisGetReachableSourcesParams params =
-        new AnalysisGetReachableSourcesParams.fromRequest(request);
-    ContextSourcePair pair = server.getContextSourcePair(params.file);
-    if (pair.context == null || pair.source == null) {
-      return new Response.getReachableSourcesInvalidFile(request);
-    }
-    Map<String, List<String>> sources =
-        new ReachableSourceCollector(pair.source, pair.context)
-            .collectSources();
-    return new AnalysisGetReachableSourcesResult(sources)
-        .toResponse(request.id);
+    return new Response.unsupportedFeature(request.id,
+        'Please contact the Dart analyzer team if you need this request.');
+//    AnalysisGetReachableSourcesParams params =
+//        new AnalysisGetReachableSourcesParams.fromRequest(request);
+//    ContextSourcePair pair = server.getContextSourcePair(params.file);
+//    if (pair.context == null || pair.source == null) {
+//      return new Response.getReachableSourcesInvalidFile(request);
+//    }
+//    Map<String, List<String>> sources =
+//        new ReachableSourceCollector(pair.source, pair.context)
+//            .collectSources();
+//    return new AnalysisGetReachableSourcesResult(sources)
+//        .toResponse(request.id);
   }
 
   @override
   Response handleRequest(Request request) {
     try {
       String requestName = request.method;
       if (requestName == ANALYSIS_GET_ERRORS) {
         getErrors(request);
         return Response.DELAYED_RESPONSE;
       } else if (requestName == ANALYSIS_GET_HOVER) {
@@ skipping 247 matching lines @@
       context.onResultChanged(descriptor).listen((result) {
         StreamController<engine.ResultChangedEvent> controller =
             controllers[result.descriptor];
         if (controller != null) {
           controller.add(result);
         }
       });
     }
   }
 }