feat(message)!: apache avro payload support

src/LEGO.AsyncAPI.Bindings/AMQP/AMQPOperationBinding.cs

@@ -5,7 +5,6 @@ namespace LEGO.AsyncAPI.Bindings.AMQP
     using System;
     using System.Collections.Generic;
     using LEGO.AsyncAPI.Models;
-    using LEGO.AsyncAPI.Readers;
     using LEGO.AsyncAPI.Readers.ParseNodes;
     using LEGO.AsyncAPI.Writers;
 

src/LEGO.AsyncAPI.Bindings/Http/HttpMessageBinding.cs

@@ -42,7 +42,7 @@ public override void SerializeProperties(IAsyncApiWriter writer)
         protected override FixedFieldMap<HttpMessageBinding> FixedFieldMap => new()
         {
             { "bindingVersion", (a, n) => { a.BindingVersion = n.GetScalarValue(); } },
-            { "headers", (a, n) => { a.Headers = JsonSchemaDeserializer.LoadSchema(n); } },
+            { "headers", (a, n) => { a.Headers = AsyncApiSchemaDeserializer.LoadSchema(n); } },
         };
     }
 }

src/LEGO.AsyncAPI.Bindings/Http/HttpOperationBinding.cs

@@ -63,7 +63,7 @@ public override void SerializeProperties(IAsyncApiWriter writer)
             { "bindingVersion", (a, n) => { a.BindingVersion = n.GetScalarValue(); } },
             { "type", (a, n) => { a.Type = n.GetScalarValue().GetEnumFromDisplayName<HttpOperationType>(); } },
             { "method", (a, n) => { a.Method = n.GetScalarValue(); } },
-            { "query", (a, n) => { a.Query = JsonSchemaDeserializer.LoadSchema(n); } },
+            { "query", (a, n) => { a.Query = AsyncApiSchemaDeserializer.LoadSchema(n); } },
         };
 
         public override string BindingKey => "http";

src/LEGO.AsyncAPI.Bindings/Kafka/KafkaMessageBinding.cs

