dnet-docker/dnet-app/frontends/is/src/app/wf-confs/wf-confs.component.ts

import { JsonPipe } from '@angular/common';
import { Component, Inject, Input, OnChanges, OnInit, SecurityContext, SimpleChanges } from '@angular/core';
import { FormControl, FormGroup, ValidatorFn, Validators } from '@angular/forms';
import { MatDialog, MatDialogRef, MAT_DIALOG_DATA } from '@angular/material/dialog';
import { MatSelectChange } from '@angular/material/select';
import { MatSnackBar } from '@angular/material/snack-bar';
import { ActivatedRoute, Router } from '@angular/router';
import { KeyValue, SimpleResource, WfConf, WfHistoryEntry, WfParam, WfSection } from '../common/is.model';
import { ResMetadataDialog } from '../resources/resources.component';
import { MatTableDataSource } from '@angular/material/table';
import { WfHistoryDialog } from '../wf-history/wf-history.component';
import { WfConfsClient } from './wf-confs.client';
import { WfConfDialog, WfConfLauncherDialog } from './wf-common.component';

@Component({
	selector: 'app-wf-confs',
	templateUrl: './wf-confs.component.html',
	styleUrls: []
})
export class WfConfsComponent implements OnInit {
	section?: WfSection;
	confs: KeyValue[] = [];
	conf?: WfConf;

	constructor(public client: WfConfsClient, public route: ActivatedRoute, public router: Router, public dialog: MatDialog, public snackBar: MatSnackBar) {
	}

	ngOnInit() {
		this.route.params.subscribe(params => {
			let sectionId = params['section'];
			let confId = params['conf'];

			if (confId) {
				this.client.loadWfConfiguration(confId, (conf: WfConf) => {
					this.conf = conf;
					if (conf.section) {
						this.client.loadWfSections((data: WfSection[]) => this.section = data.find(s => s.id == conf?.section));
						this.client.loadWfConfigurations(conf.section, (data: KeyValue[]) => this.confs = data);
					}
				});
			} else if (sectionId) {
				this.client.loadWfSections((data: WfSection[]) => this.section = data.find(s => s.id == sectionId));
				this.client.loadWfConfigurations(sectionId, (data: KeyValue[]) => {
					this.confs = data;
					if (data.length > 0) {
						this.router.navigate(['/wfs/conf', data[0].k]);
					}
				});
			} else {
				console.log("One of the following parameters is missing: sectionId or confId");
			}
		});
	}

	openAddWfConfDialog(): void {
		const dialogRef = this.dialog.open(WfConfDialog, {
			data: {
				id: '',
				name: '',
				section: this.section?.id,
				enabled: true,
				priority: 75,
				workflow: '',
				schedulingEnabled: false,
				cronExpression: '0 30 12 1/1 * ?',
				cronMinInterval: 9600,
				details: new Map,
				configured: true,
				systemParams: new Map,
				userParams: new Map
			},
			width: '80%'
		});

		dialogRef.afterClosed().subscribe(result => {
			if (result) this.router.navigate(['/wfs/conf', result.id]);;
		});
	}
}

@Component({
	selector: 'wf-conf-single',
	templateUrl: 'wf-conf-single.html',
	styleUrls: []
})
export class WfConfSingle implements OnInit, OnChanges {

	@Input() conf?: WfConf;
	prevConfId = '';

	historyEntries: WfHistoryEntry[] = [];

	constructor(public client: WfConfsClient, public dialog: MatDialog, public snackBar: MatSnackBar) { }

	ngOnInit(): void {
		this.refresh();
	}

	ngOnChanges(changes: SimpleChanges): void {
		if (this.conf && this.conf.id != this.prevConfId) {
			this.prevConfId = this.conf.id;
			this.refresh();
		}
	}

	refresh() {
		if (this.conf) {
			this.client.loadWfHistoryForConf(this.conf?.id, (data: WfHistoryEntry[]) => this.historyEntries = data);
		}
	}

	launchWfConf() {
		const wfDialogRef = this.dialog.open(WfConfLauncherDialog, {
			data: this.conf
		});
		wfDialogRef.componentInstance.newHistory.subscribe((data: WfHistoryEntry[]) => {
			this.historyEntries = data;
		});
	}

	editConf() {
		const dialogRef = this.dialog.open(WfConfDialog, {
			data: this.conf,
			width: '80%'
		});
	}

	deleteConf() {
		if (this.conf?.destroyWf) {
			if (this.conf?.id && this.conf?.workflows) {
				this.client.startDestroyWfConfiguration(this.conf?.id, (data: WfHistoryEntry) => this.snackBar.open('Destroy Workflow launched, PLEASE WAIT !!!', 'INFO', { duration: 5000 }));
			}
		} else if (this.conf?.id) {
			this.client.deleteWfConfiguration(this.conf?.id, (data: void) => {
				this.snackBar.open('Configuration deleted !!!', 'INFO', { duration: 5000 });
				this.conf = undefined;
			});
		}
	}

	openWfHistoryDialog(wf: WfHistoryEntry): void {
		alert(1);
		const wfDialogRef = this.dialog.open(WfHistoryDialog, {
			data: {
				'confId': wf.wfConfId,
				'processId': wf.processId
			}
		});
	}

}