diff options
author | 2017-02-19 10:28:42 +0200 | |
---|---|---|
committer | 2017-02-19 10:51:01 +0200 | |
commit | 451a3400b76511393c62a444f588a4ed15f4a549 (patch) | |
tree | e4f5873a863d1d3e55618eab48b83262f874719d /distribution-ci/src/main/java/org/openecomp/test/E2eFlows.java | |
parent | 5abfe4e1fb5fae4bbd5fbc340519f52075aff3ff (diff) |
Initial OpenECOMP SDC commit
Change-Id: I0924d5a6ae9cdc161ae17c68d3689a30d10f407b
Signed-off-by: Michael Lando <ml636r@att.com>
Diffstat (limited to 'distribution-ci/src/main/java/org/openecomp/test/E2eFlows.java')
-rw-r--r-- | distribution-ci/src/main/java/org/openecomp/test/E2eFlows.java | 108 |
1 files changed, 108 insertions, 0 deletions
diff --git a/distribution-ci/src/main/java/org/openecomp/test/E2eFlows.java b/distribution-ci/src/main/java/org/openecomp/test/E2eFlows.java new file mode 100644 index 0000000000..521fc21312 --- /dev/null +++ b/distribution-ci/src/main/java/org/openecomp/test/E2eFlows.java @@ -0,0 +1,108 @@ +package org.openecomp.test; + +import org.junit.rules.TestName; + +//import static org.junit.Assert.assertTrue; +// +//import java.util.concurrent.ExecutorService; +//import java.util.concurrent.Executors; +//import java.util.concurrent.Future; +//import java.util.concurrent.TimeUnit; +// +//import org.junit.After; +//import org.junit.Test; +//import org.junit.rules.TestName; +// +//import org.openecomp.sdc.api.IDistributionClient; +//import org.openecomp.sdc.api.notification.IArtifactInfo; +//import org.openecomp.sdc.api.notification.INotificationData; +//import org.openecomp.sdc.api.results.IDistributionClientResult; +//import org.openecomp.sdc.impl.DistributionClientFactory; +//import org.openecomp.sdc.utils.DistributionActionResultEnum; +//import org.openecomp.sdc.be.model.DistributionStatusEnum; +//import org.openecomp.sdc.be.model.Service; +//import org.openecomp.sdc.ci.tests.execute.lifecycle.LCSbaseTest; +//import org.openecomp.sdc.ci.tests.datatypes.http.RestResponse; +////import org.openecomp.sdc.ci.tests.users.UserUtils; +//import org.openecomp.sdc.ci.tests.utils.DbUtils; +//import org.openecomp.sdc.ci.tests.utils.rest.ResponseParser; + +public class E2eFlows { + + + +// private IDistributionClient client = DistributionClientFactory.createDistributionClient(); +// private ExecutorService newSingleThreadExecutor = Executors.newSingleThreadExecutor(); +// +// private CallableTask callableTask; +// private NotificationCallback notifCallback; +// private IArtifactInfo iArtifactInfo; +// + + +// +// @After +// public void after() throws Exception { +// client.stop(); +// Thread.sleep(5000); +// } +// +// // ---------------------------------Success +// // scenario-------------------------------------------------------------------------------- +// +// @Test +// public void distributeService() throws Exception{ +// createServiceReadyForDistribution(); +// //RestResponse changeStateToDISTRIBUTED = serviceUtils.changeDistributionStatus(serviceDetails, "1.0", UserUtils.getGovernorDetails1(), "change", DistributionStatusEnum.DISTRIBUTED); +// //assertTrue("response code is not 200, returned :" + changeStateToDISTRIBUTED.getErrorCode(), changeStateToDISTRIBUTED.getErrorCode() == 200); +// +// } +// @Test +// public void E2E_Success() throws Exception { +// Service service = createServiceReadyForDistribution(); +// +//// clean audit +// DbUtils.cleanAllAudits(); +// +// //Create task to run in BG +// callableTask = new CallableTask(service); +// +// //Run the task in BG +// System.err.println("Executing Task..."); +// Future<Boolean> f = newSingleThreadExecutor.submit(callableTask); +// +// //Wait for task to complete and return with result +// +//// while (!f.isDone()){ +// System.err.println("Waiting for result..."); +// // Thread.sleep(30000); +//// } +// Boolean result = f.get(15, TimeUnit.SECONDS); +// +// System.out.println("future:" + result); +// +// //Check Results +// notifCallback = callableTask.getNotifCallback(); +// +// INotificationData data = notifCallback.getData(); +// +// System.out.println("result map size = "+ notifCallback.getSimpleCallbackResults().size()); +// IDistributionClientResult downloadResult = notifCallback.getSimpleCallbackResults().get("downloadResult"); +// assertTrue("response code is not SUCCESS, returned :"+ downloadResult.getDistributionActionResult(),downloadResult.getDistributionActionResult() == DistributionActionResultEnum.SUCCESS); +// +// } +// +// +// private Service createServiceReadyForDistribution() throws Exception { +//// RestResponse response = LCSbaseTest.certifyService(serviceDetails); +//// assertTrue("response code is not 200, returned :" + response.getErrorCode(), response.getErrorCode() == 200); +//// Service service = ResponseParser.convertServiceResponseToJavaObject(response.getResponse()); +//// +//// RestResponse changeDistributionStateToApprove = serviceUtils.changeDistributionStateToApprove(service,UserUtils.getGovernorDetails1()); +//// assertTrue("response code is not 200, returned :" + changeDistributionStateToApprove.getErrorCode(), changeDistributionStateToApprove.getErrorCode() == 200); +//// service = ResponseParser.convertServiceResponseToJavaObject(changeDistributionStateToApprove.getResponse()); +//// return service; +// return null; +// } + +} |