Metadata for name, version, tags and type

[ccsdk/cds.git] / ms / blueprintsprocessor / modules / commons / db-lib / src / test / kotlin / org / onap / ccsdk / cds / blueprintsprocessor / db / BlueprintProcessorCatalogServiceImplTest.kt

diff --git a/ms/blueprintsprocessor/modules/commons/db-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/db/BlueprintProcessorCatalogServiceImplTest.kt b/ms/blueprintsprocessor/modules/commons/db-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/db/BlueprintProcessorCatalogServiceImplTest.kt
index 2fda159..5d546c2 100644 (file)
--- a/ms/blueprintsprocessor/modules/commons/db-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/db/BlueprintProcessorCatalogServiceImplTest.kt
+++ b/ms/blueprintsprocessor/modules/commons/db-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/db/BlueprintProcessorCatalogServiceImplTest.kt
@@ -1,6 +1,8 @@
 /*
  * Copyright (C) 2019 Bell Canada.
  *
+ * Copyright (C) 2019 IBM, Bell Canada.
+ *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
@@ -18,30 +20,60 @@ package org.onap.ccsdk.cds.blueprintsprocessor.db
 import kotlinx.coroutines.runBlocking
 import org.junit.Test
 import org.junit.runner.RunWith
+import org.onap.ccsdk.cds.blueprintsprocessor.core.BluePrintCoreConfiguration
+import org.onap.ccsdk.cds.blueprintsprocessor.db.mock.MockBlueprintProcessorCatalogServiceImpl
+import org.onap.ccsdk.cds.blueprintsprocessor.db.primary.service.BlueprintCatalogServiceImpl
+import org.onap.ccsdk.cds.blueprintsprocessor.db.primary.service.BlueprintProcessorCatalogServiceImpl
+import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintConstants
+import org.onap.ccsdk.cds.controllerblueprints.core.compress
 import org.onap.ccsdk.cds.controllerblueprints.core.deleteDir
-import org.onap.ccsdk.cds.controllerblueprints.core.interfaces.BluePrintCatalogService
 import org.onap.ccsdk.cds.controllerblueprints.core.normalizedFile
+import org.onap.ccsdk.cds.controllerblueprints.core.service.BluePrintRuntimeService
+import org.onap.ccsdk.cds.controllerblueprints.core.utils.BluePrintMetadataUtils
 import org.springframework.beans.factory.annotation.Autowired
 import org.springframework.boot.autoconfigure.EnableAutoConfiguration
 import org.springframework.context.annotation.ComponentScan
+import org.springframework.test.context.ContextConfiguration
 import org.springframework.test.context.TestPropertySource
 import org.springframework.test.context.junit4.SpringRunner
+import java.io.File
 import kotlin.test.AfterTest
 import kotlin.test.BeforeTest
 import kotlin.test.assertTrue
 
 @RunWith(SpringRunner::class)
 @EnableAutoConfiguration
-@ComponentScan(basePackages = ["org.onap.ccsdk.cds.blueprintsprocessor", "org.onap.ccsdk.cds.controllerblueprints"])
+@ComponentScan(basePackages = ["org.onap.ccsdk.cds.blueprintsprocessor"])
+@ContextConfiguration(
+    classes = [BlueprintProcessorCatalogServiceImpl::class, BluePrintCoreConfiguration::class,
+        MockBlueprintProcessorCatalogServiceImpl::class]
+)
 @TestPropertySource(locations = ["classpath:application-test.properties"])
 class BlueprintProcessorCatalogServiceImplTest {
 
     @Autowired
-    lateinit var blueprintCatalog: BluePrintCatalogService
+    lateinit var blueprintsProcessorCatalogService: BlueprintCatalogServiceImpl
+
+    @Autowired
+    lateinit var blueprintCoreConfiguration: BluePrintCoreConfiguration
+
+    private lateinit var bluePrintRuntimeService: BluePrintRuntimeService<*>
+
+    private val blueprintId = "1234"
 
     @BeforeTest
     fun setup() {
+
         deleteDir("target", "blueprints")
+
+        // Create sample CBA zip
+        normalizedFile("./../../../../../components/model-catalog/blueprint-model/test-blueprint/baseconfiguration")
+            .compress(normalizedFile("./target/blueprints/generated-cba.zip"))
+
+        bluePrintRuntimeService = BluePrintMetadataUtils.bluePrintRuntime(
+            blueprintId,
+            "./../../../../../components/model-catalog/blueprint-model/test-blueprint/baseconfiguration"
+        )
     }
 
     @AfterTest
@@ -51,18 +83,56 @@ class BlueprintProcessorCatalogServiceImplTest {
 
     @Test
     fun `test catalog service`() {
-        runBlocking {
-            //FIXME("Create ZIP from test blueprints")
 
-            val file = normalizedFile("./src/test/resources/test-cba.zip")
+        runBlocking {
+            val file = normalizedFile("./target/blueprints/generated-cba.zip")
             assertTrue(file.exists(), "couldn't get file ${file.absolutePath}")
 
-            blueprintCatalog.saveToDatabase("1234", file)
+            blueprintsProcessorCatalogService.saveToDatabase("1234", file)
+            blueprintsProcessorCatalogService.getFromDatabase("baseconfiguration", "1.0.0")
+
+            blueprintsProcessorCatalogService.deleteFromDatabase("baseconfiguration", "1.0.0")
+        }
+    }
+
+    @Test
+    fun `test save function`() {
+        runBlocking {
+            val file = normalizedFile("./target/blueprints/generated-cba.zip")
+            assertTrue(file.exists(), "couldnt get file ${file.absolutePath}")
+            val metadata = bluePrintRuntimeService.bluePrintContext().metadata!!
+            metadata[BluePrintConstants.PROPERTY_BLUEPRINT_PROCESS_ID] = blueprintId
 
-            blueprintCatalog.getFromDatabase("baseconfiguration", "1.0.0")
+            blueprintsProcessorCatalogService.save(metadata, file)
+        }
+    }
 
-            blueprintCatalog.deleteFromDatabase("baseconfiguration", "1.0.0")
+    @Test
+    fun `test get function`() {
+        runBlocking {
+            val file = normalizedFile("./target/blueprints/generated-cba.zip")
+            assertTrue(file.exists(), "couldnt get file ${file.absolutePath}")
+            val metadata = bluePrintRuntimeService.bluePrintContext().metadata!!
+            metadata[BluePrintConstants.PROPERTY_BLUEPRINT_PROCESS_ID] = blueprintId
 
+            blueprintsProcessorCatalogService.save(metadata, file)
+            blueprintsProcessorCatalogService.get("baseconfiguration", "1.0.0", true)
+        }
+
+        assertTrue(
+            File(
+                blueprintCoreConfiguration.bluePrintLoadConfiguration().blueprintArchivePath +
+                    "/baseconfiguration"
+            ).deleteRecursively(), "Couldn't get blueprint archive " +
+                "${blueprintCoreConfiguration.bluePrintLoadConfiguration().blueprintArchivePath}/baseconfiguration " +
+                "from data base."
+        )
+    }
+
+    @Test
+    fun `test delete function`() {
+        runBlocking {
+            blueprintsProcessorCatalogService.delete("baseconfiguration", "1.0.0")
         }
     }
-}
\ No newline at end of file
+}