D-Net

{

"type_source": "SVN",

"goal": "package -U source:jar",

"url": "http://svn-public.driver.research-infrastructures.eu/driver/dnet50/modules/dnet-information-service/branches/saxonHE",

"deploy_repository": "dnet5-snapshots",

"version": "5",

"mail": "alessia.bardi@isti.cnr.it",

"deploy_repository_url": "http://maven.research-infrastructures.eu/nexus/content/repositories/dnet5-snapshots",

"name": "dnet-information-service-saxonHE"

}

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 java.io.IOException;

import java.io.StringReader;

import java.io.StringWriter;

import javax.xml.parsers.DocumentBuilderFactory;

import javax.xml.parsers.ParserConfigurationException;

import javax.xml.transform.*;

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 static org.junit.Assert.assertEquals;

import static org.junit.Assert.assertNull;

import static org.mockito.Mockito.*;

/**

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

	private TransformerFactory tf;

	/**

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

		tf = TransformerFactory.newInstance();

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

	}

	/**

	 * 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) any(), (Result) any());

		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 java.util.Arrays;

import javax.xml.ws.Endpoint;

import eu.dnetlib.enabling.locators.UniqueServiceLocator;

import eu.dnetlib.rmi.common.BaseService;

import eu.dnetlib.rmi.enabling.ISLookUpException;

import eu.dnetlib.rmi.enabling.ISLookUpService;

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 static org.junit.Assert.assertFalse;

import static org.junit.Assert.assertTrue;

import static org.mockito.ArgumentMatchers.any;

import static org.mockito.ArgumentMatchers.anyString;

import static org.mockito.Mockito.when;

/**

 * test ServiceRegistrationManagerImpl.

 *

 * @author marko

 *

 */

@RunWith(MockitoJUnitRunner.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 ServiceRegistrationManager manager;

	/**

	 * registrator mock.

	 */

	@Mock

	private transient ServiceRegistrator registrator;

	/**

	 * is lookup mock.

	 */

	@Mock

	private transient ISLookUpService lookUpService;

	@Mock

	private transient Endpoint lookUpServiceEndpoint;

	@Mock

	private UniqueServiceLocator serviceLocator;

	/**

	 * prepare.

	 *

	 * @throws ISLookUpException

	 *             cannot happen

	 */

	@Before

	public void setUp() throws ISLookUpException {

		this.manager = new ServiceRegistrationManager();

		this.manager.setServiceLocator(this.serviceLocator);

		this.manager.setRegistrator(this.registrator);

		this.manager.setServices(Arrays.asList(this.lookUpServiceEndpoint));

		when(this.lookUpServiceEndpoint.getImplementor()).thenReturn(this.lookUpService);

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

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

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

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

	}

	/**

	 * test state machine.

	 * 

	 * @throws Exception

	 */

	@Test

	@Ignore

	public void testTick() throws Exception {

		when(this.registrator.registerService(any(BaseService.class), any(Endpoint.class))).thenReturn("123");

		assertFalse(this.manager.isDisabled());

		this.manager.registerAllServices();

		assertTrue(this.manager.isDisabled());

	}

}

package eu.dnetlib.enabling.inspector;

import eu.dnetlib.enabling.tools.CompatResourceIdentifierResolverImpl;

import org.junit.Before;

import org.junit.Test;

public class ResourceLinkToolTest {

	private static String PROFILE = 

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

		"<RESOURCE_PROFILE xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\">\n"+

		    "<HEADER>\n"+

		        "<RESOURCE_IDENTIFIER value=\"3cdc5e58-24c6-47ac-b678-401c84956e35_VHJhbnNmb3JtYXRpb25EU1Jlc291cmNlcy9UcmFuc2Zvcm1hdGlvbkRTUmVzb3VyY2VUeXBl\"/>\n"+

		        "<RESOURCE_TYPE value=\"TransformationDSResourceType\"/>\n"+

