D-Net

{"type_source": "SVN", "goal": "package -U -T 4C source:jar", "url": "http://svn-public.driver.research-infrastructures.eu/driver/dnet40/modules/cnr-enabling-services/trunk/", "deploy_repository": "dnet4-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/dnet4-snapshots", "name": "cnr-enabling-services"}

package eu.dnetlib.enabling.tools;

import static org.junit.Assert.assertEquals;

import static org.junit.Assert.assertNotNull;

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

import static org.mockito.Mockito.when;

import javax.xml.transform.stream.StreamResult;

import javax.xml.ws.Endpoint;

import javax.xml.ws.wsaddressing.W3CEndpointReference;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.apache.cxf.BusFactory;

import org.junit.Before;

import org.junit.BeforeClass;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.springframework.test.context.ContextConfiguration;

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

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

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

import eu.dnetlib.soap.cxf.CxfEndpointReferenceBuilder;

import eu.dnetlib.soap.cxf.JaxwsEndpointReferenceBuilder;

/**

 * jaxws service resolution.

 * 

 * @author marko

 * 

 */

@RunWith(SpringJUnit4ClassRunner.class)

@ContextConfiguration(locations = "local-cxf.xml")

public class JaxwsServiceResolverImplTest {

	/**

	 * logger.

	 */

	private static final Log log = LogFactory.getLog(JaxwsServiceResolverImplTest.class); // NOPMD by marko on

																							// 11/24/08 5:02 PM

	/**

	 * instance under test.

	 */

	private transient JaxwsServiceResolverImpl resolver;

	/**

	 * epr builder.

	 */

	private transient JaxwsEndpointReferenceBuilder eprBuilder;

	/**

	 * resultset mock.

	 */

	private transient ResultSetService resultSetService;

	/**

	 * cleanup cxf. This test requires the local transport (declared in local-cxf.xml), but other tests may have already instantiated the

	 * cxf bus singleton.

	 */

	@BeforeClass

	public static void resetCxf() {

		BusFactory.getDefaultBus().shutdown(true);

	}

	/**

	 * common.

	 */

	@Before

	public void setUp() {

		resolver = new JaxwsServiceResolverImpl();

		eprBuilder = new JaxwsEndpointReferenceBuilder();

		eprBuilder.setBuilder(new CxfEndpointReferenceBuilder());

		resultSetService = mock(ResultSetService.class);

	}

	/**

	 * get service.

	 * 

	 * @throws ResultSetException

	 *             shoudn't happen

	 */

	@Test

	public void testGetService() throws ResultSetException {

		final String rsId = "1235";

		when(resultSetService.identify()).thenReturn("foo");

		when(resultSetService.getNumberOfElements(rsId)).thenReturn(2);

		final Endpoint endpoint = Endpoint.publish("local://test", resultSetService);

		assertNotNull("check endpoint", endpoint);

		final W3CEndpointReference epr = eprBuilder.getEndpointReference(endpoint, rsId);

		epr.writeTo(new StreamResult(System.out));

		final ResultSetService rset = resolver.getService(ResultSetService.class, epr);

		assertNotNull("check resultset", rset);

		log.info(rset.getClass());

		log.info(rset);

		// NOTE: call to identify and getNumberOfElements fail because it seems that the methods are not

		// in the wsdl. This error may be related with the use of mockito and

		// method inheritance of services because there is no such error with

		// non-mocked result set service methods.

		// rset.identify();

		// assertEquals("check resultset communication", "foo",

		// rset.identify());

		assertEquals("check resolver resource id", rsId, resolver.getResourceIdentifier(epr));

		// assertEquals("check resultset communication with param", 2,

		// rset.getNumberOfElements(resolver.getResourceIdentifier(epr)));

	}

}

package eu.dnetlib.enabling.tools;

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

import org.junit.Before;

import org.junit.Test;

/**

 * test the CompatResourceIdentifierResolverImpl.

 * 

 * @author marko

 *

 */

public class CompatResourceIdentifierResolverImplTest {

	/**

	 * test resource identifier.

	 * 

	 */

	private static final String TEST_RES_ID = "first_c2Vjb25k";

	/**

	 * instance under test.

	 */

	private transient CompatResourceIdentifierResolverImpl resIdResolver;

	/**

	 * prepare the instance under test.

	 */

	@Before

	public void setUp() {

		resIdResolver = new CompatResourceIdentifierResolverImpl();

	}

	/**

	 * test get collection name.

	 */

	@Test

	public void testGetCollectionName() {

		assertEquals("check collection name", "second", resIdResolver.getCollectionName(TEST_RES_ID));

	}

	/**

	 * test get file name.

	 */

	@Test

	public void testGetFileName() {

		assertEquals("check file name", "first", resIdResolver.getFileName(TEST_RES_ID));		

	}

}

package eu.dnetlib.enabling.tools;

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

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

import java.io.IOException;

import java.io.StringReader;

import java.io.StringWriter;

