D-Net

{"type_source": "SVN", "goal": "package -U -T 4C source:jar", "url": "http://svn-public.driver.research-infrastructures.eu/driver/dnet45/modules/cnr-service-common/trunk/", "deploy_repository": "dnet45-snapshots", "version": "4", "mail": "sandro.labruzzo@isti.cnr.it,michele.artini@isti.cnr.it, claudio.atzori@isti.cnr.it, alessia.bardi@isti.cnr.it", "deploy_repository_url": "http://maven.research-infrastructures.eu/nexus/content/repositories/dnet45-snapshots", "name": "cnr-service-common"}

package eu.dnetlib.enabling.tools;

import static org.junit.Assert.assertEquals;

import static org.junit.Assert.assertNotNull;

import static org.junit.Assert.assertTrue;

import static org.mockito.Matchers.anyString;

import static org.mockito.Mockito.when;

import java.util.ArrayList;

import java.util.List;

import org.junit.Before;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.mockito.Mock;

import org.mockito.junit.MockitoJUnitRunner;

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.soap.cxf.StandaloneCxfEndpointReferenceBuilder;

/**

 * Test the dynamic service enumerator.

 *

 * @author marko

 *

 */

@RunWith(MockitoJUnitRunner.class)

public class DynamicServiceEnumeratorTest {

	/**

	 * Dummy service interface.

	 *

	 * @author marko

	 *

	 */

	interface TestService {

	}

	/**

	 * instance under test.

	 */

	private transient DynamicServiceEnumerator<TestService> enumerator;

	/**

	 * lookup service locator mock

	 */

	@Mock

	private transient ISLookUpService lookUpService;

	/**

	 * lookup mock locator.

	 */

	private transient ServiceLocator<ISLookUpService> lookUpLocator;

	/**

	 * service name resolver mock.

	 */

	@Mock

	private transient ServiceNameResolver nameResolver;

	/**

	 * epr builder.

	 */

	StandaloneCxfEndpointReferenceBuilder eprBuilder;

	/**

	 * common preparation.

	 */

	@Before

	public void setUp()  {

		lookUpLocator = new StaticServiceLocator<ISLookUpService>(lookUpService);

		eprBuilder = new StandaloneCxfEndpointReferenceBuilder();

		enumerator = new DynamicServiceEnumerator<TestService>(TestService.class);

		enumerator.setLookUpLocator(lookUpLocator);

		enumerator.setServiceNameResolver(nameResolver);

		enumerator.setEprBuilder(eprBuilder);

		when(nameResolver.getName(TestService.class)).thenReturn("TestService");

	}

	/**

	 * test get services.

	 *

	 * @throws ISLookUpException mock exception

	 */

	@Test

	public void testGetServices() throws ISLookUpException {

		List<String> services = new ArrayList<String>();

		services.add("<service><id>123</id><url>http://test.com</url></service>");

		when(lookUpService.quickSearchProfile(anyString())).thenReturn(services);

		List<ServiceRunningInstance<TestService>> instances = enumerator.getServices();

		assertEquals("query size", 1, instances.size());

		assertEquals("service id", "123", instances.get(0).getServiceId());

		assertEquals("service url", "http://test.com", instances.get(0).getUrl());

		assertNotNull("service epr", instances.get(0).getEpr());

	}

	@Test

	public void testEmptyGetServices() throws ISLookUpException {

		List<String> services = new ArrayList<String>();

		when(lookUpService.quickSearchProfile(anyString())).thenReturn(services);

		List<ServiceRunningInstance<TestService>> instances = enumerator.getServices();

		assertTrue("empty", instances.isEmpty());

	}

}

package eu.dnetlib.enabling.tools;

import static org.junit.Assert.*; // NOPMD

import static org.mockito.Mockito.*; // NOPMD

import java.util.List;

import javax.xml.ws.wsaddressing.W3CEndpointReference;

import org.junit.Before;

import org.junit.Test;

import org.junit.runner.RunWith;

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

import org.springframework.test.context.ContextConfiguration;

import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

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

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

import eu.dnetlib.enabling.resultset.rmi.ResultSetService;

/**

 * Test dynamic service locator.

 *

 * @author marko

 *

 */

@RunWith(SpringJUnit4ClassRunner.class)

@ContextConfiguration

public class DynamicServiceLocatorTest {

	/**

	 * instance under test.

	 */

	@Autowired

	private transient DynamicServiceLocator<ResultSetService> serviceLocator;