		        "<RESOURCE_KIND value=\"TransformationDSResources\"/>\n"+

		        "<RESOURCE_URI value=\"http://146.48.85.175:8280/efg-is/services/msro\"/>\n"+

		        "<DATE_OF_CREATION value=\"2010-10-27T10:41:24+02:00\"/>\n"+

		    "</HEADER>\n"+

		    "<BODY>\n"+

		        "<CONFIGURATION>\n"+

		            "<REPOSITORY_SERVICE_IDENTIFIER>d937bab1-d44c-44aa-bf7d-df5312a3b623_UmVwb3NpdG9yeVNlcnZpY2VSZXNvdXJjZXMvUmVwb3NpdG9yeVNlcnZpY2VSZXNvdXJjZVR5cGU=</REPOSITORY_SERVICE_IDENTIFIER>\n"+

		            "<TRANSFORMATION_MANAGER_SERVICE_IDENTIFIER/>\n"+

		            "<TRANSFORMATION_MANAGER_SERVICE_URI/>\n"+

		            "<SOURCE_METADATA_FORMATS>\n"+

				"<SOURCE_METADATA_FORMAT name=\"efg\" layout=\"store\" interpretation=\"native\"/>\n" +

				"</SOURCE_METADATA_FORMATS>\n"+

				"<SINK_METADATA_FORMAT interpretation=\"cleaned\" name=\"efg\" layout=\"store\"/>\n" +

				"<DATA_SOURCES>\n"+

		                "<DATA_SOURCE>dnet://MDStoreDS/8d1ab5bb-176c-4eef-9ed3-b46a0aa31d09_TURTdG9yZURTUmVzb3VyY2VzL01EU3RvcmVEU1Jlc291cmNlVHlwZQ==</DATA_SOURCE>\n"+

		            "</DATA_SOURCES>\n"+

		            "<DATA_SINK>dnet://MDStoreDS/a3a2c757-1726-41b2-9e37-bceb3f8bbd8b_TURTdG9yZURTUmVzb3VyY2VzL01EU3RvcmVEU1Jlc291cmNlVHlwZQ==?type=REFRESH</DATA_SINK>\n"+

		            "<TRANSFORMATION_RULE_DS_IDENTIFIER/>\n"+

		            "<SCHEDULING/>\n"+

		        "</CONFIGURATION>\n"+

		        "<STATUS>\n"+

		            "<LAST_UPDATE_DATE>2011-01-24T17:22:09+01:00</LAST_UPDATE_DATE>\n"+

		            "<LAST_UPDATE_STATUS>LAST_UPDATE_STATUS</LAST_UPDATE_STATUS>\n"+

		            "<LAST_UPDATE_ERROR_MESSAGE>LAST_UPDATE_ERROR_MESSAGE</LAST_UPDATE_ERROR_MESSAGE>\n"+

		        "</STATUS>\n"+

		        "<SECURITY_PARAMETERS>SECURITY_PARAMETERS</SECURITY_PARAMETERS>\n"+

		    "</BODY>\n"+

		"</RESOURCE_PROFILE>";		

	private ResourceLinkTool linkTool;

	@Before

	public void setUp() throws Exception {

		linkTool = new ResourceLinkTool();

		linkTool.setResolver(new CompatResourceIdentifierResolverImpl());

	}

	@Test

	public void linkfyToHtmlTest() {

		System.out.println(linkTool.linkfyToHtml(PROFILE));

	}

}

package eu.dnetlib.enabling.is.sn;

import java.util.Arrays;

import java.util.Collection;

import org.junit.Before;

import org.junit.Test;

import static org.junit.Assert.assertNotNull;

import static org.junit.Assert.assertNull;

