Google Git
Sign in
apache / aries-jax-rs-whiteboard / eb41442bcdd4823b3ad6f023dc0d83e3718d6345 / . / jax-rs.itests / src / main / java / test / JaxrsTest.java
blob: 26fc4ef345edb6bc409d1fc39687b9377a87d2fc [file] [log] [blame]
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package test;
import static javax.ws.rs.core.MediaType.TEXT_PLAIN_TYPE;
import static org.junit.Assert.assertArrayEquals;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
import static org.osgi.service.http.whiteboard.HttpWhiteboardConstants.HTTP_WHITEBOARD_CONTEXT_NAME;
import static org.osgi.service.http.whiteboard.HttpWhiteboardConstants.HTTP_WHITEBOARD_CONTEXT_PATH;
import static org.osgi.service.http.whiteboard.HttpWhiteboardConstants.HTTP_WHITEBOARD_CONTEXT_SELECT;
import static org.osgi.service.jaxrs.whiteboard.JaxrsWhiteboardConstants.*;
import java.io.IOException;
import java.lang.reflect.InvocationTargetException;
import java.net.MalformedURLException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.Dictionary;
import java.util.HashSet;
import java.util.Hashtable;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;
import java.util.function.Function;
import org.apache.cxf.Bus;
import org.apache.cxf.jaxrs.ext.ContextProvider;
import org.apache.cxf.message.Message;
import org.junit.Ignore;
import org.junit.Test;
import org.osgi.framework.*;
import org.osgi.service.cm.Configuration;
import org.osgi.service.cm.ConfigurationAdmin;
import org.osgi.service.http.context.ServletContextHelper;
import org.osgi.service.jaxrs.client.PromiseRxInvoker;
import org.osgi.service.jaxrs.client.SseEventSourceFactory;
import org.osgi.service.jaxrs.runtime.JaxrsServiceRuntime;
import org.osgi.service.jaxrs.runtime.dto.ApplicationDTO;
import org.osgi.service.jaxrs.runtime.dto.DTOConstants;
import org.osgi.service.jaxrs.runtime.dto.FailedApplicationDTO;
import org.osgi.service.jaxrs.runtime.dto.ResourceDTO;
import org.osgi.service.jaxrs.runtime.dto.ResourceMethodInfoDTO;
import org.osgi.service.jaxrs.runtime.dto.RuntimeDTO;
import org.osgi.util.promise.Promise;
import org.osgi.util.tracker.ServiceTracker;
import org.osgi.util.tracker.ServiceTrackerCustomizer;
import test.types.ConfigurationAwareResource;
import test.types.CxfExtensionTestAddon;
import test.types.ExtensionA;
import test.types.ExtensionB;
import test.types.PerRequestTestFilter;
import test.types.PerRequestTestResource;
import test.types.SSEResource;
import test.types.TestAddon;
import test.types.TestAddonConflict;
import test.types.TestAddonConflict2;
import test.types.TestApplication;
import test.types.TestApplicationConflict;
import test.types.TestApplicationWithAppPath;
import test.types.TestApplicationWithException;
import test.types.TestApplicationWithSingletons;
import test.types.TestAsyncResource;
import test.types.TestCxfExtension;
import test.types.TestFilter;
import test.types.TestHelper;
import test.types.TestResourceTie;
import test.types.TestResourceTie2;
import test.types.TestSSEApplication;
import test.types.TestVoidResource;
import javax.ws.rs.GET;
import javax.ws.rs.HttpMethod;
import javax.ws.rs.client.Entity;
import javax.ws.rs.client.InvocationCallback;
import javax.ws.rs.client.WebTarget;
import javax.ws.rs.container.ContainerRequestFilter;
import javax.ws.rs.container.ContainerResponseFilter;
import javax.ws.rs.core.Application;
import javax.ws.rs.core.Feature;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
import javax.ws.rs.ext.ExceptionMapper;
import javax.ws.rs.ext.Provider;
import javax.ws.rs.sse.SseEventSource;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotEquals;
import static org.junit.Assert.assertNull;
public class JaxrsTest extends TestHelper {
@Test
public void testApplicationWithAppPath() throws InterruptedException {
registerApplication(new TestApplicationWithAppPath());
assertEquals(1, getRuntimeDTO().applicationDTOs.length);
WebTarget webTarget = createDefaultTarget().path("/test-application/my");
Response response = webTarget.request().get();
assertEquals("ok", response.readEntity(String.class));
RuntimeDTO runtimeDTO = _runtime.getRuntimeDTO();
ApplicationDTO[] applicationDTOs = runtimeDTO.applicationDTOs;
assertEquals(1, applicationDTOs.length);
ApplicationDTO applicationDTO = applicationDTOs[0];
assertEquals("/test-application", applicationDTO.base);
}
@Test
public void testApplicationWithSingletonProxy() throws InterruptedException {
registerApplication(new TestApplicationWithSingletons());
assertEquals(1, getRuntimeDTO().applicationDTOs.length);
WebTarget webTarget = createDefaultTarget().path("/test-application/my");
Response response = webTarget.request().get();
assertEquals("ok", response.readEntity(String.class));
RuntimeDTO runtimeDTO = _runtime.getRuntimeDTO();
ApplicationDTO[] applicationDTOs = runtimeDTO.applicationDTOs;
assertEquals(1, applicationDTOs.length);
ApplicationDTO applicationDTO = applicationDTOs[0];
ResourceMethodInfoDTO[] resourceMethods =
applicationDTO.resourceMethods;
assertEquals(1, resourceMethods.length);
ResourceMethodInfoDTO resourceMethod = resourceMethods[0];
assertEquals(HttpMethod.GET, resourceMethod.method);
assertEquals("/my", resourceMethod.path);
assertNull(resourceMethod.consumingMimeType);
assertArrayEquals(
new String[]{MediaType.TEXT_PLAIN},
resourceMethod.producingMimeType);
assertNull(resourceMethod.nameBindings);
}
@Test
public void testApplication() throws InterruptedException {
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
registerApplication(new TestApplication());
assertEquals(1, getRuntimeDTO().applicationDTOs.length);
WebTarget webTarget = createDefaultTarget().path("/test-application");
Response response = webTarget.request().get();
assertEquals("Hello application",
response.readEntity(String.class));
RuntimeDTO runtimeDTO = _runtime.getRuntimeDTO();
ApplicationDTO[] applicationDTOs = runtimeDTO.applicationDTOs;
assertEquals(1, applicationDTOs.length);
ApplicationDTO applicationDTO = applicationDTOs[0];
ResourceMethodInfoDTO[] resourceMethods =
applicationDTO.resourceMethods;
assertEquals(1, resourceMethods.length);
ResourceMethodInfoDTO resourceMethod = resourceMethods[0];
assertEquals(HttpMethod.GET, resourceMethod.method);
assertEquals("/", resourceMethod.path);
assertNull(resourceMethod.consumingMimeType);
assertArrayEquals(
new String[]{MediaType.TEXT_PLAIN},
resourceMethod.producingMimeType);
assertNull(resourceMethod.nameBindings);
}
@Test
public void testApplicationChangeCount() throws Exception {
Long changeCount = (Long)_runtimeServiceReference.getProperty(
"service.changecount");
ServiceRegistration<?> serviceRegistration =
registerApplication(
new TestApplication(), JAX_RS_APPLICATION_BASE,
"/test-counter");
Long newCount = (Long)_runtimeServiceReference.getProperty(
"service.changecount");
assertTrue(changeCount < newCount);
changeCount = newCount;
serviceRegistration.unregister();
newCount = (Long)_runtimeServiceReference.getProperty(
"service.changecount");
assertTrue(changeCount < newCount);
}
@Test
public void testApplicationConflict() {
WebTarget webTarget = createDefaultTarget().path("test-application");
ServiceRegistration<?> serviceRegistration2;
registerApplication(new TestApplication());
Response response = webTarget.request().get();
assertEquals("Hello application", response.readEntity(String.class));
serviceRegistration2 = registerApplication(
new TestApplicationConflict(), "service.ranking", -1);
response = webTarget.request().get();
assertEquals("Hello application", response.readEntity(String.class));
assertEquals(
Response.Status.NOT_FOUND.getStatusCode(),
webTarget.path("conflict").request().get().getStatus());
serviceRegistration2.unregister();
response = webTarget.request().get();
assertEquals("Hello application", response.readEntity(String.class));
}
@Test
public void testApplicationEndpointExtension() {
WebTarget webTarget = createDefaultTarget().
path("/test-application").
path("extended");
registerApplication(new TestApplication());
registerAddon(
new TestAddon(), JAX_RS_APPLICATION_SELECT,
"(" + JAX_RS_APPLICATION_BASE + "=/test-application)");
assertEquals(
"Hello extended",
webTarget.request().get().readEntity(String.class));
RuntimeDTO runtimeDTO = _runtime.getRuntimeDTO();
ApplicationDTO[] applicationDTOs = runtimeDTO.applicationDTOs;
assertEquals(1, applicationDTOs.length);
ApplicationDTO applicationDTO = applicationDTOs[0];
ResourceMethodInfoDTO[] resourceMethods =
applicationDTO.resourceMethods;
assertEquals(1, resourceMethods.length);
ResourceMethodInfoDTO resourceMethod = resourceMethods[0];
assertEquals(HttpMethod.GET, resourceMethod.method);
assertEquals("/", resourceMethod.path);
assertNull(resourceMethod.consumingMimeType);
assertArrayEquals(
new String[]{MediaType.TEXT_PLAIN},
resourceMethod.producingMimeType);
assertNull(resourceMethod.nameBindings);
}
@Test
public void testApplicationEndpointExtensionReadd()
throws InterruptedException {
WebTarget webTarget = createDefaultTarget().
path("/test-application").
path("extended");
registerApplication(new TestApplication());
Runnable testCase = () -> {
assertEquals(webTarget.request().get().getStatus(), 404);
ServiceRegistration<?> serviceRegistration = null;
try {
serviceRegistration = registerAddon(
new TestAddon(), JAX_RS_APPLICATION_SELECT,
"(" + JAX_RS_APPLICATION_BASE + "=/test-application)");
assertEquals(
"Hello extended",
webTarget.request().get().readEntity(String.class));
}
finally {
if (serviceRegistration != null) {
serviceRegistration.unregister();
}
}
};
testCase.run();
testCase.run();
}
@Test
public void testApplicationEndpointExtensionRuntimeDTO() {
registerApplication(new TestApplication());
registerAddon(
new TestAddon(), JAX_RS_APPLICATION_SELECT,
"(" + JAX_RS_APPLICATION_BASE + "=/test-application)");
RuntimeDTO runtimeDTO = _runtime.getRuntimeDTO();
assertEquals(1, runtimeDTO.applicationDTOs.length);
ApplicationDTO applicationDTO = runtimeDTO.applicationDTOs[0];
assertEquals(applicationDTO.base, "/test-application");
assertEquals(1, applicationDTO.resourceDTOs.length);
ResourceDTO resourceDTO = applicationDTO.resourceDTOs[0];
assertEquals(1, resourceDTO.resourceMethods.length);
ResourceMethodInfoDTO resourceMethod = resourceDTO.resourceMethods[0];
assertEquals(HttpMethod.GET, resourceMethod.method);
assertEquals("/{name}", resourceMethod.path);
assertNull(resourceMethod.consumingMimeType);
assertNull(resourceMethod.producingMimeType);
assertNull(resourceMethod.nameBindings);
}
@Test
public void testApplicationOverride() throws InterruptedException {
WebTarget webTarget = createDefaultTarget().path("test-application");
JaxrsServiceRuntime runtime = getJaxrsServiceRuntime();
ServiceRegistration<?> serviceRegistration2;
assertEquals(0, runtime.getRuntimeDTO().applicationDTOs.length);
assertEquals(0, runtime.getRuntimeDTO().failedApplicationDTOs.length);
registerApplication(new TestApplication());
assertEquals(1, runtime.getRuntimeDTO().applicationDTOs.length);
assertEquals(0, runtime.getRuntimeDTO().failedApplicationDTOs.length);
Response response = webTarget.request().get();
assertEquals("Hello application", response.readEntity(String.class));
serviceRegistration2 = registerApplication(
new TestApplicationConflict(), "service.ranking", 1);
assertEquals(1, runtime.getRuntimeDTO().applicationDTOs.length);
assertEquals(1, runtime.getRuntimeDTO().failedApplicationDTOs.length);
response = webTarget.request().get();
assertEquals(
"Hello application conflict", response.readEntity(String.class));
assertEquals(
"conflict",
webTarget.path("conflict").request().get(String.class));
serviceRegistration2.unregister();
assertEquals(1, runtime.getRuntimeDTO().applicationDTOs.length);
assertEquals(0, runtime.getRuntimeDTO().failedApplicationDTOs.length);
response = webTarget.request().get();
assertEquals("Hello application", response.readEntity(String.class));
}
@Test
public void testApplicationProviderExtension() {
WebTarget webTarget = createDefaultTarget().path("/test-application");
registerApplication(new TestApplication());
registerExtension(
"filter", JAX_RS_APPLICATION_SELECT,
"(" + JAX_RS_APPLICATION_BASE + "=/test-application)");
Response response = webTarget.request().get();
assertEquals("Hello application", response.readEntity(String.class));
assertEquals("true", response.getHeaders().getFirst("Filtered"));
}
@Test
public void testApplicationProviderExtensionReadd() {
WebTarget webTarget = createDefaultTarget().path("/test-application");
registerApplication(new TestApplication());
assertEquals(
"Hello application",
webTarget.request().get().readEntity(String.class));
Runnable testCase = () -> {
Response response = webTarget.request().get();
assertNull(response.getHeaders().getFirst("Filtered"));
ServiceRegistration<?> filterRegistration = null;
try {
filterRegistration = registerExtension(
"Filter",
JAX_RS_APPLICATION_SELECT,
"(" + JAX_RS_APPLICATION_BASE + "=/test-application)");
response = webTarget.request().get();
assertEquals(
response.getHeaders().getFirst("Filtered"), "true");
}
finally {
if (filterRegistration != null) {
filterRegistration.unregister();
}
}
};
testCase.run();
testCase.run();
}
@Test
public void testApplicationReadd() throws InterruptedException {
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
WebTarget webTarget = createDefaultTarget().path("/test-application");
Runnable testCase = () -> {
int applications = getRuntimeDTO().applicationDTOs.length;
assertEquals(404, webTarget.request().get().getStatus());
ServiceRegistration<?> serviceRegistration = null;
try {
serviceRegistration = registerApplication(
new TestApplication());
assertEquals(
"Hello application",
webTarget.
request().
get().
readEntity(String.class));
assertEquals(
applications + 1,
getRuntimeDTO().applicationDTOs.length);
}
finally {
if (serviceRegistration != null) {
serviceRegistration.unregister();
}
}
};
testCase.run();
testCase.run();
}
@SuppressWarnings("serial")
@Test
public void testApplicationRebase() {
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
ServiceRegistration<Application> serviceRegistration =
registerApplication(new TestApplication());
assertEquals(1, getRuntimeDTO().applicationDTOs.length);
WebTarget webTarget = createDefaultTarget().path("/test-application");
Response response = webTarget.request().get();
assertEquals("Hello application", response.readEntity(String.class));
serviceRegistration.setProperties(
new Hashtable<String, Object>() {{
put(JAX_RS_APPLICATION_BASE, "/test-application-rebased");
}});
webTarget = createDefaultTarget().path("/test-application-rebased");
response = webTarget.request().get();
assertEquals("Hello application", response.readEntity(String.class));
serviceRegistration.setProperties(
new Hashtable<String, Object>() {{
put(JAX_RS_APPLICATION_BASE, "/test-application-rebased-again");
}});
webTarget =
createDefaultTarget().
path("/test-application-rebased-again");
response = webTarget.request().get();
assertEquals("Hello application", response.readEntity(String.class));
}
@Test
public void testApplicationReplaceDefault() {
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
registerAddon(new TestAddon());
assertEquals(
"Hello test",
createDefaultTarget().path("/test").request().get(String.class));
ServiceRegistration<Application> serviceRegistration =
registerApplication(new TestApplication(), JAX_RS_NAME, ".default");
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(1, getRuntimeDTO().failedApplicationDTOs.length);
assertEquals(
serviceRegistration.getReference().getProperty("service.id"),
getRuntimeDTO().defaultApplication.serviceId);
assertEquals(
DTOConstants.FAILURE_REASON_DUPLICATE_NAME,
getRuntimeDTO().failedApplicationDTOs[0].failureReason);
assertEquals(
"Hello application",
createDefaultTarget().
path("/test-application").
request().
get().
readEntity(String.class));
assertEquals(
404,
createDefaultTarget().path("/test").request().get().getStatus());
assertEquals(
"Hello test",
createDefaultTarget().
path("/test-application").
path("/test").
request().
get(String.class));
ServiceRegistration<Application> serviceRegistration2 =
registerApplication(
new TestApplicationConflict(), JAX_RS_NAME, ".default",
"service.ranking", 1);
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(2, getRuntimeDTO().failedApplicationDTOs.length);
assertEquals(
serviceRegistration2.getReference().getProperty("service.id"),
getRuntimeDTO().defaultApplication.serviceId);
assertEquals(
DTOConstants.FAILURE_REASON_DUPLICATE_NAME,
getRuntimeDTO().failedApplicationDTOs[0].failureReason);
assertEquals(
DTOConstants.FAILURE_REASON_DUPLICATE_NAME,
getRuntimeDTO().failedApplicationDTOs[1].failureReason);
assertEquals(
"Hello application conflict",
createDefaultTarget().
path("/test-application").
request().
get().
readEntity(String.class));
assertEquals(
404,
createDefaultTarget().path("/test").request().get().getStatus());
assertEquals(
"Hello test",
createDefaultTarget().
path("/test-application").
path("/test").
request().
get(String.class));
serviceRegistration2.unregister();
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(1, getRuntimeDTO().failedApplicationDTOs.length);
assertEquals(
serviceRegistration.getReference().getProperty("service.id"),
getRuntimeDTO().defaultApplication.serviceId);
assertEquals(
DTOConstants.FAILURE_REASON_DUPLICATE_NAME,
getRuntimeDTO().failedApplicationDTOs[0].failureReason);
assertEquals(
"Hello application",
createDefaultTarget().
path("/test-application").
request().
get().
readEntity(String.class));
assertEquals(
404,
createDefaultTarget().path("/test").request().get().getStatus());
assertEquals(
"Hello test",
createDefaultTarget().
path("/test-application").
path("/test").
request().
get(String.class));
serviceRegistration.unregister();
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
assertEquals(
"Hello test",
createDefaultTarget().path("/test").request().get(String.class));
}
@Test
public void testApplicationShadowsDefault() {
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
registerAddon(new TestAddon());
assertEquals(
"Hello test",
createDefaultTarget().path("/test").request().get(String.class));
registerApplication(
new TestApplication(), JAX_RS_APPLICATION_BASE, "/");
assertEquals(1, getRuntimeDTO().applicationDTOs.length);
assertEquals(1, getRuntimeDTO().failedApplicationDTOs.length);
assertEquals(
"Hello application",
createDefaultTarget().request().get(String.class));
}
@Test
public void testApplicationWithDedicatedExtension()
throws InterruptedException {
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
ServiceRegistration<Application> serviceRegistration =
registerApplication(
new TestApplication(),
JAX_RS_EXTENSION_SELECT,
String.format("(%s=%s)", JAX_RS_NAME, "Filter"), "propertyKey",
"propertyValue");
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(1, getRuntimeDTO().failedApplicationDTOs.length);
WebTarget webTarget = createDefaultTarget().path("/test-application");
Response response = webTarget.request().get();
assertEquals(404, response.getStatus());
ServiceRegistration<?> filterRegistration = registerExtension(
"Filter", JAX_RS_APPLICATION_SELECT, "(propertyKey=propertyValue)");
assertEquals(1, getRuntimeDTO().applicationDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
response = webTarget.request().get();
assertEquals("Hello application", response.readEntity(String.class));
filterRegistration.unregister();
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(1, getRuntimeDTO().failedApplicationDTOs.length);
response = webTarget.request().get();
assertEquals(404, response.getStatus());
serviceRegistration.unregister();
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
}
@Test
public void testApplicationWithDedicatedErroredExtension()
throws InterruptedException {
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
registerExtension(
Feature.class,
context -> {
throw new RuntimeException();
},
"ErrorFeature",
JAX_RS_APPLICATION_SELECT,
"(" + JAX_RS_APPLICATION_BASE + "=/test-application)");
registerApplication(
new TestApplication(),
JAX_RS_EXTENSION_SELECT,
String.format("(%s=%s)", JAX_RS_NAME, "ErrorFeature"));
assertEquals(1, getRuntimeDTO().failedExtensionDTOs.length);
assertEquals(1, getRuntimeDTO().failedApplicationDTOs.length);
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
WebTarget webTarget = createDefaultTarget().path("/test-application");
Response response = webTarget.request().get();
assertEquals(404, response.getStatus());
registerExtension(
"ErrorFeature",
JAX_RS_APPLICATION_SELECT,
"(" + JAX_RS_APPLICATION_BASE + "=/test-application)",
"service.ranking", 10);
assertEquals(1, getRuntimeDTO().failedExtensionDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
assertEquals(1, getRuntimeDTO().applicationDTOs.length);
webTarget = createDefaultTarget().path("/test-application");
response = webTarget.request().get();
assertEquals(200, response.getStatus());
}
@Test
public void testApplicationWithDependentExtensions() {
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
registerExtension(
"Filter1",
JAX_RS_APPLICATION_SELECT,
String.format("(%s=%s)", "extension.test", "true"),
JAX_RS_EXTENSION_SELECT,
new String[]{
String.format("(%s=%s)", JAX_RS_NAME, "Filter2"),
String.format("(%s=%s)", JAX_RS_NAME, "Filter3")
});
assertEquals(1, getRuntimeDTO().failedExtensionDTOs.length);
registerApplication(new TestApplication(), "extension.test", "true");
assertEquals(1, getRuntimeDTO().failedExtensionDTOs.length);
registerExtension(
"Filter2", JAX_RS_APPLICATION_SELECT, "(extension.test=true)");
assertEquals(1, getRuntimeDTO().failedExtensionDTOs.length);
registerExtension(
"Filter3",
JAX_RS_APPLICATION_SELECT,
"(&(extension.test=true)(!(excluded=true)))");
assertEquals(0, getRuntimeDTO().failedExtensionDTOs.length);
ServiceRegistration<Application> applicationServiceRegistration =
registerApplication(
new TestApplication(),
JAX_RS_APPLICATION_BASE, "/test-application2",
"extension.test", "true", "excluded", "true");
assertEquals(1, getRuntimeDTO().failedExtensionDTOs.length);
applicationServiceRegistration.unregister();
assertEquals(0, getRuntimeDTO().failedExtensionDTOs.length);
}
@Test
public void testApplicationWithDependentExtensionsShadowsApplication() {
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
//Depends on extension
registerApplication(
new TestApplication(), "extension.test", "true",
JAX_RS_EXTENSION_SELECT, "(osgi.jaxrs.name=Filter1)",
"service.ranking", 10);
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(1, getRuntimeDTO().failedApplicationDTOs.length);
//Shadowed by the other application, even though it is not ready
registerApplication(new TestApplication());
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(2, getRuntimeDTO().failedApplicationDTOs.length);
registerExtension(
"Filter1", JAX_RS_APPLICATION_SELECT, String.format("(%s=%s)",
"extension.test", "true"));
assertEquals(1, getRuntimeDTO().applicationDTOs.length);
assertEquals(1, getRuntimeDTO().failedApplicationDTOs.length);
}
@Test
public void testApplicationWithError() throws InterruptedException {
RuntimeDTO runtimeDTO = getRuntimeDTO();
assertEquals(0, runtimeDTO.applicationDTOs.length);
assertEquals(0, runtimeDTO.failedApplicationDTOs.length);
ServiceRegistration<?> serviceRegistration = registerApplication(
new TestApplication() {
@Override
public Set<Object> getSingletons() {
throw new RuntimeException();
}
});
runtimeDTO = getRuntimeDTO();
assertEquals(0, runtimeDTO.applicationDTOs.length);
assertEquals(1, runtimeDTO.failedApplicationDTOs.length);
assertEquals(
DTOConstants.FAILURE_REASON_UNKNOWN,
runtimeDTO.failedApplicationDTOs[0].failureReason);
WebTarget webTarget = createDefaultTarget().path("/test-application");
assertEquals(404, webTarget.request().get().getStatus());
serviceRegistration.unregister();
runtimeDTO = getRuntimeDTO();
assertEquals(0, runtimeDTO.applicationDTOs.length);
assertEquals(0, runtimeDTO.failedApplicationDTOs.length);
}
@Test
public void testApplicationWithErrorAndHigherRanking() {
RuntimeDTO runtimeDTO = getRuntimeDTO();
assertEquals(0, runtimeDTO.applicationDTOs.length);
assertEquals(0, runtimeDTO.failedApplicationDTOs.length);
ServiceRegistration<Application> applicationRegistration =
registerApplication(new TestApplication());
try {
runtimeDTO = getRuntimeDTO();
assertEquals(1, runtimeDTO.applicationDTOs.length);
assertEquals(0, runtimeDTO.failedApplicationDTOs.length);
ServiceRegistration<?> erroredRegistration = registerApplication(
new TestApplication() {
@Override
public Set<Object> getSingletons() {
throw new RuntimeException();
}
}, "service.ranking", 10);
runtimeDTO = getRuntimeDTO();
assertEquals(0, runtimeDTO.applicationDTOs.length);
assertEquals(2, runtimeDTO.failedApplicationDTOs.length);
erroredRegistration.unregister();
runtimeDTO = getRuntimeDTO();
assertEquals(1, runtimeDTO.applicationDTOs.length);
assertEquals(0, runtimeDTO.failedApplicationDTOs.length);
WebTarget webTarget = createDefaultTarget().
path("/test-application");
assertEquals(200, webTarget.request().get().getStatus());
assertEquals(
"Hello application", webTarget.request().get(String.class));
} finally {
applicationRegistration.unregister();
}
}
@Test
public void testApplicationWithExtensionDryRun()
throws InterruptedException {
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
registerApplication(
new TestApplication(), JAX_RS_EXTENSION_SELECT,
String.format("(%s=%s)", JAX_RS_NAME, "Filter"));
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
WebTarget webTarget = createDefaultTarget().path("/test-application");
Response response = webTarget.request().get();
assertEquals(404, response.getStatus());
ServiceRegistration<?> filterRegistration = registerExtension(
"Filter", JAX_RS_APPLICATION_SELECT, "(unexistent=application)");
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
response = webTarget.request().get();
assertEquals(404, response.getStatus());
filterRegistration.unregister();
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
response = webTarget.request().get();
assertEquals(404, response.getStatus());
}
@Test
public void testApplicationWithGenericExtension()
throws InterruptedException {
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
registerApplication(
new TestApplication(),
JAX_RS_EXTENSION_SELECT,
String.format("(%s=%s)", JAX_RS_NAME, "Filter"));
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
WebTarget webTarget = createDefaultTarget().path("/test-application");
Response response = webTarget.request().get();
assertEquals(404, response.getStatus());
ServiceRegistration<?> filterRegistration = registerExtension("Filter");
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
response = webTarget.request().get();
assertEquals(404, response.getStatus());
filterRegistration.unregister();
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
response = webTarget.request().get();
assertEquals(404, response.getStatus());
}
@Test
public void testApplicationWithGenericExtensionAndApplicationSelect()
throws InterruptedException {
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
registerApplication(
new TestApplication(),
JAX_RS_EXTENSION_SELECT,
String.format("(%s=%s)", JAX_RS_NAME, "Filter"));
registerApplication(
new TestApplication(),
JAX_RS_APPLICATION_BASE, "/test-application-2");
assertEquals(1, getRuntimeDTO().applicationDTOs.length);
WebTarget webTarget = createDefaultTarget().path("/test-application");
Response response = webTarget.request().get();
assertEquals(404, response.getStatus());
ServiceRegistration<?> filterRegistration = registerExtension(
"Filter", JAX_RS_APPLICATION_SELECT,
"(" + JAX_RS_EXTENSION_SELECT + "=" +
String.format("\\(%s\\=%s\\)", JAX_RS_NAME, "Filter") + ")");
assertEquals(2, getRuntimeDTO().applicationDTOs.length);
response = webTarget.request().get();
assertTrue(Boolean.parseBoolean(response.getHeaderString("Filtered")));
assertEquals("Hello application", response.readEntity(String.class));
response =
createDefaultTarget().
path("/test-application-2").
request().
get();
assertNull(response.getHeaderString("Filtered"));
assertEquals("Hello application", response.readEntity(String.class));
filterRegistration.unregister();
assertEquals(1, getRuntimeDTO().applicationDTOs.length);
response = webTarget.request().get();
assertEquals(404, response.getStatus());
}
@Test
/**
* Propietary extension... not in the spec
* breaks application isolation if several applications are forced to
* use the same ServletContext
*/
public void testApplicationWithProvidedServletContext() {
ServiceRegistration<Application> applicationRegistration =
registerApplication(
new TestApplication(), HTTP_WHITEBOARD_CONTEXT_SELECT,
"(" + HTTP_WHITEBOARD_CONTEXT_PATH + "=/context)");
WebTarget webTarget = createDefaultTarget().path(
"/test-application"
);
Response response = webTarget.request().get();
assertEquals(404, response.getStatus());
RuntimeDTO runtimeDTO = getRuntimeDTO();
FailedApplicationDTO[] failedApplicationDTOs =
runtimeDTO.failedApplicationDTOs;
assertEquals(1, failedApplicationDTOs.length);
assertEquals(
applicationRegistration.getReference().getProperty("service.id"),
failedApplicationDTOs[0].serviceId);
assertEquals(
101, failedApplicationDTOs[0].failureReason);
@SuppressWarnings("serial")
ServiceRegistration<ServletContextHelper> context =
bundleContext.registerService(
ServletContextHelper.class, new ServletContextHelper() {},
new Hashtable<String, Object>() {{
put(HTTP_WHITEBOARD_CONTEXT_PATH, "/context");
put(HTTP_WHITEBOARD_CONTEXT_NAME, "contextName");
}});
runtimeDTO = getRuntimeDTO();
failedApplicationDTOs = runtimeDTO.failedApplicationDTOs;
assertEquals(0, failedApplicationDTOs.length);
try {
webTarget = createDefaultTarget().
path(
"/context"
).path(
"/test-application"
);
String responseString = webTarget.request().get(String.class);
assertEquals("Hello application", responseString);
}
finally {
context.unregister();
}
}
@Test
/**
* Proprietary extension... not in the spec
* breaks application isolation if several applications are forced to
* use the same ServletContext
*/
public void testApplicationWithProvidedServletContextClashes() {
ServiceRegistration<Application> applicationRegistration =
registerApplication(
new TestApplication(), JAX_RS_APPLICATION_BASE,
"/context/test-application", "service.ranking", 10);
@SuppressWarnings("serial")
ServiceRegistration<ServletContextHelper> context =
bundleContext.registerService(
ServletContextHelper.class, new ServletContextHelper() {},
new Hashtable<String, Object>() {{
put(HTTP_WHITEBOARD_CONTEXT_PATH, "/context");
put(HTTP_WHITEBOARD_CONTEXT_NAME, "contextName");
}});
try {
ServiceRegistration<Application> applicationRegistration2 =
registerApplication(
new TestApplication(), HTTP_WHITEBOARD_CONTEXT_SELECT,
"(" + HTTP_WHITEBOARD_CONTEXT_PATH + "=/context)");
WebTarget webTarget = createDefaultTarget().
path(
"/context"
).
path(
"test-application"
);
Response response = webTarget.request().get();
assertEquals(
"Hello application", response.readEntity(String.class));
RuntimeDTO runtimeDTO = getRuntimeDTO();
FailedApplicationDTO[] failedApplicationDTOs =
runtimeDTO.failedApplicationDTOs;
assertEquals(1, failedApplicationDTOs.length);
assertEquals(
applicationRegistration2.getReference().getProperty(
"service.id"),
failedApplicationDTOs[0].serviceId);
assertEquals(
DTOConstants.FAILURE_REASON_SHADOWED_BY_OTHER_SERVICE,
failedApplicationDTOs[0].failureReason);
Hashtable<String, Object> properties = new Hashtable<>();
properties.put(
HTTP_WHITEBOARD_CONTEXT_SELECT,
"(" + HTTP_WHITEBOARD_CONTEXT_PATH + "=/context)");
properties.put(JAX_RS_APPLICATION_BASE, "/test-application");
properties.put("service.ranking", 20);
applicationRegistration2.setProperties(properties);
runtimeDTO = getRuntimeDTO();
failedApplicationDTOs = runtimeDTO.failedApplicationDTOs;
assertEquals(1, failedApplicationDTOs.length);
assertEquals(
applicationRegistration.getReference().getProperty(
"service.id"),
failedApplicationDTOs[0].serviceId);
assertEquals(
DTOConstants.FAILURE_REASON_SHADOWED_BY_OTHER_SERVICE,
failedApplicationDTOs[0].failureReason);
webTarget = createDefaultTarget().
path(
"/context"
).path(
"/test-application"
);
String responseString = webTarget.request().get(String.class);
assertEquals("Hello application", responseString);
context.unregister();
runtimeDTO = getRuntimeDTO();
failedApplicationDTOs = runtimeDTO.failedApplicationDTOs;
assertEquals(1, failedApplicationDTOs.length);
assertEquals(
applicationRegistration2.getReference().getProperty(
"service.id"),
failedApplicationDTOs[0].serviceId);
assertEquals(
101, failedApplicationDTOs[0].failureReason);
webTarget = createDefaultTarget().
path(
"/context"
).path(
"/test-application"
);
responseString = webTarget.request().get(String.class);
assertEquals("Hello application", responseString);
}
finally {
try {
context.unregister();
}
catch (Exception e) {
}
}
}
@Test
public void testApplicationWithoutStartingSlash()
throws InterruptedException {
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
registerApplication(
new TestApplication(), JAX_RS_APPLICATION_BASE, "test-application");
assertEquals(1, getRuntimeDTO().applicationDTOs.length);
WebTarget webTarget = createDefaultTarget().path("/test-application");
Response response = webTarget.request().get();
assertEquals("Hello application",
response.readEntity(String.class));
}
@Test
public void testAsyncResource()
throws ExecutionException, InterruptedException {
WebTarget webTarget =
createDefaultTarget().
path("whiteboard").
path("async").
path("suspended").
path("HelloAsync");
AtomicBoolean pre = new AtomicBoolean();
AtomicBoolean post = new AtomicBoolean();
CountDownLatch countDownLatch = new CountDownLatch(1);
registerAddon(
new TestAsyncResource(
() -> pre.set(true),
() -> {
post.set(true);
countDownLatch.countDown();
}));
Future<String> future = webTarget.request().async().get(
new InvocationCallback<String>() {
@Override
public void completed(String s) {
assertTrue(pre.get());
}
@Override
public void failed(Throwable throwable) {
}
});
String result = future.get();
countDownLatch.await(1, TimeUnit.MINUTES);
assertTrue(post.get());
assertEquals("This should say HelloAsync", "HelloAsync", result);
}
@Test
public void testAsyncResourceCompletionStage()
throws ExecutionException, InterruptedException {
WebTarget webTarget =
createDefaultTarget().
path("whiteboard").
path("async").
path("completionstage").
path("HelloAsync");
AtomicBoolean pre = new AtomicBoolean();
AtomicBoolean post = new AtomicBoolean();
CountDownLatch countDownLatch = new CountDownLatch(1);
registerAddon(
new TestAsyncResource(
() -> pre.set(true),
() -> {
post.set(true);
countDownLatch.countDown();
}));
Future<String> future = webTarget.request().async().get(
new InvocationCallback<String>() {
@Override
public void completed(String s) {
assertTrue(pre.get());
}
@Override
public void failed(Throwable throwable) {
}
});
String result = future.get();
countDownLatch.await(1, TimeUnit.MINUTES);
assertTrue(post.get());
assertEquals("This should say HelloAsync", "HelloAsync", result);
}
@Test
public void testAsyncResourcePromise()
throws ExecutionException, InterruptedException {
WebTarget webTarget =
createDefaultTarget().
path("whiteboard").
path("async").
path("promise").
path("HelloAsync");
AtomicBoolean pre = new AtomicBoolean();
AtomicBoolean post = new AtomicBoolean();
CountDownLatch countDownLatch = new CountDownLatch(1);
registerAddon(
new TestAsyncResource(
() -> pre.set(true),
() -> {
post.set(true);
countDownLatch.countDown();
}));
Future<String> future = webTarget.request().async().get(
new InvocationCallback<String>() {
@Override
public void completed(String s) {
assertTrue(pre.get());
}
@Override
public void failed(Throwable throwable) {
}
});
String result = future.get();
countDownLatch.await(1, TimeUnit.MINUTES);
assertTrue(post.get());
assertEquals("This should say HelloAsync", "HelloAsync", result);
}
@Test
public void testAsyncResourceClientWithPromises()
throws ExecutionException, InterruptedException,
InvocationTargetException {
WebTarget webTarget =
createDefaultTarget().
path("whiteboard").
path("async").
path("promise").
path("HelloAsync");
AtomicBoolean pre = new AtomicBoolean();
AtomicBoolean post = new AtomicBoolean();
CountDownLatch countDownLatch = new CountDownLatch(1);
registerAddon(
new TestAsyncResource(
() -> pre.set(true),
() -> {
post.set(true);
countDownLatch.countDown();
}));
Promise<String> promise =
webTarget.
request().
rx(PromiseRxInvoker.class).
get(String.class);
String result = promise.getValue();
countDownLatch.await(1, TimeUnit.MINUTES);
assertTrue(post.get());
assertEquals("This should say HelloAsync", "HelloAsync", result);
}
@Test
public void testDefaultServiceReferencePropertiesAreAvailableInFeatures() {
AtomicBoolean executed = new AtomicBoolean();
AtomicReference<Object> propertyvalue = new AtomicReference<>();
registerExtension(
Feature.class, featureContext -> {
executed.set(true);
@SuppressWarnings("unchecked")
Map<String, Object> properties =
(Map<String, Object>)
featureContext.getConfiguration().getProperty(
"osgi.jaxrs.application.serviceProperties");
propertyvalue.set(properties.get(JAX_RS_NAME));
return false;
}, "Feature", JAX_RS_APPLICATION_SELECT,
"("+ JAX_RS_NAME + "=" + JAX_RS_DEFAULT_APPLICATION + ")");
assertTrue(executed.get());
assertEquals(JAX_RS_DEFAULT_APPLICATION, propertyvalue.get());
}
@Test
@Ignore("Asynchronous problems")
public void testDefaultApplicationPath() throws
IOException, InterruptedException, InvalidSyntaxException {
WebTarget defaultTarget = createDefaultTarget();
WebTarget webTarget = defaultTarget.path("test");
registerAddon(new TestAddon());
Response response = webTarget.request().get();
assertEquals(
"This should say hello", "Hello test",
response.readEntity(String.class));
ConfigurationAdmin configurationAdmin = getConfigurationAdmin();
Configuration configuration = configurationAdmin.getConfiguration(
"org.apache.aries.jax.rs.whiteboard.default", "?");
try {
Hashtable<String, Object> properties = new Hashtable<>();
properties.put("default.application.base", "defaultpath");
CountDownLatch countDownLatch = new CountDownLatch(6);
ServiceTracker<?, ?> tracker =
new ServiceTracker<>(
bundleContext,
JaxrsServiceRuntime.class,
new ServiceTrackerCustomizer<
JaxrsServiceRuntime, Object>() {
@Override
public Object addingService(
ServiceReference<JaxrsServiceRuntime>
serviceReference) {
return serviceReference;
}
@Override
public void modifiedService(
ServiceReference<JaxrsServiceRuntime>
serviceReference,
Object o) {
countDownLatch.countDown();
}
@Override
public void removedService(
ServiceReference<JaxrsServiceRuntime>
serviceReference,
Object o) {
}
});
tracker.open();
configuration.update(properties);
countDownLatch.await(1, TimeUnit.MINUTES);
webTarget = defaultTarget.path("defaultpath").path("test");
response = webTarget.request().get();
assertEquals(
"This should say hello", "Hello test",
response.readEntity(String.class));
}
finally {
CountDownLatch countDownLatch = new CountDownLatch(3);
ServiceTracker<?, ?> tracker =
new ServiceTracker<>(
bundleContext,
JaxrsServiceRuntime.class,
new ServiceTrackerCustomizer<
JaxrsServiceRuntime, Object>() {
@Override
public Object addingService(
ServiceReference<JaxrsServiceRuntime>
serviceReference) {
return serviceReference;
}
@Override
public void modifiedService(
ServiceReference<JaxrsServiceRuntime>
serviceReference,
Object o) {
countDownLatch.countDown();
}
@Override
public void removedService(
ServiceReference<JaxrsServiceRuntime>
serviceReference,
Object o) {
}
});
tracker.open();
configuration.delete();
countDownLatch.await(1, TimeUnit.MINUTES);
}
webTarget = defaultTarget.path("test");
response = webTarget.request().get();
assertEquals(
"This should say hello", "Hello test",
response.readEntity(String.class));
}
@Test
public void testEndpointsOverride() {
WebTarget webTarget = createDefaultTarget().path("conflict");
registerAddon(new TestAddonConflict());
Response response = webTarget.request().get();
assertEquals(
"This should say hello1", "hello1",
response.readEntity(String.class));
ServiceRegistration<?> serviceRegistration = registerAddon(
new TestAddonConflict2(), "service.ranking", 1);
response = webTarget.request().get();
assertEquals(
"This should say hello2", "hello2",
response.readEntity(String.class));
serviceRegistration.unregister();
response = webTarget.request().get();
assertEquals(
"This should say hello1", "hello1",
response.readEntity(String.class));
}
@Test
public void testEndpointsOverrideTie() {
WebTarget webTarget = createDefaultTarget().
path("tie").
path("a").
path("b");
ServiceRegistration<?> serviceRegistration1 = registerAddon(
new TestResourceTie());
Response response = webTarget.request().get();
assertEquals(
"This should say tie/a/b 1", "tie/a/b 1",
response.readEntity(String.class));
ServiceRegistration<?> serviceRegistration2 = registerAddon(
new TestResourceTie2());
response = webTarget.request().get();
assertEquals(
"This should say tie/a/b 2", "tie/a/b 2",
response.readEntity(String.class));
serviceRegistration2.unregister();
response = webTarget.request().get();
assertEquals(
"This should say tie/a/b 1", "tie/a/b 1",
response.readEntity(String.class));
serviceRegistration2 = registerAddon(
new TestResourceTie2(), "service.ranking", -1);
response = webTarget.request().get();
assertEquals(
"This should say tie/a/b 1", "tie/a/b 1",
response.readEntity(String.class));
serviceRegistration2.unregister();
serviceRegistration1.unregister();
registerAddon(new TestResourceTie(), "service.ranking", 1);
registerAddon(new TestResourceTie2(), "service.ranking", 1);
response = webTarget.request().get();
assertEquals(
"This should say tie/a/b 2", "tie/a/b 2",
response.readEntity(String.class));
}
@Test
public void testErroredExtension() {
registerApplication(new TestApplication());
ServiceRegistration<Feature> serviceRegistration = registerExtension(
Feature.class,
context -> {
throw new RuntimeException();
},
"ErrorFeature",
JAX_RS_APPLICATION_SELECT,
"(" + JAX_RS_APPLICATION_BASE + "=/test-application)");
RuntimeDTO runtimeDTO = _runtime.getRuntimeDTO();
assertEquals(1, runtimeDTO.failedExtensionDTOs.length);
assertEquals(
serviceRegistration.getReference().getProperty("service.id"),
runtimeDTO.failedExtensionDTOs[0].serviceId);
assertEquals(
DTOConstants.FAILURE_REASON_UNKNOWN,
runtimeDTO.failedExtensionDTOs[0].failureReason);
}
@Test
public void testErroredExtensionInverseRegistrationOrder() {
ServiceRegistration<Feature> serviceRegistration = registerExtension(
Feature.class,
context -> {
throw new RuntimeException();
},
"ErrorFeature",
JAX_RS_APPLICATION_SELECT,
"(" + JAX_RS_APPLICATION_BASE + "=/test-application)");
registerApplication(new TestApplication());
RuntimeDTO runtimeDTO = _runtime.getRuntimeDTO();
assertEquals(0, runtimeDTO.failedApplicationDTOs.length);
assertEquals(1, runtimeDTO.failedExtensionDTOs.length);
assertEquals(
serviceRegistration.getReference().getProperty("service.id"),
runtimeDTO.failedExtensionDTOs[0].serviceId);
assertEquals(
DTOConstants.FAILURE_REASON_UNKNOWN,
runtimeDTO.failedExtensionDTOs[0].failureReason);
}
@Test
public void testExtensionRegisterOnlySignalledInterfaces()
throws InterruptedException {
WebTarget webTarget = createDefaultTarget().path("test-application");
registerApplication(new TestApplicationWithException());
ServiceRegistration<?> filterRegistration =
registerMultiExtension("Filter", ExceptionMapper.class.getName());
Response response = webTarget.request().get();
assertEquals(200, response.getStatus());
assertNull(response.getHeaders().getFirst("Filtered"));
filterRegistration.unregister();
}
@Test
public void testExtensionWithoutAName() {
Dictionary<String, Object> properties = new Hashtable<>();
properties.put(JAX_RS_EXTENSION, true);
ServiceRegistration<ContainerResponseFilter> registration =
bundleContext.registerService(
ContainerResponseFilter.class, new TestFilter(), properties);
try {
RuntimeDTO runtimeDTO = _runtime.getRuntimeDTO();
assertEquals(
(long)registration.getReference().getProperty("service.id"),
runtimeDTO.defaultApplication.extensionDTOs[0].serviceId);
}
finally {
registration.unregister();
}
}
@Test
public void testFeatureExtension() {
WebTarget webTarget = createDefaultTarget().path("/test-application");
registerApplication(new TestApplication());
registerExtension(
Feature.class,
context -> {
context.register(new TestFilter());
return true;
},
"Feature",
JAX_RS_APPLICATION_SELECT,
"(" + JAX_RS_APPLICATION_BASE + "=/test-application)");
Response response = webTarget.request().get();
assertEquals("Hello application", response.readEntity(String.class));
assertEquals("true", response.getHeaders().getFirst("Filtered"));
}
@Test
public void testGettableAndNotGettableApplication()
throws InterruptedException {
WebTarget webTarget = createDefaultTarget().path("test-application");
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
ServiceRegistration<Application> serviceRegistration =
registerApplication(new TestApplication());
assertEquals(1, getRuntimeDTO().applicationDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
assertEquals(
"Hello application",
webTarget.request().get().readEntity(String.class));
ServiceRegistration<Application> ungettableServiceRegistration =
registerUngettableApplication("service.ranking", 1);
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(2, getRuntimeDTO().failedApplicationDTOs.length);
assertThatInRuntime(
FAILED_APPLICATIONS,
fa -> fa.serviceId == getServiceId(ungettableServiceRegistration) &&
DTOConstants.FAILURE_REASON_SERVICE_NOT_GETTABLE ==
fa.failureReason);
assertEquals(404, webTarget.request().get().getStatus());
serviceRegistration.unregister();
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(1, getRuntimeDTO().failedApplicationDTOs.length);
assertEquals(404, webTarget.request().get().getStatus());
ungettableServiceRegistration.unregister();
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
}
@Test
public void testGettableAndShadowedNotGettableApplication()
throws InterruptedException {
WebTarget webTarget = createDefaultTarget().path("test-application");
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
ServiceRegistration<Application> serviceRegistration =
registerApplication(new TestApplication());
assertEquals(1, getRuntimeDTO().applicationDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
assertEquals(
"Hello application",
webTarget.request().get().readEntity(String.class));
ServiceRegistration<Application> ungettableServiceRegistration =
registerUngettableApplication("service.ranking", -1);
assertEquals(1, getRuntimeDTO().applicationDTOs.length);
assertEquals(1, getRuntimeDTO().failedApplicationDTOs.length);
assertEquals(
DTOConstants.FAILURE_REASON_SHADOWED_BY_OTHER_SERVICE,
getRuntimeDTO().failedApplicationDTOs[0].failureReason);
assertEquals(
"Hello application",
webTarget.request().get().readEntity(String.class));
serviceRegistration.unregister();
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(1, getRuntimeDTO().failedApplicationDTOs.length);
assertEquals(404, webTarget.request().get().getStatus());
ungettableServiceRegistration.unregister();
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
}
@Test
public void testInvalidExtension() throws InterruptedException {
WebTarget webTarget = createDefaultTarget().path("test");
RuntimeDTO runtimeDTO = getRuntimeDTO();
assertEquals(0, runtimeDTO.defaultApplication.extensionDTOs.length);
registerAddon(new TestAddon());
ServiceRegistration<?> filterRegistration = registerInvalidExtension(
"Filter");
runtimeDTO = getRuntimeDTO();
assertEquals(0, runtimeDTO.defaultApplication.extensionDTOs.length);
assertEquals(1, runtimeDTO.failedExtensionDTOs.length);
assertEquals(
(long)filterRegistration.getReference().getProperty(
"service.id"),
runtimeDTO.failedExtensionDTOs[0].serviceId);
assertEquals(
DTOConstants.FAILURE_REASON_NOT_AN_EXTENSION_TYPE,
runtimeDTO.failedExtensionDTOs[0].failureReason);
Response response = webTarget.request().get();
assertEquals(
"This should say hello", "Hello test",
response.readEntity(String.class));
assertNull(response.getHeaders().getFirst("Filtered"));
filterRegistration.unregister();
runtimeDTO = getRuntimeDTO();
assertEquals(0, runtimeDTO.defaultApplication.extensionDTOs.length);
assertEquals(0, runtimeDTO.failedExtensionDTOs.length);
}
@Test
public void testNotGettableApplication() throws InterruptedException {
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
ServiceRegistration<Application> serviceRegistration =
registerUngettableApplication();
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(1, getRuntimeDTO().failedApplicationDTOs.length);
assertEquals(
DTOConstants.FAILURE_REASON_SERVICE_NOT_GETTABLE,
getRuntimeDTO().failedApplicationDTOs[0].failureReason);
serviceRegistration.unregister();
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
}
@Test
public void testPerRequestLifecycleAddon() {
WebTarget webTarget = createDefaultTarget().path("state");
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
ServiceRegistration<?> serviceRegistration = registerAddon(
new PerRequestTestResource());
assertEquals("original", webTarget.request().get(String.class));
registerExtension(
ContainerRequestFilter.class,
new PerRequestTestFilter(), "perrequestfilter");
assertEquals("original-changed", webTarget.request().get(String.class));
assertEquals(
"original-changed-changed", webTarget.request().get(String.class));
serviceRegistration.unregister();
registerAddonPrototype(PerRequestTestResource::new);
assertEquals("original-changed", webTarget.request().get(String.class));
assertEquals("original-changed", webTarget.request().get(String.class));
}
@Test
public void testPrototypeScopedAddonIsReleasedAsSoonAsItIsRegistered() {
assertEquals(0, getRuntimeDTO().applicationDTOs.length);
assertEquals(0, getRuntimeDTO().failedApplicationDTOs.length);
final AtomicInteger getServiceInvocations = new AtomicInteger();
final AtomicInteger ungetServiceInvocations = new AtomicInteger();
PrototypeServiceFactory<Object> prototypeServiceFactory =
new PrototypeServiceFactory<Object>() {
@Override
public Object getService(
Bundle bundle,
ServiceRegistration<Object> registration) {
getServiceInvocations.incrementAndGet();
return new TestAddon();
}
@Override
public void ungetService(
Bundle bundle, ServiceRegistration<Object> registration,
Object service) {
ungetServiceInvocations.incrementAndGet();
}
};
Dictionary<String, Object> properties = new Hashtable<>();
properties.put(JAX_RS_RESOURCE, "true");
ServiceRegistration<?> serviceRegistration =
bundleContext.registerService(
Object.class, (ServiceFactory<?>) prototypeServiceFactory,
properties);
try {
assertEquals(1, getServiceInvocations.get());
assertEquals(1, ungetServiceInvocations.get());
} finally {
serviceRegistration.unregister();
}
assertEquals(1, getServiceInvocations.get());
assertEquals(1, ungetServiceInvocations.get());
}
@Test
public void testRegisterApplicationWithOnlyExtensions() {
ServiceRegistration<Application> serviceRegistration =
registerApplication(new Application() {
@Override
public Set<Class<?>> getClasses() {
return Collections.singleton(TestFilter.class);
}
}, JAX_RS_NAME, JAX_RS_DEFAULT_APPLICATION);
assertEquals(getServiceId(serviceRegistration),
getRuntimeDTO().defaultApplication.serviceId);
}
@Test
public void testResourcesChangeCount() throws Exception {
Long changeCount = (Long)_runtimeServiceReference.getProperty(
"service.changecount");
ServiceRegistration<?> serviceRegistration = registerAddon(
new TestAddon());
Long newCount = (Long)_runtimeServiceReference.getProperty(
"service.changecount");
assertTrue(changeCount < newCount);
changeCount = newCount;
ServiceRegistration<?> serviceRegistration2 = registerAddon(
new TestAddon());
newCount = (Long)_runtimeServiceReference.getProperty(
"service.changecount");
assertTrue(changeCount < newCount);
changeCount = newCount;
serviceRegistration.unregister();
newCount = (Long)_runtimeServiceReference.getProperty(
"service.changecount");
assertTrue(changeCount < newCount);
changeCount = newCount;
serviceRegistration2.unregister();
newCount = (Long)_runtimeServiceReference.getProperty(
"service.changecount");
assertTrue(changeCount < newCount);
}
@Test
public void testServiceEndpointInRuntimeDTO() {
RuntimeDTO runtimeDTO = _runtime.getRuntimeDTO();
assertNotNull(runtimeDTO.serviceDTO);
}
@Test
public void testServiceReferencePropertiesAreAvailableInConfigurationInjection() {
registerApplication(
new Application() {
@Override
public Set<Object> getSingletons() {
return new HashSet<>(Collections.singleton(
new ConfigurationAwareResource()
));
}
}, JAX_RS_NAME, "test", "property", "aValue");
WebTarget webTarget = createDefaultTarget().path("test-application");
assertEquals("aValue", webTarget.request().get(String.class));
}
@Test
public void testServiceReferencePropertiesAreAvailableInFeatures() {
AtomicBoolean executed = new AtomicBoolean();
AtomicReference<Object> propertyvalue = new AtomicReference<>();
registerExtension(
Feature.class, featureContext -> {
executed.set(true);
@SuppressWarnings("unchecked")
Map<String, Object> properties =
(Map<String, Object>)
featureContext.getConfiguration().getProperty(
"osgi.jaxrs.application.serviceProperties");
propertyvalue.set(properties.get("property"));
return false;
}, "Feature", JAX_RS_APPLICATION_SELECT, "(property=true)");
registerApplication(
new Application() {
@Override
public Set<Object> getSingletons() {
return Collections.singleton(
new Object() {
@GET
public String hello() {
return "hello";
}
});
}
}, JAX_RS_NAME, "test", "property", true);
assertTrue(executed.get());
assertEquals(true, propertyvalue.get());
}
@Test
public void testServiceReferencePropertiesAreAvailableInStaticFeatures() {
AtomicBoolean executed = new AtomicBoolean();
AtomicReference<Object> propertyvalue = new AtomicReference<>();
registerApplication(
new Application() {
@Override
public Set<Object> getSingletons() {
return new HashSet<>(Arrays.asList(
(Feature)featureContext -> {
executed.set(true);
@SuppressWarnings("unchecked")
Map<String, Object> properties =
(Map<String, Object>)
featureContext.
getConfiguration().
getProperty(
"osgi.jaxrs.application." +
"serviceProperties");
propertyvalue.set(properties.get("property"));
return false;
},
new Object() {
@GET
public String hello() {
return "hello";
}
}
));
}
}, JAX_RS_NAME, "test", "property", true);
assertTrue(executed.get());
assertEquals(true, propertyvalue.get());
}
@Test
public void testStandaloneEndPoint() throws InterruptedException {
WebTarget webTarget = createDefaultTarget().path("test");
getRuntimeDTO();
registerAddon(new TestAddon());
Response response = webTarget.request().get();
assertEquals(
"This should say hello", "Hello test",
response.readEntity(String.class));
}
@Test
public void testStandaloneEndPointPrototypeLifecycle() {
WebTarget webTarget =
createDefaultTarget().
path("/test-addon-lifecycle");
registerAddonLifecycle(false, JAX_RS_RESOURCE, "true");
String first = webTarget.request().get().readEntity(String.class);
String second = webTarget.request().get().readEntity(String.class);
assertNotEquals("This should be different", first, second);
}
@Test
public void testStandaloneEndPointApplicationScopedLifecycle() {
WebTarget webTarget =
createDefaultTarget().
path("/test-addon-lifecycle");
WebTarget webTarget2 =
createDefaultTarget().
path("/test-application/test-addon-lifecycle");
registerApplication(new TestApplication());
registerAddonLifecycle(
false, JAX_RS_RESOURCE, "true",
"org.apache.aries.jax.rs.whiteboard.application.scoped", true,
JAX_RS_APPLICATION_SELECT, "(osgi.jaxrs.name=*)");
String first = webTarget.request().get().readEntity(String.class);
String second = webTarget.request().get().readEntity(String.class);
String third = webTarget2.request().get().readEntity(String.class);
assertEquals("This should be equal", first, second);
assertNotEquals("This should be different", first, third);
}
@Test
public void testStandaloneEndPointReadd() {
WebTarget webTarget = createDefaultTarget().path("test");
Runnable testCase = () -> {
assertEquals(404, webTarget.request().get().getStatus());
ServiceRegistration<?> serviceRegistration = null;
try {
serviceRegistration = registerAddon(new TestAddon());
assertEquals(
"Hello test",
webTarget.request().get().readEntity(String.class));
}
finally {
if (serviceRegistration != null) {
serviceRegistration.unregister();
}
}
};
testCase.run();
testCase.run();
}
@Test
public void testStandaloneEndPointSingletonLifecycle() {
WebTarget webTarget =
createDefaultTarget().
path("/test-addon-lifecycle");
WebTarget webTarget2 =
createDefaultTarget().
path("/test-application/test-addon-lifecycle");
registerApplication(new TestApplication());
registerAddonLifecycle(
true,
JAX_RS_RESOURCE, "true",
JAX_RS_APPLICATION_SELECT, "(osgi.jaxrs.name=*)");
String first = webTarget.request().get().readEntity(String.class);
String second = webTarget2.request().get().readEntity(String.class);
assertEquals("This should be equal", first, second);
}
@Test
public void testStandaloneEndpointWithExtensionsDependencies()
throws InterruptedException {
WebTarget webTarget = createDefaultTarget().path("test");
JaxrsServiceRuntime runtime = getJaxrsServiceRuntime();
ServiceRegistration<?> serviceRegistration;
ServiceRegistration<?> extensionRegistration1;
ServiceRegistration<?> extensionRegistration2;
serviceRegistration = registerAddon(
new TestAddon(),
JAX_RS_EXTENSION_SELECT, new String[]{
"(property one=one)",
"(property two=two)",
});
RuntimeDTO runtimeDTO = runtime.getRuntimeDTO();
assertEquals(1, runtimeDTO.failedResourceDTOs.length);
assertEquals(
(long)serviceRegistration.getReference().getProperty(
"service.id"),
runtimeDTO.failedResourceDTOs[0].serviceId);
assertEquals(404, webTarget.request().get().getStatus());
extensionRegistration1 = registerExtension(
"aExtension", "property one", "one");
runtimeDTO = runtime.getRuntimeDTO();
assertEquals(1, runtimeDTO.failedResourceDTOs.length);
assertEquals(
(long)serviceRegistration.getReference().getProperty(
"service.id"),
runtimeDTO.failedResourceDTOs[0].serviceId);
assertEquals(404, webTarget.request().get().getStatus());
extensionRegistration2 = registerExtension(
"anotherExtension", "property two", "two");
runtimeDTO = runtime.getRuntimeDTO();
assertEquals(0, runtimeDTO.failedResourceDTOs.length);
Response response = webTarget.request().get();
assertEquals(
"This should say hello", "Hello test",
response.readEntity(String.class));
extensionRegistration1.unregister();
runtimeDTO = runtime.getRuntimeDTO();
assertEquals(1, runtimeDTO.failedResourceDTOs.length);
assertEquals(
(long)serviceRegistration.getReference().getProperty(
"service.id"),
runtimeDTO.failedResourceDTOs[0].serviceId);
assertEquals(404, webTarget.request().get().getStatus());
extensionRegistration1 = registerExtension(
"aExtension", "property one", "one");
runtimeDTO = runtime.getRuntimeDTO();
assertEquals(0, runtimeDTO.failedResourceDTOs.length);
assertEquals(
"This should say hello", "Hello test",
response.readEntity(String.class));
extensionRegistration2.unregister();
runtimeDTO = runtime.getRuntimeDTO();
assertEquals(1, runtimeDTO.failedResourceDTOs.length);
assertEquals(
(long)serviceRegistration.getReference().getProperty(
"service.id"),
runtimeDTO.failedResourceDTOs[0].serviceId);
assertEquals(404, webTarget.request().get().getStatus());
extensionRegistration1.unregister();
runtimeDTO = runtime.getRuntimeDTO();
assertEquals(1, runtimeDTO.failedResourceDTOs.length);
assertEquals(
(long)serviceRegistration.getReference().getProperty(
"service.id"),
runtimeDTO.failedResourceDTOs[0].serviceId);
}
@Test
public void testStandaloneEndpointWithExtensionsDependenciesOnlyOneService()
throws InterruptedException {
WebTarget webTarget = createDefaultTarget().path("test");
JaxrsServiceRuntime runtime = getJaxrsServiceRuntime();
ServiceRegistration<?> serviceRegistration;
ServiceRegistration<?> extensionRegistration1;
serviceRegistration = registerAddon(
new TestAddon(),
JAX_RS_EXTENSION_SELECT, new String[]{
"(property one=one)",
"(property two=two)",
});
RuntimeDTO runtimeDTO = runtime.getRuntimeDTO();
assertEquals(1, runtimeDTO.failedResourceDTOs.length);
assertEquals(
(long)serviceRegistration.getReference().getProperty(
"service.id"),
runtimeDTO.failedResourceDTOs[0].serviceId);
assertEquals(404, webTarget.request().get().getStatus());
extensionRegistration1 = registerExtension(
"aExtension", "property one", "one", "property two", "two");
runtimeDTO = runtime.getRuntimeDTO();
assertEquals(0, runtimeDTO.failedResourceDTOs.length);
Response response = webTarget.request().get();
assertEquals(
"This should say hello", "Hello test",
response.readEntity(String.class));
extensionRegistration1.unregister();
runtimeDTO = runtime.getRuntimeDTO();
assertEquals(1, runtimeDTO.failedResourceDTOs.length);
assertEquals(
(long)serviceRegistration.getReference().getProperty(
"service.id"),
runtimeDTO.failedResourceDTOs[0].serviceId);
assertEquals(404, webTarget.request().get().getStatus());
extensionRegistration1 = registerExtension(
"aExtension", "property one", "one", "property two", "two");
runtimeDTO = runtime.getRuntimeDTO();
assertEquals(0, runtimeDTO.failedResourceDTOs.length);
assertEquals(
"This should say hello", "Hello test",
response.readEntity(String.class));
extensionRegistration1.unregister();
runtimeDTO = runtime.getRuntimeDTO();
assertEquals(1, runtimeDTO.failedResourceDTOs.length);
assertEquals(
(long)serviceRegistration.getReference().getProperty(
"service.id"),
runtimeDTO.failedResourceDTOs[0].serviceId);
}
@Test
public void testStandaloneFilter() throws InterruptedException {
WebTarget webTarget = createDefaultTarget().path("test");
JaxrsServiceRuntime runtime = getJaxrsServiceRuntime();
RuntimeDTO runtimeDTO = runtime.getRuntimeDTO();
assertEquals(0, runtimeDTO.defaultApplication.extensionDTOs.length);
registerAddon(new TestAddon());
ServiceRegistration<?> filterRegistration = registerExtension("Filter");
runtimeDTO = runtime.getRuntimeDTO();
assertEquals(1, runtimeDTO.defaultApplication.extensionDTOs.length);
Response response = webTarget.request().get();
assertEquals(
"This should say hello", "Hello test",
response.readEntity(String.class));
assertEquals("true", response.getHeaders().getFirst("Filtered"));
filterRegistration.unregister();
runtimeDTO = runtime.getRuntimeDTO();
assertEquals(0, runtimeDTO.defaultApplication.extensionDTOs.length);
}
@Test
public void testStandaloneFilterReadd() {
WebTarget webTarget = createDefaultTarget().path("test");
registerAddon(new TestAddon());
assertEquals("Hello test",
webTarget.request().get().readEntity(String.class));
Runnable testCase = () -> {
ServiceRegistration<?> filterRegistration = null;
try {
Response response = webTarget.request().get();
assertNull(response.getHeaders().getFirst("Filtered"));
filterRegistration = registerExtension("Filter");
response = webTarget.request().get();
assertEquals(
"Hello test", response.readEntity(String.class));
assertEquals(
"true", response.getHeaders().getFirst("Filtered"));
}
finally {
if (filterRegistration != null) {
filterRegistration.unregister();
}
}
};
testCase.run();
testCase.run();
}
@Test
public void testUngettableExtension() throws InterruptedException {
WebTarget webTarget = createDefaultTarget().path("test");
JaxrsServiceRuntime runtime = getJaxrsServiceRuntime();
RuntimeDTO runtimeDTO = runtime.getRuntimeDTO();
assertEquals(0, runtimeDTO.defaultApplication.extensionDTOs.length);
registerAddon(new TestAddon());
ServiceRegistration<?> filterRegistration =
registerUngettableExtension("Filter");
runtimeDTO = runtime.getRuntimeDTO();
assertEquals(0, runtimeDTO.defaultApplication.extensionDTOs.length);
assertEquals(1, runtimeDTO.failedExtensionDTOs.length);
assertEquals(
(long)filterRegistration.getReference().getProperty(
"service.id"),
runtimeDTO.failedExtensionDTOs[0].serviceId);
assertEquals(
DTOConstants.FAILURE_REASON_SERVICE_NOT_GETTABLE,
runtimeDTO.failedExtensionDTOs[0].failureReason);
Response response = webTarget.request().get();
assertEquals(
"This should say hello", "Hello test",
response.readEntity(String.class));
assertNull(response.getHeaders().getFirst("Filtered"));
filterRegistration.unregister();
runtimeDTO = runtime.getRuntimeDTO();
assertEquals(0, runtimeDTO.defaultApplication.extensionDTOs.length);
assertEquals(0, runtimeDTO.failedExtensionDTOs.length);
}
@Test
public void testSSEApplication() throws
InterruptedException, MalformedURLException, TimeoutException {
AtomicInteger atomicInteger = new AtomicInteger();
registerApplication(
new TestSSEApplication(), JAX_RS_APPLICATION_BASE, "/sse");
registerAddon(
new SSEResource(), JAX_RS_APPLICATION_SELECT,
"(" + JAX_RS_APPLICATION_BASE + "=/sse)");
registerExtension(
ContainerResponseFilter.class,
(req, res) -> atomicInteger.incrementAndGet(), "Filter",
JAX_RS_APPLICATION_SELECT,
"(" + JAX_RS_APPLICATION_BASE + "=/sse)");
SseEventSourceFactory sseFactory = createSseFactory();
SseEventSource source1 = sseFactory.newSource(
createDefaultTarget().path("/sse").path("/subscribe"));
SseEventSource source2 = sseFactory.newSource(
createDefaultTarget().path("/sse").path("/subscribe"));
ArrayList<String> source1Events = new ArrayList<>();
ArrayList<String> source2Events = new ArrayList<>();
Phaser phaser = new Phaser(2);
source1.register(
event -> {source1Events.add(event.readData(String.class));phaser.arrive(); });
source2.register(
event -> {source2Events.add(event.readData(String.class));phaser.arrive(); });
source1.open();
source2.open();
phaser.awaitAdvanceInterruptibly(0, 10, TimeUnit.SECONDS);
//The filter IS invoked on the subscribe method
assertEquals(2, atomicInteger.get());
WebTarget broadcast = createDefaultTarget().path("/sse").path(
"/broadcast");
broadcast.request().post(
Entity.entity("message", MediaType.TEXT_PLAIN_TYPE));
phaser.awaitAdvanceInterruptibly(1, 10, TimeUnit.SECONDS);
assertEquals(Arrays.asList("welcome", "message"), source1Events);
assertEquals(Arrays.asList("welcome", "message"), source2Events);
source2.close();
phaser.arrive();
atomicInteger.set(0);
broadcast.request().post(
Entity.entity("another message", MediaType.TEXT_PLAIN_TYPE));
phaser.awaitAdvanceInterruptibly(2, 10, TimeUnit.SECONDS);
assertEquals(
Arrays.asList("welcome", "message", "another message"),
source1Events);
assertEquals(Arrays.asList("welcome", "message"), source2Events);
source1.close();
//The filter IS invoked when broadcasting events
assertEquals(1, atomicInteger.get());
}
@Test
public void testCxfExtension() {
registerApplication(new TestApplication());
registerExtension(
ContextProvider.class,
new BusContextProvider(),
"Bus provider");
registerAddon(
new CxfExtensionTestAddon(), JAX_RS_APPLICATION_SELECT,
String.format(
"(%s=%s)", JAX_RS_APPLICATION_BASE, "/test-application"));
@SuppressWarnings("serial")
ServiceRegistration<?> extensionRegistration =
bundleContext.registerService(
new String[]{
ExtensionA.class.getName(),
ExtensionB.class.getName()
},
new TestCxfExtension(),
new Hashtable<String, Object>() {{
put("cxf.extension", Boolean.TRUE);
}});
try {
WebTarget path = createDefaultTarget().
path("/test-application").
path("/extensions").
path(ExtensionA.class.getName());
String result = path.request().get(String.class);
assertTrue(Boolean.parseBoolean(result));
path = createDefaultTarget().
path("/test-application").
path("/extensions").
path(ExtensionB.class.getName());
result = path.request().get(String.class);
assertTrue(Boolean.parseBoolean(result));
extensionRegistration.unregister();
path = createDefaultTarget().
path("/test-application").
path("/extensions").
path(ExtensionA.class.getName());
result = path.request().get(String.class);
assertFalse(Boolean.parseBoolean(result));
path = createDefaultTarget().
path("/test-application").
path("/extensions").
path(ExtensionB.class.getName());
result = path.request().get(String.class);
assertFalse(Boolean.parseBoolean(result));
}
finally {
try {
extensionRegistration.unregister();
}
catch (Exception e) {
}
}
}
@Test
public void testCXFServiceListPage() {
registerApplication(new TestApplication());
WebTarget path = createDefaultTarget().
path("/test-application").
path("/services");
Response response = path.request().get();
assertEquals(404, response.getStatus());
}
@Test
public void testVoidResource() {
registerAddon(new TestVoidResource());
Response response =
createDefaultTarget().
path("returntype/void").
request(TEXT_PLAIN_TYPE).
head();
assertEquals(
Response.Status.NO_CONTENT.getStatusCode(), response.getStatus());
}
@Test
public void testVoidResourceWithFilter() {
registerAddon(new TestAddon());
registerAddon(new TestVoidResource());
ServiceRegistration<?> serviceRegistration = registerExtension(
"Filter");
Response response = createDefaultTarget().path("name").request().get();
assertEquals("Hello name", response.readEntity(String.class));
assertEquals("true", response.getHeaders().getFirst("Filtered"));
response = createDefaultTarget().
path("returntype/void").
request(TEXT_PLAIN_TYPE).
head();
assertEquals(
Response.Status.NO_CONTENT.getStatusCode(), response.getStatus());
assertEquals("true", response.getHeaders().getFirst("Filtered"));
serviceRegistration.unregister();
response = createDefaultTarget().path("name").request().get();
assertEquals("Hello name", response.readEntity(String.class));
assertNull(response.getHeaders().getFirst("Filtered"));
response = createDefaultTarget().
path("returntype/void").
request(TEXT_PLAIN_TYPE).
head();
assertEquals(
Response.Status.NO_CONTENT.getStatusCode(), response.getStatus());
assertNull(response.getHeaders().getFirst("Filtered"));
}
private static Function<RuntimeDTO, FailedApplicationDTO[]>
FAILED_APPLICATIONS = r -> r.failedApplicationDTOs;
@Provider
private static class BusContextProvider implements ContextProvider<Bus> {
@Override
public Bus createContext(Message message) {
return message.getExchange().getBus();
}
}
}