Fix missing await during JSON deserialization (#301)

rayokota · web-flow · commit d96bba56c163 · 2025-04-28T11:37:46.000-07:00
diff --git a/schemaregistry/serde/json.ts b/schemaregistry/serde/json.ts
@@ -207,7 +207,7 @@ export class JsonDeserializer extends Deserializer implements JsonSerde {
     } else {
       target = info
     }
-    msg = this.executeRules(subject, topic, RuleMode.READ, null, target, msg, null)
+    msg = await this.executeRules(subject, topic, RuleMode.READ, null, target, msg, null)
     if ((this.conf as JsonSerdeConfig).validate) {
       const validate = await this.toValidateFunction(info)
       if (validate != null && !validate(JSON.parse(msg))) {

Original file line number	Diff line number	Diff line change
`@@ -207,7 +207,7 @@ export class JsonDeserializer extends Deserializer implements JsonSerde {`
`207`	`207`	`} else {`
`208`	`208`	`target = info`
`209`	`209`	`}`
`210`		`- msg = this.executeRules(subject, topic, RuleMode.READ, null, target, msg, null)`
	`210`	`+ msg = await this.executeRules(subject, topic, RuleMode.READ, null, target, msg, null)`
`211`	`211`	`if ((this.conf as JsonSerdeConfig).validate) {`
`212`	`212`	`const validate = await this.toValidateFunction(info)`
`213`	`213`	`if (validate != null && !validate(JSON.parse(msg))) {`