aboutsummaryrefslogtreecommitdiffstats
path: root/rest-services/dmaap-client/src
diff options
context:
space:
mode:
authortkogut <tomasz.kogut@nokia.com>2021-03-25 12:31:56 +0100
committertkogut <tomasz.kogut@nokia.com>2021-03-25 17:57:39 +0100
commitb7c6e7af778acb904b0be44204532f388fd2492f (patch)
treea816615791497e7393c1a84cd4e7b4515ca042b2 /rest-services/dmaap-client/src
parent56d195e933b57360c6f23c95d91c048f76ca755c (diff)
Remove test dependencies(google.guava, apache.commons.lang3) usage from runtime code
Issue-ID: DCAEGEN2-2670 Signed-off-by: tkogut <tomasz.kogut@nokia.com> Change-Id: I8ef7a1ea6e61cb1232476e6f82238a3124e52160
Diffstat (limited to 'rest-services/dmaap-client/src')
-rw-r--r--rest-services/dmaap-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/impl/Commons.java28
1 files changed, 17 insertions, 11 deletions
diff --git a/rest-services/dmaap-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/impl/Commons.java b/rest-services/dmaap-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/impl/Commons.java
index 2bb04df4..9f534d8f 100644
--- a/rest-services/dmaap-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/impl/Commons.java
+++ b/rest-services/dmaap-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/impl/Commons.java
@@ -20,17 +20,15 @@
package org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.impl;
-import com.google.common.primitives.Bytes;
import io.vavr.Tuple;
import io.vavr.Tuple2;
import io.vavr.control.Option;
-import org.apache.commons.lang3.ArrayUtils;
import org.onap.dcaegen2.services.sdk.model.streams.AafCredentials;
import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.HttpResponse;
-import java.nio.charset.Charset;
import java.nio.charset.StandardCharsets;
import java.util.Base64;
+import java.util.Objects;
/**
* @author <a href="mailto:piotr.jaszczyk@nokia.com">Piotr Jaszczyk</a>
@@ -47,18 +45,26 @@ final class Commons {
}
static Tuple2<String, String> basicAuthHeader(AafCredentials credentials) {
- Charset utf8 = StandardCharsets.UTF_8;
- byte[] username = toBytes(credentials.username(), utf8);
- byte[] separator = ":".getBytes(utf8);
- byte[] password = toBytes(credentials.password(), utf8);
- byte[] combined = ArrayUtils.addAll(Bytes.concat(username, separator, password));
- String userCredentials = Base64.getEncoder().encodeToString(combined);
+ Objects.requireNonNull(credentials, "aafCredentials");
+ String basicAuthFormat = basicAuthFormat(credentials);
+ byte[] utf8 = bytesUTF8(basicAuthFormat);
+ String userCredentials = Base64.getEncoder().encodeToString(utf8);
return Tuple.of("Authorization", "Basic " + userCredentials);
}
- private static byte[] toBytes(String text, Charset charset) {
+ private static String basicAuthFormat(AafCredentials credentials) {
+ String username = getOrEmpty(credentials.username());
+ String password = getOrEmpty(credentials.password());
+ return username.concat(":").concat(password);
+ }
+
+ private static String getOrEmpty(String text) {
+ return Option.of(text).getOrElse("");
+ }
+
+ private static byte[] bytesUTF8(String text) {
return Option.of(text)
- .map(s -> s.getBytes(charset))
+ .map(s -> s.getBytes(StandardCharsets.UTF_8))
.getOrElse(new byte[0]);
}
}