chore: Start and stop the connector server

Author: TimothyJones

src/main/java/io/contract_testing/contractcase/ContractCaseCoreError.java

@@ -30,6 +30,15 @@ public ContractCaseCoreError(Throwable e) {
     }
   }
 
+  public ContractCaseCoreError(@NotNull String message, Throwable cause) {
+    super(message, cause);
+    if (cause instanceof ContractCaseCoreError) {
+      this.location = ((ContractCaseCoreError) cause).getLocation();
+    } else {
+      this.location = ConnectorExceptionMapper.stackTraceToString(cause);
+    }
+  }
+
   public String getLocation() {
     return location;
   }

src/main/java/io/contract_testing/contractcase/ContractDefiner.java

@@ -3,6 +3,7 @@
 import io.contract_testing.contractcase.IndividualFailedTestConfig.IndividualFailedTestConfigBuilder;
 import io.contract_testing.contractcase.case_example_mock_types.mocks.base.AnyMockDescriptor;
 import io.contract_testing.contractcase.client.InternalDefinerClient;
+import io.contract_testing.contractcase.client.server.ContractCaseProcess;
 import org.jetbrains.annotations.NotNull;
 
 public class ContractDefiner {
@@ -12,6 +13,8 @@ public class ContractDefiner {
 
 
   public ContractDefiner(final @NotNull ContractCaseConfig config) {
+    ContractCaseProcess.getInstance().start();
+    
     LogPrinter logPrinter = new LogPrinter();
     InternalDefinerClient definer = null;
     try {

src/main/java/io/contract_testing/contractcase/ContractVerifier.java

@@ -5,6 +5,7 @@
 
 import io.contract_testing.contractcase.client.InternalVerifierClient;
 import io.contract_testing.contractcase.client.MaintainerLog;
+import io.contract_testing.contractcase.client.server.ContractCaseProcess;
 import io.contract_testing.contractcase.edge.ConnectorExceptionMapper;
 import io.contract_testing.contractcase.edge.ConnectorFailure;
 import io.contract_testing.contractcase.edge.ConnectorFailureKindConstants;
@@ -16,14 +17,15 @@
 import java.util.List;
 import org.jetbrains.annotations.NotNull;
 
-public class ContractVerifier {
+public class ContractVerifier implements AutoCloseable {
 
   private final InternalVerifierClient verifier;
 
   private final List<ConnectorFailure> failures = new ArrayList<>();
 
   public ContractVerifier(ContractCaseConfig config) {
     LogPrinter logPrinter = new LogPrinter();
+    ContractCaseProcess.getInstance().start();
 
     InternalVerifierClient verification = null;
     try {
@@ -108,4 +110,9 @@ public void runVerification(ContractCaseConfig configOverrides) {
 
     }
   }
+
+  @Override
+  public void close() {
+    verifier.close();
+  }
 }

src/main/java/io/contract_testing/contractcase/client/AbstractRpcConnector.java

@@ -5,6 +5,7 @@
 import com.google.protobuf.StringValue;
 import io.contract_testing.contractcase.ContractCaseCoreError;
 import io.contract_testing.contractcase.LogPrinter;
+import io.contract_testing.contractcase.client.server.ContractCaseProcess;
 import io.contract_testing.contractcase.edge.ConnectorFailure;
 import io.contract_testing.contractcase.edge.ConnectorFailureKindConstants;
 import io.contract_testing.contractcase.edge.ConnectorResult;
@@ -29,9 +30,7 @@
 
 abstract class AbstractRpcConnector<T extends AbstractMessage, B extends Builder<B>> {
 
-  private static final int DEFAULT_PORT = 50200;
-
-  private final ConcurrentMap<String, CompletableFuture<BoundaryResult>> responseFutures = new ConcurrentHashMap<String, CompletableFuture<BoundaryResult>>();
+  private final ConcurrentMap<String, CompletableFuture<BoundaryResult>> responseFutures = new ConcurrentHashMap<>();
   private final AtomicInteger nextId = new AtomicInteger();
   private final SendingWorker<T> worker;
   private Status errorStatus;
@@ -46,8 +45,7 @@ public AbstractRpcConnector(
       @NotNull ConfigHandle configHandle,
       @NotNull RunTestCallback runTestCallback) {
     this.channel = ManagedChannelBuilder
-        // TODO: Allow configuration of the port
-        .forAddress("localhost", DEFAULT_PORT)
+        .forAddress("localhost", ContractCaseProcess.getInstance().getPortNumber())
         .usePlaintext()
         .build();
     this.worker = new SendingWorker<T>(createConnection(

src/main/java/io/contract_testing/contractcase/client/InternalVerifierClient.java

@@ -12,7 +12,7 @@
 import java.util.List;
 import org.jetbrains.annotations.NotNull;
 
-public class InternalVerifierClient {
+public class InternalVerifierClient implements AutoCloseable {
 
   private final List<String> parentVersions;
   private final RpcForVerification rpcConnector;
@@ -74,5 +74,8 @@ private ConnectorResult begin(ContractCaseConfig wireConfig) {
             .build()), "begin");
   }
 
-
+  @Override
+  public void close() {
+    rpcConnector.close();
+  }
 }

src/main/java/io/contract_testing/contractcase/client/MaintainerLog.java

@@ -2,9 +2,20 @@
 
 public class MaintainerLog {
 
+  private MaintainerLog() {
+  }
+
   public static final String CONTRACT_CASE_JAVA_WRAPPER = "ContractCase Java DSL";
 
+  public static boolean shouldDebug() {
+    final String caseConnectorDebug = System.getenv("CASE_CONNECTOR_DEBUG");
+    return caseConnectorDebug != null && !caseConnectorDebug.equals("0")
+        && !caseConnectorDebug.equalsIgnoreCase("false") && !caseConnectorDebug.equals("");
+  }
+
   public static void log(String s) {
-    // System.err.println(Thread.currentThread() + ": " + s);
+    if (shouldDebug()) {
+      System.err.println(Thread.currentThread() + ": " + s);
+    }
   }
 }

src/main/java/io/contract_testing/contractcase/client/RpcForVerification.java

@@ -47,5 +47,6 @@ VerificationRequest.Builder makeInvokeTest(StringValue invokerId) {
         );
   }
 
+
 }