feat: first support of bindings for kafka key

Close #67

index.js

@@ -1,12 +1,26 @@
 const { avroToJsonSchema } = require('./to-json-schema.js');
 
 module.exports.parse = async ({ message, defaultSchemaFormat }) => {
+  console.log("link ok")
   const transformed = await avroToJsonSchema(message.payload);
 
+
   message['x-parser-original-schema-format'] = message.schemaFormat || defaultSchemaFormat;
   message['x-parser-original-payload'] = message.payload;
   message.payload = transformed;
   delete message.schemaFormat;
+
+  async function handleKafkaKeyBindings() {
+    // not available from test but what about from generator ?
+    // if (message.hasBinding('kafka')) {
+    if (message.bindings && message.bindings.kafka && message.bindings.kafka.key) {
+      const bindingsTransformed = await avroToJsonSchema(message.bindings.kafka.key);
+      message['x-parser-original-bindings-kafka-key'] = message.bindings.kafka.key;
+      message.bindings.kafka.key = bindingsTransformed;
+    }
+  }
+
+  await handleKafkaKeyBindings();
 };
 
 module.exports.getMimeTypes = () => {

tests/asyncapi-avro-1.9.0-bindings.yaml

@@ -0,0 +1,15 @@
+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'