Initial support for getting fixes from plugins

pkg/analysis_server/lib/src/plugin/plugin_manager.dart

 // 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:async';
 import 'dart:collection';
 import 'dart:io' show Platform;
 
 import 'package:analysis_server/src/plugin/notification_manager.dart';
 import 'package:analyzer/context/context_root.dart' as analyzer;
 import 'package:analyzer/file_system/file_system.dart';
 import 'package:analyzer/instrumentation/instrumentation.dart';
 import 'package:analyzer/src/generated/bazel.dart';
 import 'package:analyzer/src/generated/gn.dart';
 import 'package:analyzer_plugin/channel/channel.dart';
 import 'package:analyzer_plugin/protocol/protocol.dart';
 import 'package:analyzer_plugin/protocol/protocol_generated.dart';
 import 'package:analyzer_plugin/src/channel/isolate_channel.dart';
 import 'package:analyzer_plugin/src/protocol/protocol_internal.dart';
 import 'package:convert/convert.dart';
 import 'package:crypto/crypto.dart';
 import 'package:meta/meta.dart';
 import 'package:path/path.dart' as path;
 
 /**
  * Information about a single plugin.
  */
-@visibleForTesting
 class PluginInfo {
   /**
    * The path to the root directory of the definition of the plugin on disk (the
    * directory containing the 'pubspec.yaml' file and the 'bin' directory).
    */
   final String path;
 
   /**
    * The path to the 'plugin.dart' file that will be executed in an isolate.
    */
@@ skipping 27 matching lines @@
    */
   PluginSession currentSession;
 
   /**
    * Initialize the newly created information about a plugin.
    */
   PluginInfo(this.path, this.executionPath, this.packagesPath,
       this.notificationManager, this.instrumentationService);
 
   /**
+   * Return the data known about this plugin.
+   */
+  PluginData get data =>
+      new PluginData(path, currentSession?.name, currentSession?.version);
+
+  /**
    * Add the given [contextRoot] to the set of context roots being analyzed by
    * this plugin.
    */
   void addContextRoot(analyzer.ContextRoot contextRoot) {
     if (contextRoots.add(contextRoot)) {
       _updatePluginRoots();
     }
   }
 
   /**
@@ skipping 105 matching lines @@
     }
     plugin.addContextRoot(contextRoot);
   }
 
   /**
    * Broadcast a request built from the given [params] to all of the plugins
    * that are currently associated with the given [contextRoot]. Return a list
    * containing futures that will complete when each of the plugins have sent a
    * response.
    */
-  List<Future<Response>> broadcast(
+  Map<PluginInfo, Future<Response>> broadcast(
       analyzer.ContextRoot contextRoot, RequestParams params) {
     List<PluginInfo> plugins = pluginsForContextRoot(contextRoot);
-    return plugins
-        .map((PluginInfo plugin) => plugin.currentSession?.sendRequest(params))
-        .toList();
+    Map<PluginInfo, Future<Response>> responseMap =
+        <PluginInfo, Future<Response>>{};
+    for (PluginInfo plugin in plugins) {
+      responseMap[plugin] = plugin.currentSession?.sendRequest(params);
+    }
+    return responseMap;
   }
 
   /**
    * Return a list of all of the plugins that are currently associated with the
    * given [contextRoot].
    */
   @visibleForTesting
   List<PluginInfo> pluginsForContextRoot(analyzer.ContextRoot contextRoot) {
     List<PluginInfo> plugins = <PluginInfo>[];
     for (PluginInfo plugin in _pluginMap.values) {
@@ skipping 277 matching lines @@
   Future<Null> stop() {
     if (channel == null) {
       throw new StateError('Cannot stop a plugin that is not running.');
     }
     // TODO(brianwilkerson) Ensure that the isolate is killed if it does not
     // terminate normally.
     sendRequest(new PluginShutdownParams());
     return pluginStoppedCompleter.future;
   }
 }