import javax.xml.parsers.DocumentBuilderFactory;

import javax.xml.parsers.ParserConfigurationException;

import javax.xml.xpath.XPathExpressionException;

import org.apache.commons.io.IOUtils;

import org.junit.Before;

import org.junit.Test;

import org.w3c.dom.Document;

import org.xml.sax.InputSource;

import org.xml.sax.SAXException;

import javax.xml.transform.Result;

import javax.xml.transform.Source;

import javax.xml.transform.Transformer;

import javax.xml.transform.TransformerException;

/**

 * Test DOM opaque resource.

 * 

 * @author marko

 * 

 */

public class DOMOpaqueResourceTest {

	/**

	 * instance under test.

	 */

	private transient DOMOpaqueResource resource;

	/**

	 * xml source, read from test-profile.xml.

	 */

	private transient String xmlSource;

	/**

	 * common preparation.

	 * 

	 * @throws ParserConfigurationException

	 *             shouldn't happen

	 * @throws IOException

	 *             shouldn't happen

	 * @throws SAXException

	 *             shouldn't happen

	 * @throws XPathExpressionException

	 *             shouldn't happen

	 */

	@Before

	public void setUp() throws SAXException, IOException, ParserConfigurationException, XPathExpressionException {

		final StringWriter writer = new StringWriter();

		IOUtils.copy(getClass().getResourceAsStream("test-profile.xml"), writer);

		xmlSource = writer.getBuffer().toString();

		final Document document = DocumentBuilderFactory.newInstance().newDocumentBuilder().parse(new InputSource(new StringReader(xmlSource)));

		resource = new DOMOpaqueResource(document);

	}

	/**

	 * test dom.

	 */

	@Test

	public void testAsDom() {

		assertEquals("check that dom is not recreated", resource.getDom(), resource.asDom());

	}

	/**

	 * serialization check.

	 * 

	 * TODO: use xmlunit

	 */

	@Test

	public void testAsString() {

		assertEquals("check xml serialization", xmlSource, resource.asString());

	}

	/**

	 * test with exception in transformer.

	 * @throws TransformerException expected

	 */

	@Test

	public void testAsStringException() throws TransformerException {

		final Transformer transformer = mock(Transformer.class);

		doThrow(new TransformerException("dummy")).when(transformer).transform((Source) anyObject(), (Result) anyObject());

		resource.setTransformer(transformer);

		assertNull("checks that upon exception we get a null string", resource.asString());

	}

	/**

	 * check resource id extraction.

	 */

	@Test

	public void testGetResourceId() {

		assertEquals("check resource id",

				"111-6b4ea417-d940-4dda-a194-3096f685789b_UmVwb3NpdG9yeVNlcnZpY2VSZXNvdXJjZXMvUmVwb3NpdG9yeVNlcnZpY2VSZXNvdXJjZVR5cGU=", resource

						.getResourceId());

	}

	/**

	 * check resource type extraction.

	 */

	@Test

	public void testGetResourceType() {

		assertEquals("check resource type", "RepositoryServiceResourceType", resource.getResourceType());

	}

	/**

	 * check resource kind extraction.

	 */

	@Test

	public void testGetResourceKind() {

		assertEquals("check resource kind", "RepositoryServiceResources", resource.getResourceKind());

	}

}

package eu.dnetlib.enabling.tools.blackboard;

import static org.junit.Assert.assertEquals;

import javax.xml.bind.JAXBException;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.junit.Test;

import eu.dnetlib.miscutils.jaxb.JaxbFactory;

/**

 * Jaxb Blackboard message implementation test.

 * 

 * @author marko

 *

 */

public class BlackboardMessageImplTest {

	/**

	 * logger.

	 */

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

	/**

	 * test message (de)serialization.

	 * 

	 * @throws JAXBException could happen

	 */

	@Test

	public void testMessage() throws JAXBException {

		final JaxbFactory<BlackboardMessage> factory = new JaxbFactory<BlackboardMessage>(BlackboardMessageImpl.class);

		final BlackboardMessage message = factory.newInstance();

		message.setAction("FEED");

		message.setActionStatus(ActionStatus.ONGOING);

		message.setId("12");

		message.setDate("5123");

		final BlackboardParameter param1 = new BlackboardParameterImpl();

		param1.setName("someName");

		param1.setValue("someValue");

		message.getParameters().add(param1);

		final BlackboardParameter param2 = new BlackboardParameterImpl();

		param2.setName("otherName");

		param2.setValue("otherValue");

		message.getParameters().add(param2);

		final String serialized = factory.serialize(message);

		log.info(serialized);

		final BlackboardMessage res = factory.parse(serialized);

		log.info(res.getParameters());

		assertEquals("list serialization", 2, res.getParameters().size());

		assertEquals("enum serialization", ActionStatus.ONGOING, res.getActionStatus());

	}

}

package eu.dnetlib.enabling.tools.registration;

import static org.junit.Assert.assertEquals;

import static org.mockito.Mockito.when;