/**

 * 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 java.util.ArrayList;

import java.util.List;

import javax.xml.ws.wsaddressing.W3CEndpointReference;

import javax.xml.ws.wsaddressing.W3CEndpointReferenceBuilder;

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

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

import eu.dnetlib.enabling.tools.OpaqueResource;

import org.junit.Before;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.mockito.ArgumentMatcher;

import org.mockito.Mock;

import org.mockito.junit.MockitoJUnitRunner;

import static org.junit.Assert.assertNotNull;

import static org.mockito.Mockito.*;

/**

 * Test the default notification detector implementation.

 *

 * @author marko

 *

 */

@RunWith(MockitoJUnitRunner.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 implements 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 NotificationMessage message) {

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

		final List<ResourceStateSubscriptionRegistry> registries = new ArrayList<ResourceStateSubscriptionRegistry>();

		registries.add(registry);

		detector.setRegistries(registries);

		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 java.util.Collection;

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

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

import eu.dnetlib.test.utils.EPRTestUtil;

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.beans.factory.annotation.Autowired;

import org.springframework.orm.hibernate5.HibernateJdbcException;

import org.springframework.test.annotation.DirtiesContext;

import org.springframework.test.context.ContextConfiguration;

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

import static org.junit.Assert.*;

/**

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

	 */

	@Autowired

	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 = HibernateJdbcException.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 eu.dnetlib.enabling.is.sn.resourcestate.AbstractResourceStateSubscriptionRegistryTest;

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

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

import org.junit.After;

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;

/**

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

	 */

	@Autowired

	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 eu.dnetlib.enabling.is.sn.SubscriptionRequest;

import eu.dnetlib.rmi.enabling.SubscriptionRequestRejectedException;

import org.junit.Before;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.mockito.ArgumentMatcher;

import org.mockito.Mock;

import org.mockito.junit.MockitoJUnitRunner;

import static org.junit.Assert.assertEquals;

import static org.junit.Assert.assertNotNull;

import static org.mockito.ArgumentMatchers.*;

import static org.mockito.Mockito.verify;

/**

 * test ResourceStateSubscriptionRegistryTest.

 *

 * @author marko

 *

 */

@RunWith(MockitoJUnitRunner.class)

public class ResourceStateSubscriptionRegistryTest {

	/**

	 * matches.

	 * 

	 * @author marko

	 *

	 */

	public static class MatchSubscription implements 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 ResourceStateSubscription sub) {

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

	}

	/**

	 * test registration.

	 * 

	 * @throws SubscriptionRequestRejectedException

	 */

	@Test(expected = SubscriptionRequestRejectedException.class)

	public void testRegisterSubscriptionReject1() throws SubscriptionRequestRejectedException {

		sub.setTopicExpression("UPDATE/OtherResourceType");

		registry.registerSubscription(sub);

		verify(subscriptionDao).addSubscription(argThat(new MatchSubscription("UPDATE", "OtherResourceType", "*")));

		assertNotNull("dummy", subscriptionDao);

	}

	/**

	 * test registration.

	 * 

	 * @throws SubscriptionRequestRejectedException

	 */

	@Test(expected = SubscriptionRequestRejectedException.class)

	public void testRegisterSubscriptionReject2() throws SubscriptionRequestRejectedException {

		sub.setTopicExpression("DELETE/*");

		registry.registerSubscription(sub);

//		verify(subscriptionDao).addSubscription(argThat(new MatchSubscription("DELETE", "*", "*")));

//

//		assertNotNull("dummy", subscriptionDao);

	}

	/**

	 * test registration.

	 * 

	 * @throws SubscriptionRequestRejectedException

	 */

	@Test(expected = SubscriptionRequestRejectedException.class)

	public void testRegisterSubscriptionReject3() throws SubscriptionRequestRejectedException {

		sub.setTopicExpression("CREATE");

		registry.registerSubscription(sub);

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

		assertNotNull("dummy", subscriptionDao);

	}

	/**

	 * test match id.

	 */

	@Test

	public void testMatchId() {

		assertEquals("check pure id", "1234123", registry.matchId("1234123").getPrefix());

		assertEquals("check with suffix", "1234123", registry.matchId("1234123/blabla/blabla").getPrefix());

		assertEquals("check suffix", "/blabla/blabla", registry.matchId("1234123/blabla/blabla").getRest());

	}

}

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

