());
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/soap/EndpointReferenceBuilder.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/soap/EndpointReferenceBuilder.java
new file mode 100644
index 0000000..c15dc52
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/soap/EndpointReferenceBuilder.java
@@ -0,0 +1,96 @@
+package eu.dnetlib.soap;
+
+import java.util.Map;
+
+import javax.xml.namespace.QName;
+import javax.xml.ws.wsaddressing.W3CEndpointReference;
+
+/**
+ * This is a generalization of org.apache.cxf.jaxws.EndpointReferenceBuilder and org.apache.cxf.jaxws.EndpointImpl
+ *
+ *
+ * javax.xml.ws.WebServiceContext org.apache.cxf.jaxws.EndpointReferenceBuilder doesn't expose the API for adding
+ * additional metadata while org.apache.cxf.jaxws.EndpointImpl doesn't take the correct endpoint address from the
+ * EndpointInfo object. org.apache.cxf.endpoint.Endpoint return a CXF proprietary endpoint reference and not the
+ * javax/w3c standard definition.
+ *
+ *
+ *
+ * This interface is intended to provide an abstract way to construct an endpoint reference for a given service,
+ * depending on the type of endpoint interface you have at hand (CXF abstract endpoint or jaxws endpoint)
+ *
+ *
+ *
+ * Normally the type parameter T will be bound to your endpoint type.
+ *
+ *
+ *
+ * In CXF jaxws applications you can easly get a WebServiceContext instance which returns an EndpointReference, however
+ * the API is cumbersome because it requires instantiating w3c DOM Element instances for each reference parameter, and
+ * it doesn't allow setting custom metadata elements.
+ *
+ *
+ *
+ * Implementors of this API will extract as many useful informations from the runtime besides the plain soap endpoint
+ * address.
+ *
+ *
+ * @author marko
+ * @param
+ * all endpoint builders are parameterized to specific endpoint type which on the used framework (not on the
+ * service)
+ *
+ */
+public interface EndpointReferenceBuilder {
+ /**
+ * get an endpoint reference with default metadata attached.
+ *
+ * @param endpoint
+ * the endpoint
+ * @return an endpoint reference
+ */
+ W3CEndpointReference getEndpointReference(T endpoint);
+
+ /**
+ * get an endpoint reference with custom metadata attached.
+ *
+ * @param endpoint
+ * the endpoint
+ * @param attrs
+ * metadata attribute map
+ * @return an endpoint reference
+ */
+ W3CEndpointReference getEndpointReference(T endpoint, Map attrs);
+
+ /**
+ * get an endpoint reference with a WSA reference parameter.
+ *
+ * @param endpoint
+ * the endpoint
+ * @param referenceParam
+ * reference parameters
+ * @return an endpoint reference
+ */
+ W3CEndpointReference getEndpointReference(T endpoint, String referenceParam);
+
+ /**
+ * get an endpoint reference with custom metadata attached and WSA reference parameter.
+ *
+ * @param endpoint
+ * endpoint
+ * @param referenceParam
+ * reference parameters
+ * @param attrs
+ * metadata attribute map
+ * @return an endpoint reference
+ */
+ W3CEndpointReference getEndpointReference(T endpoint, String referenceParam, Map attrs);
+
+ /**
+ * Sometimes we need only the address.
+ *
+ * @param endpoint endpoint
+ * @return address
+ */
+ String getAddress(T endpoint);
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/soap/StaticEndpointReferenceBuilder.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/soap/StaticEndpointReferenceBuilder.java
new file mode 100644
index 0000000..35d6313
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/soap/StaticEndpointReferenceBuilder.java
@@ -0,0 +1,60 @@
+package eu.dnetlib.soap;
+
+import java.util.Map;
+
+import javax.xml.namespace.QName;
+import javax.xml.ws.wsaddressing.W3CEndpointReference;
+import javax.xml.ws.wsaddressing.W3CEndpointReferenceBuilder;
+
+/**
+ * This endpoint reference builder builds always the same epr, with a fixed address, for any incoming endpoint (even
+ * null endpoints). Useful when registering service profiles for external services like the old perl Aggregator.
+ *
+ * @author marko
+ *
+ * @param
+ * endpoint type
+ */
+public class StaticEndpointReferenceBuilder implements EndpointReferenceBuilder {
+
+ /**
+ * service address.
+ */
+ private String address;
+
+ @Override
+ public String getAddress(final T endpoint) {
+ return address;
+ }
+
+ @Override
+ public W3CEndpointReference getEndpointReference(final T endpoint) {
+ final W3CEndpointReferenceBuilder builder = new W3CEndpointReferenceBuilder();
+ builder.address(address);
+ return builder.build();
+ }
+
+ @Override
+ public W3CEndpointReference getEndpointReference(final T endpoint, final Map attrs) {
+ return getEndpointReference(endpoint);
+ }
+
+ @Override
+ public W3CEndpointReference getEndpointReference(final T endpoint, final String referenceParam) {
+ return getEndpointReference(endpoint);
+ }
+
+ @Override
+ public W3CEndpointReference getEndpointReference(final T endpoint, final String referenceParam, final Map attrs) {
+ return getEndpointReference(endpoint);
+ }
+
+ public String getAddress() {
+ return address;
+ }
+
+ public void setAddress(final String address) {
+ this.address = address;
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/soap/cxf/CxfEndpointReferenceBuilder.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/soap/cxf/CxfEndpointReferenceBuilder.java
new file mode 100644
index 0000000..3c23a54
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/soap/cxf/CxfEndpointReferenceBuilder.java
@@ -0,0 +1,206 @@
+package eu.dnetlib.soap.cxf;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Map.Entry;
+
+import javax.xml.namespace.QName;
+import javax.xml.parsers.DocumentBuilderFactory;
+import javax.xml.parsers.ParserConfigurationException;
+import javax.xml.ws.wsaddressing.W3CEndpointReference;
+import javax.xml.ws.wsaddressing.W3CEndpointReferenceBuilder;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.cxf.endpoint.Endpoint;
+import org.apache.oro.text.perl.Perl5Util;
+import org.w3c.dom.Document;
+import org.w3c.dom.Element;
+
+import eu.dnetlib.soap.AbstractEndpointReferenceBuilder;
+
+/**
+ * The cxf endpoint is an internal cross-toolkit implementation of the messaging endpoint.
+ *
+ *
+ * End users will normally access jaxws endpoints, since jaxws is the mostly used cxf frontend. However, generic code,
+ * like interceptors, will handle cxf endpoints, so sometimes you may need to construct endpoint references from them.
+ *
+ *
+ *
+ * <ns3:Address>http://localhost:8090/app/services/isStore</ns3:Address>
+ * <ns3:ReferenceParameters/>
+ * <ns3:Metadata>
+ * <wsaw:InterfaceName>ns1:ISStoreService</wsaw:InterfaceName>
+ * <wsaw:ServiceName EndpointName="ISStoreServicePort">ns2:ISStoreServiceService</wsaw:ServiceName>
+ * <infrastructure:infrastructure>development</infrastructure:infrastructure>
+ * </ns3:Metadata>
+ *
+ *
+ * Users can easily define default system or service wide custom metadata to endpoint references by setting a
+ * defaultMetadata property:
+ *
+ *
+ * <bean name="cxfEndpointReferenceBuilder" class="eu.dnetlib.soap.cxf.CxfEndpointReferenceBuilder">
+ * <property name="defaultMetadata">
+ * <map>
+ * <entry key="{http://dnetlib.eu/endpointReference}infrastructure" value="${infrastructure.name}" />
+ * </map>
+ * </property>
+ * </bean>
+ *
+ *
+ *
+ * @author marko
+ *
+ */
+public class CxfEndpointReferenceBuilder extends AbstractEndpointReferenceBuilder {
+ /**
+ * logger.
+ */
+ private static final Log log = LogFactory.getLog(CxfEndpointReferenceBuilder.class); // NOPMD by marko on 11/24/08 4:55
+
+ /**
+ * users can put some default metadata elements into all EPRs.
+ */
+ private Map defaultMetadata;
+
+ /**
+ * regexp utility.
+ */
+ private final transient Perl5Util matcher = new Perl5Util();
+
+ /**
+ * namespace of the ResourceIdentifier reference parameter.
+ */
+ private String riNamespace = "http://www.driver.org";
+
+ /**
+ * element name of the ResourceIdentifier reference parameter.
+ */
+ private String riElementName = "ResourceIdentifier";
+
+ /**
+ * {@inheritDoc}
+ *
+ * TODO: refactor.
+ *
+ * @see eu.dnetlib.soap.EndpointReferenceBuilder#getEndpointReference(java.lang.Object, java.util.Map)
+ */
+
+ @Override
+ public W3CEndpointReference getEndpointReference(final Endpoint endpoint, final String referenceParam, final Map attributes) {
+ final String address = getAddress(endpoint);
+ return getEndpointReference(address, endpoint.getService().getName(), endpoint.getEndpointInfo().getName(), null, referenceParam,
+ attributes);
+ }
+
+ /**
+ * low level method which allows the construction of a endpoint reference knowing all basic data as the address, service name etc.
+ *
+ * @param address
+ * @param serviceName
+ * @param endpointName
+ * @param wsdl
+ * @param referenceParam
+ * @param attributes
+ * @return
+ */
+ public W3CEndpointReference getEndpointReference(
+ final String address,
+ final QName serviceName,
+ final QName endpointName,
+ final String wsdl,
+ final String referenceParam,
+ final Map attributes) {
+ Map attrs = attributes;
+
+ final W3CEndpointReferenceBuilder builder = new W3CEndpointReferenceBuilder();
+ builder.address(address);
+ if(serviceName != null)
+ builder.serviceName(serviceName);
+ if(endpointName != null)
+ builder.endpointName(endpointName);
+ builder.wsdlDocumentLocation(wsdl);
+
+ if (defaultMetadata != null) {
+ if (attrs == null)
+ attrs = new HashMap();
+ for (Entry entry : defaultMetadata.entrySet())
+ attrs.put(splitQNameString(entry.getKey()), entry.getValue());
+ }
+
+ try {
+ final Document doc = DocumentBuilderFactory.newInstance().newDocumentBuilder().newDocument(); // NOPMD
+ if (referenceParam != null) {
+ final Element referenceElement = doc.createElementNS(getRiNamespace(), getRiElementName());
+ referenceElement.setTextContent(referenceParam);
+ builder.referenceParameter(referenceElement);
+ }
+
+ if (attrs != null && !attrs.isEmpty()) {
+ for (Entry entry : attrs.entrySet()) {
+ final QName qname = entry.getKey();
+ final Element element = doc.createElementNS(qname.getNamespaceURI(), qname.getLocalPart());
+ element.setTextContent((String) entry.getValue());
+ builder.metadata(element);
+ }
+ }
+ } catch (ParserConfigurationException e) {
+ log.fatal("cannot extend EPR", e);
+ throw new IllegalStateException("cannot extend EPR", e);
+ }
+
+ return builder.build();
+ }
+
+ /**
+ * compute an endpoint address.
+ *
+ * @param endpoint
+ * endpoint
+ * @return url as string
+ */
+ @Override
+ public String getAddress(final Endpoint endpoint) {
+ return endpoint.getEndpointInfo().getAddress();
+ }
+
+ /**
+ * helper method for converting "{namespace}elementName" strings to QNames.
+ *
+ * @param key
+ * "{namespace}elementName" string
+ * @return qname
+ */
+ private QName splitQNameString(final String key) {
+ matcher.match("m/{(.*)}(.*)/", key);
+
+ return new QName(matcher.group(1), matcher.group(2));
+ }
+
+ public Map getDefaultMetadata() {
+ return defaultMetadata;
+ }
+
+ public void setDefaultMetadata(final Map defaultMetadata) {
+ this.defaultMetadata = defaultMetadata;
+ }
+
+ public String getRiNamespace() {
+ return riNamespace;
+ }
+
+ public void setRiNamespace(final String riNamespace) {
+ this.riNamespace = riNamespace;
+ }
+
+ public String getRiElementName() {
+ return riElementName;
+ }
+
+ public void setRiElementName(final String riElementName) {
+ this.riElementName = riElementName;
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/soap/cxf/JaxwsEndpointReferenceBuilder.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/soap/cxf/JaxwsEndpointReferenceBuilder.java
new file mode 100644
index 0000000..5e1d7df
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/soap/cxf/JaxwsEndpointReferenceBuilder.java
@@ -0,0 +1,64 @@
+package eu.dnetlib.soap.cxf;
+
+import java.util.Map;
+
+import javax.xml.namespace.QName;
+import javax.xml.ws.Endpoint;
+import javax.xml.ws.wsaddressing.W3CEndpointReference;
+
+import org.apache.cxf.jaxws.EndpointImpl;
+import org.springframework.beans.factory.annotation.Required;
+
+import eu.dnetlib.soap.AbstractEndpointReferenceBuilder;
+
+/**
+ * This EndpointReferenceBuilder implementation takes a jaxws endpoint and extracts the cxf endpoint from it.
+ *
+ * jaxws endpoints are the most readily available endpoint objects since they constructed from jaxws:endpoint spring
+ * beans, as shown in the CXF documentation.
+ *
+ * Since this implementation forwards the job to CxfEndpointReferenceBuilder, the 'builder' property has to be set:
+ *
+ *
+ * <bean name="jaxwsEndpointReferenceBuilder" class="eu.dnetlib.soap.cxf.JaxwsEndpointReferenceBuilder"
+ * p:builder-ref="cxfEndpointReferenceBuilder" />
+ *
+ *
+ * @author marko
+ * @see CxfEndpointReferenceBuilder
+ *
+ */
+public class JaxwsEndpointReferenceBuilder extends AbstractEndpointReferenceBuilder {
+
+ /**
+ * required reference to the cxf endpoint builder.
+ */
+ private CxfEndpointReferenceBuilder builder = null;
+
+ /**
+ * simply unpacks the cxf endpoint from the jaxws endpoint and forwards it to CxfEndpointReferenceBuilder.
+ *
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.soap.EndpointReferenceBuilder#getEndpointReference(java.lang.Object, java.util.Map)
+ */
+ @Override
+ public W3CEndpointReference getEndpointReference(final Endpoint endpoint, final String referenceParam, final Map attrs) {
+ return builder.getEndpointReference(((EndpointImpl) endpoint).getServer().getEndpoint(), referenceParam, attrs);
+ }
+
+ public CxfEndpointReferenceBuilder getBuilder() {
+ return builder;
+ }
+
+ @Required
+ public void setBuilder(final CxfEndpointReferenceBuilder builder) {
+ this.builder = builder;
+ }
+
+ @Override
+ public String getAddress(Endpoint endpoint) {
+ return builder.getAddress(((EndpointImpl) endpoint).getServer().getEndpoint());
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/soap/cxf/StandaloneCxfEndpointReferenceBuilder.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/soap/cxf/StandaloneCxfEndpointReferenceBuilder.java
new file mode 100644
index 0000000..938a58e
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/soap/cxf/StandaloneCxfEndpointReferenceBuilder.java
@@ -0,0 +1,97 @@
+package eu.dnetlib.soap.cxf;
+
+import java.net.URI;
+import java.net.URISyntaxException;
+
+import javax.annotation.PostConstruct;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.cxf.endpoint.Endpoint;
+import org.springframework.beans.factory.annotation.Required;
+
+/**
+ * CxfEndpointReferenceBuilder is not able to create correct endpoint addresses outside a http request context. This means that service
+ * initialization code cannot obtain the service address and thus cannot register himself.
+ *
+ * This subclass allows putting a local address (ip/dns + port) to be used when the runtime servlet context is not available.
+ *
+ * TODO: automated tomcat port detection, trough org.apache.catalina.ServerFactory.getServer().getServices() TODO: automated jetty port
+ * detection
+ *
+ *
+ * @author marko
+ *
+ */
+public class StandaloneCxfEndpointReferenceBuilder extends CxfEndpointReferenceBuilder {
+
+ private static final Log log = LogFactory.getLog(StandaloneCxfEndpointReferenceBuilder.class); // NOPMD by marko on 11/24/08 5:02 PM
+
+ /**
+ * base url where all services are exported.
+ */
+ private String baseAddress;
+
+ private String absoluteBase;
+
+ private boolean forceLocalAddress = false;
+
+ public String getBaseAddress() {
+ return baseAddress;
+ }
+
+ public void setBaseAddress(final String baseAddress) {
+ this.baseAddress = baseAddress;
+ }
+
+ @PostConstruct
+ public void init() throws URISyntaxException {
+ URI base = new URI(baseAddress);
+ log.info("base address: " + baseAddress);
+
+ this.absoluteBase = (new URI(base.getScheme(), base.getUserInfo(), base.getHost(), base.getPort(), null, null, null)).toString().trim();
+ log.info("absolute base address: " + absoluteBase);
+ }
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.soap.cxf.CxfEndpointReferenceBuilder#getAddress(org.apache.cxf.endpoint.Endpoint)
+ */
+ @Override
+ public String getAddress(final Endpoint endpoint) {
+ final String address = super.getAddress(endpoint);
+
+ if (forceLocalAddress) {
+ try {
+ URI uri = new URI(address);
+ if (!address.startsWith("http://")) {
+ String res = baseAddress + uri.getPath();
+ if (log.isDebugEnabled()) {
+ log.debug("fixing address to: " + res);
+ }
+ return res;
+ }
+ String res = absoluteBase + uri.getPath();
+ if (log.isDebugEnabled()) {
+ log.debug("forcing address to: " + res);
+ }
+ return res;
+ } catch (URISyntaxException e) {
+ throw new IllegalArgumentException(e);
+ }
+ }
+
+ if (!address.startsWith("http://") && (baseAddress != null)) { return baseAddress + address; }
+ return address;
+ }
+
+ public boolean isForceLocalAddress() {
+ return forceLocalAddress;
+ }
+
+ @Required
+ public void setForceLocalAddress(final boolean forceLocalAddress) {
+ this.forceLocalAddress = forceLocalAddress;
+ }
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/AbstractBaseService.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/AbstractBaseService.java
new file mode 100644
index 0000000..0957d65
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/AbstractBaseService.java
@@ -0,0 +1,85 @@
+package eu.dnetlib.enabling.tools;
+
+import javax.jws.WebService;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.context.Lifecycle;
+
+import eu.dnetlib.common.rmi.BaseService;
+
+/**
+ * This class contains default definition for BaseService contract and basic service lifecycle.
+ *
+ * TODO: split BaseService contract implementation from lifecycle and other helper method
+ *
+ * @author marko
+ *
+ */
+@WebService(targetNamespace = "http://services.dnetlib.eu/")
+public abstract class AbstractBaseService implements BaseService, Lifecycle {
+
+ /**
+ * logger.
+ */
+ private static final Log log = LogFactory // NOPMD by marko on 11/24/08 5:02 PM
+ .getLog(AbstractBaseService.class);
+
+ private boolean started = false;
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.common.rmi.BaseService#identify()
+ */
+ @Override
+ public String identify() {
+ return getClass().getName();
+ }
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.common.rmi.BaseService#notify(java.lang.String, java.lang.String, java.lang.String, java.lang.String)
+ */
+ @Override
+ public void notify(final String subscriptionId, final String topic, final String isId, final String message) {
+ log.debug("got notification: " + topic + ", profile: " + isId + ", body: " + message);
+ }
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.common.rmi.BaseService#start()
+ */
+ @Override
+ public void start() {
+ log.info("Starting service " + identify());
+ if (started) {
+ log.warn("Service " + this + "already started, check bean initializations!");
+ }
+ started = true;
+ }
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see org.springframework.context.Lifecycle#isRunning()
+ */
+ @Override
+ public boolean isRunning() {
+ log.debug("called isRunning " + this);
+ return false;
+ }
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see org.springframework.context.Lifecycle#stop()
+ */
+ @Override
+ public void stop() {
+ log.info("Stopping service " + this);
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/AbstractServiceLocator.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/AbstractServiceLocator.java
new file mode 100644
index 0000000..7e9002a
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/AbstractServiceLocator.java
@@ -0,0 +1,119 @@
+package eu.dnetlib.enabling.tools;
+
+import java.io.StringReader;
+import java.io.StringWriter;
+import java.util.Map;
+
+import javax.annotation.Resource;
+import javax.xml.parsers.DocumentBuilder;
+import javax.xml.parsers.DocumentBuilderFactory;
+import javax.xml.ws.wsaddressing.W3CEndpointReference;
+import javax.xml.xpath.XPath;
+import javax.xml.xpath.XPathConstants;
+import javax.xml.xpath.XPathFactory;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.w3c.dom.Document;
+import org.w3c.dom.Element;
+import org.w3c.dom.NodeList;
+import org.xml.sax.InputSource;
+
+import com.google.common.collect.Maps;
+
+import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpException;
+import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService;
+import eu.dnetlib.soap.cxf.StandaloneCxfEndpointReferenceBuilder;
+
+@Deprecated
+public abstract class AbstractServiceLocator implements ServiceLocator {
+
+ /**
+ * lookup locator.
+ */
+ @Resource(name="lookupLocator")
+ private ServiceLocator lookUpLocator;
+
+ /**
+ * build epr.
+ */
+ @Resource
+ private StandaloneCxfEndpointReferenceBuilder eprBuilder;
+
+ /**
+ * service resolver. used to create proxies for discovered services.
+ */
+ @Resource(name="serviceResolver")
+ private ServiceResolver serviceResolver;
+
+ /**
+ * logger.
+ */
+ private static final Log log = LogFactory.getLog(AbstractServiceLocator.class); // NOPMD by marko on 11/24/08 5:02 PM
+
+
+ @Override
+ public T getService(final String profileId, final Class clazz) {
+ final String profile = executeQuery(profileId, null);
+
+ try {
+ final XPathFactory factory = XPathFactory.newInstance();
+ final XPath xpath = factory.newXPath();
+
+ final DocumentBuilderFactory docFactory = DocumentBuilderFactory.newInstance();
+ final DocumentBuilder docBuilder = docFactory.newDocumentBuilder();
+
+ final Document doc = docBuilder.parse(new InputSource(new StringReader(profile)));
+ final String url = xpath.evaluate("//url", doc);
+ final String serviceId = xpath.evaluate("//id", doc);
+
+ final NodeList propElements = (NodeList) xpath.evaluate("//PROPERTY", doc, XPathConstants.NODESET);
+ final Map props = Maps.newHashMap();
+
+ for (int i = 0; i < propElements.getLength(); i++) {
+ Element propElement = (Element) propElements.item(i);
+ props.put(propElement.getAttribute("key"), propElement.getAttribute("value"));
+ }
+
+ final W3CEndpointReference epr = eprBuilder.getEndpointReference(url, null, null, url + "?wsdl", null, null);
+
+ final ServiceRunningInstance instance = new ServiceRunningInstance(epr, serviceId, url, props);
+
+ return serviceResolver.getService(clazz, instance.getEpr());
+ } catch(Exception e) {
+ log.error("cannot instantiate service from id: " + profileId, e);
+ throw new IllegalStateException("cannot instantiate service from id: " + profileId, e);
+ }
+ }
+
+ @Override
+ public String getServiceId(final String profileId) {
+ return executeQuery(profileId, "/RESOURCE_PROFILE/HEADER/RESOURCE_IDENTIFIER/@value/string()");
+ }
+
+ private String executeQuery(final String profileId, final String xpath) {
+ final StringWriter sw = new StringWriter();
+ sw.append("let $uri:=/RESOURCE_PROFILE/HEADER[./RESOURCE_IDENTIFIER/@value='");
+ sw.append(profileId);
+ sw.append("']/RESOURCE_URI/@value/string()");
+ sw.append("\n\n");
+ sw.append("for $x in collection('/db/DRIVER/ServiceResources')/RESOURCE_PROFILE/HEADER");
+ sw.append("\n");
+ sw.append("where $x/RESOURCE_PROFILE/HEADER/RESOURCE_URI/@value = $uri");
+ sw.append("\n");
+ sw.append("return $x");
+ if (xpath != null) {
+ sw.append(xpath);
+ }
+ final String xq = sw.toString();
+
+ try {
+ return lookUpLocator.getService().getResourceProfileByQuery(xq);
+ } catch (ISLookUpException e) {
+ log.error("cannot locate service using query: " + xq, e);
+ throw new IllegalStateException("cannot locate service using query: " + xq, e);
+ }
+ }
+
+
+}
\ No newline at end of file
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/AbstractServiceResolverImpl.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/AbstractServiceResolverImpl.java
new file mode 100644
index 0000000..63e9fec
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/AbstractServiceResolverImpl.java
@@ -0,0 +1,32 @@
+package eu.dnetlib.enabling.tools;
+
+import javax.xml.transform.dom.DOMResult;
+import javax.xml.ws.wsaddressing.W3CEndpointReference;
+import javax.xml.xpath.XPathExpressionException;
+import javax.xml.xpath.XPathFactory;
+
+/**
+ * implement common functionality of ServiceResolvers.
+ *
+ * @author marko
+ *
+ */
+public abstract class AbstractServiceResolverImpl implements ServiceResolver {
+
+ /**
+ * {@inheritDoc}
+ * @see eu.dnetlib.enabling.tools.ServiceResolver#getResourceIdentifier(javax.xml.ws.wsaddressing.W3CEndpointReference)
+ */
+ @Override
+ public String getResourceIdentifier(final W3CEndpointReference epr) {
+ final DOMResult dom = new DOMResult();
+ epr.writeTo(dom);
+
+ try {
+ return XPathFactory.newInstance().newXPath().evaluate("//*[local-name() = 'ResourceIdentifier']", dom.getNode());
+ } catch (XPathExpressionException e) {
+ throw new IllegalStateException("cannot construct xpath expression", e);
+ }
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/DOMOpaqueResource.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/DOMOpaqueResource.java
new file mode 100644
index 0000000..6c298e1
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/DOMOpaqueResource.java
@@ -0,0 +1,264 @@
+package eu.dnetlib.enabling.tools;
+
+import java.io.StringWriter;
+import java.util.Date;
+
+import javax.xml.transform.Transformer;
+import javax.xml.transform.TransformerConfigurationException;
+import javax.xml.transform.TransformerException;
+import javax.xml.transform.TransformerFactory;
+import javax.xml.transform.TransformerFactoryConfigurationError;
+import javax.xml.transform.dom.DOMSource;
+import javax.xml.transform.stream.StreamResult;
+import javax.xml.xpath.XPath;
+import javax.xml.xpath.XPathConstants;
+import javax.xml.xpath.XPathExpressionException;
+import javax.xml.xpath.XPathFactory;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.w3c.dom.Document;
+import org.w3c.dom.Element;
+
+import eu.dnetlib.miscutils.datetime.DateUtils;
+
+/**
+ * OpaqueResource holding a plain old DOM document.
+ *
+ * @author marko
+ *
+ */
+public class DOMOpaqueResource implements OpaqueResource {
+ /**
+ * xpath expression error message.
+ */
+ private static final String XPATH_ERROR = "cannot compile xpath expression";
+
+ /**
+ * value attribute.
+ */
+ private static final String VALUE_ATTR = "value";
+
+ /**
+ * logger.
+ */
+ private static final Log log = LogFactory.getLog(DOMOpaqueResource.class); // NOPMD by marko on 11/24/08 5:02 PM
+
+ /**
+ * resource identifier.
+ */
+ private String resourceId;
+
+ /**
+ * resource type.
+ */
+ private String resourceType;
+
+ /**
+ * resource kind.
+ */
+ private String resourceKind;
+
+ /**
+ * resource uri.
+ */
+ private String resourceUri;
+
+ /**
+ * modification time stamp.
+ */
+ private Date modificationDate;
+
+ /**
+ * original document DOM.
+ */
+ private Document dom;
+
+ /**
+ * xslt transformer instance.
+ */
+ private Transformer transformer;
+
+ /**
+ * construct a DOMOpaqueInstance from a W3C DOM document.
+ *
+ * @param dom
+ * DOM document
+ * @throws XPathExpressionException
+ * happens
+ */
+ public DOMOpaqueResource(final Document dom) throws XPathExpressionException {
+ this.dom = dom;
+
+ try {
+ transformer = TransformerFactory.newInstance().newTransformer();
+ } catch (TransformerConfigurationException e) {
+ throw new IllegalStateException("transformer configuration", e);
+ } catch (TransformerFactoryConfigurationError e) {
+ throw new IllegalStateException("transformer configuration", e);
+ }
+
+ final XPath xpath = XPathFactory.newInstance().newXPath();
+
+ this.resourceId = xpath.evaluate("/RESOURCE_PROFILE/HEADER/RESOURCE_IDENTIFIER/@value", dom);
+ this.resourceType = xpath.evaluate("/RESOURCE_PROFILE/HEADER/RESOURCE_TYPE/@value", dom);
+ this.resourceKind = xpath.evaluate("/RESOURCE_PROFILE/HEADER/RESOURCE_KIND/@value", dom);
+ this.resourceUri = xpath.evaluate("/RESOURCE_PROFILE/HEADER/RESOURCE_URI/@value", dom);
+
+ String modificationDateSource = xpath.evaluate("/RESOURCE_PROFILE/HEADER/DATE_OF_CREATION/@value", dom);
+
+ try {
+ this.modificationDate = new DateUtils().parse(modificationDateSource);
+ } catch (IllegalStateException e) {
+ log.debug("invalid date '" + modificationDateSource + "'", e);
+ }
+ }
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.enabling.tools.OpaqueResource#asDom()
+ */
+ @Override
+ public Document asDom() {
+ return getDom();
+ }
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.enabling.tools.OpaqueResource#asString()
+ */
+ @Override
+ public String asString() {
+ final StringWriter writer = new StringWriter();
+
+ try {
+ transformer.transform(new DOMSource(getDom()), new StreamResult(writer));
+ } catch (TransformerException e) {
+ log.fatal("cannot serialize document", e);
+ return null;
+ }
+ return writer.toString();
+ }
+
+ public Document getDom() {
+ return dom;
+ }
+
+ public void setDom(final Document dom) {
+ this.dom = dom;
+ }
+
+ @Override
+ public String getResourceId() {
+ return resourceId;
+ }
+
+ @Override
+ public String getResourceType() {
+ return resourceType;
+ }
+
+ public void setResourceType(final String resourceType) {
+ this.resourceType = resourceType;
+ }
+
+ @Override
+ public String getResourceKind() {
+ return resourceKind;
+ }
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.enabling.tools.OpaqueResource#setResourceKind(java.lang.String)
+ */
+ @Override
+ public void setResourceKind(final String resourceKind) {
+ try {
+ final XPath xpath = XPathFactory.newInstance().newXPath();
+ final Element kindEl = (Element) xpath.evaluate("/RESOURCE_PROFILE/HEADER/RESOURCE_KIND", asDom(), XPathConstants.NODE);
+ kindEl.setAttribute(VALUE_ATTR, resourceKind);
+ this.resourceKind = resourceKind;
+ } catch (XPathExpressionException e) {
+ throw new IllegalStateException(XPATH_ERROR, e);
+ }
+
+ }
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.enabling.tools.OpaqueResource#setResourceId(java.lang.String)
+ */
+ @Override
+ public void setResourceId(final String identifier) {
+ try {
+ final XPath xpath = XPathFactory.newInstance().newXPath();
+ final Element idEl = (Element) xpath.evaluate("/RESOURCE_PROFILE/HEADER/RESOURCE_IDENTIFIER", asDom(), XPathConstants.NODE);
+ idEl.setAttribute(VALUE_ATTR, identifier);
+ resourceId = identifier;
+ } catch (XPathExpressionException e) {
+ throw new IllegalStateException(XPATH_ERROR, e);
+ }
+ }
+
+ @Override
+ public Date getModificationDate() {
+ return modificationDate;
+ }
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.enabling.tools.OpaqueResource#setModificationDate(java.util.Date)
+ */
+ @Override
+ public void setModificationDate(final Date modificationDate) {
+ try {
+ final XPath xpath = XPathFactory.newInstance().newXPath();
+ final Element idEl = (Element) xpath.evaluate("/RESOURCE_PROFILE/HEADER/DATE_OF_CREATION", asDom(), XPathConstants.NODE);
+ if (idEl == null) {
+ log.warn("resource with type " + getResourceType() + " has no date of creation element");
+ return;
+ }
+ idEl.setAttribute(VALUE_ATTR, new DateUtils(modificationDate).getDateAsISO8601String());
+ this.modificationDate = modificationDate;
+ } catch (XPathExpressionException e) {
+ throw new IllegalStateException(XPATH_ERROR, e);
+ }
+
+ }
+
+ @Override
+ public String getResourceUri() {
+ return resourceUri;
+ }
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.enabling.tools.OpaqueResource#setResourceUri(java.lang.String)
+ */
+ @Override
+ public void setResourceUri(final String resourceUri) {
+ try {
+ final XPath xpath = XPathFactory.newInstance().newXPath();
+ final Element uriEl = (Element) xpath.evaluate("/RESOURCE_PROFILE/HEADER/RESOURCE_URI", asDom(), XPathConstants.NODE);
+ uriEl.setAttribute(VALUE_ATTR, resourceUri);
+ this.resourceUri = resourceUri;
+ } catch (XPathExpressionException e) {
+ throw new IllegalStateException(XPATH_ERROR, e);
+ }
+ }
+
+ public Transformer getTransformer() {
+ return transformer;
+ }
+
+ public void setTransformer(final Transformer transformer) {
+ this.transformer = transformer;
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/DefaultServiceLocatorLocationScorer.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/DefaultServiceLocatorLocationScorer.java
new file mode 100644
index 0000000..874c7f1
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/DefaultServiceLocatorLocationScorer.java
@@ -0,0 +1,107 @@
+package eu.dnetlib.enabling.tools;
+
+import java.net.MalformedURLException;
+import java.net.URL;
+
+import javax.annotation.Resource;
+
+import eu.dnetlib.soap.cxf.StandaloneCxfEndpointReferenceBuilder;
+
+/**
+ * Assign better scores for near services. Can be configured.
+ *
+ * @author marko
+ *
+ */
+@Deprecated
+public class DefaultServiceLocatorLocationScorer implements DynamicServiceLocatorLocationScorer {
+
+ /**
+ * default score assigned when the other service has the same host.
+ */
+ private static final int LOCAL_HOST_SCORE = 5;
+
+ /**
+ * default score assigned when the other service has the same host and port (same container).
+ */
+ private static final int LOCAL_PORT_SCORE = 10;
+
+ /**
+ * default score assigned when the other service has the same host and port (same container and context).
+ */
+ private static final int LOCAL_SRV_SCORE = 15;
+
+
+ /**
+ * score assigned when the other service has the same host.
+ */
+ private int localHostScore = LOCAL_HOST_SCORE;
+
+ /**
+ * score assigned when the other service has the same host and port (same container).
+ */
+ private int localPortScore = LOCAL_PORT_SCORE;
+
+ /**
+ * score assigned when the other service has the same host and port (same container and context).
+ */
+ private int localSrvScore = LOCAL_SRV_SCORE;
+
+ /**
+ * build epr.
+ */
+ @Resource
+ private StandaloneCxfEndpointReferenceBuilder eprBuilder;
+
+ /**
+ * {@inheritDoc}
+ * @throws MalformedURLException
+ * @see eu.dnetlib.enabling.tools.DynamicServiceLocatorLocationScorer#score(java.net.URL)
+ */
+ @Override
+ public int score(final URL url) throws MalformedURLException {
+ final URL localBase = new URL(eprBuilder.getBaseAddress());
+ if (url.toString().startsWith(localBase.toString()))
+ return localSrvScore;
+
+ if (localBase.getHost().equals(url.getHost())) {
+ if (localBase.getPort() == url.getPort())
+ return localPortScore;
+ return localHostScore;
+ }
+ return 0;
+ }
+
+ public StandaloneCxfEndpointReferenceBuilder getEprBuilder() {
+ return eprBuilder;
+ }
+
+ public void setEprBuilder(final StandaloneCxfEndpointReferenceBuilder eprBuilder) {
+ this.eprBuilder = eprBuilder;
+ }
+
+ public int getLocalHostScore() {
+ return localHostScore;
+ }
+
+ public void setLocalHostScore(final int localHostScore) {
+ this.localHostScore = localHostScore;
+ }
+
+ public int getLocalPortScore() {
+ return localPortScore;
+ }
+
+ public void setLocalPortScore(final int localPortScore) {
+ this.localPortScore = localPortScore;
+ }
+
+ public int getLocalSrvScore() {
+ return localSrvScore;
+ }
+
+ public void setLocalSrvScore(final int localSrvScore) {
+ this.localSrvScore = localSrvScore;
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/DynamicHNMLocator.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/DynamicHNMLocator.java
new file mode 100644
index 0000000..6ac18f4
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/DynamicHNMLocator.java
@@ -0,0 +1,62 @@
+package eu.dnetlib.enabling.tools;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.beans.factory.annotation.Required;
+
+import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpDocumentNotFoundException;
+import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpException;
+import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService;
+import eu.dnetlib.enabling.locators.UniqueServiceLocator;
+
+/**
+ * Locates a registered HNM running on a given url.
+ *
+ * @author marko
+ *
+ */
+@Deprecated
+public class DynamicHNMLocator implements HNMLocator {
+
+ /**
+ * logger.
+ */
+ private static final Log log = LogFactory.getLog(DynamicHNMLocator.class); // NOPMD by marko on 11/24/08 5:02 PM
+
+ /**
+ * service locator.
+ */
+ UniqueServiceLocator serviceLocator;
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.enabling.tools.HNMLocator#getHNMForUrl(java.lang.String)
+ */
+ @Override
+ public String getHNMForUrl(final String url) {
+
+ final String prefix = url.substring(0, url.indexOf('/', "http://".length()));
+ final String query = "collection('')//RESOURCE_PROFILE[.//RESOURCE_TYPE/@value = 'HostingNodeManagerServiceResourceType' and starts-with(.//RESOURCE_URI/@value, '"
+ + prefix + "')]//RESOURCE_IDENTIFIER/@value/string()";
+
+ try {
+ return serviceLocator.getService(ISLookUpService.class).getResourceProfileByQuery(query);
+ } catch (final ISLookUpDocumentNotFoundException e) {
+ log.debug("doument not found for query: " + query);
+ return null;
+ } catch (final ISLookUpException e) {
+ throw new IllegalStateException("cannot search hnm", e);
+ }
+ }
+
+ public UniqueServiceLocator getServiceLocator() {
+ return serviceLocator;
+ }
+
+ @Required
+ public void setServiceLocator(UniqueServiceLocator serviceLocator) {
+ this.serviceLocator = serviceLocator;
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/DynamicServiceEnumerator.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/DynamicServiceEnumerator.java
new file mode 100644
index 0000000..9ab9b70
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/DynamicServiceEnumerator.java
@@ -0,0 +1,182 @@
+package eu.dnetlib.enabling.tools;
+
+import java.io.IOException;
+import java.io.StringReader;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import javax.annotation.Resource;
+import javax.xml.parsers.DocumentBuilder;
+import javax.xml.parsers.DocumentBuilderFactory;
+import javax.xml.parsers.ParserConfigurationException;
+import javax.xml.ws.wsaddressing.W3CEndpointReference;
+import javax.xml.xpath.XPath;
+import javax.xml.xpath.XPathConstants;
+import javax.xml.xpath.XPathExpressionException;
+import javax.xml.xpath.XPathFactory;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.beans.factory.annotation.Required;
+import org.w3c.dom.Document;
+import org.w3c.dom.Element;
+import org.w3c.dom.NodeList;
+import org.xml.sax.InputSource;
+import org.xml.sax.SAXException;
+
+import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpException;
+import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService;
+import eu.dnetlib.enabling.tools.registration.ServiceNameResolver;
+import eu.dnetlib.miscutils.collections.EnsureCollection;
+import eu.dnetlib.soap.cxf.StandaloneCxfEndpointReferenceBuilder;
+
+/**
+ * Enumerates all services of a given type.
+ *
+ * @author marko
+ *
+ * @param
+ * service class
+ */
+@Deprecated
+public class DynamicServiceEnumerator implements ServiceEnumerator {
+
+ /**
+ * logger.
+ */
+ private static final Log log = LogFactory.getLog(DynamicServiceEnumerator.class); // NOPMD by marko on 11/24/08 5:02 PM
+
+ /**
+ * service class
+ */
+ private Class clazz;
+
+ /**
+ * lookup locator.
+ */
+ private ServiceLocator lookUpLocator;
+
+ /**
+ * service name resolver.
+ */
+ @Resource
+ private ServiceNameResolver serviceNameResolver; // NOPMD
+
+ /**
+ * build epr.
+ */
+ @Resource
+ private StandaloneCxfEndpointReferenceBuilder eprBuilder;
+
+ /**
+ * default constructor, useful for spring based instantiation.
+ */
+ public DynamicServiceEnumerator() {
+ // default
+ }
+
+ /**
+ * Build a dynamic service enumerator for a given class
+ *
+ * @param clazz
+ * class
+ */
+ public DynamicServiceEnumerator(final Class clazz) {
+ super();
+ this.clazz = clazz;
+ }
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.enabling.tools.ServiceEnumerator#getServices()
+ */
+ @Override
+ public List> getServices() {
+ final String serviceName = serviceNameResolver.getName(clazz);
+ log.debug("searching for service: " + serviceName);
+
+ final String xquery = "for $x in collection('/db/DRIVER/ServiceResources')//RESOURCE_PROFILE[.//RESOURCE_TYPE/@value/string() = '"
+ + serviceName
+ + "ResourceType'] return {$x//RESOURCE_IDENTIFIER/@value/string()}{$x//PROTOCOL[@name = 'SOAP']/@address/string()}{$x//SERVICE_PROPERTIES/PROPERTY}";
+ log.debug(xquery);
+
+ final XPathFactory factory = XPathFactory.newInstance();
+ final XPath xpath = factory.newXPath();
+
+ final DocumentBuilderFactory docFactory = DocumentBuilderFactory.newInstance();
+
+ try {
+ final DocumentBuilder docBuilder = docFactory.newDocumentBuilder();
+
+ final List services = lookUpLocator.getService().quickSearchProfile(xquery);
+ final List> instances = new ArrayList>();
+
+ for (final String source : EnsureCollection.list(services)) {
+ final Document doc = docBuilder.parse(new InputSource(new StringReader(source)));
+ final String url = xpath.evaluate("//url", doc);
+ final String serviceId = xpath.evaluate("//id", doc);
+
+ final NodeList propElements = (NodeList) xpath.evaluate("//PROPERTY", doc, XPathConstants.NODESET);
+ Map props = new HashMap();
+
+ for (int i = 0; i < propElements.getLength(); i++) {
+ Element propElement = (Element) propElements.item(i);
+ props.put(propElement.getAttribute("key"), propElement.getAttribute("value"));
+ }
+
+ final W3CEndpointReference epr = eprBuilder.getEndpointReference(url, null, null, url + "?wsdl", null, null);
+
+ instances.add(new ServiceRunningInstance(epr, serviceId, url, props));
+ }
+
+ return instances;
+ } catch (final ISLookUpException e) {
+ throw new IllegalStateException("cannot locate service " + serviceName, e);
+ } catch (final XPathExpressionException e) {
+ throw new IllegalStateException("cannot locate service " + serviceName, e);
+ } catch (final SAXException e) {
+ throw new IllegalStateException("cannot locate service " + serviceName, e);
+ } catch (final IOException e) {
+ throw new IllegalStateException("cannot locate service " + serviceName, e);
+ } catch (final ParserConfigurationException e) {
+ throw new IllegalStateException("cannot locate service " + serviceName, e);
+ }
+ }
+
+ public Class getClazz() {
+ return clazz;
+ }
+
+ @Required
+ public void setClazz(final Class clazz) {
+ this.clazz = clazz;
+ }
+
+ public ServiceLocator getLookUpLocator() {
+ return lookUpLocator;
+ }
+
+ public void setLookUpLocator(final ServiceLocator lookUpLocator) {
+ this.lookUpLocator = lookUpLocator;
+ }
+
+ public ServiceNameResolver getServiceNameResolver() {
+ return serviceNameResolver;
+ }
+
+ public void setServiceNameResolver(final ServiceNameResolver serviceNameResolver) {
+ this.serviceNameResolver = serviceNameResolver;
+ }
+
+ public StandaloneCxfEndpointReferenceBuilder getEprBuilder() {
+ return eprBuilder;
+ }
+
+ public void setEprBuilder(StandaloneCxfEndpointReferenceBuilder eprBuilder) {
+ this.eprBuilder = eprBuilder;
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/DynamicServiceLocator.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/DynamicServiceLocator.java
new file mode 100644
index 0000000..120ca5a
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/DynamicServiceLocator.java
@@ -0,0 +1,205 @@
+package eu.dnetlib.enabling.tools;
+
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.util.Collections;
+import java.util.Comparator;
+import java.util.List;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.beans.factory.annotation.Required;
+
+import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService;
+import eu.dnetlib.enabling.tools.registration.ServiceNameResolver;
+import eu.dnetlib.soap.cxf.StandaloneCxfEndpointReferenceBuilder;
+
+/**
+ * Locates a service through dynamic service discovery.
+ *
+ * @author marko
+ *
+ * @param
+ */
+@Deprecated
+public class DynamicServiceLocator extends AbstractServiceLocator {
+
+ /**
+ * logger.
+ */
+ private static final Log log = LogFactory.getLog(DynamicServiceLocator.class); // NOPMD by marko on 11/24/08 5:02 PM
+
+ /**
+ * service interface.
+ */
+ private Class clazz;
+
+ /**
+ * lookup locator.
+ */
+ private ServiceLocator lookUpLocator;
+
+ /**
+ * service name resolver.
+ */
+ @Resource
+ private ServiceNameResolver serviceNameResolver; // NOPMD
+
+ /**
+ * build epr.
+ * TODO: obsolete, replace by full enumerator injection
+ */
+ @Resource
+ private StandaloneCxfEndpointReferenceBuilder eprBuilder;
+
+ /**
+ * service resolver. used to create proxies for discovered services.
+ */
+ private ServiceResolver serviceResolver;
+
+ /**
+ * delegate the score computation to this component. By default use a DefaultServiceLocatorLocationScorer.
+ */
+ private DynamicServiceLocatorLocationScorer scorer;
+
+ /**
+ * service enumerator.
+ */
+ private ServiceEnumerator enumerator;
+
+ /**
+ * By default use a DefaultServiceLocatorLocationScorer if no scorer is defined.
+ */
+ @PostConstruct
+ protected void init() {
+ if (scorer == null) {
+ final DefaultServiceLocatorLocationScorer tmp = new DefaultServiceLocatorLocationScorer();
+ tmp.setEprBuilder(eprBuilder);
+ scorer = tmp;
+ }
+
+ if (enumerator == null) {
+ final DynamicServiceEnumerator tmp = new DynamicServiceEnumerator(clazz);
+ tmp.setLookUpLocator(lookUpLocator);
+ tmp.setServiceNameResolver(serviceNameResolver);
+ tmp.setEprBuilder(eprBuilder);
+ enumerator = tmp;
+ }
+ }
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.enabling.tools.ServiceLocator#getService()
+ */
+ @Override
+ public T getService() {
+ return serviceResolver.getService(clazz, findFirstCandidate().getEpr());
+ }
+
+ @Override
+ public String getServiceId() {
+ return findFirstCandidate().getServiceId();
+ }
+
+ private ServiceRunningInstance findFirstCandidate() {
+ final String serviceName = serviceNameResolver.getName(clazz);
+ log.debug("searching for service: " + serviceName);
+
+ // TODO: backward compat hack
+ if(enumerator == null) {
+ log.warn("Enumerator is null in " + this + ". Postconstruct not called by spring, please check. Now called manually to workaround this problem");
+ init();
+ }
+
+
+ final List> candidates = enumerator.getServices();
+ if (candidates == null || candidates.isEmpty())
+ throw new IllegalStateException("cannot locate service " + serviceName + ", no matching service profile found");
+
+ Collections.sort(candidates, new Comparator>() {
+ @Override
+ public int compare(final ServiceRunningInstance o1, final ServiceRunningInstance o2) {
+ try {
+ final Integer u1Score = computeScore(new URL(o1.getUrl()));
+ final Integer u2Score = computeScore(new URL(o2.getUrl()));
+ return -u1Score.compareTo(u2Score);
+ } catch (MalformedURLException e) {
+ log.warn("ignoring service with malformed url", e);
+ return 0;
+ }
+ }
+ });
+ log.debug(candidates);
+
+ return candidates.get(0);
+ }
+
+ /**
+ * compute the score for a given service url.
+ *
+ * @param url
+ * url to be scored
+ * @return score
+ * @throws MalformedURLException
+ * happens
+ */
+ protected int computeScore(final URL url) throws MalformedURLException {
+ return scorer.score(url);
+ }
+
+ public Class getClazz() {
+ return clazz;
+ }
+
+ @Required
+ public void setClazz(final Class clazz) {
+ this.clazz = clazz;
+ }
+
+ public ServiceLocator getLookUpLocator() {
+ return lookUpLocator;
+ }
+
+ @Required
+ public void setLookUpLocator(final ServiceLocator lookUpLocator) {
+ this.lookUpLocator = lookUpLocator;
+ }
+
+ public ServiceNameResolver getServiceNameResolver() {
+ return serviceNameResolver;
+ }
+
+ public void setServiceNameResolver(final ServiceNameResolver serviceNameResolver) { // NOPMD
+ this.serviceNameResolver = serviceNameResolver;
+ }
+
+ public StandaloneCxfEndpointReferenceBuilder getEprBuilder() {
+ return eprBuilder;
+ }
+
+ public void setEprBuilder(final StandaloneCxfEndpointReferenceBuilder eprBuilder) {
+ this.eprBuilder = eprBuilder;
+ }
+
+ @Required
+ public ServiceResolver getServiceResolver() {
+ return serviceResolver;
+ }
+
+ public void setServiceResolver(final ServiceResolver serviceResolver) {
+ this.serviceResolver = serviceResolver;
+ }
+
+ public DynamicServiceLocatorLocationScorer getScorer() {
+ return scorer;
+ }
+
+ public void setScorer(final DynamicServiceLocatorLocationScorer scorer) {
+ this.scorer = scorer;
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/DynamicServiceLocatorLocationScorer.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/DynamicServiceLocatorLocationScorer.java
new file mode 100644
index 0000000..59f3684
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/DynamicServiceLocatorLocationScorer.java
@@ -0,0 +1,21 @@
+package eu.dnetlib.enabling.tools;
+
+import java.net.MalformedURLException;
+import java.net.URL;
+
+/**
+ * Implementors of this interface provide custom methods to assign scores to services based solely on their location.
+ * @author marko
+ *
+ */
+@Deprecated
+public interface DynamicServiceLocatorLocationScorer {
+ /**
+ * Compute the score assigned to a given service location (url).
+ *
+ * @param url service url
+ * @return score (the higher the better)
+ * @throws MalformedURLException could happen
+ */
+ int score(URL url) throws MalformedURLException;
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/HNMLocator.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/HNMLocator.java
new file mode 100644
index 0000000..a308efe
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/HNMLocator.java
@@ -0,0 +1,19 @@
+package eu.dnetlib.enabling.tools;
+
+/**
+ * finds an HNM profile for a giver service url.
+ *
+ * @author marko
+ *
+ */
+public interface HNMLocator {
+
+ /**
+ * finds an HNM profile for a giver service url.
+ *
+ * @param url
+ * service address
+ * @return hnm id
+ */
+ String getHNMForUrl(String url);
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/JaxwsServiceResolverImpl.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/JaxwsServiceResolverImpl.java
new file mode 100644
index 0000000..77bfce9
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/JaxwsServiceResolverImpl.java
@@ -0,0 +1,25 @@
+package eu.dnetlib.enabling.tools;
+
+import javax.xml.ws.WebServiceFeature;
+import javax.xml.ws.wsaddressing.W3CEndpointReference;
+
+/**
+ * This service resolver asks jaxws to obtain a proxy to a remote service.
+ *
+ * @author marko
+ *
+ */
+public class JaxwsServiceResolverImpl extends AbstractServiceResolverImpl implements ServiceResolver {
+
+ /**
+ * {@inheritDoc}
+ * @see eu.dnetlib.enabling.tools.ServiceResolver#getService(java.lang.Class, javax.xml.ws.wsaddressing.W3CEndpointReference)
+ */
+ @Override
+ public T getService(final Class clazz, final W3CEndpointReference epr) {
+ synchronized(this) {
+ return epr.getPort(clazz, new WebServiceFeature[] {});
+ }
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/LocalServiceResolverImpl.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/LocalServiceResolverImpl.java
new file mode 100644
index 0000000..34960cb
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/LocalServiceResolverImpl.java
@@ -0,0 +1,91 @@
+package eu.dnetlib.enabling.tools;
+
+import java.io.StringReader;
+import java.util.Map;
+
+import javax.xml.ws.wsaddressing.W3CEndpointReference;
+import javax.xml.xpath.XPathExpressionException;
+import javax.xml.xpath.XPathFactory;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.xml.sax.InputSource;
+
+/**
+ * This service resolver parses the EPR and returns a local reference to a service instance if the EPR refers to the
+ * local node.
+ *
+ * @author marko
+ *
+ */
+public class LocalServiceResolverImpl extends AbstractServiceResolverImpl implements ServiceResolver, ApplicationContextAware {
+ private static final Log log = LogFactory.getLog(LocalServiceResolverImpl.class); // NOPMD by marko on 11/24/08 5:02 PM
+
+ private String baseAddress;
+
+ private ApplicationContext applicationContext;
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.enabling.tools.ServiceResolver#getService(java.lang.Class,
+ * javax.xml.ws.wsaddressing.W3CEndpointReference)
+ */
+ @Override
+ public T getService(final Class clazz, final W3CEndpointReference epr) {
+
+ // backward compat
+ if (baseAddress == null) {
+ log.warn("please set baseAddress in " + this);
+ return null;
+ }
+
+ try {
+ // TODO: measure performance impact of this. I wrote it this way just to be sure of thread safety
+ String address = XPathFactory.newInstance().newXPath().evaluate("/*[local-name() ='EndpointReference']/*[local-name() = 'Address']",
+ new InputSource(new StringReader(epr.toString())));
+ if (log.isDebugEnabled())
+ log.debug("epr address " + address);
+
+ if (address.startsWith(baseAddress))
+ return resolveLocalService(clazz, epr);
+ } catch (XPathExpressionException e) {
+ log.warn("cannot parse epr", e);
+ }
+
+ return null;
+ }
+
+ private T resolveLocalService(final Class clazz, W3CEndpointReference epr) {
+ log.debug("resolving local service " + clazz);
+
+ Map services = (Map) applicationContext.getBeansOfType(clazz, false, false);
+
+ log.debug("found services: " + services);
+ if(services.size() > 0)
+ for(T service : services.values())
+ return service;
+
+ return null;
+ }
+
+ public String getBaseAddress() {
+ return baseAddress;
+ }
+
+ public void setBaseAddress(String baseAddress) {
+ this.baseAddress = baseAddress;
+ }
+
+ public ApplicationContext getApplicationContext() {
+ return applicationContext;
+ }
+
+ @Override
+ public void setApplicationContext(ApplicationContext applicationContext) {
+ this.applicationContext = applicationContext;
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/NullHNMLocator.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/NullHNMLocator.java
new file mode 100644
index 0000000..30dc2d0
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/NullHNMLocator.java
@@ -0,0 +1,21 @@
+package eu.dnetlib.enabling.tools;
+
+/**
+ * simplest HNM locator: doesn't find any.
+ *
+ * @author marko
+ *
+ */
+public class NullHNMLocator implements HNMLocator {
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.enabling.tools.HNMLocator#getHNMForUrl(java.lang.String)
+ */
+ @Override
+ public String getHNMForUrl(final String url) {
+ return "";
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/OpaqueResource.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/OpaqueResource.java
new file mode 100644
index 0000000..7cab9f7
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/OpaqueResource.java
@@ -0,0 +1,98 @@
+package eu.dnetlib.enabling.tools;
+
+import java.util.Date;
+
+import org.w3c.dom.Document;
+
+/**
+ * Some services, in particular the enabling layer, needs to manipulate all types of resources without knowing the exact
+ * structure of their content, but only some well defined properties defined here.
+ *
+ *
+ * Different wrappers can be provided for different kind of resources. For example resources returned from the xmldb
+ * layer can be cheaply mapped to an OpaqueResource, without going to full xml->bean conversion.
+ *
+ *
+ * @author marko
+ *
+ */
+public interface OpaqueResource {
+ /**
+ * Resource type.
+ *
+ * @return resource type string
+ */
+ String getResourceType();
+
+ /**
+ * Resource kind.
+ *
+ * @return resource kind string
+ */
+ String getResourceKind();
+
+ /**
+ * Resource identifier.
+ *
+ * @return resource identifier string
+ */
+ String getResourceId();
+
+ /**
+ * Resource URI.
+ *
+ * @return resource uri string
+ */
+ String getResourceUri();
+
+ /**
+ * get modification time stamp.
+ *
+ * @return time stamp
+ */
+ Date getModificationDate();
+
+ /**
+ * Implementors may need to serialize the resource to a xml string representation.
+ *
+ * @return xml serialization
+ */
+ String asString();
+
+ /**
+ * Implementors may store the DOM in the first place. Otherwise they should
+ * return a parsed w3c DOM instance.
+ *
+ * @return DOM document
+ */
+ Document asDom();
+
+ /**
+ * change the resource identifier.
+ *
+ * @param identifier new identifier
+ */
+ void setResourceId(String identifier);
+
+ /**
+ * change the resource kind.
+ *
+ * @param kind new kind
+ */
+ void setResourceKind(String kind);
+
+ /**
+ * change the resource uri.
+ *
+ * @param uri new uri
+ */
+ void setResourceUri(String uri);
+
+ /**
+ * set modification timestamp.
+ *
+ * @param timeStamp modification time stamp
+ */
+ void setModificationDate(Date timeStamp);
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ResourceIdentifierResolver.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ResourceIdentifierResolver.java
new file mode 100644
index 0000000..1c6add9
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ResourceIdentifierResolver.java
@@ -0,0 +1,30 @@
+package eu.dnetlib.enabling.tools;
+
+/**
+ * Resource identifiers may carry, implicitly or explicity, some informations about the location of the resource in the
+ * hierarchical xmldb namespace.
+ *
+ * Implementors of this interface may take different approachs to the problem.
+ *
+ * @author marko
+ *
+ */
+public interface ResourceIdentifierResolver {
+ /**
+ * get the xmldb filename associated to this resource identifier, usually extracted from the identifier itself.
+ *
+ * @param resId resource identifier
+ * @return xmldb file name
+ */
+ String getFileName(String resId);
+
+ /**
+ * get the xmldb collection name associated to this resource identifier.
+ * Implementors may decide to encode it in the identifier itself or use a secondary associative memory.
+ * to quickly transform identifiers.
+ *
+ * @param resId resource identifier
+ * @return xmldb collection name
+ */
+ String getCollectionName(String resId);
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ResourceLoaderHelper.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ResourceLoaderHelper.java
new file mode 100644
index 0000000..1c48148
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ResourceLoaderHelper.java
@@ -0,0 +1,44 @@
+package eu.dnetlib.enabling.tools;
+
+import org.springframework.context.ResourceLoaderAware;
+import org.springframework.core.io.ResourceLoader;
+import org.springframework.core.io.support.ResourcePatternResolver;
+import org.springframework.core.io.support.ResourcePatternUtils;
+
+/**
+ * Some beans aren't directly instantiated (like quartz jobs for instance), so they cannot receive the resource loader
+ * by implementing the ResourceLoaderAware interface.
+ *
+ * This class is a temporary solution to this problem until we find a way to obtain a bean reference to the
+ * application context (the actual resource loader) itself and inject it directly. It could be done by turning this
+ * class into a bean factory and expose the resource loader through it.
+ *
+ * @author marko
+ *
+ */
+public class ResourceLoaderHelper implements ResourceLoaderAware {
+
+ /**
+ * injected resource loader.
+ */
+ private ResourceLoader resourceLoader;
+
+ /**
+ * obtain a resource pattern resolver for a given resource loader.
+ *
+ * @return pattern resolver
+ */
+ public ResourcePatternResolver getResourcePatternResolver() {
+ return ResourcePatternUtils.getResourcePatternResolver(getResourceLoader());
+ }
+
+ public ResourceLoader getResourceLoader() {
+ return resourceLoader;
+ }
+
+ @Override
+ public void setResourceLoader(final ResourceLoader resourceLoader) {
+ this.resourceLoader = resourceLoader;
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ServiceEnumerator.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ServiceEnumerator.java
new file mode 100644
index 0000000..c791616
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ServiceEnumerator.java
@@ -0,0 +1,19 @@
+package eu.dnetlib.enabling.tools;
+
+import java.util.List;
+
+/**
+ * A service enumerator returns a bunch of service descriptions. The logic depends on the service enumerator.
+ *
+ * @author marko
+ *
+ */
+@Deprecated
+public interface ServiceEnumerator {
+ /**
+ * Obtain a list of services.
+ *
+ * @return a list of service running instance descriptions
+ */
+ List> getServices();
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ServiceLocator.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ServiceLocator.java
new file mode 100644
index 0000000..2c4abaa
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ServiceLocator.java
@@ -0,0 +1,47 @@
+package eu.dnetlib.enabling.tools;
+
+/**
+ * A service locator provides a reference to a, possibly remote, service.
+ *
+ * @author marko
+ *
+ * @param
+ * the type of the service to return
+ * @deprecated As of release 2.0.0, use instead {@link eu.dnetlib.enabling.locators.DefaultUniqueServiceLocator}
+ */
+@Deprecated
+public interface ServiceLocator {
+
+ /**
+ * locate and return a service of this type.
+ *
+ * @return a service client instance
+ */
+ T getService();
+
+ /**
+ * Locate using a profileID (service or datastructure) the service of this type.
+ *
+ * @param profileId
+ * @param clazz
+ * @return a service client instance
+ */
+ T getService(final String profileId, final Class clazz);
+
+ /**
+ * locate and return a service ID.
+ *
+ * @return a service ID
+ */
+ String getServiceId();
+
+ /**
+ * locate and return a service ID.
+ *
+ * @param profileId
+ * (the id of the service or the id of one of its datastructures)
+ * @return a service ID.
+ */
+ String getServiceId(final String profileId);
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ServiceLocatorChain.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ServiceLocatorChain.java
new file mode 100644
index 0000000..d1225e3
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ServiceLocatorChain.java
@@ -0,0 +1,69 @@
+package eu.dnetlib.enabling.tools;
+
+import java.util.Collection;
+
+/**
+ * This class allows chaining several service locators and return the first one matching. Usually this is usefully when
+ * we want a StaticLocator as a fallback if the DynamicLocator cannot find anything.
+ *
+ * @author marko
+ *
+ * @param
+ * service type
+ */
+@Deprecated
+public class ServiceLocatorChain extends AbstractServiceLocator {
+
+ /**
+ * service locators, iterated in order.
+ */
+ private Collection> locators;
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.enabling.tools.ServiceLocator#getService()
+ */
+ @Override
+ public T getService() {
+ IllegalStateException lastException = null; // NOPMD
+
+ for (ServiceLocator locator : locators) {
+ try {
+ return locator.getService();
+ } catch (IllegalStateException e) {
+ lastException = e;
+ }
+ }
+ if (lastException != null) {
+ throw new IllegalStateException("cannot find any matching service. Last locator in the chain reported as cause", lastException);
+ }
+ throw new IllegalStateException("cannot find any matching service: the service locator chain is empty");
+ }
+
+ @Override
+ public String getServiceId() {
+ IllegalStateException lastException = null; // NOPMD
+
+ for (ServiceLocator locator : locators) {
+ try {
+ return locator.getServiceId();
+ } catch (IllegalStateException e) {
+ lastException = e;
+ }
+ }
+ if (lastException != null) {
+ throw new IllegalStateException("cannot find any matching service. Last locator in the chain reported as cause", lastException);
+ }
+ throw new IllegalStateException("cannot find any matching service: the service locator chain is empty");
+ }
+
+ public Collection> getLocators() {
+ return locators;
+ }
+
+ public void setLocators(final Collection> locators) {
+ this.locators = locators;
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ServiceResolver.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ServiceResolver.java
new file mode 100644
index 0000000..3888ecb
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ServiceResolver.java
@@ -0,0 +1,32 @@
+package eu.dnetlib.enabling.tools;
+
+import javax.xml.ws.wsaddressing.W3CEndpointReference;
+
+/**
+ * Instances of this type resolve EPR references to service endpoints.
+ *
+ * @author marko
+ *
+ */
+public interface ServiceResolver {
+ /**
+ * return a service client given an EPR instance.
+ *
+ * @param
+ * the service type
+ * @param clazz
+ * needed for type inference of type parameter
+ * @param epr
+ * EPR
+ * @return a service client reference
+ */
+ T getService(Class clazz, W3CEndpointReference epr);
+
+ /**
+ * Extract the resource identifier embedded in the EPR.
+ *
+ * @param epr end point reference
+ * @return resource identifier
+ */
+ String getResourceIdentifier(W3CEndpointReference epr);
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ServiceResolverChain.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ServiceResolverChain.java
new file mode 100644
index 0000000..a512c25
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ServiceResolverChain.java
@@ -0,0 +1,61 @@
+package eu.dnetlib.enabling.tools;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import javax.xml.ws.wsaddressing.W3CEndpointReference;
+
+/**
+ * This resolver chains a list of resolvers.
+ *
+ * @author marko
+ *
+ */
+public class ServiceResolverChain implements ServiceResolver {
+
+ /**
+ * service resolvers in decreasing order or priority.
+ */
+ private List resolvers = new ArrayList();
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.enabling.tools.ServiceResolver#getService(java.lang.Class,
+ * javax.xml.ws.wsaddressing.W3CEndpointReference)
+ */
+ @Override
+ public T getService(final Class clazz, final W3CEndpointReference epr) {
+ for (ServiceResolver resolver : getResolvers()) {
+ final T service = resolver.getService(clazz, epr);
+
+ if (service != null)
+ return service;
+ }
+ return null;
+ }
+
+ /**
+ * {@inheritDoc}
+ * @see eu.dnetlib.enabling.tools.ServiceResolver#getResourceIdentifier(javax.xml.ws.wsaddressing.W3CEndpointReference)
+ */
+ @Override
+ public String getResourceIdentifier(final W3CEndpointReference epr) {
+ for (ServiceResolver resolver : getResolvers()) {
+ final String rsId = resolver.getResourceIdentifier(epr);
+
+ if (rsId != null)
+ return rsId;
+ }
+ return null;
+ }
+
+ public List getResolvers() {
+ return resolvers;
+ }
+
+ public void setResolvers(final List resolvers) {
+ this.resolvers = resolvers;
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ServiceRunningInstance.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ServiceRunningInstance.java
new file mode 100644
index 0000000..cc1bfba
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/ServiceRunningInstance.java
@@ -0,0 +1,95 @@
+package eu.dnetlib.enabling.tools;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import javax.xml.ws.wsaddressing.W3CEndpointReference;
+
+/**
+ * This bean packages the minimum information for describing a service running instance.
+ *
+ * @author marko
+ *
+ */
+@Deprecated
+public class ServiceRunningInstance {
+ /**
+ * service endpoint.
+ */
+ private W3CEndpointReference epr;
+
+ /**
+ * service resource id.
+ */
+ private String serviceId;
+
+ /**
+ * service endpoint url.
+ */
+ private String url;
+
+ /**
+ * arbitrary service properties stored in the profile.
+ */
+ private Map serviceProperties;
+
+ /**
+ * Create a service running instance.
+ *
+ * @param epr service epr
+ * @param serviceId service profile resource id
+ * @param url service endpoint url
+ */
+ public ServiceRunningInstance(final W3CEndpointReference epr, final String serviceId, final String url) {
+ this(epr, serviceId, url, new HashMap());
+ }
+
+ /**
+ * Create a service running instance.
+ *
+ * @param epr service epr
+ * @param serviceId service profile resource id
+ * @param url service endpoint url
+ * @param serviceProperties service property map
+ */
+ public ServiceRunningInstance(final W3CEndpointReference epr, final String serviceId, final String url, final Map serviceProperties) {
+ super();
+ this.epr = epr;
+ this.serviceId = serviceId;
+ this.url = url;
+ this.serviceProperties = serviceProperties;
+ }
+
+ public W3CEndpointReference getEpr() {
+ return epr;
+ }
+
+ public void setEpr(final W3CEndpointReference epr) {
+ this.epr = epr;
+ }
+
+ public String getServiceId() {
+ return serviceId;
+ }
+
+ public void setServiceId(final String serviceId) {
+ this.serviceId = serviceId;
+ }
+
+ public Map getServiceProperties() {
+ return serviceProperties;
+ }
+
+ public void setServiceProperties(final Map serviceProperties) {
+ this.serviceProperties = serviceProperties;
+ }
+
+ public String getUrl() {
+ return url;
+ }
+
+ public void setUrl(String url) {
+ this.url = url;
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/SplittedQueryExecutor.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/SplittedQueryExecutor.java
new file mode 100644
index 0000000..fbf1b42
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/SplittedQueryExecutor.java
@@ -0,0 +1,171 @@
+package eu.dnetlib.enabling.tools;
+
+import java.util.List;
+import java.util.Map;
+
+import org.springframework.beans.factory.annotation.Required;
+
+import com.google.common.collect.Lists;
+
+import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpDocumentNotFoundException;
+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.miscutils.collections.PositionalStringMapGenerator;
+
+/**
+ * Utility class which interacts with a lookup, performs a query and fills a java domain object splitting the result into constructor
+ * arguments.
+ *
+ * @author marko
+ *
+ */
+public class SplittedQueryExecutor {
+
+ /**
+ * service locator.
+ */
+ private UniqueServiceLocator serviceLocator;
+
+ /**
+ * default constructor. lookupLocator has to be injected.
+ */
+ public SplittedQueryExecutor() {
+ // empty
+ }
+
+ /**
+ * Commodity constructor for constructor injection.
+ *
+ * @param lookupLocator
+ * lookup locator
+ */
+ public SplittedQueryExecutor(final UniqueServiceLocator serviceLocator) {
+ super();
+ this.serviceLocator = serviceLocator;
+ }
+
+ /**
+ * Performs the query, splits the result at ":-:".
+ *
+ * @param
+ * domain class type
+ * @param clazz
+ * domain class
+ * @param query
+ * xquery
+ * @return iterable of domain class instances
+ */
+ public Iterable query(final Class clazz, final String query) {
+ return query(clazz, query, ":-:");
+ }
+
+ /**
+ * Performs the query, splits the result at separator
+ *
+ * @param
+ * domain class type
+ * @param clazz
+ * domain class
+ * @param query
+ * xquery
+ * @param separator
+ * split separator
+ * @return iterable of domain class instances
+ */
+ public Iterable query(final Class clazz, final String query, final String separator) {
+ return new PositionalStringMapGenerator().split(clazz, performQuery(query), separator);
+ }
+
+ /**
+ * Return a list of maps of splitted query results
+ *
+ * @param query
+ * xquery
+ * @param keys
+ * list of keys
+ * @return collection of key/value pairs
+ */
+ public Iterable> query(final String query, final String... keys) {
+ return new PositionalStringMapGenerator(keys).split(performQuery(query), ":-:");
+ }
+
+ /**
+ * Like query(String, String..) but returns a container that whose values can be modified.
+ *
+ * @param query
+ * xquery
+ * @param keys
+ * list of keys
+ * @return mutable collection of key/value pairs
+ */
+ public Iterable> mutableQuery(final String query, final String... keys) {
+ return Lists.newArrayList(query(query, keys));
+ }
+
+ /**
+ * Like query(Class, String), but returns a container which can be modified.
+ *
+ * @param
+ * some domain class
+ * @param clazz
+ * domain class
+ * @param query
+ * xquery
+ * @return mutable collection of X
+ */
+ public Iterable mutableQuery(final Class clazz, final String query) {
+ return Lists.newArrayList(query(clazz, query));
+ }
+
+ /**
+ * Like query(Class, String, String), but returns a container which can be modified.
+ *
+ * @param
+ * some domain class
+ * @param clazz
+ * domain class
+ * @param query
+ * xquery
+ * @param separator
+ * separator
+ * @return mutable collection of X
+ */
+ public Iterable mutableQuery(final Class clazz, final String query, final String separator) {
+ return Lists.newArrayList(query(clazz, query, separator));
+ }
+
+ public List performQuery(final String query) {
+ try {
+ return serviceLocator.getService(ISLookUpService.class).quickSearchProfile(query);
+ } catch (final ISLookUpException e) {
+ throw new IllegalStateException(e);
+ }
+ }
+
+ /**
+ * Fetch only one string result.
+ *
+ * @param query
+ * @return null if no such result
+ */
+ public String queryFirst(final String query) {
+ try {
+ return serviceLocator.getService(ISLookUpService.class).getResourceProfileByQuery(query);
+ } catch (ISLookUpDocumentNotFoundException e) {
+ return null;
+ } catch (final ISLookUpException e) {
+ throw new IllegalStateException(e);
+ }
+
+ }
+
+ public UniqueServiceLocator getServiceLocator() {
+ return serviceLocator;
+ }
+
+ @Required
+ public void setServiceLocator(final UniqueServiceLocator serviceLocator) {
+ this.serviceLocator = serviceLocator;
+ }
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/StaticServiceLocator.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/StaticServiceLocator.java
new file mode 100644
index 0000000..1787647
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/StaticServiceLocator.java
@@ -0,0 +1,91 @@
+package eu.dnetlib.enabling.tools;
+
+import java.util.Map;
+
+import org.springframework.beans.BeansException;
+import org.springframework.beans.factory.annotation.Required;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+
+import eu.dnetlib.enabling.tools.registration.ServiceRegistrationManager;
+
+/**
+ * This service locator returns always one service instance.
+ *
+ * Usually declared as a spring bean an injected in service when a static configuration is needed.
+ *
+ * @author marko
+ *
+ * @param
+ * the type of the service
+ */
+@Deprecated
+public class StaticServiceLocator extends AbstractServiceLocator implements ApplicationContextAware {
+
+ /**
+ * static service reference.
+ */
+ private T service;
+
+ private ApplicationContext applicationContext;
+
+ /**
+ * default constructor. initialize with setter.
+ */
+ public StaticServiceLocator() {
+ // no operation
+ }
+
+ /**
+ * construct a static service locator pointing at a given service.
+ *
+ * @param service
+ * service
+ */
+ public StaticServiceLocator(final T service) {
+ this.service = service;
+ }
+
+ /**
+ * The usual usage pattern of service locators is to call chain a direct call
+ * on the result of this method. In order to avoid nullpointer exception, this method throws an exception
+ * with a better explanation, in case the service is null.
+ *
+ * TODO: consider using checked exceptions.
+ *
+ * {@inheritDoc}
+ * @see eu.dnetlib.enabling.tools.ServiceLocator#getService()
+ */
+ @Override
+ public T getService() {
+ if (service == null) {
+ throw new IllegalStateException("cannot find service, check configuration");
+ }
+ return service;
+ }
+
+ @Override
+ public String getServiceId() {
+ final Map beans = applicationContext.getBeansOfType(ServiceRegistrationManager.class);
+
+ if (beans != null) {
+ for (ServiceRegistrationManager r : beans.values()) {
+ if (r.getService() == getService()) {
+ return r.getServiceProfile().getResourceId();
+ }
+ }
+ }
+ throw new IllegalStateException("cannot find service, check configuration");
+ }
+
+ @Required
+ public void setService(final T service) {
+ this.service = service;
+ }
+
+ @Override
+ public void setApplicationContext(final ApplicationContext applicationContext) throws BeansException {
+ this.applicationContext = applicationContext;
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/StreamOpaqueResource.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/StreamOpaqueResource.java
new file mode 100644
index 0000000..9a089a6
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/StreamOpaqueResource.java
@@ -0,0 +1,54 @@
+package eu.dnetlib.enabling.tools; // NOPMD
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.StringWriter;
+
+import javax.xml.parsers.ParserConfigurationException;
+import javax.xml.xpath.XPathExpressionException;
+
+import org.apache.commons.io.IOUtils;
+import org.xml.sax.SAXException;
+
+/**
+ * implements a possibly optimized OpaqueResource constructed from a stream containing the xml source.
+ *
+ * the optimization consists of postponing the parsing as possibly and parse the profile passing the stream
+ * directly to the xml parser.
+ *
+ *
+ * TODO: implement the optimization, currenly converts to string and reuses StringOpaqueResource
+ *
+ *
+ * @author marko
+ *
+ */
+public class StreamOpaqueResource extends StringOpaqueResource {
+
+ /**
+ * construct with an input stream.
+ *
+ * @param source source stream of xml text
+ * @throws XPathExpressionException shouldn't happen
+ * @throws SAXException could happen
+ * @throws IOException could happen
+ * @throws ParserConfigurationException shouldn't happen
+ */
+ public StreamOpaqueResource(final InputStream source) throws XPathExpressionException, SAXException, IOException, ParserConfigurationException {
+ super(stringify(source));
+ }
+
+ /**
+ * helper method: reads a stream to a string.
+ *
+ * @param source input stream
+ * @return string containing the whole stream content.
+ * @throws IOException could happen.
+ */
+ private static String stringify(final InputStream source) throws IOException {
+ final StringWriter writer = new StringWriter();
+ IOUtils.copy(source, writer);
+ return writer.getBuffer().toString();
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/StringOpaqueResource.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/StringOpaqueResource.java
new file mode 100644
index 0000000..77d0e6a
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/StringOpaqueResource.java
@@ -0,0 +1,48 @@
+package eu.dnetlib.enabling.tools; // NOPMD
+
+import java.io.IOException;
+import java.io.StringReader;
+
+import javax.xml.parsers.DocumentBuilderFactory;
+import javax.xml.parsers.ParserConfigurationException;
+import javax.xml.xpath.XPathExpressionException;
+
+import org.xml.sax.InputSource;
+import org.xml.sax.SAXException;
+
+/**
+ * Opaque resource initialized from a string.
+ *
+ * Currently it extends a DOMOpaqueResource, but in future it should postpone xml parsing as late as possible.
+ *
+ * @author marko
+ *
+ */
+public class StringOpaqueResource extends DOMOpaqueResource {
+
+ /**
+ * construct an opaque resource from a xml source string.
+ *
+ * @param source xml source
+ * @throws XPathExpressionException happens
+ * @throws SAXException happens
+ * @throws IOException happens
+ * @throws ParserConfigurationException happens
+ */
+ public StringOpaqueResource(final String source) throws XPathExpressionException, SAXException, IOException, ParserConfigurationException {
+ super(getBuilderFactory().newDocumentBuilder().parse(new InputSource(new StringReader(source))));
+
+ }
+
+ /**
+ * get a namespace aware document builder factory.
+ *
+ * @return document builder factory.
+ */
+ private static DocumentBuilderFactory getBuilderFactory() {
+ final DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
+ factory.setNamespaceAware(true);
+ return factory;
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/UniqueIdentifierGenerator.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/UniqueIdentifierGenerator.java
new file mode 100644
index 0000000..8259536
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/UniqueIdentifierGenerator.java
@@ -0,0 +1,25 @@
+package eu.dnetlib.enabling.tools;
+
+/**
+ * genrate unique identifiers.
+ *
+ * @author marko
+ *
+ */
+public interface UniqueIdentifierGenerator {
+
+ /**
+ * generate a new unique identifier.
+ *
+ * @return string identifier
+ */
+ String generateIdentifier();
+
+ /**
+ * helps identify valid identifiers.
+ *
+ * @return string regex
+ */
+ String getRegEx();
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/UniqueIdentifierGeneratorImpl.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/UniqueIdentifierGeneratorImpl.java
new file mode 100644
index 0000000..785fda3
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/UniqueIdentifierGeneratorImpl.java
@@ -0,0 +1,74 @@
+package eu.dnetlib.enabling.tools;
+
+import java.util.UUID;
+
+/**
+ * generates unique UUID identifiers.
+ *
+ * @author marko
+ *
+ */
+public class UniqueIdentifierGeneratorImpl implements UniqueIdentifierGenerator {
+
+ /**
+ * helps identify valid identifiers.
+ */
+ public static final String UUID_REGEX = "[a-f0-9]{8}-[a-f0-9]{4}-[a-f0-9]{4}-[a-f0-9]{4}-[a-f0-9]{12}";
+
+ /**
+ * prefixes all identifiers with this string.
+ */
+ private String prefix = "";
+
+ /**
+ * create a new instance with an empty prefix.
+ */
+ public UniqueIdentifierGeneratorImpl() {
+ //
+ }
+
+ /**
+ * construct a new instance with a given prefix.
+ *
+ * @param prefix prefix
+ */
+ public UniqueIdentifierGeneratorImpl(final String prefix) {
+ this.prefix = prefix;
+ }
+
+ public String getPrefix() {
+ return prefix;
+ }
+
+ public void setPrefix(final String prefix) {
+ this.prefix = prefix;
+ }
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.enabling.tools.UniqueIdentifierGenerator#generateIdentifier()
+ */
+ @Override
+ public String generateIdentifier() {
+ return prefix + createUUID();
+ }
+
+ /**
+ * the real job of creating the uuid is here.
+ *
+ * @return new uuid
+ */
+ private String createUUID() {
+ return UUID.randomUUID().toString();
+ }
+
+ /**
+ * {@inheritDoc}
+ * @see eu.dnetlib.enabling.tools.UniqueIdentifierGenerator#getRegEx()
+ */
+ @Override
+ public String getRegEx() {
+ return UUID_REGEX;
+ }
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/XQueryUtils.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/XQueryUtils.java
new file mode 100644
index 0000000..7522251
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/XQueryUtils.java
@@ -0,0 +1,39 @@
+package eu.dnetlib.enabling.tools;
+
+/**
+ * Implementations of this interface will provide functionalities useful to create xqueries or parts of thereof, like
+ * xmldb collection names for a given profile.
+ *
+ * @author marko
+ *
+ */
+public interface XQueryUtils {
+ /**
+ * obtain the name of the xmldb collection for a given resource.
+ * @param resource resource
+ * @return path of the collection relative to the xmldb dnet root.
+ */
+ String getCollectionPath(OpaqueResource resource);
+
+ /**
+ * obtain the absolute xmldb collection path for a given resource.
+ * @param resource resource
+ * @return collection absolute path
+ */
+ String getCollectionAbsPath(OpaqueResource resource);
+
+ /**
+ * get the absolute xmldb collection path.
+ *
+ * @return root xmldb root collection path
+ */
+ String getRootCollection();
+
+ /**
+ * Return the xmldb filename for a given resource.
+ *
+ * @param resource resource
+ * @return xmldb filename
+ */
+ String getFileName(OpaqueResource resource);
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/BlackboardServiceRegistrator.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/BlackboardServiceRegistrator.java
new file mode 100644
index 0000000..cca9cbb
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/BlackboardServiceRegistrator.java
@@ -0,0 +1,40 @@
+package eu.dnetlib.enabling.tools.registration;
+
+import javax.xml.ws.Endpoint;
+
+import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService;
+import eu.dnetlib.enabling.is.sn.rmi.ISSNService;
+import eu.dnetlib.enabling.tools.OpaqueResource;
+import eu.dnetlib.enabling.tools.StringOpaqueResource;
+
+/**
+ * This service registrator also subscribes the service to it's own blackboard.
+ *
+ * XXX: this class is a hack. It only works with the ValidatingServiceRegistrationManager
+ *
+ * @author marko
+ *
+ */
+public class BlackboardServiceRegistrator extends ServiceRegistrator {
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.enabling.tools.registration.ServiceRegistrator#validateProfile(java.lang.String)
+ */
+ @Override
+ public String validateProfile(final String profId, final Endpoint endpoint) {
+ final String profileId = super.validateProfile(profId, endpoint);
+
+ try {
+ final OpaqueResource serviceProfile = new StringOpaqueResource(getServiceLocator().getService(ISLookUpService.class).getResourceProfile(profileId));
+
+ getServiceLocator().getService(ISSNService.class, true).subscribe(getEprBuilder().getEndpointReference(endpoint),
+ "UPDATE/" + serviceProfile.getResourceType() + "/" + profileId + "/RESOURCE_PROFILE/BODY/BLACKBOARD/LAST_REQUEST", 0);
+ } catch (Exception e) {
+ throw new IllegalStateException("cannot validate service profile", e);
+ }
+ return profileId;
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/InterfaceServiceNameResolver.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/InterfaceServiceNameResolver.java
new file mode 100644
index 0000000..e7964fe
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/InterfaceServiceNameResolver.java
@@ -0,0 +1,74 @@
+package eu.dnetlib.enabling.tools.registration;
+
+import java.lang.annotation.Annotation;
+
+import javax.jws.WebService;
+
+/**
+ * This service name resolver tries to find the real service name through various heuristics based on the existence of the WebService
+ * annotation on some interface the service implements.
+ *
+ *
+ * NOTE: The search for the interface is depth first on interfaces and then on subclasses.
+ *
+ *
+ * @author marko
+ *
+ */
+public class InterfaceServiceNameResolver implements ServiceNameResolver {
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.enabling.tools.registration.ServiceNameResolver#getName(java.lang.Object)
+ */
+ @Override
+ public String getName(final Object service) {
+
+ Class res = findInterface(WebService.class, service.getClass());
+ if (res == null) {
+ res = service.getClass();
+ }
+
+ return getName(res);
+ }
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.enabling.tools.registration.ServiceNameResolver#getName(java.lang.Class)
+ */
+ @Override
+ public String getName(final Class iface) {
+ return iface.getSimpleName();
+ }
+
+ /**
+ * recursively searches a given annotation and returns the class/interface which contains it.
+ *
+ * @param
+ * annotation type
+ * @param annotation
+ * annotation to search
+ * @param clazz
+ * root of the class hierarchy.
+ * @return class which contains annotation 'annotation'
+ */
+ private Class findInterface(final Class annotation, final Class clazz) {
+ if (clazz == null) return null;
+
+ final T ann = clazz.getAnnotation(annotation);
+ if ((ann != null) && clazz.isInterface()) return clazz;
+
+ for (Class iface : clazz.getInterfaces()) {
+ final Class ires = findInterface(annotation, iface);
+ if (ires != null) return ires;
+ }
+
+ final Class sres = findInterface(annotation, clazz.getSuperclass());
+ if (sres != null) return sres;
+
+ return null;
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/InterfaceServiceNameResolverCompatibility.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/InterfaceServiceNameResolverCompatibility.java
new file mode 100644
index 0000000..514129a
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/InterfaceServiceNameResolverCompatibility.java
@@ -0,0 +1,45 @@
+package eu.dnetlib.enabling.tools.registration;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * Allow manual (external) override of service types, through an appropriate mapping (e.g. injected with spring).
+ *
+ * @author marko
+ *
+ */
+public class InterfaceServiceNameResolverCompatibility extends InterfaceServiceNameResolver {
+
+ /**
+ * Service names resolved with InterfaceServiceNameResolver will be used as keys in this map. If there is a match,
+ * the mapping is used instead of the inferred name.
+ */
+ private Map mapping = new HashMap();
+
+ public Map getMapping() {
+ return mapping;
+ }
+
+ public void setMapping(final Map mapping) {
+ this.mapping = mapping;
+ }
+
+ /**
+ * {@inheritDoc}
+ * @see eu.dnetlib.enabling.tools.registration.InterfaceServiceNameResolver#getName(java.lang.Object)
+ */
+ @Override
+ public String getName(final Class iface) {
+ final String name = super.getName(iface);
+
+ final String override = getMapping().get(name);
+ if (override != null)
+ return override;
+
+ if(name.charAt(0) == 'I' && Character.isUpperCase(name.charAt(1)) && !Character.isUpperCase(name.charAt(2)))
+ return name.substring(1);
+
+ return name;
+ }
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/ServiceNameResolver.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/ServiceNameResolver.java
new file mode 100644
index 0000000..41e9832
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/ServiceNameResolver.java
@@ -0,0 +1,26 @@
+package eu.dnetlib.enabling.tools.registration;
+
+/**
+ * Infers the actual name of the service from a service instance.
+ *
+ * @author marko
+ *
+ */
+public interface ServiceNameResolver {
+ /**
+ * returns the service name for a given service.
+ *
+ * @param service service instance
+ * @return service name
+ */
+ String getName(Object service);
+
+
+ /**
+ * Get the service name for a given service interface.
+ *
+ * @param serviceInterface service interface
+ * @return service name.
+ */
+ String getName(Class serviceInterface);
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/ServiceRegistrationManager.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/ServiceRegistrationManager.java
new file mode 100644
index 0000000..9d560cc
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/ServiceRegistrationManager.java
@@ -0,0 +1,55 @@
+package eu.dnetlib.enabling.tools.registration;
+
+import javax.xml.ws.Endpoint;
+
+import org.springframework.beans.factory.annotation.Required;
+
+import eu.dnetlib.enabling.tools.OpaqueResource;
+
+/**
+ * A service registration manager manages the registration of the service profile for a given service.
+ *
+ * @author marko
+ *
+ */
+public interface ServiceRegistrationManager {
+ /**
+ * service to register.
+ *
+ * @param service service instance
+ */
+ @Required
+ void setService(Object service);
+
+ /**
+ * service endpoint.
+ *
+ * @param endpoint service endpoint
+ */
+ @Required
+ void setEndpoint(Endpoint endpoint);
+
+ /**
+ * set to true if we want to disable service registration.
+ *
+ * @param disabled
+ */
+ @Required
+ void setDisabled(boolean disabled);
+
+ /**
+ * returns the service profile associated with the service.
+ *
+ * @return service profile
+ */
+ OpaqueResource getServiceProfile();
+
+ /**
+ * returns the registered service
+ *
+ * @return the service
+ */
+ Object getService();
+
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/ServiceRegistrationManagerImpl.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/ServiceRegistrationManagerImpl.java
new file mode 100644
index 0000000..052c527
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/ServiceRegistrationManagerImpl.java
@@ -0,0 +1,366 @@
+package eu.dnetlib.enabling.tools.registration;
+
+import static eu.dnetlib.enabling.tools.registration.ServiceRegistrationManagerImpl.State.PENDING;
+import static eu.dnetlib.enabling.tools.registration.ServiceRegistrationManagerImpl.State.REGISTERED;
+import static eu.dnetlib.enabling.tools.registration.ServiceRegistrationManagerImpl.State.UNKNOWN;
+import static eu.dnetlib.enabling.tools.registration.ServiceRegistrationManagerImpl.State.UNREGISTERED;
+
+import java.io.IOException;
+
+import javax.xml.parsers.ParserConfigurationException;
+import javax.xml.ws.Endpoint;
+import javax.xml.xpath.XPathExpressionException;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.beans.factory.annotation.Required;
+import org.xml.sax.SAXException;
+
+import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpDocumentNotFoundException;
+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.enabling.tools.OpaqueResource;
+import eu.dnetlib.enabling.tools.StringOpaqueResource;
+
+/**
+ * Simple service registration manager implementation.
+ *
+ *
+ * The simplest way to use of the service registration manager is to declare the following in your bean definition file:
+ *
+ *
+ *
+ * <template:instance name="serviceRegistrationManager"
+ * t:name="myServiceRegistrationManager" t:service="myService" t:endpoint="myServiceEndpoint"
+ * t:jobScheduler="jobScheduler"/>
+ *
+ *
+ *
+ * The ServiceRegistrationManager requires periodic ticks from a quartz job scheduler (the 'jobScheduler' bean in the above example)
+ *
+ *
+ *
+ * See the ValidatingServiceRegistrationManagerImpl class for a special implementation which performs automatic service profile validation.
+ *
+ *
+ * @see ValidatingServiceRegistrationManagerImpl
+ * @author marko
+ *
+ */
+public class ServiceRegistrationManagerImpl implements ServiceRegistrationManager {
+
+ /**
+ * error message: the profile is not found. This actually happens a lot, because of the way the old ISLookUpService API was concieved.
+ */
+ private static final String PROFILE_NOT_FOUND = "profile not found";
+
+ /**
+ * error message: some error during searches for service profile state.
+ */
+ private static final String ERROR_CHECK = "error checking profile";
+
+ /**
+ * logger.
+ */
+ private static final Log log = LogFactory.getLog(ServiceRegistrationManagerImpl.class); // NOPMD by marko on 11/24/08 5:02 PM
+
+ /**
+ * registration manager states.
+ *
+ * @author marko
+ *
+ */
+ public enum State {
+ /**
+ * service profile is either registered or registered and we have to check out if the profile already exists.
+ */
+ UNKNOWN,
+ /**
+ * service profile is not yet registered or the registration disappeared.
+ */
+ UNREGISTERED, /**
+ * the service profile is registered for validation. A validation operation is awaited.
+ */
+ PENDING, /**
+ * the service profile is fully registered.
+ */
+ REGISTERED
+ }
+
+ /**
+ * service profile identifier.
+ */
+ private String profileId;
+
+ /**
+ * service to be registered.
+ */
+ private Object service;
+
+ /**
+ * service endpoint.
+ */
+ private Endpoint endpoint;
+
+ /**
+ * service locator.
+ */
+ private UniqueServiceLocator serviceLocator;
+
+ /**
+ * service registrator.
+ */
+ private ServiceRegistrator registrator;
+
+ /**
+ * service profile resource local cache.
+ */
+ private OpaqueResource serviceProfile;
+
+ /**
+ * if true the service profile schema will be always updated at boot.
+ */
+ private boolean schemaUpdate = true;
+
+ /**
+ * disable the service registration.
+ */
+ private boolean disabled = false;
+
+ /**
+ * registration state of the service profile.
+ */
+ private State state = State.UNKNOWN;
+
+ /**
+ * check if we have already a registered service profile for this service.
+ */
+ void checkExisting() {
+ final String uri = registrator.getEprBuilder().getAddress(endpoint) + "?wsdl";
+ final String query = "for $x in //RESOURCE_PROFILE[.//RESOURCE_URI/@value='" + uri + "']"
+ + " where contains($x//RESOURCE_TYPE/@value/string(), 'Service') return $x";
+
+ try {
+ final OpaqueResource resource = new StringOpaqueResource(serviceLocator.getService(ISLookUpService.class, true).getResourceProfileByQuery(query));
+
+ if ("PendingServiceResources".equals(resource.getResourceKind())) {
+ state = State.PENDING;
+ } else {
+ setProfileId(resource.getResourceId());
+ setServiceProfile(resource);
+ state = State.REGISTERED;
+ }
+ } catch (final ISLookUpDocumentNotFoundException e) {
+ log.debug("there is no service registered for uri: " + uri);
+ state = State.UNREGISTERED;
+ } catch (final ISLookUpException e) {
+ log.warn(ERROR_CHECK, e);
+ } catch (final XPathExpressionException e) {
+ log.warn(ERROR_CHECK, e);
+ } catch (final SAXException e) {
+ log.warn(ERROR_CHECK, e);
+ } catch (final IOException e) {
+ log.warn(ERROR_CHECK, e);
+ } catch (final ParserConfigurationException e) {
+ log.warn(ERROR_CHECK, e);
+ }
+ }
+
+ /**
+ * check that a pending service profile has been validated.
+ *
+ * if it has been validated change the state to REGISTERED.
+ */
+ void checkPending() {
+ log.debug("checking pending status: " + getService());
+
+ final String uri = serviceProfile.getResourceUri();
+ final String query = "collection('')//RESOURCE_PROFILE[.//RESOURCE_URI/@value='" + uri + "']";
+ try {
+ final OpaqueResource resource = new StringOpaqueResource(serviceLocator.getService(ISLookUpService.class, true).getResourceProfileByQuery(query));
+
+ if (!"PendingServiceResources".equals(resource.getResourceKind())) {
+ setProfileId(resource.getResourceId());
+ setServiceProfile(resource);
+ state = State.REGISTERED;
+ }
+ } catch (final ISLookUpDocumentNotFoundException e) {
+ log.debug(PROFILE_NOT_FOUND, e);
+ } catch (final ISLookUpException e) {
+ log.warn(ERROR_CHECK, e);
+ } catch (final XPathExpressionException e) {
+ log.warn(ERROR_CHECK, e);
+ } catch (final SAXException e) {
+ log.warn(ERROR_CHECK, e);
+ } catch (final IOException e) {
+ log.warn(ERROR_CHECK, e);
+ } catch (final ParserConfigurationException e) {
+ log.warn(ERROR_CHECK, e);
+ }
+ }
+
+ /**
+ * ensure the service is registered.
+ */
+ public void registerService() {
+ log.debug("registering service profile: " + getService());
+
+ setProfileId(getRegistrator().registerService(getService(), getEndpoint()));
+
+ if (getProfileId() == null) {
+ log.debug("cannot register profile, no hnm");
+ return;
+ }
+
+ log.debug("Service profile registered: " + getProfileId());
+
+ retrieveServiceProfile();
+ state = State.PENDING;
+ if (getProfileId() == null) throw new IllegalStateException("cannot be true, I'm dreaming");
+ }
+
+ /**
+ * register service schema.
+ */
+ public void registerSchema() {
+ getRegistrator().registerServiceSchema(getService());
+ }
+
+ /**
+ * maintain the cached service profile.
+ */
+ private void retrieveServiceProfile() {
+ log.debug("Retrieving service profile: " + getProfileId());
+
+ try {
+ setServiceProfile(new StringOpaqueResource(serviceLocator.getService(ISLookUpService.class, true).getResourceProfile(getProfileId())));
+ } catch (final ISLookUpDocumentNotFoundException e) {
+ log.debug(PROFILE_NOT_FOUND, e);
+ } catch (final ISLookUpException e) {
+ log.warn(ERROR_CHECK, e);
+ } catch (final XPathExpressionException e) {
+ log.warn(ERROR_CHECK, e);
+ } catch (final SAXException e) {
+ log.warn(ERROR_CHECK, e);
+ } catch (final IOException e) {
+ log.warn(ERROR_CHECK, e);
+ } catch (final ParserConfigurationException e) {
+ log.warn(ERROR_CHECK, e);
+ }
+ }
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see eu.dnetlib.enabling.tools.registration.ServiceRegistrationManager#getServiceProfile()
+ */
+ @Override
+ public OpaqueResource getServiceProfile() {
+ retrieveServiceProfile();
+ return serviceProfile;
+ }
+
+ /**
+ * called periodically to advance the state machine.
+ */
+ public void tick() {
+ if (disabled) return;
+
+ synchronized (registrator) {
+ if (state != REGISTERED) {
+ log.debug("checking service profile registration: " + getService() + " (" + state + ")");
+ }
+
+ if (state == UNKNOWN) {
+ if (schemaUpdate) {
+ registerSchema();
+ }
+ checkExisting();
+ } else if (state == UNREGISTERED) {
+ registerService();
+ } else if (state == PENDING) {
+ checkPending();
+ }
+
+ if (state != REGISTERED) {
+ log.debug("tick finished");
+ }
+ }
+ }
+
+ public void setProfileId(final String profileId) {
+ this.profileId = profileId;
+ }
+
+ public String getProfileId() {
+ return profileId;
+ }
+
+ @Override
+ public Object getService() {
+ return service;
+ }
+
+ @Override
+ public void setService(final Object service) {
+ this.service = service;
+ }
+
+ public Endpoint getEndpoint() {
+ return endpoint;
+ }
+
+ @Override
+ public void setEndpoint(final Endpoint endpoint) {
+ this.endpoint = endpoint;
+ }
+
+ public ServiceRegistrator getRegistrator() {
+ return registrator;
+ }
+
+ @Required
+ public void setRegistrator(final ServiceRegistrator registrator) {
+ this.registrator = registrator;
+ }
+
+ public void setServiceProfile(final OpaqueResource serviceProfile) {
+ this.serviceProfile = serviceProfile;
+ }
+
+ public State getState() {
+ return state;
+ }
+
+ public void setState(final State state) {
+ this.state = state;
+ }
+
+ public boolean isSchemaUpdate() {
+ return schemaUpdate;
+ }
+
+ public void setSchemaUpdate(final boolean schemaUpdate) {
+ this.schemaUpdate = schemaUpdate;
+ }
+
+ public boolean isDisabled() {
+ return disabled;
+ }
+
+ @Override
+ public void setDisabled(final boolean disabled) {
+ this.disabled = disabled;
+ }
+
+ public UniqueServiceLocator getServiceLocator() {
+ return serviceLocator;
+ }
+
+ @Required
+ public void setServiceLocator(UniqueServiceLocator serviceLocator) {
+ this.serviceLocator = serviceLocator;
+ }
+
+}
diff --git a/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/ServiceRegistrator.java b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/ServiceRegistrator.java
new file mode 100644
index 0000000..1ca7fe2
--- /dev/null
+++ b/dnet-core-components/src/main/java/eu/dnetlib/enabling/tools/registration/ServiceRegistrator.java
@@ -0,0 +1,331 @@
+package eu.dnetlib.enabling.tools.registration;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.StringWriter;
+import java.util.HashMap;
+import java.util.Map;
+
+import javax.xml.transform.dom.DOMResult;
+import javax.xml.ws.Endpoint;
+import javax.xml.ws.wsaddressing.W3CEndpointReference;
+
+import org.antlr.stringtemplate.StringTemplate;
+import org.apache.commons.io.IOUtils;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.beans.factory.annotation.Required;
+
+import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpDocumentNotFoundException;
+import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpException;
+import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService;
+import eu.dnetlib.enabling.is.registry.rmi.ISRegistryException;
+import eu.dnetlib.enabling.is.registry.rmi.ISRegistryService;
+import eu.dnetlib.enabling.locators.UniqueServiceLocator;
+import eu.dnetlib.enabling.tools.HNMLocator;
+import eu.dnetlib.enabling.tools.NullHNMLocator;
+import eu.dnetlib.soap.EndpointReferenceBuilder;
+
+/**
+ * This class takes care of registering a service.
+ *
+ * TODO: merge the implementation
+ *
+ * @author marko
+ *
+ */
+public class ServiceRegistrator {
+
+ /**
+ * second.
+ */
+ private static final int SECOND = 0;
+
+ /**
+ * logger.
+ */
+ private static final Log log = LogFactory.getLog(ServiceRegistrator.class); // NOPMD
+ // by
+ // marko
+ // on
+ // 11/24/08
+ // 5:02
+ // PM
+
+ /**
+ * locator.
+ */
+ private UniqueServiceLocator serviceLocator;
+
+ /**
+ * epr builder.
+ */
+ private EndpointReferenceBuilder eprBuilder;
+
+ /**
+ * component which finds an hnm profile.
+ */
+ private HNMLocator hnmLocator = new NullHNMLocator();
+
+ /**
+ * Key-value pairs with service specific parameters which will appear in service profile.
+ */
+ private Map serviceProperties = new HashMap();
+
+ /**
+ * Key-value pairs [name - endpoint] of extra protocols available in service profiles.
+ */
+ private Map extraProtocols = new HashMap