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>dnet-parent</artifactId>

		<version>1.0.0</version>

		<relativePath />

	</parent>

	<modelVersion>4.0.0</modelVersion>

	<groupId>eu.dnetlib</groupId>

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

	<packaging>jar</packaging>

	<version>3.1.8</version>

	<scm>

		<developerConnection>scm:svn:https://svn.driver.research-infrastructures.eu/driver/dnet40/modules/dnet-msro-service/tags/dnet-msro-service-3.1.8</developerConnection>

	</scm>

	<dependencies>

		<dependency>

			<groupId>opensymphony</groupId>

			<artifactId>quartz</artifactId>

			<version>1.6.6</version>

		</dependency>

		<dependency>

			<groupId>eu.dnetlib</groupId>

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

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

		</dependency>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>cnr-resultset-service</artifactId>

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

		</dependency>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>cnr-data-utility-cleaner-rmi</artifactId>

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

		</dependency>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>cnr-resultset-client</artifactId>

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

		</dependency>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>dnet-download-service-rmi</artifactId>

			<version>[1.1.0,2.0.0)</version>

		</dependency>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>dnet-datasource-manager-rmi</artifactId>

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

		</dependency>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>cnr-blackboard-common</artifactId>

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

		</dependency>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>dnet-mongo-logging</artifactId>

			<version>[1.0.0,2.0.0)</version>

		</dependency>

		<dependency>

			<groupId>com.googlecode</groupId>

			<artifactId>sarasvati</artifactId>

			<version>1.0.3</version>

		</dependency>

		<dependency>

			<groupId>com.googlecode</groupId>

			<artifactId>sarasvati-visual</artifactId>

			<version>1.0.3</version>

		</dependency>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>dnet-modular-collector-service-rmi</artifactId>

			<version>[1.3.0,2.0.0)</version>

		</dependency>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>cnr-enabling-database-api</artifactId>

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

		</dependency>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>dnet-objectstore-rmi</artifactId>

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

		</dependency>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>dnet-data-transformation-service-rmi</artifactId>

			<version>[1.0.0,2.0.0)</version>

		</dependency>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>dnet-data-provision-rmi</artifactId>

			<version>[1.0.0,2.0.0)</version>

		</dependency>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>dnet-runtime</artifactId>

			<version>[1.0.0,2.0.0)</version>

		</dependency>

		<dependency>

			<groupId>javax.mail</groupId>

			<artifactId>mail</artifactId>

			<version>1.4</version>

		</dependency>

		<dependency>

			<groupId>org.codehaus.groovy</groupId>

			<artifactId>groovy-all</artifactId>

			<version>2.1.6</version>

		</dependency>

		<dependency>

			<groupId>junit</groupId>

			<artifactId>junit</artifactId>

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

			<scope>test</scope>

		</dependency>

		<dependency>

			<groupId>joda-time</groupId>

			<artifactId>joda-time</artifactId>

			<version>2.3</version>

		</dependency>

	</dependencies>

	<properties>

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

	</properties>

</project>

dnet.log.index.conf { "system:profileId" {}, "system:processId" {}, "system:isCompletedSuccessfully" {}, "system:profileFamily" {} }

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

<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

       xmlns:p="http://www.springframework.org/schema/p"

       xmlns:http="http://cxf.apache.org/transports/http/configuration" xmlns="http://www.springframework.org/schema/beans"

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

                                    http://cxf.apache.org/transports/http/configuration http://cxf.apache.org/schemas/configuration/http-conf.xsd">

	<bean id="wfNodeSelection" class="eu.dnetlib.msro.workflows.nodes.sel.SelectiveNode"

		scope="prototype" />

	<!-- IS -->

	<bean id="wfNodeValidateProfiles"

		class="eu.dnetlib.msro.workflows.nodes.is.ValidateProfilesJobNode"

		scope="prototype" />

	<!-- Datasources -->

	<bean id="wfNodeSetProviderInfo"

		class="eu.dnetlib.msro.workflows.nodes.info.SetProviderInfoJobNode"

		scope="prototype" />

	<bean id="wfNodeValidateDatasource"

		class="eu.dnetlib.msro.workflows.nodes.repohi.ValidateDatasourceJobNode"

		scope="prototype" />

	<bean id="wfNodeVerifyDatasource"

		class="eu.dnetlib.msro.workflows.nodes.repohi.VerifyDatasourceJobNode"

		scope="prototype" />

	<bean id="wfNodeCreateObjectStore"

		class="eu.dnetlib.msro.workflows.nodes.repohi.CreateObjectStoreJobNode"

		scope="prototype" />

	<bean id="wfNodeDropContentObjectStore"

	      class="eu.dnetlib.msro.workflows.nodes.objectStore.DropContentObjectStoreJobNode"

	      scope="prototype"/>

	<!-- Unpack -->

	<bean id="wfNodeUnpack" 

		class="eu.dnetlib.msro.workflows.nodes.unpack.UnpackJobNode"

		p:resultSetClientFactory-ref="resultSetClientFactory"

		p:iterableResultSetFactory-ref="iterableResultSetFactory" 

		scope="prototype" />

	<!--  ObjectStore -->

	<bean id="wfNodeDownloadIntoObjectStore"

		class="eu.dnetlib.msro.workflows.nodes.objectStore.DownloadIntoObjectStoreJobNode"

		scope="prototype" 

		p:processCountingResultSetFactory-ref="msroProcessCountingResultSetFactory"

		p:resultSetClientFactory-ref="resultSetClientFactory"

		p:iterableResultSetFactory-ref="iterableResultSetFactory"  />

	<bean id ="wfNodeDeleteObjectStore" class= "eu.dnetlib.msro.workflows.nodes.repobye.DeleteObjectStoreJobNode"

		scope="prototype" />

	<bean id="wfNodeRetrieveURLS"

		class="eu.dnetlib.msro.workflows.nodes.objectStore.RetrieveURLSJobNode"

		p:xpathMetadataId="${msro.wf.nodes.download.xpathMetadataId}"

		scope="prototype" />

	<!-- Download Service -->

	<bean id="wfNodeRetrieveMdStoreId" class ="eu.dnetlib.msro.workflows.nodes.objectStore.RetrieveMdStoreId"

		p:metadataFormat="${msro.wf.nodes.mdstoreSearch.format}"

		p:interpretation="${msro.wf.nodes.mdstoreSearch.interpretation}"

	/>

	<bean id ="wfNodeDownloadFromMetadata" class="eu.dnetlib.msro.workflows.nodes.download.DownloadFromMetadataJobNode"		

		scope="prototype" />

	<bean id ="wfNodeUpdateObjectStoreSize" class="eu.dnetlib.msro.workflows.nodes.objectStore.UpdateObjectStoreSizeJobNode"		

		scope="prototype" />

	<!-- Collector service -->

	<bean id="wfNodeCollectRecords"

		class="eu.dnetlib.msro.workflows.nodes.collect.CollectRecordsJobNode"

		scope="prototype" />

	<bean id="wfNodeDateRangeCollectRecords"

		class="eu.dnetlib.msro.workflows.nodes.collect.DateRangeCollectRecordsJobNode"

		scope="prototype" />

	<bean id="wfNodeFindDateRangeForIncrementalHarvesting" 

		class="eu.dnetlib.msro.workflows.nodes.collect.FindDateRangeForIncrementalHarvestingJobNode" 

		scope="prototype"/>

	<bean id="wfNodeMdBuilder"

		class="eu.dnetlib.msro.workflows.nodes.transform.MdBuilderJobNode"

		p:xsltMappedResultSetFactory-ref="xsltResultSetFactory"

		p:mdBuilderTemplateXslt="${msro.wf.nodes.mdbuilder.xslt.template}"

		scope="prototype" />

	<!-- Transform -->

	<bean id="wfNodeTransform"

		class="eu.dnetlib.msro.workflows.nodes.transform.TransformJobNode"

		scope="prototype" />

	<bean id="wfNodeApplyXslt"

		class="eu.dnetlib.msro.workflows.nodes.transform.ApplyXsltJobNode"

		p:xsltMappedResultSetFactory-ref="xsltResultSetFactory"

		scope="prototype" />	

	<bean id="wfNodeGroovy"

		class="eu.dnetlib.msro.workflows.nodes.transform.GroovyJobNode"

		p:mappedResultSetFactory-ref="xsltResultSetFactory"

		scope="prototype" />

	<bean id="wfNodeClean"

		class="eu.dnetlib.msro.workflows.nodes.transform.CleanJobNode"

		scope="prototype" />		

	<!-- Index -->

	<bean id="wfNodeUpdateIndex" class="eu.dnetlib.msro.workflows.nodes.index.UpdateIndexJobNode"

		scope="prototype" 

		p:layoutToRecordStylesheet="classpath:/eu/dnetlib/msro/workflows/xslt/layoutToRecordStylesheet.xsl"

		p:xsltRSFactory-ref="xsltResultSetFactory"

		p:processCountingResultSetFactory-ref="msroProcessCountingResultSetFactory"

		p:defaultIndexId="${service.msro.index.defaultIndex}"  />

	<bean id="wfNodeCreateIndex" class="eu.dnetlib.msro.workflows.nodes.index.CreateIndexJobNode"

		scope="prototype" p:defaultBackendId="${service.msro.index.defaultIndex}" />

	<bean id="wfNodeDeleteIndex" class="eu.dnetlib.msro.workflows.nodes.index.DeleteIndexJobNode"

		scope="prototype" p:defaultIndexId="${service.msro.index.defaultIndex}" />	

	<bean id="wfNodePrepareCreateIndex"

		class="eu.dnetlib.msro.workflows.nodes.index.PrepareCreateIndexJobNode"

		scope="prototype" />

	<!-- Database -->

	<bean id="wfNodeUpdateDb" class="eu.dnetlib.msro.workflows.nodes.db.UpdateDbJobNode"

		scope="prototype" p:processCountingResultSetFactory-ref="msroProcessCountingResultSetFactory" />

	<bean id="wfNodeQueryDb" class="eu.dnetlib.msro.workflows.nodes.db.QueryDbJobNode"

		scope="prototype" />

	<bean id="wfNodeExecuteSql" class="eu.dnetlib.msro.workflows.nodes.db.ExecuteSqlJobNode"

		scope="prototype" />

	<bean id="wfNodeExecuteSqlFromEnv" class="eu.dnetlib.msro.workflows.nodes.db.ExecuteSqlFromEnvJobNode"

	      scope="prototype"/>

	<!-- MDStore -->

	<bean id="wfNodeCreateMDStore"

		class="eu.dnetlib.msro.workflows.nodes.repohi.CreateMDStoreJobNode"

		scope="prototype" />

	<bean id="wfNodeStoreMDStoreRecords"

		class="eu.dnetlib.msro.workflows.nodes.mdstore.StoreMDStoreRecordsJobNode"

		scope="prototype" p:processCountingResultSetFactory-ref="msroProcessCountingResultSetFactory" />

	<bean id="wfNodeFetchMDStoreRecords"

		class="eu.dnetlib.msro.workflows.nodes.mdstore.FetchMDStoreRecordsJobNode"

		scope="prototype" />

	<bean id="wfNodeFetchMultipleMDStoreRecords"

		class="eu.dnetlib.msro.workflows.nodes.mdstore.FetchMultipleMDStores"

		scope="prototype" />

	<bean id="wfNodeMDStoreToApiExtraField"

		class="eu.dnetlib.msro.workflows.nodes.info.MDStoreToApiExtraFieldJobNode"

		scope="prototype" />

	<bean id="wfNodeObjectStoreToApiExtraField"

		class="eu.dnetlib.msro.workflows.nodes.info.ObjectStoreToApiExtraFieldJobNode"

		scope="prototype" />

	<bean id="wfNodeRemoveApiExtraFields"

		class="eu.dnetlib.msro.workflows.nodes.info.RemoveApiExtraFieldsJobNode"

		scope="prototype" />

	<bean id="wfNodeSetFormatInfo"

		class="eu.dnetlib.msro.workflows.nodes.SetFormatInfoJobNode"

		scope="prototype" />

	<bean id="wfNodeSetEnvParameter"

		class="eu.dnetlib.msro.workflows.nodes.SetEnvParameterJobNode"

		scope="prototype" />

</beans>

package eu.dnetlib.msro.workflows.nodes.transform;

import javax.annotation.Resource;

import javax.xml.ws.wsaddressing.W3CEndpointReference;

import com.googlecode.sarasvati.Arc;

import com.googlecode.sarasvati.NodeToken;

import eu.dnetlib.data.transformation.service.rmi.TransformationService;

import eu.dnetlib.enabling.locators.UniqueServiceLocator;

import eu.dnetlib.enabling.resultset.client.utils.EPRUtils;

import eu.dnetlib.msro.workflows.nodes.SimpleJobNode;

public class TransformJobNode extends SimpleJobNode {

	private String inputEprParam;

	private String outputEprParam;

	private String ruleId;

	@Resource

	private UniqueServiceLocator serviceLocator;

	@Override

	protected String execute(final NodeToken token) throws Exception {

		final W3CEndpointReference inputEpr = new EPRUtils().getEpr(token.getEnv().getAttribute(inputEprParam));

		final W3CEndpointReference outputEpr = serviceLocator.getService(TransformationService.class).transform(ruleId, inputEpr);

		token.getEnv().setAttribute(outputEprParam, outputEpr.toString());

		return Arc.DEFAULT_ARC;

	}

	public String getInputEprParam() {

		return inputEprParam;

	}

	public void setInputEprParam(final String inputEprParam) {

		this.inputEprParam = inputEprParam;

	}

	public String getOutputEprParam() {

		return outputEprParam;

	}

	public void setOutputEprParam(final String outputEprParam) {

		this.outputEprParam = outputEprParam;

	}

	public String getRuleId() {

		return ruleId;

	}

	public void setRuleId(final String ruleId) {

		this.ruleId = ruleId;

	}

}

msro.wf.ui.dataprovider.protocols = [ {name: 'OAI', value: 'OAI', icon: 'icon-book'}, {name: 'FTP', value: 'FTP', icon: 'icon-download-alt'}, {name: 'local dir', value: 'filesystem', icon: 'icon-folder-open'}, {name: 'local file', value: 'file', icon: 'icon-file'}, {name: 'http', value: 'http', icon: 'icon-arrow-down'} ]