import static org.junit.Assert.assertEquals;

import static org.junit.Assert.assertNotNull;

import static org.junit.Assert.assertTrue;

import java.util.Collection;

import org.apache.commons.beanutils.BeanComparator;

import org.junit.Before;

import org.junit.Ignore;

import org.junit.Test;

/**

 * testing MemoryResourceStateSubscriptionDAOImpl.

 * 

 * @author marko

 * 

 */

public abstract class AbstractResourceStateSubscriptionDAOImplTest {

	/**

	 * update topic prefix.

	 */

	private static final String UPDATE = "UPDATE";

	/**

	 * create topic prefix.

	 */

	private static final String CREATE = "CREATE";

	/**

	 * test resource type.

	 */

	private static final String SOME_TYPE = "someType";

	/**

	 * test other resource type.

	 */

	private static final String SOME_OTHER_TYPE = "someOtherType";

	/**

	 * test resource id.

	 */

	private static final String SOME_ID = "123";

	/**

	 * class under test.

	 */

	private ResourceStateSubscriptionDAO dao;

	/**

	 * test subscription.

	 */

	private transient ResourceStateSubscription sub;

	/**

	 * test subscription.

	 */

	private transient ResourceStateSubscription sub2;

	/**

	 * test subscription.

	 */

	private transient ResourceStateSubscription sub3;

	/**

	 * test subscription.

	 */

	private transient ResourceStateSubscription sub4;

	/**

	 * test subscription.

	 */

	private transient ResourceStateSubscription sub5;

	/**

	 * common setup.

	 */

	@Before

	public void setUp() {

		prepareDao();

		sub = new ResourceStateSubscription();

		sub.setSubscriptionId("sn123");

		sub.setPrefix(CREATE);

		sub.setType(SOME_TYPE);

		sub.setXpath("somePath");

		sub2 = new ResourceStateSubscription();

		sub2.setSubscriptionId("sn666");

		sub2.setPrefix(UPDATE);

		sub2.setType(SOME_TYPE);

		sub2.setXpath("somePath");

		sub3 = new ResourceStateSubscription();

		sub3.setSubscriptionId("sn000");

		sub3.setPrefix(CREATE);

		sub3.setType(SOME_TYPE);

		sub3.setXpath("somePath");

		sub4 = new ResourceStateSubscription();

		sub4.setSubscriptionId("sn987");

		sub4.setPrefix(CREATE);

		sub4.setType("*");

		sub4.setResourceId(SOME_ID);

		sub5 = new ResourceStateSubscription();

		sub5.setSubscriptionId("sn888");

		sub5.setPrefix(UPDATE);

		sub5.setType(SOME_TYPE);

		sub5.setResourceId(SOME_ID);

	}

	/**

	 * subsclasses should implement this in order to plug their implementation of the dao.

	 */

	protected abstract void prepareDao();

	/**

	 * compare two subscriptions.

	 * 

	 * @param left

	 *            lhs

	 * @param right

	 *            rhs

	 * @return true if the objects are equal

	 */

	protected boolean compare(final ResourceStateSubscription left, final ResourceStateSubscription right) {

		return new BeanComparator("subscriptionId").compare(left, right) == 0 && new BeanComparator("prefix").compare(left, right) == 0

		&& new BeanComparator("type").compare(left, right) == 0 && new BeanComparator("resourceId").compare(left, right) == 0;

	}

	/**

	 * test list subscriptions for prefix and type.

	 */

	@Test

