Compare commits
25 Commits
v3.0.0-jer
...
v2.0.8-cxf
Author | SHA1 | Date | |
---|---|---|---|
8c9cbecd53 | |||
81198de0fb | |||
803d49e53e | |||
adad70d884 | |||
26c37ab737 | |||
4de7968e11 | |||
378563560b | |||
d23a4249f7 | |||
8628d2dce8 | |||
e4e393a855 | |||
c7ce4e7c57 | |||
458cdad213 | |||
8b03d251e8 | |||
a1acb3f9d9 | |||
00f25ff054 | |||
003afc208e | |||
85df5d3ea4 | |||
c9833bb4b1 | |||
23b9c4ccb2 | |||
6bb1561825 | |||
0ce2369452 | |||
ae82bc4ec7 | |||
cc8d9e9d13 | |||
93a2eaa34e | |||
1a1cbb1246 |
19
README.md
19
README.md
@@ -1,7 +1,7 @@
|
|||||||
|
|
||||||
# Common ReST Client Library
|
# Common ReST Client Library
|
||||||
|
|
||||||
This project provides a library for Spring and POJO-based REST client instantiation. It includes special classes for the Jersey JAXRS-based client frameworks.
|
This project provides a library for Spring and POJO-based REST client instantiation. It includes special classes with classifiers for two popular JAXRS-based client frameworks: Apache CXF and Jersey.
|
||||||
|
|
||||||
## Usage
|
## Usage
|
||||||
|
|
||||||
@@ -15,7 +15,8 @@ First, you will need to include the library in your project.
|
|||||||
<dependency>
|
<dependency>
|
||||||
<groupId>com.inteligr8</groupId>
|
<groupId>com.inteligr8</groupId>
|
||||||
<artifactId>common-rest-client</artifactId>
|
<artifactId>common-rest-client</artifactId>
|
||||||
<version>...-jersey</version>
|
<classifier>...</classifier>
|
||||||
|
<version>...</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
...
|
...
|
||||||
</dependencies>
|
</dependencies>
|
||||||
@@ -23,6 +24,8 @@ First, you will need to include the library in your project.
|
|||||||
</project>
|
</project>
|
||||||
```
|
```
|
||||||
|
|
||||||
|
Valid `classifier` values are `cxf` or `jersey`.
|
||||||
|
|
||||||
### Spring Framework
|
### Spring Framework
|
||||||
|
|
||||||
#### Single Client
|
#### Single Client
|
||||||
@@ -33,27 +36,29 @@ If you will only be declaring a single client in your Spring context, this is ea
|
|||||||
@Component
|
@Component
|
||||||
public class ... {
|
public class ... {
|
||||||
@Autowired
|
@Autowired
|
||||||
@Qualifier("client.jersey") // may be optional
|
@Qualifier("client.cxf") // may be optional
|
||||||
private Client client;
|
private Client client;
|
||||||
}
|
}
|
||||||
```
|
```
|
||||||
|
|
||||||
Next, you need to configure that client. You can do that by providing a single implementation of the `ClientConfiguration` (or `ClientJerseyConfiguration`) interface.
|
Next, you need to configure that client. You can do that by providing a single implementation of the `ClientConfiguration` (or `ClientCxfConfiguration`) interface.
|
||||||
|
|
||||||
```java
|
```java
|
||||||
@Configuration
|
@Configuration
|
||||||
public class ... implements ClientJerseyConfiguration {
|
public class ... implements ClientCxfConfiguration {
|
||||||
...
|
...
|
||||||
}
|
}
|
||||||
```
|
```
|
||||||
|
|
||||||
|
For Jersey implementations, just use `client.jersey` and `ClientJerseyConfiguration`. If you want to provide one of each, then follow the instructions for multiple clients below.
|
||||||
|
|
||||||
#### Multiple Clients
|
#### Multiple Clients
|
||||||
|
|
||||||
If you will or may have multiple clients in your Spring context, there is an extra step. You will still need to define a `ClientConfiguration` for each. On top of that, you will need to create specialized implementations of each client. That special implementation will reference the configuration directly. An example is below.
|
If you will or may have multiple clients in your Spring context, there is an extra step. You will still need to define a `ClientConfiguration` for each. On top of that, you will need to create specialized implementations of each client. That special implementation will reference the configuration directly. An example is below.
|
||||||
|
|
||||||
```java
|
```java
|
||||||
@Component("my.client")
|
@Component("my.client")
|
||||||
public class MyClient extends ClientJerseyImpl {
|
public class MyClient extends ClientCxfImpl {
|
||||||
@Autowired
|
@Autowired
|
||||||
public MyClient(MyClientConfiguration config) {
|
public MyClient(MyClientConfiguration config) {
|
||||||
super(config);
|
super(config);
|
||||||
@@ -82,6 +87,6 @@ You do not have to use the Spring framework to use these classes. You can insta
|
|||||||
```java
|
```java
|
||||||
MyClientConfiguration config = new MyClientConfiguration();
|
MyClientConfiguration config = new MyClientConfiguration();
|
||||||
...
|
...
|
||||||
ClientJerseyImpl client = new ClientJerseyImpl(config);
|
ClientCxfImpl client = new ClientCxfImpl(config);
|
||||||
MyJaxRsApi api = client.getApi(MyJaxRsApi.class);
|
MyJaxRsApi api = client.getApi(MyJaxRsApi.class);
|
||||||
```
|
```
|
||||||
|
68
pom.xml
68
pom.xml
@@ -6,11 +6,11 @@
|
|||||||
|
|
||||||
<groupId>com.inteligr8</groupId>
|
<groupId>com.inteligr8</groupId>
|
||||||
<artifactId>common-rest-client</artifactId>
|
<artifactId>common-rest-client</artifactId>
|
||||||
<version>3.0.0-jersey</version>
|
<version>2.0.8-cxf</version>
|
||||||
<packaging>jar</packaging>
|
<packaging>jar</packaging>
|
||||||
|
|
||||||
<name>ReST API Client for Java</name>
|
<name>ReST API Client for Java</name>
|
||||||
<description>A common library for building Jersey REST API clients</description>
|
<description>A common library for building CXF REST API clients</description>
|
||||||
<url>https://bitbucket.org/inteligr8/common-rest-client</url>
|
<url>https://bitbucket.org/inteligr8/common-rest-client</url>
|
||||||
|
|
||||||
<licenses>
|
<licenses>
|
||||||
@@ -40,21 +40,16 @@
|
|||||||
|
|
||||||
<properties>
|
<properties>
|
||||||
<project.build.sourceEncoding>utf-8</project.build.sourceEncoding>
|
<project.build.sourceEncoding>utf-8</project.build.sourceEncoding>
|
||||||
<maven.compiler.source>11</maven.compiler.source>
|
<maven.compiler.source>8</maven.compiler.source>
|
||||||
<maven.compiler.target>11</maven.compiler.target>
|
<maven.compiler.target>8</maven.compiler.target>
|
||||||
|
|
||||||
<junit.version>5.10.0</junit.version>
|
<junit.version>5.7.2</junit.version>
|
||||||
<spring.version>6.0.19</spring.version>
|
<spring.version>5.3.27</spring.version>
|
||||||
<jackson.version>2.17.2</jackson.version>
|
<jackson.version>2.15.1</jackson.version>
|
||||||
<jersey.version>3.1.8</jersey.version>
|
<cxf.version>3.5.6</cxf.version>
|
||||||
</properties>
|
</properties>
|
||||||
|
|
||||||
<dependencies>
|
<dependencies>
|
||||||
<dependency>
|
|
||||||
<groupId>jakarta.annotation</groupId>
|
|
||||||
<artifactId>jakarta.annotation-api</artifactId>
|
|
||||||
<version>2.1.1</version>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.springframework</groupId>
|
<groupId>org.springframework</groupId>
|
||||||
<artifactId>spring-context</artifactId>
|
<artifactId>spring-context</artifactId>
|
||||||
@@ -66,8 +61,8 @@
|
|||||||
<version>${jackson.version}</version>
|
<version>${jackson.version}</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>com.fasterxml.jackson.jakarta.rs</groupId>
|
<groupId>com.fasterxml.jackson.jaxrs</groupId>
|
||||||
<artifactId>jackson-jakarta-rs-json-provider</artifactId>
|
<artifactId>jackson-jaxrs-json-provider</artifactId>
|
||||||
<version>${jackson.version}</version>
|
<version>${jackson.version}</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
<dependency>
|
||||||
@@ -75,20 +70,15 @@
|
|||||||
<artifactId>jackson-datatype-jsr310</artifactId>
|
<artifactId>jackson-datatype-jsr310</artifactId>
|
||||||
<version>${jackson.version}</version>
|
<version>${jackson.version}</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
|
||||||
<groupId>org.apache.commons</groupId>
|
|
||||||
<artifactId>commons-lang3</artifactId>
|
|
||||||
<version>3.14.0</version>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.slf4j</groupId>
|
<groupId>org.slf4j</groupId>
|
||||||
<artifactId>slf4j-api</artifactId>
|
<artifactId>slf4j-api</artifactId>
|
||||||
<version>2.0.13</version>
|
<version>1.7.36</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>jakarta.ws.rs</groupId>
|
<groupId>jakarta.ws.rs</groupId>
|
||||||
<artifactId>jakarta.ws.rs-api</artifactId>
|
<artifactId>jakarta.ws.rs-api</artifactId>
|
||||||
<version>3.1.0</version>
|
<version>2.1.6</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.junit.jupiter</groupId>
|
<groupId>org.junit.jupiter</groupId>
|
||||||
@@ -109,33 +99,11 @@
|
|||||||
<scope>test</scope>
|
<scope>test</scope>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
<!-- Jersey libraries -->
|
<!-- Apache CXF libraries -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.glassfish.jersey.ext</groupId>
|
<groupId>org.apache.cxf</groupId>
|
||||||
<artifactId>jersey-proxy-client</artifactId>
|
<artifactId>cxf-rt-rs-client</artifactId>
|
||||||
<version>${jersey.version}</version>
|
<version>${cxf.version}</version>
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.glassfish.jersey.core</groupId>
|
|
||||||
<artifactId>jersey-client</artifactId>
|
|
||||||
<version>${jersey.version}</version>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.glassfish.jersey.media</groupId>
|
|
||||||
<artifactId>jersey-media-multipart</artifactId>
|
|
||||||
<version>${jersey.version}</version>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.glassfish.jersey.inject</groupId>
|
|
||||||
<artifactId>jersey-hk2</artifactId>
|
|
||||||
<version>${jersey.version}</version>
|
|
||||||
<scope>test</scope>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.glassfish.jersey.media</groupId>
|
|
||||||
<artifactId>jersey-media-json-jackson</artifactId>
|
|
||||||
<version>${jersey.version}</version>
|
|
||||||
<scope>test</scope>
|
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
@@ -151,7 +119,7 @@
|
|||||||
<goals><goal>add-source</goal></goals>
|
<goals><goal>add-source</goal></goals>
|
||||||
<configuration>
|
<configuration>
|
||||||
<sources>
|
<sources>
|
||||||
<source>src/main/jersey</source>
|
<source>src/main/cxf</source>
|
||||||
</sources>
|
</sources>
|
||||||
</configuration>
|
</configuration>
|
||||||
</execution>
|
</execution>
|
||||||
@@ -160,7 +128,7 @@
|
|||||||
<goals><goal>add-test-source</goal></goals>
|
<goals><goal>add-test-source</goal></goals>
|
||||||
<configuration>
|
<configuration>
|
||||||
<sources>
|
<sources>
|
||||||
<source>src/test/jersey</source>
|
<source>src/test/cxf</source>
|
||||||
</sources>
|
</sources>
|
||||||
</configuration>
|
</configuration>
|
||||||
</execution>
|
</execution>
|
||||||
|
@@ -14,22 +14,35 @@
|
|||||||
*/
|
*/
|
||||||
package com.inteligr8.rs;
|
package com.inteligr8.rs;
|
||||||
|
|
||||||
|
import org.apache.cxf.jaxrs.client.WebClient;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* This interface defines additional configurations specific to the Jersey
|
* This interface defines additional configurations specific to the Apache CXF
|
||||||
* JAX-RS library and its nuances.
|
* JAX-RS library and its nuances.
|
||||||
*
|
*
|
||||||
* @author brian@inteligr8.com
|
* @author brian@inteligr8.com
|
||||||
*/
|
*/
|
||||||
public interface ClientJerseyConfiguration extends ClientConfiguration {
|
public interface ClientCxfConfiguration extends ClientConfiguration {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Jersey is automatically strict in its adherence to the ReST API
|
* Apache CXF uses a global bus configuration where interceptors could
|
||||||
* specifications. It requires a body to PUT calls by default.
|
* wreck havoc on your implementation. This method allows you to
|
||||||
|
* explicitly by-pass the default bus.
|
||||||
*
|
*
|
||||||
* @return true to require body in PUT calls; false to make it optional
|
* See https://cxf.apache.org/docs/bus-configuration.html.
|
||||||
|
*
|
||||||
|
* @return true to use the default bus; false otherwise.
|
||||||
*/
|
*/
|
||||||
default boolean isPutBodyRequired() {
|
default boolean isDefaultBusEnabled() {
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* A Jackson provider, logging filter, and authentication filter are already registered.
|
||||||
|
*
|
||||||
|
* @param client A CXF client to configure.
|
||||||
|
*/
|
||||||
|
default void configureClient(WebClient client) {
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
185
src/main/cxf/com/inteligr8/rs/ClientCxfImpl.java
Normal file
185
src/main/cxf/com/inteligr8/rs/ClientCxfImpl.java
Normal file
@@ -0,0 +1,185 @@
|
|||||||
|
/*
|
||||||
|
* This program is free software: you can redistribute it and/or modify it
|
||||||
|
* under the terms of the GNU Lesser General Public License as published by
|
||||||
|
* the Free Software Foundation, either version 3 of the License, or (at your
|
||||||
|
* option) any later version.
|
||||||
|
*
|
||||||
|
* This program is distributed in the hope that it will be useful, but WITHOUT
|
||||||
|
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
|
||||||
|
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
|
||||||
|
* more details.
|
||||||
|
*
|
||||||
|
* You should have received a copy of the GNU General Public License along
|
||||||
|
* with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||||
|
*/
|
||||||
|
package com.inteligr8.rs;
|
||||||
|
|
||||||
|
import java.util.LinkedList;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
import javax.annotation.PostConstruct;
|
||||||
|
import javax.ws.rs.ext.RuntimeDelegate;
|
||||||
|
|
||||||
|
import org.apache.cxf.BusFactory;
|
||||||
|
import org.apache.cxf.jaxrs.client.JAXRSClientFactory;
|
||||||
|
import org.apache.cxf.jaxrs.client.WebClient;
|
||||||
|
import org.apache.cxf.jaxrs.impl.RuntimeDelegateImpl;
|
||||||
|
import org.apache.cxf.transport.http.HTTPConduit;
|
||||||
|
import org.apache.cxf.transports.http.configuration.HTTPClientPolicy;
|
||||||
|
import org.slf4j.Logger;
|
||||||
|
import org.slf4j.LoggerFactory;
|
||||||
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||||
|
import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
|
||||||
|
import com.fasterxml.jackson.jaxrs.json.JacksonJaxbJsonProvider;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* A class that provides pre-configured JAX-RS Client & WebTarget &
|
||||||
|
* CXF WebClient objects.
|
||||||
|
*
|
||||||
|
* @author brian@inteligr8.com
|
||||||
|
*/
|
||||||
|
@Component("client.cxf")
|
||||||
|
public class ClientCxfImpl extends Client {
|
||||||
|
|
||||||
|
private final Logger logger = LoggerFactory.getLogger(ClientCxfImpl.class);
|
||||||
|
|
||||||
|
private final Object sync = new Object();
|
||||||
|
private ClientCxfConfiguration config;
|
||||||
|
private WebClient client;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* This constructor is for Spring or POJO use.
|
||||||
|
* @param config The client configuration.
|
||||||
|
*/
|
||||||
|
@Autowired
|
||||||
|
public ClientCxfImpl(ClientCxfConfiguration config) {
|
||||||
|
this.config = config;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* This method registers the Apache CXF library as the default provider for
|
||||||
|
* the JAX-RS specification.
|
||||||
|
*/
|
||||||
|
@PostConstruct
|
||||||
|
public void register() {
|
||||||
|
if (RuntimeDelegate.getInstance() == null) {
|
||||||
|
this.logger.info("Setting JAX-RS runtime delegate to the CXF library");
|
||||||
|
RuntimeDelegate.setInstance(new RuntimeDelegateImpl());
|
||||||
|
} else if (RuntimeDelegate.getInstance() instanceof RuntimeDelegateImpl) {
|
||||||
|
this.logger.info("JAX-RS runtime delegate already the CXF library");
|
||||||
|
} else {
|
||||||
|
this.logger.warn("Setting JAX-RS runtime delegate to the CXF library; was: " + RuntimeDelegate.getInstance().getClass().getName());
|
||||||
|
RuntimeDelegate.setInstance(new RuntimeDelegateImpl());
|
||||||
|
}
|
||||||
|
|
||||||
|
if (this.logger.isInfoEnabled())
|
||||||
|
this.logger.info("API Base URL: " + this.getConfig().getBaseUrl());
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @return A CXF client (not JAX-RS).
|
||||||
|
*/
|
||||||
|
public WebClient getCxfClient() {
|
||||||
|
synchronized (this.sync) {
|
||||||
|
if (this.client == null)
|
||||||
|
this.client = this.buildCxfClient(null);
|
||||||
|
}
|
||||||
|
|
||||||
|
return this.client;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param authFilter A dynamic authorization filter.
|
||||||
|
* @return A pre-configured CXF client (no URL) with the specified authorization.
|
||||||
|
*/
|
||||||
|
public WebClient getCxfClient(AuthorizationFilter authFilter) {
|
||||||
|
if (authFilter == null) {
|
||||||
|
return this.getCxfClient();
|
||||||
|
} else {
|
||||||
|
return this.buildCxfClient(authFilter);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param authFilter A post-configuration authorization filter.
|
||||||
|
* @return A CXF client (not JAX-RS).
|
||||||
|
*/
|
||||||
|
public WebClient buildCxfClient(AuthorizationFilter authFilter) {
|
||||||
|
ObjectMapper om = new ObjectMapper();
|
||||||
|
om.registerModules(new JavaTimeModule());
|
||||||
|
this.getConfig().configureJacksonMapper(om);
|
||||||
|
|
||||||
|
JacksonJaxbJsonProvider jacksonProvider = new JacksonJaxbJsonProvider(om, JacksonJaxbJsonProvider.DEFAULT_ANNOTATIONS);
|
||||||
|
this.getConfig().configureJacksonProvider(jacksonProvider);
|
||||||
|
|
||||||
|
List<Object> providersAndFilters = new LinkedList<Object>();
|
||||||
|
providersAndFilters.add(jacksonProvider);
|
||||||
|
providersAndFilters.add(new CxfLoggingFilter());
|
||||||
|
providersAndFilters.add(new CxfMultipartProvider());
|
||||||
|
|
||||||
|
if (authFilter == null)
|
||||||
|
authFilter = this.getConfig().createAuthorizationFilter();
|
||||||
|
if (authFilter != null)
|
||||||
|
providersAndFilters.add(authFilter);
|
||||||
|
|
||||||
|
this.addProvidersAndFilters(providersAndFilters);
|
||||||
|
|
||||||
|
// we can't use JAXRSClientFactory with a JAXRS client (duh!)
|
||||||
|
// so we need to create a CXF client
|
||||||
|
WebClient client = WebClient.create(this.getConfig().getBaseUrl(), providersAndFilters);
|
||||||
|
|
||||||
|
if (this.getConfig().getConnectTimeoutInMillis() != null || this.getConfig().getResponseTimeoutInMillis() != null) {
|
||||||
|
HTTPConduit conduit = client.getConfiguration().getHttpConduit();
|
||||||
|
HTTPClientPolicy policy = conduit.getClient();
|
||||||
|
if (policy == null)
|
||||||
|
conduit.setClient(policy = new HTTPClientPolicy());
|
||||||
|
if (this.getConfig().getConnectTimeoutInMillis() != null)
|
||||||
|
policy.setConnectionTimeout(this.getConfig().getConnectTimeoutInMillis());
|
||||||
|
if (this.getConfig().getResponseTimeoutInMillis() != null)
|
||||||
|
policy.setReceiveTimeout(this.getConfig().getResponseTimeoutInMillis());
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!this.getConfig().isDefaultBusEnabled()) {
|
||||||
|
// Some applications (like ACS) add interceptors to the default bus
|
||||||
|
// those interceptors may treat all messages as SOAP messages (like ACS), resulting in ClassCastExceptions
|
||||||
|
// we need to ignore the default bus
|
||||||
|
org.apache.cxf.jaxrs.client.ClientConfiguration config = WebClient.getConfig(client);
|
||||||
|
config.setBus(BusFactory.newInstance().createBus());
|
||||||
|
}
|
||||||
|
|
||||||
|
this.config.configureClient(client);
|
||||||
|
|
||||||
|
return client;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param providersAndFilters A list of JAX-RS and CXF providers.
|
||||||
|
*/
|
||||||
|
public void addProvidersAndFilters(List<Object> providersAndFilters) {
|
||||||
|
// for extension purposes
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @return The client configuration.
|
||||||
|
*/
|
||||||
|
public ClientCxfConfiguration getConfig() {
|
||||||
|
return this.config;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* This method retrieves a JAX-RS implementation of the specified API with
|
||||||
|
* the specified authorization.
|
||||||
|
*
|
||||||
|
* @param authFilter A dynamic authorization filter.
|
||||||
|
* @param apiClass A JAX-RS annotation API class.
|
||||||
|
* @return An instance of the API class.
|
||||||
|
*/
|
||||||
|
@Override
|
||||||
|
public <T> T getApi(AuthorizationFilter authFilter, Class<T> apiClass) {
|
||||||
|
return JAXRSClientFactory.fromClient(this.getCxfClient(authFilter), apiClass);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
52
src/main/cxf/com/inteligr8/rs/CxfLoggingFilter.java
Normal file
52
src/main/cxf/com/inteligr8/rs/CxfLoggingFilter.java
Normal file
@@ -0,0 +1,52 @@
|
|||||||
|
/*
|
||||||
|
* This program is free software: you can redistribute it and/or modify it
|
||||||
|
* under the terms of the GNU Lesser General Public License as published by
|
||||||
|
* the Free Software Foundation, either version 3 of the License, or (at your
|
||||||
|
* option) any later version.
|
||||||
|
*
|
||||||
|
* This program is distributed in the hope that it will be useful, but WITHOUT
|
||||||
|
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
|
||||||
|
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
|
||||||
|
* more details.
|
||||||
|
*
|
||||||
|
* You should have received a copy of the GNU General Public License along
|
||||||
|
* with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||||
|
*/
|
||||||
|
package com.inteligr8.rs;
|
||||||
|
|
||||||
|
import java.io.IOException;
|
||||||
|
import java.util.LinkedList;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
import javax.ws.rs.client.ClientRequestContext;
|
||||||
|
import javax.ws.rs.core.MediaType;
|
||||||
|
|
||||||
|
import org.apache.cxf.jaxrs.ext.multipart.Attachment;
|
||||||
|
import org.apache.cxf.jaxrs.ext.multipart.MultipartBody;
|
||||||
|
import org.slf4j.Logger;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* This is a CXF specific handling of the logging of multipart requests, which
|
||||||
|
* would otherwise be ignored by the base LoggingFilter. It is meant to be
|
||||||
|
* used for debugging purposes. When used, it will write to 'jaxrs.request' and
|
||||||
|
* 'jaxrs.response' loggers at the 'trace' level.
|
||||||
|
*
|
||||||
|
* @author brian@inteligr8.com
|
||||||
|
*/
|
||||||
|
public class CxfLoggingFilter extends LoggingFilter {
|
||||||
|
|
||||||
|
@Override
|
||||||
|
protected void logUnhandledRequest(ClientRequestContext requestContext, Logger logger) throws IOException {
|
||||||
|
if (MediaType.MULTIPART_FORM_DATA_TYPE.equals(requestContext.getMediaType())) {
|
||||||
|
if (requestContext.getEntity() instanceof MultipartBody) {
|
||||||
|
List<String> attIds = new LinkedList<>();
|
||||||
|
for (Attachment att : ((MultipartBody)requestContext.getEntity()).getAllAttachments())
|
||||||
|
attIds.add(att.getContentId());
|
||||||
|
logger.trace("request: {} {}: {}", requestContext.getMethod(), requestContext.getUri(), attIds);
|
||||||
|
} else {
|
||||||
|
logger.trace("request: {} {}: failed to output form", requestContext.getMethod(), requestContext.getUri());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
49
src/main/cxf/com/inteligr8/rs/CxfMultipartProvider.java
Normal file
49
src/main/cxf/com/inteligr8/rs/CxfMultipartProvider.java
Normal file
@@ -0,0 +1,49 @@
|
|||||||
|
/*
|
||||||
|
* This program is free software: you can redistribute it and/or modify it
|
||||||
|
* under the terms of the GNU Lesser General Public License as published by
|
||||||
|
* the Free Software Foundation, either version 3 of the License, or (at your
|
||||||
|
* option) any later version.
|
||||||
|
*
|
||||||
|
* This program is distributed in the hope that it will be useful, but WITHOUT
|
||||||
|
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
|
||||||
|
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
|
||||||
|
* more details.
|
||||||
|
*
|
||||||
|
* You should have received a copy of the GNU General Public License along
|
||||||
|
* with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||||
|
*/
|
||||||
|
package com.inteligr8.rs;
|
||||||
|
|
||||||
|
import java.lang.annotation.Annotation;
|
||||||
|
import java.lang.reflect.Type;
|
||||||
|
|
||||||
|
import javax.ws.rs.Consumes;
|
||||||
|
import javax.ws.rs.Produces;
|
||||||
|
import javax.ws.rs.core.MediaType;
|
||||||
|
import javax.ws.rs.ext.Provider;
|
||||||
|
|
||||||
|
import org.apache.cxf.jaxrs.ext.multipart.MultipartBody;
|
||||||
|
import org.apache.cxf.jaxrs.provider.MultipartProvider;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* This implements a JAX-RS provider that adds support for the handling of CXF
|
||||||
|
* MultipartBody.
|
||||||
|
*
|
||||||
|
* @author brian@inteligr8.com
|
||||||
|
*/
|
||||||
|
@Consumes(MediaType.MULTIPART_FORM_DATA)
|
||||||
|
@Produces(MediaType.MULTIPART_FORM_DATA)
|
||||||
|
@Provider
|
||||||
|
public class CxfMultipartProvider extends MultipartProvider {
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean isReadable(Class<?> type, Type genericType, Annotation[] annotations, MediaType mediaType) {
|
||||||
|
return MultipartBody.class.isAssignableFrom(type) || super.isReadable(type, genericType, annotations, mediaType);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean isWriteable(Class<?> type, Type genericType, Annotation[] annotations, MediaType mediaType) {
|
||||||
|
return MultipartBody.class.isAssignableFrom(type) || super.isWriteable(type, genericType, annotations, mediaType);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
@@ -14,7 +14,7 @@
|
|||||||
*/
|
*/
|
||||||
package com.inteligr8.rs;
|
package com.inteligr8.rs;
|
||||||
|
|
||||||
import jakarta.ws.rs.client.ClientRequestFilter;
|
import javax.ws.rs.client.ClientRequestFilter;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* This is a marker that allows the developer to segregate, restrict, or limit
|
* This is a marker that allows the developer to segregate, restrict, or limit
|
||||||
|
@@ -17,10 +17,8 @@ package com.inteligr8.rs;
|
|||||||
import java.io.UnsupportedEncodingException;
|
import java.io.UnsupportedEncodingException;
|
||||||
import java.util.Base64;
|
import java.util.Base64;
|
||||||
|
|
||||||
import jakarta.ws.rs.client.ClientRequestContext;
|
import javax.ws.rs.client.ClientRequestContext;
|
||||||
import jakarta.ws.rs.core.HttpHeaders;
|
import javax.ws.rs.core.HttpHeaders;
|
||||||
|
|
||||||
import org.apache.commons.lang3.StringUtils;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* This class implements a simple 2-credential (username & password) based
|
* This class implements a simple 2-credential (username & password) based
|
||||||
@@ -38,8 +36,8 @@ public class BasicAuthorizationFilter implements AuthorizationFilter {
|
|||||||
* @param password A password or secret key.
|
* @param password A password or secret key.
|
||||||
*/
|
*/
|
||||||
public BasicAuthorizationFilter(String username, String password) {
|
public BasicAuthorizationFilter(String username, String password) {
|
||||||
this.username = StringUtils.trimToNull(username);
|
this.username = username;
|
||||||
this.password = StringUtils.trimToNull(password);
|
this.password = password;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@@ -14,8 +14,8 @@
|
|||||||
*/
|
*/
|
||||||
package com.inteligr8.rs;
|
package com.inteligr8.rs;
|
||||||
|
|
||||||
import jakarta.ws.rs.client.ClientRequestContext;
|
import javax.ws.rs.client.ClientRequestContext;
|
||||||
import jakarta.ws.rs.core.HttpHeaders;
|
import javax.ws.rs.core.HttpHeaders;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* This class implements a simple long living or proxied token-based
|
* This class implements a simple long living or proxied token-based
|
||||||
|
@@ -16,14 +16,14 @@ package com.inteligr8.rs;
|
|||||||
|
|
||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
import jakarta.ws.rs.client.ClientBuilder;
|
import javax.ws.rs.client.ClientBuilder;
|
||||||
import jakarta.ws.rs.client.WebTarget;
|
import javax.ws.rs.client.WebTarget;
|
||||||
|
|
||||||
import com.fasterxml.jackson.databind.DeserializationFeature;
|
import com.fasterxml.jackson.databind.DeserializationFeature;
|
||||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||||
import com.fasterxml.jackson.databind.SerializationFeature;
|
import com.fasterxml.jackson.databind.SerializationFeature;
|
||||||
import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
|
import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
|
||||||
import com.fasterxml.jackson.jakarta.rs.json.JacksonJsonProvider;
|
import com.fasterxml.jackson.jaxrs.json.JacksonJaxbJsonProvider;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* A class that provides pre-configured JAX-RS Client & WebTarget objects.
|
* A class that provides pre-configured JAX-RS Client & WebTarget objects.
|
||||||
@@ -33,7 +33,7 @@ import com.fasterxml.jackson.jakarta.rs.json.JacksonJsonProvider;
|
|||||||
public abstract class Client {
|
public abstract class Client {
|
||||||
|
|
||||||
private final Object sync = new Object();
|
private final Object sync = new Object();
|
||||||
private jakarta.ws.rs.client.Client client;
|
private javax.ws.rs.client.Client client;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @return The client configuration.
|
* @return The client configuration.
|
||||||
@@ -43,7 +43,7 @@ public abstract class Client {
|
|||||||
/**
|
/**
|
||||||
* @return A pre-configured JAX-RS client (no URL) with configured authorization.
|
* @return A pre-configured JAX-RS client (no URL) with configured authorization.
|
||||||
*/
|
*/
|
||||||
public final jakarta.ws.rs.client.Client getClient() {
|
public final javax.ws.rs.client.Client getClient() {
|
||||||
synchronized (this.sync) {
|
synchronized (this.sync) {
|
||||||
if (this.client == null)
|
if (this.client == null)
|
||||||
this.client = this.buildClient((AuthorizationFilter)null);
|
this.client = this.buildClient((AuthorizationFilter)null);
|
||||||
@@ -56,7 +56,7 @@ public abstract class Client {
|
|||||||
* @param authFilter A dynamic authorization filter.
|
* @param authFilter A dynamic authorization filter.
|
||||||
* @return A pre-configured JAX-RS client (no URL) with the specified authorization.
|
* @return A pre-configured JAX-RS client (no URL) with the specified authorization.
|
||||||
*/
|
*/
|
||||||
public jakarta.ws.rs.client.Client getClient(AuthorizationFilter authFilter) {
|
public javax.ws.rs.client.Client getClient(AuthorizationFilter authFilter) {
|
||||||
if (authFilter == null) {
|
if (authFilter == null) {
|
||||||
return this.getClient();
|
return this.getClient();
|
||||||
} else {
|
} else {
|
||||||
@@ -68,12 +68,12 @@ public abstract class Client {
|
|||||||
* @param authFilter A dynamic authorization filter.
|
* @param authFilter A dynamic authorization filter.
|
||||||
* @return A pre-configured JAX-RS client (no URL) with the specified authorization.
|
* @return A pre-configured JAX-RS client (no URL) with the specified authorization.
|
||||||
*/
|
*/
|
||||||
public final jakarta.ws.rs.client.Client buildClient(AuthorizationFilter authFilter) {
|
public final javax.ws.rs.client.Client buildClient(AuthorizationFilter authFilter) {
|
||||||
ObjectMapper om = new ObjectMapper();
|
ObjectMapper om = new ObjectMapper();
|
||||||
om.registerModules(new JavaTimeModule());
|
om.registerModules(new JavaTimeModule());
|
||||||
this.getConfig().configureJacksonMapper(om);
|
this.getConfig().configureJacksonMapper(om);
|
||||||
|
|
||||||
JacksonJsonProvider provider = new JacksonJsonProvider(om, JacksonJsonProvider.BASIC_ANNOTATIONS);
|
JacksonJaxbJsonProvider provider = new JacksonJaxbJsonProvider(om, JacksonJaxbJsonProvider.DEFAULT_ANNOTATIONS);
|
||||||
this.getConfig().configureJacksonProvider(provider);
|
this.getConfig().configureJacksonProvider(provider);
|
||||||
|
|
||||||
if (this.getConfig().isWrapRootValueEnabled())
|
if (this.getConfig().isWrapRootValueEnabled())
|
||||||
|
@@ -16,10 +16,10 @@ package com.inteligr8.rs;
|
|||||||
|
|
||||||
import java.net.URI;
|
import java.net.URI;
|
||||||
|
|
||||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
import javax.ws.rs.client.ClientBuilder;
|
||||||
import com.fasterxml.jackson.jakarta.rs.json.JacksonJsonProvider;
|
|
||||||
|
|
||||||
import jakarta.ws.rs.client.ClientBuilder;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||||
|
import com.fasterxml.jackson.jaxrs.json.JacksonJaxbJsonProvider;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* This interface defines the configurable parameters of the clients; primarily
|
* This interface defines the configurable parameters of the clients; primarily
|
||||||
@@ -151,9 +151,9 @@ public interface ClientConfiguration {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param provider A Jackson Jakarta RS provider to configure.
|
* @param provider A Jackson JAX-RS provider to configure.
|
||||||
*/
|
*/
|
||||||
default void configureJacksonProvider(JacksonJsonProvider provider) {
|
default void configureJacksonProvider(JacksonJaxbJsonProvider provider) {
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@@ -14,9 +14,7 @@
|
|||||||
*/
|
*/
|
||||||
package com.inteligr8.rs;
|
package com.inteligr8.rs;
|
||||||
|
|
||||||
import jakarta.ws.rs.client.ClientRequestContext;
|
import javax.ws.rs.client.ClientRequestContext;
|
||||||
|
|
||||||
import org.apache.commons.lang3.StringUtils;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* This class is the base for implementations of client authorization similar
|
* This class is the base for implementations of client authorization similar
|
||||||
@@ -47,8 +45,8 @@ public class ClientEnforcementAuthorizationFilter implements AuthorizationFilter
|
|||||||
* @param clientSecret A secret corresponding to the client ID.
|
* @param clientSecret A secret corresponding to the client ID.
|
||||||
*/
|
*/
|
||||||
public ClientEnforcementAuthorizationFilter(String clientId, String clientSecret) {
|
public ClientEnforcementAuthorizationFilter(String clientId, String clientSecret) {
|
||||||
this.clientId = StringUtils.trimToNull(clientId);
|
this.clientId = clientId;
|
||||||
this.clientSecret = StringUtils.trimToNull(clientSecret);
|
this.clientSecret = clientSecret;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@@ -14,11 +14,13 @@
|
|||||||
*/
|
*/
|
||||||
package com.inteligr8.rs;
|
package com.inteligr8.rs;
|
||||||
|
|
||||||
import jakarta.annotation.PostConstruct;
|
import javax.annotation.PostConstruct;
|
||||||
import jakarta.ws.rs.client.ClientBuilder;
|
import javax.ws.rs.client.ClientBuilder;
|
||||||
|
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* A class that provides pre-configured JAX-RS Client & WebTarget objects
|
* A class that provides pre-configured JAX-RS Client & WebTarget objects
|
||||||
@@ -26,6 +28,7 @@ import org.slf4j.LoggerFactory;
|
|||||||
*
|
*
|
||||||
* @author brian@inteligr8.com
|
* @author brian@inteligr8.com
|
||||||
*/
|
*/
|
||||||
|
@Component("client.jaxrs")
|
||||||
public class ClientImpl extends Client {
|
public class ClientImpl extends Client {
|
||||||
|
|
||||||
private final Logger logger = LoggerFactory.getLogger(ClientImpl.class);
|
private final Logger logger = LoggerFactory.getLogger(ClientImpl.class);
|
||||||
@@ -36,6 +39,7 @@ public class ClientImpl extends Client {
|
|||||||
* This constructor is for Spring or POJO use.
|
* This constructor is for Spring or POJO use.
|
||||||
* @param config The client configuration.
|
* @param config The client configuration.
|
||||||
*/
|
*/
|
||||||
|
@Autowired
|
||||||
public ClientImpl(ClientConfiguration config) {
|
public ClientImpl(ClientConfiguration config) {
|
||||||
this.config = config;
|
this.config = config;
|
||||||
}
|
}
|
||||||
|
@@ -14,8 +14,8 @@
|
|||||||
*/
|
*/
|
||||||
package com.inteligr8.rs;
|
package com.inteligr8.rs;
|
||||||
|
|
||||||
import jakarta.ws.rs.client.ClientRequestContext;
|
import javax.ws.rs.client.ClientRequestContext;
|
||||||
import jakarta.ws.rs.core.HttpHeaders;
|
import javax.ws.rs.core.HttpHeaders;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* This class implements a proxied or forwarded authorization header based
|
* This class implements a proxied or forwarded authorization header based
|
||||||
|
@@ -16,12 +16,12 @@ package com.inteligr8.rs;
|
|||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
import jakarta.ws.rs.client.ClientRequestContext;
|
import javax.ws.rs.client.ClientRequestContext;
|
||||||
import jakarta.ws.rs.client.ClientRequestFilter;
|
import javax.ws.rs.client.ClientRequestFilter;
|
||||||
import jakarta.ws.rs.client.ClientResponseContext;
|
import javax.ws.rs.client.ClientResponseContext;
|
||||||
import jakarta.ws.rs.client.ClientResponseFilter;
|
import javax.ws.rs.client.ClientResponseFilter;
|
||||||
import jakarta.ws.rs.core.Form;
|
import javax.ws.rs.core.Form;
|
||||||
import jakarta.ws.rs.core.MediaType;
|
import javax.ws.rs.core.MediaType;
|
||||||
|
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
|
@@ -16,11 +16,7 @@ package com.inteligr8.rs;
|
|||||||
|
|
||||||
import java.net.URI;
|
import java.net.URI;
|
||||||
|
|
||||||
import jakarta.ws.rs.core.Form;
|
import javax.ws.rs.core.Form;
|
||||||
|
|
||||||
import org.apache.commons.lang3.StringUtils;
|
|
||||||
import org.slf4j.Logger;
|
|
||||||
import org.slf4j.LoggerFactory;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* This class implements the OAuth Authorization Code flow as an authorization
|
* This class implements the OAuth Authorization Code flow as an authorization
|
||||||
@@ -30,8 +26,6 @@ import org.slf4j.LoggerFactory;
|
|||||||
*/
|
*/
|
||||||
public class OAuthAuthorizationCodeAuthorizationFilter extends OAuthAuthorizationFilter {
|
public class OAuthAuthorizationCodeAuthorizationFilter extends OAuthAuthorizationFilter {
|
||||||
|
|
||||||
private final Logger logger = LoggerFactory.getLogger(this.getClass());
|
|
||||||
|
|
||||||
private final String code;
|
private final String code;
|
||||||
private final URI redirectUri;
|
private final URI redirectUri;
|
||||||
|
|
||||||
@@ -74,13 +68,12 @@ public class OAuthAuthorizationCodeAuthorizationFilter extends OAuthAuthorizatio
|
|||||||
public OAuthAuthorizationCodeAuthorizationFilter(String tokenUrl, String clientId, String clientSecret, String code, URI redirectUri) {
|
public OAuthAuthorizationCodeAuthorizationFilter(String tokenUrl, String clientId, String clientSecret, String code, URI redirectUri) {
|
||||||
super(tokenUrl, clientId, clientSecret);
|
super(tokenUrl, clientId, clientSecret);
|
||||||
|
|
||||||
this.code = StringUtils.trimToNull(code);
|
this.code = code;
|
||||||
this.redirectUri = redirectUri;
|
this.redirectUri = redirectUri;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected Form createForm() {
|
protected Form createForm() {
|
||||||
this.logger.debug("Using OAuth grant_type 'authorization_code'");
|
|
||||||
Form form = new Form().param("grant_type", "authorization_code");
|
Form form = new Form().param("grant_type", "authorization_code");
|
||||||
if (this.redirectUri != null)
|
if (this.redirectUri != null)
|
||||||
form.param("redirect_uri", this.redirectUri.toString());
|
form.param("redirect_uri", this.redirectUri.toString());
|
||||||
|
@@ -16,22 +16,21 @@ package com.inteligr8.rs;
|
|||||||
|
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
import jakarta.ws.rs.WebApplicationException;
|
import javax.ws.rs.WebApplicationException;
|
||||||
import jakarta.ws.rs.client.Client;
|
import javax.ws.rs.client.Client;
|
||||||
import jakarta.ws.rs.client.ClientBuilder;
|
import javax.ws.rs.client.ClientBuilder;
|
||||||
import jakarta.ws.rs.client.ClientRequestContext;
|
import javax.ws.rs.client.ClientRequestContext;
|
||||||
import jakarta.ws.rs.client.Entity;
|
import javax.ws.rs.client.Entity;
|
||||||
import jakarta.ws.rs.client.WebTarget;
|
import javax.ws.rs.client.WebTarget;
|
||||||
import jakarta.ws.rs.core.Form;
|
import javax.ws.rs.core.Form;
|
||||||
import jakarta.ws.rs.core.HttpHeaders;
|
import javax.ws.rs.core.HttpHeaders;
|
||||||
import jakarta.ws.rs.core.Response;
|
import javax.ws.rs.core.Response;
|
||||||
import jakarta.ws.rs.core.Response.Status.Family;
|
import javax.ws.rs.core.Response.Status.Family;
|
||||||
|
|
||||||
import org.apache.commons.lang3.StringUtils;
|
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
|
|
||||||
import com.fasterxml.jackson.jakarta.rs.json.JacksonJsonProvider;
|
import com.fasterxml.jackson.jaxrs.json.JacksonJaxbJsonProvider;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* This class is the base for implementations of OAuth authorization flows.
|
* This class is the base for implementations of OAuth authorization flows.
|
||||||
@@ -89,9 +88,9 @@ public abstract class OAuthAuthorizationFilter implements AuthorizationFilter {
|
|||||||
*/
|
*/
|
||||||
public OAuthAuthorizationFilter(String tokenUrl, String clientId, String clientSecret, String scope) {
|
public OAuthAuthorizationFilter(String tokenUrl, String clientId, String clientSecret, String scope) {
|
||||||
this.tokenUrl = tokenUrl;
|
this.tokenUrl = tokenUrl;
|
||||||
this.clientId = StringUtils.trimToNull(clientId);
|
this.clientId = clientId;
|
||||||
this.clientSecret = StringUtils.trimToNull(clientSecret);
|
this.clientSecret = clientSecret;
|
||||||
this.scope = StringUtils.trimToNull(scope);
|
this.scope = scope;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -159,7 +158,7 @@ public abstract class OAuthAuthorizationFilter implements AuthorizationFilter {
|
|||||||
Entity<Form> entity = Entity.form(form);
|
Entity<Form> entity = Entity.form(form);
|
||||||
|
|
||||||
Client client = ClientBuilder.newBuilder()
|
Client client = ClientBuilder.newBuilder()
|
||||||
.register(new JacksonJsonProvider())
|
.register(new JacksonJaxbJsonProvider())
|
||||||
.build();
|
.build();
|
||||||
WebTarget target = client.target(this.tokenUrl);
|
WebTarget target = client.target(this.tokenUrl);
|
||||||
|
|
||||||
|
@@ -14,10 +14,7 @@
|
|||||||
*/
|
*/
|
||||||
package com.inteligr8.rs;
|
package com.inteligr8.rs;
|
||||||
|
|
||||||
import jakarta.ws.rs.core.Form;
|
import javax.ws.rs.core.Form;
|
||||||
|
|
||||||
import org.slf4j.Logger;
|
|
||||||
import org.slf4j.LoggerFactory;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* This class implements the OAuth Client Credential flow as an authorization
|
* This class implements the OAuth Client Credential flow as an authorization
|
||||||
@@ -27,8 +24,6 @@ import org.slf4j.LoggerFactory;
|
|||||||
*/
|
*/
|
||||||
public class OAuthClientCredentialAuthorizationFilter extends OAuthAuthorizationFilter {
|
public class OAuthClientCredentialAuthorizationFilter extends OAuthAuthorizationFilter {
|
||||||
|
|
||||||
private final Logger logger = LoggerFactory.getLogger(this.getClass());
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param tokenUrl The URL to the OAuth IdP token service.
|
* @param tokenUrl The URL to the OAuth IdP token service.
|
||||||
* @param clientId The ID provided by the OAuth IdP administrator.
|
* @param clientId The ID provided by the OAuth IdP administrator.
|
||||||
@@ -40,7 +35,6 @@ public class OAuthClientCredentialAuthorizationFilter extends OAuthAuthorization
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected Form createForm() {
|
protected Form createForm() {
|
||||||
this.logger.debug("Using OAuth grant_type 'client_credentials'");
|
|
||||||
return new Form().param("grant_type", "client_credentials");
|
return new Form().param("grant_type", "client_credentials");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -14,11 +14,7 @@
|
|||||||
*/
|
*/
|
||||||
package com.inteligr8.rs;
|
package com.inteligr8.rs;
|
||||||
|
|
||||||
import jakarta.ws.rs.core.Form;
|
import javax.ws.rs.core.Form;
|
||||||
|
|
||||||
import org.apache.commons.lang3.StringUtils;
|
|
||||||
import org.slf4j.Logger;
|
|
||||||
import org.slf4j.LoggerFactory;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* This class implements the OAuth Password Grant flow as an authorization
|
* This class implements the OAuth Password Grant flow as an authorization
|
||||||
@@ -28,8 +24,6 @@ import org.slf4j.LoggerFactory;
|
|||||||
*/
|
*/
|
||||||
public class OAuthPasswordGrantAuthorizationFilter extends OAuthAuthorizationFilter {
|
public class OAuthPasswordGrantAuthorizationFilter extends OAuthAuthorizationFilter {
|
||||||
|
|
||||||
private final Logger logger = LoggerFactory.getLogger(this.getClass());
|
|
||||||
|
|
||||||
private final String username;
|
private final String username;
|
||||||
private final String password;
|
private final String password;
|
||||||
|
|
||||||
@@ -52,13 +46,12 @@ public class OAuthPasswordGrantAuthorizationFilter extends OAuthAuthorizationFil
|
|||||||
*/
|
*/
|
||||||
public OAuthPasswordGrantAuthorizationFilter(String tokenUrl, String clientId, String clientSecret, String username, String password) {
|
public OAuthPasswordGrantAuthorizationFilter(String tokenUrl, String clientId, String clientSecret, String username, String password) {
|
||||||
super(tokenUrl, clientId, clientSecret);
|
super(tokenUrl, clientId, clientSecret);
|
||||||
this.username = StringUtils.trimToNull(username);
|
this.username = username;
|
||||||
this.password = StringUtils.trimToNull(password);
|
this.password = password;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected Form createForm() {
|
protected Form createForm() {
|
||||||
this.logger.debug("Using OAuth grant_type 'password': {}", this.username);
|
|
||||||
return new Form().param("grant_type", "password")
|
return new Form().param("grant_type", "password")
|
||||||
.param("username", this.username);
|
.param("username", this.username);
|
||||||
}
|
}
|
||||||
|
@@ -1,101 +0,0 @@
|
|||||||
/*
|
|
||||||
* This program is free software: you can redistribute it and/or modify it
|
|
||||||
* under the terms of the GNU Lesser General Public License as published by
|
|
||||||
* the Free Software Foundation, either version 3 of the License, or (at your
|
|
||||||
* option) any later version.
|
|
||||||
*
|
|
||||||
* This program is distributed in the hope that it will be useful, but WITHOUT
|
|
||||||
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
|
|
||||||
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
|
|
||||||
* more details.
|
|
||||||
*
|
|
||||||
* You should have received a copy of the GNU General Public License along
|
|
||||||
* with this program. If not, see <https://www.gnu.org/licenses/>.
|
|
||||||
*/
|
|
||||||
package com.inteligr8.rs;
|
|
||||||
|
|
||||||
import jakarta.annotation.PostConstruct;
|
|
||||||
import jakarta.ws.rs.client.ClientBuilder;
|
|
||||||
import jakarta.ws.rs.ext.RuntimeDelegate;
|
|
||||||
|
|
||||||
import org.glassfish.jersey.client.ClientProperties;
|
|
||||||
import org.glassfish.jersey.client.proxy.WebResourceFactory;
|
|
||||||
import org.glassfish.jersey.internal.RuntimeDelegateImpl;
|
|
||||||
import org.glassfish.jersey.media.multipart.MultiPartFeature;
|
|
||||||
import org.slf4j.Logger;
|
|
||||||
import org.slf4j.LoggerFactory;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* A class that provides pre-configured JAX-RS Client & WebTarget objects
|
|
||||||
* for Jersey.
|
|
||||||
*
|
|
||||||
* @author brian@inteligr8.com
|
|
||||||
*/
|
|
||||||
public class ClientJerseyImpl extends Client {
|
|
||||||
|
|
||||||
private final Logger logger = LoggerFactory.getLogger(ClientJerseyImpl.class);
|
|
||||||
|
|
||||||
private ClientJerseyConfiguration config;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* This constructor is for Spring or POJO use.
|
|
||||||
* @param config The client configuration.
|
|
||||||
*/
|
|
||||||
public ClientJerseyImpl(ClientJerseyConfiguration config) {
|
|
||||||
this.config = config;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* This method registers the Jersey library as the default provider for the
|
|
||||||
* JAX-RS specification.
|
|
||||||
*/
|
|
||||||
@PostConstruct
|
|
||||||
public void register() {
|
|
||||||
if (RuntimeDelegate.getInstance() == null) {
|
|
||||||
this.logger.info("Setting JAX-RS runtime delegate to the Jersey library");
|
|
||||||
RuntimeDelegate.setInstance(new RuntimeDelegateImpl());
|
|
||||||
} else if (RuntimeDelegate.getInstance() instanceof RuntimeDelegateImpl) {
|
|
||||||
this.logger.info("JAX-RS runtime delegate already the Jersey library");
|
|
||||||
} else {
|
|
||||||
this.logger.warn("Setting JAX-RS runtime delegate to the Jersey library; was: " + RuntimeDelegate.getInstance().getClass().getName());
|
|
||||||
RuntimeDelegate.setInstance(new RuntimeDelegateImpl());
|
|
||||||
}
|
|
||||||
|
|
||||||
if (this.logger.isInfoEnabled())
|
|
||||||
this.logger.info("API Base URL: " + this.getConfig().getBaseUrl());
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @param clientBuilder A client builder.
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public void buildClient(ClientBuilder clientBuilder) {
|
|
||||||
clientBuilder.register(MultiPartFeature.class);
|
|
||||||
|
|
||||||
if (!this.getConfig().isPutBodyRequired()) {
|
|
||||||
// allow PUT operations without body data
|
|
||||||
clientBuilder.property(ClientProperties.SUPPRESS_HTTP_COMPLIANCE_VALIDATION, true);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @return The client configuration.
|
|
||||||
*/
|
|
||||||
public ClientJerseyConfiguration getConfig() {
|
|
||||||
return this.config;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* This method retrieves a JAX-RS implementation of the specified API with
|
|
||||||
* the specified authorization.
|
|
||||||
*
|
|
||||||
* @param authFilter A dynamic authorization filter.
|
|
||||||
* @param apiClass A JAX-RS annotation API class.
|
|
||||||
* @return An instance of the API class.
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public <T> T getApi(AuthorizationFilter authFilter, Class<T> apiClass) {
|
|
||||||
return WebResourceFactory.newResource(apiClass, this.getTarget(authFilter));
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
Reference in New Issue
Block a user