summaryrefslogtreecommitdiff
path: root/src/main/java/at/gv/util/client/mis
diff options
context:
space:
mode:
authorThomas Lenz <thomas.lenz@egiz.gv.at>2019-04-10 08:46:33 +0200
committerThomas Lenz <thomas.lenz@egiz.gv.at>2019-04-10 08:46:33 +0200
commit2d03e741a91f6155dce75952b0174e3e52a12740 (patch)
tree13c3d191bc7b27982eee51cc60ab965d20bf9392 /src/main/java/at/gv/util/client/mis
parentc7e92047632432346c13723925f45888461887e9 (diff)
downloadegovutils-2d03e741a91f6155dce75952b0174e3e52a12740.tar.gz
egovutils-2d03e741a91f6155dce75952b0174e3e52a12740.tar.bz2
egovutils-2d03e741a91f6155dce75952b0174e3e52a12740.zip
add PVP R-Profile authentication based HTTP headers to USP_V2 client
Diffstat (limited to 'src/main/java/at/gv/util/client/mis')
-rw-r--r--src/main/java/at/gv/util/client/mis/usp_v2/USPClient.java43
1 files changed, 25 insertions, 18 deletions
diff --git a/src/main/java/at/gv/util/client/mis/usp_v2/USPClient.java b/src/main/java/at/gv/util/client/mis/usp_v2/USPClient.java
index 334df87..4d23a1e 100644
--- a/src/main/java/at/gv/util/client/mis/usp_v2/USPClient.java
+++ b/src/main/java/at/gv/util/client/mis/usp_v2/USPClient.java
@@ -2,14 +2,11 @@ package at.gv.util.client.mis.usp_v2;
import java.net.URL;
import java.util.ArrayList;
-import java.util.Date;
import java.util.List;
import java.util.Map;
import javax.annotation.Resource;
import javax.net.ssl.SSLContext;
-import javax.xml.datatype.DatatypeConfigurationException;
-import javax.xml.namespace.QName;
import javax.xml.ws.BindingProvider;
import javax.xml.ws.WebServiceContext;
import javax.xml.ws.handler.Handler;
@@ -26,20 +23,15 @@ import org.slf4j.LoggerFactory;
import at.gv.util.LaxHostNameVerifier;
import at.gv.util.LoggingHandler;
import at.gv.util.MiscUtil;
-import at.gv.util.client.szr.SZRSOAPHandler;
+import at.gv.util.client.szr.SZRHTTPHeaderHandler;
import at.gv.util.config.EgovUtilConfiguration;
import at.gv.util.ex.EgovUtilException;
-import at.gv.util.wsdl.mis.usp.GetMandatesPortType;
-import at.gv.util.wsdl.mis.usp.GetMandatesService;
import at.gv.util.wsdl.mis.usp_v2.ISyncService;
import at.gv.util.wsdl.mis.usp_v2.ListMandatesFault;
import at.gv.util.wsdl.mis.usp_v2.SynchronisationServiceServiceagent;
-import at.gv.util.xsd.mis.usp.GetMandatesRequest;
-import at.gv.util.xsd.mis.usp.GetMandatesRequest.MandateFilters;
-import at.gv.util.xsd.mis.usp.GetMandatesResponse;
-import at.gv.util.xsd.mis.usp.IdentificationType;
import at.gv.util.xsd.mis.usp_v2.eai.syncmsgs.ListMandatesRequest;
import at.gv.util.xsd.mis.usp_v2.eai.syncmsgs.ListMandatesResponseType;
+import at.gv.util.xsd.mis.usp_v2.eai.syncmsgs.MandateAttributesSearchFilterType;
import at.gv.util.xsd.szr.pvp.PvpTokenType;
public class USPClient {
@@ -98,10 +90,21 @@ public class USPClient {
public void getMandates(String bpkType, String bpkValue, List<String> mandateFilters) {
ListMandatesRequest parameters = new ListMandatesRequest();
+ MandateAttributesSearchFilterType searchFilterType = new MandateAttributesSearchFilterType();
+
+ Object searchFilter = null;
+ searchFilterType.setFilter(searchFilter );
+
+
+
//request USP
try {
+ log.trace("Request pre-processing finished. Requesting USP ... ");
+
ListMandatesResponseType results = this.uspSuche.listMandates(parameters );
+ log.trace("Receive response from USP. Starting response post-processing ... ");
+
} catch (ListMandatesFault e) {
// TODO Auto-generated catch block
e.printStackTrace();
@@ -134,17 +137,20 @@ public class USPClient {
if (handlerList == null) {
handlerList = new ArrayList();
}
- LoggingHandler loggingHandler = new LoggingHandler();
- if (this.logEnabled) {
- handlerList.add(loggingHandler);
- }
-
+
// PV authentication
log.trace("Adding WS-Security Header handler.");
- PvpTokenType pvpToken = config.getURPVPToken();
- SZRSOAPHandler szrSOAPHandler = new SZRSOAPHandler();
+ PvpTokenType pvpToken = config.getUSPPVPToken();
+ SZRHTTPHeaderHandler szrSOAPHandler = new SZRHTTPHeaderHandler();
szrSOAPHandler.configure(pvpToken);
handlerList.add(szrSOAPHandler);
+
+ LoggingHandler loggingHandler = new LoggingHandler();
+ if (this.logEnabled) {
+ handlerList.add(loggingHandler);
+ }
+
+ // set handler
bindingProvider.getBinding().setHandlerChain(handlerList);
Client client = ClientProxy.getClient(uspSuche);
@@ -156,7 +162,8 @@ public class USPClient {
httpClientPolicy.setAllowChunking(false);
httpClientPolicy.setReceiveTimeout(32000);
http.setClient(httpClientPolicy);
-
+
+
// check for ssl
if (uspURL.toLowerCase().startsWith("https")) {
log.trace("Using ssl for SZR client request.");