unit with bindings

asyncapi · Aug 8, 2024 · c03cf70 · c03cf70
1 parent dacc7d8
commit c03cf70
Show file tree

Hide file tree

Showing 2 changed files with 57 additions and 0 deletions.
diff --git a/test/Saunter.Tests/AttributeProvider/DocumentGenerationTests/ArrangeAttributesTests.cs b/test/Saunter.Tests/AttributeProvider/DocumentGenerationTests/ArrangeAttributesTests.cs
@@ -26,6 +26,7 @@ public FakeAsyncApiOptions(Type[] types)
         public static void Arrange(out AsyncApiOptions options, out AttributeDocumentProvider documentProvider, params Type[] targetTypes)
         {
             options = new FakeAsyncApiOptions(targetTypes);
+
             documentProvider = new AttributeDocumentProvider(
                 ActivatorServiceProvider.Instance,
                 new AsyncApiSchemaGenerator(),

diff --git a/test/Saunter.Tests/AttributeProvider/DocumentGenerationTests/MethodAttributesTests.cs b/test/Saunter.Tests/AttributeProvider/DocumentGenerationTests/MethodAttributesTests.cs
@@ -1,4 +1,5 @@
 using System;
+using LEGO.AsyncAPI.Bindings.Kafka;
 using Saunter.AttributeProvider.Attributes;
 using Shouldly;
 using Xunit;
@@ -42,6 +43,61 @@ public void PublishTenantEvent<TEvent>(Guid tenantId, TEvent @event)
             {
             }
         }
+
+        [Fact]
+        public void GenerateDocument_GeneratesDocumentWithKafkaOperationBinding()
+        {
+            // Arrange
+            ArrangeAttributesTests.Arrange(out var options, out var documentProvider, typeof(TenantMessagePublisherWithBind));
+
+            options.AsyncApi.Components = new()
+            {
+                OperationBindings =
+                {
+                    {
+                        "sample_kaffka",
+                        new()
+                        {
+                            new KafkaOperationBinding()
+                            {
+                                ClientId = new()
+                                {
+                                    Type = LEGO.AsyncAPI.Models.SchemaType.Integer,
+                                }
+                            }
+                        }
+                    }
+                }
+            };
+
+            // Act
+            var document = documentProvider.GetDocument(null, options);
+
+            // Assert
+            document.ShouldNotBeNull();
+
+            var channel = document.AssertAndGetChannel("asw.tenant_service.tenants_history.with_bind", "Tenant events.");
+
+            var publish = channel.Publish;
+            publish.ShouldNotBeNull();
+            publish.OperationId.ShouldBe("TenantMessagePublisher");
+            publish.Summary.ShouldBe("Publish domains events about tenants.");
+            publish.Bindings.Reference.Reference.ShouldBe("#/components/operationBindings/sample_kaffka");
+
+            document.AssertByMessage(publish, "anyTenantCreated");
+        }
+
+        [AsyncApi]
+        public class TenantMessagePublisherWithBind : ITenantMessagePublisher
+        {
+            [Channel("asw.tenant_service.tenants_history.with_bind", Description = "Tenant events.")]
+            [PublishOperation(OperationId = "TenantMessagePublisher", Summary = "Publish domains events about tenants.", BindingsRef = "sample_kaffka")]
+            [Message(typeof(AnyTenantCreated))]
+            public void PublishTenantEvent<TEvent>(Guid tenantId, TEvent @event)
+                where TEvent : IEvent
+            {
+            }
+        }
     }
 
     public class AnyTenantCreated : IEvent { }