D-Net

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

	<parent>

		<groupId>eu.dnetlib</groupId>

		<artifactId>dnet45-parent</artifactId>

		<version>1.0.0</version>

	</parent>

	<modelVersion>4.0.0</modelVersion>

	<groupId>eu.dnetlib</groupId>

	<artifactId>dnet-modular-workflows-ui</artifactId>

	<packaging>jar</packaging>

	<version>5.0.2</version>

	<scm>

		<developerConnection>scm:svn:https://svn.driver.research-infrastructures.eu/driver/dnet45/modules/dnet-modular-workflows-ui/tags/dnet-modular-workflows-ui-5.0.2</developerConnection>

	</scm>

	<dependencies>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>dnet-modular-ui</artifactId>

			<version>[3.0.0,4.0.0)</version>

		</dependency>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>dnet-msro-service</artifactId>

			<version>[4.0.0,5.0.0)</version>

		</dependency>

		<dependency>

			<groupId>joda-time</groupId>

			<artifactId>joda-time</artifactId>

			<version>2.3</version>

		</dependency>

		<dependency>

			<groupId>javax.servlet</groupId>

			<artifactId>javax.servlet-api</artifactId>

			<version>${javax.servlet.version}</version>

			<scope>provided</scope>

		</dependency>

		<dependency>

			<groupId>org.apache.httpcomponents</groupId>

			<artifactId>httpclient</artifactId>

			<version>4.5.3</version>

		</dependency>

		<dependency>

			<groupId>junit</groupId>

			<artifactId>junit</artifactId>

			<version>${junit.version}</version>

			<scope>test</scope>

		</dependency>

	</dependencies>

	<properties>

		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

	</properties>

</project>

package eu.dnetlib.functionality.modular.ui.workflows.objects;

import java.util.List;

import eu.dnetlib.msro.workflows.util.WorkflowParam;

public class NodeInfo {

	private String name;

	private String description;

	private List<WorkflowParam> params;

	public NodeInfo(String name, String description, List<WorkflowParam> params) {

		this.name = name;

		this.description = description;

		this.params = params;

	}

	public String getName() {

		return name;

	}

	public void setName(String name) {

		this.name = name;

	}

	public String getDescription() {

		return description;

	}

	public void setDescription(String description) {

		this.description = description;

	}

	public List<WorkflowParam> getParams() {

		return params;

	}

	public void setParams(List<WorkflowParam> params) {

		this.params = params;

	}

}

var module = angular.module('wfJournalUI', ['ngGrid','ui.bootstrap']);

module.directive('sliderDateRange', function($compile) {

	var months = ["Jan", "Feb", "Mar", "Apr", "May", "Jun", "Jul", "Aug", "Sept", "Oct", "Nov", "Dec"];

	return {

		restrict: 'A',

		scope: {

			min   : '=',

			max   : '=',

			start : '=',

			end   : '=',

			updateFunction: '='

		},

		link: function(scope, elem, attrs) {

    		$(elem).dateRangeSlider({

    			valueLabels: "change",

    			delayOut: 1000,

    			"bounds" : {

					min: scope.min,

					max: scope.max

				},

				"defaultValues" : {

					min: scope.start,

					max: scope.end

				},

				"scales": [{

					first: function(value) {

						return value;

					},

					end: function(value) {

						return value;

					},

					next: function(value) {

						var next = new Date(value);

						return new Date(next.setMonth(value.getMonth() + 1));

					},

					label: function(value) {

						return months[value.getMonth()];

					},

					format:	function(tickContainer, tickStart, tickEnd) {

						tickContainer.addClass("myCustomClass");

					}

				}]

    		});

    		$(elem).bind("valuesChanged", function(e, data){

    			scope.updateFunction(data.values.min, data.values.max);

    		});

    	}

    }

});

function wfJournalCtrl($scope, $http, $sce) {

	commonInitialize($scope, $http, $sce);

	initSpinner();

	$scope.journal = [];

	$scope.currentProcId = '';

	$scope.family = getFamily();

	$scope.filterJournal = { filterText: '' };

	$scope.maxDate = new Date();

	$scope.minDate = new Date($scope.maxDate.getTime() - 31536000000); // 1 YEAR AGO

	$scope.endDate = new Date();

	$scope.startDate = new Date();

	$scope.updateDates = function(start, end) {

		$scope.startDate = start;

		$scope.endDate = end;

		$scope.$apply();

		$scope.refresh();

	}

	// Set date range to [7 days before today, today] inclusive

	$scope.startDate.setDate($scope.endDate.getDate()-7);

	// Grid configuration

	$scope.gridWfJournal = { 

			data: 'journal',

			enableCellSelection: false,

			enableRowSelection: false,

			enableCellEditOnFocus: false,

			enablePaging: false,

			enableHighlighting: true,

			sortInfo: { fields: ['date'], directions: ['desc']},

			filterOptions: $scope.filterJournal,

			columnDefs: [{field: 'procId', displayName: 'Process ID'      , width: '15%', cellTemplate: '<div class="ngCellText"><a href="javascript:void(0)" ng-click="showProcess(row.getProperty(col.field))">{{row.getProperty(col.field)}}</a></div>'},

			             {field: 'name'  , displayName: 'Workflow name'   , width: '20%',},

			             {field: 'family', displayName: 'Workflow family' , width: '15%' },

			             {field: 'repo'  , displayName: 'Datasource', cellTemplate: '<div class="ngCellText"><a href="repoApis.do#/api/{{row.getProperty(\'repoId\')}}/{{row.getProperty(\'apiId\')}}/ALL/ALL" ng-if="row.getProperty(\'repoId\') && row.getProperty(\'apiId\') && row.getProperty(\'repo\')">{{row.getProperty(col.field)}}</a><span ng-if="!(row.getProperty(\'repoId\') && row.getProperty(\'apiId\'))">{{row.getProperty(col.field)}}</span></div>'},

			             {field: 'status', displayName: 'Status'          , width: '10%', cellTemplate: '<div class="ngCellText"><span class="label label-default" ng-class="{ \'label-success\': row.getProperty(col.field) == \'SUCCESS\', \'label-danger\': row.getProperty(col.field) == \'FAILURE\', \'label-info\': row.getProperty(col.field) == \'EXECUTING\'}">{{row.getProperty(col.field)}}</span></div>'},

			             {field: 'date'  , displayName: 'Date'            , width: '10%', cellTemplate: '<div class="ngCellText">{{ (row.getProperty("date") > 0 && row.getProperty("date") < 9999999999999) ? (row.getProperty("date") | date:"yyyy-MM-dd HH:mm:ss") : "not yet started" }}</div>'}

			            ]

	};

	$scope.formatDate = function(date) {

		var year = date.getFullYear();

		var month = ("00" + (date.getMonth() + 1)).slice(-2);

		var day = ("00" + date.getDate()).slice(-2);

		return year + '-' + month + '-' + day;

	}

	$scope.refresh = function() {

		$scope.showSpinner();

		var url = '';

		if ($scope.family) {

			url = 'wf_journal_byFamily.find?family=' + $scope.family;

		} else {

			url = 'wf_journal.range?start=' + $scope.formatDate($scope.startDate) + '&end=' + $scope.formatDate($scope.endDate);

		}

		$http.get(url).success(

			function(data) {

				$scope.journal = data;

				$scope.hideSpinner();

			}

		).error(

			function(err) {

				$scope.showError(err.message);

				$scope.hideSpinner();

			}

		);

	}

	$scope.resizeMainElement = function(elem) {

		var height = 0;

		var body = window.document.body;

		if (window.innerHeight) {

			height = window.innerHeight;

		} else if (body.parentElement.clientHeight) {

			height = body.parentElement.clientHeight;

		} else if (body && body.clientHeight) {

			height = body.clientHeight;

		}

		elem.style.height = ((height - elem.offsetTop - 280) + "px");

	}

	$scope.refresh();

	$scope.resizeMainElement(document.getElementById('wfJournalTable'));

	if (initProcId()) {

		$scope.showProcess(initProcId());

	}

}

window.onresize = function() {

	var elem = document.getElementById('wfJournalTable');

    angular.element(elem).scope().resizeMainElement(elem);

};

package eu.dnetlib.functionality.modular.ui.workflows.objects;

import java.util.Set;

import com.google.common.collect.Sets;

import eu.dnetlib.msro.workflows.util.WorkflowsConstants.WorkflowStatus;

public class AdvancedMetaWorkflowDescriptor extends MetaWorkflowDescriptor {

	private String email;

	private boolean scheduled;

	private String cronExpression;

	private int minInterval;

	private Set<String> innerWfs = Sets.newHashSet();

	private String html;

	public AdvancedMetaWorkflowDescriptor(final String id, final String name, final String email,

			final boolean scheduled, final String cronExpression, final int minInterval, final WorkflowStatus statusEnum, final String family, final Set<String> innerWfs, final String html) {

		super(id, name, statusEnum, family);

		this.email = email;

		this.scheduled = scheduled;

		this.cronExpression = cronExpression;

		this.minInterval = minInterval;

		this.innerWfs = innerWfs;

		this.setHtml(html);

	}

	public boolean isScheduled() {

		return scheduled;

	}

	public void setScheduled(final boolean scheduled) {

		this.scheduled = scheduled;

	}

	public String getCronExpression() {

		return cronExpression;

	}

	public void setCronExpression(final String cronExpression) {

		this.cronExpression = cronExpression;

	}

	public int getMinInterval() {

		return minInterval;

	}

	public void setMinInterval(final int minInterval) {

		this.minInterval = minInterval;

	}

	public String getEmail() {

		return email;

	}

	public void setEmail(final String email) {

		this.email = email;

	}

	public Set<String> getInnerWfs() {

		return innerWfs;

	}

	public void setInnerWfs(Set<String> innerWfs) {

		this.innerWfs = innerWfs;

	}

	public String getHtml() {

		return html;

	}

	public void setHtml(String html) {

		this.html = html;

	}

}

var module = angular.module('wfTimelineUI', ['ngGrid']);

