OLD | NEW |
(Empty) | |
| 1 // Copyright (c) 2016, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. |
| 4 |
| 5 import 'dart:async'; |
| 6 import 'dart:html'; |
| 7 import 'package:observatory/service_html.dart'; |
| 8 import 'package:observatory/src/elements/helpers/tag.dart'; |
| 9 import 'package:observatory/src/elements/helpers/rendering_scheduler.dart'; |
| 10 |
| 11 class WebSocketVMTargetEvent { |
| 12 final WebSocketVMTarget target; |
| 13 |
| 14 WebSocketVMTargetEvent(this.target); |
| 15 } |
| 16 |
| 17 class VmConnectTargetElement extends HtmlElement implements Renderable{ |
| 18 |
| 19 static const tag = |
| 20 const Tag<VmConnectTargetElement>('vm-connect-target-wrapped'); |
| 21 |
| 22 RenderingScheduler<VmConnectTargetElement> _r; |
| 23 |
| 24 Stream<RenderedEvent<VmConnectTargetElement>> get onRendered => _r.onRendered; |
| 25 |
| 26 final StreamController<WebSocketVMTargetEvent> _onConnect = |
| 27 new StreamController<WebSocketVMTargetEvent>(); |
| 28 Stream<WebSocketVMTargetEvent> get onConnect => _onConnect.stream; |
| 29 final StreamController<WebSocketVMTargetEvent> _onDelete = |
| 30 new StreamController<WebSocketVMTargetEvent>(); |
| 31 Stream<WebSocketVMTargetEvent> get onDelete => _onDelete.stream; |
| 32 |
| 33 WebSocketVMTarget _target; |
| 34 bool _current; |
| 35 |
| 36 WebSocketVMTarget get target => _target; |
| 37 bool get current => _current; |
| 38 |
| 39 factory VmConnectTargetElement(WebSocketVMTarget target, |
| 40 {bool current: false}) { |
| 41 assert(target != null); |
| 42 assert(current is bool); |
| 43 VmConnectTargetElement e = document.createElement(tag.name); |
| 44 e._target = target; |
| 45 e._current = current; |
| 46 return e; |
| 47 } |
| 48 |
| 49 VmConnectTargetElement.created() : super.created() { |
| 50 _r = new RenderingScheduler<VmConnectTargetElement>(this); |
| 51 } |
| 52 |
| 53 @override |
| 54 void attached() { |
| 55 super.attached(); |
| 56 assert(target != null); |
| 57 _r.scheduleRendering(); |
| 58 } |
| 59 |
| 60 @override |
| 61 void detached() { |
| 62 super.detached(); |
| 63 children = []; |
| 64 _r.scheduleNotification(); |
| 65 } |
| 66 |
| 67 void connect() { |
| 68 _connect(new WebSocketVMTargetEvent(target)); |
| 69 } |
| 70 |
| 71 void delete() { |
| 72 _delete(new WebSocketVMTargetEvent(target)); |
| 73 } |
| 74 |
| 75 void render() { |
| 76 children = [ |
| 77 new AnchorElement(href: '#/vm') |
| 78 ..text = current ? '${target.name} (Connected)' : '${target.name}' |
| 79 ..onClick.where(_filter).map(_toEvent).listen(_connect), |
| 80 new ButtonElement() |
| 81 ..text = '✖ Remove' ..classes = ['delete-button'] |
| 82 ..onClick.map(_toEvent).listen(_delete) |
| 83 ]; |
| 84 } |
| 85 |
| 86 void _connect(WebSocketVMTargetEvent e) { |
| 87 if (_onConnect.hasListener) { |
| 88 _onConnect.add(e); |
| 89 } |
| 90 } |
| 91 |
| 92 void _delete(WebSocketVMTargetEvent e) { |
| 93 if (_onDelete.hasListener) { |
| 94 _onDelete.add(e); |
| 95 } |
| 96 } |
| 97 |
| 98 WebSocketVMTargetEvent _toEvent(_) { |
| 99 return new WebSocketVMTargetEvent(target); |
| 100 } |
| 101 |
| 102 static bool _filter(MouseEvent event) { |
| 103 return !(event.button > 0 || event.metaKey || event.ctrlKey || |
| 104 event.shiftKey || event.altKey); |
| 105 } |
| 106 } |
OLD | NEW |