D-Net

package eu.dnetlib.msro.workflows.procs;

import java.text.SimpleDateFormat;

import java.util.Date;

import org.apache.commons.lang3.StringUtils;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

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

import org.springframework.stereotype.Component;

import eu.dnetlib.clients.is.InformationServiceClient;

import eu.dnetlib.msro.exceptions.MSROException;

import eu.dnetlib.msro.workflows.WorkflowInstance;

import eu.dnetlib.services.async.AsyncServerCallback;

/**

 * Created by michele on 25/11/15.

 */

@Component

public class ProcessFactory {

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

	private String oldGeneratedId = "";

	@Autowired

	private InformationServiceClient isLookup;

	public WorkflowProcess newProcess(final WorkflowInstance wf, final AsyncServerCallback callback) throws MSROException {

		return new WorkflowProcess(generateProcessId(),

				wf.getName(),

				wf.getFamily(),

				wf.getDsId(),

				findDsName(wf.getDsId()),

				wf.getDsInterface(),

				wf.getGraph(),

				wf.getPriority(),

				wf.getProfileId(),

				wf.isTemplate(),

				wf.getGlobalParams(),

				callback, wf.getParent());

	}

	private String findDsName(final String dsId) throws MSROException {

		if (StringUtils.isBlank(dsId)) { return null; }

		final String query = "collection('/db/DRIVER/RepositoryServiceResources/RepositoryServiceResourceType')/*[.//RESOURCE_IDENTIFIER/@value='" + dsId

				+ "' or .//DATASOURCE_ORIGINAL_ID='" + dsId + "']//OFFICIAL_NAME/text()";

		try {

			return isLookup.findOne(query);

		} catch (final Exception e) {

			log.error("Error executing xquery: " + query);

			throw new MSROException("Error executing xquery: " + query, e);

		}

	}

	private synchronized String generateProcessId() {

		String id = "";

		do {

			id = "wf_" + (new SimpleDateFormat("yyyyMMdd_HHmmss_S")).format(new Date());

			log.info("Generated processID " + id);

		} while (id.equals(oldGeneratedId));

		oldGeneratedId = id;

		return id;

	}

}