msro.wf.ui.dataprovider.typologies= [ {name: 'Publication repository', value: 'pubsrepository', icon: 'icon-hdd'}, {name: 'Dataset repository', value: 'datarepository', icon: 'icon-hdd'}, {name: 'Aggregator', value: 'AGGREGATOR', icon: 'icon-hdd'}, {name: 'Entity registry', value: 'entityregistry', icon: 'icon-hdd'} ]

msro.wf.logger.name = wf_logs

msro.wf.logger.index.conf = classpath:/eu/dnetlib/msro/service/logIndex.conf

msro.wf.registry.maxSize = 20

msro.wf.max.running = 5

msro.wf.scheduler.startDelay = 60000

msro.wf.scheduler.repeatInterval = 600000

msro.wf.scheduler.window.size = 7200000

msro.wf.mail.thread.startDelay = 60000

msro.wf.mail.thread.repeatInterval = 60000

msro.wf.mail.from = dnet-noreply@research-infrastructures.eu

msro.wf.mail.fromName = D-NET Workflow Manager

msro.wf.mail.cc = michele.artini@isti.cnr.it

msro.wf.mail.smtp.host = localhost

msro.wf.mail.smtp.port = 587

msro.wf.mail.smtp.user = 

msro.wf.mail.smtp.password =

msro.wf.nodes.mdstoreSearch.format = DMF

msro.wf.nodes.mdstoreSearch.interpretation = cleaned

msro.wf.nodes.download.xpathMetadataId = //*[local-name()='objIdentifier']

service.msro.index.defaultIndex = solr

msro.wf.mail.message.baseUrl = http://localhost:8280/app/mvc/ui

msro.wf.mail.message.infrastructure= ${container.hostname}

#This property is the default value used by the bean 'mdBuilderTemplateXslt' and injected in MdBuilderJobNode node ~ A.M.

msro.wf.nodes.mdbuilder.xslt.template = classpath:/eu/dnetlib/msro/workflows/xslt/mdBuilder.xslt.st

package eu.dnetlib.msro.workflows.nodes.transform;

import java.util.Map;

import eu.dnetlib.miscutils.functional.UnaryFunction;

public abstract class GroovyUnaryFunction implements UnaryFunction<String, String> {

	private Map<String, String> params;

	@Override

	abstract public String evaluate(String input);

	public Map<String, String> getParams() {

		return params;

	}

	public void setParams(final Map<String, String> params) {

		this.params = params;

	}

}

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

