import org.onap.cps.ncmp.impl.data.models.DmiOperationCmHandle;
import org.onap.cps.ncmp.impl.data.policyexecutor.PolicyExecutor;
import org.onap.cps.ncmp.impl.data.utils.DmiDataOperationsHelper;
-import org.onap.cps.ncmp.impl.dmi.DmiProperties;
import org.onap.cps.ncmp.impl.dmi.DmiRestClient;
+import org.onap.cps.ncmp.impl.dmi.DmiServiceAuthenticationProperties;
import org.onap.cps.ncmp.impl.inventory.InventoryPersistence;
import org.onap.cps.ncmp.impl.inventory.models.YangModelCmHandle;
import org.onap.cps.ncmp.impl.models.DmiRequestBody;
private final InventoryPersistence inventoryPersistence;
private final AlternateIdMatcher alternateIdMatcher;
private final JsonObjectMapper jsonObjectMapper;
- private final DmiProperties dmiProperties;
+ private final DmiServiceAuthenticationProperties dmiServiceAuthenticationProperties;
private final DmiRestClient dmiRestClient;
private final PolicyExecutor policyExecutor;
.queryParameter("resourceIdentifier", resourceIdentifier)
.queryParameter("options", optionsParamInQuery)
.queryParameter("topic", topicParamInQuery)
- .createUrlTemplateParameters(dmiServiceName, dmiProperties.getDmiBasePath());
+ .createUrlTemplateParameters(dmiServiceName, dmiServiceAuthenticationProperties.getDmiBasePath());
}
private UrlTemplateParameters getUrlTemplateParameters(final String dmiServiceName,
.fixedPathSegment("data")
.queryParameter("requestId", requestId)
.queryParameter("topic", topicParamInQuery)
- .createUrlTemplateParameters(dmiServiceName, dmiProperties.getDmiBasePath());
+ .createUrlTemplateParameters(dmiServiceName, dmiServiceAuthenticationProperties.getDmiBasePath());
}
private void validateIfCmHandleStateReady(final YangModelCmHandle yangModelCmHandle,
import lombok.RequiredArgsConstructor;
import org.onap.cps.ncmp.api.datajobs.DataJobResultService;
-import org.onap.cps.ncmp.impl.dmi.DmiProperties;
import org.onap.cps.ncmp.impl.dmi.DmiRestClient;
+import org.onap.cps.ncmp.impl.dmi.DmiServiceAuthenticationProperties;
import org.onap.cps.ncmp.impl.utils.http.RestServiceUrlTemplateBuilder;
import org.onap.cps.ncmp.impl.utils.http.UrlTemplateParameters;
import org.springframework.stereotype.Service;
public class DataJobResultServiceImpl implements DataJobResultService {
private final DmiRestClient dmiRestClient;
- private final DmiProperties dmiProperties;
+ private final DmiServiceAuthenticationProperties dmiServiceAuthenticationProperties;
@Override
public String getDataJobResult(final String authorization,
.variablePathSegment("dataProducerJobId", dataProducerJobId)
.fixedPathSegment("result")
.queryParameter("destination", destination)
- .createUrlTemplateParameters(dmiServiceName, dmiProperties.getDmiBasePath());
+ .createUrlTemplateParameters(dmiServiceName,
+ dmiServiceAuthenticationProperties.getDmiBasePath());
return dmiRestClient.getDataJobResult(urlTemplateParameters, authorization).block();
}
}
import lombok.RequiredArgsConstructor;
import org.onap.cps.ncmp.api.datajobs.DataJobStatusService;
-import org.onap.cps.ncmp.impl.dmi.DmiProperties;
import org.onap.cps.ncmp.impl.dmi.DmiRestClient;
+import org.onap.cps.ncmp.impl.dmi.DmiServiceAuthenticationProperties;
import org.onap.cps.ncmp.impl.utils.http.RestServiceUrlTemplateBuilder;
import org.onap.cps.ncmp.impl.utils.http.UrlTemplateParameters;
import org.springframework.stereotype.Service;
public class DataJobStatusServiceImpl implements DataJobStatusService {
private final DmiRestClient dmiRestClient;
- private final DmiProperties dmiProperties;
+ private final DmiServiceAuthenticationProperties dmiServiceAuthenticationProperties;
@Override
public String getDataJobStatus(final String authorization,
.fixedPathSegment("dataProducerJob")
.variablePathSegment("dataProducerJobId", dataProducerJobId)
.fixedPathSegment("status")
- .createUrlTemplateParameters(dmiServiceName, dmiProperties.getDmiBasePath());
+ .createUrlTemplateParameters(dmiServiceName, dmiServiceAuthenticationProperties.getDmiBasePath());
}
}
import org.onap.cps.ncmp.api.datajobs.models.ProducerKey;
import org.onap.cps.ncmp.api.datajobs.models.SubJobWriteRequest;
import org.onap.cps.ncmp.api.datajobs.models.SubJobWriteResponse;
-import org.onap.cps.ncmp.impl.dmi.DmiProperties;
import org.onap.cps.ncmp.impl.dmi.DmiRestClient;
+import org.onap.cps.ncmp.impl.dmi.DmiServiceAuthenticationProperties;
import org.onap.cps.ncmp.impl.models.RequiredDmiService;
import org.onap.cps.ncmp.impl.utils.http.RestServiceUrlTemplateBuilder;
import org.onap.cps.ncmp.impl.utils.http.UrlTemplateParameters;
public class DmiSubJobRequestHandler {
private final DmiRestClient dmiRestClient;
- private final DmiProperties dmiProperties;
+ private final DmiServiceAuthenticationProperties dmiServiceAuthenticationProperties;
private final JsonObjectMapper jsonObjectMapper;
/**
return RestServiceUrlTemplateBuilder.newInstance()
.fixedPathSegment("cmwriteJob")
.queryParameter("destination", destination)
- .createUrlTemplateParameters(producerKey.dmiServiceName(), dmiProperties.getDmiBasePath());
+ .createUrlTemplateParameters(producerKey.dmiServiceName(),
+ dmiServiceAuthenticationProperties.getDmiBasePath());
}
}
private static final String NOT_SPECIFIED = "";
- private final DmiProperties dmiProperties;
+ private final DmiServiceAuthenticationProperties dmiServiceAuthenticationProperties;
private final JsonObjectMapper jsonObjectMapper;
@Qualifier("dataServicesWebClient")
private final WebClient dataServicesWebClient;
}
private void configureHttpHeaders(final HttpHeaders httpHeaders, final String authorization) {
- if (dmiProperties.isDmiBasicAuthEnabled()) {
- httpHeaders.setBasicAuth(dmiProperties.getAuthUsername(), dmiProperties.getAuthPassword());
+ if (dmiServiceAuthenticationProperties.isDmiBasicAuthEnabled()) {
+ httpHeaders.setBasicAuth(dmiServiceAuthenticationProperties.getAuthUsername(),
+ dmiServiceAuthenticationProperties.getAuthPassword());
} else if (authorization != null && authorization.toLowerCase(Locale.getDefault()).startsWith("bearer ")) {
httpHeaders.add(HttpHeaders.AUTHORIZATION, authorization);
}
@Getter
@Component
-public class DmiProperties {
+public class DmiServiceAuthenticationProperties {
@Value("${ncmp.dmi.auth.username}")
private String authUsername;
@Value("${ncmp.dmi.auth.password}")
import lombok.RequiredArgsConstructor;
import org.onap.cps.api.model.ModuleReference;
import org.onap.cps.ncmp.api.inventory.models.YangResource;
-import org.onap.cps.ncmp.impl.dmi.DmiProperties;
import org.onap.cps.ncmp.impl.dmi.DmiRestClient;
+import org.onap.cps.ncmp.impl.dmi.DmiServiceAuthenticationProperties;
import org.onap.cps.ncmp.impl.inventory.models.YangModelCmHandle;
import org.onap.cps.ncmp.impl.models.DmiRequestBody;
import org.onap.cps.ncmp.impl.utils.http.RestServiceUrlTemplateBuilder;
public class DmiModelOperations {
private final JsonObjectMapper jsonObjectMapper;
- private final DmiProperties dmiProperties;
+ private final DmiServiceAuthenticationProperties dmiServiceAuthenticationProperties;
private final DmiRestClient dmiRestClient;
/**
.fixedPathSegment("ch")
.variablePathSegment("cmHandleId", cmHandle)
.fixedPathSegment(resourceName)
- .createUrlTemplateParameters(dmiServiceName, dmiProperties.getDmiBasePath());
+ .createUrlTemplateParameters(dmiServiceName, dmiServiceAuthenticationProperties.getDmiBasePath());
return dmiRestClient.synchronousPostOperationWithJsonData(MODEL, urlTemplateParameters, jsonRequestBody, READ,
null);
}
import org.onap.cps.ncmp.events.async1_0_0.DataOperationEvent
import org.onap.cps.ncmp.impl.data.policyexecutor.PolicyExecutor
import org.onap.cps.ncmp.impl.dmi.DmiOperationsBaseSpec
-import org.onap.cps.ncmp.impl.dmi.DmiProperties
+import org.onap.cps.ncmp.impl.dmi.DmiServiceAuthenticationProperties
import org.onap.cps.ncmp.impl.utils.AlternateIdMatcher
import org.onap.cps.ncmp.impl.utils.http.UrlTemplateParameters
import org.onap.cps.ncmp.utils.TestUtils
import static org.onap.cps.ncmp.utils.events.CloudEventMapper.toTargetEvent
@SpringBootTest
-@ContextConfiguration(classes = [EventsProducer, CpsApplicationContext, DmiProperties, DmiDataOperations, PolicyExecutor])
+@ContextConfiguration(classes = [EventsProducer, CpsApplicationContext, DmiServiceAuthenticationProperties, DmiDataOperations, PolicyExecutor])
class DmiDataOperationsSpec extends DmiOperationsBaseSpec {
def NO_TOPIC = null
package org.onap.cps.ncmp.impl.datajobs
-import org.onap.cps.ncmp.impl.dmi.DmiProperties
import org.onap.cps.ncmp.impl.dmi.DmiRestClient
+import org.onap.cps.ncmp.impl.dmi.DmiServiceAuthenticationProperties
import org.onap.cps.ncmp.impl.utils.http.UrlTemplateParameters
import reactor.core.publisher.Mono
import spock.lang.Specification
class DataJobResultServiceImplSpec extends Specification {
def mockDmiRestClient = Mock(DmiRestClient)
- def mockDmiProperties = Mock(DmiProperties)
- def objectUnderTest = new DataJobResultServiceImpl(mockDmiRestClient, mockDmiProperties)
+ def mockDmiServiceAuthenticationProperties = Mock(DmiServiceAuthenticationProperties)
+ def objectUnderTest = new DataJobResultServiceImpl(mockDmiRestClient, mockDmiServiceAuthenticationProperties)
def setup() {
- mockDmiProperties.dmiBasePath >> 'dmi'
+ mockDmiServiceAuthenticationProperties.dmiBasePath >> 'dmi'
}
def 'Retrieve data job result.'() {
package org.onap.cps.ncmp.impl.datajobs
-import org.onap.cps.ncmp.impl.dmi.DmiProperties
import org.onap.cps.ncmp.impl.dmi.DmiRestClient
+import org.onap.cps.ncmp.impl.dmi.DmiServiceAuthenticationProperties
import org.onap.cps.ncmp.impl.utils.http.UrlTemplateParameters
import reactor.core.publisher.Mono
import spock.lang.Specification
class DataJobStatusServiceImplSpec extends Specification {
def mockDmiRestClient = Mock(DmiRestClient)
- def mockDmiProperties = Mock(DmiProperties)
- def objectUnderTest = new DataJobStatusServiceImpl(mockDmiRestClient, mockDmiProperties)
+ def mockDmiServiceAuthenticationProperties = Mock(DmiServiceAuthenticationProperties)
+ def objectUnderTest = new DataJobStatusServiceImpl(mockDmiRestClient, mockDmiServiceAuthenticationProperties)
def setup() {
- mockDmiProperties.dmiBasePath >> 'dmi'
+ mockDmiServiceAuthenticationProperties.dmiBasePath >> 'dmi'
}
def 'Forward a data job status query to DMI.' () {
import org.onap.cps.ncmp.api.datajobs.models.DataJobMetadata
import org.onap.cps.ncmp.api.datajobs.models.DmiWriteOperation
import org.onap.cps.ncmp.api.datajobs.models.ProducerKey
-import org.onap.cps.ncmp.api.datajobs.models.SubJobWriteResponse
-import org.onap.cps.ncmp.impl.dmi.DmiProperties
+import org.onap.cps.ncmp.impl.dmi.DmiServiceAuthenticationProperties
import org.onap.cps.ncmp.impl.dmi.DmiRestClient
import org.onap.cps.ncmp.impl.models.RequiredDmiService
import org.onap.cps.utils.JsonObjectMapper
def mockDmiRestClient = Mock(DmiRestClient)
def jsonObjectMapper = new JsonObjectMapper(new ObjectMapper())
- def mockDmiProperties = Mock(DmiProperties)
- def objectUnderTest = new DmiSubJobRequestHandler(mockDmiRestClient, mockDmiProperties, jsonObjectMapper)
+ def mockDmiServiceAuthenticationProperties = Mock(DmiServiceAuthenticationProperties)
+ def objectUnderTest = new DmiSubJobRequestHandler(mockDmiRestClient, mockDmiServiceAuthenticationProperties, jsonObjectMapper)
def 'Send a sub-job request to the DMI Plugin.'() {
given: 'a data job id, metadata and a map of producer keys and write operations to create a request'
def mockRequestBody = Mock(WebClient.RequestBodyUriSpec)
def mockResponse = Mock(WebClient.ResponseSpec)
- def mockDmiProperties = Mock(DmiProperties)
+ def mockDmiServiceAuthenticationProperties = Mock(DmiServiceAuthenticationProperties)
JsonObjectMapper jsonObjectMapper = new JsonObjectMapper(new ObjectMapper())
- DmiRestClient objectUnderTest = new DmiRestClient(mockDmiProperties, jsonObjectMapper, mockDataServicesWebClient, mockModelServicesWebClient, mockHealthChecksWebClient)
+ DmiRestClient objectUnderTest = new DmiRestClient(mockDmiServiceAuthenticationProperties, jsonObjectMapper, mockDataServicesWebClient, mockModelServicesWebClient, mockHealthChecksWebClient)
def setup() {
mockRequestBody.uri(_,_) >> mockRequestBody
def 'DMI auth header #scenario'() {
when: 'Specific dmi properties are provided'
- mockDmiProperties.dmiBasicAuthEnabled >> authEnabled
- mockDmiProperties.authUsername >> 'some user'
- mockDmiProperties.authPassword >> 'some password'
+ mockDmiServiceAuthenticationProperties.dmiBasicAuthEnabled >> authEnabled
+ mockDmiServiceAuthenticationProperties.authUsername >> 'some user'
+ mockDmiServiceAuthenticationProperties.authPassword >> 'some password'
then: 'http headers to conditionally have Authorization header'
def httpHeaders = new HttpHeaders()
objectUnderTest.configureHttpHeaders(httpHeaders, ncmpAuthHeader)
import spock.lang.Specification
-class DmiPropertiesSpec extends Specification {
+class DmiServiceAuthenticationPropertiesSpec extends Specification {
- def objectUnderTest = new DmiProperties()
+ def objectUnderTest = new DmiServiceAuthenticationProperties()
def 'Geting dmi base path.'() {
given: 'base path of #dmiBasePath'
package org.onap.cps.ncmp.impl.inventory.sync
import org.onap.cps.ncmp.impl.dmi.DmiOperationsBaseSpec
-import org.onap.cps.ncmp.impl.dmi.DmiProperties
+import org.onap.cps.ncmp.impl.dmi.DmiServiceAuthenticationProperties
import org.onap.cps.ncmp.impl.utils.http.UrlTemplateParameters
import org.onap.cps.api.model.ModuleReference
import org.onap.cps.utils.JsonObjectMapper
import static org.onap.cps.ncmp.impl.models.RequiredDmiService.MODEL
@SpringBootTest
-@ContextConfiguration(classes = [DmiProperties, DmiModelOperations, JsonObjectMapper])
+@ContextConfiguration(classes = [DmiServiceAuthenticationProperties, DmiModelOperations, JsonObjectMapper])
class DmiModelOperationsSpec extends DmiOperationsBaseSpec {
def NO_AUTH_HEADER = null