restructure internal request to implement CompletionRequest API,

pkg/analysis_server/lib/src/domain_completion.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 domain.completion;
 
 import 'dart:async';
 
+import 'package:analysis_server/completion/completion_core.dart'
+    show CompletionRequest;
 import 'package:analysis_server/src/analysis_server.dart';
 import 'package:analysis_server/src/constants.dart';
 import 'package:analysis_server/src/protocol.dart';
 import 'package:analysis_server/src/services/completion/completion_manager.dart';
 import 'package:analysis_server/src/services/search/search_engine.dart';
 import 'package:analyzer/src/generated/engine.dart';
 import 'package:analyzer/src/generated/source.dart';
 
 export 'package:analysis_server/src/services/completion/completion_manager.dart'
     show CompletionPerformance, CompletionRequest, OperationPerformance;
 
 /**
  * Instances of the class [CompletionDomainHandler] implement a [RequestHandler]
  * that handles requests in the search domain.
  */
 class CompletionDomainHandler implements RequestHandler {
   /**
+   * The maximum number of performance measurements to keep.
+   */
+  static const int performanceListMaxLength = 50;
+
+  /**
    * The analysis server that is using this handler to process requests.
    */
   final AnalysisServer server;
 
   /**
    * The [SearchEngine] for this server.
    */
   SearchEngine searchEngine;
 
   /**
@@ skipping 18 matching lines @@
   CompletionPerformance performance;
 
   /**
    * A list of code completion peformance measurements for the latest
    * completion operation up to [performanceListMaxLength] measurements.
    */
   final List<CompletionPerformance> performanceList =
       new List<CompletionPerformance>();
 
   /**
-   * The maximum number of performance measurements to keep.
-   */
-  static const int performanceListMaxLength = 50;
-
-  /**
    * Performance for the last priority change event.
    */
   CompletionPerformance computeCachePerformance;
 
   /**
    * Initialize a new request handler for the given [server].
    */
   CompletionDomainHandler(this.server) {
     server.onContextsChanged.listen(contextsChanged);
     server.onPriorityChange.listen(priorityChanged);
@@ skipping 99 matching lines @@
     AnalysisContext context = contextSource.context;
     Source source = contextSource.source;
     if (context == null || !context.exists(source)) {
       return new Response.unknownSource(request);
     }
     recordRequest(performance, context, source, params.offset);
     if (manager == null) {
       manager = completionManagerFor(context, source);
     }
     CompletionRequest completionRequest =
-        new CompletionRequest(params.offset, performance);
+        new CompletionRequestImpl(server, context, source, params.offset);
     int notificationCount = 0;
     manager.results(completionRequest).listen((CompletionResult result) {
       ++notificationCount;
       performance.logElapseTime("notification $notificationCount send", () {
         sendCompletionNotification(completionId, result.replacementOffset,
             result.replacementLength, result.suggestions, result.last);
       });
       if (notificationCount == 1) {
         performance.logFirstNotificationComplete('notification 1 complete');
         performance.suggestionCountFirst = result.suggestions.length;
@@ skipping 71 matching lines @@
     if (_sourcesChangedSubscription != null) {
       _sourcesChangedSubscription.cancel();
       _sourcesChangedSubscription = null;
     }
     if (_manager != null) {
       _manager.dispose();
       _manager = null;
     }
   }
 }