D-Net

import java.io.IOException;

import java.io.StringReader;

import org.dom4j.Document;

import org.dom4j.DocumentException;

import org.dom4j.Element;

import org.dom4j.io.SAXReader;

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

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

import com.fasterxml.jackson.core.type.TypeReference;

import eu.dnetlib.clients.is.InformationServiceClient;

import eu.dnetlib.exceptions.InformationServiceException;

import eu.dnetlib.msro.workflows.GraphNodeParameter;

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

	@Autowired

	private GraphLoader graphLoader;

	@Autowired

	private InformationServiceClient isClient;

	@RequestMapping(value = "startWorkflowTemplate", method = RequestMethod.GET)

	public WorkflowRef startWorkflowTemplate(@RequestParam final String parent, @RequestParam final String node) throws MSROException {

		try {

			final Document docParent = (new SAXReader()).read(new StringReader(isClient.getProfile(parent)));

			final String family = docParent.valueOf("//WORKFLOW_FAMILY");

			final String dsId = docParent.valueOf("//DATASOURCE/@id");

			final String iface = docParent.valueOf("//DATASOURCE/@interface");

			final String workerId = docParent.valueOf("//RESOURCE_MANAGER/@value");

			final Map<String, String> globalParams = new HashMap<>();

			for (final Object o : docParent.selectNodes("//CONFIGURATION/PARAMETERS/PARAM")) {

				final Element p = (Element) o;

				globalParams.put(p.valueOf("@name"), p.getTextTrim());

			}

			final Map<String, GraphNodeParameter> mapParams =

					graphLoader.calculateParamsForNode(docParent.selectSingleNode("//NODE[@name='" + node + "']"), globalParams);

			final String wfTemplateId = mapParams.get("wfTemplateId").getValue();

			final Map<String, String> params = new HashMap<>();

			final Map<String, GraphNodeParameter> unresolved =

					(new ObjectMapper()).readValue(mapParams.get("wfTemplateParams").getValue(), new TypeReference<Map<String, GraphNodeParameter>>() {});

			for (final Map.Entry<String, GraphNodeParameter> entry : unresolved.entrySet()) {

				final String k = entry.getKey();

				if (entry.getValue().isEnvParam()) {

					log.error("Error launching a template containing ENV parmaters");

					throw new MSROException("Error launching a template containing ENV parmaters");

				} else {

					params.put(k, entry.getValue().getValue());

				}

			}

			final WorkflowTemplate wfTemplate = new WorkflowTemplate(wfTemplateId, parent, node, family, dsId, iface, params, workerId);

			return startWorkflowTemplate(wfTemplate);

		} catch (final IOException | InformationServiceException | DocumentException e) {

			log.error("Error executing wfTemplate: " + node, e);

			throw new MSROException("Error executing wfTemplate: " + node, e);

		}

	}

	@RequestMapping(value = "startWorkflowTemplate", method = RequestMethod.POST)

	public WorkflowRef startWorkflowTemplate(@RequestBody final WorkflowTemplate wf) throws MSROException {

		return dispatcher.startWorkflowTemplate(wf, getBaseUrl(), null);

	}

	public List<WorkflowLog> logs(@RequestParam final String wfId) {

			final WorkflowTemplate wfTemplate = new WorkflowTemplate(repoByeTemplateId, null, name, "REPO_BYE", dsId, iface, params, workerId);

			return startWorkflowTemplate(wfTemplate, localBaseUrl, res -> {

	public WorkflowRef startWorkflowTemplate(final WorkflowTemplate wfTemplate,

			final String profile = isClient.getProfile(wfTemplate.getId());

				if (StringUtils.isNotBlank((wfTemplate.getParams().get(pname)))) {

					globalParams.put(pname, wfTemplate.getParams().get(pname));

			wf.setName(wfTemplate.getName());

			wf.setFamily(wfTemplate.getFamily());

			wf.setDsId(wfTemplate.getDsId());

			wf.setDsInterface(wfTemplate.getIface());

			wf.setProfileId(wfTemplate.getId());

			wf.setParent(wfTemplate.getParent());

			wf.setWorkerId(wfTemplate.getWorkerId());

			log.error("Error starting workflow template: " + wfTemplate.getId(), e);

	public @ResponseBody WorkflowRef startWorkflowTemplate(

			@RequestParam final String parent) throws Exception {

		return clientFactory.getClient(MsroClient.class).startWorkflowTemplate(node, parent);

<wf-process-modal proc-id="currentProcId" visible="showProcModal" worker="currentWorker"></wf-process-modal>

					url = '/ajax/wfs/startWorkflowTemplate?node=' + name + '&parent=' + parent;

import eu.dnetlib.clients.msro.WorkflowTemplate;

			final WorkflowTemplate wf =

					new WorkflowTemplate(getWfTemplateId(), process.getProfileId(), getNodeName(), family, dsId, iface, wfTemplateParams,

							worker.getProfileId());

			msro.startWorkflowTemplate(wf, worker.getBaseUrl(),

	public WorkflowRef startWorkflowTemplate(final String node, final String parent) {

		final StringWriter url = new StringWriter();

		url.append(getBaseUrl());

		url.append("/startWorkflowTemplate?parent=");

		url.append(parent);

		url.append("&node=");

		url.append(node);

		return (new RestTemplate()).getForObject(url.toString(), WorkflowRef.class);

	}

	public void startWorkflowTemplate(final WorkflowTemplate wf, final String localBaseUrl, final AsyncClientCallback callback) {

		asyncClientUtils.invokeRemoteMethod(getBaseUrl(), "startWorkflowTemplate", localBaseUrl, wf, callback);

	}