// 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/models.dart' as M;
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';

class EventDeleteEvent{
  final M.Event event;
  EventDeleteEvent(this.event);
}

class NavNotifyEventElement extends HtmlElement implements Renderable {
  static const tag = const Tag<NavNotifyEventElement>('nav-event');

  RenderingScheduler _r;

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

  final StreamController<EventDeleteEvent> _onDelete =
      new StreamController<EventDeleteEvent>.broadcast();
  Stream<EventDeleteEvent> get onDelete => _onDelete.stream;

  M.Event _event;
  M.Event get event => _event;

  factory NavNotifyEventElement(M.Event event, {RenderingQueue queue}) {
    assert(event != null);
    NavNotifyEventElement e = document.createElement(tag.name);
    e._r = new RenderingScheduler(e, queue: queue);
    e._event = event;
    return e;
  }

  NavNotifyEventElement.created() : super.created();

  @override
  void attached() {
    super.attached();
    _r.enable();
  }

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

  void render() {
    children = [];
    List<Element> content;
    if (event is M.PauseStartEvent) {
      content = _managePauseStartEvent(event as M.PauseStartEvent);
    } else if (event is M.PauseExitEvent) {
      content = _managePauseExitEvent(event as M.PauseExitEvent);
    } else if (event is M.PauseBreakpointEvent) {
      content = _managePauseBreakpointEvent(event as M.PauseBreakpointEvent);
    } else if (event is M.PauseInterruptedEvent) {
      content = _managePauseInterruptedEvent(event as M.PauseInterruptedEvent);
    } else if (event is M.PauseExceptionEvent) {
      content = _managePauseExceptionEvent(event as M.PauseExceptionEvent);
    } else if (event is M.NoneEvent) {
      content = _manageNoneEvent(event as M.NoneEvent);
    } else if (event is M.ConnectionClosedEvent) {
      content = _manageConnectionClosedEvent(event as M.ConnectionClosedEvent);
    } else if (event is M.InspectEvent) {
      content = _manageInspectEvent(event as M.InspectEvent);
    } else if (event is M.IsolateReloadEvent) {
      content = _manageIsolateReloadEvent(event as M.IsolateReloadEvent);
    } else {
      return;
    }
    children = [
      new DivElement()
        ..children = []
        ..children.addAll(content)
        ..children.add(new ButtonElement()..innerHtml = '&times;'
            ..onClick.map(_toEvent).listen(_delete))
    ];
  }

  static List<Element> _managePauseStartEvent(M.PauseStartEvent event) {
    return [
      new SpanElement()..text = 'Isolate ',
      new AnchorElement(
        href: Uris.inspect(event.isolate))
        ..text = event.isolate.name,
      new SpanElement()..text = ' is paused at isolate start',
      new BRElement(), new BRElement(), new SpanElement()..text = '[',
      new AnchorElement(
        href: Uris.debugger(event.isolate))
        ..text = 'debug',
      new SpanElement()..text = ']'
    ];
  }

  static List<Element> _managePauseExitEvent(M.PauseExitEvent event) {
    return [
      new SpanElement()..text = 'Isolate ',
      new AnchorElement(
        href: Uris.inspect(event.isolate))
        ..text = event.isolate.name,
      new SpanElement()..text = ' is paused at isolate exit',
      new BRElement(), new BRElement(), new SpanElement()..text = '[',
      new AnchorElement(
        href: Uris.debugger(event.isolate))
        ..text = 'debug',
      new SpanElement()..text = ']'
    ];
  }

  static List<Element> _managePauseBreakpointEvent(M.PauseBreakpointEvent event) {
    String message = ' is paused';
    if (event.breakpoint != null) {
       message += ' at breakpoint ${event.breakpoint.number}';
    }
    return [
      new SpanElement()..text = 'Isolate ',
      new AnchorElement(
        href: Uris.inspect(event.isolate))
        ..text = event.isolate.name,
      new SpanElement()
        ..text = message,
      new BRElement(), new BRElement(), new SpanElement()..text = '[',
      new AnchorElement(
        href: Uris.debugger(event.isolate))
        ..text = 'debug',
      new SpanElement()..text = ']'
    ];
  }

  static List<Element> _managePauseInterruptedEvent(M.PauseInterruptedEvent event) {
    return [
      new SpanElement()..text = 'Isolate ',
      new AnchorElement(
        href: Uris.inspect(event.isolate))
        ..text = event.isolate.name,
      new SpanElement()
        ..text = ' is paused',
      new BRElement(), new BRElement(), new SpanElement()..text = '[',
      new AnchorElement(
        href: Uris.debugger(event.isolate))
        ..text = 'debug',
      new SpanElement()..text = ']'
    ];
  }

  static List<Element> _managePauseExceptionEvent(M.PauseExceptionEvent event) {
    return [
      new SpanElement()..text = 'Isolate ',
      new AnchorElement(
        href: Uris.inspect(event.isolate))
        ..text = event.isolate.name,
      new SpanElement()
        ..text = ' is paused due to exception',
      new BRElement(), new BRElement(), new SpanElement()..text = '[',
      new AnchorElement(
        href: Uris.debugger(event.isolate))
        ..text = 'debug',
      new SpanElement()..text = ']'
    ];
  }

  static List<Element> _manageNoneEvent(M.NoneEvent event) {
    return [
      new SpanElement()..text = 'Isolate ',
      new AnchorElement(
        href: Uris.inspect(event.isolate))
        ..text = event.isolate.name,
      new SpanElement()
        ..text = ' is paused',
      new BRElement(), new BRElement(), new SpanElement()..text = '[',
      new AnchorElement(
        href: Uris.debugger(event.isolate))
        ..text = 'debug',
      new SpanElement()..text = ']'
    ];
  }

  static List<Element> _manageConnectionClosedEvent(M.ConnectionClosedEvent event) {
    return [
      new SpanElement()..text = 'Disconnected from VM: ${event.reason}',
      new BRElement(), new BRElement(), new SpanElement()..text = '[',
      new AnchorElement(href: Uris.vmConnect())..text = 'Connect to a VM',
      new SpanElement()..text = ']'
    ];
  }

  static List<Element> _manageInspectEvent(M.InspectEvent event) {
    return [
      new SpanElement()..text = 'Inspect ${event.inspectee.id}',
      new BRElement(), new BRElement(), new SpanElement()..text = '[',
      new AnchorElement(href: Uris.inspect(event.isolate,
          object: event.inspectee))
        ..text = 'Inspect',
      new SpanElement()..text = ']'
      // TODO(cbernaschina) add InstanceRefElement back.
      //new InstanceRefElement()..instance = event.inspectee
    ];
  }

  static List<Element> _manageIsolateReloadEvent(M.IsolateReloadEvent event) {
    if (event.error != null) {
      return [
        new SpanElement()..text = 'Isolate reload failed:',
        new BRElement(), new BRElement(),
        new DivElement()
          ..classes = ["indent", "error"]
          ..text = event.error.message.toString()
      ];
    } else {
      return [new SpanElement()..text = 'Isolate reload'];
    }
  }

  EventDeleteEvent _toEvent(_) {
    return new EventDeleteEvent(_event);
  }

  void _delete(EventDeleteEvent e) {
    _onDelete.add(e);
  }

  void delete() {
    _onDelete.add(new EventDeleteEvent(_event));
  }
}