Merge "Error reporting when registering cm handle with alternate id 2 - update scenario"
authorToine Siebelink <toine.siebelink@est.tech>
Wed, 6 Mar 2024 09:33:19 +0000 (09:33 +0000)
committerGerrit Code Review <gerrit@onap.org>
Wed, 6 Mar 2024 09:33:19 +0000 (09:33 +0000)
1  2 
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/NetworkCmProxyDataServiceImpl.java
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/NetworkCmProxyDataServiceImplSpec.groovy

@@@ -154,11 -154,10 +154,11 @@@ public class NetworkCmProxyDataServiceI
  
      @Override
      public void executeDataOperationForCmHandles(final String topicParamInQuery,
 -                                                 final DataOperationRequest
 -                                                     dataOperationRequest,
 -                                                 final String requestId) {
 -        dmiDataOperations.requestResourceDataFromDmi(topicParamInQuery, dataOperationRequest, requestId);
 +                                                 final DataOperationRequest dataOperationRequest,
 +                                                 final String requestId,
 +                                                 final String authorization) {
 +        dmiDataOperations.requestResourceDataFromDmi(topicParamInQuery, dataOperationRequest, requestId,
 +                authorization);
      }
  
      @Override
          final List<NcmpServiceCmHandle> cmHandlesToBeCreated,
          final List<CmHandleRegistrationResponse> cmHandleRegistrationResponses) {
          final Collection<String> rejectedCmHandleIds = alternateIdChecker
-             .getIdsOfCmHandlesWithRejectedAlternateId(cmHandlesToBeCreated);
+             .getIdsOfCmHandlesWithRejectedAlternateId(cmHandlesToBeCreated, AlternateIdChecker.Operation.CREATE);
          cmHandleRegistrationResponses.addAll(CmHandleRegistrationResponse.createFailureResponses(
              rejectedCmHandleIds, ALTERNATE_ID_ALREADY_ASSOCIATED));
          return rejectedCmHandleIds;
@@@ -158,9 -158,9 +158,9 @@@ class NetworkCmProxyDataServiceImplSpe
          given: 'cpsDataService returns valid data node'
              def dataOperationRequest = getDataOperationRequest(datastoreName)
          when: 'request resource data for data operation is called'
 -            objectUnderTest.executeDataOperationForCmHandles('some topic', dataOperationRequest, 'requestId')
 +            objectUnderTest.executeDataOperationForCmHandles('some topic', dataOperationRequest, 'requestId', NO_AUTH_HEADER)
          then: 'request resource data for data operation returns expected response'
 -            1 * mockDmiDataOperations.requestResourceDataFromDmi('some topic', dataOperationRequest, 'requestId')
 +            1 * mockDmiDataOperations.requestResourceDataFromDmi('some topic', dataOperationRequest, 'requestId', NO_AUTH_HEADER)
          where: 'the following data stores are used'
              datastoreName << [PASSTHROUGH_RUNNING.datastoreName, PASSTHROUGH_OPERATIONAL.datastoreName]
      }
              dmiPluginRegistration.createdCmHandles = [ncmpServiceCmHandle]
              mockDmiPluginRegistration.getCreatedCmHandles() >> [ncmpServiceCmHandle]
          and: 'no rejected cm handles because of alternate ids'
-             mockAlternateIdChecker.getIdsOfCmHandlesWithRejectedAlternateId(_) >> []
+             mockAlternateIdChecker.getIdsOfCmHandlesWithRejectedAlternateId(*_) >> []
          when: 'parse and create cm handle in dmi registration then sync module'
              mockDmiPluginRegistration.createdCmHandles = ['test-cm-handle-id']
              objectUnderTest.processCreatedCmHandles(mockDmiPluginRegistration, new DmiPluginRegistrationResponse())