<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

       xmlns:jaxws="http://cxf.apache.org/jaxws" xmlns:sec="http://cxf.apache.org/configuration/security"

       xmlns:wsa="http://cxf.apache.org/ws/addressing" xmlns:p="http://www.springframework.org/schema/p"

       xmlns:http="http://cxf.apache.org/transports/http/configuration" xmlns:t="http://dnetlib.eu/springbeans/t"

       xmlns:template="http://dnetlib.eu/springbeans/template" xmlns="http://www.springframework.org/schema/beans"

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

                                    http://cxf.apache.org/ws/addressing http://cxf.apache.org/schemas/ws-addr-conf.xsd

                                    http://cxf.apache.org/configuration/security http://cxf.apache.org/schemas/configuration/security.xsd

                                    http://cxf.apache.org/transports/http/configuration http://cxf.apache.org/schemas/configuration/http-conf.xsd

                            http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd

                            http://dnetlib.eu/springbeans/template http://dnetlib.eu/springbeans/template.xsd">

	<!-- beans -->

	<bean id="msroService" class="eu.dnetlib.msro.MSROServiceImpl"

		init-method="start" destroy-method="stop" 

		p:notificationHandler-ref="msroNotificationHandlerChain"

		p:processRegistry-ref="graphProcessRegistry" />

	<bean id="msroNotificationHandlerChain"

		class="eu.dnetlib.enabling.tools.blackboard.NotificationHandlerChainImpl">

		<property name="handlerExecutor">

			<bean class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"

				p:corePoolSize="32" p:keepAliveSeconds="3600" p:queueCapacity="0" />

		</property>

		<property name="handlers">

			<list>

				<ref bean="msroBlackboardNotificationHandler" />

			</list>

		</property>

	</bean>

	<bean id="wfDependencyLauncherNotificationHandler" class="eu.dnetlib.msro.notification.WfDependencyLauncherNotificationHandler"

		p:enabled="true" p:topicExpression="UPDATE/WorkflowDSResourceType/*/RESOURCE_PROFILE/BODY/STATUS/LAST_EXECUTION_DATE" />

	<alias name="cxfEndpointReferenceBuilder" alias="eprBuilder" />

	<bean id="msroWfEngine" class="eu.dnetlib.msro.workflows.sarasvati.loader.InjectableMemEngine">

		<property name="graphFactory">

			<bean class="eu.dnetlib.msro.workflows.sarasvati.loader.InjectableMemGraphFactory">

				<property name="nodeFactory">

					<bean class="eu.dnetlib.msro.workflows.sarasvati.loader.InjectableNodeFactory"

						p:beanNamePrefix="wfNode" />				

				</property>

			</bean>

		</property>

	</bean>

	<bean id="graphProcessRegistry" class="eu.dnetlib.msro.workflows.sarasvati.registry.GraphProcessRegistry" 

		p:maxSize="${msro.wf.registry.maxSize}" />

	<bean id="sarasvatiGraphLoader" 

		class="eu.dnetlib.msro.workflows.sarasvati.loader.GraphLoader" 

		p:engine-ref="msroWfEngine" /> 

	<bean id="sarasvatiWorkflowExecutor" class="eu.dnetlib.msro.workflows.sarasvati.loader.WorkflowExecutor"

	      p:engine-ref="msroWfEngine"

	      p:graphLoader-ref="sarasvatiGraphLoader"

	      p:graphProcessRegistry-ref="graphProcessRegistry"

	      p:profileToSarasvatiConverter-ref="msroProfileToSarasvatiConverter"

	      p:maxRunningWorkflows="${msro.wf.max.running}"

	      init-method="init"/>

	<bean id="workflowsConstants" class="eu.dnetlib.msro.workflows.util.WorkflowsConstants"

		init-method="init" 

		p:dataproviderProtocolsJson="${msro.wf.ui.dataprovider.protocols}" 

		p:dataproviderTypologiesJson="${msro.wf.ui.dataprovider.typologies}" />

	<bean id="msroProfileToSarasvatiConverter" class="eu.dnetlib.msro.workflows.sarasvati.loader.ProfileToSarasvatiConverter"

	 	p:xslt="classpath:/eu/dnetlib/msro/workflows/xslt/wf_profile2sarasvati.xslt" />

	<bean id="msroBlackboardNotificationHandler"

		class="eu.dnetlib.enabling.tools.blackboard.DeletingBlackboardNotificationHandler"

		p:blackboardHandler-ref="blackboardClientHandler" />

	<bean id="datasourceMetaWorkflowFactory" class="eu.dnetlib.msro.workflows.metawf.DatasourceMetaWorkflowFactory"/>

	<bean id="msroProcessCountingResultSetFactory" 

		class="eu.dnetlib.msro.workflows.resultset.ProcessCountingResultSetFactory"

		p:resultSetFactory-ref="openResultSetFactory" p:serviceResolver-ref="serviceResolver" />

	<bean t:id="msroJobSchedulerAccessor"

		class="org.springframework.scheduling.quartz.SchedulerAccessorBean"

		p:scheduler-ref="jobScheduler">

		<property name="triggers">

			<list>

				<bean class="org.springframework.scheduling.quartz.SimpleTriggerBean"

					p:startDelay="6000" p:repeatCount="0">

					<property name="jobDetail">

						<bean class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"

							p:targetObject-ref="msroBlackboardSubscriber" p:targetMethod="subscribeAll" />

					</property>

				</bean>

				<bean class="org.springframework.scheduling.quartz.SimpleTriggerBean"

					p:startDelay="${msro.wf.scheduler.startDelay}" p:repeatInterval="${msro.wf.scheduler.repeatInterval}">

					<property name="jobDetail">

						<bean class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"

							p:targetObject-ref="msroScheduledWorkflowLauncher" p:targetMethod="verifySheduledWorkflows" />

					</property>

				</bean>

				<bean class="org.springframework.scheduling.quartz.SimpleTriggerBean"

					p:startDelay="${msro.wf.mail.thread.startDelay}" p:repeatInterval="${msro.wf.mail.thread.repeatInterval}">

					<property name="jobDetail">

						<bean class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"

							p:targetObject-ref="msroMailDispatcher" p:targetMethod="processMailQueue" />

					</property>

				</bean>

			</list>

		</property>

	</bean>		

	<bean id="msroBlackboardSubscriber" class="eu.dnetlib.msro.workflows.nodes.blackboard.BlackboardSubscriber"

		p:endpoint-ref="msroServiceEndpoint" />

	<bean id="msroScheduledWorkflowLauncher" class="eu.dnetlib.msro.cron.ScheduledWorkflowLauncher"

		p:graphProcessRegistry-ref="graphProcessRegistry" p:workflowExecutor-ref="sarasvatiWorkflowExecutor"

		p:windowSize="${msro.wf.scheduler.window.size}" />

	<bean id="msroWorkflowLogger" class="eu.dnetlib.common.logging.DnetLogger"

		p:name="${msro.wf.logger.name}" p:indexConf="${msro.wf.logger.index.conf}" />

	<bean id="msroMailDispatcher" class="eu.dnetlib.msro.notification.EmailDispatcher"

		p:from="${msro.wf.mail.from}" p:fromName="${msro.wf.mail.fromName}" p:cc="${msro.wf.mail.cc}"

		p:smtpHost="${msro.wf.mail.smtp.host}" p:smtpPort="${msro.wf.mail.smtp.port}" p:smtpUser="${msro.wf.mail.smtp.user}" p:smtpPassword="${msro.wf.mail.smtp.password}" 

		p:baseUrl="${msro.wf.mail.message.baseUrl}" p:infrastructure="${msro.wf.mail.message.infrastructure}"/>

	<!-- System nodes -->

	<bean id="wfNodeSuccess" class="eu.dnetlib.msro.workflows.nodes.SuccessFailureNode" p:success="true" scope="prototype" />

	<bean id="wfNodeFailure" class="eu.dnetlib.msro.workflows.nodes.SuccessFailureNode" p:success="false" scope="prototype" />

	<!-- REPO_HI and REPO_BYE -->

	<bean id="wfNodeRegisterMetaWf"	class="eu.dnetlib.msro.workflows.nodes.repohi.RegisterMetaWfJobNode" scope="prototype" />

	<bean id="wfNodeUpdateMetaWf" class="eu.dnetlib.msro.workflows.nodes.repohi.UpdateMetaWfJobNode" scope="prototype" />

	<bean id="wfNodeUpdateMetaWfStatus"	class="eu.dnetlib.msro.workflows.nodes.repohi.UpdateMetaWfStatusJobNode" scope="prototype" />

	<bean id="wfNodeDeleteMetaWf" class="eu.dnetlib.msro.workflows.nodes.repobye.DeleteMetaWfJobNode" scope="prototype" />

	<bean id="wfNodeDeleteMDStore" class="eu.dnetlib.msro.workflows.nodes.repobye.DeleteMDStoreJobNode" scope="prototype" />

	<!-- endpoints -->

	<jaxws:endpoint id="msroServiceEndpoint" implementor="#msroService"

		implementorClass="eu.dnetlib.msro.rmi.MSROService"

		address="/msro" />

	<template:instance name="serviceRegistrationManager"

		t:serviceRegistrationManagerClass="eu.dnetlib.enabling.tools.registration.ValidatingServiceRegistrationManagerImpl"

		t:name="msroServiceRegistrationManager" t:service="msroService"

		t:endpoint="msroServiceEndpoint" t:jobScheduler="jobScheduler" />

</beans>

package eu.dnetlib.msro.workflows.nodes.info;

import java.io.StringReader;

import java.util.Map;

import javax.annotation.Resource;

import org.dom4j.Document;

import org.dom4j.Node;

import org.dom4j.io.SAXReader;

import com.google.common.collect.Maps;

import com.googlecode.sarasvati.Arc;

import com.googlecode.sarasvati.NodeToken;

import eu.dnetlib.enabling.datasources.rmi.DatasourceManagerService;

import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService;

import eu.dnetlib.enabling.locators.UniqueServiceLocator;

import eu.dnetlib.msro.workflows.nodes.SimpleJobNode;

public class MDStoreToApiExtraFieldJobNode extends SimpleJobNode {

	private String mdId;

	private String datasourceId;

	private String datasourceInterface;

	private String extraFieldForTotal;

	private String extraFieldForDate;

	private String extraFieldForMdId;

	@Resource

	private UniqueServiceLocator serviceLocator;

	@Override

	protected String execute(final NodeToken token) throws Exception {

		final String xq = "for $x in collection('/db/DRIVER/MDStoreDSResources/MDStoreDSResourceType') " +

				"where $x//RESOURCE_IDENTIFIER/@value='" + mdId + "' " +

				"return concat($x//NUMBER_OF_RECORDS, ' @=@ ', $x//LAST_STORAGE_DATE)";

		final String s = serviceLocator.getService(ISLookUpService.class).getResourceProfileByQuery(xq);

		final String[] arr = s.split(" @=@ ");

		final Map<String, String> map = getCurrentExtraFields(datasourceId, datasourceInterface);

		map.put(extraFieldForTotal, arr[0].trim());

		map.put(extraFieldForDate, arr[1].trim());

		map.put(extraFieldForMdId, mdId);

		serviceLocator.getService(DatasourceManagerService.class).bulkUpdateApiExtraFields(datasourceId, datasourceInterface, map);

		return Arc.DEFAULT_ARC;

	}

