Upgrade to schema.nt 2.0 (#924)

Signed-off-by: fjtirado <[email protected]>

Author: fjtirado

api/src/main/java/io/serverlessworkflow/api/ValidationReader.java

@@ -16,31 +16,30 @@
 package io.serverlessworkflow.api;
 
 import com.fasterxml.jackson.databind.JsonNode;
+import com.networknt.schema.Error;
 import com.networknt.schema.InputFormat;
-import com.networknt.schema.JsonSchema;
-import com.networknt.schema.JsonSchemaFactory;
-import com.networknt.schema.SchemaValidatorsConfig;
-import com.networknt.schema.SpecVersion.VersionFlag;
-import com.networknt.schema.ValidationMessage;
+import com.networknt.schema.Schema;
+import com.networknt.schema.SchemaRegistry;
+import com.networknt.schema.SpecificationVersion;
 import io.serverlessworkflow.api.types.Workflow;
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.Reader;
 import java.io.UncheckedIOException;
-import java.util.Set;
+import java.util.Collection;
 import java.util.stream.Collectors;
 
 class ValidationReader implements WorkflowReaderOperations {
-  private final JsonSchema schemaObject;
+  private final Schema schemaObject;
 
   ValidationReader() {
     try (InputStream input =
         Thread.currentThread()
             .getContextClassLoader()
             .getResourceAsStream("schema/workflow.yaml")) {
       this.schemaObject =
-          JsonSchemaFactory.getInstance(VersionFlag.V7)
-              .getSchema(input, InputFormat.YAML, SchemaValidatorsConfig.builder().build());
+          SchemaRegistry.withDefaultDialect(SpecificationVersion.DRAFT_7)
+              .getSchema(input, InputFormat.YAML);
     } catch (IOException e) {
       throw new UncheckedIOException(e);
     }
@@ -67,12 +66,10 @@ public Workflow read(String input, WorkflowFormat format) throws IOException {
   }
 
   private Workflow validate(JsonNode value, WorkflowFormat format) {
-    Set<ValidationMessage> validationErrors = schemaObject.validate(value);
+    Collection<Error> validationErrors = schemaObject.validate(value);
     if (!validationErrors.isEmpty()) {
       throw new IllegalArgumentException(
-          validationErrors.stream()
-              .map(ValidationMessage::toString)
-              .collect(Collectors.joining("\n")));
+          validationErrors.stream().map(Error::toString).collect(Collectors.joining("\n")));
     }
     return format.mapper().convertValue(value, Workflow.class);
   }

impl/validation/src/main/java/io/serverlessworkflow/impl/jackson/schema/JsonSchemaValidator.java

@@ -16,25 +16,26 @@
 package io.serverlessworkflow.impl.jackson.schema;
 
 import com.fasterxml.jackson.databind.JsonNode;
-import com.networknt.schema.JsonSchema;
-import com.networknt.schema.JsonSchemaFactory;
-import com.networknt.schema.SpecVersion.VersionFlag;
-import com.networknt.schema.ValidationMessage;
+import com.networknt.schema.Error;
+import com.networknt.schema.Schema;
+import com.networknt.schema.SchemaRegistry;
+import com.networknt.schema.SpecificationVersion;
 import io.serverlessworkflow.impl.WorkflowModel;
 import io.serverlessworkflow.impl.schema.SchemaValidator;
-import java.util.Set;
+import java.util.Collection;
 
 public class JsonSchemaValidator implements SchemaValidator {
 
-  private final JsonSchema schemaObject;
+  private final Schema schemaObject;
 
   public JsonSchemaValidator(JsonNode jsonNode) {
-    this.schemaObject = JsonSchemaFactory.getInstance(VersionFlag.V7).getSchema(jsonNode);
+    this.schemaObject =
+        SchemaRegistry.withDefaultDialect(SpecificationVersion.DRAFT_7).getSchema(jsonNode);
   }
 
   @Override
   public void validate(WorkflowModel node) {
-    Set<ValidationMessage> report =
+    Collection<Error> report =
         schemaObject.validate(
             node.as(JsonNode.class)
                 .orElseThrow(

pom.xml

@@ -82,7 +82,7 @@
         <version.ch.qos.logback>1.5.20</version.ch.qos.logback>
         <version.com.fasterxml.jackson>2.20.0</version.com.fasterxml.jackson>
         <version.com.fasterxml.jackson.annotations>2.20</version.com.fasterxml.jackson.annotations>
-        <version.com.networknt>1.5.9</version.com.networknt>
+        <version.com.networknt>2.0.0</version.com.networknt>
         <version.com.squareup.okhttp3.mockwebserver>5.2.1</version.com.squareup.okhttp3.mockwebserver>
         <version.io.cloudevents>4.0.1</version.io.cloudevents>
         <version.jakarta.validation>3.1.1</version.jakarta.validation>