fixed bugs

dataphos · Jan 9, 2025 · e55fb8a · e55fb8a
1 parent a5a63d3
commit e55fb8a
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 4 deletions.
diff --git a/registry/server/util.go b/registry/server/util.go
@@ -18,7 +18,6 @@ import (
 	"encoding/json"
 	"io"
 	"net/http"
-	"slices"
 	"strings"
 
 	"github.com/dataphos/schema-registry/registry"
@@ -29,7 +28,7 @@ type responseBodyAndCode struct {
 	Code int
 }
 
-var SupportedFormats = []string{"json", "avro", "xml", "csv", "protobuf"}
+var supportedFormats = []string{"json", "avro", "xml", "csv", "protobuf"}
 
 func writeResponse(w http.ResponseWriter, response responseBodyAndCode) {
 	w.Header().Set("Content-Type", "application/json")
@@ -55,13 +54,22 @@ func readSchemaRegisterRequest(body io.ReadCloser) (registry.SchemaRegistrationR
 
 	// check if format is unknown
 	format := strings.ToLower(schemaRegisterRequest.SchemaType)
-	if !slices.Contains(SupportedFormats, format) {
+	if !containsFormat(format) {
 		return registry.SchemaRegistrationRequest{}, registry.ErrUnknownFormat
 	}
 
 	return schemaRegisterRequest, nil
 }
 
+func containsFormat(format string) bool {
+	for _, supportedFormat := range supportedFormats {
+		if format == supportedFormat {
+			return true
+		}
+	}
+	return false
+}
+
 func readSchemaUpdateRequest(body io.ReadCloser) (registry.SchemaUpdateRequest, error) {
 	encoded, err := io.ReadAll(body)
 	if err != nil {

diff --git a/...validity/external/validity-checker/src/main/java/net/syntio/validity/checker/Checker.java b/...validity/external/validity-checker/src/main/java/net/syntio/validity/checker/Checker.java
@@ -32,7 +32,7 @@ public static boolean checkValidity(String schemaType, String schema, String mod
             case "full" -> ValidityLevel.FULL;
             default -> ValidityLevel.NONE;
         };
-        ContentValidator validator = ValidatorFactory.createValidator(schemaType);
+        ContentValidator validator = ValidatorFactory.createValidator(schemaType.toLowerCase());
         if (validator == null) { // in case ValidatorFactory returns null
           return false;
         }