	/**

	 * list of mock service profiles saved in files.

	 */

	@javax.annotation.Resource(name = "serviceProfiles")

	private transient List<String> serviceUris;

	/**

	 * service resolver mock.

	 */

	private transient ServiceResolver serviceResolver;

	/**

	 * setup.

	 *

	 * @throws ISLookUpException

	 *             mock

	 */

	@Before

	public void setUp() throws ISLookUpException {

//		final ISLookUpService lookupService = mock(ISLookUpService.class);

//		serviceLocator.setLookUpLocator(new StaticServiceLocator<ISLookUpService>(lookupService));

		serviceResolver = mock(ServiceResolver.class);

		serviceLocator.setServiceResolver(serviceResolver);

		final ISLookUpService lookupService = serviceLocator.getLookUpLocator().getService();

		when(lookupService.quickSearchProfile(anyString())).thenReturn(serviceUris);

	}

	/**

	 * test get service.

	 */

	@Test

	public void testGetService() {

		assertNull("dummy", serviceLocator.getService());

		verify(serviceResolver).getService(eq(ResultSetService.class), (W3CEndpointReference) anyObject());

	}

}

package eu.dnetlib.enabling.tools.registration;

import static org.junit.Assert.assertEquals;

import org.junit.Before;

import org.junit.Test;

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

import eu.dnetlib.enabling.resultset.rmi.ResultSetService;

public class InterfaceServiceNameResolverCompatibilityTest {

	private transient InterfaceServiceNameResolverCompatibility resolver;

	private interface IndexService {}

	private interface ISomethingService {}

	@Before

	public void setUp() throws Exception {

		resolver = new InterfaceServiceNameResolverCompatibility();

	}

	@Test

	public void testGetNameClassOfQ() {

		assertEquals("IndexService", resolver.getName(IndexService.class));

		assertEquals("SomethingService", resolver.getName(ISomethingService.class));

		assertEquals("ISRegistryService", resolver.getName(ISRegistryService.class));

		assertEquals("ResultSetService", resolver.getName(ResultSetService.class));

	}

}

package eu.dnetlib.enabling.locators;

import java.util.Map;

import java.util.Set;

import com.google.common.collect.Lists;

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.enabling.locators.comparators.PreferLocalRunningInstanceComparator;

import eu.dnetlib.enabling.resultset.rmi.ResultSetService;

import eu.dnetlib.enabling.tools.OpaqueResource;

import eu.dnetlib.enabling.tools.registration.ServiceNameResolver;

import eu.dnetlib.enabling.tools.registration.ServiceRegistrationManager;

import org.antlr.stringtemplate.StringTemplate;

import org.apache.commons.io.IOUtils;

import org.junit.Before;

import org.junit.Ignore;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.mockito.Mock;

import org.mockito.junit.MockitoJUnitRunner;

import org.springframework.context.ApplicationContext;

import static org.junit.Assert.assertEquals;

import static org.junit.Assert.assertTrue;

import static org.mockito.Matchers.anyString;

import static org.mockito.Mockito.*;

@RunWith(MockitoJUnitRunner.class)

public class DefaultUniqueServiceLocatorTest {

	/**

	 * Class under test.

	 */

	private DefaultUniqueServiceLocator locator;

	@Mock

	private ISLookUpService lookupService;

	@Mock

	private ResultSetService resultsetService;

	@Mock

	private ApplicationContext appContext;

	@Mock

	private ServiceNameResolver serviceNameResolver;

	@Mock

	private ServiceRegistrationManager resultSetRegistrator;

	@Mock

	private OpaqueResource opaqueResource;

	private static final String SERVICE_NAME = "ResultsetService";

	private static final String XQUERY = "for $x in collection('/db/DRIVER/ServiceResources/" + SERVICE_NAME + "ResourceType') return $x";

	@Before

