Add builder for OpenAPIContract.

src/main/java/io/vertx/openapi/contract/OpenAPIContract.java

@@ -12,51 +12,51 @@
 
 package io.vertx.openapi.contract;
 
-import static io.vertx.core.Future.failedFuture;
-import static io.vertx.openapi.contract.OpenAPIContractException.createInvalidContract;
-import static io.vertx.openapi.impl.Utils.readYamlOrJson;
-import static java.util.Collections.emptyMap;
-
 import io.vertx.codegen.annotations.Nullable;
 import io.vertx.codegen.annotations.VertxGen;
 import io.vertx.core.Future;
-import io.vertx.core.Promise;
 import io.vertx.core.Vertx;
 import io.vertx.core.http.HttpMethod;
-import io.vertx.core.internal.ContextInternal;
 import io.vertx.core.json.JsonObject;
-import io.vertx.json.schema.JsonSchema;
-import io.vertx.json.schema.JsonSchemaValidationException;
 import io.vertx.json.schema.SchemaRepository;
-import io.vertx.openapi.contract.impl.OpenAPIContractImpl;
-import java.util.ArrayList;
-import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
 @VertxGen
 public interface OpenAPIContract {
 
+  /**
+   * Instantiates a new builder for an openapi-contract.
+   *
+   * @param vertx The vert.x instance
+   * @return A new builder.
+   */
+  static OpenAPIContractBuilder builder(Vertx vertx) {
+    return new OpenAPIContractBuilder(vertx);
+  }
+
   /**
    * Resolves / dereferences the passed contract and creates an {@link OpenAPIContract} instance.
    *
-   * @param vertx                  The related Vert.x instance.
-   * @param unresolvedContractPath The path to the unresolved contract.
+   * @param vertx        The related Vert.x instance.
+   * @param contractPath The path to contract.
    * @return A succeeded {@link Future} holding an {@link OpenAPIContract} instance, otherwise a failed {@link Future}.
    */
-  static Future<OpenAPIContract> from(Vertx vertx, String unresolvedContractPath) {
-    return readYamlOrJson(vertx, unresolvedContractPath).compose(json -> from(vertx, json));
+  static Future<OpenAPIContract> from(Vertx vertx, String contractPath) {
+    return builder(vertx).setContractPath(contractPath).build();
   }
 
   /**
    * Resolves / dereferences the passed contract and creates an {@link OpenAPIContract} instance.
    *
-   * @param vertx              The related Vert.x instance.
-   * @param unresolvedContract The unresolved contract.
+   * @param vertx    The related Vert.x instance.
+   * @param contract The contract.
    * @return A succeeded {@link Future} holding an {@link OpenAPIContract} instance, otherwise a failed {@link Future}.
    */
-  static Future<OpenAPIContract> from(Vertx vertx, JsonObject unresolvedContract) {
-    return from(vertx, unresolvedContract, emptyMap());
+  static Future<OpenAPIContract> from(Vertx vertx, JsonObject contract) {
+    return builder(vertx)
+        .setContract(contract)
+        .build();
   }
 
   /**
@@ -65,23 +65,18 @@ static Future<OpenAPIContract> from(Vertx vertx, JsonObject unresolvedContract)
    * This method can be used in case that the contract is split into several files. These files can be passed in a
    * Map that has the reference as key and the path to the file as value.
    *
-   * @param vertx                   The related Vert.x instance.
-   * @param unresolvedContractPath  The path to the unresolved contract.
-   * @param additionalContractFiles The additional contract files
+   * @param vertx                       The related Vert.x instance.
+   * @param contract                    The path to the contract.
+   * @param additionalContractPartPaths The additional contract part paths
    * @return A succeeded {@link Future} holding an {@link OpenAPIContract} instance, otherwise a failed {@link Future}.
    */
-  static Future<OpenAPIContract> from(Vertx vertx, String unresolvedContractPath,
-      Map<String, String> additionalContractFiles) {
+  static Future<OpenAPIContract> from(Vertx vertx, String contract,
+      Map<String, String> additionalContractPartPaths) {
 
-    Map<String, Future<JsonObject>> jsonFilesFuture = new HashMap<>();
-    jsonFilesFuture.put(unresolvedContractPath, readYamlOrJson(vertx, unresolvedContractPath));
-    additionalContractFiles.forEach((key, value) -> jsonFilesFuture.put(key, readYamlOrJson(vertx, value)));
-
-    return Future.all(new ArrayList<>(jsonFilesFuture.values())).compose(compFut -> {
-      Map<String, JsonObject> resolvedFiles = new HashMap<>();
-      additionalContractFiles.keySet().forEach(key -> resolvedFiles.put(key, jsonFilesFuture.get(key).result()));
-      return from(vertx, jsonFilesFuture.get(unresolvedContractPath).result(), resolvedFiles);
-    });
+    return builder(vertx)
+        .setContractPath(contract)
+        .setAdditionalContractPartPaths(additionalContractPartPaths)
+        .build();
   }
 
   /**
@@ -90,56 +85,18 @@ static Future<OpenAPIContract> from(Vertx vertx, String unresolvedContractPath,
    * This method can be used in case that the contract is split into several files. These files can be passed in a
    * Map that has the reference as key and the path to the file as value.
    *
-   * @param vertx                   The related Vert.x instance.
-   * @param unresolvedContract      The unresolved contract.
-   * @param additionalContractFiles The additional contract files
+   * @param vertx                       The related Vert.x instance.
+   * @param contract                    The unresolved contract.
+   * @param additionalContractPartPaths The additional contract part paths
    * @return A succeeded {@link Future} holding an {@link OpenAPIContract} instance, otherwise a failed {@link Future}.
    */
-  static Future<OpenAPIContract> from(Vertx vertx, JsonObject unresolvedContract,
-      Map<String, JsonObject> additionalContractFiles) {
-    if (unresolvedContract == null) {
-      return failedFuture(createInvalidContract("Spec must not be null"));
-    }
-
-    OpenAPIVersion version = OpenAPIVersion.fromContract(unresolvedContract);
-    String baseUri = "app://";
-
-    ContextInternal ctx = (ContextInternal) vertx.getOrCreateContext();
-    Promise<OpenAPIContract> promise = ctx.promise();
-
-    version.getRepository(vertx, baseUri)
-        .compose(repository -> {
-          List<Future<?>> validationFutures = new ArrayList<>(additionalContractFiles.size());
-          for (String ref : additionalContractFiles.keySet()) {
-            // Todo: As soon a more modern Java version is used the validate part could be extracted in a private static
-            // method and reused below.
-            JsonObject file = additionalContractFiles.get(ref);
-            Future<?> validationFuture = version.validateAdditionalContractFile(vertx, repository, file)
-                .compose(v -> vertx.executeBlocking(() -> repository.dereference(ref, JsonSchema.of(ref, file))));
-
-            validationFutures.add(validationFuture);
-          }
-          return Future.all(validationFutures).map(repository);
-        }).compose(repository -> version.validateContract(vertx, repository, unresolvedContract).compose(res -> {
-          try {
-            res.checkValidity();
-            return version.resolve(vertx, repository, unresolvedContract);
-          } catch (JsonSchemaValidationException | UnsupportedOperationException e) {
-            return failedFuture(createInvalidContract(null, e));
-          }
-        })
-            .map(resolvedSpec -> (OpenAPIContract) new OpenAPIContractImpl(resolvedSpec, version, repository)))
-        .recover(e -> {
-          // Convert any non-openapi exceptions into an OpenAPIContractException
-          if (e instanceof OpenAPIContractException) {
-            return failedFuture(e);
-          }
-
-          return failedFuture(
-              createInvalidContract("Found issue in specification for reference: " + e.getMessage(), e));
-        }).onComplete(promise);
-
-    return promise.future();
+  static Future<OpenAPIContract> from(Vertx vertx, JsonObject contract,
+      Map<String, JsonObject> additionalContractPartPaths) {
+    return builder(vertx)
+        .setContract(contract)
+        .setAdditionalContractParts(additionalContractPartPaths)
+        .build();
+
   }
 
   /**