feat(AsyncAPI 2.6.0): Channel - Bindings

asyncapi#126
Pakisan · Feb 12, 2023 · fa26600 · fa26600
1 parent c5f46e3
commit fa26600
Show file tree

Hide file tree

Showing 2 changed files with 104 additions and 3 deletions.
diff --git a/...c/main/java/com/asyncapi/v2/_6_0/jackson/binding/channel/ChannelBindingsDeserializer.java b/...c/main/java/com/asyncapi/v2/_6_0/jackson/binding/channel/ChannelBindingsDeserializer.java
@@ -0,0 +1,96 @@
+package com.asyncapi.v2._6_0.jackson.binding.channel;
+
+import com.asyncapi.v2._6_0.binding.channel.amqp.AMQPChannelBinding;
+import com.asyncapi.v2._6_0.binding.channel.amqp1.AMQP1ChannelBinding;
+import com.asyncapi.v2._6_0.binding.channel.anypointmq.AnypointMQChannelBinding;
+import com.asyncapi.v2._6_0.binding.channel.googlepubsub.GooglePubSubChannelBinding;
+import com.asyncapi.v2._6_0.binding.channel.http.HTTPChannelBinding;
+import com.asyncapi.v2._6_0.binding.channel.ibmmq.IBMMQChannelBinding;
+import com.asyncapi.v2._6_0.binding.channel.jms.JMSChannelBinding;
+import com.asyncapi.v2._6_0.binding.channel.kafka.KafkaChannelBinding;
+import com.asyncapi.v2._6_0.binding.channel.mercure.MercureChannelBinding;
+import com.asyncapi.v2._6_0.binding.channel.mqtt.MQTTChannelBinding;
+import com.asyncapi.v2._6_0.binding.channel.mqtt5.MQTT5ChannelBinding;
+import com.asyncapi.v2._6_0.binding.channel.nats.NATSChannelBinding;
+import com.asyncapi.v2._6_0.binding.channel.pulsar.PulsarChannelBinding;
+import com.asyncapi.v2._6_0.binding.channel.redis.RedisChannelBinding;
+import com.asyncapi.v2._6_0.binding.channel.sns.SNSChannelBinding;
+import com.asyncapi.v2._6_0.binding.channel.solace.SolaceChannelBinding;
+import com.asyncapi.v2._6_0.binding.channel.sqs.SQSChannelBinding;
+import com.asyncapi.v2._6_0.binding.channel.stomp.STOMPChannelBinding;
+import com.asyncapi.v2._6_0.binding.channel.ws.WebSocketsChannelBinding;
+import com.asyncapi.v2._6_0.model.Reference;
+import com.fasterxml.jackson.core.JsonParser;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.core.ObjectCodec;
+import com.fasterxml.jackson.databind.DeserializationContext;
+import com.fasterxml.jackson.databind.JsonDeserializer;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * Serializes channel bindings map.
+ *
+ * @author Pavel Bodiachevskii
+ */
+public class ChannelBindingsDeserializer extends JsonDeserializer<Map<String, Object>> {
+
+    private final ObjectMapper objectMapper = new ObjectMapper();
+
+    @Override
+    public Map<String, Object> deserialize(
+            JsonParser p,
+            DeserializationContext ctxt
+    ) throws IOException, JsonProcessingException {
+        ObjectCodec objectCodec = p.getCodec();
+        JsonNode node = objectCodec.readTree(p);
+
+        Map<String, Object> bindings = new HashMap<>();
+
+        node.fieldNames().forEachRemaining(
+                fieldName -> {
+                    try {
+                        bindings.put(fieldName, chooseKnownPojo(fieldName, node.get(fieldName)));
+                    } catch (IOException e) {
+                        e.printStackTrace();
+                    }
+                }
+        );
+
+        return bindings;
+    }
+
+    private Object chooseKnownPojo(String bindingKey, JsonNode binding) throws IOException {
+        if (binding.get("$ref" ) != null) {
+            return objectMapper.readValue(binding.toString(), Reference.class);
+        }
+
+        switch (bindingKey) {
+            case "amqp": return objectMapper.readValue(binding.toString(), AMQPChannelBinding.class);
+            case "amqp1": return objectMapper.readValue(binding.toString(), AMQP1ChannelBinding.class);
+            case "anypointmq": return objectMapper.readValue(binding.toString(), AnypointMQChannelBinding.class);
+            case "googlepubsub": return objectMapper.readValue(binding.toString(), GooglePubSubChannelBinding.class);
+            case "http": return objectMapper.readValue(binding.toString(), HTTPChannelBinding.class);
+            case "ibmmq": return objectMapper.readValue(binding.toString(), IBMMQChannelBinding.class);
+            case "jms": return objectMapper.readValue(binding.toString(), JMSChannelBinding.class);
+            case "kafka": return objectMapper.readValue(binding.toString(), KafkaChannelBinding.class);
+            case "mercure": return objectMapper.readValue(binding.toString(), MercureChannelBinding.class);
+            case "mqtt": return objectMapper.readValue(binding.toString(), MQTTChannelBinding.class);
+            case "mqtt5": return objectMapper.readValue(binding.toString(), MQTT5ChannelBinding.class);
+            case "nats": return objectMapper.readValue(binding.toString(), NATSChannelBinding.class);
+            case "pulsar": return objectMapper.readValue(binding.toString(), PulsarChannelBinding.class);
+            case "redis": return objectMapper.readValue(binding.toString(), RedisChannelBinding.class);
+            case "sns": return objectMapper.readValue(binding.toString(), SNSChannelBinding.class);
+            case "solace": return objectMapper.readValue(binding.toString(), SolaceChannelBinding.class);
+            case "sqs": return objectMapper.readValue(binding.toString(), SQSChannelBinding.class);
+            case "stomp": return objectMapper.readValue(binding.toString(), STOMPChannelBinding.class);
+            case "ws": return objectMapper.readValue(binding.toString(), WebSocketsChannelBinding.class);
+            default: return null;
+        }
+    }
+
+}
diff --git a/asyncapi-core/src/main/java/com/asyncapi/v2/_6_0/model/channel/ChannelItem.java b/asyncapi-core/src/main/java/com/asyncapi/v2/_6_0/model/channel/ChannelItem.java
@@ -1,7 +1,6 @@
 package com.asyncapi.v2._6_0.model.channel;
 
-import com.asyncapi.v2.binding.ChannelBinding;
-import com.asyncapi.v2.binding.ChannelBindingsDeserializer;
+import com.asyncapi.v2._6_0.jackson.binding.channel.ChannelBindingsDeserializer;
 import com.asyncapi.v2._6_0.jackson.model.channel.ChannelParametersDeserializer;
 import com.asyncapi.v2._6_0.model.channel.operation.Operation;
 import com.fasterxml.jackson.annotation.JsonProperty;
@@ -80,9 +79,15 @@ public class ChannelItem {
 
     /**
      * A map where the keys describe the name of the protocol and the values describe protocol-specific definitions for the channel.
+     * <p>
+     * MUST BE:
+     * <ul>
+     *     <li>{@link com.asyncapi.v2._6_0.model.Reference}</li>
+     *     <li>{@link com.asyncapi.v2._6_0.binding.channel.ChannelBinding}</li>
+     * </ul>
      */
     @CheckForNull
     @JsonDeserialize(using = ChannelBindingsDeserializer.class)
-    private Map<String, ? extends ChannelBinding> bindings;
+    private Map<String, Object> bindings;
 
 }