Project

General

Profile

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

    
3
import com.googlecode.sarasvati.Arc;
4
import com.googlecode.sarasvati.NodeToken;
5
import eu.dnetlib.msro.workflows.nodes.SimpleJobNode;
6
import eu.dnetlib.msro.workflows.util.WorkflowsConstants;
7

    
8
public class SetProviderInfoJobNode extends SimpleJobNode {
9

    
10
	private String providerId;
11
	private String providerName;
12
	private String api;
13

    
14
	@Override
15
	protected String execute(NodeToken token) throws Exception {
16
		token.getEnv().setAttribute(WorkflowsConstants.DATAPROVIDER_ID, getProviderId());
17
		token.getEnv().setAttribute(WorkflowsConstants.DATAPROVIDER_NAME, getProviderName());
18
		token.getEnv().setAttribute(WorkflowsConstants.DATAPROVIDER_INTERFACE, getApi());
19

    
20
		token.getFullEnv().setAttribute(WorkflowsConstants.DATAPROVIDER_ID, getProviderId());
21
		token.getFullEnv().setAttribute(WorkflowsConstants.DATAPROVIDER_NAME, getProviderName());
22
		token.getFullEnv().setAttribute(WorkflowsConstants.DATAPROVIDER_INTERFACE, getApi());
23

    
24
		token.getProcess().getEnv().setAttribute(WorkflowsConstants.DATAPROVIDER_ID, getProviderId());
25
		token.getProcess().getEnv().setAttribute(WorkflowsConstants.DATAPROVIDER_NAME, getProviderName());
26
		token.getProcess().getEnv().setAttribute(WorkflowsConstants.DATAPROVIDER_INTERFACE, getApi());
27

    
28
		return Arc.DEFAULT_ARC;
29
	}
30

    
31
	public String getProviderId() {
32
		return providerId;
33
	}
34

    
35
	public void setProviderId(String providerId) {
36
		this.providerId = providerId;
37
	}
38

    
39
	public String getProviderName() {
40
		return providerName;
41
	}
42

    
43
	public void setProviderName(String providerName) {
44
		this.providerName = providerName;
45
	}
46

    
47
	public String getApi() {
48
		return api;
49
	}
50

    
51
	public void setApi(String api) {
52
		this.api = api;
53
	}
54

    
55
}
(4-4/4)