Add dist mode

Issue-ID: VNFSDK-792

Signed-off-by: sharath reddy <bs.reddy@huawei.com>
Change-Id: Ic49782ee2a3d4f23a86e6cf9592bed490b670df2
Signed-off-by: sharath reddy <bs.reddy@huawei.com>

1 files changed, 102 insertions, 7 deletions

diff --git a/vnfmarket-be/vnf-sdk-marketplace/src/test/java/org/onap/vtp/execution/VTPExecutionResourceTest.java b/vnfmarket-be/vnf-sdk-marketplace/src/test/java/org/onap/vtp/execution/VTPExecutionResourceTest.java
index 661f51a1..e558a6bb 100644
--- a/vnfmarket-be/vnf-sdk-marketplace/src/test/java/org/onap/vtp/execution/VTPExecutionResourceTest.java
+++ b/vnfmarket-be/vnf-sdk-marketplace/src/test/java/org/onap/vtp/execution/VTPExecutionResourceTest.java
@@ -19,6 +19,17 @@ import com.google.gson.Gson;
 import com.google.gson.JsonElement;
 import com.google.gson.JsonParser;
 import mockit.MockUp;
+
+import org.apache.http.Header;
+import org.apache.http.HeaderIterator;
+import org.apache.http.HttpEntity;
+import org.apache.http.HttpResponse;
+import org.apache.http.ProtocolVersion;
+import org.apache.http.StatusLine;
+import org.apache.http.client.ClientProtocolException;
+import org.apache.http.client.HttpClient;
+import org.apache.http.client.methods.HttpUriRequest;
+import org.apache.http.params.HttpParams;
 import org.glassfish.jersey.media.multipart.ContentDisposition;
 import org.glassfish.jersey.media.multipart.FormDataBodyPart;
 import org.junit.Before;
@@ -27,15 +38,22 @@ import org.junit.runner.RunWith;
 import org.mockito.Mock;
 import org.mockito.runners.MockitoJUnitRunner;
 import org.onap.vtp.execution.model.VTPTestExecution;
+import org.onap.vtp.manager.DistManager;
+import org.onap.vtp.manager.model.Tester;
 import org.open.infc.grpc.Output;
 import org.open.infc.grpc.Result;
+import org.open.infc.grpc.client.OpenRemoteCli;
 import org.onap.vtp.VTPResource;
 import org.onap.vtp.error.VTPError;
 
 import java.io.IOException;
 import java.util.*;
 
+import javax.ws.rs.client.Client;
+import javax.ws.rs.client.WebTarget;
+
 import static org.junit.Assert.*;
+import static org.mockito.Mockito.mock;
 @RunWith(MockitoJUnitRunner.class)
 public class VTPExecutionResourceTest {
 
@@ -86,6 +104,14 @@ public class VTPExecutionResourceTest {
                 return gson.fromJson(dummyValue,Output.class);
             }
         };
