Fix regression in JSONSchema (de)serialization

Fix checking headers in the script
Remove unused error code and recorder error codes

error_codes.go

@@ -29,9 +29,8 @@ const (
 	failedUnmarshalJSON         errCode = 2007
 	failedValidateJSON          errCode = 2008
 	failedEncodeToJSON          errCode = 2009
-	failedEncodeJSONToBinary    errCode = 2010
-	failedDecodeJSONFromBinary  errCode = 2011
-	failedToUnmarshalSchema     errCode = 2012
+	failedDecodeJSONFromBinary  errCode = 2010
+	failedToUnmarshalSchema     errCode = 2011
 
 	// producer.
 	failedWriteMessage errCode = 3000

jsonschema.go

@@ -71,18 +71,18 @@ func SerializeJSON(
 	if schemaInfo != nil {
 		schemaID = schemaInfo.ID()
 
-		// Encode the data into JSON and then the wire format
-		jsonEncodedData, _, err := schemaInfo.Codec().NativeFromTextual(bytesData)
-		if err != nil {
-			return nil, NewXk6KafkaError(failedEncodeToJSON,
-				"Failed to encode data into JSON",
+		var jsonBytes interface{}
+		if err := json.Unmarshal(bytesData, &jsonBytes); err != nil {
+			return nil, NewXk6KafkaError(failedUnmarshalJSON,
+				"Failed to unmarshal JSON data",
 				err)
 		}
 
-		bytesData, err = schemaInfo.Codec().BinaryFromNative(nil, jsonEncodedData)
+		// Encode the data into JSON and then the wire format
+		err := schemaInfo.JsonSchema().Validate(jsonBytes)
 		if err != nil {
-			return nil, NewXk6KafkaError(failedEncodeJSONToBinary,
-				"Failed to encode JSON data into binary",
+			return nil, NewXk6KafkaError(failedEncodeToJSON,
+				"Failed to encode data into JSON",
 				err)
 		}
 	}
@@ -148,14 +148,21 @@ func DeserializeJSON(
 	}
 
 	if schemaInfo != nil {
+		var jsonBytes interface{}
+		if err := json.Unmarshal(bytesDecodedData, &jsonBytes); err != nil {
+			return nil, NewXk6KafkaError(failedUnmarshalJSON,
+				"Failed to unmarshal JSON data",
+				err)
+		}
+
 		// Decode the data from Json
-		jsonDecodedData, _, err := schemaInfo.Codec().NativeFromBinary(bytesDecodedData)
+		err := schemaInfo.JsonSchema().Validate(jsonBytes)
 		if err != nil {
 			return nil, NewXk6KafkaError(failedDecodeJSONFromBinary,
 				"Failed to decode data from JSON",
 				err)
 		}
-		return jsonDecodedData, nil
+		return jsonBytes, nil
 	}
 
 	return bytesDecodedData, nil

scripts/test_jsonschema_with_schema_registry.js

@@ -108,7 +108,7 @@ export default function () {
         "Key is correct": (msg) => msg.key.key == "key0",
         "Value is correct": (msg) =>
             msg.value.firstName == "firstName-0" && msg.value.lastName == "lastName-0",
-        "Headers are correct": (msg) => msg.headers.length == 0,
+        "Headers are correct": (msg) => msg.headers.hasOwnProperty("mykey") == false,
         "Time is past": (msg) => new Date(msg["time"]) < new Date(),
         "Offset is correct": (msg) => msg.offset == 0,
         "Partition is correct": (msg) => msg.partition == 0,