feat: first support of bindings for AVRO key (#77)

* feat: support of AVRO bindings key Close #67 * fixup: PR review, only handle kafka key on bindings * fix linter errors * fixup: magicmatatjahu PR suggestion Co-authored-by: Maciej Urbańczyk <[email protected]> Co-authored-by: Maciej Urbańczyk <[email protected]>
asyncapi · Sep 17, 2021 · be78b76 · be78b76
1 parent c8c9ce5
commit be78b76
Show file tree

Hide file tree

Showing 3 changed files with 40 additions and 0 deletions.
diff --git a/index.js b/index.js
@@ -7,6 +7,20 @@ module.exports.parse = async ({ message, defaultSchemaFormat }) => {
   message['x-parser-original-payload'] = message.payload;
   message.payload = transformed;
   delete message.schemaFormat;
+
+  // remove that function when https://github.com/asyncapi/spec/issues/622 will be introduced in AsyncAPI spec
+  async function handleKafkaProtocolKey() {
+    if (message.bindings && message.bindings.kafka) {
+      const key = message.bindings.kafka.key;
+      if (key) {
+        const bindingsTransformed = await avroToJsonSchema(key);
+        message['x-parser-original-bindings-kafka-key'] = key;
+        message.bindings.kafka.key = bindingsTransformed;
+      }
+    }
+  }
+
+  await handleKafkaProtocolKey();
 };
 
 module.exports.getMimeTypes = () => {

diff --git a/tests/asyncapi-avro-1.9.0-bindings.yaml b/tests/asyncapi-avro-1.9.0-bindings.yaml
@@ -0,0 +1,19 @@
+asyncapi: 2.0.0
+info:
+  title: My API
+  version: '1.0.0'
+channels:
+  mychannel:
+    publish:
+      message:
+        schemaFormat: application/vnd.apache.avro;version=1.9.0
+        payload:
+          $ref: 'schemas/Person-1.9.0-namespace.avsc'
+        bindings:
+          kafka:
+            key:
+              $ref: 'schemas/Person-1.9.0-namespace.avsc'
+          mqtt:
+            x-test:
+              type: string
+
diff --git a/tests/parse.test.js b/tests/parse.test.js