cloudfoundry/stratos

import { Component, Input, OnDestroy, OnInit } from '@angular/core';
import { FormControl, FormGroup } from '@angular/forms';
import { Subscription } from 'rxjs';
import { debounceTime, distinctUntilChanged } from 'rxjs/operators';

import { safeUnsubscribe } from '../../../../../core/src/core/utils.service';
import { ListConfig } from '../../../../../core/src/shared/components/list/list.component.types';
import { APIResource } from '../../../../../store/src/types/api.types';
import { CfEventsConfigService } from '../list/list-types/cf-events/cf-events-config.service';

@Component({
  selector: 'app-cloud-foundry-events-list',
  templateUrl: './cloud-foundry-events-list.component.html',
  styleUrls: ['./cloud-foundry-events-list.component.scss']
})
export class CloudFoundryEventsListComponent implements OnInit, OnDestroy {

  /**
   * Values in the `event` filter mist contain this value, for instance `audit.app`
   */
  @Input() typeMustContain: string;

  filtersFormGroup: FormGroup;
  typeValues: string[] = [
    'app.crash',
    'audit.app.copy-bits',
    'audit.app.create',
    'audit.app.delete-request',
    'audit.app.droplet.mapped',
    'audit.app.map-route',
    'audit.app.package.create',
    'audit.app.package.delete',
    'audit.app.package.download',
    'audit.app.package.upload',
    'audit.app.restage',
    'audit.app.ssh-authorized',
    'audit.app.ssh-unauthorized',
    'audit.app.start',
    'audit.app.stop',
    'audit.app.unmap-route',
    'audit.app.update',
    'audit.app.upload-bits',
    'audit.organization.create',
    'audit.organization.delete-request',
    'audit.organization.update',
    'audit.route.create',
    'audit.route.delete-request',
    'audit.route.update',
    'audit.service.create',
    'audit.service.delete',
    'audit.service.update',
    'audit.service_binding.create',
    'audit.service_binding.delete',
    'audit.service_broker.create',
    'audit.service_broker.delete',
    'audit.service_broker.update',
    'audit.service_dashboard_client.create',
    'audit.service_dashboard_client.delete',
    'audit.service_instance.bind_route',
    'audit.service_instance.create',
    'audit.service_instance.delete',
    'audit.service_instance.unbind_route',
    'audit.service_instance.update',
    'audit.service_key.create',
    'audit.service_key.delete',
    'audit.service_plan.create',
    'audit.service_plan.delete',
    'audit.service_plan.update',
    'audit.service_plan_visibility.create',
    'audit.service_plan_visibility.delete',
    'audit.service_plan_visibility.update',
    'audit.space.create',
    'audit.space.delete-request',
    'audit.space.update',
    'audit.user_provided_service_instance.create',
    'audit.user_provided_service_instance.delete',
    'audit.user_provided_service_instance.update',
    'audit.user.space_auditor_add',
    'audit.user.space_auditor_remove',
    'audit.user.space_manager_add',
    'audit.user.space_manager_remove',
    'audit.user.space_developer_add',
    'audit.user.space_developer_remove',
    'audit.user.organization_auditor_add',
    'audit.user.organization_auditor_remove',
    'audit.user.organization_billing_manager_add',
    'audit.user.organization_billing_manager_remove',
    'audit.user.organization_manager_add',
    'audit.user.organization_manager_remove',
    'audit.user.organization_user_add',
    'audit.user.organization_user_remove',
    'blob.remove_orphan',
    'audit.app.build.create',
    'audit.app.droplet.create',
    'audit.app.droplet.delete',
    'audit.app.droplet.download',
    'audit.app.process.crash',
    'audit.app.process.create',
    'audit.app.process.delete',
    'audit.app.process.scale',
    'audit.app.process.terminate_instance',
    'audit.app.process.update',
    'audit.app.task.cancel',
    'audit.app.task.create',
    'audit.service_instance.share',
    'audit.service_instance.unshare'
  ];
  showActee = false;
  private subs: Subscription[] = [];
  private config: CfEventsConfigService;
  private initialSet = false;
  public hasActeeFilter = false;

  constructor(
    listConfig: ListConfig<APIResource>,
  ) {
    this.filtersFormGroup = new FormGroup({
      actee: new FormControl(null, []),
      type: new FormControl(null, []),
    });
    this.config = (listConfig as CfEventsConfigService);

    // Set initial filter values
    this.subs.push(
      this.config.getEventFilters().pipe(
        distinctUntilChanged()
      ).subscribe(params => {
        if (!this.initialSet) {
          this.updateType(params.type);
          this.updateActee(params.actee);
          this.initialSet = true;
        } else if (this.filtersFormGroup.controls.actee.value !== params.actee) {
          this.updateActee(params.actee);
        }
      })
    );

    // Set new filter values
    this.subs.push(
      this.filtersFormGroup.valueChanges.pipe(
        debounceTime(250)
      ).subscribe(values => {
        this.config.setEventFilters(values);
        this.hasActeeFilter = !!values.actee;
      })
    );

    // If we have an actee there's no need to show the actee guid selector
    this.showActee = !this.config.acteeGuid;
  }

  ngOnInit() {
    if (this.typeMustContain) {
      this.typeValues = this.typeValues.filter(type => type.indexOf(this.typeMustContain) >= 0);
    }
  }

  ngOnDestroy() {
    safeUnsubscribe(...this.subs);
  }

  public clearActeeFilter() {
    this.filtersFormGroup.patchValue({ actee: '' });
  }

  private updateType(type: string[]) {
    this.filtersFormGroup.controls.type.setValue(type);
    this.filtersFormGroup.controls.type.markAsDirty();
  }

  private updateActee(actee: string) {
    this.filtersFormGroup.controls.actee.setValue(actee);
    this.filtersFormGroup.controls.actee.markAsDirty();
    this.hasActeeFilter = !!actee;
  }

}