D-Net

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

import javax.annotation.Resource;

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

import eu.dnetlib.enabling.locators.UniqueServiceLocator;

import eu.dnetlib.msro.workflows.graph.Arc;

import eu.dnetlib.msro.workflows.graph.Env;

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

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

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

public class UpdateWfStatusJobNode extends SimpleJobNode {

	@Resource

	private UniqueServiceLocator serviceLocator;

	@Override

	protected String execute(final Env env) throws Exception {

		final String wfId = env.getAttribute("WORKFLOW_ID", String.class);

		final String dsId = env.getAttribute(WorkflowsConstants.DATASOURCE_ID, String.class);

		final String ifaceId = env.getAttribute(WorkflowsConstants.DATASOURCE_INTERFACE, String.class);

		updateDatasource(dsId, ifaceId);

		if (isReady(wfId)) {

			serviceLocator.getService(ISRegistryService.class).updateProfileNode(wfId, "//CONFIGURATION/@status", "'" + WorkflowStatus.EXECUTABLE + "'");

		}

		return Arc.DEFAULT_ARC;

	}

	protected void updateDatasource(final String dsId, final String ifaceId) throws Exception {

		serviceLocator.getService(ISRegistryService.class).updateProfileNode(dsId, "//INTERFACE[@id = '" + ifaceId + "']/@active", "'true'");

	}

	private boolean isReady(final String wfId) throws Exception {

		//TODO: verificare che tutti i workflow figli abbiano non abbiamo nodi "//PARAM[@required='true' and string-length(text()) = 0]"

		return true;

	}

}