	public void setUp() throws Exception {

		locator = new DefaultUniqueServiceLocator();

		locator.setApplicationContext(appContext);

		locator.setDefaultComparator(new PreferLocalRunningInstanceComparator());

		locator.setServiceNameResolver(serviceNameResolver);

		locator.setIsLookupService(lookupService);

		final Map<String, ServiceRegistrationManager> registratorBeans = Maps.newHashMap();

		registratorBeans.put("resultSetRegistrator", resultSetRegistrator);

		final Map<String, ResultSetService> serviceBeans = Maps.newHashMap();

		serviceBeans.put("resultSetService", resultsetService);

		final StringTemplate st1 = new StringTemplate(IOUtils.toString(getClass().getResourceAsStream("serviceProfile.xml.st")));

		st1.setAttribute("name", SERVICE_NAME);

		st1.setAttribute("id", "1111");

		final StringTemplate st2 = new StringTemplate(IOUtils.toString(getClass().getResourceAsStream("serviceProfile.xml.st")));

		st2.setAttribute("name", SERVICE_NAME);

		st2.setAttribute("id", "2222");

		final StringTemplate st3 = new StringTemplate(IOUtils.toString(getClass().getResourceAsStream("serviceProfile.xml.st")));

		st3.setAttribute("name", SERVICE_NAME);

		st3.setAttribute("id", "3333");

		when(serviceNameResolver.getName(ResultSetService.class)).thenReturn(SERVICE_NAME);

		when(lookupService.quickSearchProfile(XQUERY)).thenReturn(Lists.newArrayList(st1.toString(), st2.toString(), st3.toString()));

		when(lookupService.getResourceProfileByQuery(anyString())).thenReturn(st2.toString());

		//when(appContext.getBeansOfType(ServiceRegistrationManager.class)).thenReturn(registratorBeans);

		//when(appContext.getBeansOfType(ResultSetService.class)).thenReturn(serviceBeans);

		//when(resultSetRegistrator.getServiceProfile()).thenReturn(opaqueResource);

		//when(resultSetRegistrator.getService()).thenReturn(resultsetService);

		//when(opaqueResource.getResourceId()).thenReturn("2222");

	}

	@Test

	public void testGetServiceClassOfT_1() {

		assertEquals(lookupService, locator.getService(ISLookUpService.class));

	}

	@Test

	@Ignore

	public void testGetServiceClassOfT_2() throws ISLookUpException {

		assertEquals(resultsetService, locator.getService(ResultSetService.class, false));

		verify(lookupService, times(1)).quickSearchProfile(XQUERY);

	}

	@Test

	@Ignore

	public void testGetServiceClassOfTComparatorOfServiceRunningInstance() throws ISLookUpException {

		assertEquals(resultsetService, locator.getService(ResultSetService.class, new PreferLocalRunningInstanceComparator()));

		verify(lookupService, times(1)).quickSearchProfile(XQUERY);

	}

	@Test

	@Ignore

	public void testGetServiceClassOfTString() {

		assertEquals(resultsetService, locator.getService(ResultSetService.class, "rs-1234"));

	}

	@Test

	@Ignore

	public void testGetServiceClassOfTBoolean() throws ISLookUpException {

		assertEquals(resultsetService, locator.getService(ResultSetService.class, true));

		verify(lookupService, never()).quickSearchProfile(XQUERY);

	}

	@Test

	public void testGetServiceIdClassOfT() {

		assertEquals("1111", locator.getServiceId(ResultSetService.class));

	}

	@Test

	public void testGetServiceIdClassOfTComparatorOfServiceRunningInstance() {

		assertEquals("1111", locator.getServiceId(ResultSetService.class, new PreferLocalRunningInstanceComparator()));

	}

	@Test

	public void testGetServiceIdClassOfTString() {

		assertEquals("2222", locator.getServiceId(ResultSetService.class, "rs-1234"));

	}

	@Test

	@Ignore

	public void testGetAllServices() {

		final Set<ResultSetService> list = locator.getAllServices(ResultSetService.class);

		assertEquals(3, list.size());

		assertTrue(list.contains(resultsetService));

	}

	@Test

	public void testGetAllServiceIds() {

		final Set<String> list = locator.getAllServiceIds(ResultSetService.class);

		assertEquals(3, list.size());

		assertTrue(list.contains("1111"));

		assertTrue(list.contains("2222"));

		assertTrue(list.contains("3333"));

	}

}

package eu.dnetlib.enabling.locators.comparators;

import static org.junit.Assert.*;

import static org.mockito.Mockito.when;

import org.junit.Before;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.mockito.Mock;

import org.mockito.junit.MockitoJUnitRunner;

import eu.dnetlib.enabling.locators.ServiceRunningInstance;

@RunWith(MockitoJUnitRunner.class)

public class HandledDatastructuresComparatorTest {

	/**

	 * Class Under test.

	 */

	private HandledDatastructuresComparator comparator;

	@Mock

	private ServiceRunningInstance s1;

	@Mock

	private ServiceRunningInstance s2;

	@Mock

	private ServiceRunningInstance s3;

	@Before

