core/src/test/java/org/eclipse/gemini/blueprint/service/OsgiServiceUtilsTest.java

/******************************************************************************
 * Copyright (c) 2006, 2010 VMware Inc.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * and Apache License v2.0 which accompanies this distribution. 
 * The Eclipse Public License is available at 
 * http://www.eclipse.org/legal/epl-v10.html and the Apache License v2.0
 * is available at http://www.opensource.org/licenses/apache2.0.php.
 * You may elect to redistribute this code under either of these licenses. 
 * 
 * Contributors:
 *   VMware Inc.
 *****************************************************************************/

package org.eclipse.gemini.blueprint.service;

import java.io.Serializable;
import java.util.Arrays;

import junit.framework.TestCase;

import static org.easymock.EasyMock.*;
import org.osgi.framework.BundleContext;
import org.osgi.framework.ServiceReference;
import org.springframework.aop.framework.ProxyFactory;
import org.springframework.util.ClassUtils;
import org.springframework.util.ObjectUtils;

/**
 * @author Adrian Colyer
 * @author Costin Leau
 * @since 2.0
 */
public class OsgiServiceUtilsTest extends TestCase {
	private BundleContext bundleContext;

	protected void setUp() throws Exception {
		super.setUp();
		this.bundleContext = createMock(BundleContext.class);
	}

//	public void testGetServiceWithBadFilter() throws InvalidSyntaxException {
//		this.bundleContext.getServiceReferences(ApplicationContext.class.getName(), "junk-filter");
//		this.mockControl.setThrowable(new InvalidSyntaxException("aaa", "xxx"));
//		this.mockControl.replay();
//		try {
//			OsgiServiceUtils.getService(this.bundleContext, ApplicationContext.class, "junk-filter");
//			fail("Should throw IllegalArgumentException");
//		}
//		catch (IllegalArgumentException ex) {
//			assertEquals("aaa", ex.getMessage());
//		}
//		this.mockControl.verify();
//	}
//
//	public void testGetServiceWithOneMatch() throws InvalidSyntaxException {
//		this.bundleContext.getServiceReferences(ApplicationContext.class.getName(), "");
//		ServiceReference sRef = getServiceReference();
//		ServiceReference[] refs = new ServiceReference[] { sRef };
//		this.mockControl.setReturnValue(refs);
//		this.mockControl.replay();
//		ServiceReference ret = OsgiServiceUtils.getService(this.bundleContext, ApplicationContext.class, "");
//		this.mockControl.verify();
//		assertSame("Should get the reference returned by osgi", sRef, ret);
//	}
//
//	public void testGetServiceWithNoMatches() throws InvalidSyntaxException {
//		this.bundleContext.getServiceReferences(ApplicationContext.class.getName(), "");
//		this.mockControl.setReturnValue(new ServiceReference[0]);
//		this.mockControl.replay();
//		try {
//			OsgiServiceUtils.getService(this.bundleContext, ApplicationContext.class, "");
//			fail("Expecting NoSuchServiceException");
//		}
//		catch (NoSuchServiceException ex) {
//			assertTrue("Should contain message about the service type we tried to look up", ex.getMessage().startsWith(
//					"A service of type 'org.springframework.context.ApplicationContext'"));
//			assertEquals("serviceType should be ApplicationContext", ApplicationContext.class, ex.getServiceType());
//			assertEquals("filter should be empty", "", ex.getFilter());
//		}
//		this.mockControl.verify();
//	}
//
//	public void testGetServiceWithMultipleMatches() throws InvalidSyntaxException {
//		this.bundleContext.getServiceReferences(ApplicationContext.class.getName(), "");
//		this.mockControl.setReturnValue(new ServiceReference[2]);
//		this.mockControl.replay();
//		try {
//			OsgiServiceUtils.getService(this.bundleContext, ApplicationContext.class, "");
//			fail("Expecting AmbiguousServiceReferencepException");
//		}
//		catch (AmbiguousServiceReferenceException ex) {
//			assertTrue("Should contain message about the service type we tried to look up", ex.getMessage().startsWith(
//					"Found 2 services of type"));
//			assertEquals("serviceType should be ApplicationContext", ApplicationContext.class, ex.getServiceType());
//			assertEquals("filter should be empty", "", ex.getFilter());
//		}
//		this.mockControl.verify();
//	}
//
//	public void testGetServicesWithBadFilter() throws InvalidSyntaxException {
//		this.bundleContext.getServiceReferences(ApplicationContext.class.getName(), "junk-filter");
//		this.mockControl.setThrowable(new InvalidSyntaxException("aaa", "xxx"));
//		this.mockControl.replay();
//		try {
//			OsgiServiceUtils.getServices(this.bundleContext, ApplicationContext.class, "junk-filter");
//			fail("Should throw IllegalArgumentException");
//		}
//		catch (IllegalArgumentException ex) {
//			assertEquals("aaa", ex.getMessage());
//		}
//		this.mockControl.verify();
//	}
//
//	public void testGetServicesWithNoMatches() throws InvalidSyntaxException {
//		this.bundleContext.getServiceReferences(ApplicationContext.class.getName(), "");
//		this.mockControl.setReturnValue(new ServiceReference[0]);
//		this.mockControl.replay();
//		ServiceReference[] ret = OsgiServiceUtils.getServices(this.bundleContext, ApplicationContext.class, "");
//		this.mockControl.verify();
//		assertEquals("no services should be found", 0, ret.length);
//	}
//
//	public void testGetServicesWithMatches() throws InvalidSyntaxException {
//		this.bundleContext.getServiceReferences(ApplicationContext.class.getName(), "");
//		ServiceReference[] sRefs = new ServiceReference[2];
//		sRefs[0] = getServiceReference();
//		sRefs[1] = getServiceReference();
//		this.mockControl.setReturnValue(sRefs);
//		this.mockControl.replay();
//		ServiceReference[] ret = OsgiServiceUtils.getServices(this.bundleContext, ApplicationContext.class, "");
//		this.mockControl.verify();
//		assertEquals("2 services should be found", 2, ret.length);
//		assertSame(sRefs[0], ret[0]);
//		assertSame(sRefs[1], ret[1]);
//	}

