Compare commits

..

No commits in common. "develop" and "develop-v2.x" have entirely different histories.

15 changed files with 108 additions and 245 deletions

34
pom.xml
View File

@ -6,7 +6,7 @@
<groupId>com.inteligr8</groupId> <groupId>com.inteligr8</groupId>
<artifactId>common-rest-client</artifactId> <artifactId>common-rest-client</artifactId>
<version>3.0-SNAPSHOT</version> <version>2.0-SNAPSHOT</version>
<packaging>jar</packaging> <packaging>jar</packaging>
<name>ReST API Client for Java</name> <name>ReST API Client for Java</name>
@ -40,19 +40,19 @@
<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.12.0</junit.version> <junit.version>5.7.2</junit.version>
<spring.version>6.0.23</spring.version> <spring.version>5.3.27</spring.version>
<jackson.version>2.17.3</jackson.version> <jackson.version>2.15.1</jackson.version>
</properties> </properties>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>jakarta.annotation</groupId> <groupId>javax.annotation</groupId>
<artifactId>jakarta.annotation-api</artifactId> <artifactId>javax.annotation-api</artifactId>
<version>2.1.1</version> <version>1.3.2</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.springframework</groupId> <groupId>org.springframework</groupId>
@ -65,8 +65,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>
@ -77,17 +77,17 @@
<dependency> <dependency>
<groupId>org.apache.commons</groupId> <groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId> <artifactId>commons-lang3</artifactId>
<version>3.17.0</version> <version>3.14.0</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.slf4j</groupId> <groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId> <artifactId>slf4j-api</artifactId>
<version>2.0.17</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>
@ -113,7 +113,7 @@
<plugins> <plugins>
<plugin> <plugin>
<artifactId>maven-surefire-plugin</artifactId> <artifactId>maven-surefire-plugin</artifactId>
<version>3.4.0</version> <version>3.1.0</version>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>org.junit.jupiter</groupId> <groupId>org.junit.jupiter</groupId>
@ -124,7 +124,7 @@
</plugin> </plugin>
<plugin> <plugin>
<artifactId>maven-failsafe-plugin</artifactId> <artifactId>maven-failsafe-plugin</artifactId>
<version>3.4.0</version> <version>3.1.0</version>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>org.junit.jupiter</groupId> <groupId>org.junit.jupiter</groupId>
@ -180,7 +180,7 @@
<plugin> <plugin>
<groupId>org.sonatype.plugins</groupId> <groupId>org.sonatype.plugins</groupId>
<artifactId>nexus-staging-maven-plugin</artifactId> <artifactId>nexus-staging-maven-plugin</artifactId>
<version>1.6.14</version> <version>1.6.13</version>
<configuration> <configuration>
<serverId>ossrh</serverId> <serverId>ossrh</serverId>
<nexusUrl>https://s01.oss.sonatype.org/</nexusUrl> <nexusUrl>https://s01.oss.sonatype.org/</nexusUrl>

View File

@ -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

View File

