D-Net

import eu.dnetlib.clients.locators.ServiceClientFactory;

import eu.dnetlib.clients.msro.MsroClient;

import eu.dnetlib.services.async.AsyncClientCallback;

import eu.dnetlib.services.async.AsyncResponse;

	@Autowired

	private ServiceClientFactory clientFactory;

	@RequestMapping("startWorkflow")

	public boolean startWorkflow(@RequestParam final String wfId) throws Exception {

		final MsroClient msro = clientFactory.getClient(MsroClient.class);

		msro.startWorkflow(wfId, null, null, new AsyncClientCallback() {

			@Override

			public void onGoing(final AsyncResponse res) {

				log.info("ONGOING - " + res.getResponseJson());

			}

			@Override

			public void onFailed(final AsyncResponse res) {

				log.info("FAILED - " + res.getResponseJson());

			}

			@Override

			public void onDone(final AsyncResponse res) {

				log.info("DONE - " + res.getResponseJson());

			}

		});

		return true;

	}

	@RequestMapping("startWorkflowTemplate")

	public @ResponseBody boolean startWorkflowTemplate(

			@RequestParam final String node,

			@RequestParam final String parentWf) throws Exception {

		// TODO

		/*

		 * final String profile = isClient.getProfile(parentWf); final Document doc = (new SAXReader()).read(new StringReader(profile));

		 * final String family = doc.valueOf("//WORKFLOW_FAMILY"); final int priority =

		 * NumberUtils.toInt(doc.valueOf("//WORKFLOW_PRIORITY"), WorkflowsConstants.DEFAULT_WF_PRIORITY); final String dsId =

		 * doc.valueOf("//DATASOURCE/@id"); final String iface = doc.valueOf("//DATASOURCE/@interface");

		 *

		 * final Map<String, String> globalParams = new HashMap<String, String>(); for (final Object o :

		 * doc.selectNodes("//CONFIGURATION/PARAMETERS/PARAM")) { final Element p = (Element) o; globalParams.put(p.valueOf("@name"),

		 * p.getTextTrim()); }

		 *

		 * final Node n = doc.selectSingleNode("//NODE[@name='" + node + "']"); final Map<String, Object> params = GraphNode.newNode(node,

		 * n.valueOf("@type"), graphLoader.calculateParamsForNode(node, globalParams)) .resolveParamsWithNoEnv();

		 *

		 * if (!params.containsKey("wfTemplateId") || !(params.get("wfTemplateId") instanceof String) || StringUtils.isBlank((String)

		 * params.get("wfTemplateId"))) { log.error("wfTemplateId is invalid or missing in profile " + parentWf); throw new

		 * DnetGenericException("wfTemplateId is invalid or missing in profile " + parentWf); }

		 *

		 * if (params.containsKey("wfTemplateParams") && !(params.get("wfTemplateParams") instanceof Map)) { log.error(

		 * "wfTemplateParams is invalid in profile " + parentWf); throw new DnetGenericException("wfTemplateParams is invalid in profile " +

		 * parentWf); }

		 *

		 * final String wfTtemplateId = (String) params.get("wfTemplateId");

		 *

		 * @SuppressWarnings("unchecked") final Map<String, String> wfTtemplateParams = (Map<String, String>)

		 * params.get("wfTemplateParams");

		 *

		 * final MsroClient msro = clientFactory.getClient(MsroClient.class);

		 *

		 * msro.startWorkflowTemplate(wfTtemplateId, parentWf, node, family, wfTtemplateParams, dsId, iface, null);

		 */

		return true;

	}