From: Toine Siebelink <toine.siebelink@est.tech>
Date: Wed, 6 Mar 2024 14:36:40 +0000 (+0000)
Subject: Merge "Test of retry of failed module sync"
X-Git-Tag: 3.4.7~20
X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=b4b2b568b37aabba4b7a71dcafeeb48144a315d4;hp=-c;p=cps.git

Merge "Test of retry of failed module sync"
---

b4b2b568b37aabba4b7a71dcafeeb48144a315d4
diff --combined integration-test/src/test/groovy/org/onap/cps/integration/base/CpsIntegrationSpecBase.groovy
index 1577524f2c,21e225e0b8..33945a6c21
--- a/integration-test/src/test/groovy/org/onap/cps/integration/base/CpsIntegrationSpecBase.groovy
+++ b/integration-test/src/test/groovy/org/onap/cps/integration/base/CpsIntegrationSpecBase.groovy
@@@ -41,27 -41,29 +41,32 @@@ import org.onap.cps.spi.utils.SessionMa
  import org.springframework.beans.factory.annotation.Autowired
  import org.springframework.boot.autoconfigure.EnableAutoConfiguration
  import org.springframework.boot.autoconfigure.domain.EntityScan
 +import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc
  import org.springframework.boot.test.context.SpringBootTest
  import org.springframework.context.annotation.ComponentScan
  import org.springframework.data.jpa.repository.config.EnableJpaRepositories
  import org.springframework.http.HttpStatus
  import org.springframework.http.MediaType
  import org.springframework.test.web.client.MockRestServiceServer
 +import org.springframework.test.web.servlet.MockMvc
  import org.springframework.web.client.RestTemplate
  import org.testcontainers.spock.Testcontainers
  import spock.lang.Shared
  import spock.lang.Specification
  import spock.util.concurrent.PollingConditions
  
+ import java.time.format.DateTimeFormatter
+ 
  import static org.springframework.test.web.client.match.MockRestRequestMatchers.requestTo
  import static org.springframework.test.web.client.response.MockRestResponseCreators.withStatus
+ import static org.onap.cps.ncmp.api.impl.ncmppersistence.NcmpPersistence.NCMP_DATASPACE_NAME;
+ import static org.onap.cps.ncmp.api.impl.ncmppersistence.NcmpPersistence.NCMP_DMI_REGISTRY_ANCHOR;
+ import static org.onap.cps.ncmp.api.impl.ncmppersistence.NcmpPersistence.NCMP_DMI_REGISTRY_PARENT;
  
 -@SpringBootTest(classes = [CpsDataspaceService])
 +@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.MOCK, classes = [CpsDataspaceService])
  @Testcontainers
  @EnableAutoConfiguration
 +@AutoConfigureMockMvc
  @EnableJpaRepositories(basePackageClasses = [DataspaceRepository])
  @ComponentScan(basePackages = ['org.onap.cps'])
  @EntityScan('org.onap.cps.spi.entities')
@@@ -70,9 -72,6 +75,9 @@@ abstract class CpsIntegrationSpecBase e
      @Shared
      DatabaseTestContainer databaseTestContainer = DatabaseTestContainer.getInstance()
  
 +    @Autowired
 +    MockMvc mvc;
 +
      @Autowired
      CpsDataspaceService cpsDataspaceService
  
@@@ -122,7 -121,7 +127,7 @@@
              createStandardBookStoreSchemaSet(GENERAL_TEST_DATASPACE)
              initialized = true
          }