	public void testListSubscriptionsStringString() {

		dao.addSubscription(sub);

		dao.addSubscription(sub2);

		dao.addSubscription(sub3);

		dao.addSubscription(sub4);

		for (ResourceStateSubscription s : dao.listSubscriptions(UPDATE, SOME_TYPE, SOME_ID))

			assertTrue("check subscription", compare(s, sub2));

		assertEquals("check size", 2, dao.listSubscriptions(CREATE, SOME_TYPE, "*").size());

		for (ResourceStateSubscription s : dao.listSubscriptions(CREATE, "*", SOME_ID))

			assertTrue("check subscription star", compare(s, sub4));

		assertEquals("check size star", 1, dao.listSubscriptions(CREATE, "*", SOME_ID).size());	

	}

	/**

	 * enable this test when the manual merging of subscriptions is removed from the ResourceStateSubscriptionRegistry.

	 * The ResourceState subscription DAO alone should be able to quickly resolve wildcards. 

	 */

	@Test

	@Ignore

	public void testListSubscriptionsStar() {

		dao.addSubscription(sub);

		dao.addSubscription(sub2);

		dao.addSubscription(sub3);

		dao.addSubscription(sub4);

		for (ResourceStateSubscription s : dao.listSubscriptions(CREATE, SOME_OTHER_TYPE, SOME_ID))

			assertTrue("check subscription fixed star", compare(s, sub4));

		assertEquals("check size fixed tar", 1, dao.listSubscriptions(CREATE, SOME_OTHER_TYPE, SOME_ID).size());

	}

	/**

	 * test get a specific subscription by id.

	 */

	@Test

	public void testGetSubscription() {

		dao.addSubscription(sub);

		assertNotNull("check that it's registered", dao.getSubscription(sub.getSubscriptionId()));

	}

	/**

	 * test list all subscriptions.

	 */

	@Test

	public void testListSubscriptions() {

		dao.addSubscription(sub);

		for (ResourceStateSubscription s : dao.listSubscriptions())

			assertTrue("check subscription", compare(s, sub));

		assertEquals("check size", 1, dao.listSubscriptions().size());

	}

	/**

	 * test specific subscription.

	 */

	@Test

	public void testSpecificSubscription() {

		dao.addSubscription(sub5);

		final Collection<ResourceStateSubscription> res = dao.listSubscriptions(UPDATE, SOME_TYPE, SOME_ID);

		assertEquals("only one", 1, res.size());

		assertNotNull("", res.iterator().next());

	}

	/**

	 * test list subscriptions for a given prefix.

	 */

	@Test

	public void testListSubscriptionsString() {

		dao.addSubscription(sub);

		dao.addSubscription(sub2);

		for (ResourceStateSubscription s : dao.listSubscriptions(UPDATE))

			assertTrue("check subscription", compare(s, sub2));

	}

	public ResourceStateSubscriptionDAO getDao() {

		return dao;

	}

	public void setDao(final ResourceStateSubscriptionDAO dao) {

		this.dao = dao;

	}

	public ResourceStateSubscription getSub() {

		return sub;

	}

	public void setSub(final ResourceStateSubscription sub) {

		this.sub = sub;

	}

	public ResourceStateSubscription getSub2() {

		return sub2;

	}

	public void setSub2(final ResourceStateSubscription sub2) {

		this.sub2 = sub2;

	}

	public ResourceStateSubscription getSub3() {

		return sub3;

	}

	public void setSub3(final ResourceStateSubscription sub3) {

		this.sub3 = sub3;

	}

	public ResourceStateSubscription getSub4() {

		return sub4;

	}

	public void setSub4(final ResourceStateSubscription sub4) {

		this.sub4 = sub4;

	}

}

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

import static org.junit.Assert.assertEquals;

import static org.junit.Assert.assertFalse;

import static org.junit.Assert.assertTrue;

import java.util.Collection;

import org.junit.Before;

import org.junit.Test;

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

import eu.dnetlib.rmi.enabling.SubscriptionRequestRejectedException;

import eu.dnetlib.test.utils.EPRTestUtil;

/**

 * Common tests for resource state subscription registry tests.

 *

 * @author marko

 *

 */