	private Map<String, String> getCurrentExtraFields(final String repoId, final String ifaceId) throws Exception {

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

		final String profile = serviceLocator.getService(ISLookUpService.class).getResourceProfile(repoId);

		final SAXReader reader = new SAXReader();

		final Document doc = reader.read(new StringReader(profile));

		final Node ifcNode = doc.selectSingleNode("//INTERFACE[@id='" + ifaceId + "']");

		if (ifcNode != null) {

			for (Object o : ifcNode.selectNodes("./INTERFACE_EXTRA_FIELD")) {

				res.put(((Node) o).valueOf("@name"), ((Node) o).getText());

			}

		}

		return res;

	}

	public String getMdId() {

		return mdId;

	}

	public void setMdId(final String mdId) {

		this.mdId = mdId;

	}

	public String getDatasourceId() {

		return datasourceId;

	}

	public void setDatasourceId(final String datasourceId) {

		this.datasourceId = datasourceId;

	}

	public String getDatasourceInterface() {

		return datasourceInterface;

	}

	public void setDatasourceInterface(final String datasourceInterface) {

		this.datasourceInterface = datasourceInterface;

	}

	public String getExtraFieldForTotal() {

		return extraFieldForTotal;

	}

	public void setExtraFieldForTotal(final String extraFieldForTotal) {

		this.extraFieldForTotal = extraFieldForTotal;

	}

	public String getExtraFieldForDate() {

		return extraFieldForDate;

	}

	public void setExtraFieldForDate(final String extraFieldForDate) {

		this.extraFieldForDate = extraFieldForDate;

	}

	public String getExtraFieldForMdId() {

		return extraFieldForMdId;

	}

	public void setExtraFieldForMdId(final String extraFieldForMdId) {

		this.extraFieldForMdId = extraFieldForMdId;

	}

}

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

<RESOURCE_PROFILE>

	<HEADER>

		<RESOURCE_IDENTIFIER value="" />

		<RESOURCE_TYPE value="MetaWorkflowDSResourceType" />

		<RESOURCE_KIND value="MetaWorkflowDSResources" />

		<RESOURCE_URI value="" />

		<DATE_OF_CREATION value="2006-05-04T18:13:51.0Z" />

	</HEADER>

	<BODY>

		<DATAPROVIDER id="$dsId$" interface="$ifaceId$">$dsName$</DATAPROVIDER>

		<METAWORKFLOW_NAME family="$wfFamily$">$wfName$</METAWORKFLOW_NAME>

		<METAWORKFLOW_DESCRIPTION></METAWORKFLOW_DESCRIPTION>

		<METAWORKFLOW_SECTION>$section$</METAWORKFLOW_SECTION>

		<ADMIN_EMAIL>$adminEmail$</ADMIN_EMAIL>

		<CONFIGURATION status="$status$" />

		<SCHEDULING enabled="false">

			<CRON>0 0 0 ? * *</CRON>

			<MININTERVAL>10080</MININTERVAL>

		</SCHEDULING>

	</BODY>

</RESOURCE_PROFILE>

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

<RESOURCE_PROFILE>

    <HEADER>

        <RESOURCE_IDENTIFIER value=""/>

        <RESOURCE_TYPE value="WorkflowDSResourceType"/>

        <RESOURCE_KIND value="WorkflowDSResources"/>

        <RESOURCE_URI value=""/>

        <DATE_OF_CREATION value="2006-05-04T18:13:51.0Z"/>

    </HEADER>

    <BODY>

        <WORKFLOW_NAME>$name$</WORKFLOW_NAME>

		<WORKFLOW_TYPE>$type$</WORKFLOW_TYPE>

		<WORKFLOW_PRIORITY>$priority$</WORKFLOW_PRIORITY>

        <CONFIGURATION start="$startMode$">

        	$conf$

        </CONFIGURATION>

        <STATUS />

    </BODY>

</RESOURCE_PROFILE>

package eu.dnetlib.msro.workflows.nodes.info;

import java.io.StringReader;

import java.util.Map;

import javax.annotation.Resource;

import org.dom4j.Document;

import org.dom4j.Node;

import org.dom4j.io.SAXReader;

import com.google.common.collect.Maps;

import com.googlecode.sarasvati.Arc;

import com.googlecode.sarasvati.NodeToken;

import eu.dnetlib.enabling.datasources.rmi.DatasourceManagerService;

import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService;

import eu.dnetlib.enabling.locators.UniqueServiceLocator;

import eu.dnetlib.msro.workflows.nodes.SimpleJobNode;

public class ObjectStoreToApiExtraFieldJobNode extends SimpleJobNode {

	private String objId;

	private String datasourceId;

	private String datasourceInterface;

	private String extraFieldForTotal;

	private String extraFieldForDate;

	private String extraFieldForObjId;

	@Resource

	private UniqueServiceLocator serviceLocator;

	@Override

	protected String execute(final NodeToken token) throws Exception {

		final String xq = "for $x in collection('/db/DRIVER/ObjectStoreDSResources/ObjectStoreDSResourceType') " + "where $x//RESOURCE_IDENTIFIER/@value='"

				+ objId + "' " + "return concat($x//COUNT_STORE, ' @=@ ', $x//LAST_STORAGE_DATE)";

		final String s = serviceLocator.getService(ISLookUpService.class).getResourceProfileByQuery(xq);

		final String[] arr = s.split(" @=@ ");

		final Map<String, String> map = getCurrentExtraFields(datasourceId, datasourceInterface);

		map.put(extraFieldForTotal, arr[0].trim());

		map.put(extraFieldForDate, arr[1].trim());

		map.put(extraFieldForObjId, objId);

		serviceLocator.getService(DatasourceManagerService.class).bulkUpdateApiExtraFields(datasourceId, datasourceInterface, map);

		return Arc.DEFAULT_ARC;

	}

	private Map<String, String> getCurrentExtraFields(final String repoId, final String ifaceId) throws Exception {

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

		final String profile = serviceLocator.getService(ISLookUpService.class).getResourceProfile(repoId);

		final SAXReader reader = new SAXReader();

		final Document doc = reader.read(new StringReader(profile));

		final Node ifcNode = doc.selectSingleNode("//INTERFACE[@id='" + ifaceId + "']");

		if (ifcNode != null) {

			for (Object o : ifcNode.selectNodes("./INTERFACE_EXTRA_FIELD")) {

				res.put(((Node) o).valueOf("@name"), ((Node) o).getText());

			}

		}

		return res;

	}

	public String getDatasourceId() {

		return datasourceId;

	}

	public void setDatasourceId(final String datasourceId) {

		this.datasourceId = datasourceId;

	}

	public String getDatasourceInterface() {

		return datasourceInterface;

	}

	public void setDatasourceInterface(final String datasourceInterface) {

		this.datasourceInterface = datasourceInterface;

	}

	public String getExtraFieldForTotal() {

		return extraFieldForTotal;

	}

	public void setExtraFieldForTotal(final String extraFieldForTotal) {

		this.extraFieldForTotal = extraFieldForTotal;

	}

	public String getExtraFieldForDate() {

		return extraFieldForDate;

	}

	public void setExtraFieldForDate(final String extraFieldForDate) {

		this.extraFieldForDate = extraFieldForDate;

	}

	/**

	 * @return the objId

	 */

	public String getObjId() {

		return objId;

	}

	/**

	 * @param objId

	 *            the objId to set

	 */

	public void setObjId(final String objId) {

		this.objId = objId;

	}

