[#12] - implement idempotency support

Boundaries/Comanda.Orchestrator/Source/Comanda.Orchestrator.WebApi/Comanda.Orchestrator.WebApi.csproj

@@ -13,6 +13,7 @@
 
   <ItemGroup>
     <PackageReference Include="FluentValidation.AspNetCore" Version="11.3.1" />
+    <PackageReference Include="Idempwanna" Version="1.0.0" />
     <PackageReference Include="Microsoft.AspNetCore.HeaderPropagation" Version="9.0.11" />
     <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="9.0.11" />
     <PackageReference Include="Scalar.AspNetCore" Version="2.12.7" />

Boundaries/Comanda.Orchestrator/Source/Comanda.Orchestrator.WebApi/Controllers/OrdersController.cs

@@ -32,6 +32,7 @@ public async Task<IActionResult> GetOrdersAsync([FromQuery] OrdersFetchParameter
     }
 
     [HttpPost]
+    [Idempotent] // https://developer.mozilla.org/en-US/docs/Glossary/Idempotent
     [Authorize(Roles = Permissions.CreateOrder)]
     public async Task<IActionResult> CreateOrderAsync([FromBody] OrderCreationScheme request, CancellationToken cancellation)
     {

Boundaries/Comanda.Orchestrator/Source/Comanda.Orchestrator.WebApi/Controllers/PaymentsController.cs

@@ -7,6 +7,7 @@
 public sealed class PaymentsController(IDispatcher dispatcher, IEventDispatcher eventDispatcher) : ControllerBase
 {
     [HttpPost("online")]
+    [Idempotent] // https://developer.mozilla.org/en-US/docs/Glossary/Idempotent
     [Authorize(Roles = Permissions.MakePayment)]
     public async Task<IActionResult> CreateOnlineChargeAsync(
         [FromBody] CheckoutSessionCreationScheme request, [FromHeader(Name = Headers.Credential)] string credential, CancellationToken cancellation)
@@ -33,6 +34,7 @@ public async Task<IActionResult> CreateOnlineChargeAsync(
     }
 
     [HttpPost("offline")]
+    [Idempotent] // https://developer.mozilla.org/en-US/docs/Glossary/Idempotent
     [Authorize(Roles = Permissions.MakePayment)]
     public async Task<IActionResult> CreateOfflinePaymentAsync([FromBody] OfflinePaymentScheme request, CancellationToken cancellation)
     {

Boundaries/Comanda.Orchestrator/Source/Comanda.Orchestrator.WebApi/Controllers/ProfilesController.cs

@@ -32,6 +32,7 @@ public async Task<IActionResult> GetCustomersAsync([FromQuery] FetchCustomersPar
     }
 
     [HttpPost("customers")]
+    [Idempotent] // https://developer.mozilla.org/en-US/docs/Glossary/Idempotent
     [Authorize]
     public async Task<IActionResult> CreateCustomerAsync([FromBody] CustomerCreationScheme request, CancellationToken cancellation)
     {
@@ -138,6 +139,7 @@ public async Task<IActionResult> GetCustomerAddressesAsync(
 
     [HttpPost("customers/{customerId}/addresses")]
     [Authorize(Roles = Permissions.EditCustomers)]
+    [Idempotent]
     public async Task<IActionResult> AssignCustomerAddressAsync(
         [FromBody] AssignCustomerAddressScheme request, [FromRoute] string customerId, CancellationToken cancellation)
     {
@@ -232,6 +234,7 @@ public async Task<IActionResult> GetOwnersAsync([FromQuery] FetchOwnersParameter
     }
 
     [HttpPost("owners")]
+    [Idempotent] // https://developer.mozilla.org/en-US/docs/Glossary/Idempotent
     [Authorize]
     public async Task<IActionResult> CreateOwnerAsync([FromBody] OwnerCreationScheme request, CancellationToken cancellation)
     {

Boundaries/Comanda.Orchestrator/Source/Comanda.Orchestrator.WebApi/Controllers/StoresController.cs

@@ -35,6 +35,7 @@ public async Task<IActionResult> GetEstablishmentsAsync(
     }
 
     [HttpPost]
+    [Idempotent] // https://developer.mozilla.org/en-US/docs/Glossary/Idempotent
     [Authorize(Roles = Permissions.CreateEstablishment)]
     public async Task<IActionResult> CreateEstablishmentAsync(
         [FromBody] EstablishmentCreationScheme request, CancellationToken cancellation)
@@ -111,6 +112,7 @@ public async Task<IActionResult> DeleteEstablishmentAsync(
 
     [HttpPost("{establishmentId}/checkout")]
     [Authorize(Roles = Permissions.MakePayment)]
+    [Idempotent] // https://developer.mozilla.org/en-US/docs/Glossary/Idempotent
     public async Task<IActionResult> CheckoutAsync(
         [FromBody] CreateCheckoutScheme request, [FromRoute] string establishmentId, CancellationToken cancellation)
     {
@@ -162,6 +164,7 @@ public async Task<IActionResult> GetProductsAsync(
 
     [HttpPost("{establishmentId}/products")]
     [Authorize(Roles = Permissions.CreateProduct)]
+    [Idempotent] // https://developer.mozilla.org/en-US/docs/Glossary/Idempotent
     public async Task<IActionResult> CreateProductAsync(
         [FromBody] ProductCreationScheme request, [FromRoute] string establishmentId, CancellationToken cancellation)
     {
@@ -292,6 +295,7 @@ public async Task<IActionResult> GetCredentialsAsync(
 
     [HttpPost("{establishmentId}/integrations/credentials")]
     [Authorize(Roles = Permissions.CreateCredential)]
+    [Idempotent] // https://developer.mozilla.org/en-US/docs/Glossary/Idempotent
     public async Task<IActionResult> AssignCredentialAsync(
         [FromBody] CredentialCreationScheme request, [FromRoute] string establishmentId, CancellationToken cancellation)
     {

Boundaries/Comanda.Orchestrator/Source/Comanda.Orchestrator.WebApi/Controllers/SubscriptionsController.cs

@@ -6,6 +6,7 @@ public sealed class SubscriptionsController(IDispatcher dispatcher) : Controller
 {
     [HttpPost]
     [Authorize(Roles = Permissions.Subscribe)]
+    [Idempotent] // https://developer.mozilla.org/en-US/docs/Glossary/Idempotent
     public async Task<IActionResult> CreateCheckoutSessionAsync(
         [FromBody] SubscriptionCheckoutSessionCreationScheme request, CancellationToken cancellation)
     {
@@ -29,6 +30,7 @@ public async Task<IActionResult> CreateCheckoutSessionAsync(
 
     [HttpDelete("{id}")]
     [Authorize(Roles = Permissions.CancelSubscription)]
+    [Idempotent] // https://developer.mozilla.org/en-US/docs/Glossary/Idempotent
     public async Task<IActionResult> CancelSubscriptionAsync(
         [FromQuery] SubscriptionCancelationScheme request, [FromRoute] string id, CancellationToken cancellation)
     {

Boundaries/Comanda.Orchestrator/Source/Comanda.Orchestrator.WebApi/Extensions/WebInfrastructureExtension.cs

@@ -27,5 +27,13 @@ public static void AddWebComposition(this IServiceCollection services)
             options.Realm = settings.Federation.Realm;
             options.ClientSecret = settings.Federation.ClientSecret;
         });
+
+        services.AddIdempotency()
+            .WithInMemoryCache(options =>
+            {
+                options.DefaultCacheExpiration = TimeSpan.FromMinutes(1);
+                options.DefaultHeaderName = Headers.Idempotency;
+                options.ThrowOnMissingKey = false;
+            });
     }
 }

Boundaries/Comanda.Orchestrator/Source/Comanda.Orchestrator.WebApi/Usings.cs

@@ -37,8 +37,11 @@
 global using HttpsRichardy.Federation.Sdk.Extensions;
 global using HttpsRichardy.Federation.Sdk.Contracts.Errors;
 
-global using Scalar.AspNetCore;
 global using Serilog;
 global using Serilog.Context;
+
+global using Scalar.AspNetCore;
 global using FluentValidation.AspNetCore;
 
+global using Idempwanna.Core.Configuration;
+global using Idempwanna.Core.Attributes;