+        new MockUp<VTPResource>(){
+            @mockit.Mock
+            protected Output makeRpc(String testSuite,String scenario, String requestId, String profile, String testCase, JsonElement argsJsonNode) throws VTPError.VTPException {
+                String dummyValue = "{\"execution-id\":\"execution-id\"}";
+                Gson gson = new Gson();
+                return gson.fromJson(dummyValue,Output.class);
+            }
+        };
         new MockUp<Output>(){
             @mockit.Mock
             public Map<String, String> getAddonsMap() {
@@ -140,12 +166,21 @@ public class VTPExecutionResourceTest {
     {
         new MockUp<VTPResource>(){
             @mockit.Mock
-            protected Output makeRpc(String scenario, String requestId, String profile, String testCase, JsonElement argsJsonNode) throws VTPError.VTPException {
+            protected Output makeRpc(String scenario, String requestId, String profile, String testCase,
+                    JsonElement argsJsonNode) throws VTPError.VTPException {
                 String dummyValue = "{\"execution-id\":\"execution-id\"}";
                 Gson gson = new Gson();
-                return gson.fromJson(dummyValue,Output.class);
+                return gson.fromJson(dummyValue, Output.class);
             }
         };
+         new MockUp<VTPResource>(){
+                @mockit.Mock
+                protected Output makeRpc(String testSuite,String scenario, String requestId, String profile, String testCase, JsonElement argsJsonNode) throws VTPError.VTPException {
+                    String dummyValue = "{\"execution-id\":\"execution-id\"}";
+                    Gson gson = new Gson();
+                    return gson.fromJson(dummyValue,Output.class);
+                }
+            };
         new MockUp<Output>(){
             @mockit.Mock
             public Map<String, String> getAddonsMap() {
@@ -168,6 +203,26 @@ public class VTPExecutionResourceTest {
                 return false;
             }
         };
+        new MockUp<OpenRemoteCli>(){
+            @mockit.Mock
+            public Output invoke(String arg0, String arg1, String arg2, Map<String, String> arg3) throws Exception{
+                 String dummyValue = "{\"execution-id\":\"execution-id\"}";
+                 Gson gson = new Gson();
+                 return gson.fromJson(dummyValue,Output.class);
+            }
+        };
+        new MockUp<DistManager>(){
+            @mockit.Mock
+            protected Tester httpRequestTestcase(String testSuite, String scenario, String testCase)  { 
+          Tester tester =  new Tester();
+        tester.setId("1");
+        tester.setIp("localhost");
+        tester.setPort(50051);
+        tester.setTesterId("123");
+        return tester;
+        }
+
+        };
         VTPTestExecution.VTPTestExecutionList executions= new VTPTestExecution.VTPTestExecutionList();
         List<VTPTestExecution> list= new ArrayList<>();
         JsonParser jsonParser = new JsonParser();
@@ -198,7 +253,7 @@ public class VTPExecutionResourceTest {
     public void testListTestExecutionsHandler() throws Exception
     {
         vtpExecutionResource = new VTPExecutionResource();
-        vtpExecutionResource.listTestExecutionsHandler(requestId,"abc","abc","abc","abc","123","123");
+        vtpExecutionResource.listTestExecutionsHandler(requestId,"abc","abc","abc","abc","123","123",1,0);
     }
     @Test
     public void testListTestExecutionsHandlerForGson() throws Exception
@@ -214,8 +269,19 @@ public class VTPExecutionResourceTest {
                 return jsonParser.parse(values);
             }
         };
+        new MockUp<VTPResource>(){
+            @mockit.Mock
+            protected JsonElement makeRpcAndGetJson(List<String> args,int count,int index, int timeout) throws VTPError.VTPException, IOException {
+                String values = "[{\"start-time\":\"start-time\", \"end-time\":\"end-time\", " +
+                        "\"request-id\":\"request-id\", \"product\":\"product\"," +
+                        "\"service\":\"service\", \"command\":\"command\", " +
+                        "\"profile\":\"profile\", \"status\":\"status\", \"execution-id\":\"execution-id\"}]";
+                JsonParser jsonParser = new JsonParser();
+                return jsonParser.parse(values);
+            }
+        };
         vtpExecutionResource = new VTPExecutionResource();
-        assertNotNull(vtpExecutionResource.listTestExecutionsHandler(requestId,"abc","abc","abc","abc","123","123"));
+        assertNotNull(vtpExecutionResource.listTestExecutionsHandler(requestId,"abc","abc","abc","abc","123","123",1,0));
     }
     @Test
     public void testListTestExecutionsHandlerTestmakeRpcAndGetJson() throws Exception
@@ -230,19 +296,48 @@ public class VTPExecutionResourceTest {
                 return result;
             }
         };
+        new MockUp<VTPResource>(){
+            @mockit.Mock
+            protected Result makeRpc(List<String> args,int count,int index) throws VTPError.VTPException {
+                Result result = Result.newBuilder().build();
+                return result;
+            }
+        };
+        new MockUp<VTPResource>(){
+            @mockit.Mock
+            protected JsonElement makeRpcAndGetJson(List<String> args,int count,int index, int timeout) throws VTPError.VTPException {
+                  String values = "[{\"start-time\":\"start-time\", \"end-time\":\"end-time\", " +
+                          "\"request-id\":\"request-id\", \"product\":\"product\"," +
+                          "\"service\":\"service\", \"command\":\"command\", " +
+                          "\"profile\":\"profile\", \"status\":\"status\", \"execution-id\":\"execution-id\"}]";
+                  JsonParser jsonParser = new JsonParser();
+                  return jsonParser.parse(values);
+            }
+        };
+        new MockUp<VTPResource>(){
+            @mockit.Mock
+            protected JsonElement makeRpcAndGetJson(List<String> args,int count,int index) throws VTPError.VTPException {
+                  String values = "[{\"start-time\":\"start-time\", \"end-time\":\"end-time\", " +
+                          "\"request-id\":\"request-id\", \"product\":\"product\"," +
+                          "\"service\":\"service\", \"command\":\"command\", " +
+                          "\"profile\":\"profile\", \"status\":\"status\", \"execution-id\":\"execution-id\"}]";
+                  JsonParser jsonParser = new JsonParser();
+                  return jsonParser.parse(values);
+            }
+        };
         new MockUp<Result>(){
             @mockit.Mock
             public String getOutput() {
-                return "[{\"product\":\"tutorial\"}]";
+                return "{\"product\":\"tutorial\"}";
             }
         };
-        VTPTestExecution.VTPTestExecutionList vtpTestExecutionList = vtpExecutionResource1.listTestExecutionsHandler(requestId,"tutorial","ut","list-users","abc","123","123");
+        VTPTestExecution.VTPTestExecutionList vtpTestExecutionList = vtpExecutionResource1.listTestExecutionsHandler(requestId,"tutorial","ut","list-users","abc","123","123",1,0);
         assertTrue(vtpTestExecutionList.getExecutions().size()>0);
     }
     public void testListTestExecutions() throws Exception
     {
         vtpExecutionResource = new VTPExecutionResource();
-        vtpExecutionResource.listTestExecutions(requestId,"abc","abc","abc","abc","123","123");
+        vtpExecutionResource.listTestExecutions(requestId,"abc","abc","abc","abc","123","123",1,0);
     }
     public void testGetTestExecution() throws Exception
     {