D-Net

package eu.dnetlib.msro.worker.nodes.repobye;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

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

import com.googlecode.sarasvati.Arc;

import com.googlecode.sarasvati.NodeToken;

import eu.dnetlib.enabling.datastructures.Datasource;

import eu.dnetlib.enabling.datastructures.MetaWorkflow;

import eu.dnetlib.enabling.is.client.InformationServiceClient;

import eu.dnetlib.msro.worker.WorkflowConstants;

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

import eu.dnetlib.rmi.objects.datasources.IfaceDesc;

import eu.dnetlib.rmi.soap.InformationService;

public class DeleteMetaWfJobNode extends SimpleJobNode {

	private String metaWfId;

	@Autowired

	private InformationService informationService;

	@Autowired

	private InformationServiceClient isClient;

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

	@Override

	protected String execute(final NodeToken token) throws Exception {

		final MetaWorkflow metaWf = isClient.getResourceByCode(metaWfId, MetaWorkflow.class);

		final String dsId = metaWf.getDatasourceId();

		final String dsName = metaWf.getDatasourceName();

		final String ifaceId = metaWf.getDatasourceInterfaceId();

		log.info("Removing a MetaWf of dataprovider: " + metaWf.getDatasourceId());

		token.getEnv().setAttribute(WorkflowConstants.DATAPROVIDER_ID, dsId);

		token.getEnv().setAttribute(WorkflowConstants.DATAPROVIDER_NAME, dsName);

		token.getEnv().setAttribute(WorkflowConstants.DATAPROVIDER_INTERFACE, metaWf.getDatasourceInterfaceId());

		isClient.deleteResourceByCode(metaWfId, MetaWorkflow.class);

		verifyDatasource(dsId, ifaceId);

		return Arc.DEFAULT_ARC;

	}

	private void verifyDatasource(final String dsId, final String ifaceId) throws Exception {

		final String sql = String.format(

				"select id from resource_properties where name = 'metaWf::ifaceId' and value = '%s'", ifaceId);

		final boolean active = !informationService.searchSql(sql).isEmpty();

		updateIfaceActivationStatus(dsId, ifaceId, active);

	}

	protected void updateIfaceActivationStatus(final String dsId, final String ifaceId, final boolean active) throws Exception {

		final Datasource ds = isClient.getResourceByCode(dsId, Datasource.class);

		for (IfaceDesc iface : ds.getInterfaces()) {

			if (iface.getId().equals(ifaceId)) {

				iface.setActive(active);

				isClient.updateResource(ds);

			}

		}

	}

	public String getMetaWfId() {

		return metaWfId;

	}

	public void setMetaWfId(final String metaWfId) {

		this.metaWfId = metaWfId;

	}

}