@@ -67,7 +67,7 @@ public override void SerializeProperties(IAsyncApiWriter writer)
         protected override FixedFieldMap<KafkaMessageBinding> FixedFieldMap => new()
         {
             { "bindingVersion", (a, n) => { a.BindingVersion = n.GetScalarValue(); } },
-            { "key", (a, n) => { a.Key = JsonSchemaDeserializer.LoadSchema(n); } },
+            { "key", (a, n) => { a.Key = AsyncApiSchemaDeserializer.LoadSchema(n); } },
             { "schemaIdLocation", (a, n) => { a.SchemaIdLocation = n.GetScalarValue(); } },
             { "schemaIdPayloadEncoding", (a, n) => { a.SchemaIdPayloadEncoding = n.GetScalarValue(); } },
             { "schemaLookupStrategy", (a, n) => { a.SchemaLookupStrategy = n.GetScalarValue(); } },

src/LEGO.AsyncAPI.Bindings/Kafka/KafkaOperationBinding.cs

@@ -28,8 +28,8 @@ public class KafkaOperationBinding : OperationBinding<KafkaOperationBinding>
         protected override FixedFieldMap<KafkaOperationBinding> FixedFieldMap => new()
         {
             { "bindingVersion", (a, n) => { a.BindingVersion = n.GetScalarValue(); } },
-            { "groupId", (a, n) => { a.GroupId = JsonSchemaDeserializer.LoadSchema(n); } },
-            { "clientId", (a, n) => { a.ClientId = JsonSchemaDeserializer.LoadSchema(n); } },
+            { "groupId", (a, n) => { a.GroupId = AsyncApiSchemaDeserializer.LoadSchema(n); } },
+            { "clientId", (a, n) => { a.ClientId = AsyncApiSchemaDeserializer.LoadSchema(n); } },
         };
 
         /// <summary>

src/LEGO.AsyncAPI.Bindings/MQTT/LastWill.cs

@@ -2,9 +2,9 @@
 
 namespace LEGO.AsyncAPI.Bindings.MQTT
 {
+    using System;
     using LEGO.AsyncAPI.Models.Interfaces;
     using LEGO.AsyncAPI.Writers;
-    using System;
 
     public class LastWill : IAsyncApiElement
     {

src/LEGO.AsyncAPI.Bindings/MQTT/MQTTMessageBinding.cs

@@ -57,7 +57,7 @@ public override void SerializeProperties(IAsyncApiWriter writer)
         protected override FixedFieldMap<MQTTMessageBinding> FixedFieldMap => new()
         {
             { "payloadFormatIndicator", (a, n) => { a.PayloadFormatIndicator = n.GetIntegerValueOrDefault(); } },
-            { "correlationData", (a, n) => { a.CorrelationData = JsonSchemaDeserializer.LoadSchema(n); } },
+            { "correlationData", (a, n) => { a.CorrelationData = AsyncApiSchemaDeserializer.LoadSchema(n); } },
             { "contentType", (a, n) => { a.ContentType = n.GetScalarValue(); } },
             { "responseTopic", (a, n) => { a.ResponseTopic = n.GetScalarValue(); } },
         };

src/LEGO.AsyncAPI.Bindings/MQTT/MQTTOperationBinding.cs

@@ -3,9 +3,6 @@
 namespace LEGO.AsyncAPI.Bindings.MQTT
 {
     using System;
-    using System.Collections.Generic;
-    using LEGO.AsyncAPI.Models;
-    using LEGO.AsyncAPI.Readers;
     using LEGO.AsyncAPI.Readers.ParseNodes;
     using LEGO.AsyncAPI.Writers;
 

src/LEGO.AsyncAPI.Bindings/Sns/Ordering.cs

@@ -11,7 +11,7 @@ namespace LEGO.AsyncAPI.Bindings.Sns
     public class Ordering : IAsyncApiExtensible
     {
         /// <summary>
-        /// What type of SNS Topic is this?
+        /// What type of SNS Topic is this?.
         /// </summary>
         public OrderingType Type { get; set; }
 

src/LEGO.AsyncAPI.Bindings/Sns/Statement.cs

@@ -19,7 +19,7 @@ public class Statement : IAsyncApiExtensible
         public StringOrStringList Principal { get; set; }
 
         /// <summary>
-        /// The SNS permission being allowed or denied e.g. sns:Publish
+        /// The SNS permission being allowed or denied e.g. sns:Publish.
         /// </summary>
         public StringOrStringList Action { get; set; }
 

src/LEGO.AsyncAPI.Bindings/Sqs/Queue.cs

@@ -16,7 +16,7 @@ public class Queue : IAsyncApiExtensible
         public string Name { get; set; }
 
         /// <summary>
-        /// Is this a FIFO queue?
+        /// Is this a FIFO queue?.
         /// </summary>
         public bool FifoQueue { get; set; }
 
@@ -56,7 +56,7 @@ public class Queue : IAsyncApiExtensible
         public RedrivePolicy RedrivePolicy { get; set; }
 
         /// <summary>
-        /// The security policy for the SQS Queue
+        /// The security policy for the SQS Queue.
         /// </summary>
         public Policy Policy { get; set; }
 

src/LEGO.AsyncAPI.Bindings/Sqs/RedrivePolicy.cs

@@ -3,9 +3,9 @@
 namespace LEGO.AsyncAPI.Bindings.Sqs
 {
     using System;
+    using System.Collections.Generic;
     using LEGO.AsyncAPI.Models.Interfaces;
     using LEGO.AsyncAPI.Writers;
-    using System.Collections.Generic;
 
     public class RedrivePolicy : IAsyncApiExtensible
     {

src/LEGO.AsyncAPI.Bindings/Sqs/SqsOperationBinding.cs

@@ -10,7 +10,7 @@ namespace LEGO.AsyncAPI.Bindings.Sqs
     public class SqsOperationBinding : OperationBinding<SqsOperationBinding>
     {
         /// <summary>
-        /// Queue objects that are either the endpoint for an SNS Operation Binding Object, or the deadLetterQueue of the SQS Operation Binding Object
+        /// Queue objects that are either the endpoint for an SNS Operation Binding Object, or the deadLetterQueue of the SQS Operation Binding Object.
         /// </summary>
         public List<Queue> Queues { get; set; }
 

src/LEGO.AsyncAPI.Bindings/Sqs/Statement.cs

@@ -19,7 +19,7 @@ public class Statement : IAsyncApiExtensible
         public StringOrStringList Principal { get; set; }
 
         /// <summary>
-        /// The SNS permission being allowed or denied e.g. sns:Publish
+        /// The SNS permission being allowed or denied e.g. sns:Publish.
         /// </summary>
         public StringOrStringList Action { get; set; }
 

src/LEGO.AsyncAPI.Bindings/WebSockets/WebSocketsChannelBinding.cs

@@ -31,8 +31,8 @@ public class WebSocketsChannelBinding : ChannelBinding<WebSocketsChannelBinding>
         {
             { "bindingVersion", (a, n) => { a.BindingVersion = n.GetScalarValue(); } },
             { "method", (a, n) => { a.Method = n.GetScalarValue(); } },
-            { "query", (a, n) => { a.Query = JsonSchemaDeserializer.LoadSchema(n); } },
-            { "headers", (a, n) => { a.Headers = JsonSchemaDeserializer.LoadSchema(n); } },
+            { "query", (a, n) => { a.Query = AsyncApiSchemaDeserializer.LoadSchema(n); } },
+            { "headers", (a, n) => { a.Headers = AsyncApiSchemaDeserializer.LoadSchema(n); } },
         };
 
         public override void SerializeProperties(IAsyncApiWriter writer)

src/LEGO.AsyncAPI.Readers/AsyncApiExternalReferenceResolver.cs

@@ -6,7 +6,6 @@ namespace LEGO.AsyncAPI.Readers
     using System;
     using System.Collections.Generic;
     using System.Linq;
-    using LEGO.AsyncAPI.Exceptions;
     using LEGO.AsyncAPI.Models;
     using LEGO.AsyncAPI.Models.Interfaces;
 
@@ -91,7 +90,10 @@ public override void Visit(AsyncApiOperation operation)
         public override void Visit(AsyncApiMessage message)
         {
             this.ResolveObject(message.Headers, r => message.Headers = r);
-            this.ResolveObject(message.Payload, r => message.Payload = r);
+            if (message.Payload is AsyncApiJsonSchemaPayload)
+            {
+                this.ResolveObject(message.Payload as AsyncApiJsonSchemaPayload, r => message.Payload = r);
+            }
             this.ResolveList(message.Traits);
             this.ResolveObject(message.CorrelationId, r => message.CorrelationId = r);
             this.ResolveObject(message.Bindings, r => message.Bindings = r);

src/LEGO.AsyncAPI.Readers/AsyncApiJsonDocumentReader.cs

@@ -1,7 +1,5 @@
 // Copyright (c) The LEGO Group. All rights reserved.
 
-using System;
-
 namespace LEGO.AsyncAPI.Readers
 {
     using System.Collections.Generic;

src/LEGO.AsyncAPI.Readers/AsyncApiTextReader.cs

@@ -4,7 +4,6 @@ namespace LEGO.AsyncAPI.Readers
 {
     using System.IO;
     using System.Linq;
-    using System.Runtime.CompilerServices;
     using System.Text.Json;
     using System.Text.Json.Nodes;
     using System.Threading;

src/LEGO.AsyncAPI.Readers/Exceptions/AsyncApiUnsupportedSpecVersionException.cs

@@ -29,7 +29,7 @@ public AsyncApiUnsupportedSpecVersionException(string specificationVersion)
         /// inner exception.
         /// </summary>
         /// <param name="specificationVersion">Version that caused this exception to be thrown.</param>
-        /// <param name="settings">The setting used for reading and writing</param>
+        /// <param name="settings">The setting used for reading and writing.</param>
         /// <param name="innerException">Inner exception that caused this exception to be thrown.</param>
         public AsyncApiUnsupportedSpecVersionException(string specificationVersion, Exception innerException)
             : base(string.Format(CultureInfo.InvariantCulture, MessagePattern, specificationVersion), innerException)

src/LEGO.AsyncAPI.Readers/Interface/IAsyncApiExternalReferenceReader.cs

@@ -1,7 +1,7 @@
 namespace LEGO.AsyncAPI.Readers;
 
 /// <summary>
-/// Interface that provides method for reading external references.å
+/// Interface that provides method for reading external references.å.
 /// </summary>
 public interface IAsyncApiExternalReferenceReader
 {

src/LEGO.AsyncAPI.Readers/ParseNodes/MapNode.cs

@@ -214,6 +214,14 @@ public override AsyncApiAny CreateAny()
             return new AsyncApiAny(this.node);
         }
 
+        public void ParseFields<T>(ref T parentInstance, IDictionary<string, Action<T, ParseNode>> fixedFields, IDictionary<Func<string, bool>, Action<T, string, ParseNode>> patternFields)
+        {
+            foreach (var propertyNode in this)
+            {
+                propertyNode.ParseField(parentInstance, fixedFields, patternFields);
+            }
+        }
+
         private string ToScalarValue(JsonNode node)
         {
             var scalarNode = node is JsonValue value ? value : throw new AsyncApiException($"Expected scalar value");

src/LEGO.AsyncAPI.Readers/ParseNodes/PropertyNode.cs

@@ -79,7 +79,7 @@ public void ParseField<T>(
                 else
                 {
                     this.Context.Diagnostic.Errors.Add(
-                        new AsyncApiError("", $"{this.Name} is not a valid property at {this.Context.GetLocation()}"));
+                        new AsyncApiError(string.Empty, $"{this.Name} is not a valid property at {this.Context.GetLocation()}"));
                 }
             }
         }

src/LEGO.AsyncAPI.Readers/ParseNodes/ValueNode.cs

@@ -2,11 +2,11 @@
 
 namespace LEGO.AsyncAPI.Readers.ParseNodes
 {
+    using System;
+    using System.Text.Json.Nodes;
     using LEGO.AsyncAPI.Exceptions;
     using LEGO.AsyncAPI.Models;
     using LEGO.AsyncAPI.Readers.Exceptions;
-    using System;
-    using System.Text.Json.Nodes;
 
     public class ValueNode : ParseNode
     {