Add minimal support for sending notifications

pkg/analyzer_plugin/test/plugin/plugin_test.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 'package:analyzer/file_system/file_system.dart';
 import 'package:analyzer/file_system/memory_file_system.dart';
 import 'package:analyzer/src/dart/analysis/driver.dart';
 import 'package:analyzer_plugin/protocol/protocol.dart';
 import 'package:analyzer_plugin/protocol/protocol_common.dart';
 import 'package:analyzer_plugin/protocol/protocol_generated.dart';
 import 'package:path/src/context.dart';
 import 'package:test/test.dart';
 import 'package:test_reflective_loader/test_reflective_loader.dart';
 
@@ skipping 340 matching lines @@
         new PluginVersionCheckParams('byteStorePath', 'sdkPath', '0.1.0')));
     PluginVersionCheckResult result =
         new PluginVersionCheckResult.fromResponse(response);
     expect(result, isNotNull);
     expect(result.interestingFiles, ['*.dart']);
     expect(result.isCompatible, isTrue);
     expect(result.name, 'Test Plugin');
     expect(result.version, '0.1.0');
   }
 
+  test_sendNotificationsForFile() {
+    AnalysisService service1 = AnalysisService.FOLDING;
+    AnalysisService service2 = AnalysisService.NAVIGATION;
+    AnalysisService service3 = AnalysisService.OUTLINE;
+    plugin.subscriptionManager.setSubscriptions({
+      service1: [filePath1, filePath2],
+      service2: [filePath1],
+      service3: [filePath2]
+    });
+    plugin.sendNotificationsForFile(filePath1);
+    Map<String, List<AnalysisService>> notifications = plugin.sentNotifications;
+    expect(notifications, hasLength(1));
+    List<AnalysisService> services = notifications[filePath1];
+    expect(services, unorderedEquals([service1, service2]));
+  }
+
+  test_sendNotificationsForSubscriptions() {
+    Map<String, List<AnalysisService>> subscriptions =
+        <String, List<AnalysisService>>{};
+
+    plugin.sendNotificationsForSubscriptions(subscriptions);
+    Map<String, List<AnalysisService>> notifications = plugin.sentNotifications;
+    expect(notifications, hasLength(subscriptions.length));
+    for (String path in subscriptions.keys) {
+      List<AnalysisService> subscribedServices = subscriptions[path];
+      List<AnalysisService> notifiedServices = notifications[path];
+      expect(notifiedServices, isNotNull,
+          reason: 'Not notified for file $path');
+      expect(notifiedServices, unorderedEquals(subscribedServices),
+          reason: 'Wrong notifications for file $path');
+    }
+  }
+
   AnalysisDriverGeneric _getDriver(ContextRoot targetRoot) {
     for (ContextRoot root in plugin.driverMap.keys) {
       if (root.root == targetRoot.root) {
         return plugin.driverMap[root];
       }
     }
     return null;
   }
 }
 
 class _TestServerPlugin extends MockServerPlugin {
-  Map<String, List<AnalysisService>> latestSubscriptions;
+  Map<String, List<AnalysisService>> sentNotifications =
+      <String, List<AnalysisService>>{};
 
   _TestServerPlugin(ResourceProvider resourceProvider)
       : super(resourceProvider);
 
   @override
-  void sendNotificationsForSubscriptions(
-      Map<String, List<AnalysisService>> subscriptions) {
-    latestSubscriptions = subscriptions;
+  Future<Null> sendFoldingNotification(String path) {
+    _sent(path, AnalysisService.FOLDING);
+    return new Future.value();
+  }
+
+  @override
+  Future<Null> sendHighlightsNotification(String path) {
+    _sent(path, AnalysisService.HIGHLIGHTS);
+    return new Future.value();
+  }
+
+  @override
+  Future<Null> sendNavigationNotification(String path) {
+    _sent(path, AnalysisService.NAVIGATION);
+    return new Future.value();
+  }
+
+  @override
+  Future<Null> sendOccurrencesNotification(String path) {
+    _sent(path, AnalysisService.OCCURRENCES);
+    return new Future.value();
+  }
+
+  @override
+  Future<Null> sendOutlineNotification(String path) {
+    _sent(path, AnalysisService.OUTLINE);
+    return new Future.value();
+  }
+
+  void _sent(String path, AnalysisService service) {
+    sentNotifications.putIfAbsent(path, () => <AnalysisService>[]).add(service);
   }
 }