services/self-service/src/main/resources/webapp/src/app/administration/project/project-list/project-list.component.ts

/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */

import {Component, OnInit, Output, EventEmitter, OnDestroy, Inject, Input} from '@angular/core';
import { ToastrService } from 'ngx-toastr';
import { MatTableDataSource } from '@angular/material/table';
import { Subscription } from 'rxjs';
import { MatDialogRef, MAT_DIALOG_DATA, MatDialog } from '@angular/material/dialog';

import { ProjectDataService } from '../project-data.service';
import { Project, Endpoint } from '../project.component';
import { CheckUtils } from '../../../core/util';
import {ProgressBarService} from '../../../core/services/progress-bar.service';
import {EdgeActionDialogComponent} from '../../../shared/modal-dialog/edge-action-dialog';
import {EndpointService} from '../../../core/services';


@Component({
  selector: 'project-list',
  templateUrl: './project-list.component.html',
  styleUrls: ['./project-list.component.scss', '../../../resources/computational/computational-resources-list/computational-resources-list.component.scss']
})
export class ProjectListComponent implements OnInit, OnDestroy {

  displayedColumns: string[] = ['name', 'groups', 'endpoints', 'actions'];
  dataSource: Project[] | any = [];
  projectList: Project[];

  @Input() isProjectAdmin: boolean;
  @Output() editItem: EventEmitter<{}> = new EventEmitter();
  @Output() toggleStatus: EventEmitter<{}> = new EventEmitter();
  private subscriptions: Subscription = new Subscription();

  constructor(
    public toastr: ToastrService,
    private projectDataService: ProjectDataService,
    private progressBarService: ProgressBarService,
    @Inject(MAT_DIALOG_DATA) public data: any,
    public dialogRef: MatDialogRef<ProjectListComponent>,
    public dialog: MatDialog,
  ) {
  }


  ngOnInit() {
    this.getProjectList();
  }

  ngOnDestroy() {
    this.subscriptions.unsubscribe();
  }

  private getProjectList() {
    this.progressBarService.startProgressBar();
    this.subscriptions.add(this.projectDataService._projects.subscribe((value: Project[]) => {
      this.projectList = value;
      if (this.projectList) {
        this.projectList.forEach(project => {
          project.areRunningNode = this.areResoursesInStatuses(project.endpoints, ['RUNNING']);
          project.areStoppedNode = this.areResoursesInStatuses(project.endpoints, ['STOPPED']);
          project.areTerminatedNode = this.areResoursesInStatuses(project.endpoints, ['TERMINATED', 'FAILED']);
        });
      }
      if (value) this.dataSource = new MatTableDataSource(value);
      this.progressBarService.stopProgressBar();
    }, () => this.progressBarService.stopProgressBar()));
  }

  public showActiveInstances(): void {
    const filteredList = this.projectList.map(project => {
      project.endpoints = project.endpoints.filter((endpoint: Endpoint) => endpoint.status !== 'TERMINATED' && endpoint.status !== 'TERMINATING' && endpoint.status !== 'FAILED');
      return project;
    });

    this.dataSource = new MatTableDataSource(filteredList);
  }

  public editProject(item: Project[]) {
    this.editItem.emit(item);
  }

  public openEdgeDialog(action, project) {
      const endpoints = project.endpoints.filter(endpoint => {
        if (action === 'stop') {
          return endpoint.status === 'RUNNING';
        }
        if (action === 'start') {
          return endpoint.status === 'STOPPED';
        }
        if (action === 'terminate') {
          return endpoint.status === 'RUNNING' || endpoint.status === 'STOPPED';
        }
        if (action === 'recreate') {
          return endpoint.status === 'TERMINATED' || endpoint.status === 'FAILED';
        }
      });
      if (action === 'terminate' && endpoints.length === 1) {
        this.toggleStatus.emit({project, endpoint: endpoints, action, oneEdge: true});
      } else {
        this.dialog.open(EdgeActionDialogComponent, {data: {type: action, item: endpoints}, panelClass: 'modal-sm'})
          .afterClosed().subscribe(endpoint => {
            if (endpoint && endpoint.length) {
              this.toggleStatus.emit({project, endpoint, action});
            }
          }, error => this.toastr.error(error.message || `Endpoint ${action} failed!`, 'Oops!')
        );
      }
    }

  public areResoursesInStatuses(resources, statuses: Array<string>) {
    return resources.some(resource => statuses.some(status => resource.status === status));
  }
}