import static org.mockito.Matchers.anyString;

import static org.mockito.Matchers.eq;

import javax.xml.namespace.QName;

import org.apache.cxf.endpoint.Endpoint;

import org.apache.cxf.endpoint.ServerImpl;

import org.apache.cxf.jaxws.EndpointImpl;

import org.apache.cxf.service.Service;

import org.apache.cxf.service.model.EndpointInfo;

//import org.junit.Before;

import org.junit.Test;

import org.junit.Ignore;

import org.junit.runner.RunWith;

import org.mockito.Mock;

import org.mockito.runners.MockitoJUnit44Runner;

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

import eu.dnetlib.soap.cxf.JaxwsEndpointReferenceBuilder;

/**

 * ServiceRegistrator test.

 *

 * @author marko

 *

 */

@RunWith(MockitoJUnit44Runner.class)

public class ServiceRegistratorTest {

	/**

	 * instance under test.

	 */

	private transient ServiceRegistrator registrator;

	/**

	 * service mock.

	 */

	@Mock

	private transient Service service;

	/**

	 * endpoint info mock.

	 */

	@Mock

	private transient EndpointInfo endpointInfo;

	/**

	 * endpoint mock.

	 */

	@Mock

	private transient Endpoint endpoint;

	/**

	 * registry service mock.

	 */

	@Mock

	private transient ISRegistryService registryService;

	/**

	 * jaxws endpoint mock.

	 */

	@Mock

	private transient EndpointImpl jaxwsEndpoint;

	/**

	 * cxf server mock.

	 */

	@Mock

	private transient ServerImpl server;

	/**

	 * hnm locator mock.

	 */

	@Mock

	private transient HNMLocator hnmLocator;

	@Mock

	private UniqueServiceLocator serviceLocator;

	/**

	 * setup common stuff.

	 *

	 */

        //@Before

	public void disabled() {

		when(service.getName()).thenReturn(new QName("http://my.test", "TestService"));

		when(endpoint.getEndpointInfo()).thenReturn(endpointInfo);

		when(endpoint.getService()).thenReturn(service);

		when(endpointInfo.getAddress()).thenReturn("http://localhost/something");

		when(endpointInfo.getName()).thenReturn(new QName("http://my.test", "TestServiceEndpoint"));

		when(jaxwsEndpoint.getServer()).thenReturn(server);

		when(server.getEndpoint()).thenReturn(endpoint);

		when(hnmLocator.getHNMForUrl("http://localhost/something")).thenReturn("555444");

		when(serviceLocator.getService(ISRegistryService.class)).thenReturn(registryService);

		when(serviceLocator.getService(ISRegistryService.class, true)).thenReturn(registryService);

		registrator = new ServiceRegistrator();

		registrator.setServiceLocator(serviceLocator);

		final CxfEndpointReferenceBuilder cxfEprBuilder = new CxfEndpointReferenceBuilder();

		final JaxwsEndpointReferenceBuilder eprBuilder = new JaxwsEndpointReferenceBuilder();

		eprBuilder.setBuilder(cxfEprBuilder);

		registrator.setEprBuilder(eprBuilder);

		registrator.setHnmLocator(hnmLocator);

	}

	/**

	 * test register service.

	 * @throws ISRegistryException shouldn't happen

	 */

	@Test

        @Ignore

	public void testRegisterService() throws ISRegistryException {

		when(registryService.insertProfileForValidation(eq("TestServiceResourceType"), anyString())).thenReturn("123");

		final String rsId = registrator.registerService("TestService", jaxwsEndpoint);

		assertEquals("registered", "123", rsId);

	}

}

package eu.dnetlib.enabling.tools.registration;

import static org.junit.Assert.assertEquals;

import static org.mockito.Matchers.anyObject;

import static org.mockito.Matchers.anyString;

import static org.mockito.Mockito.when;

import javax.xml.ws.Endpoint;

import org.junit.Before;

import org.junit.Ignore;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.mockito.Mock;

import org.mockito.runners.MockitoJUnit44Runner;

import eu.dnetlib.enabling.is.lookup.ISLookUpServiceImpl;

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

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

import eu.dnetlib.enabling.locators.UniqueServiceLocator;

/**

 * test ServiceRegistrationManagerImpl.

 *

 * @author marko

 *

 */

@RunWith(MockitoJUnit44Runner.class)

public class ServiceRegistrationManagerImplTest {

	/**

	 * fake profile.

	 */

	private static final String PROFILE = "<RESOURCE_PROFILE><HEADER><RESOURCE_KIND value=\"PendingServiceResources\"/></HEADER></RESOURCE_PROFILE>";

	/**

	 * instance under test.

	 */

	private transient ServiceRegistrationManagerImpl manager;

	/**

	 * registrator mock.

	 */

	@Mock

	private transient ServiceRegistrator registrator;

	/**

	 * is lookup mock.

	 */

	@Mock

	private transient ISLookUpService lookUpService;

