-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
added new RestClientHelper class, refactoring
Issue #210
- Loading branch information
Showing
4 changed files
with
210 additions
and
54 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
143 changes: 143 additions & 0 deletions
143
imixs-archive-service/src/main/java/org/imixs/archive/service/util/RestClientHelper.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,143 @@ | ||
| package org.imixs.archive.service.util; | ||
|
|
||
| import java.io.Serializable; | ||
| import java.util.List; | ||
| import java.util.Optional; | ||
| import java.util.logging.Logger; | ||
|
|
||
| import org.eclipse.microprofile.config.inject.ConfigProperty; | ||
| import org.imixs.archive.service.ImixsArchiveApp; | ||
| import org.imixs.melman.BasicAuthenticator; | ||
| import org.imixs.melman.CookieAuthenticator; | ||
| import org.imixs.melman.DocumentClient; | ||
| import org.imixs.melman.EventLogClient; | ||
| import org.imixs.melman.FormAuthenticator; | ||
| import org.imixs.melman.JWTAuthenticator; | ||
| import org.imixs.melman.RestAPIException; | ||
| import org.imixs.melman.WorkflowClient; | ||
|
|
||
| import jakarta.enterprise.context.ApplicationScoped; | ||
| import jakarta.inject.Inject; | ||
| import jakarta.inject.Named; | ||
| import jakarta.ws.rs.client.ClientRequestFilter; | ||
| import jakarta.ws.rs.core.Cookie; | ||
|
|
||
| /** | ||
| * The RestClientHelper provides helper method to create a DocumentRestClient | ||
| * and a EventLogRestClient. | ||
| * | ||
| * @author rsoika | ||
| * | ||
| */ | ||
| @Named | ||
| @ApplicationScoped | ||
| public class RestClientHelper implements Serializable { | ||
|
|
||
| private static Logger logger = Logger.getLogger(RestClientHelper.class.getName()); | ||
|
|
||
| private static final long serialVersionUID = 1L; | ||
|
|
||
| @Inject | ||
| @ConfigProperty(name = ImixsArchiveApp.WORKFLOW_SERVICE_ENDPOINT) | ||
| Optional<String> instanceEndpoint; | ||
|
|
||
| @Inject | ||
| @ConfigProperty(name = ImixsArchiveApp.WORKFLOW_SERVICE_USER) | ||
| Optional<String> instanceUser; | ||
|
|
||
| @Inject | ||
| @ConfigProperty(name = ImixsArchiveApp.WORKFLOW_SERVICE_PASSWORD) | ||
| Optional<String> instancePassword; | ||
|
|
||
| @Inject | ||
| @ConfigProperty(name = ImixsArchiveApp.WORKFLOW_SERVICE_AUTHMETHOD) | ||
| Optional<String> instanceAuthmethod; | ||
|
|
||
| DocumentClient documentClient = null; | ||
| EventLogClient eventLogClient = null; | ||
|
|
||
| /** | ||
| * This method creates a new DocumentClient instance. | ||
| * | ||
| * If an instance already exists, we return the existing instance. | ||
| * | ||
| * @return | ||
| * @throws RestAPIException | ||
| */ | ||
| public DocumentClient createDocumentClient() throws RestAPIException { | ||
|
|
||
| // test if we have already an instance | ||
| if (documentClient != null) { | ||
| return documentClient; | ||
| } | ||
| logger.info("RestClientHelper create DocumentClient...."); | ||
| if (instanceEndpoint.isPresent()) { | ||
|
|
||
| documentClient = new WorkflowClient(instanceEndpoint.get()); | ||
| String auttype = instanceAuthmethod.orElse("BASIC").toUpperCase(); | ||
| if ("BASIC".equals(auttype)) { | ||
| // Create a authenticator | ||
| BasicAuthenticator basicAuth = new BasicAuthenticator(instanceUser.orElse(""), | ||
| instancePassword.orElse("")); | ||
| // register the authenticator | ||
| documentClient.registerClientRequestFilter(basicAuth); | ||
| } | ||
| if ("FORM".equals(auttype)) { | ||
|
|
||
| logger.info("RestClientHelper create FormAuthenticator.... instance endpoint=" | ||
| + instanceEndpoint.orElse("")); | ||
| // Create a authenticator | ||
| FormAuthenticator formAuth = new FormAuthenticator(instanceEndpoint.orElse(""), instanceUser.orElse(""), | ||
| instancePassword.orElse("")); | ||
| // register the authenticator | ||
| documentClient.registerClientRequestFilter(formAuth); | ||
|
|
||
| } | ||
| if ("COOKIE".equals(auttype)) { | ||
| Cookie cookie = new Cookie.Builder(instanceUser.orElse("")).path("/").value(instancePassword.orElse("")) | ||
| .build(); | ||
|
|
||
| // Cookie cookie = new Cookie(instanceUser.orElse(""), | ||
| // instancePassword.orElse(""), "/", ""); | ||
| CookieAuthenticator cookieAuth = new CookieAuthenticator(cookie); | ||
| documentClient.registerClientRequestFilter(cookieAuth); | ||
| } | ||
| if ("JWT".equalsIgnoreCase(instancePassword.orElse(""))) { | ||
| JWTAuthenticator jwtAuht = new JWTAuthenticator(instancePassword.orElse("")); | ||
| documentClient.registerClientRequestFilter(jwtAuht); | ||
| } | ||
| } | ||
|
|
||
| return documentClient; | ||
|
|
||
| } | ||
|
|
||
| /** | ||
| * Creates a EventLogClient form a given DocumentClient instance | ||
| * | ||
| * If an instance already exists, we return the existing instance. | ||
| * | ||
| * @param documentClient - a existing documentClient | ||
| * @return - a eventLogClient instance | ||
| */ | ||
| public EventLogClient createEventLogClient(DocumentClient documentClient) { | ||
|
|
||
| // test if we have already an instance | ||
| if (eventLogClient != null) { | ||
| return eventLogClient; | ||
| } | ||
| if (documentClient != null) { | ||
| EventLogClient client = new EventLogClient(documentClient.getBaseURI()); | ||
| // register all filters from workfow client | ||
| List<ClientRequestFilter> filterList = documentClient.getRequestFilterList(); | ||
| for (ClientRequestFilter filter : filterList) { | ||
| client.registerClientRequestFilter(filter); | ||
| } | ||
| return client; | ||
| } else { | ||
| // no existing workflow client define! | ||
| return null; | ||
| } | ||
| } | ||
|
|
||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters