Chromium Code Reviews| Index: runtime/observatory/lib/src/elements/ports.dart |
| diff --git a/runtime/observatory/lib/src/elements/ports.dart b/runtime/observatory/lib/src/elements/ports.dart |
| index 8f9cb3911e798f3476ef8bcc67ed18a33a59b3a0..b86697703e95638751cdb67c3eb3d2614e39eafb 100644 |
| --- a/runtime/observatory/lib/src/elements/ports.dart |
| +++ b/runtime/observatory/lib/src/elements/ports.dart |
| @@ -2,31 +2,146 @@ |
| // 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 ports; |
| - |
| +import 'dart:html'; |
| import 'dart:async'; |
| -import 'observatory_element.dart'; |
| -import 'package:observatory/service.dart'; |
| -import 'package:polymer/polymer.dart'; |
| +import 'package:observatory/models.dart' as M; |
| +import 'package:observatory/src/elements/helpers/any_ref.dart'; |
| +import 'package:observatory/src/elements/helpers/rendering_scheduler.dart'; |
| +import 'package:observatory/src/elements/helpers/tag.dart'; |
| +import 'package:observatory/src/elements/helpers/uris.dart'; |
| +import 'package:observatory/src/elements/instance_ref.dart'; |
| +import 'package:observatory/src/elements/nav/bar.dart'; |
| +import 'package:observatory/src/elements/nav/isolate_menu.dart'; |
| +import 'package:observatory/src/elements/nav/menu.dart'; |
| +import 'package:observatory/src/elements/nav/notify.dart'; |
| +import 'package:observatory/src/elements/nav/refresh.dart'; |
| +import 'package:observatory/src/elements/nav/top_menu.dart'; |
| +import 'package:observatory/src/elements/nav/vm_menu.dart'; |
| +import 'package:observatory/src/elements/view_footer.dart'; |
| -@CustomTag('ports-page') |
| -class PortsPageElement extends ObservatoryElement { |
| - PortsPageElement.created() : super.created(); |
| +class PortsElement extends HtmlElement implements Renderable { |
| + static const tag = const Tag<PortsElement>('ports-page', |
| + dependencies: const [ |
|
Cutch
2016/08/22 16:45:04
indentation
cbernaschina
2016/08/22 16:46:54
Done.
|
| + NavBarElement.tag, |
| + NavTopMenuElement.tag, |
| + NavVMMenuElement.tag, |
| + NavIsolateMenuElement.tag, |
| + NavMenuElement.tag, |
| + NavRefreshElement.tag, |
| + NavNotifyElement.tag, |
| + InstanceRefElement.tag, |
| + ViewFooterElement.tag |
| + ]); |
| - @observable Isolate isolate; |
| - @observable var /*ObservableList | ServiceObject*/ ports; |
| + RenderingScheduler<PortsElement> _r; |
| - void isolateChanged(oldValue) { |
| - if (isolate != null) { |
| - isolate.getPorts().then(_refreshView); |
| - } |
| + Stream<RenderedEvent<PortsElement>> get onRendered => _r.onRendered; |
| + |
| + M.VM _vm; |
| + M.IsolateRef _isolate; |
| + M.EventRepository _events; |
| + M.NotificationRepository _notifications; |
| + M.PortsRepository _ports; |
| + M.InstanceRepository _instances; |
| + M.Ports _isolatePorts; |
| + |
| + |
| + M.IsolateRef get isolate => _isolate; |
| + M.NotificationRepository get notifications => _notifications; |
| + M.PortsRepository get ports => _ports; |
| + M.VMRef get vm => _vm; |
| + |
| + factory PortsElement(M.VM vm, M.IsolateRef isolate, |
| + M.EventRepository events, |
| + M.NotificationRepository notifications, |
| + M.PortsRepository ports, |
| + M.InstanceRepository instances, |
| + {RenderingQueue queue}) { |
| + assert(vm != null); |
| + assert(isolate != null); |
| + assert(events != null); |
| + assert(notifications != null); |
| + assert(ports != null); |
| + assert(instances != null); |
| + PortsElement e = document.createElement(tag.name); |
| + e._r = new RenderingScheduler(e, queue: queue); |
| + e._vm = vm; |
| + e._isolate = isolate; |
| + e._events = events; |
| + e._notifications = notifications; |
| + e._ports = ports; |
| + e._instances = instances; |
| + return e; |
| + } |
| + |
| + PortsElement.created() : super.created(); |
| + |
| + @override |
| + void attached() { |
| + super.attached(); |
| + _r.enable(); |
| + _refresh(); |
| + } |
| + |
| + @override |
| + void detached() { |
| + super.detached(); |
| + children = []; |
| + _r.disable(notify: true); |
| } |
| - Future refresh() { |
| - return isolate.getPorts().then(_refreshView); |
| + void render() { |
| + children = [ |
| + new NavBarElement(queue: _r.queue) |
| + ..children = [ |
| + new NavTopMenuElement(queue: _r.queue), |
| + new NavVMMenuElement(_vm, _events, queue: _r.queue), |
| + new NavIsolateMenuElement(_isolate, _events, queue: _r.queue), |
| + new NavMenuElement('ports', link: Uris.ports(_isolate), last: true, |
| + queue: _r.queue), |
| + new NavRefreshElement(queue: _r.queue) |
| + ..onRefresh.listen((_) => _refresh()), |
| + new NavNotifyElement(_notifications, queue: _r.queue) |
| + ], |
| + new DivElement() |
| + ..classes = ['content-centered'] |
| + ..children = [ |
| + new HeadingElement.h1()..text = 'Ports', |
| + new BRElement(), new HRElement(), |
| + new DivElement() |
| + ..children = _createList(), |
| + new HRElement() |
| + ], |
| + new ViewFooterElement(queue: _r.queue) |
| + ]; |
| + } |
| + |
| + List<Element> _createList() { |
| + if (_isolatePorts == null) { |
| + return const []; |
| + } |
| + int i = 0; |
| + return _isolatePorts.elements.map((port) => |
| + new DivElement()..classes = ['memberItem'] |
| + ..children = [ |
| + new DivElement()..classes = ['memberName'] |
| + ..children = [ |
| + new SpanElement()..classes = ['port-number'] |
| + ..text = '[ ${++i} ] ', |
| + new SpanElement()..text = '${port.name}' |
| + ], |
| + new DivElement()..classes = ['memberValue'] |
| + ..children = [ |
| + anyRef(_isolate, port.handler, _instances, queue: _r.queue) |
| + ] |
| + ] |
| + ).toList(); |
| } |
| - _refreshView(/*ObservableList | ServiceObject*/ object) { |
| - ports = object['ports']; |
| + Future _refresh() async { |
| + _isolatePorts = null; |
| + _r.dirty(); |
| + _isolatePorts = await _ports.get(_isolate); |
| + _r.dirty(); |
| } |
| } |