function wfTimelineCtrl($scope, $http, $sce, $filter) {

	commonInitialize($scope, $http, $sce);

	initSpinner();

	// Set date range to [3 days before today, today] inclusive

	$scope.endDate = new Date();

	$scope.startDate = new Date();

	$scope.startDate.setDate($scope.endDate.getDate()-3);

	$scope.data= [];

	$scope.timeline = new links.Timeline(document.getElementById('divTimeline'));		

	$scope.timelineData = [];

	$scope.currentLog = [];

	$scope.currentLogTitle = '';

	$scope.formatDate = function(date) {

		var year = date.getFullYear();

		var month = ("00" + (date.getMonth() + 1)).slice(-2);

		var day = ("00" + date.getDate()).slice(-2);

		return year + '-' + month + '-' + day;

	}

	$scope.gridLogDetails = { 

			data: 'currentLog',

			enableCellSelection: false,

			enableRowSelection: false,

			enableCellEditOnFocus: false,

			enablePaging: false,

			sortInfo: { fields: ['name'], directions: ['asc'] },

			columnDefs: [{field: 'name', displayName: 'Key', width: '20%' },

			             {field: 'value', displayName: 'Value' }]

	};

	$scope.registerListener = function() {

		links.events.addListener($scope.timeline, 'select', function() {

	        var sel = $scope.timeline.getSelection();

	        if (sel.length) {

	            if (sel[0].row != undefined) {

	                var row = sel[0].row;

	                $scope.showProcess($scope.timelineData[row].procId);

	            }

	        }

	    });

        // attach an event listener using the links events handler

		links.events.addListener($scope.timeline, 'rangechanged', function(properties) {

			if ($scope.formatDate($scope.endDate) != $scope.formatDate(properties.end) || $scope.formatDate($scope.startDate) != $scope.formatDate(properties.start)) {

				$scope.endDate = properties.end;

				$scope.startDate = properties.start;

				$scope.refresh();

			}

		});

	}

	$scope.refresh = function() {

		$scope.showSpinner();

		$http.get('wf_journal.range?start=' + $scope.formatDate($scope.startDate) + '&end=' + $scope.formatDate($scope.endDate))

        .success(

            function(data) {

            	$scope.data = data;

                $scope.drawVisualization($scope.data);

                $scope.hideSpinner();

            }

        ).error(

            function(err) {

            	$scope.showError(err.message);

            	$scope.hideSpinner();

            }

        );

	}

	$scope.resizeMainElement = function(elem) {

		var height = 0;

		var body = window.document.body;

		if (window.innerHeight) {

			height = window.innerHeight;

		} else if (body.parentElement.clientHeight) {

			height = body.parentElement.clientHeight;

		} else if (body && body.clientHeight) {

			height = body.clientHeight;

		}

		elem.style.height = ((height - elem.offsetTop - 160) + "px");

	}

	$scope.drawVisualization = function(entries) {

		$scope.timelineData = [];

		angular.forEach(entries, function(value, key) {

			var clazz = 'text-success';

			if (value.status == 'FAILURE') {

				clazz = 'text-danger';

			}

			var s = "";

			if (value.repo) {

				s += value.repo + " (" + value.name + ")";

			} else {

				var s = value.name;

			}

			var prettyDate = "not yet started";

			if (value.date > 0 && value.date < 9999999999999) { // sabato 20 novembre 2286 17.46.39 GMT

				prettyDate = $filter('date')(new Date(value.date),'yyyy-MM-dd HH:mm:ss');

			}

			$scope.timelineData.push({

				'title': value.name + " (" + prettyDate + ")",

				'procId': value.procId,

                'start': new Date(value.date),

                'content': s,

                'className': clazz

            });

		});

		$scope.timeline = new links.Timeline(document.getElementById('divTimeline'));

		$scope.registerListener();

		var opts = {'width': '100%', 

					'height': '99%', 

					'style': 'dot',

					'zoomMin': 1000000,

					'zoomMax': 1314000000, // a half month

					'start': $scope.startDate,

					'end': $scope.endDate};

		$scope.timeline.draw($filter('filter')($scope.timelineData, $scope.filterText), opts);

    }

	$scope.refresh();

	//$scope.timeline.setScale(links.Timeline.StepDate.SCALE.DAY, 1);

	$scope.resizeMainElement(document.getElementById('divTimeline'));

}

window.onresize = function() {

	var elem = document.getElementById('divTimeline');

    angular.element(elem).scope().resizeMainElement(elem);

    angular.element(elem).scope().timeline.redraw();

};

package eu.dnetlib.functionality.modular.ui.workflows.objects;

import com.google.gson.Gson;

public abstract class AbstractWorkflowDescriptor implements Comparable<AbstractWorkflowDescriptor> {

	private String wfId;

	private String name;

	private String cssClass;

	public AbstractWorkflowDescriptor(final String wfId, final String name, final String cssClass) {

		super();

		this.wfId = wfId;

		this.name = name;

		this.cssClass = cssClass;

	}

	public String getName() {

		return name;

	}

	public void setName(final String name) {

		this.name = name;

	}

	public String getCssClass() {

		return cssClass;

	}

	public void setCssClass(final String cssClass) {

		this.cssClass = cssClass;

	}

	public String toJson() {

		return (new Gson()).toJson(this);

	}

	public String getWfId() {

		return wfId;

	}

	public void setWfId(final String wfId) {

		this.wfId = wfId;

	}

	@Override

	public int compareTo(final AbstractWorkflowDescriptor o) {

		return getName().compareTo(o.getName());

	}

}

function getScope(selector) {

	return angular.element($(selector)).scope();

}