	public void setUp() throws Exception {

		comparator = new HandledDatastructuresComparator();

		when(s1.getHandledDatastructures()).thenReturn(0);

		when(s2.getHandledDatastructures()).thenReturn(0);

		when(s3.getHandledDatastructures()).thenReturn(10);

	}

	@Test

	public void testCompare() {

		assertEquals(0, comparator.compare(s1, s2));

		assertEquals(-1, comparator.compare(s1, s3));

		assertEquals(1, comparator.compare(s3, s1));

	}

}

package eu.dnetlib.enabling.locators.comparators;

import static org.junit.Assert.*;

import static org.mockito.Mockito.when;

import org.junit.Before;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.mockito.Mock;

import eu.dnetlib.enabling.locators.ServiceRunningInstance;

import org.mockito.junit.MockitoJUnitRunner;

@RunWith(MockitoJUnitRunner.class)

public class PreferLocalRunningInstanceComparatorTest {

	/**

	 * Class Under test.

	 */

	private PreferLocalRunningInstanceComparator comparator;

	@Mock

	private ServiceRunningInstance s1;

	@Mock

	private ServiceRunningInstance s2;

	@Mock

	private ServiceRunningInstance s3;

	@Before

	public void setUp() throws Exception {

		comparator = new PreferLocalRunningInstanceComparator();

		when(s1.isLocal()).thenReturn(true);

		when(s2.isLocal()).thenReturn(false);

		when(s3.isLocal()).thenReturn(false);

	}

	@Test

	public void testCompare() {

		assertEquals(-1, comparator.compare(s1, s3));

		assertEquals(1, comparator.compare(s3, s1));

		assertEquals(0, comparator.compare(s2, s3));

	}

}

package eu.dnetlib.enabling.locators.comparators;

import static org.junit.Assert.*;

import org.junit.Before;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.mockito.Mock;

import static org.mockito.Mockito.*;

import org.mockito.junit.MockitoJUnitRunner;

import eu.dnetlib.enabling.locators.ServiceRunningInstance;

@RunWith(MockitoJUnitRunner.class)

public class DiskSpaceComparatorTest {

	/**

	 * Class Under test.

	 */

	private DiskSpaceComparator comparator;

	@Mock

	private ServiceRunningInstance s1;

	@Mock

	private ServiceRunningInstance s2;

	@Mock

	private ServiceRunningInstance s3;

	@Before

	public void setUp() throws Exception {

		comparator = new DiskSpaceComparator();

		when(s1.getUsedDiskSpace()).thenReturn(0);

		when(s2.getUsedDiskSpace()).thenReturn(0);

		when(s3.getUsedDiskSpace()).thenReturn(10);

	}

	@Test