public abstract class AbstractResourceStateSubscriptionRegistryTest {

	/**

	 * star.

	 */

	private static final String STAR = "*";

	/**

	 * create topic prefix.

	 */

	private static final String CREATE = "CREATE";

	/**

	 * test resource type.

	 */

	private static final String SOME_TYPE = "someType";

	/**

	 * test other resource type.

	 */

	private static final String SOME_OTHER_TYPE = "someOtherType";

	/**

	 * test resource id.

	 */

	private static final String SOME_ID = "sub123";

	/**

	 * instance under test.

	 */

	private ResourceStateSubscriptionRegistry registry;

	/**

	 * test subscritpion request.

	 */

	private transient SubscriptionRequest sub;

	/**

	 * setup registry. subclasses should set the dao.

	 */

	@Before

	public void setUpRegistry() {

		registry = new ResourceStateSubscriptionRegistry();

		final SubscriptionRequestFilter filter = new SubscriptionRequestFilter();

		filter.setActive(true);

		registry.setSubscriptionRequestFilter(filter);

		setUpDao();

		sub = new SubscriptionRequest(SOME_ID, EPRTestUtil.getTestEpr(), "CREATE/*/*/someXpath", 0);

	}

	/**

	 * test subscription registration.

	 *

	 * @throws SubscriptionRequestRejectedException

	 */

	@Test

	public void testRegisterSubscription() throws SubscriptionRequestRejectedException {

		registry.registerSubscription(sub);

		final Collection<ResourceStateSubscription> res = registry.listMatchingSubscriptions(CREATE, STAR, STAR);

		for (final ResourceStateSubscription r : res) {

			assertEquals("check add subscription", SOME_ID, r.getSubscriptionId());

		}

		assertEquals("check that is really added", 1, res.size());

	}

	/**

	 * test match.

	 *

	 * @throws SubscriptionRequestRejectedException

	 */

	@Test

	public void testMatch() throws SubscriptionRequestRejectedException {

		registry.registerSubscription(sub);

		ResourceStateSubscription re1 = null; // NOPMD

		ResourceStateSubscription re2 = null; // NOPMD

		final Collection<ResourceStateSubscription> res = registry.listMatchingSubscriptions(CREATE, SOME_TYPE, STAR);

		for (final ResourceStateSubscription r : res) {

			re1 = r; // NOPMD

			assertEquals("check match subscription", SOME_ID, r.getSubscriptionId());

		}

		assertEquals("check that only one matched", 1, res.size());

		final Collection<ResourceStateSubscription> res2 = registry.listMatchingSubscriptions(CREATE, SOME_OTHER_TYPE, STAR);

		for (final ResourceStateSubscription r : res2) {

			re2 = r; // NOPMD

			assertEquals("check match subscription", SOME_ID, r.getSubscriptionId());

		}

		assertEquals("check that only one matched", 1, res2.size());

		assertEquals("check that the same subscription is returned", re1, re2);

	}

	/**

	 * multiple subscriptions should be registered only once.

	 *

	 * @throws SubscriptionRequestRejectedException

	 */

	@Test

	public void testMultiple() throws SubscriptionRequestRejectedException {

		final String subId = registry.registerSubscription(sub);

		final String subId2 = registry.registerSubscription(sub);

		assertEquals("avoid duplicates", subId, subId2);

	}

	/**

	 * test unsubscribe.

	 *

	 * @throws SubscriptionRequestRejectedException

	 */

	@Test

	public void testUnsubscribe() throws SubscriptionRequestRejectedException {

		final String subId = registry.registerSubscription(sub);

		final boolean res = registry.unsubscribe(subId);

		assertTrue("unsubscribed", res);

		final boolean res2 = registry.unsubscribe(subId);

		assertFalse("not unsubscribed", res2);

	}

	/**

	 * subclasses should implement this with a specific instance of the dao.

	 */

	protected abstract void setUpDao();