feat(bindings): add SNS AWS bindings

src/LEGO.AsyncAPI.Bindings/BindingsCollection.cs

@@ -1,14 +1,13 @@
 // Copyright (c) The LEGO Group. All rights reserved.
-
-using LEGO.AsyncAPI.Bindings.Sqs;
-
 namespace LEGO.AsyncAPI.Bindings
 {
     using System;
     using System.Collections.Generic;
     using LEGO.AsyncAPI.Bindings.Http;
     using LEGO.AsyncAPI.Bindings.Kafka;
     using LEGO.AsyncAPI.Bindings.Pulsar;
+    using LEGO.AsyncAPI.Bindings.Sns;
+    using LEGO.AsyncAPI.Bindings.Sqs;
     using LEGO.AsyncAPI.Bindings.WebSockets;
     using LEGO.AsyncAPI.Models.Interfaces;
     using LEGO.AsyncAPI.Readers.Interface;
@@ -43,6 +42,8 @@ public static TCollection Add<TCollection, TItem>(
             Kafka,
             Http,
             Websockets,
+            Sqs,
+            Sns,
         };
 
         public static IEnumerable<IBindingParser<IBinding>> Http => new List<IBindingParser<IBinding>>
@@ -75,5 +76,11 @@ public static TCollection Add<TCollection, TItem>(
             new SqsChannelBinding(),
             new SqsOperationBinding(),
         };
+
+        public static IEnumerable<IBindingParser<IBinding>> Sns => new List<IBindingParser<IBinding>>
+        {
+            new SnsChannelBinding(),
+            new SnsOperationBinding(),
+        };
     }
 }

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

@@ -0,0 +1,80 @@
+namespace LEGO.AsyncAPI.Bindings.Sns
+{
+    using System;
+    using System.Collections.Generic;
+    using LEGO.AsyncAPI.Attributes;
+    using LEGO.AsyncAPI.Models.Interfaces;
+    using LEGO.AsyncAPI.Writers;
+
+    public class Consumer : IAsyncApiExtensible
+    {
+        /// <summary>
+        /// The protocol that this endpoint will receive messages by.
+        /// </summary>
+        public Protocol Protocol { get; set; }
+
+        /// <summary>
+        /// The endpoint messages are delivered to.
+        /// </summary>
+        public Identifier Endpoint { get; set; }
+
+        /// <summary>
+        /// Only receive a subset of messages from the channel, determined by this policy.
+        /// </summary>
+        public FilterPolicy FilterPolicy { get; set; }
+
+        /// <summary>
+        /// If true AWS SNS attributes are removed from the body, and for SQS, SNS message attributes are copied to SQS message attributes. If false the SNS attributes are included in the body.
+        /// </summary>
+        public bool RawMessageDelivery { get; set; }
+
+        /// <summary>
+        /// Prevent poison pill messages by moving un-processable messages to an SQS dead letter queue.
+        /// </summary>
+        public RedrivePolicy RedrivePolicy { get; set; }
+
+        /// <summary>
+        /// Policy for retries to HTTP. The parameter is for that SNS Subscription and overrides any policy on the SNS Topic.
+        /// </summary>
+        public DeliveryPolicy DeliveryPolicy { get; set; }
+
+        /// <summary>
+        /// The display name to use with an SNS subscription.
+        /// </summary>
+        public string DisplayName { get; set; }
+
+        public IDictionary<string, IAsyncApiExtension> Extensions { get; set; } = new Dictionary<string, IAsyncApiExtension>();
+
+        public void Serialize(IAsyncApiWriter writer)
+        {
+            if (writer is null)
+            {
+                throw new ArgumentNullException(nameof(writer));
+            }
+
+            writer.WriteStartObject();
+            writer.WriteRequiredProperty("protocol", this.Protocol.GetDisplayName());
+            writer.WriteRequiredObject("endpoint", this.Endpoint, (w, e) => e.Serialize(w));
+            writer.WriteOptionalObject("filterPolicy", this.FilterPolicy, (w, f) => f.Serialize(w));
+            writer.WriteRequiredProperty("rawMessageDelivery", this.RawMessageDelivery);
+            writer.WriteOptionalObject("redrivePolicy", this.RedrivePolicy, (w, p) => p.Serialize(w));
+            writer.WriteOptionalObject("deliveryPolicy", this.DeliveryPolicy, (w, p) => p.Serialize(w));
+            writer.WriteOptionalProperty("displayName", this.DisplayName);
+            writer.WriteExtensions(this.Extensions);
+            writer.WriteEndObject();
+        }
+    }
+
+    public enum Protocol
+    {
+        [Display("http")] Http,
+        [Display("https")] Https,
+        [Display("email")] Email,
+        [Display("email-json")] EmailJson,
+        [Display("sms")] Sms,
+        [Display("sqs")] Sqs,
+        [Display("application")] Application,
+        [Display("lambda")] Lambda,
+        [Display("firehose")] Firehose,
+    }
+}

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

