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;
public void testSaveNewArtifact() {
// daoUploader = new ArtifactUploader(artifactDAO);
if (daoUploader == null) {
- fail();
+ assertTrue(false);
}
String strData = "qweqwqweqw34e4wrwer";
}
- /*
- * @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() {
}
- /*
- * @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());
status = daoUploader.updateArtifact(arData);
assertEquals(status, ResourceUploadStatus.OK);
- // resourceDAO.delete(IndexedNodeType.class, indexedNodeType.getId());
-
}
private ESArtifactData getArtifactData(String componentName, String componentVersion) {
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());
- }
-
}
Code Review / sdc.git / commitdiff