feat: Add ContractVerifier

Author: TimothyJones

contractcase/src/main/java/io/contracttesting/contractcase/BoundaryConfigMapper.java

@@ -2,12 +2,63 @@
 
 import io.contract_testing.contractcase.case_boundary.ContractCaseBoundaryConfig;
 import io.contract_testing.contractcase.case_boundary.UserNamePassword;
+import org.jetbrains.annotations.NotNull;
 
 class BoundaryConfigMapper {
 
+  static <T> ContractCaseBoundaryConfig mapSuccessExample(
+      final IndividualSuccessTestConfig<T> config,
+      final String testRunId) {
+    var builder = makeBuilder(config, testRunId);
+
+    if (config.trigger != null) {
+      if (config.testResponse != null) {
+        builder.triggerAndTest(BoundaryTriggerMapper.map(config.trigger, config.testResponse));
+      } else {
+        throw new ContractCaseConfigurationError(
+            "Must specify `testResponse` if you are specifying a `trigger`");
+      }
+    } else {
+      if (config.testResponse != null) {
+        throw new ContractCaseConfigurationError(
+            "Must specify `trigger` if you are specifying a `testResponse` function");
+      }
+    }
+
+    return builder.build();
+  }
+
+  public static <T> ContractCaseBoundaryConfig mapFailingExample(
+      IndividualFailedTestConfig<T> config,
+      String testRunId) {
+    var builder = makeBuilder(config, testRunId);
+
+    if (config.trigger != null) {
+      if (config.testErrorResponse != null) {
+        builder.triggerAndTest(BoundaryTriggerMapper.map(config.trigger, config.testErrorResponse));
+      } else {
+        throw new ContractCaseConfigurationError(
+            "Must specify `testErrorResponse` if you are specifying a `trigger`");
+      }
+    } else {
+      if (config.testErrorResponse != null) {
+        throw new ContractCaseConfigurationError(
+            "Must specify `trigger` if you are specifying a `testErrorResponse` function");
+      }
+    }
+    
+    return builder.build();
+  }
+
   static ContractCaseBoundaryConfig map(final ContractCaseConfig config,
       final String testRunId) {
 
+    return makeBuilder(config, testRunId).build();
+  }
+
+  @NotNull
+  private static ContractCaseBoundaryConfig.Builder makeBuilder(ContractCaseConfig config,
+      String testRunId) {
     var builder = ContractCaseBoundaryConfig.builder().testRunId(testRunId);
 
     if (config.brokerBaseUrl != null) {
@@ -66,9 +117,10 @@ static ContractCaseBoundaryConfig map(final ContractCaseConfig config,
     if (config.stateHandlers != null) {
       builder.stateHandlers(BoundaryStateHandlerMapper.map(config.stateHandlers));
     }
-
-    return builder.build();
+    return builder;
   }
+
+
 }
 
 

contractcase/src/main/java/io/contracttesting/contractcase/ContractCaseConfigurationError.java

@@ -1,11 +1,20 @@
 package io.contracttesting.contractcase;
 
+import java.util.Arrays;
+import java.util.stream.Collectors;
 import org.jetbrains.annotations.NotNull;
 
 public class ContractCaseConfigurationError extends RuntimeException {
 
   private final String location;
 
+  public ContractCaseConfigurationError(@NotNull String message) {
+    super(message);
+    this.location = Arrays.stream(Thread.currentThread().getStackTrace())
+        .map(StackTraceElement::toString).collect(
+            Collectors.joining());
+  }
+
   public ContractCaseConfigurationError(@NotNull String message, @NotNull String location) {
     super(message);
     this.location = location;

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

@@ -5,14 +5,13 @@
 
 public class ContractDefiner {
 
-
   private static final String TEST_RUN_ID = "JAVA";
-  private final LogPrinter logPrinter;
   private final BoundaryContractDefiner definer;
 
+
   public ContractDefiner(final @NotNull ContractCaseConfig config) {
 
-    this.logPrinter = new LogPrinter();
+    LogPrinter logPrinter = new LogPrinter();
 
     // TODO figure out how to get versions
     this.definer = new BoundaryContractDefiner(BoundaryConfigMapper.map(config, TEST_RUN_ID),
@@ -21,16 +20,16 @@ public ContractDefiner(final @NotNull ContractCaseConfig config) {
         BoundaryVersionGenerator.VERSIONS);
   }
 
-  public void runExample(ExampleDefinition definition,
-      final @NotNull ContractCaseConfig additionalConfig) {
+  public <T> void runExample(ExampleDefinition definition,
+      final @NotNull IndividualSuccessTestConfig<T> additionalConfig) {
     BoundaryResultMapper.map(definer.runExample(BoundaryDefinitionMapper.map(definition),
-        BoundaryConfigMapper.map(additionalConfig, TEST_RUN_ID)));
+        BoundaryConfigMapper.mapSuccessExample(additionalConfig, TEST_RUN_ID)));
   }
 
-  public void runThrowingExample(ExampleDefinition definition,
-      ContractCaseConfig additionalConfig) {
+  public <T> void runThrowingExample(ExampleDefinition definition,
+      IndividualFailedTestConfig<T> additionalConfig) {
     BoundaryResultMapper.map(definer.runRejectingExample(BoundaryDefinitionMapper.map(definition),
-        BoundaryConfigMapper.map(additionalConfig, TEST_RUN_ID)));
+        BoundaryConfigMapper.mapFailingExample(additionalConfig, TEST_RUN_ID)));
   }
 
 }

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

@@ -0,0 +1,41 @@
+package io.contracttesting.contractcase;
+
+import io.contract_testing.contractcase.case_boundary.BoundaryContractVerifier;
+import io.contract_testing.contractcase.case_boundary.BoundaryResult;
+import io.contract_testing.contractcase.case_boundary.BoundarySuccess;
+import io.contract_testing.contractcase.case_boundary.IInvokeCoreTest;
+import io.contract_testing.contractcase.case_boundary.IRunTestCallback;
+import org.jetbrains.annotations.NotNull;
+
+public class ContractVerifier {
+
+  private final BoundaryContractVerifier verifier;
+
+  public ContractVerifier(ContractCaseConfig config) {
+    LogPrinter logPrinter = new LogPrinter();
+    this.verifier = new BoundaryContractVerifier(BoundaryConfigMapper.map(config, "VERIFICATION"),
+        new IRunTestCallback() {
+          @Override
+          public @NotNull BoundaryResult runTest(@NotNull String testName,
+              @NotNull IInvokeCoreTest invoker) {
+            // TODO replace this with something that knows about JUnit
+            try {
+              try {
+                BoundaryResultMapper.map(invoker.verify());
+              } catch (Exception e) {
+                System.err.println(e);
+              }
+              return new BoundarySuccess();
+            } catch (Exception e) {
+              return BoundaryExceptionMapper.map(e);
+            }
+          }
+
+        }, logPrinter, logPrinter, BoundaryVersionGenerator.VERSIONS);
+  }
+
+  public void runVerification(ContractCaseConfig configOverrides) {
+    this.verifier.runVerification(
+        BoundaryConfigMapper.map(configOverrides, "VERIFICATION"));
+  }
+}

contractcase/src/main/java/io/contracttesting/contractcase/IndividualFailedTestConfig.java

@@ -0,0 +1,8 @@
+package io.contracttesting.contractcase;
+
+public class IndividualFailedTestConfig<T> extends ContractCaseConfig {
+
+  public Trigger<T> trigger;
+  public TestErrorResponseFunction testErrorResponse;
+
+}

contractcase/src/main/java/io/contracttesting/contractcase/IndividualSuccessTestConfig.java

@@ -0,0 +1,8 @@
+package io.contracttesting.contractcase;
+
+public class IndividualSuccessTestConfig<T> extends ContractCaseConfig {
+
+  public Trigger<T> trigger;
+  public TestResponseFunction<T> testResponse;
+
+}