D-Net

package eu.dnetlib.msro.openaireplus.workflows.nodes.stats;

import java.util.List;

import javax.annotation.Resource;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

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

import com.googlecode.sarasvati.NodeToken;

import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpException;

import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService;

import eu.dnetlib.enabling.locators.UniqueServiceLocator;

import eu.dnetlib.msro.rmi.MSROException;

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

public class FindStatsServiceJobNode extends SimpleJobNode {

	/**

	 * logger.

	 */

	private static final Log log = LogFactory.getLog(FindStatsServiceJobNode.class); // NOPMD by marko on 11/24/08 5:02 PM

	@Resource

	private UniqueServiceLocator serviceLocator;

	@Value(value = "${dnet.openaire.service.stats.lookup.xquery}")

	private String xquery;

	private String xqueryForServiceIdParam;

	/**

	 * {@inheritDoc}

	 * 

	 * @throws ISLookUpException

	 * @throws MSROException

	 * 

	 * @see com.googlecode.sarasvati.mem.MemNode#execute(com.googlecode.sarasvati.Engine, com.googlecode.sarasvati.NodeToken)

	 */

	@Override

	public String execute(final NodeToken token) throws ISLookUpException, MSROException {

		log.info("lookup for stats service: " + getXquery());

		List<String> statsServiceIds = serviceLocator.getService(ISLookUpService.class).quickSearchProfile(getXquery());

		if (statsServiceIds.size() > 1) { throw new MSROException("too many stats services: " + statsServiceIds); }

		if (statsServiceIds.isEmpty()) {

			return "notFound";

		} else {

			token.getEnv().setAttribute(getXqueryForServiceIdParam(), getXquery());

			return "found";

		}

	}

	public String getXquery() {

		return xquery;

	}

	public void setXquery(final String xquery) {

		this.xquery = xquery;

	}

	public String getXqueryForServiceIdParam() {

		return xqueryForServiceIdParam;

	}

	public void setXqueryForServiceIdParam(final String xqueryForServiceIdParam) {

		this.xqueryForServiceIdParam = xqueryForServiceIdParam;

	}

}