function addCommonDirectives(module) {

	module.directive('compileTemplate', function($compile, $parse){

	    return {

	            link: function(scope, element, attr){

	                    var parsed = $parse(attr.ngBindHtml);

	                    function getStringValue() { return (parsed(scope) || '').toString(); }

	                    //Recompile if the template changes

	                    scope.$watch(getStringValue, function() {

	            $compile(element, null, -9999)(scope);  //The -9999 makes it skip directives so that we do not recompile ourselves

	                    });

	            }         

	    }

	});

	module.directive('tooltip', function() {

		return {

			restrict : 'A',

			link : function(scope, element, attrs) {

				$(element).tooltip();

			}

		}

	});

	module.filter('sprintf', function() {

		function parse(str) {

			var args = [].slice.call(arguments, 1),

			i = 0;

			return str.replace(/%s/g, function() {

				return args[i++];

			});

		}

		return function(str) {

			return parse(str, arguments[1], arguments[2], arguments[3], arguments[4], arguments[5]);

		};

	});

}

function commonInitialize($scope, $http, $sce) {

	$scope.currentProc = {};

	$scope.currentProcNode = {};

	$scope.currentValue = {};

	$scope.currentNode = null;

	$scope.currentLog = [];

	$scope.currentSimpleLog = [];

	$scope.currentAdvancedLog = [];

	$scope.currentStartWf = '-';

	$scope.currentEndWf = '-';

	$scope.gridCurrentLogDetails = {

		data : 'currentLog',

		enableCellSelection : false,

		enableRowSelection : false,

		enableColumnResize : true,

		enableCellEditOnFocus : false,

		enablePaging : false,

		enableHighlighting: true,

		sortInfo : { fields : [ 'name' ], directions : [ 'asc' ] },

		columnDefs : [ 

		              {	field : 'name', displayName : 'Key', width : '25%', cellTemplate : '<div class="ngCellText" ng-class="col.colIndex()"><span ng-cell-text><a href="javascript:void(0)" ng-click="setCurrentValue(row.entity)">{{row.getProperty(col.field).replace(\"mainlog:\", \"\")}}</a></span></div>' },

		              {	field : 'value', displayName : 'Value' } 

		             ],        

		filterOptions: {filterText: '', useExternalFilter: false},

		showFilter: true

	};

	$scope.gridCurrentProcNodeEnvParams = {

			data : 'currentProcNode.params',

			enableCellSelection : false,

			enableRowSelection : false,

			enableCellEditOnFocus : false,

			enablePaging : false,

			enableHighlighting: true,

			sortInfo : { fields : [ 'name' ], directions : [ 'asc' ] },

			columnDefs : [ 

			              {	field : 'name', displayName : 'Env Parameter Name', width : '25%', cellTemplate : '<div class="ngCellText" ng-class="col.colIndex()"><span ng-cell-text><a href="javascript:void(0)" ng-click="setCurrentValue(row.entity)">{{row.getProperty(col.field)}}</a></span></div>' },

			              {	field : 'value', displayName : 'Env Parameter Value' } 

			             ],        

			filterOptions: {filterText: '', useExternalFilter: false},

			showFilter: true

		};

	$scope.to_trusted = function(html_code) {

		return $sce.trustAsHtml(html_code);

	}

	$scope.showError = function(error) {

		show_notification("error", error);

	}

	$scope.showNotification = function(message) {

		show_notification("info", message);

	}

	$scope.showSpinner = function() {

		showSpinner();

	}

	$scope.hideSpinner = function() {

		hideSpinner();

	}

	initSpinner();

	$scope.getNodeDetails = function(wf, node) {

		$scope.currentNode = null;

		$scope.showSpinner();

		$http

				.get('wf_workflow_node.json?wf=' + wf + '&node=' + node)

				.success(function(data) {

					$scope.currentNode = data;

					$scope.hideSpinner();

					$('#nodeEditModal').modal('show');

				})

				.error(

						function(err) {

							$scope.showError(err.message);

							$scope.hideSpinner();

						});

	}

	$scope.setCurrentValue  = function(row) {

		$scope.currentValue = row;

	}

	$scope.showProcess = function(id) {

		$('#journalWfModal').modal('hide');

		$('#monitorWfModal').modal('hide');

		$scope.showSpinner();

		if (!$('#monitorProcWfModal').hasClass('in')) {

			$scope.currentStartWf = 0;

			$scope.currentEndWf = 0;

			$scope.currentValue = {};

			$scope.currentLog = null;

			$scope.currentAdvancedLog = null;

			$scope.currentSimpleLog = null;

			$scope.currentProc = null;

		}

		$http.get('wf_journal.get?id=' + id).success(function(data) {

			if (data.graph) {

				$scope.currentProc = data.graph;

			}

			if (!$('#monitorProcWfModal').hasClass('in')) {

				if (data.journal) {

					$scope.currentAdvancedLog = data.journal;

					$scope.currentSimpleLog = [];

					angular.forEach($scope.currentAdvancedLog, function(value, key){

						if ((/^dataprovider\:/).test(value.name) || (/^mainlog\:/).test(value.name) || ((/error/).test(value.name) && (value.value))) {

							$scope.currentSimpleLog.push(value);

						} else if (value.name == 'system:startDate') {

							$scope.currentStartWf = value.value;

						} else if (value.name == 'system:endDate') {

							$scope.currentEndWf = value.value;

						}

					});

					$scope.currentLog = $scope.currentSimpleLog;

					$scope.hideSpinner();

					$('#currentLogDetailsModal').modal('show');

				} else if ($scope.currentProc) {

					$('#monitorProcWfModal').modal('show');

				}

			}

			$scope.hideSpinner();

		}).error(function(err) {

			$scope.showError(err.message);

			$scope.hideSpinner();

		});

	}

	$scope.calculateDateDiff = function(start, end) {

		if (start <= 0 || end <= 0) {

			return '-';

		}

		var seconds = 0;

		var minutes = 0;

		var hours = 0;

		var days = 0;

		if (end > start) {

			seconds = Math.round((end - start) / 1000);

			if (seconds > 60) {

				minutes = Math.floor(seconds / 60);

				seconds = seconds % 60;

				if (minutes > 60) {

					hours = Math.floor(minutes / 60);

					minutes = minutes % 60;

					if (hours > 24) {

						days = Math.floor(hours / 24);

						hours = hours % 24;

					}

				}

			}

		}

		var res = '';

		if (days > 0) {

			if (res) {	res += ', '; } 

			res += days + " day(s)"

		}

		if (hours > 0) {

			if (res) {	res += ', '; } 

			res += hours + " hour(s)"

		}

		if (minutes > 0) {

			if (res) {	res += ', '; } 

			res += minutes + " minute(s)"

		}

		if (seconds > 0) {

			if (res) {	res += ', '; } 

			res += seconds + " second(s)"

		}

		if (!res) {

			res = '0 seconds';

		} 

		return res;

	} 

	$scope.getProcessNodeDetails = function(procId, nodeId) {

		$('#monitorProcWfModal').modal('hide');

		$scope.showSpinner();

		$http

				.get('wf_proc_node.json?id=' + procId + "&node=" + nodeId)

				.success(function(data) {

					$scope.currentProcNode = data;

					$scope.hideSpinner();

					$('#monitorProcNodeModal').modal('show');

				})

				.error(

						function(err) {

							$scope.showError(err.message);

							$scope.hideSpinner();

						});

	}

	$scope.killProcess = function(procId) {

		if (confirm("Are you sure ?")) {

			$scope.showSpinner();

			$http.get('wf_proc.kill?id=' + procId).success(function(data) {

				$scope.currentProc = {};

				$scope.hideSpinner();

				$('#monitorProcWfModal').modal('hide');

				$scope.showNotification('Workflow killed !');

			}).error(function(err) {

				$scope.showError(err.message);

				$scope.hideSpinner();

			});

		}

	}

	$scope.showSpinner();

}