@@ -0,0 +1,81 @@
+namespace LEGO.AsyncAPI.Bindings.Sns
+{
+    using System;
+    using System.Collections.Generic;
+    using LEGO.AsyncAPI.Attributes;
+    using LEGO.AsyncAPI.Models.Interfaces;
+    using LEGO.AsyncAPI.Writers;
+
+    public class DeliveryPolicy : IAsyncApiExtensible
+    {
+        /// <summary>
+        /// The minimum delay for a retry in seconds.
+        /// </summary>
+        public int? MinDelayTarget { get; set; }
+
+        /// <summary>
+        /// The maximum delay for a retry in seconds.
+        /// </summary>
+        public int? MaxDelayTarget { get; set; }
+
+        /// <summary>
+        /// The total number of retries, including immediate, pre-backoff, backoff, and post-backoff retries.
+        /// </summary>
+        public int? NumRetries { get; set; }
+
+        /// <summary>
+        /// The number of immediate retries (with no delay).
+        /// </summary>
+        public int? NumNoDelayRetries { get; set; }
+
+        /// <summary>
+        /// The number of immediate retries (with delay).
+        /// </summary>
+        public int? NumMinDelayRetries { get; set; }
+
+        /// <summary>
+        /// The number of post-backoff phase retries, with the maximum delay between retries.
+        /// </summary>
+        public int? NumMaxDelayRetries { get; set; }
+
+        /// <summary>
+        /// The algorithm for backoff between retries.
+        /// </summary>
+        public BackoffFunction BackoffFunction { get; set; }
+
+        /// <summary>
+        /// The maximum number of deliveries per second, per subscription.
+        /// </summary>
+        public int? MaxReceivesPerSecond { get; set; }
+
+        public IDictionary<string, IAsyncApiExtension> Extensions { get; set; } = new Dictionary<string, IAsyncApiExtension>();
+
+        public void Serialize(IAsyncApiWriter writer)
+        {
+            if (writer is null)
+            {
+                throw new ArgumentNullException(nameof(writer));
+            }
+
+            writer.WriteStartObject();
+            writer.WriteOptionalProperty("minDelayTarget", this.MinDelayTarget);
+            writer.WriteOptionalProperty("maxDelayTarget", this.MaxDelayTarget);
+            writer.WriteOptionalProperty("numRetries", this.NumRetries);
+            writer.WriteOptionalProperty("numNoDelayRetries", this.NumNoDelayRetries);
+            writer.WriteOptionalProperty("numMinDelayRetries", this.NumMinDelayRetries);
+            writer.WriteOptionalProperty("numMaxDelayRetries", this.NumMaxDelayRetries);
+            writer.WriteOptionalProperty("backoffFunction", this.BackoffFunction.GetDisplayName());
+            writer.WriteOptionalProperty("maxReceivesPerSecond", this.MaxReceivesPerSecond);
+            writer.WriteExtensions(this.Extensions);
+            writer.WriteEndObject();
+        }
+    }
+
+    public enum BackoffFunction
+    {
+        [Display("arithmetic")] Arithmetic,
+        [Display("exponential")] Exponential,
+        [Display("geometric")] Geometric,
+        [Display("linear")] Linear,
+    }
+}

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

@@ -0,0 +1,30 @@
+namespace LEGO.AsyncAPI.Bindings.Sns
+{
+    using System;
+    using System.Collections.Generic;
+    using LEGO.AsyncAPI.Models.Interfaces;
+    using LEGO.AsyncAPI.Writers;
+
+    public class FilterPolicy : IAsyncApiExtensible
+    {
+        /// <summary>
+        /// A map of a message attribute 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 IAsyncApiAny Attributes { get; set; }
+
+        public IDictionary<string, IAsyncApiExtension> Extensions { get; set; } = new Dictionary<string, IAsyncApiExtension>();
+
+        public void Serialize(IAsyncApiWriter writer)
+        {
+            if (writer is null)
+            {
+                throw new ArgumentNullException(nameof(writer));
+            }
+
+            writer.WriteStartObject();
+            writer.WriteRequiredObject("attributes", this.Attributes, (w, a) => w.WriteAny(a));
+            writer.WriteExtensions(this.Extensions);
+            writer.WriteEndObject();
+        }
+    }
+}

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

