Add support for watch events and error notifications

pkg/analysis_server/test/context_manager_test.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 test.context.directory.manager;
 
+import 'dart:async';
 import 'dart:collection';
 
 import 'package:analysis_server/src/context_manager.dart';
 import 'package:analysis_server/src/utilities/null_string_sink.dart';
 import 'package:analyzer/context/context_root.dart';
 import 'package:analyzer/error/error.dart';
 import 'package:analyzer/file_system/file_system.dart';
 import 'package:analyzer/file_system/memory_file_system.dart';
 import 'package:analyzer/instrumentation/instrumentation.dart';
 import 'package:analyzer/source/error_processor.dart';
 import 'package:analyzer/src/context/builder.dart';
 import 'package:analyzer/src/dart/analysis/byte_store.dart';
 import 'package:analyzer/src/dart/analysis/driver.dart';
 import 'package:analyzer/src/dart/analysis/file_state.dart';
 import 'package:analyzer/src/error/codes.dart';
 import 'package:analyzer/src/generated/engine.dart' hide AnalysisResult;
 import 'package:analyzer/src/generated/sdk.dart';
 import 'package:analyzer/src/generated/source.dart';
 import 'package:analyzer/src/generated/source_io.dart';
 import 'package:analyzer/src/services/lint.dart';
 import 'package:analyzer/src/summary/summary_file_builder.dart';
 import 'package:analyzer/src/util/glob.dart';
 import 'package:linter/src/rules.dart';
 import 'package:linter/src/rules/avoid_as.dart';
 import 'package:path/path.dart' as path;
 import 'package:plugin/manager.dart';
 import 'package:plugin/plugin.dart';
 import 'package:test/test.dart';
 import 'package:test_reflective_loader/test_reflective_loader.dart';
+import 'package:watcher/watcher.dart';
 
 import 'mock_sdk.dart';
 import 'mocks.dart';
 
 main() {
   defineReflectiveSuite(() {
     defineReflectiveTests(AbstractContextManagerTest);
     defineReflectiveTests(ContextManagerWithNewOptionsTest);
     defineReflectiveTests(ContextManagerWithOldOptionsTest);
   });
@@ skipping 2545 matching lines @@
 analyzer:
   strong-mode: true
 ''');
     String libPath = newFolder([projPath, ContextManagerTest.LIB_NAME]);
     newFile([libPath, 'main.dart']);
     // Setup context.
     manager.setRoots(<String>[projPath], <String>[], <String, String>{});
     // Verify that analysis options was parsed and strong-mode set.
     expect(analysisOptions.strongMode, true);
   }
+
+  test_watchEvents() async {
+    String libPath = newFolder([projPath, ContextManagerTest.LIB_NAME]);
+    manager.setRoots(<String>[projPath], <String>[], <String, String>{});
+    newFile([libPath, 'main.dart']);
+    await new Future.delayed(new Duration(milliseconds: 1));
+    expect(callbacks.watchEvents, hasLength(1));
+  }
 }
 
 class TestContextManagerCallbacks extends ContextManagerCallbacks {
   /**
    * Source of timestamps stored in [currentContextFilePaths].
    */
   int now = 0;
 
   /**
    * The analysis context that was created.
@@ skipping 46 matching lines @@
   /**
    * The scheduler used by the driver.
    */
   final AnalysisDriverScheduler scheduler;
 
   /**
    * The list of `flushedFiles` in the last [removeContext] invocation.
    */
   List<String> lastFlushedFiles;
 
+  /**
+   * The watch events that have been broadcast.
+   */
+  List<WatchEvent> watchEvents = <WatchEvent>[];
+
   TestContextManagerCallbacks(
       this.resourceProvider, this.sdkManager, this.logger, this.scheduler);
 
   /**
    * Return the current set of analysis options.
    */
   AnalysisOptions get analysisOptions => currentDriver == null
       ? currentContext.analysisOptions
       : currentDriver.analysisOptions;
 
@@ skipping 118 matching lines @@
 
   void assertContextFiles(String contextPath, List<String> expectedFiles) {
     expect(getCurrentFilePaths(contextPath), unorderedEquals(expectedFiles));
   }
 
   void assertContextPaths(List<String> expected) {
     expect(currentContextRoots, unorderedEquals(expected));
   }
 
   @override
+  void broadcastWatchEvent(WatchEvent event) {
+    watchEvents.add(event);
+  }
+
+  @override
   void computingPackageMap(bool computing) {
     // Do nothing.
   }
 
   @override
   ContextBuilder createContextBuilder(Folder folder, AnalysisOptions options,
       {bool useSummaries = false}) {
     ContextBuilderOptions builderOptions = new ContextBuilderOptions();
     builderOptions.defaultOptions = options;
     ContextBuilder builder = new ContextBuilder(
@@ skipping 84 matching lines @@
 class TestUriResolver extends UriResolver {
   Map<Uri, Source> uriMap;
 
   TestUriResolver(this.uriMap);
 
   @override
   Source resolveAbsolute(Uri uri, [Uri actualUri]) {
     return uriMap[uri];
   }
 }