function wf_init($scope, $http, $sce) {

	$scope.currentWorkflow = {};

	$scope.currentUserParams = {};

	$scope.currentMetaWorkflow = {};

	$scope.metaworkflows = [];

	$scope.validParamValuesCache = {};

	$scope.currentHistory = [];

	$scope.filterMetaWfHistory = { filterText : '' };

	$scope.gridHistory = {

		data : 'currentHistory',

		enableCellEditOnFocus : false,

		enablePaging : false,

		enableHighlighting : true,

		sortInfo : { fields : [ 'date' ], directions : [ 'desc' ] },

		filterOptions : $scope.filterMetaWfHistory,

		columnDefs : [

			{ field : 'procId', displayName : 'Process ID', width : '15%', cellTemplate : '<div class="ngCellText"><a href="javascript:void(0)" ng-click="showProcess(row.getProperty(col.field))">{{row.getProperty(col.field)}}</a></div>' },

			{ field : 'name', displayName : 'Workflow name', width : '40%' },

			{ field : 'family', displayName : 'Workflow Family', width : '15%' },

			{ field : 'status', displayName : 'Status', width : '10%', cellTemplate : '<div class="ngCellText"><span class="label label-default" ng-class="{ \'label-success\': row.getProperty(col.field) == \'SUCCESS\', \'label-danger\': row.getProperty(col.field) == \'FAILURE\', \'label-info\': row.getProperty(col.field) == \'EXECUTING\'}">{{row.getProperty(col.field)}}</span></div>' },

			{ field : 'date', displayName : 'Last activity', cellTemplate : '<div class="ngCellText">{{ (row.getProperty("date") > 0 && row.getProperty("date") < 9999999999999) ? (row.getProperty("date") | date:"yyyy-MM-dd HH:mm:ss") : "not yet started" }}</div>' }

		]

	};

	$scope.verifyType = function(val, type) {

		if (type == 'string') {

			return val.length > 0;

		} else if (type == 'text') {

			return val.length > 0;

		} else if (type == 'boolean') {

			return (val == 'true') || (val == 'false');

		} else if (type == 'int') {

			return val.test(/^\s*-?\d+\s*$/);

		} else if (type == 'float') {

			return val.test(/^\s*-?\d*(\.\d+)?\s*$/);

		} else if (type == 'date') {

			return val.test(/^(0[1-9]|[12][0-9]|3[01])[- \/.](0[1-9]|1[012])[- \/.](19|20)\d\d$/);

		} else if (type == 'datetime') {

			return true;

		} else if (type == 'property') {

			return true;

		} else {

			return false;

		}

	}

	$scope.getMetaWorkflow = function(id) {

		if (id) {

			$scope.showSpinner();

			$http.get('wf_metaworkflow.json?id=' + id).success(function(data) {

				$scope.currentMetaWorkflow = data;

				$scope.hideSpinner();

			}).error(function(err) {

				$scope.showError(err.message);

				$scope.hideSpinner();

			});

		}

	}

	$scope.getAtomicWorkflow = function(id) {

		$scope.currentWorkflow = null;

		$scope.currentNode = null;

		$scope.showSpinner();

		$http.get('wf_atomic_workflow.json?id=' + id).success(function(data) {

			$scope.currentWorkflow = data;

			$scope.hideSpinner();

			$('#atomWfModal').modal('show')

		}).error(function(err) {

			$scope.showError(err.message);

			$scope.hideSpinner();

		});

	}

	$scope.getAtomicWorkflowAndMetaWf = function(metaWfId, wfId) {

		$scope.showSpinner();

		$http.get('wf_metaworkflow.json?id=' + metaWfId).success(function(data) {

			$scope.currentMetaWorkflow = data;

			$scope.getAtomicWorkflow(wfId);

		}).error(function(err) {

			$scope.showError(err.message);

			$scope.hideSpinner();

		});

	}

	$scope.getWorkflows = function(loadFirstElement, params) {

		$scope.showSpinner();

		$http.get('list_metaworkflows.json?' + params).success(function(data) {

			$scope.metaworkflows = data;

			$scope.hideSpinner();

			if (loadFirstElement) {

				if ($scope.initialWf && $scope.initialMetaWf) {

					angular.forEach($scope.metaworkflows, function(mw, key) {

						if (mw.wfId == $scope.initialMetaWf) {

							$scope.getAtomicWorkflowAndMetaWf($scope.initialMetaWf, $scope.initialWf);

							return;

						}

					});

				} else if ($scope.initialMetaWf) {

					angular.forEach($scope.metaworkflows, function(mw, key) {

						if (mw.wfId == $scope.initialMetaWf) {

							$scope.getMetaWorkflow(mw.wfId);

							return;

						}

					});

				} else if ($scope.metaworkflows.length > 0) {

					var id = $scope.metaworkflows[0].wfId;

					$scope.getMetaWorkflow(id);

				}

			} else {

				angular.forEach($scope.metaworkflows, function(value, key){

					if (value.wfId == $scope.currentMetaWorkflow.wfId) {

						$scope.currentMetaWorkflow = value;

					}

				});

			}

		}).error(function(err) {

			$scope.showError(err.message);

			$scope.hideSpinner();

		});	

	}

	$scope.executeWf = function(wfId) {

		$http.get('wf.start?id=' + wfId).success(function(data) {

			$scope.updateMetaWorkflowHistory();

			$('#monitorWfModal').modal('show');

		}).error(function(err) {

			$scope.showError(err.message);

		});

	};

	$scope.executeMetaWf = function() {

		$http.get('metawf.start?id=' + $scope.currentMetaWorkflow.wfId).success(function(data) {

			$scope.updateMetaWorkflowHistory();

			$('#monitorWfModal').modal('show');

		}).error(function(err) {

			$scope.showError(err.message);

		});

	};

	$scope.prepareMetaWfEdit = function() {

		$scope.tempMetaWorkflow = angular.copy($scope.currentMetaWorkflow);

	};

	$scope.saveCurrentMetaWf = function() {

		$scope.showSpinner();

		$http.defaults.headers.post["Content-Type"] = "application/x-www-form-urlencoded; charset=UTF-8";

		$http.post('wf_metaworkflow.edit', $.param({

			'json' : JSON.stringify($scope.tempMetaWorkflow)

		})).success(function(data) {

			$scope.hideSpinner();

			angular.forEach($scope.metaworkflows, function(value, key) {

				if (value.wfId == $scope.tempMetaWorkflow.wfId || value.id == $scope.tempMetaWorkflow.wfId) {

					value.name = $scope.tempMetaWorkflow.name;

				}

			});

			$scope.showNotification('MetaWorkflow updated !');

			$scope.getMetaWorkflow($scope.tempMetaWorkflow.wfId);

		}).error(function(err) {

			$scope.showError(err.message);

			$scope.hideSpinner();

		});

	};

	$scope.changeWfStartMode = function(wfId, val) {

		$scope.showSpinner();

		$http.get('wf_atomic_workflow.enable?start=' + val + "&id="	+ wfId).success(function(data) {

			$scope.hideSpinner();

			$scope.getMetaWorkflow($scope.currentMetaWorkflow.wfId);

		}).error(function(err) {

			$scope.showError(err.message);

			$scope.hideSpinner();

		});

	}

	$scope.listValidValuesForUserParam = function(func) {

		if (!$scope.validParamValuesCache[func]) {

			$scope.showSpinner();

			try {

				$scope.validParamValuesCache[func] = eval(func);

			} catch (e) {

				alert('Error evaluating function: ' + func);

				$scope.validParamValuesCache[func] = [];

			}

			$scope.hideSpinner();

		}

		return $scope.validParamValuesCache[func];

	}

	$scope.listWorkflowsUserParams = function(wfId) {

		$scope.showSpinner();

		$scope.currentUserParams = {};

		$http.get('workflow_user_params.json?wf=' + wfId)

        .success(

            function(data) {

            	$scope.hideSpinner();

            	$scope.currentUserParams = {

            		'wfId' : wfId,

            		'data' : data  

            	};

            }

        ).error(

            function(err) {

            	$scope.showError(err.message);

            	$scope.hideSpinner();

            }

        );

	}	

	$scope.saveWorkflowsUserParams = function() {

		$scope.showSpinner();

		$http.defaults.headers.post["Content-Type"] = "application/x-www-form-urlencoded; charset=UTF-8";

		$http.post('save_user_params.do', $.param({

			'wf' : $scope.currentUserParams.wfId,

			'params' : JSON.stringify($scope.currentUserParams.data)

		})).success(function(b) {

			$scope.hideSpinner();

			$scope.showNotification('Workflow updated !');

			$scope.getMetaWorkflow($scope.currentMetaWorkflow.wfId);

		}).error(function(err) {

			$scope.hideSpinner();

			$scope.showError(err.message);

		});

	}

	$scope.updateMetaWorkflowHistory = function() {

		$scope.updateHistory($scope.currentMetaWorkflow.innerWfs);

	};

	$scope.updateHistory = function(ids) {

		$scope.currentHistory = [];

		$scope.showSpinner();

		$http.defaults.headers.post["Content-Type"] = "application/x-www-form-urlencoded; charset=UTF-8";

		$http.post('wf_journal.find', $.param({

			'wfs' : JSON.stringify(ids)

		})).success(function(data) {

			$scope.hideSpinner();

			$scope.currentHistory = data;

			$('#monitorWfModal').modal('show')

		}).error(function(err) {

			$scope.hideSpinner();

			$scope.showError(err.message);

		});

	};

}

