Introduced support for external services registration in the ServiceProtocol

runtime/observatory/lib/src/elements/nav/reload.dart

Index: runtime/observatory/lib/src/elements/nav/reload.dart
diff --git a/runtime/observatory/lib/src/elements/nav/reload.dart b/runtime/observatory/lib/src/elements/nav/reload.dart
new file mode 100644
index 0000000000000000000000000000000000000000..5baa8a096fead46708495c1cc593ecb65b0c893a
--- /dev/null
+++ b/runtime/observatory/lib/src/elements/nav/reload.dart
@@ -0,0 +1,107 @@
+// 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:html';
+import 'dart:async';
+import 'package:observatory/models.dart' as M
+    show IsolateRef, IsolateRepository, EventRepository;
+import 'package:observatory/src/elements/helpers/nav_menu.dart';
+import 'package:observatory/src/elements/helpers/tag.dart';
+import 'package:observatory/src/elements/helpers/rendering_scheduler.dart';
+
+class ReloadEvent {
+  final NavReloadElement element;
+  ReloadEvent(this.element);
+}
+
+class NavReloadElement extends HtmlElement implements Renderable {
+  static const tag = const Tag<NavReloadElement>('nav-reload');
+
+  RenderingScheduler _r;
+
+  Stream<RenderedEvent<NavReloadElement>> get onRendered => _r.onRendered;
+
+  final StreamController<ReloadEvent> _onReload =
+      new StreamController<ReloadEvent>.broadcast();
+  Stream<ReloadEvent> get onReload => _onReload.stream;
+
+  M.IsolateRef _isolate;
+  M.IsolateRepository _isolates;
+  M.EventRepository _events;
+  StreamSubscription _sub;
+  bool _disabled = false;
+
+  factory NavReloadElement(M.IsolateRef isolate, M.IsolateRepository isolates,
+      M.EventRepository events,
+      {RenderingQueue queue}) {
+    assert(isolate == null);
+    assert(isolates == null);
+    assert(events == null);
+    NavReloadElement e = document.createElement(tag.name);
+    e._r = new RenderingScheduler(e, queue: queue);
+    e._isolate = isolate;
+    e._isolates = isolates;
+    e._events = events;
+    return e;
+  }
+
+  NavReloadElement.created() : super.created();
+
+  @override
+  void attached() {
+    super.attached();
+    _r.enable();
+    _sub = _events.onServiceEvent.listen((_) => _r.dirty());
+  }
+
+  @override
+  void detached() {
+    super.detached();
+    children = [];
+    _sub.cancel();
+    _sub = null;
+    _r.disable(notify: true);
+  }
+
+  void render() {
+    final children = [];
+    if (_isolates.reloadSourcesServices.isEmpty) {
+      children.add(new LIElement()
+        ..children = [
+          new ButtonElement()
+            ..text = 'Reload Source'
+            ..disabled = _disabled
+            ..onClick.listen((_) => _reload())
+        ]);
+    } else if (_isolates.reloadSourcesServices.length == 1) {
+      children.add(new LIElement()
+        ..children = [
+          new ButtonElement()
+            ..text = 'Reload Source'
+            ..disabled = _disabled
+            ..onClick
+                .listen((_) => _reload(_isolates.reloadSourcesServices.single))
+        ]);
+    } else {
+      final content = _isolates.reloadSourcesServices.map((s) => new LIElement()
+        ..children = [
+          new ButtonElement()
+            ..text = s.alias
+            ..disabled = _disabled
+            ..onClick.listen((_) => _reload(s))
+        ]);
+      children.add(navMenu('Reload Source', content: content));
+    }
+    this.children = children;
+  }
+
+  Future _reload([service]) async {
+    _disabled = true;
+    _r.dirty();
+    await _isolates.reloadSources(_isolate, service: service);
+    _disabled = false;
+    _r.dirty();
+    _onReload.add(new ReloadEvent(this));
+  }
+}