From 4a1457c84c5f3a68ccdfb3e348996e14ccea89e8 Mon Sep 17 00:00:00 2001 From: wasala Date: Tue, 11 Sep 2018 09:50:21 +0200 Subject: PRH:security vulnerabilities fix *Removed unused libraries *Fixed vulnerablities in connection with clm scan *Replaced AssertJ in tests verification by using StepVerifier Change-Id: I81c3ac54e5514735f0fca8150fcc218d96dc5ce3 Issue-ID: DCAEGEN2-770 Signed-off-by: wasala --- .../producer/AaiProducerReactiveHttpClient.java | 24 ++++++++-------------- 1 file changed, 9 insertions(+), 15 deletions(-) (limited to 'prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/producer/AaiProducerReactiveHttpClient.java') diff --git a/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/producer/AaiProducerReactiveHttpClient.java b/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/producer/AaiProducerReactiveHttpClient.java index 4e0758c1..9e282cde 100644 --- a/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/producer/AaiProducerReactiveHttpClient.java +++ b/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/producer/AaiProducerReactiveHttpClient.java @@ -26,17 +26,19 @@ import static org.onap.dcaegen2.services.prh.model.logging.MdcVariables.X_INVOCA import static org.onap.dcaegen2.services.prh.model.logging.MdcVariables.X_ONAP_REQUEST_ID; import java.net.URI; -import java.net.URISyntaxException; import java.util.UUID; -import org.apache.http.client.utils.URIBuilder; + import org.onap.dcaegen2.services.prh.config.AaiClientConfiguration; import org.onap.dcaegen2.services.prh.model.ConsumerDmaapModel; import org.slf4j.MDC; import org.springframework.web.reactive.function.client.ClientResponse; import org.springframework.web.reactive.function.client.WebClient; +import org.springframework.web.util.DefaultUriBuilderFactory; import reactor.core.publisher.Mono; + + public class AaiProducerReactiveHttpClient { private WebClient webClient; @@ -66,11 +68,7 @@ public class AaiProducerReactiveHttpClient { * @return status code of operation */ public Mono getAaiProducerResponse(ConsumerDmaapModel consumerDmaapModelMono) { - try { - return patchAaiRequest(consumerDmaapModelMono); - } catch (URISyntaxException e) { - return Mono.error(e); - } + return patchAaiRequest(consumerDmaapModelMono); } public AaiProducerReactiveHttpClient createAaiWebClient(WebClient webClient) { @@ -78,7 +76,7 @@ public class AaiProducerReactiveHttpClient { return this; } - private Mono patchAaiRequest(ConsumerDmaapModel dmaapModel) throws URISyntaxException { + private Mono patchAaiRequest(ConsumerDmaapModel dmaapModel) { return webClient.patch() .uri(getUri(dmaapModel.getSourceName())) @@ -88,12 +86,8 @@ public class AaiProducerReactiveHttpClient { .exchange(); } - URI getUri(String pnfName) throws URISyntaxException { - return new URIBuilder() - .setScheme(aaiProtocol) - .setHost(aaiHost) - .setPort(aaiHostPortNumber) - .setPath(aaiBasePath + aaiPnfPath + "/" + pnfName) - .build(); + URI getUri(String pnfName) { + return new DefaultUriBuilderFactory().builder().scheme(aaiProtocol).host(aaiHost).port(aaiHostPortNumber) + .path(aaiBasePath + aaiPnfPath + "/" + pnfName).build(); } } -- cgit 1.2.3-korg