D-Net

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

	}

}