	/**

	 * @return the extraFieldForObjId

	 */

	public String getExtraFieldForObjId() {

		return extraFieldForObjId;

	}

	/**

	 * @param extraFieldForObjId

	 *            the extraFieldForObjId to set

	 */

	public void setExtraFieldForObjId(final String extraFieldForObjId) {

		this.extraFieldForObjId = extraFieldForObjId;

	}

}

<STATUS>

	<LAST_EXECUTION_ID>$procId$</LAST_EXECUTION_ID>

	<LAST_EXECUTION_DATE>$date$</LAST_EXECUTION_DATE>

	$if(error)$

		<LAST_EXECUTION_STATUS>FAILURE</LAST_EXECUTION_STATUS>

		<LAST_EXECUTION_ERROR>$error$</LAST_EXECUTION_ERROR>

	$else$

		<LAST_EXECUTION_STATUS>SUCCESS</LAST_EXECUTION_STATUS>

		<LAST_EXECUTION_ERROR />

	$endif$

	$params.keys:{k|<LAST_EXECUTION_OUTPUT name='$k$'>$params.(k)$</LAST_EXECUTION_OUTPUT>}$

</STATUS>

package eu.dnetlib.msro.workflows.nodes.db;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.springframework.beans.factory.annotation.Required;

import com.googlecode.sarasvati.NodeToken;

import eu.dnetlib.enabling.database.rmi.DatabaseService;

import eu.dnetlib.enabling.tools.blackboard.BlackboardJob;

import eu.dnetlib.msro.workflows.nodes.BlackboardJobNode;

import eu.dnetlib.msro.workflows.nodes.ProgressJobNode;

import eu.dnetlib.msro.workflows.resultset.ProcessCountingResultSetFactory;

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

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

public class UpdateDbJobNode extends BlackboardJobNode implements ProgressJobNode {

	private String db;

	private String dbParam;

	private String eprParam;

	private ProcessCountingResultSetFactory processCountingResultSetFactory;

	private ResultsetProgressProvider progressProvider;

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

	@Override

	protected String obtainServiceId(final NodeToken token) {

		return getServiceLocator().getServiceId(DatabaseService.class);

	}

	@Override

	protected void prepareJob(final BlackboardJob job, final NodeToken token) throws Exception {

		if (db == null || db.isEmpty()) {

			db = token.getEnv().getAttribute(getDbParam());

		}

		log.info("preparing blackboard job to update DB: " + db);

		final String epr = token.getEnv().getAttribute(getEprParam());

		this.progressProvider = processCountingResultSetFactory.createProgressProvider(token.getProcess(), epr);

		job.setAction("IMPORT");

		job.getParameters().put("db", db);

		job.getParameters().put("epr", this.progressProvider.getEpr().toString());

	}

	@Override

	public ProgressProvider getProgressProvider() {

		return progressProvider;

	}

	public String getDb() {

		return db;

	}

	public void setDb(final String db) {

		this.db = db;

	}

	public String getEprParam() {

		return eprParam;

	}

	public void setEprParam(final String eprParam) {

		this.eprParam = eprParam;

	}

	public ProcessCountingResultSetFactory getProcessCountingResultSetFactory() {

		return processCountingResultSetFactory;

	}

	@Required

	public void setProcessCountingResultSetFactory(final ProcessCountingResultSetFactory processCountingResultSetFactory) {

		this.processCountingResultSetFactory = processCountingResultSetFactory;

	}

	public String getDbParam() {

		return dbParam;

	}

	public void setDbParam(final String dbParam) {

		this.dbParam = dbParam;

	}

}

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

<xsl:stylesheet version="1.0" xmlns:xsl="http://www.w3.org/1999/XSL/Transform"

    xmlns:datetime="http://exslt.org/dates-and-times" xmlns:exslt="http://exslt.org/common"

    xmlns:oai="http://www.openarchives.org/OAI/2.0/"

    xmlns:dnet="eu.dnetlib.miscutils.functional.xml.DnetXsltFunctions"

    xmlns:dri="http://www.driver-repository.eu/namespace/dri"

    exclude-result-prefixes="xsl datetime exslt dnet">

    <xsl:variable name="status" select="/*[local-name() = 'record']/*[local-name() = 'header']/@status" />

    <xsl:template match="/">

        <oai:record xmlns:oai="http://www.openarchives.org/OAI/2.0/"

            xmlns:dri="http://www.driver-repository.eu/namespace/dri"

            xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">

            <xsl:variable name="datestamp" select="datetime:dateTime()" />

            <xsl:variable name="evaluatedMetadataId" select="normalize-space($xpath$)" />

			<!-- Patch OAI header or create ex-novo if not oai -->

            <oai:header>

                <xsl:if test="\$status">

                    <xsl:attribute name="status" >

                        <xsl:value-of select="\$status"/>

                    </xsl:attribute>

                </xsl:if>

                <xsl:if test="not(.//dri:objIdentifier)">

                	<xsl:if test="\$evaluatedMetadataId != ''">

	                    <dri:objIdentifier><xsl:value-of select="concat('$namespacePrefix$::', dnet:md5(\$evaluatedMetadataId))"/></dri:objIdentifier>

                	</xsl:if>

                </xsl:if>

                <xsl:if test="not(.//dri:recordIdentifier)">

                    <dri:recordIdentifier><xsl:value-of select="\$evaluatedMetadataId"/></dri:recordIdentifier>

                </xsl:if>

                <xsl:if test="not(.//dri:dateOfCollection)">

                    <dri:dateOfCollection><xsl:value-of select="\$datestamp"/></dri:dateOfCollection>

                </xsl:if>

				<xsl:if test="not(.//dri:repositoryId)">

                    <dri:repositoryId>$datasourceId$</dri:repositoryId>

                </xsl:if>

                <xsl:if test="not(.//dri:datasourceprefix)">

                    <dri:datasourceprefix>$namespacePrefix$</dri:datasourceprefix>

                </xsl:if>

				<!-- Bulk copy of old header -->

                <xsl:for-each select="/*[local-name() = 'record']/*[local-name() = 'header']/*">

                    <xsl:copy-of select="."/>

                </xsl:for-each>

            </oai:header>

			<!-- Handle metadata block -->

            <xsl:choose>

            	<!-- If OAI then copy copy the metadata block along -->

                <xsl:when test="count(/*[local-name() = 'record']/*[local-name() = 'metadata']) &gt; 0">

                    <xsl:copy-of select="/*[local-name() = 'record']/*[local-name() = 'metadata']"/>

                </xsl:when>

                <!-- If OAI copy in bulk the metadata block -->

                <xsl:when test="\$status = 'deleted'" />

                <!-- If not-OAI copy ALL the record inside metadata block -->

                <xsl:otherwise>

                    <oai:metadata>

                        <xsl:copy-of select="."/>

                    </oai:metadata>

                </xsl:otherwise>

            </xsl:choose>

            <!-- Handle oai:about block -->

            <oai:about>

                <provenance xmlns="http://www.openarchives.org/OAI/2.0/provenance" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.openarchives.org/OAI/2.0/provenance http://www.openarchives.org/OAI/2.0/provenance.xsd">

  					<originDescription harvestDate="{\$datestamp}" altered="true">

	    				<baseURL>$baseurl$</baseURL>

	    				<identifier><xsl:value-of select="//*[local-name()='header']/*[local-name()='identifier']"/></identifier>

	    				<datestamp><xsl:value-of select="//*[local-name()='header']/*[local-name()='datestamp']"/></datestamp>

	    				<metadataNamespace>$metadatanamespace$</metadataNamespace>

	    				<xsl:copy-of select="//*[local-name()='provenance']/*[local-name() = 'originDescription']"/>

  					</originDescription>

				</provenance>

			</oai:about>

        </oai:record>

    </xsl:template>

