LEGO · VisualBean · Mar 26, 2024 · Mar 26, 2024 · Mar 26, 2024 · Mar 26, 2024
@@ -29,15 +29,15 @@ public class AMQPChannelBinding : ChannelBinding<AMQPChannelBinding>
 
         public override string BindingKey => "amqp";
 
-        protected override FixedFieldMap<AMQPChannelBinding> FixedFieldMap => new ()
+        protected override FixedFieldMap<AMQPChannelBinding> FixedFieldMap => new()
         {
             { "bindingVersion", (a, n) => { a.BindingVersion = n.GetScalarValue(); } },
             { "is", (a, n) => { a.Is = n.GetScalarValue().GetEnumFromDisplayName<ChannelType>(); } },
             { "exchange", (a, n) => { a.Exchange = n.ParseMap(ExchangeFixedFields); } },
             { "queue", (a, n) => { a.Queue = n.ParseMap(QueueFixedFields); } },
         };
 
-        private static FixedFieldMap<Exchange> ExchangeFixedFields = new ()
+        private static FixedFieldMap<Exchange> ExchangeFixedFields = new()
         {
             { "name", (a, n) => { a.Name = n.GetScalarValue(); } },
             { "durable", (a, n) => { a.Durable = n.GetBooleanValue(); } },

@@ -41,7 +41,7 @@ public override void SerializeProperties(IAsyncApiWriter writer)
 
         public override string BindingKey => "amqp";
 
-        protected override FixedFieldMap<AMQPMessageBinding> FixedFieldMap => new ()
+        protected override FixedFieldMap<AMQPMessageBinding> FixedFieldMap => new()
         {
             { "bindingVersion", (a, n) => { a.BindingVersion = n.GetScalarValue(); } },
             { "contentEncoding", (a, n) => { a.ContentEncoding = n.GetScalarValue(); } },

@@ -13,7 +13,6 @@ namespace LEGO.AsyncAPI.Bindings.Http
     /// </summary>
     public class HttpMessageBinding : MessageBinding<HttpMessageBinding>
     {
-
         /// <summary>
         /// A Schema object containing the definitions for HTTP-specific headers. This schema MUST be of type object and have a properties key.
         /// </summary>
@@ -40,11 +39,10 @@ public override void SerializeProperties(IAsyncApiWriter writer)
 
         public override string BindingKey => "http";
 
-        protected override FixedFieldMap<HttpMessageBinding> FixedFieldMap => new ()
+        protected override FixedFieldMap<HttpMessageBinding> FixedFieldMap => new()
         {
             { "bindingVersion", (a, n) => { a.BindingVersion = n.GetScalarValue(); } },
             { "headers", (a, n) => { a.Headers = JsonSchemaDeserializer.LoadSchema(n); } },
         };
-
     }
 }
@@ -58,7 +58,7 @@ public override void SerializeProperties(IAsyncApiWriter writer)
             writer.WriteEndObject();
         }
 