	@Mock

	private UniqueServiceLocator serviceLocator;

	/**

	 * prepare.

	 *

	 * @throws ISLookUpException

	 *             cannot happen

	 */

	@Before

	public void setUp() throws ISLookUpException {

		manager = new ServiceRegistrationManagerImpl();

		manager.setServiceLocator(serviceLocator);

		manager.setRegistrator(registrator);

		manager.setService(new ISLookUpServiceImpl());

		when(serviceLocator.getService(ISLookUpService.class)).thenReturn(lookUpService);

		when(serviceLocator.getService(ISLookUpService.class, true)).thenReturn(lookUpService);

		when(lookUpService.getResourceProfile("123")).thenReturn(PROFILE);

		when(lookUpService.getResourceProfileByQuery(anyString())).thenReturn(PROFILE);

	}

	/**

	 * test state machine.

	 */

	@Test

	@Ignore

	public void testTick() {

		when(registrator.registerService(anyObject(), (Endpoint) anyObject())).thenReturn("123");

		assertEquals("check unregistered state", ServiceRegistrationManagerImpl.State.UNREGISTERED, manager.getState());

		manager.tick();

		assertEquals("check pending state", ServiceRegistrationManagerImpl.State.PENDING, manager.getState());

		assertEquals("ensure that the mock is correct", "PendingServiceResources", manager.getServiceProfile().getResourceKind());

		manager.tick();

		assertEquals("should remain pending", ServiceRegistrationManagerImpl.State.PENDING, manager.getState());

		manager.tick();

		assertEquals("should remain pending forever", ServiceRegistrationManagerImpl.State.PENDING, manager.getState());

	}

}

package eu.dnetlib.enabling.tools.registration;

import static org.junit.Assert.assertEquals;

import org.junit.Before;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.mockito.Mock;

import org.mockito.runners.MockitoJUnit44Runner;

import eu.dnetlib.enabling.is.registry.ISRegistryServiceImpl;

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

/**

 * test heuristic service name generator.

 * @author marko

 *

 */

@RunWith(MockitoJUnit44Runner.class)

public class InterfaceServiceNameGeneratorTest {

	/**

	 * instance under test.

	 */

	private transient ServiceNameResolver generator = new InterfaceServiceNameResolver();

	/**

	 * simulates the extension of the service interface.

	 * 

	 * @author marko

	 *

	 */

	interface SomeDummyInterface extends ISRegistryService {

	}

	/**

	 * simulates the implementation of the service interface.

	 * @author marko

	 *

	 */

	abstract class AbstractDummyService implements SomeDummyInterface {

	}

	/**

	 * simulates the subclassing of the service implementation class.

	 * 

	 * @author marko

	 *

	 */

	abstract class AbstractDummyServiceImpl extends AbstractDummyService {

	}

	/**

	 * service mock.

	 */

	@Mock

	private transient AbstractDummyServiceImpl service;

	/**

	 * setup.

	 */

	@Before

	public void setUp() {

		generator = new InterfaceServiceNameResolver();

	}

	/**

	 * test getName().

	 */

	@Test

	public void testGetName() {

		assertEquals("check service name", "ISRegistryService", generator.getName(service));

	}

	/**

	 * test getName() on real classes.

	 */

	@Test

	public void testGetNameReal() {

		assertEquals("check service name", "ISRegistryService", generator.getName(new ISRegistryServiceImpl()));

	}

}

package eu.dnetlib.enabling.tools.registration;

import static org.junit.Assert.assertEquals;

import static org.mockito.Matchers.anyObject;

import static org.mockito.Matchers.anyString;

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

import javax.xml.ws.Endpoint;

import org.junit.Before;

import org.junit.Ignore;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.mockito.Mock;

import org.mockito.runners.MockitoJUnit44Runner;

import eu.dnetlib.enabling.is.lookup.ISLookUpServiceImpl;

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

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

import eu.dnetlib.enabling.locators.UniqueServiceLocator;

/**

 * test ValidatingServiceRegistrationManagerImpl.

 *

 * @author marko

 *

 */

@RunWith(MockitoJUnit44Runner.class)

public class ValidatingServiceRegistrationManagerImplTest {

	/**

	 * profile id.

	 */

	private static final String PROF_ID = "123";

	/**

	 * validated profile id.

	 */

	private static final String VPROF_ID = "V123";

	/**

	 * fake profile.

	 */

	private static final String PROFILE = "<RESOURCE_PROFILE><HEADER><RESOURCE_KIND value=\"PendingServiceResources\"/></HEADER></RESOURCE_PROFILE>";

	/**

	 * fake profile.

	 */

	private static final String VPROFILE = "<RESOURCE_PROFILE><HEADER><RESOURCE_IDENTIFIER value=\"V123\"/><RESOURCE_KIND value=\"ServiceResources\"/></HEADER></RESOURCE_PROFILE>";

	/**

	 * instance under test.

	 */

	private transient ServiceRegistrationManagerImpl manager;

