Validator Interface Update & Converter Changes

incubator/catalog-inline/src/main/java/io/aklivity/zilla/runtime/catalog/inline/internal/InlineCatalogHandler.java

@@ -38,6 +38,12 @@ public InlineCatalogHandler(
         registerSchema(config.subjects);
     }
 
+    @Override
+    public String type()
+    {
+        return INLINE;
+    }
+
     @Override
     public int register(
         String subject,

incubator/catalog-schema-registry/src/main/java/io/aklivity/zilla/runtime/catalog/schema/registry/internal/SchemaRegistryCatalogHandler.java

@@ -51,6 +51,12 @@ public SchemaRegistryCatalogHandler(
         this.schemaIdCache = new Int2ObjectCache<>(1, 1024, i -> {});
     }
 
+    @Override
+    public String type()
+    {
+        return SCHEMA_REGISTRY;
+    }
+
     @Override
     public int register(
         String subject,

incubator/validator-avro.spec/src/main/scripts/io/aklivity/zilla/specs/validator/avro/config/validator.yaml

@@ -0,0 +1,50 @@
+#
+# Copyright 2021-2023 Aklivity Inc
+#
+# Licensed under the Aklivity Community License (the "License"); you may not use
+# this file except in compliance with the License.  You may obtain a copy of the
+# License at
+#
+#   https://www.aklivity.io/aklivity-community-license/
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+# WARRANTIES OF ANY KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations under the License.
+#
+
+---
+name: test
+catalogs:
+  test0:
+    type: test
+    options:
+      schema: |
+        {
+          "fields": [
+            {
+              "name": "id",
+              "type": "string"
+            },
+            {
+              "name": "status",
+              "type": "string"
+            }
+          ],
+          "name": "Event",
+          "namespace": "io.aklivity.example",
+          "type": "record"
+        }
+bindings:
+  test:
+    kind: server
+    type: test
+    options:
+      value:
+        type: avro
+        format: json
+        catalog:
+          catalog0:
+            - subject: test0
+              version: latest
+    exit: test

incubator/validator-avro.spec/src/main/scripts/io/aklivity/zilla/specs/validator/avro/schema/avro.schema.patch.json

@@ -3,5 +3,134 @@
         "op": "add",
         "path": "/$defs/validator/types/enum/-",
         "value": "avro"
+    },
+    {
+        "op": "add",
+        "path": "/$defs/validator/allOf/-",
+        "value":
+        {
+            "if":
+            {
+                "properties":
+                {
+                    "type":
+                    {
+                        "const": "avro"
+                    }
+                }
+            },
+            "then":
+            {
+                "properties":
+                {
+                    "type":
+                    {
+                        "const": "avro"
+                    },
+                    "format":
+                    {
+                        "type": "string",
+                        "enum":
+                        [
+                            "json"
+                        ]
+                    },
+                    "catalog":
+                    {
+                        "type": "object",
+                        "patternProperties":
+                        {
+                            "^[a-zA-Z]+[a-zA-Z0-9\\._\\-]*$":
+                            {
+                                "type": "array",
+                                "items":
+                                {
+                                    "oneOf":
+                                    [
+                                        {
+                                            "type": "object",
+                                            "properties":
+                                            {
+                                                "id":
+                                                {
+                                                    "type": "integer"
+                                                }
+                                            },
+                                            "required":
+                                            [
+                                                "id"
+                                            ],
+                                            "additionalProperties": false
+                                        },
+                                        {
+                                            "type": "object",
+                                            "properties":
+                                            {
+                                                "schema":
+                                                {
+                                                    "type": "string"
+                                                },
+                                                "version":
+                                                {
+                                                    "type": "string",
+                                                    "default": "latest"
+                                                }
+                                            },
+                                            "required":
+                                            [
+                                                "schema"
+                                            ],
+                                            "additionalProperties": false
+                                        },
+                                        {
+                                            "type": "object",
+                                            "properties":
+                                            {
+                                                "strategy":
+                                                {
+                                                    "type": "string"
+                                                },
+                                                "version":
+                                                {
+                                                    "type": "string",
+                                                    "default": "latest"
+                                                }
+                                            },
+                                            "required":
+                                            [
+                                                "strategy"
+                                            ],
+                                            "additionalProperties": false
+                                        },
+                                        {
+                                            "type": "object",
+                                            "properties":
+                                            {
+                                                "subject":
+                                                {
+                                                    "type": "string"
+                                                },
+                                                "version":
+                                                {
+                                                    "type": "string",
+                                                    "default": "latest"
+                                                }
+                                            },
+                                            "required":
+                                            [
+                                                "subject"
+                                            ],
+                                            "additionalProperties": false
+                                        }
+                                    ]
+                                }
+                            }
+                        },
+                        "maxProperties": 1
+                    }
+                },
+                "additionalProperties": false
+            }
+        }
     }
 ]

incubator/validator-avro.spec/src/test/java/io/aklivity/zilla/specs/validator/avro/config/SchemaTest.java

@@ -0,0 +1,44 @@
+/*
+ * Copyright 2021-2023 Aklivity Inc
+ *
+ * Licensed under the Aklivity Community License (the "License"); you may not use
+ * this file except in compliance with the License.  You may obtain a copy of the
+ * License at
+ *
+ *   https://www.aklivity.io/aklivity-community-license/
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OF ANY KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+package io.aklivity.zilla.specs.validator.avro.config;
+
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.hamcrest.Matchers.not;
+import static org.hamcrest.Matchers.nullValue;
+
+import jakarta.json.JsonObject;
+
+import org.junit.Rule;
+import org.junit.Test;
+
+import io.aklivity.zilla.specs.engine.config.ConfigSchemaRule;
+
+public class SchemaTest
+{
+    @Rule
+    public final ConfigSchemaRule schema = new ConfigSchemaRule()
+        .schemaPatch("io/aklivity/zilla/specs/engine/schema/binding/test.schema.patch.json")
+        .schemaPatch("io/aklivity/zilla/specs/engine/schema/catalog/test.schema.patch.json")
+        .schemaPatch("io/aklivity/zilla/specs/validator/avro/schema/avro.schema.patch.json")
+        .configurationRoot("io/aklivity/zilla/specs/validator/avro/config");
+
+    @Test
+    public void shouldValidateCatalog()
+    {
+        JsonObject config = schema.validate("validator.yaml");
+
+        assertThat(config, not(nullValue()));
+    }
+}

incubator/validator-avro/pom.xml

@@ -26,7 +26,7 @@
   <properties>
     <maven.compiler.source>11</maven.compiler.source>
     <maven.compiler.target>11</maven.compiler.target>
-    <jacoco.coverage.ratio>0.80</jacoco.coverage.ratio>
+    <jacoco.coverage.ratio>0.91</jacoco.coverage.ratio>
     <jacoco.missed.count>0</jacoco.missed.count>
   </properties>