	private ServiceReference getServiceReference() {
		return createNiceMock(ServiceReference.class);
	}

	public void testSimpleClassDetermination() throws Exception {
		Class<?>[] classes = new Class<?>[] { Object.class, Serializable.class, Cloneable.class };
		Class<?>[] expected = new Class<?>[] { Serializable.class, Cloneable.class };
		Class<?>[] clazz = org.eclipse.gemini.blueprint.util.internal.ClassUtils.removeParents(classes);

		assertTrue(Arrays.equals(expected, clazz));
	}

	public void testIntefacesAlreadyContainedInTheSpecifiedClass() throws Exception {
		Class<?>[] classes = new Class<?>[] { Serializable.class, Number.class, Comparable.class, Object.class };
		Class<?>[] expected = new Class<?>[] { Number.class, Comparable.class };
		Class<?>[] clazz = org.eclipse.gemini.blueprint.util.internal.ClassUtils.removeParents(classes);
		assertTrue(Arrays.equals(expected, clazz));
	}

	public void testMultipleClassesAndInterfaces() throws Exception {
		Class<?>[] classes = new Class<?>[] { Serializable.class, Number.class, Comparable.class, Object.class, Long.class,
				Integer.class };
		Class<?>[] expected = new Class<?>[] { Long.class, Integer.class };
		Class<?>[] clazz = org.eclipse.gemini.blueprint.util.internal.ClassUtils.removeParents(classes);
		assertTrue(Arrays.equals(expected, clazz));
	}

	public void tstProxyCreation() throws Exception {
		ProxyFactory pf = new ProxyFactory();
		pf.setInterfaces(new Class<?>[] { Serializable.class, Comparable.class });
		//pf.setTargetClass(Number.class);
		pf.setProxyTargetClass(true);
		Object proxy = pf.getProxy();
		System.out.println(ObjectUtils.nullSafeToString(ClassUtils.getAllInterfaces(proxy)));
		assertTrue(proxy instanceof Number);
	}
}