	/**

	 * registrator mock.

	 */

	@Mock

	private transient ServiceRegistrator registrator;

	/**

	 * is lookup mock.

	 */

	@Mock

	private transient ISLookUpService lookUpService;

	@Mock

	private UniqueServiceLocator serviceLocator;

	/**

	 * prepare.

	 *

	 * @throws ISLookUpException

	 *             cannot happen

	 */

	@Before

	public void setUp() throws ISLookUpException {

		manager = new ValidatingServiceRegistrationManagerImpl();

		manager.setServiceLocator(serviceLocator);

		manager.setRegistrator(registrator);

		manager.setService(new ISLookUpServiceImpl());

		when(lookUpService.getResourceProfile(PROF_ID)).thenReturn(PROFILE);

		when(lookUpService.getResourceProfile(VPROF_ID)).thenReturn(VPROFILE);

		when(lookUpService.getResourceProfileByQuery(anyString())).thenReturn(PROFILE);

		when(registrator.validateProfile(eq(PROF_ID), (Endpoint) anyObject())).thenReturn(VPROF_ID);

		when(serviceLocator.getService(ISLookUpService.class)).thenReturn(lookUpService);

		when(serviceLocator.getService(ISLookUpService.class, true)).thenReturn(lookUpService);

	}

	/**

	 * test state machine.

	 *

	 * @throws ISLookUpException

	 *             cannot happen

	 */

	@Test

	@Ignore

	public void testTick() throws ISLookUpException {

		when(registrator.registerService(anyObject(), (Endpoint) anyObject())).thenReturn(PROF_ID);

		assertEquals("check unregistered state", ServiceRegistrationManagerImpl.State.UNKNOWN, manager.getState());

		manager.tick();

		assertEquals("check pending state", ServiceRegistrationManagerImpl.State.PENDING, manager.getState());

		assertEquals("ensure that the mock is correct", "PendingServiceResources", manager.getServiceProfile().getResourceKind());

		manager.tick();

		assertEquals("should register directly", ServiceRegistrationManagerImpl.State.REGISTERED, manager.getState());

		verify(registrator).validateProfile(eq(PROF_ID), (Endpoint) anyObject());

		assertEquals("check validation id", VPROF_ID, manager.getProfileId());

		assertEquals("check validation profile", VPROF_ID, manager.getServiceProfile().getResourceId());

		manager.tick();

		assertEquals("should remain registered", ServiceRegistrationManagerImpl.State.REGISTERED, manager.getState());

	}

}

package eu.dnetlib.enabling.tools.registration;

import static org.junit.Assert.assertEquals;

import java.util.HashMap;

import java.util.Map;

import org.junit.Before;

import org.junit.Test;

import eu.dnetlib.enabling.is.store.ISStoreServiceImpl;

/**

 * compatibility interface service name tester.

 * @author marko

 *

 */

public class InterfaceServiceNameResolverCompatibilityTest {

	/**

	 * instance under test.

	 */

	private transient InterfaceServiceNameResolverCompatibility resolver;

	/**

	 * setup. 

	 */

	@Before

	public void setUp() {

		resolver = new InterfaceServiceNameResolverCompatibility();

	}

	/**

	 * test mapping without override.

	 */

	@Test

	public void testGetName() {

		assertEquals("check without override", "ISStoreService", resolver.getName(new ISStoreServiceImpl()));

	}

	/**

	 * test mapping override.

	 */

	@Test

	public void testGetNameWithOverride() {

		final Map<String, String> mapping = new HashMap<String, String>();

		mapping.put("ISStoreService", "IS_StoreService");

		resolver.setMapping(mapping);	

		assertEquals("check is store service name", "IS_StoreService", resolver.getName(new ISStoreServiceImpl()));

	}

}

package eu.dnetlib.enabling.is.sn;

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

import java.util.Collection;

import org.junit.Before;

import org.junit.Test;

import java.util.Arrays;

/**

 * abstract subscription registry test.

 * 

 * @author marko

 * 

 */

public class AbstractSubscriptionRegistryTest {

	/**

	 * object under test.

	 */

	private transient AbstractSubscriptionRegistry registry;

	/**

	 * setup .

	 * 

	 * @throws Exception

	 */

	@Before

	public void setUp() {

		registry = new AbstractSubscriptionRegistry() {

			@Override

			protected Collection<String> getAcceptedPrefixes() {

				return Arrays.asList(new String[] { "CREATE", "DELETE", "UPDATE", "DEEP/SUB" });

			}

		};

	}

	/**

	 * test prefixes.

	 */

	@Test