	public void testCompare() {

		assertEquals(0, comparator.compare(s1, s2));

		assertEquals(-1, comparator.compare(s1, s3));

		assertEquals(1, comparator.compare(s3, s1));

	}

}

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"

	xmlns:util="http://www.springframework.org/schema/util"

	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd

		http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd">

	<bean id="propertyConfigurer"

		class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">

		<property name="properties">

			<props>

				<prop key="transport.soap.baseAddress">http://localhost:8090/app/services/

				</prop>

				<prop key="infrastructure.name">junitTest</prop>

				<prop key="transport.soap.force.local.address">true</prop>

			</props>

		</property>

	</bean>

	<import

		resource="classpath:/eu/dnetlib/soap/cxf/applicationContext-eprbuilders.xml" />

	<bean id="defaultServiceNameResolver"

		class="eu.dnetlib.enabling.tools.registration.InterfaceServiceNameResolver" />

	<bean id="serviceResolver" 

		class="eu.dnetlib.test.utils.MockBeanFactory" 

		p:clazz="eu.dnetlib.enabling.tools.ServiceResolver" />		

	<bean id="lookupLocator" class="eu.dnetlib.enabling.tools.StaticServiceLocator">

		<property name="service">

			<bean class="eu.dnetlib.test.utils.MockBeanFactory" p:clazz="eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService" />

		</property>

	</bean>

	<bean id="dynamicLocator" class="eu.dnetlib.enabling.tools.DynamicServiceLocator"

		p:clazz="eu.dnetlib.enabling.resultset.rmi.ResultSetService"

		p:lookUpLocator-ref="lookupLocator" />

	<util:list id="serviceProfiles">

		<value><![CDATA[<service><id>1234</id><url>http://localhost:1234/app/services/resultSet</url></service>]]>

		</value>

		<value><![CDATA[<service><id>1234</id><url>http://localhost:8090/otherContext/services/resultSet</url></service>]]>

		</value>

		<value><![CDATA[<service><id>1234</id><url>http://localhost:8090/app/services/resultSet</url></service>]]>

		</value>

		<value><![CDATA[<service><id>1234</id><url>http://192.168.1.12:8090/app/services/resultSet</url></service>]]>

		</value>

	</util:list>

</beans>

<?xml version="1.0" encoding="UTF-8"?>

<RESOURCE_PROFILE>

    <HEADER>

        <RESOURCE_IDENTIFIER value="$id$"/>

        <RESOURCE_TYPE value="$name$ResourceType"/>

        <RESOURCE_KIND value="ServiceResources"/>

        <RESOURCE_URI value="http://localhost:8280/is/services/$name$?wsdl"/>

        <PARENT_ID value="" type="HNM"/>

        <DATE_OF_CREATION value="2014-11-04T19:34:56+01:00"/>

        <PROTOCOLS>

            <PROTOCOL name="SOAP" address="http://localhost:8280/is/services/$name$"/>

        </PROTOCOLS>

    </HEADER>

    <BODY>

        <CONFIGURATION>

            <TYPOLOGY/>

            <MAX_SIZE_OF_DATASTRUCTURE>0</MAX_SIZE_OF_DATASTRUCTURE>

            <AVAILABLE_DISKSPACE>0</AVAILABLE_DISKSPACE>

            <MAX_NUMBER_OF_DATASTRUCTURE>0</MAX_NUMBER_OF_DATASTRUCTURE>

            <SERVICE_PROPERTIES/>

        </CONFIGURATION>

        <STATUS>

            <HANDLED_DATASTRUCTURE>0</HANDLED_DATASTRUCTURE>

            <USED_DISKSPACE>0</USED_DISKSPACE>

            <LAST_UPDATE value="2000-01-01T00:00:00+00:00"/>

        </STATUS>

        <QOS>

            <AVAILABILITY/>

            <CAPACITY/>

            <RESPONSE_TIME>0</RESPONSE_TIME>

            <THROUGHPUT>0</THROUGHPUT>

        </QOS>

        <SECURITY_PARAMETERS/>

        <BLACKBOARD>

            <LAST_REQUEST />

            <LAST_RESPONSE />

        </BLACKBOARD>

    </BODY>

</RESOURCE_PROFILE>

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;

}

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;

	}

}

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 "";

	}

}

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<T> {

	/**

	 * Obtain a list of services.

	 *

	 * @return a list of service running instance descriptions

	 */

	List<ServiceRunningInstance<T>> getServices();

}

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.

 * 

 * <p>

 * 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.

 * </p>

 * 

 * @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);

}

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;

	}

}

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);

}

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 <T>

 *            service class

 */

@Deprecated

public class DynamicServiceEnumerator<T> implements ServiceEnumerator<T> {

	/**

	 * logger.

	 */

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

	/**

	 * service class

	 */

	private Class<T> clazz;

	/**

	 * lookup locator.

	 */

	private ServiceLocator<ISLookUpService> 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<T> clazz) {

		super();

		this.clazz = clazz;

	}

	/**

	 * {@inheritDoc}

	 *

	 * @see eu.dnetlib.enabling.tools.ServiceEnumerator#getServices()

	 */

	@Override

	public List<ServiceRunningInstance<T>> 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 <service><id>{$x//RESOURCE_IDENTIFIER/@value/string()}</id><url>{$x//PROTOCOL[@name = 'SOAP']/@address/string()}</url><properties>{$x//SERVICE_PROPERTIES/PROPERTY}</properties></service>";

		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<String> services = lookUpLocator.getService().quickSearchProfile(xquery);

			final List<ServiceRunningInstance<T>> instances = new ArrayList<ServiceRunningInstance<T>>();

			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<String, String> props = new HashMap<String, String>();

				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<T>(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<T> getClazz() {

		return clazz;

	}

	@Required

	public void setClazz(final Class<T> clazz) {

		this.clazz = clazz;

	}

	public ServiceLocator<ISLookUpService> getLookUpLocator() {

		return lookUpLocator;

	}

	public void setLookUpLocator(final ServiceLocator<ISLookUpService> 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;

	}

}

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<T> implements ServiceLocator<T> {

	/**

	 * lookup locator.

	 */

	@Resource(name="lookupLocator")

	private ServiceLocator<ISLookUpService> 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<T> 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<String, String> 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"));