From fa266000e5f975cec699dffaec8d076039f56304 Mon Sep 17 00:00:00 2001 From: Pavel Bodiachevskii Date: Sun, 12 Feb 2023 06:14:02 +0400 Subject: [PATCH] feat(AsyncAPI 2.6.0): Channel - Bindings https://github.com/asyncapi/jasyncapi/issues/126 --- .../channel/ChannelBindingsDeserializer.java | 96 +++++++++++++++++++ .../v2/_6_0/model/channel/ChannelItem.java | 11 ++- 2 files changed, 104 insertions(+), 3 deletions(-) create mode 100644 asyncapi-core/src/main/java/com/asyncapi/v2/_6_0/jackson/binding/channel/ChannelBindingsDeserializer.java diff --git a/asyncapi-core/src/main/java/com/asyncapi/v2/_6_0/jackson/binding/channel/ChannelBindingsDeserializer.java b/asyncapi-core/src/main/java/com/asyncapi/v2/_6_0/jackson/binding/channel/ChannelBindingsDeserializer.java new file mode 100644 index 00000000..700bfc9a --- /dev/null +++ b/asyncapi-core/src/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> { + + private final ObjectMapper objectMapper = new ObjectMapper(); + + @Override + public Map deserialize( + JsonParser p, + DeserializationContext ctxt + ) throws IOException, JsonProcessingException { + ObjectCodec objectCodec = p.getCodec(); + JsonNode node = objectCodec.readTree(p); + + Map 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 index a08e80e1..38044449 100644 --- 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. + *

+ * MUST BE: + *

    + *
  • {@link com.asyncapi.v2._6_0.model.Reference}
    • + *
  • {@link com.asyncapi.v2._6_0.binding.channel.ChannelBinding}
    • + *
*/ @CheckForNull @JsonDeserialize(using = ChannelBindingsDeserializer.class) - private Map bindings; + private Map bindings; }