@ -17,8 +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; import org.apache.commons.lang3.StringUtils;
@ -34,8 +34,6 @@ public class BasicAuthorizationFilter implements AuthorizationFilter {
private final String password; private final String password;
/** /**
* This constructor instantiates the filter with required fields.
*
* @param username A username or access key. * @param username A username or access key.
* @param password A password or secret key. * @param password A password or secret key.
*/ */

View File

@ -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
@ -32,8 +32,6 @@ public class BearerTokenAuthorizationFilter implements AuthorizationFilter {
private final String token; private final String token;
/** /**
* This constructor instantiates the filter with required fields.
*
* @param token A 'Bearer' token. * @param token A 'Bearer' token.
*/ */
public BearerTokenAuthorizationFilter(String token) { public BearerTokenAuthorizationFilter(String token) {

View File

@ -16,39 +16,34 @@ 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 Jakarta RS Client &amp; WebTarget objects. * A class that provides pre-configured JAX-RS Client &amp; WebTarget objects.
* *
* @author brian@inteligr8.com * @author brian@inteligr8.com
*/ */
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;
/** /**
* This method retrieves the configuration for the client.
*
* @return The client configuration. * @return The client configuration.
*/ */
public abstract ClientConfiguration getConfig(); public abstract ClientConfiguration getConfig();
/** /**
* This method retrieves an anonymous cached instance of the underlying * @return A pre-configured JAX-RS client (no URL) with configured authorization.
* Jakarta RS client.
*
* @return A pre-configured Jakarta 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);
@ -58,13 +53,10 @@ public abstract class Client {
} }
/** /**
* This method retrieves either an anonymous cached instance or builds an
* authorized instance of the underlying Jakarta RS client.
*
* @param authFilter A dynamic authorization filter. * @param authFilter A dynamic authorization filter.
* @return A pre-configured Jakarta 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 {
@ -73,17 +65,15 @@ public abstract class Client {
} }
/** /**
* This method builds a new Jakarta RS client with optional authorization.
*
* @param authFilter A dynamic authorization filter. * @param authFilter A dynamic authorization filter.
* @return A pre-configured Jakarta 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())
@ -111,19 +101,14 @@ public abstract class Client {
} }
/** /**
* This method allows sub-classes to extend the Jakarta RS client builder * @param clientBuilder A client builder
* before the client is built.
*
* @param clientBuilder A Jakarta RS client builder.
*/ */
public void buildClient(ClientBuilder clientBuilder) { public void buildClient(ClientBuilder clientBuilder) {
// for extension purposes // for extension purposes
} }
/** /**
* This method builds an anonymous Jakarta RS target. * @return A pre-configured JAX-RS target (client w/ base URL) with configured authorization.
*
* @return A pre-configured Jakarta RS target (client w/ base URL) with configured authorization.
*/ */
public final WebTarget getTarget() { public final WebTarget getTarget() {
return this.getClient() return this.getClient()
@ -131,10 +116,8 @@ public abstract class Client {
} }
/** /**
* This method builds an authorized Jakarta RS target.
*
* @param authFilter A dynamic authorization filter. * @param authFilter A dynamic authorization filter.
* @return A pre-configured Jakarta RS target (client w/ base URL) with the specified authorization. * @return A pre-configured JAX-RS target (client w/ base URL) with the specified authorization.
*/ */
public WebTarget getTarget(AuthorizationFilter authFilter) { public WebTarget getTarget(AuthorizationFilter authFilter) {
if (authFilter == null) { if (authFilter == null) {
@ -146,10 +129,10 @@ public abstract class Client {
} }
/** /**
* This method retrieves a Jakarta RS implementation of the specified API. * This method retrieves a JAX-RS implementation of the specified API.
* *
* @param <T> A Jakarta RS annotated API class. * @param <T> A JAX-RS annotated API class.
* @param apiClass A Jakarta RS annotated API class. * @param apiClass A JAX-RS annotated API class.
* @return An instance of the API class. * @return An instance of the API class.
*/ */
public final <T> T getApi(Class<T> apiClass) { public final <T> T getApi(Class<T> apiClass) {
@ -157,12 +140,12 @@ public abstract class Client {
} }
/** /**
* This method retrieves a Jakarta RS implementation of the specified API with * This method retrieves a JAX-RS implementation of the specified API with
* the specified authorization. * the specified authorization.
* *
* @param <T> A Jakarta RS annotated API class. * @param <T> A JAX-RS annotated API class.
* @param authFilter A dynamic authorization filter. * @param authFilter A dynamic authorization filter.
* @param apiClass A Jakarta RS annotated API class. * @param apiClass A JAX-RS annotated API class.
* @return An instance of the API class. * @return An instance of the API class.
*/ */
public abstract <T> T getApi(AuthorizationFilter authFilter, Class<T> apiClass); public abstract <T> T getApi(AuthorizationFilter authFilter, Class<T> apiClass);

View File

@ -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
@ -30,127 +30,89 @@ import jakarta.ws.rs.client.ClientBuilder;
public interface ClientConfiguration { public interface ClientConfiguration {
/** /**
* This method retrieves the base/root URL of the client service. * @return The base or root URL of the service.
*
* @return The URL.
*/ */
String getBaseUrl(); String getBaseUrl();
/** /**
* This method retrieves the username to use in HTTP BASIC authentication/authorization. * @return The username for BASIC authentication.
*
* @return A username.
*/ */
default String getBasicAuthUsername() { default String getBasicAuthUsername() {
return null; return null;
} }
/** /**
* This method retrieves the password to use in HTTP BASIC authentication/authorization. * @return The corresponding password for the username in BASIC authentication.
*
* @return The corresponding password for the username.
*/ */
default String getBasicAuthPassword() { default String getBasicAuthPassword() {
return null; return null;
} }
/** /**
* This method retrieves the client identifier to use in Client Enforcement authorization. * @return The client ID for Client Enforcement authentication.
*
* @return A client identifier.
*/ */
default String getClientId() { default String getClientId() {
return null; return null;
} }
/** /**
* This method retrieves the client secret to use in Client Enforcement authorization. * @return The corresponding client secret for the client ID in Client Enforcement authentication.
*
* @return The corresponding client secret for the client identifier.
*/ */
default String getClientSecret() { default String getClientSecret() {
return null; return null;
} }
/** /**
* This method retrieves the token to use in HTTP BEARER authorization. * @return The token for BEARER authorization.
* This is provided in a response to the token URL.
*
* @return An access token.
*/ */
default String getBearerToken() { default String getBearerToken() {
return null; return null;
} }
/** /**
* This method retrieves the token URL to use for OAuth authorization. * @return The token URL for OAuth authorization.
* The value can be pulled from OAuth endpoint well-known meta-data. That
* endpoint or the token URL itself may also be provided OAuth IdP
* administrator.
*
* @return An OAuth token URL.
*/ */
default String getOAuthTokenUrl() { default String getOAuthTokenUrl() {
return null; return null;
} }
/** /**
* This method retrieves the client identifier to use in OAuth * @return The client ID provided by the OAuth IdP administrator.
* authorization. This is provided by the OAuth IdP administrator or
* tooling.
*
* @return A client identifier.
*/ */
default String getOAuthClientId() { default String getOAuthClientId() {
return this.getClientId(); return this.getClientId();
} }
/** /**
* This method retrieves the client secret to use in OAuth authorization. * @return The corresponding client secret for the client ID provided by the OAuth IdP administrator.
* This is provided by the OAuth IdP administrator or tooling.
*
* @return The corresponding client secret for the client identifier.
*/ */
default String getOAuthClientSecret() { default String getOAuthClientSecret() {
return this.getClientSecret(); return this.getClientSecret();
} }
/** /**
* This method retrieves the authorization code to use in OAuth * @return The authorization code used in the OAuth Authorization Code flow.
* Authorization Code flow. This is provided by the OAuth IdP
* administrator or tooling.
*
* @return An authorization code.
*/ */
default String getOAuthAuthCode() { default String getOAuthAuthCode() {
return null; return null;
} }
/** /**
* This method retrieves the redirect URL to use in OAuth Authorization * @return The redirect URL used in the OAuth Authorization Code flow.
* Code flow. This has meaning to the client-side web application.
*
* @return A URL for the OAuth flow to redirect to when complete.
*/ */
default String getOAuthAuthRedirectUri() { default String getOAuthAuthRedirectUri() {
return null; return null;
} }
/** /**
* This method retrieves the username to use in OAuth Password Grant flow. * @return The username used in the OAuth Password Grant flow.
* This is provided by the OAuth IdP administrator or tooling.
*
* @return A username.
*/ */
default String getOAuthUsername() { default String getOAuthUsername() {
return null; return null;
} }
/** /**
* This method retrieves the password to use in OAuth Password Grant flow. * @return The corresponding password for the username used in the OAuth Password Grant flow.
* This is provided by the OAuth IdP administrator or tooling.
*
* @return The corresponding password for the username.
*/ */
default String getOAuthPassword() { default String getOAuthPassword() {
return null; return null;
@ -158,22 +120,10 @@ public interface ClientConfiguration {
/**
* This method retrieves the connection (before request sent) timeout for
* the client.
*
* @return A timeout in milliseconds.
*/
default Integer getConnectTimeoutInMillis() { default Integer getConnectTimeoutInMillis() {
return null; return null;
} }
/**
* This method retrieves the response (after request sent) timeout for the
* client.
*
* @return A timeout in milliseconds.
*/
default Integer getResponseTimeoutInMillis() { default Integer getResponseTimeoutInMillis() {
return null; return null;
} }
@ -181,38 +131,29 @@ public interface ClientConfiguration {
/** /**
* This method enables/disables the JackSON UNWRAP_ROOT_VALUE feature. * @return true to enable Jackson UNWRAP_ROOT_VALUE feature; false otherwise.
*
* @return `true` to enable; `false` otherwise.
*/ */
default boolean isUnwrapRootValueEnabled() { default boolean isUnwrapRootValueEnabled() {
return false; return false;
} }
/** /**
* This method enables/disables the JackSON WRAP_ROOT_VALUE feature. * @return true to enable Jackson WRAP_ROOT_VALUE feature; false otherwise.
*
* @return `true` to enable; `false` otherwise.
*/ */
default boolean isWrapRootValueEnabled() { default boolean isWrapRootValueEnabled() {
return false; return false;
} }
/** /**
* This method allows sub-classes to extend the JackSON mapper * @param mapper A Jackson object mapper to configure.
* configuration and behavior.
*
* @param mapper A JackSON object mapper.
*/ */
default void configureJacksonMapper(ObjectMapper mapper) { default void configureJacksonMapper(ObjectMapper mapper) {
} }
/** /**
* This method allows sub-classes to extend the JackSON JSON provider. * @param provider A Jackson JAX-RS provider to configure.
*
* @param provider A JackSON Jakarta RS provider.
*/ */
default void configureJacksonProvider(JacksonJsonProvider provider) { default void configureJacksonProvider(JacksonJaxbJsonProvider provider) {
} }

View File

@ -14,7 +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; import org.apache.commons.lang3.StringUtils;

View File

@ -14,15 +14,15 @@
*/ */
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;
/** /**
* A class that provides pre-configured Jakarta RS Client &amp; WebTarget * A class that provides pre-configured JAX-RS Client &amp; WebTarget objects
* objects. * for Jersey.
* *
* @author brian@inteligr8.com * @author brian@inteligr8.com
*/ */
@ -34,7 +34,6 @@ 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.
*/ */
public ClientImpl(ClientConfiguration config) { public ClientImpl(ClientConfiguration config) {
@ -42,22 +41,36 @@ public class ClientImpl extends Client {
} }
/** /**
* This method is a placeholder. * This method registers the Jersey library as the default provider for the
* JAX-RS specification.
*/ */
@PostConstruct @PostConstruct
public void register() { public void register() {
this.logger.info("API Base URL: {}", this.getConfig().getBaseUrl()); this.logger.info("API Base URL: {}", this.getConfig().getBaseUrl());
} }
/**
* @param clientBuilder A client builder.
*/
@Override @Override
public void buildClient(ClientBuilder clientBuilder) { public void buildClient(ClientBuilder clientBuilder) {
} }
@Override /**
* @return The client configuration.
*/
public ClientConfiguration getConfig() { public ClientConfiguration getConfig() {
return this.config; 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 @Override
public <T> T getApi(AuthorizationFilter authFilter, Class<T> apiClass) { public <T> T getApi(AuthorizationFilter authFilter, Class<T> apiClass) {
throw new UnsupportedOperationException(); throw new UnsupportedOperationException();

View File

@ -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
@ -32,8 +32,6 @@ public class ForwardingAuthorizationFilter implements AuthorizationFilter {
private final String authorizationHeaderValue; private final String authorizationHeaderValue;
/** /**
* This constructor instantiates the filter with required fields.
*
* @param authorizationHeaderValue A previously used or formulated 'Authorization' header. * @param authorizationHeaderValue A previously used or formulated 'Authorization' header.
*/ */
public ForwardingAuthorizationFilter(String authorizationHeaderValue) { public ForwardingAuthorizationFilter(String authorizationHeaderValue) {

View File

@ -1,68 +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 java.io.UnsupportedEncodingException;
import java.util.List;
import java.util.Map.Entry;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import jakarta.ws.rs.client.ClientRequestContext;
/**
* This class implements a header-based authorization filter.
*
* @author brian@inteligr8.com
*/
public class HeaderAuthorizationFilter implements AuthorizationFilter {
private final MultiValueMap<String, Object> headers = new LinkedMultiValueMap<>();
/**
* This constructor instantiates the filter with required fields.
*
* @param headerName A header name.
* @param headerValue A header value.
*/
public HeaderAuthorizationFilter(String headerName, Object headerValue) {
this.headers.add(headerName, headerValue);
}
/**
* This method adds another header name/value to outgoing requests.
*
* @param headerName A header name.
* @param headerValue A header value.
* @return This class for fluent chaining.
*/
public HeaderAuthorizationFilter add(String headerName, Object headerValue) {
this.headers.add(headerName, headerValue);
return this;
}
/**
* This method applies the 'Authorization' header to the {@link ClientRequestContext}.
*
* @param requestContext A request context.
*/
@Override
public void filter(ClientRequestContext requestContext) throws UnsupportedEncodingException {
for (Entry<String, List<Object>> header : this.headers.entrySet())
requestContext.getHeaders().put(header.getKey(), header.getValue());
}
}

View File

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

View File

@ -16,7 +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.apache.commons.lang3.StringUtils;
import org.slf4j.Logger; import org.slf4j.Logger;

View File

@ -16,22 +16,22 @@ 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.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.
@ -159,7 +159,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);

View File

@ -14,7 +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.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;

View File

@ -14,7 +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.apache.commons.lang3.StringUtils;
import org.slf4j.Logger; import org.slf4j.Logger;