// Copyright (c) 2016, 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_2/models.dart' as M;
import 'package:observatory_2/src/elements/helpers/custom_element.dart';
import 'package:observatory_2/src/elements/helpers/rendering_scheduler.dart';
import 'package:observatory_2/src/elements/nav/notify_event.dart';
import 'package:observatory_2/src/elements/nav/notify_exception.dart';

class NavNotifyElement extends CustomElement implements Renderable {
  RenderingScheduler<NavNotifyElement> _r;

  Stream<RenderedEvent<NavNotifyElement>> get onRendered => _r.onRendered;

  M.NotificationRepository _repository;
  StreamSubscription _subscription;

  bool _notifyOnPause;

  bool get notifyOnPause => _notifyOnPause;

  set notifyOnPause(bool value) =>
      _notifyOnPause = _r.checkAndReact(_notifyOnPause, value);

  factory NavNotifyElement(M.NotificationRepository repository,
      {bool notifyOnPause: true, RenderingQueue queue}) {
    assert(repository != null);
    assert(notifyOnPause != null);
    NavNotifyElement e = new NavNotifyElement.created();
    e._r = new RenderingScheduler<NavNotifyElement>(e, queue: queue);
    e._repository = repository;
    e._notifyOnPause = notifyOnPause;
    return e;
  }

  NavNotifyElement.created() : super.created('nav-notify');

  @override
  void attached() {
    super.attached();
    _subscription = _repository.onChange.listen((_) => _r.dirty());
    _r.enable();
  }

  @override
  void detached() {
    super.detached();
    children = <Element>[];
    _r.disable(notify: true);
    _subscription.cancel();
  }

  void render() {
    children = <Element>[
      new DivElement()
        ..children = <Element>[
          new DivElement()
            ..children = _repository
                .list()
                .where(_filter)
                .map<Element>(_toElement)
                .toList()
        ]
    ];
  }

  bool _filter(M.Notification notification) {
    if (!_notifyOnPause && notification is M.EventNotification) {
      return notification.event is! M.PauseEvent;
    }
    return true;
  }

  Element _toElement(M.Notification notification) {
    if (notification is M.EventNotification) {
      return (new NavNotifyEventElement(notification.event, queue: _r.queue)
            ..onDelete.listen((_) => _repository.delete(notification)))
          .element;
    } else if (notification is M.ExceptionNotification) {
      return (new NavNotifyExceptionElement(notification.exception,
              stacktrace: notification.stacktrace, queue: _r.queue)
            ..onDelete.listen((_) => _repository.delete(notification)))
          .element;
    } else {
      assert(false);
      return new DivElement()..text = 'Invalid Notification Type';
    }
  }
}