-         mockDmiServer = MockRestServiceServer.createServer(restTemplate)
+         mockDmiServer = MockRestServiceServer.bindTo(restTemplate).ignoreExpectOrder(true).build()
      }
  
      def cleanup() {
@@@ -194,7 -193,7 +199,7 @@@
      def registerCmHandle(dmiPlugin, cmHandleId, moduleSetTag, dmiModuleReferencesResponse, dmiModuleResourcesResponse) {
          def cmHandleToCreate = new NcmpServiceCmHandle(cmHandleId: cmHandleId, moduleSetTag: moduleSetTag)
          networkCmProxyDataService.updateDmiRegistrationAndSyncModule(new DmiPluginRegistration(dmiPlugin: dmiPlugin, createdCmHandles: [cmHandleToCreate]))
-         mockDmiResponsesForRegistration(dmiPlugin, cmHandleId, dmiModuleReferencesResponse, dmiModuleResourcesResponse)
+         mockDmiResponsesForModuleSync(dmiPlugin, cmHandleId, dmiModuleReferencesResponse, dmiModuleResourcesResponse)
          moduleSyncWatchdog.moduleSyncAdvisedCmHandles()
          new PollingConditions().within(3, () -> {
              CmHandleState.READY == networkCmProxyDataService.getCmHandleCompositeState(cmHandleId).cmHandleState
@@@ -210,14 -209,23 +215,23 @@@
          networkCmProxyDataService.updateDmiRegistrationAndSyncModule(new DmiPluginRegistration(dmiPlugin: dmiPlugin, removedCmHandles: cmHandleIds))
      }
  
-     def mockDmiResponsesForRegistration(dmiPlugin, cmHandleId, dmiModuleReferencesResponse, dmiModuleResourcesResponse) {
-         if (dmiModuleReferencesResponse != null) {
-             mockDmiServer.expect(requestTo("${dmiPlugin}/dmi/v1/ch/${cmHandleId}/modules"))
-                     .andRespond(withStatus(HttpStatus.OK).contentType(MediaType.APPLICATION_JSON).body(dmiModuleReferencesResponse))
-         }
-         if (dmiModuleResourcesResponse != null) {
-             mockDmiServer.expect(requestTo("${dmiPlugin}/dmi/v1/ch/${cmHandleId}/moduleResources"))
-                     .andRespond(withStatus(HttpStatus.OK).contentType(MediaType.APPLICATION_JSON).body(dmiModuleResourcesResponse))
-         }
+     def mockDmiResponsesForModuleSync(dmiPlugin, cmHandleId, dmiModuleReferencesResponse, dmiModuleResourcesResponse) {
+         mockDmiServer.expect(requestTo("${dmiPlugin}/dmi/v1/ch/${cmHandleId}/modules"))
+                 .andRespond(withStatus(HttpStatus.OK).contentType(MediaType.APPLICATION_JSON).body(dmiModuleReferencesResponse))
+         mockDmiServer.expect(requestTo("${dmiPlugin}/dmi/v1/ch/${cmHandleId}/moduleResources"))
+                 .andRespond(withStatus(HttpStatus.OK).contentType(MediaType.APPLICATION_JSON).body(dmiModuleResourcesResponse))
+     }
+ 
+     def mockDmiIsNotAvailableForModuleSync(dmiPlugin, cmHandleId) {
+         mockDmiServer.expect(requestTo("${dmiPlugin}/dmi/v1/ch/${cmHandleId}/modules"))
+                 .andRespond(withStatus(HttpStatus.SERVICE_UNAVAILABLE))
+     }
+ 
+     def overrideCmHandleLastUpdateTime(cmHandleId, newUpdateTime) {
+         String ISO_TIMESTAMP_PATTERN = "yyyy-MM-dd'T'HH:mm:ss.SSSZ";
+         DateTimeFormatter ISO_TIMESTAMP_FORMATTER = DateTimeFormatter.ofPattern(ISO_TIMESTAMP_PATTERN);
+         def jsonForUpdate = '{ "state": { "last-update-time": "%s" } }'.formatted(ISO_TIMESTAMP_FORMATTER.format(newUpdateTime))
+         cpsDataService.updateNodeLeaves(NCMP_DATASPACE_NAME, NCMP_DMI_REGISTRY_ANCHOR,
+                 NCMP_DMI_REGISTRY_PARENT + "/cm-handles[@id='${cmHandleId}']", jsonForUpdate, now)
      }
  }