Handle incremental diagnostics.

dart/site/try/src/interaction_manager.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 trydart.interaction_manager;
 
 import 'dart:html';
 
 import 'dart:convert' show
     JSON;
@@ skipping 90 matching lines @@
   // In rare cases, some UI components can be independent of this state
   // machine. For example, animation and auto-save loops.
 
   // Implementation note: The state machine is actually implemented by
   // [InteractionContext], this class represents public event handlers.
 
   factory InteractionManager() => new InteractionContext();
 
   InteractionManager.internal();
 
+  // TODO(ahe): Remove this.
+  Set<AnchorElement> get oldDiagnostics;
+
   void onInput(Event event);
 
   // TODO(ahe): Rename to onKeyDown (as it is called in response to keydown
   // event).
   void onKeyUp(KeyboardEvent event);
 
   void onMutation(List<MutationRecord> mutations, MutationObserver observer);
 
   void onSelectionChange(Event event);
 
   /// Called when the content of a CompilationUnit changed.
   void onCompilationUnitChanged(CompilationUnit unit);
 
   Future<List<String>> projectFileNames();
 
   /// Called when the user selected a new project file.
   void onProjectFileSelected(String projectFile);
 
   /// Called when notified about a project file changed (on the server).
   void onProjectFileFsEvent(MessageEvent e);
 
   /// Called every 500ms.
   void onHeartbeat(Timer timer);
 
   /// Called by [:window.onMessage.listen:].
   void onMessage(MessageEvent event);
+
+  void onCompilationDone();
+
+  /// Called when a compilation is starting, but just before sending the
+  /// initiating message to the compiler isolate.
+  void compilationStarting();
 }
 
 /**
  * State machine for UI interactions.
  */
 class InteractionContext extends InteractionManager {
   InteractionState state;
 
   final Map<String, CompilationUnit> projectFiles = <String, CompilationUnit>{};
 
   final Set<CompilationUnit> modifiedUnits = new Set<CompilationUnit>();
 
   final Queue<CompilationUnit> unitsToSave = new Queue<CompilationUnit>();
 
   final Stopwatch saveTimer = new Stopwatch();
 
   final Stopwatch compileTimer = new Stopwatch();
 
   CompilationUnit currentCompilationUnit =
       // TODO(ahe): Don't use a fake unit.
       new CompilationUnit('fake', '');
 
   Timer heartbeat;
 
   Completer<String> completeSaveOperation;
 
+  final Set<AnchorElement> oldDiagnostics = new Set<AnchorElement>();
+
   InteractionContext()
       : super.internal() {
     state = new InitialState(this);
     heartbeat = new Timer.periodic(HEARTBEAT_INTERVAL, onHeartbeat);
   }
 
   void onInput(Event event) => state.onInput(event);
 
   void onKeyUp(KeyboardEvent event) => state.onKeyUp(event);
 
@@ skipping 39 matching lines @@
     return state.onProjectFileSelected(projectFile);
   }
 
   void onProjectFileFsEvent(MessageEvent e) {
     return state.onProjectFileFsEvent(e);
   }
 
   void onHeartbeat(Timer timer) => state.onHeartbeat(timer);
 
   void onMessage(MessageEvent event) => state.onMessage(event);
+
+  void onCompilationDone() => state.onCompilationDone();
+
+  void compilationStarting() => state.compilationStarting();
 }
 
 abstract class InteractionState implements InteractionManager {
   InteractionContext get context;
 
+  // TODO(ahe): Remove this.
+  Set<AnchorElement> get oldDiagnostics {
+    throw 'Use context.oldDiagnostics instead';
+  }
+
   void set state(InteractionState newState);
 
   void onStateChanged(InteractionState previous) {
     print('State change ${previous.runtimeType} -> ${runtimeType}.');
   }
 
   void transitionToInitialState() {
     state = new InitialState(context);
   }
 }
@@ skipping 340 matching lines @@
     window.console
         ..groupCollapsed('Bad message')
         ..dir(event)
         ..log(event.source.runtimeType)
         ..groupEnd();
   }
 
   void consolePrintLine(data) {
     outputDiv.appendText('$data\n');
   }
+
+  void onCompilationDone() {
+    for (AnchorElement diagnostic in context.oldDiagnostics) {
+      if (diagnostic.parent != null) {
+        // Problem fixed, remove the diagnostic.
+        diagnostic.replaceWith(new Text(getText(diagnostic)));
+      }
+    }
+    context.oldDiagnostics.clear();
+    observer.takeRecords(); // Discard mutations.
+  }
+
+  void compilationStarting() {
+    context.oldDiagnostics
+        ..clear()
+        ..addAll(mainEditorPane.querySelectorAll('a.diagnostic'));
+  }
 }
 
 Future<String> getString(uri) {
   return new Future<String>.sync(() => HttpRequest.getString('$uri'));
 }
 
 class PendingInputState extends InitialState {
   PendingInputState(InteractionContext context)
       : super(context);
 
@@ skipping 429 matching lines @@
   return text.split(new RegExp('^', multiLine: true));
 }
 
 void removeCodeCompletion() {
   List<Node> highlighting =
       mainEditorPane.querySelectorAll('.dart-code-completion');
   for (Element element in highlighting) {
     element.remove();
   }
 }