diff options
Diffstat (limited to 'catalog-dao/src/test/java/org/openecomp/sdc/be/resources/ArtifactDaoTest.java')
-rw-r--r-- | catalog-dao/src/test/java/org/openecomp/sdc/be/resources/ArtifactDaoTest.java | 392 |
1 files changed, 2 insertions, 390 deletions
diff --git a/catalog-dao/src/test/java/org/openecomp/sdc/be/resources/ArtifactDaoTest.java b/catalog-dao/src/test/java/org/openecomp/sdc/be/resources/ArtifactDaoTest.java index fe31e39199..dc65d5d236 100644 --- a/catalog-dao/src/test/java/org/openecomp/sdc/be/resources/ArtifactDaoTest.java +++ b/catalog-dao/src/test/java/org/openecomp/sdc/be/resources/ArtifactDaoTest.java @@ -21,9 +21,6 @@ package org.openecomp.sdc.be.resources; import fj.data.Either; -import static org.junit.Assert.fail; -import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest; -import org.elasticsearch.action.admin.indices.delete.DeleteIndexResponse; import org.junit.Test; import org.junit.runner.RunWith; import org.openecomp.sdc.be.config.ConfigurationManager; @@ -70,7 +67,7 @@ public class ArtifactDaoTest extends DAOConfDependentTest { public void testSaveNewArtifact() { // daoUploader = new ArtifactUploader(artifactDAO); if (daoUploader == null) { - fail(); + assertTrue(false); } String strData = "qweqwqweqw34e4wrwer"; @@ -86,111 +83,6 @@ public class ArtifactDaoTest extends DAOConfDependentTest { } - /* - * @Test public void testSaveNewImage(){ - * - * Path iconPath = Paths.get(TEST_IMAGES_DIRECTORY, "apache.png"); - * - * ImageData imageData = new ImageData(); try { - * imageData.setData(Files.readAllBytes(iconPath)); - * imageData.setComponentName("ComponentMarina"); - * imageData.setComponentVersion("v.1.0"); - * imageData.setArtifactName("apache.png"); - * imageData.setResourceCreator("Marina"); - * imageData.setResourceLastUpdater("Marina"); ResourceUploadStatus status = - * daoUploader.saveImage(imageData, true); assertEquals(status, - * ResourceUploadStatus.OK); } catch (IOException e) { e.printStackTrace(); } - * - * - * } - */ - - // @Test - // public void testGetArtifactsList() { - // //daoUploader = new ArtifactUploader(artifactDAO); - // if(daoUploader==null){ - // assertTrue(false); - // } - // String myNodeType = "MyListNodeType"; - // - // - // - // //resourceDAO.save(indexedNodeType); - // - // String strData = "qweqwqweqw34e4wrwer"; - // ESArtifactData arData1 = new ESArtifactData("artifactNewMarina_1", - // strData.getBytes()); - // - // - // ResourceUploadStatus status = daoUploader.saveArtifact(arData1, true); - // assertEquals(status, ResourceUploadStatus.OK); - // - // ESArtifactData arData2 = new ESArtifactData("artifactNewMarina_2", - // strData.getBytes()); - // - // - // status = daoUploader.saveArtifact(arData2, true); - // assertEquals(status, ResourceUploadStatus.OK); - // - // ESArtifactData arData3 = new ESArtifactData("artifactNewMarina_3", - // strData.getBytes()); - // - // - // status = daoUploader.saveArtifact(arData3, true); - // assertEquals(status, ResourceUploadStatus.OK); - // - // - // - // Either<List<ESArtifactData>, ResourceUploadStatus> arrArray = - // daoUploader.getArtifacts(myNodeType, nodeTypeVersion); - // assertTrue(arrArray.isLeft()); - // - // assertEquals(3, arrArray.left().value().size()); - // - // daoUploader.deleteArtifact(arData1.getId()); - // daoUploader.deleteArtifact(arData2.getId()); - // daoUploader.deleteArtifact(arData3.getId()); - // - // //resourceDAO.delete(IndexedNodeType.class, indexedNodeType.getId()); - // - // } - // - - /* - * @Test public void testGetSeviceArtifactsList() { - * - * if(daoUploader==null){ assertTrue(false); } String strData = - * "qweqwqweqw34e4wrwer"; - * - * ServiceArtifactData serviceArData = new - * ServiceArtifactData("serviceArData", topologyTemplateName, - * topologyTemplateVersion, nodeTypeTemplate1, nodeType, nodeTypeVersion, - * "YANG", strData.getBytes(), strData.getBytes(), "Marina", null); - * //serviceArData.setRefArtifactId(arData.getId()); ResourceUploadStatus - * status = daoUploader.saveServiceArtifact(serviceArData, true); - * - * ServiceArtifactData serviceArData1 = new - * ServiceArtifactData("serviceArData1", topologyTemplateName, - * topologyTemplateVersion, nodeTypeTemplate2, nodeType2, nodeTypeVersion2, - * "YANG", strData.getBytes(), strData.getBytes(), "Marina", null); - * //serviceArData1.setRefArtifactId(arData4.getId()); status = - * daoUploader.saveServiceArtifact(serviceArData1, true); - * ServiceArtifactData getServiceData = - * daoUploader.getServiceArtifact(serviceArData.getId()).left().value(); - * - * List<ServiceArtifactData> arrArray = - * daoUploader.getServiceArtifacts(topologyTemplateName, - * topologyTemplateVersion).left().value(); - * - * assertEquals(2, arrArray.size()); - * - * daoUploader.deleteArtifact(serviceArData.getId()); - * daoUploader.deleteArtifact(serviceArData1.getId()); - * - * - * } - */ - @Test public void testGetArtifact() { @@ -210,67 +102,16 @@ public class ArtifactDaoTest extends DAOConfDependentTest { } - /* - * @Test public void testGetSeviceArtifact() { - * - * ServiceArtifactData servArData = getServiceArtifactData(); - * - * Either<ServiceArtifactData, ResourceUploadStatus> - * getServiceArtifactStatus = - * daoUploader.getServiceArtifact("MyService:v.1.1:updatedServiceArtifact"); - * if (!getServiceArtifactStatus.isLeft()){ - * daoUploader.saveServiceArtifact(servArData, true); - * getServiceArtifactStatus = - * daoUploader.getServiceArtifact(servArData.getId()); } - * - * assertNotNull(getServiceArtifactStatus.left().value()); - * - * daoUploader.deleteArtifact(getServiceArtifactStatus.left().value().getId( - * )); - * - * - * } - */ - - /* - * @Test public void testGetSeviceArtifactsCollection() { - * - * prepareTopolgyService(); prepareTestTopolgyService(); - * Either<ServiceArtifactsDataCollection, ResourceUploadStatus> - * getServiceArtifactsCollectionStatus = - * daoUploader.getServiceArtifactsCollection(topologyTemplateName, - * topologyTemplateVersion); ServiceArtifactsDataCollection serviceAtrifacts - * = getServiceArtifactsCollectionStatus.left().value(); - * - * Map<String, List<ArtifactData>> map = - * serviceAtrifacts.getServiceArtifactDataMap(); - * - * List<ArtifactData> list = map.get(nodeType); assertNotNull(list); - * assertEquals(2, list.size()); - * - * - * list = map.get(nodeTypeTemplate1 ); assertNotNull(list); assertEquals(1, - * list.size()); - * - * list = map.get(nodeTypeTemplate2 ); assertNotNull(list); assertEquals(1, - * list.size()); - * - * - * } - */ @Test public void testUpdateArtifact() { - // daoUploader = new ArtifactUploader(artifactDAO); if (daoUploader == null) { - fail(); + fail(); } ResourceUploadStatus status = ResourceUploadStatus.OK; String myNodeType = "MyUpdatedNodeType"; - // resourceDAO.save(indexedNodeType); - ESArtifactData arData = getArtifactData(myNodeType, nodeTypeVersion); Either<ESArtifactData, ResourceUploadStatus> getArtifactStatus = daoUploader.getArtifact(arData.getId()); @@ -283,8 +124,6 @@ public class ArtifactDaoTest extends DAOConfDependentTest { status = daoUploader.updateArtifact(arData); assertEquals(status, ResourceUploadStatus.OK); - // resourceDAO.delete(IndexedNodeType.class, indexedNodeType.getId()); - } private ESArtifactData getArtifactData(String componentName, String componentVersion) { @@ -292,231 +131,4 @@ public class ArtifactDaoTest extends DAOConfDependentTest { return new ESArtifactData("updatedArtifact", strData.getBytes()); } - - /* - * private ServiceArtifactData getServiceArtifactData(){ String strData = - * "qweqwqweqw34e4wrwer"; ServiceArtifactData arData = new - * ServiceArtifactData("updatedServiceArtifact", "MyService", "v.1.1", - * "MyComponentTemplate", "MyComponent", "v.1.1", "YANG", - * strData.getBytes(), strData.getBytes(), "Marina", null); - * - * return arData; } - */ - - /* - * private void prepareTopolgyService(){ - * - * List<String> listCap = new ArrayList<String>(); listCap.add("very_evil"); - * List<String> listCap1 = new ArrayList<String>(); listCap.add("evil"); - * try{ // Initialize test data IndexedNodeType indexedNodeType = new - * IndexedNodeType(); CSARDependency dep = new CSARDependency(); - * dep.setName(nodeType); dep.setVersion(nodeTypeVersion); - * indexedNodeType.setElementId(nodeType); - * indexedNodeType.setArchiveName(nodeType); - * indexedNodeType.setArchiveVersion(nodeTypeVersion); - * indexedNodeType.setCreationDate(new Date()); - * indexedNodeType.setLastUpdateDate(new Date()); - * indexedNodeType.setDefaultCapabilities(listCap); - * resourceDAO.save(indexedNodeType); - * - * - * IndexedNodeType indexedNodeType1 = new IndexedNodeType(); - * indexedNodeType1.setElementId(nodeType2); - * indexedNodeType1.setArchiveName(nodeType2); - * indexedNodeType1.setArchiveVersion(nodeTypeVersion2); CSARDependency dep1 - * = new CSARDependency(); dep1.setName(nodeType2); - * dep1.setVersion(nodeTypeVersion2); indexedNodeType1.setCreationDate(new - * Date()); indexedNodeType1.setLastUpdateDate(new Date()); - * indexedNodeType1.setDefaultCapabilities(listCap1); - * resourceDAO.save(indexedNodeType1); - * - * - * indexedNodeType.setElementId(nodeType3); - * indexedNodeType.setArchiveName(nodeType3); - * indexedNodeType.setArchiveVersion(nodeNypeVersion3); CSARDependency dep2 - * = new CSARDependency(); dep2.setName(nodeType3); - * dep2.setVersion(nodeNypeVersion3); indexedNodeType.setCreationDate(new - * Date()); indexedNodeType.setLastUpdateDate(new Date()); - * indexedNodeType.setDefaultCapabilities(null); - * resourceDAO.save(indexedNodeType); String osgiliath100Id = - * indexedNodeType.getId(); - * - * Topology topology = new Topology(); topology.setId(topologyId); - * Set<CSARDependency> dependencies = new HashSet<CSARDependency>(); - * dependencies.add(dep); dependencies.add(dep2); dependencies.add(dep1); - * topology.setDependencies(dependencies); Map<String, NodeTemplate> - * nodeTemplates = new HashMap <String, NodeTemplate>(); - * - * NodeTemplate template1 = new NodeTemplate(nodeType, null, null, null, - * null, null, null); template1.setName(nodeTypeTemplate1); - * nodeTemplates.put(nodeTypeTemplate1, template1 ); - * - * NodeTemplate template2 = new NodeTemplate(nodeType2, null, null, null, - * null, null, null); template2.setName(nodeTypeTemplate2 ); - * nodeTemplates.put(nodeTypeTemplate2, template2 ); - * - * NodeTemplate template3 = new NodeTemplate(nodeType, null, null, null, - * null, null, null); template3.setName(nodeTypeTemplate3 ); - * nodeTemplates.put(nodeTypeTemplate3, template3); - * - * topology.setNodeTemplates(nodeTemplates); resourceDAO.save(topology); - * - * TopologyTemplate topologyTemplate = new TopologyTemplate(); - * topologyTemplate.setId(topologyTemplateName); - * topologyTemplate.setName(topologyTemplateName); - * topologyTemplate.setTopologyId(topology.getId()); - * topologyTemplate.setDescription("my topology template"); - * resourceDAO.save(topologyTemplate); - * - * String strData = "qweqwqweqw34e4wrwer"; ArtifactData arData = new - * ArtifactData("artifact1", nodeType, nodeTypeVersion, "YANG", - * strData.getBytes(), strData.getBytes(), "Marina"); ArtifactData arData1 = - * new ArtifactData("artifact2", nodeType, nodeTypeVersion, "YANG", - * strData.getBytes(), strData.getBytes(), "Marina"); ResourceUploadStatus - * status = daoUploader.saveArtifact(arData, true); status = - * daoUploader.saveArtifact(arData1, true); - * - * ArtifactData arData3 = new ArtifactData("artifact1", nodeType2, - * nodeTypeVersion2, "YANG", strData.getBytes(), strData.getBytes(), - * "Marina"); status = daoUploader.saveArtifact(arData3, true); - * - * ArtifactData arData4 = new ArtifactData("artifact2", nodeType2, - * nodeTypeVersion2, "YANG", strData.getBytes(), strData.getBytes(), - * "Marina"); status = daoUploader.saveArtifact(arData4, true); - * - * ServiceArtifactData serviceArData = new - * ServiceArtifactData("serviceArData", topologyTemplateName, - * topologyTemplateVersion, nodeTypeTemplate1, nodeType, nodeTypeVersion, - * "YANG", strData.getBytes(), strData.getBytes(), "Marina", - * arData.getId()); - * - * status = daoUploader.saveServiceArtifact(serviceArData, true); - * - * ServiceArtifactData serviceArData1 = new - * ServiceArtifactData("serviceArData1", topologyTemplateName, - * topologyTemplateVersion, nodeTypeTemplate2, nodeType2, nodeTypeVersion2, - * "YANG", strData.getBytes(), strData.getBytes(), "Marina", - * arData4.getId()); - * - * status = daoUploader.saveServiceArtifact(serviceArData1, true); - * - * - * } catch (Exception e) { - * e.printStackTrace(); } - * - * } - * - * private void prepareTestTopolgyService(){ - * - * List<String> listCap = new ArrayList<String>(); - * listCap.add("very_evil test"); List<String> listCap1 = new - * ArrayList<String>(); listCap.add("evil test"); try{ // Initialize test - * data IndexedNodeType indexedNodeType = new IndexedNodeType(); - * CSARDependency dep = new CSARDependency(); dep.setName(nodeType + - * " test"); dep.setVersion(nodeTypeVersion); - * indexedNodeType.setElementId(nodeType + " test"); - * indexedNodeType.setArchiveName(nodeType + " test"); - * indexedNodeType.setArchiveVersion(nodeTypeVersion); - * indexedNodeType.setCreationDate(new Date()); - * indexedNodeType.setLastUpdateDate(new Date()); - * indexedNodeType.setDefaultCapabilities(listCap); - * resourceDAO.save(indexedNodeType); - * - * - * IndexedNodeType indexedNodeType1 = new IndexedNodeType(); - * indexedNodeType1.setElementId(nodeType2 + " test"); - * indexedNodeType1.setArchiveName(nodeType2 + " test"); - * indexedNodeType1.setArchiveVersion(nodeTypeVersion2); CSARDependency dep1 - * = new CSARDependency(); dep1.setName(nodeType2 + " test"); - * dep1.setVersion(nodeTypeVersion2); indexedNodeType1.setCreationDate(new - * Date()); indexedNodeType1.setLastUpdateDate(new Date()); - * indexedNodeType1.setDefaultCapabilities(listCap1); - * resourceDAO.save(indexedNodeType1); - * - * - * indexedNodeType.setElementId(nodeType3 + " test"); - * indexedNodeType.setArchiveName(nodeType3 + " test"); - * indexedNodeType.setArchiveVersion(nodeNypeVersion3); CSARDependency dep2 - * = new CSARDependency(); dep2.setName(nodeType3 + " test"); - * dep2.setVersion(nodeNypeVersion3); indexedNodeType.setCreationDate(new - * Date()); indexedNodeType.setLastUpdateDate(new Date()); - * indexedNodeType.setDefaultCapabilities(null); - * resourceDAO.save(indexedNodeType); String osgiliath100Id = - * indexedNodeType.getId(); - * - * Topology topology = new Topology(); topology.setId(topologyId + " test"); - * Set<CSARDependency> dependencies = new HashSet<CSARDependency>(); - * dependencies.add(dep); dependencies.add(dep2); dependencies.add(dep1); - * topology.setDependencies(dependencies); Map<String, NodeTemplate> - * nodeTemplates = new HashMap <String, NodeTemplate>(); - * - * NodeTemplate template1 = new NodeTemplate(nodeType + " test", null, null, - * null, null, null, null); template1.setName(nodeTypeTemplate1 + " test"); - * nodeTemplates.put(nodeTypeTemplate1 + " test", template1 ); - * - * NodeTemplate template2 = new NodeTemplate(nodeType2 + " test", null, - * null, null, null, null, null); template2.setName(nodeTypeTemplate2 + - * " test" ); nodeTemplates.put(nodeTypeTemplate2 + " test", template2 ); - * - * NodeTemplate template3 = new NodeTemplate(nodeType, null, null, null, - * null, null, null); template3.setName(nodeTypeTemplate3 + " test" ); - * nodeTemplates.put(nodeTypeTemplate3 + " test", template3); - * - * topology.setNodeTemplates(nodeTemplates); resourceDAO.save(topology); - * - * TopologyTemplate topologyTemplate = new TopologyTemplate(); - * topologyTemplate.setId(topologyTemplateName + " test"); - * topologyTemplate.setName(topologyTemplateName + " test"); - * topologyTemplate.setTopologyId(topology.getId()); - * topologyTemplate.setDescription("my topology template"); - * resourceDAO.save(topologyTemplate); - * - * String strData = "qweqwqweqw34e4wrwer"; ArtifactData arData = new - * ArtifactData("artifact1 test", nodeType + " test", nodeTypeVersion, - * "YANG", strData.getBytes(), strData.getBytes(), "Marina"); ArtifactData - * arData1 = new ArtifactData("artifact2 test", nodeType + " test", - * nodeTypeVersion, "YANG", strData.getBytes(), strData.getBytes(), - * "Marina"); ResourceUploadStatus status = daoUploader.saveArtifact(arData, - * true); status = daoUploader.saveArtifact(arData1, true); - * - * ArtifactData arData3 = new ArtifactData("artifact1 test", nodeType2 + - * " test", nodeTypeVersion2, "YANG", strData.getBytes(), - * strData.getBytes(), "Marina"); status = daoUploader.saveArtifact(arData3, - * true); - * - * ArtifactData arData4 = new ArtifactData("artifact2 test", nodeType2 + - * " test", nodeTypeVersion2, "YANG", strData.getBytes(), - * strData.getBytes(), "Marina"); status = daoUploader.saveArtifact(arData4, - * true); - * - * ServiceArtifactData serviceArData = new - * ServiceArtifactData("serviceArData test" , topologyTemplateName + - * " test", topologyTemplateVersion, nodeTypeTemplate1 + " test", nodeType + - * " test", nodeTypeVersion, "YANG", strData.getBytes(), strData.getBytes(), - * "Marina", arData.getId()); - * - * status = daoUploader.saveServiceArtifact(serviceArData, true); - * - * ServiceArtifactData serviceArData1 = new - * ServiceArtifactData("serviceArData1 test", topologyTemplateName + - * " test", topologyTemplateVersion, nodeTypeTemplate2 + " test", nodeType2 - * + " test", nodeTypeVersion2, "YANG", strData.getBytes(), - * strData.getBytes(), "Marina", arData4.getId()); - * - * status = daoUploader.saveServiceArtifact(serviceArData1, true); - * - * - * } catch (Exception e) { - * e.printStackTrace(); } - * - * } - */ - - private void clearIndex(String indexName, Class<?> clazz) throws InterruptedException { - - DeleteIndexResponse actionGet = esclient.getClient().admin().indices().delete(new DeleteIndexRequest(indexName)) - .actionGet(); - assertTrue(actionGet.isAcknowledged()); - } - } |