import { Component, OnInit } from '@angular/core';
import { ActivatedRoute } from '@angular/router';
import { mergeMap, map } from 'rxjs/operators';
import { Observable } from 'rxjs';
import { TasksService } from '../../tasks.service';
import { ToolsService } from '../../components/flo/tools.service';
import { TaskConversion } from '../../components/flo/model/models';

/**
 * Component that shows the summary details of a Stream Definition
 *
 * @author Damien Vitrac
 */
@Component({
  selector: 'app-task-summary',
  templateUrl: 'task-summary.component.html',
  styleUrls: ['../styles.scss'],
})
export class TaskSummaryComponent implements OnInit {

  /**
   * Observable of stream information
   * Contains the stream definition, a list of the streams"s apps
   */
  task$: Observable<any>;

  /**
   * Constructor
   *
   * @param {ActivatedRoute} route
   * @param {ToolsService} toolsService
   * @param {TasksService} tasksService
   */
  constructor(private route: ActivatedRoute,
              private toolsService: ToolsService,
              private tasksService: TasksService) {
  }

  /**
   * Init component, call refresh method
   */
  ngOnInit() {
    this.refresh();
  }

  /**
   * Refresh
   * Create an observable which provides the required data
   */
  refresh() {
    this.task$ = this.route.parent.params
      .pipe(mergeMap(val => this.tasksService.getDefinition(val.id)))
      .pipe(mergeMap(
        val => this.toolsService.parseTaskTextToGraph(val.dslText, val.name)
          .pipe(map((val2: TaskConversion) => {
            let apps = [];
            if (val2.graph && val2.graph.nodes) {
              apps = val2.graph.nodes.map((node) => {
                if (node.name === 'START' || node.name === 'END') {
                  return null;
                }
                const item = {
                  name: node.name,
                  origin: node.name,
                  type: 'task'
                };
                if (node.metadata && node.metadata['label']) {
                  item.name = node.metadata['label'];
                }
                return item;
              }).filter((app) => app !== null);
            }
            return {
              taskDefinition: val,
              apps: apps
            };
          }))
      ));
  }

}