Grpc controller

jdk_8_maven/cs/rpc/grpc/artificial/grpc-ncs/pom.xml

@@ -67,7 +67,24 @@
                     </execution>
                 </executions>
             </plugin>
+
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>repackage</goal>
+                        </goals>
+                        <configuration>
+                            <finalName>rpc-grpc-ncs</finalName>
+                            <classifier>sut</classifier>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+
         </plugins>
     </build>
 
-</project>
+</project>

jdk_8_maven/cs/rpc/grpc/artificial/grpc-ncs/src/main/java/org/grpc/ncs/NcsServer.java

@@ -15,12 +15,6 @@
  */
 public class NcsServer {
 
-//    public static void main(String[] args) throws IOException, InterruptedException {
-//        Server server = ServerBuilder.forPort(8080).addService(new NcsServiceImplBaseImpl()).build();
-//        server.start();
-//        server.awaitTermination();
-//    }
-
     private static final Logger logger = Logger.getLogger(NcsServer.class.getName());
 
     private final int port;
@@ -38,7 +32,7 @@ public NcsServer(ServerBuilder<?> serverBuilder, int port) {
 
     public void start() throws IOException {
         server.start();
-        logger.info("Server started, listening on " + port);
+        logger.info("NcsServer started, listening on " + port);
         Runtime.getRuntime().addShutdownHook(new Thread() {
             @Override
             public void run() {
@@ -66,7 +60,15 @@ void blockUntilShutdown() throws InterruptedException {
     }
 
     public static void main(String[] args) throws Exception {
-        NcsServer server = new NcsServer(8980);
+        int sutPort = 8980;
+        if (args.length == 1){
+            try{
+                sutPort = Integer.parseInt(args[0]);
+            }catch (Exception NumberFormatException){
+
+            }
+        }
+        NcsServer server = new NcsServer(sutPort);
         server.start();
         server.blockUntilShutdown();
     }

jdk_8_maven/cs/rpc/grpc/artificial/grpc-scs/pom.xml

@@ -66,6 +66,23 @@
                     </execution>
                 </executions>
             </plugin>
+
+
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>repackage</goal>
+                        </goals>
+                        <configuration>
+                            <finalName>rpc-grpc-scs</finalName>
+                            <classifier>sut</classifier>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
         </plugins>
     </build>
-</project>
+</project>

jdk_8_maven/cs/rpc/grpc/artificial/grpc-scs/src/main/java/org/grpc/scs/ScsServer.java

@@ -15,12 +15,6 @@
  */
 public class ScsServer {
 
-//    public static void main(String[] args) throws IOException, InterruptedException {
-//        Server server = ServerBuilder.forPort(8080).addService(new NcsServiceImplBaseImpl()).build();
-//        server.start();
-//        server.awaitTermination();
-//    }
-
     private static final Logger logger = Logger.getLogger(ScsServer.class.getName());
 
     private final int port;
@@ -38,7 +32,7 @@ public ScsServer(ServerBuilder<?> serverBuilder, int port) {
 
     public void start() throws IOException {
         server.start();
-        logger.info("Server started, listening on " + port);
+        logger.info("ScsServer started, listening on " + port);
         Runtime.getRuntime().addShutdownHook(new Thread() {
             @Override
             public void run() {
@@ -66,7 +60,16 @@ void blockUntilShutdown() throws InterruptedException {
     }
 
     public static void main(String[] args) throws Exception {
-        ScsServer server = new ScsServer(8980);
+        int sutPort = 8980;
+        if (args.length == 1){
+            try{
+                sutPort = Integer.parseInt(args[0]);
+            }catch (Exception NumberFormatException){
+
+            }
+        }
+
+        ScsServer server = new ScsServer(sutPort);
         server.start();
         server.blockUntilShutdown();
     }

jdk_8_maven/em/embedded/grpc/ncs/pom.xml

@@ -0,0 +1,24 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.evomaster</groupId>
+        <artifactId>evomaster-benchmark-em-embedded-grpc</artifactId>
+        <version>1.6.2-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>evomaster-benchmark-em-embedded-grpc-ncs</artifactId>
+    <packaging>jar</packaging>
+
+
+    <dependencies>
+        <dependency>
+            <groupId>org.evomaster</groupId>
+            <artifactId>evomaster-benchmark-cs-rpc-grpc-artificial-ncs</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+    </dependencies>
+
+</project>

jdk_8_maven/em/embedded/grpc/ncs/src/main/java/em/embedded/org/grpcncs/EmbeddedEvoMasterController.java

@@ -0,0 +1,129 @@
+package em.embedded.org.grpcncs;
+
+import io.grpc.*;
+import org.evomaster.client.java.controller.EmbeddedSutController;
+import org.evomaster.client.java.controller.InstrumentedSutStarter;
+import org.evomaster.client.java.controller.api.dto.AuthenticationDto;
+import org.evomaster.client.java.controller.api.dto.SutInfoDto;
+import org.evomaster.client.java.controller.api.dto.problem.rpc.RPCType;
+import org.evomaster.client.java.controller.internal.db.DbSpecification;
+import org.evomaster.client.java.controller.problem.ProblemInfo;
+import org.evomaster.client.java.controller.problem.RPCProblem;
+import org.grpc.ncs.NcsServiceImplBaseImpl;
+import org.grpc.ncs.generated.NcsServiceGrpc;
+
+import java.io.IOException;
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+
+public class EmbeddedEvoMasterController extends EmbeddedSutController {
+
+    public static void main(String[] args) {
+
+        int port = 40100;
+        if (args.length > 0) {
+            port = Integer.parseInt(args[0]);
+        }
+
+        EmbeddedEvoMasterController controller = new EmbeddedEvoMasterController(port);
+        InstrumentedSutStarter starter = new InstrumentedSutStarter(controller);
+
+        starter.start();
+    }
+
+    public EmbeddedEvoMasterController() {
+        this(40100);
+    }
+
+    public EmbeddedEvoMasterController(int port) {
+        registeredService = new NcsServiceImplBaseImpl();
+        setControllerPort(port);
+    }
+
+
+
+    protected ManagedChannel channel;
+    private Server server;
+
+    private NcsServiceGrpc.NcsServiceBlockingStub stub;
+
+    private final BindableService registeredService;
+
+    @Override
+    public boolean isSutRunning() {
+        return server != null && !server.isShutdown() && !server.isTerminated();
+    }
+
+    @Override
+    public String getPackagePrefixesToCover() {
+        return "org.grpc.ncs.";
+    }
+
+    @Override
+    public List<AuthenticationDto> getInfoForAuthentication() {
+        return null;
+    }
+
+    @Override
+    public ProblemInfo getProblemInfo() {
+        return new RPCProblem(NcsServiceGrpc.NcsServiceBlockingStub.class, stub, RPCType.gRPC);
+    }
+
+    @Override
+    public SutInfoDto.OutputFormat getPreferredOutputFormat() {
+        return SutInfoDto.OutputFormat.JAVA_JUNIT_4;
+    }
+
+    @Override
+    public String startSut() {
+
+        try {
+            server = ServerBuilder.forPort(0).addService(registeredService).build();
+            server.start();
+
+            startClient();
+            return "http://localhost:"+server.getPort();
+
+        } catch (IOException e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    private String startClient() {
+        channel = ManagedChannelBuilder.forAddress("localhost", getSutPort()).usePlaintext().build();
+        stub = NcsServiceGrpc.newBlockingStub(channel);
+
+
+        return "started:"+!(channel.isShutdown() || channel.isTerminated());
+    }
+
+    protected int getSutPort() {
+        return server.getPort();
+    }
+
+    @Override
+    public void stopSut() {
+
+        try {
+            if (channel != null)
+                channel.shutdown().awaitTermination(2, TimeUnit.SECONDS);
+            if (server != null)
+                server.shutdown().awaitTermination(2, TimeUnit.SECONDS);
+
+            server = null;
+        } catch (InterruptedException e) {
+            throw new RuntimeException(e);
+        }
+
+    }
+
+    @Override
+    public void resetStateOfSUT() {
+
+    }
+
+    @Override
+    public List<DbSpecification> getDbSpecifications() {
+        return null;
+    }
+}

jdk_8_maven/em/embedded/grpc/pom.xml

@@ -0,0 +1,19 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.evomaster</groupId>
+        <artifactId>evomaster-benchmark-em-embedded</artifactId>
+        <version>1.6.2-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>evomaster-benchmark-em-embedded-grpc</artifactId>
+    <packaging>pom</packaging>
+    <modules>
+        <module>ncs</module>
+        <module>scs</module>
+    </modules>
+
+</project>

jdk_8_maven/em/embedded/grpc/scs/pom.xml

@@ -0,0 +1,24 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.evomaster</groupId>
+        <artifactId>evomaster-benchmark-em-embedded-grpc</artifactId>
+        <version>1.6.2-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>evomaster-benchmark-em-embedded-grpc-scs</artifactId>
+    <packaging>jar</packaging>
+
+
+    <dependencies>
+        <dependency>
+            <groupId>org.evomaster</groupId>
+            <artifactId>evomaster-benchmark-cs-rpc-grpc-artificial-scs</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+    </dependencies>
+
+</project>