	public void testMatchPrefix() {

		final SubscriptionRequest sub = new SubscriptionRequest();

		sub.setTopicExpression("CREATE/MyResourceType");

		assertNotNull("check create", registry.matchPrefix(sub));

		sub.setTopicExpression("DELETE/MyResourceType");

		assertNotNull("check delete", registry.matchPrefix(sub));

		sub.setTopicExpression("UPDATE/MyResourceType");

		assertNotNull("check update", registry.matchPrefix(sub));

		sub.setTopicExpression("VERIFY/MyResourceType");

		assertNull("check non declared prefix", registry.matchPrefix(sub));

		sub.setTopicExpression("UPDATED/MyResourceType");

		assertNull("check non delimited prefix", registry.matchPrefix(sub));

		sub.setTopicExpression("UPDATE");

		assertNotNull("check only prefix", registry.matchPrefix(sub));

		sub.setTopicExpression("DEEP/MyResourceType");

		assertNull("check deep", registry.matchPrefix(sub));

		sub.setTopicExpression("DEEP/SUB/MyResourceType");

		assertNotNull("check deep sub", registry.matchPrefix(sub));

	}

}

package eu.dnetlib.enabling.is.sn;

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

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

import java.util.ArrayList;

import java.util.List;

import javax.xml.ws.wsaddressing.W3CEndpointReference;

import javax.xml.ws.wsaddressing.W3CEndpointReferenceBuilder;

import org.junit.Before;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.mockito.ArgumentMatcher;

import org.mockito.Mock;

import org.mockito.runners.MockitoJUnit44Runner;

import eu.dnetlib.enabling.is.sn.resourcestate.ResourceStateSubscription;

import eu.dnetlib.enabling.is.sn.resourcestate.ResourceStateSubscriptionRegistry;

import eu.dnetlib.enabling.tools.OpaqueResource;

/**

 * Test the default notification detector implementation.

 *

 * @author marko

 *

 */

@RunWith(MockitoJUnit44Runner.class)

public class NotificationDetectorImplTest {

	/**

	 * some type.

	 */

	private static final String SOME_TYPE = "SomeType";

	/**

	 * some resource identifier.

	 */

	private static final String SOME_ID = "123";

	/**

	 * Check if a message has the correct content.

	 *

	 * @author marko

	 *

	 */

	private final class CheckMessage extends ArgumentMatcher<NotificationMessage> {

		/**

		 * prefix.

		 */

		private final transient String prefix;

		/**

		 * constructor.

		 *

		 * @param prefix topic prefix

		 */

		CheckMessage(final String prefix) {

			super();

			this.prefix = prefix;

		}

		/**

		 * {@inheritDoc}

		 * @see org.mockito.ArgumentMatcher#matches(java.lang.Object)

		 */

		@Override

		public boolean matches(final Object argument) {

			final NotificationMessage message = (NotificationMessage) argument;

			return message.getSubscriptionId() == subscription.getSubscriptionId() && message.getResourceId().equals("123")

					&& message.getTopic().equals(prefix + ".*.*");

		}

	}

	/**

	 * instance under test.

	 */

	private transient NotificationDetectorImpl detector;

	/**

	 * registry mock.

	 */

	@Mock

	private transient ResourceStateSubscriptionRegistry registry;

	/**

	 * sender mock.

	 */

	@Mock

	private transient NotificationSender sender;

	/**

	 * resource mock.

	 */

	@Mock

	private transient OpaqueResource resource;

	/**

	 * resource subscription.

	 */

	@Mock

	private transient ResourceStateSubscription subscription;

	/**

	 * mock subscriber.

	 */

	private transient W3CEndpointReference subscriber;

	/**

	 * common.

	 */

	@Before

	public void setUp() {

		detector = new NotificationDetectorImpl();

		detector.setRegistry(registry);

		detector.setSender(sender);

		final W3CEndpointReferenceBuilder builder = new W3CEndpointReferenceBuilder();

		builder.address("http://test.com/test/test");

		subscriber = builder.build();

		final List<ResourceStateSubscription> subscriptions = new ArrayList<ResourceStateSubscription>();

		subscriptions.add(subscription);

		when(registry.listMatchingSubscriptions(ResourceStateSubscription.PREFIX_CREATE, SOME_TYPE, SOME_ID)).thenReturn(subscriptions);

		when(registry.listMatchingSubscriptions(ResourceStateSubscription.PREFIX_DELETE, SOME_TYPE, SOME_ID)).thenReturn(subscriptions);

		when(registry.listMatchingSubscriptions(ResourceStateSubscription.PREFIX_UPDATE, SOME_TYPE, SOME_ID)).thenReturn(subscriptions);

		when(resource.getResourceId()).thenReturn(SOME_ID);

		when(resource.getResourceType()).thenReturn(SOME_TYPE);

		when(subscription.getSubscriptionId()).thenReturn("sn123");

		when(subscription.getSubscriberAsEpr()).thenReturn(subscriber);

		when(subscription.getXpath()).thenReturn("");

		when(subscription.getType()).thenReturn("*");

		when(subscription.getResourceId()).thenReturn("*");

	}

	/**

	 * test 'create'.

	 */

	@Test