@@ -0,0 +1,39 @@
+namespace LEGO.AsyncAPI.Bindings.Sns
+{
+    using System;
+    using System.Collections.Generic;
+    using LEGO.AsyncAPI.Models.Interfaces;
+    using LEGO.AsyncAPI.Writers;
+
+    public class Identifier : IAsyncApiExtensible
+    {
+        public string Url { get; set; }
+
+        public string Email { get; set; }
+
+        public string Phone { get; set; }
+
+        public string Arn { get; set; }
+
+        public string Name { get; set; }
+
+        public IDictionary<string, IAsyncApiExtension> Extensions { get; set; } = new Dictionary<string, IAsyncApiExtension>();
+
+        public void Serialize(IAsyncApiWriter writer)
+        {
+            if (writer is null)
+            {
+                throw new ArgumentNullException(nameof(writer));
+            }
+
+            writer.WriteStartObject();
+            writer.WriteOptionalProperty("url", this.Url);
+            writer.WriteOptionalProperty("email", this.Email);
+            writer.WriteOptionalProperty("phone", this.Phone);
+            writer.WriteOptionalProperty("arn", this.Arn);
+            writer.WriteOptionalProperty("name", this.Name);
+            writer.WriteExtensions(this.Extensions);
+            writer.WriteEndObject();
+        }
+    }
+}

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

@@ -0,0 +1,45 @@
+namespace LEGO.AsyncAPI.Bindings.Sns
+{
+    using System;
+    using System.Collections.Generic;
+    using LEGO.AsyncAPI.Attributes;
+    using LEGO.AsyncAPI.Models.Interfaces;
+    using LEGO.AsyncAPI.Writers;
+
+    public class Ordering : IAsyncApiExtensible
+    {
+        /// <summary>
+        /// What type of SNS Topic is this?
+        /// </summary>
+        public OrderingType Type { get; set; }
+
+        /// <summary>
+        /// True to turn on de-duplication of messages for a channel.
+        /// </summary>
+        public bool ContentBasedDeduplication { get; set; }
+
+        public IDictionary<string, IAsyncApiExtension> Extensions { get; set; } = new Dictionary<string, IAsyncApiExtension>();
+
+        public void Serialize(IAsyncApiWriter writer)
+        {
+            if (writer is null)
+            {
+                throw new ArgumentNullException(nameof(writer));
+            }
+
+            writer.WriteStartObject();
+            writer.WriteRequiredProperty("type", this.Type.GetDisplayName());
+            writer.WriteOptionalProperty("contentBasedDeduplication", this.ContentBasedDeduplication);
+            writer.WriteExtensions(this.Extensions);
+            writer.WriteEndObject();
+        }
+    }
+
+    public enum OrderingType
+    {
+        [Display("standard")]
+        Standard,
+        [Display("FIFO")]
+        Fifo,
+    }
+}

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

@@ -0,0 +1,31 @@
+namespace LEGO.AsyncAPI.Bindings.Sns
+{
+    using System;
+    using System.Collections.Generic;
+    using LEGO.AsyncAPI.Models;
+    using LEGO.AsyncAPI.Models.Interfaces;
+    using LEGO.AsyncAPI.Writers;
+
+    public class Policy : IAsyncApiExtensible
+    {
+        /// <summary>
+        /// An array of statement objects, each of which controls a permission for this topic.
+        /// </summary>
+        public List<Statement> Statements { get; set; }
+
+        public IDictionary<string, IAsyncApiExtension> Extensions { get; set; } = new Dictionary<string, IAsyncApiExtension>();
+
+        public void Serialize(IAsyncApiWriter writer)
+        {
+            if (writer is null)
+            {
+                throw new ArgumentNullException(nameof(writer));
+            }
+
+            writer.WriteStartObject();
+            writer.WriteOptionalCollection("statements", this.Statements, (w, t) => t.Serialize(w));
+            writer.WriteExtensions(this.Extensions);
+            writer.WriteEndObject();
+        }
+    }
+}

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

@@ -0,0 +1,36 @@
+namespace LEGO.AsyncAPI.Bindings.Sns
+{
+    using System;
+    using System.Collections.Generic;
+    using LEGO.AsyncAPI.Models.Interfaces;
+    using LEGO.AsyncAPI.Writers;
+
+    public class RedrivePolicy : IAsyncApiExtensible
+    {
+        /// <summary>
+        /// Prevent poison pill messages by moving un-processable messages to an SQS dead letter queue.
+        /// </summary>
+        public Identifier DeadLetterQueue { get; set; }
+
+        /// <summary>
+        /// The number of times a message is delivered to the source queue before being moved to the dead-letter queue.
+        /// </summary>
+        public int? MaxReceiveCount { get; set; }
+
+        public IDictionary<string, IAsyncApiExtension> Extensions { get; set; } = new Dictionary<string, IAsyncApiExtension>();
+
+        public void Serialize(IAsyncApiWriter writer)
+        {
+            if (writer is null)
+            {
+                throw new ArgumentNullException(nameof(writer));
+            }
+
+            writer.WriteStartObject();
+            writer.WriteRequiredObject("deadLetterQueue", this.DeadLetterQueue, (w, q) => q.Serialize(w));
+            writer.WriteOptionalProperty("maxReceiveCount", this.MaxReceiveCount);
+            writer.WriteExtensions(this.Extensions);
+            writer.WriteEndObject();
+        }
+    }
+}