package eu.dnetlib.functionality.modular.ui.workflows.objects;

public class FilterElem {

	private String name;

	private String icon;

	private String value;

	public FilterElem(String name, String icon, String value) {

		super();

		this.name = name;

		this.icon = icon;

		this.value = value;

	}

	public String getName() {

		return name;

	}

	public void setName(String name) {

		this.name = name;

	}

	public String getIcon() {

		return icon;

	}

	public void setIcon(String icon) {

		this.icon = icon;

	}

	public String getValue() {

		return value;

	}

	public void setValue(String value) {

		this.value = value;

	}

}

var module = angular.module('workflowsUI', ['ngGrid']);

addCommonDirectives(module);

function workflowsCtrl($scope, $http, $sce) {

	$scope.currentSection = getSection();

	$scope.initialWf = getInitialWf();

	$scope.initialMetaWf = getInitialMetaWf();

	commonInitialize($scope, $http, $sce);

	wf_init($scope, $http, $sce);

	$scope.cloneMetaWf = function(id, name) {

		$scope.showSpinner();

		$http.get('clone_metaworkflow.do?id=' + id +'&name=' + name)

        .success(

            function(data) {

            	$scope.hideSpinner();

				$scope.reload(false);

				$scope.getMetaWorkflow(data);

            }

        ).error(

            function(err) {

            	$scope.showError(err.message);

            	$scope.hideSpinner();

            }

        );

	}	

	$scope.reload = function(loadFirstElement) {

		if ($scope.currentSection) { $scope.getWorkflows(loadFirstElement, 'section=' + $scope.currentSection) }

		else                       { $scope.hideSpinner(); }

	}

	$scope.reload(true);

}

