Refactored Delete SchemaSet functionality
[cps.git] / cps-service / src / test / groovy / org / onap / cps / api / impl / E2ENetworkSliceSpec.groovy
index aa54a99..d18bcf5 100755 (executable)
@@ -1,7 +1,8 @@
-/*-\r
+/*\r
  * ============LICENSE_START=======================================================\r
- *  Copyright (C) 2021 Nordix Foundation. All rights reserved.\r
- *  Modifications Copyright (C) 2021 Bell Canada.\r
+ * Copyright (C) 2021 Nordix Foundation.\r
+ * Modifications Copyright (C) 2021-2022 Bell Canada.\r
+ * Modifications Copyright (C) 2021 Pantheon.tech\r
  * ================================================================================\r
  * Licensed under the Apache License, Version 2.0 (the "License");\r
  * you may not use this file except in compliance with the License.\r
@@ -23,6 +24,7 @@ package org.onap.cps.api.impl
 \r
 import org.onap.cps.TestUtils\r
 import org.onap.cps.api.CpsAdminService\r
+import org.onap.cps.notification.NotificationService\r
 import org.onap.cps.spi.CpsDataPersistenceService\r
 import org.onap.cps.spi.CpsModulePersistenceService\r
 import org.onap.cps.spi.model.Anchor\r
@@ -34,20 +36,22 @@ class E2ENetworkSliceSpec extends Specification {
     def mockModuleStoreService = Mock(CpsModulePersistenceService)\r
     def mockDataStoreService = Mock(CpsDataPersistenceService)\r
     def mockCpsAdminService = Mock(CpsAdminService)\r
-    def cpsModuleServiceImpl = new CpsModuleServiceImpl()\r
-    def cpsDataServiceImple = new CpsDataServiceImpl()\r
+    def mockNotificationService = Mock(NotificationService)\r
+    def cpsDataServiceImpl = new CpsDataServiceImpl()\r
     def mockYangTextSchemaSourceSetCache = Mock(YangTextSchemaSourceSetCache)\r
+    def cpsModuleServiceImpl = new CpsModuleServiceImpl(mockModuleStoreService,\r
+            mockYangTextSchemaSourceSetCache,mockCpsAdminService )\r
 \r
     def dataspaceName = 'someDataspace'\r
     def anchorName = 'someAnchor'\r
     def schemaSetName = 'someSchemaSet'\r
+    def noTimestamp = null\r
 \r
     def setup() {\r
-        cpsDataServiceImple.cpsDataPersistenceService = mockDataStoreService\r
-        cpsDataServiceImple.cpsAdminService = mockCpsAdminService\r
-        cpsDataServiceImple.yangTextSchemaSourceSetCache = mockYangTextSchemaSourceSetCache\r
-        cpsModuleServiceImpl.yangTextSchemaSourceSetCache = mockYangTextSchemaSourceSetCache\r
-        cpsModuleServiceImpl.cpsModulePersistenceService = mockModuleStoreService\r
+        cpsDataServiceImpl.cpsDataPersistenceService = mockDataStoreService\r
+        cpsDataServiceImpl.cpsAdminService = mockCpsAdminService\r
+        cpsDataServiceImpl.yangTextSchemaSourceSetCache = mockYangTextSchemaSourceSetCache\r
+        cpsDataServiceImpl.notificationService = mockNotificationService\r
     }\r
 \r
     def 'E2E model can be parsed by CPS.'() {\r
@@ -88,7 +92,7 @@ class E2ENetworkSliceSpec extends Specification {
                     YangTextSchemaSourceSetBuilder.of(yangResourcesNameToContentMap)\r
             mockModuleStoreService.getYangSchemaResources(dataspaceName, schemaSetName) >> schemaContext\r
         when: 'saveData method is invoked'\r
-            cpsDataServiceImple.saveData(dataspaceName, anchorName, jsonData)\r
+            cpsDataServiceImpl.saveData(dataspaceName, anchorName, jsonData, noTimestamp)\r
         then: 'Parameters are validated and processing is delegated to persistence service'\r
             1 * mockDataStoreService.storeDataNode('someDataspace', 'someAnchor', _) >>\r
                     { args -> dataNodeStored = args[2]}\r
@@ -120,7 +124,7 @@ class E2ENetworkSliceSpec extends Specification {
             mockYangTextSchemaSourceSetCache.get('someDataspace', 'someSchemaSet') >> YangTextSchemaSourceSetBuilder.of(yangResourcesNameToContentMap)\r
             mockModuleStoreService.getYangSchemaResources('someDataspace', 'someSchemaSet') >> schemaContext\r
         when: 'saveData method is invoked'\r
-            cpsDataServiceImple.saveData('someDataspace', 'someAnchor', jsonData)\r
+            cpsDataServiceImpl.saveData('someDataspace', 'someAnchor', jsonData, noTimestamp)\r
         then: 'parameters are validated and processing is delegated to persistence service'\r
             1 * mockDataStoreService.storeDataNode('someDataspace', 'someAnchor', _) >>\r
                     { args -> dataNodeStored = args[2]}\r