aboutsummaryrefslogtreecommitdiffstats
path: root/prh-aai-client/src/main/java
diff options
context:
space:
mode:
authorpwielebs <piotr.wielebski@nokia.com>2018-06-05 12:19:28 +0200
committerLusheng Ji <lji@research.att.com>2018-06-05 14:35:53 +0000
commit07ebdbb579bc2b9ef1f0e26d0c98d2c0fdcd353d (patch)
tree759f4ad513f7cdd18a0c6529046817548f88607a /prh-aai-client/src/main/java
parente30c7d54b34daf855303f32035827ee19555b536 (diff)
basic authentication for AAI Producer Client2.0.0-ONAPbeijing2.0.0-ONAP
Change-Id: I087db36dc3c60015f91de5fde49358b18564ab9e Issue-ID: DCAEGEN2-451 Signed-off-by: pwielebs <piotr.wielebski@nokia.com>
Diffstat (limited to 'prh-aai-client/src/main/java')
-rw-r--r--prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/AAIProducerClient.java14
1 files changed, 12 insertions, 2 deletions
diff --git a/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/AAIProducerClient.java b/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/AAIProducerClient.java
index dce326ec..f9c2708e 100644
--- a/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/AAIProducerClient.java
+++ b/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/AAIProducerClient.java
@@ -35,6 +35,7 @@ import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.URI;
import java.net.URISyntaxException;
+import java.util.Base64;
import java.util.Map;
import java.util.Optional;
@@ -49,6 +50,8 @@ public class AAIProducerClient implements AAIExtendedHttpClient {
private final Integer aaiHostPortNumber;
private final String aaiPath;
private final Map<String,String> aaiHeaders;
+ private final String aaiUserName;
+ private final String aaiUserPassword;
public AAIProducerClient(AAIClientConfiguration aaiClientConfiguration) {
@@ -58,6 +61,8 @@ public class AAIProducerClient implements AAIExtendedHttpClient {
aaiHostPortNumber = aaiClientConfiguration.aaiHostPortNumber();
aaiPath = aaiClientConfiguration.aaiBasePath() + aaiClientConfiguration.aaiPnfPath();
aaiHeaders = aaiClientConfiguration.aaiHeaders();
+ aaiUserName = aaiClientConfiguration.aaiUserName();
+ aaiUserPassword = aaiClientConfiguration.aaiUserPassword();
}
@@ -71,7 +76,6 @@ public class AAIProducerClient implements AAIExtendedHttpClient {
return Optional.empty();
}
});
-
}
private Optional<HttpRequestBase> createRequest(ConsumerDmaapModel consumerDmaapModel) throws URISyntaxException {
@@ -98,11 +102,17 @@ public class AAIProducerClient implements AAIExtendedHttpClient {
});
}
- private HttpPatch createHttpPatch(URI extendedURI, String jsonBody) throws UnsupportedEncodingException {
+ HttpPatch createHttpPatch(URI extendedURI, String jsonBody) throws UnsupportedEncodingException {
HttpPatch httpPatch = new HttpPatch(extendedURI);
httpPatch.setEntity( new StringEntity(jsonBody));
aaiHeaders.forEach(httpPatch::addHeader);
httpPatch.addHeader("Content-Type", "application/merge-patch+json");
+ httpPatch.addHeader("Authorization", "Basic " + encode());
return httpPatch;
}
+
+ String encode() throws UnsupportedEncodingException {
+ return Base64.getEncoder().encodeToString((this.aaiUserName + ":" + this.aaiUserPassword)
+ .getBytes("UTF-8"));
+ }
}