	public void testResourceCreated() {

		when(subscription.getPrefix()).thenReturn(ResourceStateSubscription.PREFIX_CREATE);

		detector.resourceCreated(resource);

		verify(sender).send(eq(subscriber), argThat(new CheckMessage(ResourceStateSubscription.PREFIX_CREATE)));

		assertNotNull("dummy", sender);

	}

	/**

	 * test 'delete'.

	 */

	@Test

	public void testResourceDeleted() {

		when(subscription.getPrefix()).thenReturn(ResourceStateSubscription.PREFIX_DELETE);

		detector.resourceDeleted(resource);

		verify(sender).send(eq(subscriber), argThat(new CheckMessage(ResourceStateSubscription.PREFIX_DELETE)));

		assertNotNull("dummy", sender);

	}

	/**

	 * test 'update'.

	 */

	@Test

	public void testResourceUpdated() {

		when(subscription.getXpath()).thenReturn(null);

		when(subscription.getPrefix()).thenReturn(ResourceStateSubscription.PREFIX_UPDATE);

		detector.resourceUpdated(resource, resource);

		verify(sender).send(eq(subscriber), argThat(new CheckMessage(ResourceStateSubscription.PREFIX_UPDATE)));

		assertNotNull("dummy", sender);

	}

}

package eu.dnetlib.enabling.is.sn.resourcestate;

/**

 * Perform ResourceStateSubscriptionRegistryTest tests on a memory backed resource state subscription dao instance.

 * 

 * @author marko

 *

 */

public class MemoryResourceStateSubscriptionRegistryTest extends AbstractResourceStateSubscriptionRegistryTest { // NOPMD

	/** 

	 * {@inheritDoc}

	 * @see eu.dnetlib.enabling.is.sn.resourcestate.AbstractResourceStateSubscriptionRegistryTest#setUpDao()

	 */

	@Override

	protected void setUpDao() {

		getRegistry().setSubscriptionDao(new MemoryResourceStateSubscriptionDAOImpl());

	}

}

package eu.dnetlib.enabling.is.sn.resourcestate.hib;

import static org.junit.Assert.assertEquals;

import static org.junit.Assert.assertNotNull;

import static org.junit.Assert.assertTrue;

import java.util.Collection;

import javax.annotation.Resource;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.junit.After;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.springframework.dao.DataIntegrityViolationException;

import org.springframework.test.annotation.DirtiesContext;

import org.springframework.test.context.ContextConfiguration;

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

import eu.dnetlib.enabling.is.sn.resourcestate.AbstractResourceStateSubscriptionDAOImplTest;

import eu.dnetlib.enabling.is.sn.resourcestate.ResourceStateSubscription;

import eu.dnetlib.test.utils.EPRTestUtil;

/**

 * test HibernateResourceStateSubscriptionDAOImplTest.

 * 

 * @author marko

 * 

 */

@RunWith(SpringJUnit4ClassRunner.class)

@ContextConfiguration

public class HibernateResourceStateSubscriptionDAOImplTest extends AbstractResourceStateSubscriptionDAOImplTest {

	/**

	 * logger.

	 */

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

	/**

	 * instance under test.

	 */

	@Resource

	private transient HibernateResourceStateSubscriptionDAOImpl hibdao;

	/**

	 * cleanup db.

	 */

	@After

	public void tearDown() {

		final Collection<ResourceStateSubscription> subs = hibdao.listSubscriptions();

		if (subs != null)

			for (ResourceStateSubscription r : subs)

				hibdao.removeSubscription(r.getSubscriptionId());

//		for (ResourceStateSubscription r : subs)

//			log.info("deleted: " + r);

	}

	/**

	 * test addition.

	 */

	@Test

	public void testAddSubscription() {

		assertNotNull("check dao", getDao());

		getDao().addSubscription(getSub());

		log.info("sub id: " + getSub().getSubscriptionId());

	}

	/**

	 * test encoding of endpoint references.

	 */

	@Test

	@DirtiesContext

	public void testEndpoint() {

		getSub().setSubscriber(EPRTestUtil.getTestEpr());

		getDao().addSubscription(getSub());

		final ResourceStateSubscription fresh = getDao().getSubscription(getSub().getSubscriptionId());

		assertNotNull("check", fresh);

		assertTrue("equals", compare(getSub(), fresh));

		assertNotNull("epr", getSub().getSubscriber());

		assertNotNull("fetched epr", fresh.getSubscriber());

		assertEquals("eprs", getSub().getSubscriber().toString(), fresh.getSubscriber().toString());

	}

	/**

	 * multiple subscriptions should not be allowed.

	 */

	@Test(expected = DataIntegrityViolationException.class)

	@DirtiesContext

	public void testMultiple() { // NOPMD

		getDao().addSubscription(getSub());

		getDao().addSubscription(getSub());

	}

	/**

	 * {@inheritDoc}

	 * 

	 * @see eu.dnetlib.enabling.is.sn.resourcestate.AbstractResourceStateSubscriptionDAOImplTest#prepareDao()

	 */

	@Override

	protected void prepareDao() {

		setDao(hibdao);

	}

}

package eu.dnetlib.enabling.is.sn.resourcestate.hib;

import java.util.Collection;

import javax.annotation.Resource;

import org.junit.After;

import org.junit.runner.RunWith;

import org.springframework.test.context.ContextConfiguration;

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

import eu.dnetlib.enabling.is.sn.resourcestate.AbstractResourceStateSubscriptionRegistryTest;

import eu.dnetlib.enabling.is.sn.resourcestate.ResourceStateSubscription;

import eu.dnetlib.enabling.is.sn.resourcestate.ResourceStateSubscriptionDAO;

/**

 * Perform ResourceStateSubscriptionRegistryTest tests on a hibernate backed resource state subscription dao instance.

 * 

 * @author marko

 * 

 */

@RunWith(SpringJUnit4ClassRunner.class)

@ContextConfiguration(locations = { "HibernateResourceStateSubscriptionDAOImplTest-context.xml" })

public class HibernateResourceStateSubscriptionRegistryTest extends AbstractResourceStateSubscriptionRegistryTest { // NOPMD

	/**

	 * hibernate subscription dao.

	 */

	@Resource

	private transient ResourceStateSubscriptionDAO dao;

	/**

	 * cleanup db. hsql doesn't recreate the database on spring context reload.

	 */

	@After

	public void tearDown() {

		final Collection<ResourceStateSubscription> subs = dao.listSubscriptions();

		if (subs != null)

			for (ResourceStateSubscription r : subs)

				dao.removeSubscription(r.getSubscriptionId());

	}

	/**

	 * {@inheritDoc}

	 * 

	 * @see eu.dnetlib.enabling.is.sn.resourcestate.AbstractResourceStateSubscriptionRegistryTest#setUpDao()

	 */

	@Override

	protected void setUpDao() {

		getRegistry().setSubscriptionDao(dao);

	}

}

package eu.dnetlib.enabling.is.sn.resourcestate;

import static org.junit.Assert.assertEquals;

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

import static org.mockito.Matchers.argThat;

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

import org.junit.Before;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.mockito.ArgumentMatcher;

import org.mockito.Mock;

import org.mockito.runners.MockitoJUnit44Runner;

import eu.dnetlib.enabling.is.sn.SubscriptionRequest;

import eu.dnetlib.enabling.is.sn.rmi.SubscriptionRequestRejectedException;

/**

 * test ResourceStateSubscriptionRegistryTest.

 *

 * @author marko

 *

 */

@RunWith(MockitoJUnit44Runner.class)

public class ResourceStateSubscriptionRegistryTest {

	/**

	 * matches.

	 * 

	 * @author marko

	 *

	 */

	public static class MatchSubscription extends ArgumentMatcher<ResourceStateSubscription> {

		/**

		 * prefix.

		 */

		private final transient String prefix;

		/**

		 * type.

		 */

		private final transient String type;

		/**

		 * resource id.

		 */

		private final transient String resId;

		/**

		 * create a new match subscription checker for a given prefix and a given type.

		 * 

		 * @param prefix

		 *            prefix

		 * @param type

		 *            type

		 * @param resId

		 *            resource id

		 */

		MatchSubscription(final String prefix, final String type, final String resId) {

			super();

			this.prefix = prefix;

			this.type = type;

			this.resId = resId;

		}

		/**

		 * {@inheritDoc}

		 * 

		 * @see org.mockito.ArgumentMatcher#matches(java.lang.Object)

		 */

		@Override

		public boolean matches(final Object argument) {

			final ResourceStateSubscription sub = (ResourceStateSubscription) argument;

			return sub.getPrefix().equals(this.prefix) && sub.getType().equals(this.type) && sub.getResourceId().equals(this.resId);

		}

	}

	/**

	 * object under test.

	 */

	private transient ResourceStateSubscriptionRegistry registry;

	/**

	 * DAO mock.

	 */

	@Mock

	private transient ResourceStateSubscriptionDAO subscriptionDao;

	/**

	 * subscription request.

	 */

	private transient SubscriptionRequest sub;

	/**

	 * common setup.

	 */

	@Before

	public void setUp() {

		registry = new ResourceStateSubscriptionRegistry();

		registry.setSubscriptionDao(subscriptionDao);

		final SubscriptionRequestFilter filter = new SubscriptionRequestFilter();

		filter.setActive(true);

		registry.setSubscriptionRequestFilter(filter);

		sub = new SubscriptionRequest();

	}

	/**

	 * test registration.

	 * 

	 * @throws SubscriptionRequestRejectedException

	 */

	@Test

	public void testRegisterSubscription() throws SubscriptionRequestRejectedException {

		sub.setTopicExpression("CREATE/MyResourceType/123/some/path");

		registry.registerSubscription(sub);

		verify(subscriptionDao).addSubscription(argThat(new MatchSubscription("CREATE", "MyResourceType", "123")));

		assertNotNull("dummy", subscriptionDao);

	}

	/**