</xsl:stylesheet>

package eu.dnetlib.msro.workflows.nodes;

import java.util.Map;

import javax.annotation.Resource;

import com.google.common.collect.Maps;

import com.googlecode.sarasvati.Arc;

import com.googlecode.sarasvati.NodeToken;

import eu.dnetlib.common.logging.DnetLogger;

import eu.dnetlib.common.logging.LogMessage;

import eu.dnetlib.enabling.is.registry.rmi.ISRegistryService;

import eu.dnetlib.enabling.locators.UniqueServiceLocator;

import eu.dnetlib.miscutils.datetime.DateUtils;

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

import org.antlr.stringtemplate.StringTemplate;

import org.apache.commons.io.IOUtils;

import org.apache.commons.lang.StringEscapeUtils;

import org.apache.commons.lang.StringUtils;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.springframework.beans.factory.annotation.Required;

/**

 * The success node sets the "isCompletedSuccessfully" env var.

 * 

 */

public class SuccessFailureNode extends SimpleJobNode {

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

	/**

	 * is completed successfully.

	 */

	private boolean success;

	@Resource

	private UniqueServiceLocator serviceLocator;

	@Resource(name = "msroWorkflowLogger")

	private DnetLogger dnetLogger;

	@Override

	protected String execute(final NodeToken token) {

		final String profileId = token.getFullEnv().getAttribute(WorkflowsConstants.SYSTEM_WF_PROFILE_ID).trim();

		final long now = DateUtils.now();

		final String date = DateUtils.calculate_ISO8601(now);

		token.getProcess().getEnv().setAttribute(WorkflowsConstants.SYSTEM_END_DATE, now);

		token.getProcess().getEnv().setAttribute(WorkflowsConstants.SYSTEM_END_HUMAN_DATE, date);

		final Map<String, String> params = mergeEnvAttributes(token);

		final LogMessage logMessage = dnetLogger.newLogMessage().addDetails(params);

		try {

			final String template = IOUtils.toString(getClass().getResourceAsStream("/eu/dnetlib/msro/workflows/templates/workflow_status.xml.st"));

			final StringTemplate st = new StringTemplate(template);

			st.setAttribute("procId", StringEscapeUtils.escapeXml(params.get(WorkflowsConstants.SYSTEM_WF_PROCESS_ID)));

			st.setAttribute("date", StringEscapeUtils.escapeXml(date));

			st.setAttribute("params", filterOutputParams(params));

			if (!isSuccess()) {

				st.setAttribute("error", StringEscapeUtils.escapeXml(params.get(WorkflowsConstants.SYSTEM_ERROR)));

			}

			serviceLocator.getService(ISRegistryService.class).updateProfileNode(profileId, "//STATUS", st.toString());

			token.getProcess().getEnv().setAttribute(WorkflowsConstants.SYSTEM_COMPLETED_SUCCESSFULLY, isSuccess());

			logMessage.addDetail(WorkflowsConstants.SYSTEM_COMPLETED_SUCCESSFULLY, Boolean.toString(isSuccess()));

		} catch (Exception e) {

			log.error("Error updating workflow profile: " + profileId, e);

			token.getProcess().getEnv().setAttribute(WorkflowsConstants.SYSTEM_COMPLETED_SUCCESSFULLY, false);

			logMessage.addDetail(WorkflowsConstants.SYSTEM_COMPLETED_SUCCESSFULLY, Boolean.toString(false));

		}

		logMessage.flush();

		return Arc.DEFAULT_ARC;

	}

	private Map<String, String> filterOutputParams(final Map<String, String> map) {

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

		if (map != null) {

			for (String k : map.keySet()) {

				if (!StringUtils.isBlank(k) && (k.startsWith(WorkflowsConstants.DATAPROVIDER_PREFIX) || k.startsWith(WorkflowsConstants.MAIN_LOG_PREFIX))) {

					final String key = StringEscapeUtils.escapeXml(k);

					final String v = map.get(k);

					res.put(key, v != null ? escapeAttribute(StringEscapeUtils.escapeXml(v)) : "null");

				}

			}

		}

		return res;

	}

	private String escapeAttribute(String s) {

		return s.replaceAll("&", "&amp;").replaceAll("<", "&lt;").replaceAll(">", "&gt;").replaceAll("\"", "&quot;").replaceAll("'", "&apos;").replaceAll("\\{", "{{").replaceAll("\\}", "}}");

	}

	private Map<String, String> mergeEnvAttributes(final NodeToken token) {

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

		for (String s : token.getEnv().getAttributeNames()) {

			map.put(s, token.getEnv().getAttribute(s));

		}

		for (String s : token.getFullEnv().getAttributeNames()) {

			map.put(s, token.getFullEnv().getAttribute(s));

		}

		return map;

	}

	public boolean isSuccess() {

		return success;

	}

	@Required

	public void setSuccess(final boolean success) {

		this.success = success;

	}

}

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