var module = angular.module('workflowsUI', ['ngGrid']);

addCommonDirectives(module);

function workflowsCtrl($scope, $http, $sce) {

	commonInitialize($scope, $http, $sce);

	wf_init($scope, $http, $sce);

	$scope.getMetaWorkflow($scope.initialMetaWf);

}

package eu.dnetlib.functionality.modular.ui.workflows.values;

import java.io.File;

import java.util.List;

import java.util.Map;

import org.springframework.core.io.Resource;

import org.springframework.core.io.support.PathMatchingResourcePatternResolver;

import org.springframework.core.io.support.ResourcePatternResolver;

import com.google.common.collect.Lists;

import eu.dnetlib.msro.workflows.util.ValidNodeValuesFetcher;

public class ListFilesValues extends ValidNodeValuesFetcher {

	private final ResourcePatternResolver pathResolver = new PathMatchingResourcePatternResolver();

	@Override

	protected List<DnetParamValue> obtainValues(final Map<String, String> params) throws Exception {

		verifyParams(params, "path", "ext");

		final String pathTmp = params.get("path");

		final String path = pathTmp.startsWith("/") ? pathTmp : "/" + pathTmp;

		final List<DnetParamValue> values = Lists.newArrayList();

		for (Resource r : pathResolver.getResources("classpath*:" + path + "/*." + params.get("ext"))) {

			values.add(new DnetParamValue(path + File.separator + r.getFilename(), r.getFilename()));

		}

		return values;

	}

}

function validValues(arr) {

	var res = [];

	for (i=0; i<arr.length; i++) {

		res.push({'id': arr[i], 'name': arr[i]});

	}

	return res;

}

function intRange(from, to) {

	var res = [];

	for (i=from; i<to; i++) {

		res.push({'id': i, 'name': i});

	}

	return res;

}

function obtainValues(bean, params) {

	var strReturn = [];

	jQuery.ajax({

		type: "POST",

		url: "wf_obtainValidValues.list?bean=" + bean,

		async:false,

		data: params,

		dataType: "json",

		success: function(json) {

			strReturn = json;

		}

	});

	return strReturn;

}

function listFiles(path, ext)      { return obtainValues('listFiles', { 'path': path, 'ext': ext }); }

function listProfiles(type, xpath) { return obtainValues('listProfiles', { 'type': type, 'xpath': xpath }); }

package eu.dnetlib.functionality.modular.ui.workflows.util.functions;

import java.util.List;

import java.util.Map;

import org.apache.commons.lang.StringUtils;

import org.dom4j.Node;

import com.google.common.base.Function;

import com.google.common.collect.Lists;

import com.google.common.collect.Maps;

import eu.dnetlib.msro.workflows.util.WorkflowParam;

import eu.dnetlib.msro.workflows.util.WorkflowParamUI;

public class NodeToWorkflowParam implements Function<Node, WorkflowParam> {