-        protected override FixedFieldMap<HttpOperationBinding> FixedFieldMap => new ()
+        protected override FixedFieldMap<HttpOperationBinding> FixedFieldMap => new()
         {
             { "bindingVersion", (a, n) => { a.BindingVersion = n.GetScalarValue(); } },
             { "type", (a, n) => { a.Type = n.GetScalarValue().GetEnumFromDisplayName<HttpOperationType>(); } },

@@ -34,7 +34,7 @@ public class KafkaChannelBinding : ChannelBinding<KafkaChannelBinding>
 
         public override string BindingKey => "kafka";
 
-        protected override FixedFieldMap<KafkaChannelBinding> FixedFieldMap => new ()
+        protected override FixedFieldMap<KafkaChannelBinding> FixedFieldMap => new()
         {
             { "bindingVersion", (a, n) => { a.BindingVersion = n.GetScalarValue(); } },
             { "topic", (a, n) => { a.Topic = n.GetScalarValue(); } },
@@ -43,7 +43,7 @@ public class KafkaChannelBinding : ChannelBinding<KafkaChannelBinding>
             { "replicas", (a, n) => { a.Replicas = n.GetIntegerValue(); } },
         };
 
-        private static FixedFieldMap<TopicConfigurationObject> kafkaChannelTopicConfigurationObjectFixedFields = new ()
+        private static FixedFieldMap<TopicConfigurationObject> kafkaChannelTopicConfigurationObjectFixedFields = new()
         {
             { "cleanup.policy", (a, n) => { a.CleanupPolicy = n.CreateSimpleList(s => s.GetScalarValue()); } },
             { "retention.ms", (a, n) => { a.RetentionMilliseconds = n.GetLongValue(); } },

@@ -36,7 +36,7 @@ public class KafkaMessageBinding : MessageBinding<KafkaMessageBinding>
         /// <summary>
         /// The version of this binding. If omitted, "latest" MUST be assumed.
         /// </summary>
-        
+
         public override void SerializeProperties(IAsyncApiWriter writer)
         {
             if (writer is null)
@@ -62,9 +62,9 @@ public override void SerializeProperties(IAsyncApiWriter writer)
         /// <param name="writer">The writer.</param>
         /// <exception cref="ArgumentNullException">writer.</exception>
 
-       public override string BindingKey => "kafka";
+        public override string BindingKey => "kafka";
 
-        protected override FixedFieldMap<KafkaMessageBinding> FixedFieldMap => new ()
+        protected override FixedFieldMap<KafkaMessageBinding> FixedFieldMap => new()
         {
             { "bindingVersion", (a, n) => { a.BindingVersion = n.GetScalarValue(); } },
             { "key", (a, n) => { a.Key = JsonSchemaDeserializer.LoadSchema(n); } },

@@ -25,7 +25,7 @@ public class KafkaOperationBinding : OperationBinding<KafkaOperationBinding>
 
         public override string BindingKey => "kafka";
 
-        protected override FixedFieldMap<KafkaOperationBinding> FixedFieldMap => new ()
+        protected override FixedFieldMap<KafkaOperationBinding> FixedFieldMap => new()
         {
             { "bindingVersion", (a, n) => { a.BindingVersion = n.GetScalarValue(); } },
             { "groupId", (a, n) => { a.GroupId = JsonSchemaDeserializer.LoadSchema(n); } },

@@ -24,7 +24,7 @@ public class KafkaServerBinding : ServerBinding<KafkaServerBinding>
 
         public override string BindingKey => "kafka";
 
-        protected override FixedFieldMap<KafkaServerBinding> FixedFieldMap => new ()
+        protected override FixedFieldMap<KafkaServerBinding> FixedFieldMap => new()
         {
             { "bindingVersion", (a, n) => { a.BindingVersion = n.GetScalarValue(); } },
             { "schemaRegistryUrl", (a, n) => { a.SchemaRegistryUrl = n.GetScalarValue(); } },

@@ -1,5 +1,5 @@
 <Project Sdk="Microsoft.NET.Sdk">
-  <Import Project="../../Common.Build.props"/>
+  <Import Project="../../Common.Build.props" />
   <PropertyGroup>
 	  <Description>AsyncAPI.NET Bindings</Description>
 	  <PackageId>AsyncAPI.NET.Bindings</PackageId>
@@ -15,7 +15,7 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="StyleCop.Analyzers" Version="1.1.118">
+    <PackageReference Include="StyleCop.Analyzers" Version="1.2.0-beta.556">
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
     </PackageReference>

@@ -54,7 +54,7 @@ public override void SerializeProperties(IAsyncApiWriter writer)
 
         public override string BindingKey => "mqtt";
 
-        protected override FixedFieldMap<MQTTMessageBinding> FixedFieldMap => new ()
+        protected override FixedFieldMap<MQTTMessageBinding> FixedFieldMap => new()
         {
             { "payloadFormatIndicator", (a, n) => { a.PayloadFormatIndicator = n.GetIntegerValueOrDefault(); } },
             { "correlationData", (a, n) => { a.CorrelationData = JsonSchemaDeserializer.LoadSchema(n); } },

@@ -49,7 +49,7 @@ public class MQTTServerBinding : ServerBinding<MQTTServerBinding>
 
         public override string BindingKey => "mqtt";
 
-        protected override FixedFieldMap<MQTTServerBinding> FixedFieldMap => new ()
+        protected override FixedFieldMap<MQTTServerBinding> FixedFieldMap => new()
         {
             { "bindingVersion", (a, n) => { a.BindingVersion = n.GetScalarValue(); } },
             { "clientId", (a, n) => { a.ClientId = n.GetScalarValue(); } },
@@ -60,7 +60,7 @@ public class MQTTServerBinding : ServerBinding<MQTTServerBinding>
             { "maximumPacketSize", (a, n) => { a.MaximumPacketSize = n.GetIntegerValueOrDefault(); } },
         };
 
-        private static FixedFieldMap<LastWill> LastWillFixedFields = new ()
+        private static FixedFieldMap<LastWill> LastWillFixedFields = new()
         {
             { "topic", (a, n) => { a.Topic = n.GetScalarValue(); } },
             { "qos", (a, n) => { a.QoS = (uint?)n.GetIntegerValueOrDefault(); } },

@@ -6,7 +6,7 @@ namespace LEGO.AsyncAPI.Bindings
     using LEGO.AsyncAPI.Readers;
     using LEGO.AsyncAPI.Readers.ParseNodes;
 
-    public abstract class OperationBinding<T> : Binding<T> , IOperationBinding
+    public abstract class OperationBinding<T> : Binding<T>, IOperationBinding
         where T : IOperationBinding, new()
     {
         protected abstract FixedFieldMap<T> FixedFieldMap { get; }

@@ -68,7 +68,7 @@ public override void SerializeProperties(IAsyncApiWriter writer)
             writer.WriteEndObject();
         }
 
-        protected override FixedFieldMap<PulsarChannelBinding> FixedFieldMap => new ()
+        protected override FixedFieldMap<PulsarChannelBinding> FixedFieldMap => new()
         {
             { "bindingVersion", (a, n) => { a.BindingVersion = n.GetScalarValue(); } },
             { "namespace", (a, n) => { a.Namespace = n.GetScalarValue(); } },
@@ -80,7 +80,7 @@ public override void SerializeProperties(IAsyncApiWriter writer)
             { "deduplication", (a, n) => { a.Deduplication = n.GetBooleanValue(); } },
         };
 
-        private FixedFieldMap<RetentionDefinition> pulsarServerBindingRetentionFixedFields = new ()
+        private FixedFieldMap<RetentionDefinition> pulsarServerBindingRetentionFixedFields = new()
         {
             { "time", (a, n) => { a.Time = n.GetIntegerValue(); } },
             { "size", (a, n) => { a.Size = n.GetIntegerValue(); } },

@@ -19,7 +19,7 @@ public class PulsarServerBinding : ServerBinding<PulsarServerBinding>
 
         public override string BindingKey => "pulsar";
 
-        protected override FixedFieldMap<PulsarServerBinding> FixedFieldMap => new ()
+        protected override FixedFieldMap<PulsarServerBinding> FixedFieldMap => new()
         {
             { "bindingVersion", (a, n) => { a.BindingVersion = n.GetScalarValue(); } },
             { "tenant", (a, n) => { a.Tenant = n.GetScalarValue(); } },

@@ -1,3 +1,5 @@
+// Copyright (c) The LEGO Group. All rights reserved.
+
 namespace LEGO.AsyncAPI.Bindings.Sns
 {
     using System;
@@ -24,7 +26,7 @@ public class Consumer : IAsyncApiExtensible
         /// Depending on the FilterPolicyScope, a map of either a message attribute or message body to an array of possible matches. The match may be a simple string for an exact match, but it may also be an object that represents a constraint and values for that constraint.
         /// </summary>
         public AsyncApiAny FilterPolicy { get; set; }
-        
+
         /// <summary>
         /// Determines whether the FilterPolicy applies to MessageAttributes or MessageBody.
         /// </summary>
@@ -85,7 +87,7 @@ public enum Protocol
         [Display("lambda")] Lambda,
         [Display("firehose")] Firehose,
     }
-    
+
     public enum FilterPolicyScope
     {
         [Display("MessageAttributes")] MessageAttributes,

@@ -1,3 +1,5 @@
+// Copyright (c) The LEGO Group. All rights reserved.
+
 namespace LEGO.AsyncAPI.Bindings.Sns
 {
     using System;

@@ -1,3 +1,5 @@
+// Copyright (c) The LEGO Group. All rights reserved.
+
 namespace LEGO.AsyncAPI.Bindings.Sns
 {
     using System;

@@ -1,3 +1,5 @@
+// Copyright (c) The LEGO Group. All rights reserved.
+
 namespace LEGO.AsyncAPI.Bindings.Sns
 {
     using System;

@@ -1,3 +1,5 @@
+// Copyright (c) The LEGO Group. All rights reserved.
+
 namespace LEGO.AsyncAPI.Bindings.Sns
 {
     using System;

@@ -1,3 +1,5 @@
+// Copyright (c) The LEGO Group. All rights reserved.
+
 namespace LEGO.AsyncAPI.Bindings.Sns
 {
     using System;

@@ -1,3 +1,5 @@
+// Copyright (c) The LEGO Group. All rights reserved.
+
 namespace LEGO.AsyncAPI.Bindings.Sns
 {
     using System;

@@ -1,3 +1,5 @@
+// Copyright (c) The LEGO Group. All rights reserved.
+
 namespace LEGO.AsyncAPI.Bindings.Sns
 {
     using System;
@@ -43,7 +45,7 @@ public class SnsOperationBinding : OperationBinding<SnsOperationBinding>
             { "name", (a, n) => { a.Name = n.GetScalarValue(); } },
         };
 
-        private FixedFieldMap<Consumer> consumerFixedFields => new ()
+        private FixedFieldMap<Consumer> consumerFixedFields => new()
         {
             { "protocol", (a, n) => { a.Protocol = n.GetScalarValue().GetEnumFromDisplayName<Protocol>(); } },
             { "endpoint", (a, n) => { a.Endpoint = n.ParseMapWithExtensions(this.identifierFixFields); } },

@@ -1,3 +1,5 @@
+// Copyright (c) The LEGO Group. All rights reserved.
+
 namespace LEGO.AsyncAPI.Bindings.Sns
 {
     using System;
@@ -8,7 +10,6 @@ namespace LEGO.AsyncAPI.Bindings.Sns
 
     public class Statement : IAsyncApiExtensible
     {
-
         public Effect Effect { get; set; }
 
         /// <summary>

@@ -1,3 +1,5 @@
+// Copyright (c) The LEGO Group. All rights reserved.
+
 namespace LEGO.AsyncAPI.Bindings.Sqs
 {
     using System;

@@ -1,3 +1,5 @@
+// Copyright (c) The LEGO Group. All rights reserved.
+
 namespace LEGO.AsyncAPI.Bindings.Sqs
 {
     using System;

@@ -1,3 +1,5 @@
+// Copyright (c) The LEGO Group. All rights reserved.
+
 namespace LEGO.AsyncAPI.Bindings.Sqs
 {
     using System;
@@ -26,7 +28,7 @@ public class Queue : IAsyncApiExtensible
         /// <summary>
         /// Specifies whether the FIFO queue throughput quota applies to the entire queue or per message group. Valid values are perQueue (default) and perMessageGroupId.
         /// </summary>
-       public FifoThroughputLimit? FifoThroughputLimit { get; set; }
+        public FifoThroughputLimit? FifoThroughputLimit { get; set; }
 
         /// <summary>
         /// The number of seconds to delay before a message sent to the queue can be received. used to create a delay queue.

@@ -1,3 +1,5 @@
+// Copyright (c) The LEGO Group. All rights reserved.
+
 namespace LEGO.AsyncAPI.Bindings.Sqs
 {
     using System;

@@ -1,3 +1,5 @@
+// Copyright (c) The LEGO Group. All rights reserved.
+
 namespace LEGO.AsyncAPI.Bindings.Sqs
 {
     using System;

@@ -1,3 +1,5 @@
+// Copyright (c) The LEGO Group. All rights reserved.
+
 namespace LEGO.AsyncAPI.Bindings.Sqs
 {
     using System;

@@ -1,3 +1,5 @@
+// Copyright (c) The LEGO Group. All rights reserved.
+
 namespace LEGO.AsyncAPI.Bindings.Sqs
 {
     using System;
@@ -8,7 +10,6 @@ namespace LEGO.AsyncAPI.Bindings.Sqs
 
     public class Statement : IAsyncApiExtensible
     {
-
         public Effect Effect { get; set; }
 
         /// <summary>

@@ -18,7 +18,7 @@ public StringOrStringList(AsyncApiAny value)
             {
                 JsonArray array => IsValidStringList(array) ? new AsyncApiAny(array) : throw new ArgumentException($"{nameof(StringOrStringList)} value should only contain string items."),
                 JsonValue jValue => IsString(jValue) ? new AsyncApiAny(jValue) : throw new ArgumentException($"{nameof(StringOrStringList)} should be a string value or a string list."),
-                _ => throw new ArgumentException($"{nameof(StringOrStringList)} should be a string value or a string list.")
+                _ => throw new ArgumentException($"{nameof(StringOrStringList)} should be a string value or a string list."),
             };
         }
 
@@ -31,15 +31,15 @@ public static StringOrStringList Parse(ParseNode node)
                 case ValueNode:
                     return new StringOrStringList(new AsyncApiAny(node.GetScalarValue()));
                 case ListNode:
-                {
-                    var jsonArray = new JsonArray();
-                    foreach (var item in node as ListNode)
                     {
-                        jsonArray.Add(item.GetScalarValue());
-                    }
+                        var jsonArray = new JsonArray();
+                        foreach (var item in node as ListNode)
+                        {
+                            jsonArray.Add(item.GetScalarValue());
+                        }
 
-                    return new StringOrStringList(new AsyncApiAny(jsonArray));
-                }
+                        return new StringOrStringList(new AsyncApiAny(jsonArray));
+                    }
 
                 default:
                     throw new ArgumentException($"An error occured while parsing a {nameof(StringOrStringList)} node. " +

@@ -25,9 +25,9 @@ public class WebSocketsChannelBinding : ChannelBinding<WebSocketsChannelBinding>
         /// </summary>
         public AsyncApiSchema Headers { get; set; }
 
-       public override  string BindingKey => "websockets";
+        public override string BindingKey => "websockets";
 
-        protected override FixedFieldMap<WebSocketsChannelBinding> FixedFieldMap => new ()
+        protected override FixedFieldMap<WebSocketsChannelBinding> FixedFieldMap => new()
         {
             { "bindingVersion", (a, n) => { a.BindingVersion = n.GetScalarValue(); } },
             { "method", (a, n) => { a.Method = n.GetScalarValue(); } },