1 files changed, 115 insertions, 0 deletions
diff --git a/src/main/java/com/att/ecomp/dcae/ci/api/tests/composition/SaveAndSubmitCompositionFullFlowTest.java b/src/main/java/com/att/ecomp/dcae/ci/api/tests/composition/SaveAndSubmitCompositionFullFlowTest.java
new file mode 100644
index 0000000..aaeebdc
--- /dev/null
+++ b/src/main/java/com/att/ecomp/dcae/ci/api/tests/composition/SaveAndSubmitCompositionFullFlowTest.java
@@ -0,0 +1,115 @@
+package com.att.ecomp.dcae.ci.api.tests.composition;
+
+import com.att.ecomp.dcae.ci.api.tests.DcaeRestBaseTest;
+import com.att.ecomp.dcae.ci.utilities.DcaeRestClient;
+import com.aventstack.extentreports.Status;
+import com.google.gson.reflect.TypeToken;
+import org.onap.sdc.dcae.composition.restmodels.CreateMcResponse;
+import org.onap.sdc.dcae.composition.restmodels.CreateVFCMTRequest;
+import org.onap.sdc.dcae.composition.restmodels.MonitoringComponent;
+import org.onap.sdc.dcae.composition.restmodels.sdc.ExternalReferencesMap;
+import org.onap.sdc.dcae.composition.restmodels.sdc.Resource;
+import org.onap.sdc.dcae.composition.restmodels.sdc.ResourceDetailed;
+import org.onap.sdc.dcae.composition.services.Service;
+import org.onap.sdc.dcae.composition.util.DcaeBeConstants;
+import org.openecomp.d2.ci.datatypes.http.RestResponse;
+import org.openecomp.d2.ci.report.ExtentTestActions;
+import org.testng.annotations.BeforeClass;
+import org.testng.annotations.Test;
+
+import java.lang.reflect.Type;
+import java.util.List;
+import java.util.Map;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+public class SaveAndSubmitCompositionFullFlowTest extends DcaeRestBaseTest {
+
+    private Resource baseTemplate = null;
+
+
+    @BeforeClass
+    public void setup() {
+        try {
+            ExtentTestActions.log(Status.INFO, "running before class - find a base template");
+            Resource[] resources = gson.fromJson(DcaeRestClient.getAllMonitoringTemplatesVfcmts().getResponse(), Resource[].class);
+            if (resources.length > 0){
+                baseTemplate = resources[0];
+            }
+        } catch (Exception e) {
+            ExtentTestActions.log(Status.ERROR, e);
+        }
+    }
+
+
+    @Test
+    public void saveAndSubmitCompositionSuccessTest() throws Exception {
+
+        CreateVFCMTRequest request = new CreateVFCMTRequest();
+        // If you crashed here (below) it is because your environment has no Base Monitoring Templates
+        request.setTemplateUuid(baseTemplate.getUuid());
+        Service service = createServiceWithVFiAsSdcDesigner();
+        request.setVfiName(service.getResources().get(0).getResourceInstanceName());
+        request.setServiceUuid(service.getUuid());
+        DcaeRestClient.fillCreateMcRequestMandatoryFields(request);
+
+        RestResponse response = DcaeRestClient.createMc(gson.toJson(request));
+        assertThat(response.getStatusCode())
+                .as("status code")
+                .isEqualTo(200);
+
+        CreateMcResponse mcResponse = gson.fromJson(response.getResponse(), CreateMcResponse.class);
+        ExtentTestActions.log(Status.INFO, "Vfcmt created successfully. About to update composition");
+        String initialUuid =  mcResponse.getVfcmt().getUuid();
+        response = DcaeRestClient.saveComposition(request.getServiceUuid(), request.getVfiName(), initialUuid, gson.toJson(mcResponse.getCdump()));
+        assertThat(response.getStatusCode())
+                .as("status code")
+                .isEqualTo(200);
+
+        ResourceDetailed mc = gson.fromJson(response.getResponse(), ResourceDetailed.class);
+        // the save action should check the mc out then in - promoting the version
+        assertThat(mc.getLifecycleState()).isEqualTo(DcaeBeConstants.LifecycleStateEnum.NOT_CERTIFIED_CHECKIN.name());
+        assertThat(mc.getVersion()).isEqualTo("0.2");
+
+		ExtentTestActions.log(Status.INFO, "About to submit the composition");
+        response = DcaeRestClient.submitComposition(request.getServiceUuid(), request.getVfiName(), mc.getUuid());
+		assertThat(response.getStatusCode())
+				.as("status code")
+				.isEqualTo(200);
+		// the submit action should certify the mc.
+		ExtentTestActions.log(Status.INFO, "Save new composition version after submit");
+		response = DcaeRestClient.saveComposition(request.getServiceUuid(), request.getVfiName(), initialUuid, gson.toJson(mcResponse.getCdump()));
+		assertThat(response.getStatusCode())
+				.as("status code")
+				.isEqualTo(200);
+		// the save action should promote the mc version to 1.1 and create a new reference to it - both references should be kept at this point
+		mc = gson.fromJson(response.getResponse(), ResourceDetailed.class);
+		assertThat(mc.getLifecycleState()).isEqualTo(DcaeBeConstants.LifecycleStateEnum.NOT_CERTIFIED_CHECKIN.name());
+		assertThat(mc.getVersion()).isEqualTo("1.1");
+
+		response = DcaeRestClient.getServiceExternalReferences(service.getUuid(), service.getVersion());
+		assertThat(response.getStatusCode())
+				.as("status code")
+				.isEqualTo(200);
+		ExtentTestActions.log(Status.INFO, "Verify service vfi has references to both mc versions");
+		Type typeToken = new TypeToken<Map<String, List<MonitoringComponent>>>(){}.getType();
+		Map<String, List<MonitoringComponent>> monitoringComponents = gson.fromJson(response.getResponse(), typeToken);
+		assertThat(monitoringComponents.get("monitoringComponents").size()).isEqualTo(2);
+		ExtentTestActions.log(Status.INFO, "About to re-submit the composition");
+		response = DcaeRestClient.submitComposition(request.getServiceUuid(), request.getVfiName(), mc.getUuid());
+		assertThat(response.getStatusCode())
+				.as("status code")
+				.isEqualTo(200);
+		// a successful submission of the new version should result in the deletion of the previous reference
+		response = DcaeRestClient.getServiceExternalReferences(service.getUuid(), service.getVersion());
+		assertThat(response.getStatusCode())
+				.as("status code")
+				.isEqualTo(200);
+		monitoringComponents = gson.fromJson(response.getResponse(), typeToken);
+		List<MonitoringComponent> mcList = monitoringComponents.get("monitoringComponents");
+		assertThat(mcList.size()).isEqualTo(1);
+		assertThat(mcList.get(0).getUuid()).isEqualTo(mc.getUuid());
+
+    }
+
+}