	private Map<String, List<WorkflowParamUI>> mapUis = Maps.newHashMap();

	public NodeToWorkflowParam(final Map<String, List<WorkflowParamUI>> mapUis) {

		this.mapUis = mapUis;

	}

	@Override

	public WorkflowParam apply(final Node n) {

		final String key = n.valueOf("@name");

		final boolean required = "true".equalsIgnoreCase(n.valueOf("@required"));

		final String type = n.valueOf("@type");

		final String function = n.valueOf("@function");

		final String value = n.getText();

		final boolean userParam = "user".equals(n.valueOf("@managedBy"));

		final String category = n.valueOf("@category");

		final List<WorkflowParamUI> uis = calculateUis(category);

		return new WorkflowParam(key, value, required, userParam, type, function, uis);

	}

	private List<WorkflowParamUI> calculateUis(final String category) {

		if (!StringUtils.isEmpty(category) && mapUis.containsKey(category)) {

			return mapUis.get(category);

		} else {

			return Lists.newArrayList();

		}

	}

}

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"

	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

	<bean name="/ui/workflows.do"

		class="eu.dnetlib.functionality.modular.ui.workflows.controllers.WfEntryPointController"

		p:menu="Infrastructure Management" 

		p:title="Infrastructure Management"

		p:description="Infrastructure Workflows Management" 

		p:group="Infrastructure Management"

		p:validMenuEntry="false">

		<property name="permissionLevels">

			<set>

				<value>DS_ADMIN</value>

			</set>

		</property>

	</bean>

	<bean name="/ui/workflow_journal.do"

		class="eu.dnetlib.functionality.modular.ui.workflows.controllers.WfHistoryEntryPointController"

		p:menu="Workflow history" 

		p:title="Workflow history"

		p:description="Workflow history" 

		p:group="Logs"

		p:order="10"

		p:groupOrder="100">

		<property name="permissionLevels">

			<set>

				<value>WF_ADMIN</value>

				<value>DS_ADMIN</value>

			</set>

		</property>

	</bean>

	<bean name="/ui/workflow_timeline.do"

		class="eu.dnetlib.functionality.modular.ui.workflows.controllers.WfHistoryEntryPointController"

		p:menu="Workflow timeline" 

		p:title="Workflow timeline"

		p:description="Workflow timeline" 

		p:group="Logs"

		p:order="11"

		p:groupOrder="100">

		<property name="permissionLevels">

			<set>

				<value>WF_ADMIN</value>

				<value>DS_ADMIN</value>

			</set>

		</property>

	</bean>

	<bean name="infrastructureManagementMenu"

		class="eu.dnetlib.functionality.modular.ui.workflows.menu.InfrastructureManagementGroup"

		p:title="Infrastructure Management" 

		p:order="11"/>

</beans>

package eu.dnetlib.functionality.modular.ui.workflows.controllers;

import java.io.IOException;

import java.io.StringReader;

import java.util.ArrayList;

import java.util.Collections;

import java.util.Enumeration;

import java.util.List;

import java.util.Map;

import javax.annotation.Resource;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import org.apache.commons.io.IOUtils;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestParam;

import com.google.common.collect.Maps;

import com.google.gson.Gson;

import eu.dnetlib.functionality.modular.ui.AbstractAjaxController;

import eu.dnetlib.msro.workflows.util.ValidNodeValuesFetcher;

import eu.dnetlib.msro.workflows.util.ValidNodeValuesFetcher.DnetParamValue;

@Controller

public class DnetParamValuesController extends AbstractAjaxController {

	@Resource

	private List<ValidNodeValuesFetcher> validNodesFetchers;

	private static final Log log = LogFactory.getLog(DnetParamValuesController.class);

	@RequestMapping("/ui/**/wf_obtainValidValues.list")

	public void obtainValidValues(final HttpServletRequest request,

		final HttpServletResponse response,

		@RequestParam(value = "bean", required = true) final String bean) throws IOException {

		final ValidNodeValuesFetcher fetcher = findValidNodeValuesFetcher(bean);

		if (fetcher == null) {

			log.error("ValidNodeValuesFetcher not found: " + bean);

			sendResponse(response, new ArrayList<>());

		} else {

			final Map<String, String> params = findParams(request);

			sendResponse(response, fetcher.evaluate(params));

		}

	}

	private ValidNodeValuesFetcher findValidNodeValuesFetcher(final String bean) {

		for (final ValidNodeValuesFetcher fetcher : validNodesFetchers) {

			if (fetcher.getName().equals(bean)) { return fetcher; }

		}

		return null;

	}

	private Map<String, String> findParams(final HttpServletRequest request) {

		final Map<String, String> params = Maps.newHashMap();

		final Enumeration<?> e = request.getParameterNames();

		while (e.hasMoreElements()) {

			final String name = (String) e.nextElement();

			params.put(name, request.getParameter(name));

		}

		return params;

	}

	private void sendResponse(final HttpServletResponse response, final List<DnetParamValue> values) throws IOException {

		Collections.sort(values);

		response.setContentType("application/json;charset=UTF-8");

		IOUtils.copy(new StringReader(new Gson().toJson(values)), response.getOutputStream());

	}

}

package eu.dnetlib.functionality.modular.ui.workflows.controllers;

import java.io.StringWriter;

import java.net.URLEncoder;

import java.util.List;

import javax.annotation.Resource;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import org.apache.commons.lang.StringUtils;