<xsl:stylesheet version="1.0"

	xmlns:xsl="http://www.w3.org/1999/XSL/Transform" xmlns:nxsl="http://www.w3.org/1999/XSL/TransformXX"

	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">

	<xsl:output omit-xml-declaration="yes" method="xml"

		encoding="UTF-8" />

	<xsl:namespace-alias stylesheet-prefix="nxsl"

		result-prefix="xsl" />

	<xsl:param name="format" />

	<xsl:template match="/">

		<xsl:apply-templates select="//LAYOUT" />

	</xsl:template>

	<xsl:template match="LAYOUT">

		<nxsl:stylesheet version="1.0"

			xmlns:dr="http://www.driver-repository.eu/namespace/dr" xmlns:dc="http://purl.org/dc/elements/1.1/"

			xmlns:dri="http://www.driver-repository.eu/namespace/dri" xmlns:dnet="eu.dnetlib.miscutils.functional.xml.DnetXsltFunctions"

			xmlns:exsl="http://exslt.org/common"

      extension-element-prefixes="exsl">

			<nxsl:output version="1.0" omit-xml-declaration="yes"

				method="xml" encoding="UTF8" />

			<nxsl:variable name="format">

				<xsl:value-of select="$format" />

			</nxsl:variable>

			<nxsl:template match="/">

				<indexRecord>

					<indexRecordIdentifier>

						<nxsl:value-of select="//dri:objIdentifier" />

					</indexRecordIdentifier>

					<targetFields>

						<nxsl:if test="count(//*[local-name()='metadata']/*) &gt; 0">

							<xsl:apply-templates select="FIELDS/FIELD[@indexable='true']" />

						</nxsl:if>		

					</targetFields>

					<result>

						<header>

							<dri:objIdentifier>

								<nxsl:value-of select="//dri:objIdentifier" />

							</dri:objIdentifier>

							<dri:repositoryId>

								<nxsl:value-of select="//dri:repositoryId" />

							</dri:repositoryId>

							<dri:dateOfCollection>

								<nxsl:value-of select="//dri:dateOfCollection" />

							</dri:dateOfCollection>

							<xsl:apply-templates select="FIELDS/FIELD"

								mode="header" />

						</header>

						<metadata>

							<xsl:apply-templates select="FIELDS/FIELD"

								mode="result" />

						</metadata>

					</result>

				</indexRecord>

			</nxsl:template>

		</nxsl:stylesheet>

	</xsl:template>

	<xsl:template match="FIELD[@indexable='true']">

		<xsl:choose>

			<!-- 

			<xsl:when test="@name = 'description'">

				<nxsl:for-each select="{@xpath}">

					<xsl:element name="{@name}">

						<nxsl:value-of select="substring(.,1,210)" />

					</xsl:element>

				</nxsl:for-each>

			</xsl:when>

			 -->

			<xsl:when test="@constant">

				<xsl:element name="{@name}">

					<xsl:value-of select="@constant" />

				</xsl:element>

			</xsl:when>

			<xsl:when test="@value and not(@xpath)">

				<nxsl:element name="{@name}">

					<nxsl:value-of select="{@value}" />

				</nxsl:element>

			</xsl:when>

			<xsl:otherwise>

				<xsl:variable name="value">

					<xsl:choose>

						<xsl:when test="@value">

							<xsl:value-of select="@value" />

						</xsl:when>

						<xsl:otherwise>

							.

						</xsl:otherwise>

					</xsl:choose>

				</xsl:variable>

				<nxsl:for-each select="{@xpath}">

					<xsl:element name="{@name}">

						<xsl:if test="@external='true'">

							<xsl:attribute name="external">true</xsl:attribute>

						</xsl:if>

						<xsl:choose>

							<xsl:when test="@tokenizable='false'">

								<nxsl:value-of select="normalize-space({normalize-space($value)})" />

							</xsl:when>

							<xsl:otherwise>

								<nxsl:value-of select="{normalize-space($value)}" />

							</xsl:otherwise>

						</xsl:choose>

					</xsl:element>

				</nxsl:for-each>

			</xsl:otherwise>

		</xsl:choose>

	</xsl:template>

	<xsl:template match="FIELD" mode="result">

		<xsl:if test="@result='true'">

			<nxsl:copy-of select="{@xpath}" />

		</xsl:if>

	</xsl:template>

	<xsl:template match="FIELD" mode="header">

		<xsl:if test="@header='true'">

			<nxsl:copy-of select="{@xpath}" />

		</xsl:if>

	</xsl:template>

</xsl:stylesheet>

package eu.dnetlib.msro.workflows.nodes.repohi;

import java.util.Map;

import org.apache.commons.lang.StringUtils;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import com.googlecode.sarasvati.Engine;

import com.googlecode.sarasvati.NodeToken;

import com.googlecode.sarasvati.env.Env;

import eu.dnetlib.data.objectstore.rmi.ObjectStoreService;

import eu.dnetlib.enabling.tools.blackboard.BlackboardJob;

import eu.dnetlib.msro.workflows.nodes.BlackboardJobNode;

import eu.dnetlib.msro.workflows.nodes.blackboard.BlackboardWorkflowJobListener;

public class CreateObjectStoreJobNode extends BlackboardJobNode {

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

	private String interpretation;

	private String outputPrefix = "objectStore_";

	@Override

	protected String obtainServiceId(final NodeToken token) {

		return getServiceLocator().getServiceId(ObjectStoreService.class);

	}

	@Override

	protected void prepareJob(final BlackboardJob job, final NodeToken token) {

		log.info("preparing blackboard job for the creation of the objectStore ");

		String basePath  = token.getEnv().getAttribute("objectStoreBasePath");

		job.setAction("CREATE");

		job.getParameters().put("interpretation", interpretation);

		if (!StringUtils.isEmpty(basePath)) {

			job.getParameters().put("basePath", basePath);

		}

	}

	public String getInterpretation() {

		return interpretation;

	}

	public void setInterpretation(final String interpretation) {

		this.interpretation = interpretation;

	}

	public String getOutputPrefix() {

		return outputPrefix;

	}

	public void setOutputPrefix(final String outputPrefix) {

		this.outputPrefix = outputPrefix;

	}

	@Override

	protected BlackboardWorkflowJobListener generateBlackboardListener(final Engine engine, final NodeToken token) {

		return new BlackboardWorkflowJobListener(engine, token) {

			@Override

			protected void populateEnv(final Env env, final Map<String, String> responseParams) {

				env.setAttribute(getOutputPrefix() + "interpretation", interpretation);

				env.setAttribute(getOutputPrefix() + "id", responseParams.get("objectStoreId"));

			}

		};

	}

}

<?xml version="1.0"?>

<xsl:stylesheet version="1.0"

	xmlns:xsl="http://www.w3.org/1999/XSL/Transform">

	<xsl:template match="/">

		<xsl:variable name="wfname" select="translate(.//WORKFLOW_NAME, ' ', '_')" />

		<process-definition name="{$wfname}" xmlns="http://sarasvati.googlecode.com/ProcessDefinition">

			<xsl:apply-templates select=".//NODE"/>            

			<node name="success" type="Success" />

			<node name="failure" type="Failure" />

		</process-definition>

	</xsl:template>

	<xsl:template match="NODE">

		<xsl:element name="node" namespace="http://sarasvati.googlecode.com/ProcessDefinition">

			<xsl:attribute name="name"><xsl:value-of select="@name" /></xsl:attribute>

			<xsl:if test="@isJoin = 'true'">

				<xsl:attribute name="joinType">and</xsl:attribute>

			</xsl:if>

			<xsl:if test="@isStart = 'true'">

				<xsl:attribute name="isStart">true</xsl:attribute>

			</xsl:if>

			<xsl:if test="string-length(@type) &gt; 0">

				<xsl:attribute name="type"><xsl:value-of select="@type" /></xsl:attribute>

			</xsl:if>

			<xsl:apply-templates select=".//ARC"/>

			<arc xmlns="http://sarasvati.googlecode.com/ProcessDefinition" name="failed" to="failure" />

			<xsl:if test="count(.//PARAM[string-length(normalize-space(text())) &gt; 0]) &gt; 0">

				<custom xmlns="http://sarasvati.googlecode.com/ProcessDefinition">

					<xsl:apply-templates select=".//PARAM"/>

				</custom>

			</xsl:if>

		</xsl:element>

	</xsl:template>

	<xsl:template match="ARC">

		<xsl:element name="arc" namespace="http://sarasvati.googlecode.com/ProcessDefinition">

			<xsl:attribute name="to"><xsl:value-of select="@to" /></xsl:attribute>

			<xsl:if test="string-length(@name) &gt; 0">

				<xsl:attribute name="name"><xsl:value-of select="@name" /></xsl:attribute>

			</xsl:if>

		</xsl:element> 

	</xsl:template>