package org.apache.felix.ipojo.test;
import java.util.List;
import java.util.Map;
import java.util.Properties;
import org.apache.felix.ipojo.ComponentInstance;
import org.apache.felix.ipojo.ConfigurationException;
import org.apache.felix.ipojo.Factory;
import org.apache.felix.ipojo.MissingHandlerException;
import org.apache.felix.ipojo.UnacceptableConfiguration;
import org.apache.felix.ipojo.junit4osgi.OSGiTestCase;
import org.apache.felix.ipojo.test.scenarios.util.Utils;
import org.osgi.framework.ServiceReference;
public class WbpTests extends OSGiTestCase {
Factory provFactory;
Factory factory, factory2, factory3, factory4;
public void setUp() {
provFactory = Utils.getFactoryByName(context, "fooprovider");
factory = Utils.getFactoryByName(context, "under-providers");
factory2 = Utils.getFactoryByName(context, "under-properties");
factory3 = Utils.getFactoryByName(context, "under-providers-lifecycle");
factory4 = Utils.getFactoryByName(context, "under-providers-2");
}
public void tearDown() {
}
public void testServiceProviders() throws UnacceptableConfiguration, MissingHandlerException, ConfigurationException {
ComponentInstance ci = factory.createComponentInstance(new Properties());
ServiceReference ref = Utils.getServiceReferenceByName(context, Observable.class.getName(), ci.getInstanceName());
assertNotNull("Check Observable availability", ref);
Observable obs = (Observable) context.getService(ref);
Map map = obs.getObservations();
assertEquals("Check empty list" , ((List) map.get("list")).size(), 0);
Properties p1 = new Properties();
p1.put("foo", "foo");
ComponentInstance prov1 = provFactory.createComponentInstance(p1);
map = obs.getObservations();
assertEquals("Check list #1" , ((List) map.get("list")).size(), 1);
Properties p2 = new Properties();
p2.put("foo", "foo");
ComponentInstance prov2 = provFactory.createComponentInstance(p2);
map = obs.getObservations();
assertEquals("Check list #2" , ((List) map.get("list")).size(), 2);
prov1.stop();
map = obs.getObservations();
assertEquals("(1) Check list #1" , ((List) map.get("list")).size(), 1);
prov2.stop();
map = obs.getObservations();
assertEquals("(2) Check list #0" , ((List) map.get("list")).size(), 0);
prov2.start();
map = obs.getObservations();
assertEquals("(3) Check list #1" , ((List) map.get("list")).size(), 1);
prov1.start();
map = obs.getObservations();
assertEquals("(4) Check list #2" , ((List) map.get("list")).size(), 2);
prov1.dispose();
map = obs.getObservations();
assertEquals("(5) Check list #1" , ((List) map.get("list")).size(), 1);
prov2.dispose();
map = obs.getObservations();
assertEquals("(6) Check list #0" , ((List) map.get("list")).size(), 0);
context.ungetService(ref);
ci.dispose();
}
public void testPropertiesProviders() throws UnacceptableConfiguration, MissingHandlerException, ConfigurationException {
ComponentInstance ci = factory2.createComponentInstance(new Properties());
ServiceReference ref = Utils.getServiceReferenceByName(context, Observable.class.getName(), ci.getInstanceName());
assertNotNull("Check Observable availability", ref);
Observable obs = (Observable) context.getService(ref);
Map map = obs.getObservations();
assertEquals("Check empty list" , ((List) map.get("list")).size(), 0);
Properties p1 = new Properties();
p1.put("foo", "foo");
ComponentInstance prov1 = provFactory.createComponentInstance(p1);
ServiceReference ref1 = Utils.getServiceReferenceByName(context, FooService.class.getName(), prov1.getInstanceName());
FooService fs1 = (FooService) context.getService(ref1);
map = obs.getObservations();
assertEquals("Check list #1" , ((List) map.get("list")).size(), 1);
Properties p2 = new Properties();
p2.put("foo", "foo");
ComponentInstance prov2 = provFactory.createComponentInstance(p2);
ServiceReference ref2 = Utils.getServiceReferenceByName(context, FooService.class.getName(), prov2.getInstanceName());
FooService fs2 = (FooService) context.getService(ref2);
map = obs.getObservations();
assertEquals("Check list #2" , ((List) map.get("list")).size(), 2);
fs1.foo();
map = obs.getObservations();
assertEquals("(1) Check list #1" , ((List) map.get("list")).size(), 1);
fs2.foo();
map = obs.getObservations();
assertEquals("(2) Check list #0" , ((List) map.get("list")).size(), 0);
fs2.foo();
map = obs.getObservations();
assertEquals("(3) Check list #1" , ((List) map.get("list")).size(), 1);
fs1.foo();
map = obs.getObservations();
assertEquals("(4) Check list #2" , ((List) map.get("list")).size(), 2);
prov1.dispose();
map = obs.getObservations();
assertEquals("(5) Check list #1" , ((List) map.get("list")).size(), 1);
prov2.dispose();
map = obs.getObservations();
assertEquals("(6) Check list #0" , ((List) map.get("list")).size(), 0);
context.ungetService(ref1);
context.ungetService(ref2);
context.ungetService(ref);
ci.dispose();
}
public void testModifications() throws UnacceptableConfiguration, MissingHandlerException, ConfigurationException {
ComponentInstance ci = factory.createComponentInstance(new Properties());
ServiceReference ref = Utils.getServiceReferenceByName(context, Observable.class.getName(), ci.getInstanceName());
assertNotNull("Check Observable availability", ref);
Observable obs = (Observable) context.getService(ref);
Map map = obs.getObservations();
assertEquals("Check empty list" , ((List) map.get("list")).size(), 0);
Properties p1 = new Properties();
p1.put("foo", "foo");
ComponentInstance prov1 = provFactory.createComponentInstance(p1);
map = obs.getObservations();
assertEquals("Check list #1" , ((List) map.get("list")).size(), 1);
assertEquals("Check modification #0" , ((Integer) map.get("modifications")).intValue(), 0);
ServiceReference ref2 = Utils.getServiceReference(context, FooService.class.getName(), null);
assertNotNull("Check FooService availability", ref2);
FooService fs = (FooService) context.getService(ref2);
fs.foo();
map = obs.getObservations();
assertEquals("Check list #1" , ((List) map.get("list")).size(), 1);
assertEquals("Check modification #1 (" + map.get("modifications")+")" , ((Integer) map.get("modifications")).intValue(), 1);
fs.foo();
map = obs.getObservations();
assertEquals("Check list #1" , ((List) map.get("list")).size(), 1);
assertEquals("Check modification #2" , ((Integer) map.get("modifications")).intValue(), 2);
prov1.dispose();
map = obs.getObservations();
assertEquals("Check list #0" , ((List) map.get("list")).size(), 0);
assertEquals("Check modification #2" , ((Integer) map.get("modifications")).intValue(), 2);
context.ungetService(ref);
context.ungetService(ref2);
ci.dispose();
}
public void testLifecycleCompliance() throws UnacceptableConfiguration, MissingHandlerException, ConfigurationException {
// First expose a service.
Properties p1 = new Properties();
p1.put("foo", "foo");
ComponentInstance prov1 = provFactory.createComponentInstance(p1);
ComponentInstance ci = factory3.createComponentInstance(new Properties());
ServiceReference ref = Utils.getServiceReferenceByName(context, Observable.class.getName(), ci.getInstanceName());
assertNotNull("Check Observable availability", ref);
Observable obs = (Observable) context.getService(ref);
Map map = obs.getObservations();
// Check time
Long validate = (Long) map.get("validate");
Long arrival = (Long) map.get("arrival");
// Validate must be call before.
assertTrue(validate.longValue() + " <?> " + arrival.longValue(), validate.longValue() < arrival.longValue());
prov1.dispose();
ci.dispose();
}
public void testServiceProvidersWhiteWhiteboards() throws UnacceptableConfiguration, MissingHandlerException, ConfigurationException {
ComponentInstance ci = factory4.createComponentInstance(new Properties());
ServiceReference ref = Utils.getServiceReferenceByName(context, Observable.class.getName(), ci.getInstanceName());
assertNotNull("Check Observable availability", ref);
Observable obs = (Observable) context.getService(ref);
Map map = obs.getObservations();
assertEquals("Check empty list" , ((List) map.get("list")).size(), 0);
Properties p1 = new Properties();
p1.put("foo", "foo");
ComponentInstance prov1 = provFactory.createComponentInstance(p1);
map = obs.getObservations();
assertEquals("Check list #1" , ((List) map.get("list")).size(), 1);
Properties p2 = new Properties();
p2.put("foo", "foo");
ComponentInstance prov2 = provFactory.createComponentInstance(p2);
map = obs.getObservations();
assertEquals("Check list #2" , ((List) map.get("list")).size(), 2);
prov1.stop();
map = obs.getObservations();
assertEquals("(1) Check list #1" , ((List) map.get("list")).size(), 1);
prov2.stop();
map = obs.getObservations();
assertEquals("(2) Check list #0" , ((List) map.get("list")).size(), 0);
prov2.start();
map = obs.getObservations();
assertEquals("(3) Check list #1" , ((List) map.get("list")).size(), 1);
prov1.start();
map = obs.getObservations();
assertEquals("(4) Check list #2" , ((List) map.get("list")).size(), 2);
prov1.dispose();
map = obs.getObservations();
assertEquals("(5) Check list #1" , ((List) map.get("list")).size(), 1);
prov2.dispose();
map = obs.getObservations();
assertEquals("(6) Check list #0" , ((List) map.get("list")).size(), 0);
context.ungetService(ref);
ci.dispose();
}
}