Correção de erro na secret da Cliente.API

Author: jeffreysSharp

src/building blocks/JSE.Core/Messages/Integration/PedidoRealizadoIntegrationEvent.cs

@@ -0,0 +1,12 @@
+namespace JSE.Core.Messages.Integration
+{
+    public class PedidoRealizadoIntegrationEvent : IntegrationEvent
+    {
+        public Guid ClienteId { get; private set; }
+
+        public PedidoRealizadoIntegrationEvent(Guid clienteId)
+        {
+            ClienteId = clienteId;
+        }
+    }
+}

src/services/JSE.Carrinho.API/Configuration/MessageBusConfig.cs

@@ -0,0 +1,16 @@
+using JSE.Carrinho.API.Services;
+using JSE.Core.Utils;
+using JSE.MessageBus;
+
+namespace JSE.Carrinho.API.Configuration
+{
+    public static class MessageBusConfig
+    {
+        public static void AddMessageBusConfiguration(this IServiceCollection services,
+            IConfiguration configuration)
+        {
+            services.AddMessageBus(configuration.GetMessageQueueConnection("MessageBus"))
+                .AddHostedService<CarrinhoIntegrationHandler>();
+        }
+    }
+}

src/services/JSE.Carrinho.API/Data/CarrinhoContext.cs

@@ -51,7 +51,8 @@ protected override void OnModelCreating(ModelBuilder modelBuilder)
                 .WithOne(i => i.CarrinhoCliente)
                 .HasForeignKey(c => c.CarrinhoId);
 
-            foreach (var relationship in modelBuilder.Model.GetEntityTypes().SelectMany(e => e.GetForeignKeys())) relationship.DeleteBehavior = DeleteBehavior.ClientSetNull;
+            foreach (var relationship in modelBuilder.Model.GetEntityTypes()
+                .SelectMany(e => e.GetForeignKeys())) relationship.DeleteBehavior = DeleteBehavior.Cascade;
         }
     }
 }

src/services/JSE.Carrinho.API/JSE.Carrinho.API.csproj

@@ -18,11 +18,16 @@
     </PackageReference>
     <PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="8.0.10" />
     <PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" Version="8.0.10" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore.Tools" Version="8.0.10">
+      <PrivateAssets>all</PrivateAssets>
+      <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
+    </PackageReference>
     <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.21.0" />
     <PackageReference Include="Swashbuckle.AspNetCore" Version="6.4.0" />
   </ItemGroup>
 
   <ItemGroup>
+    <ProjectReference Include="..\..\building blocks\JSE.MessageBus\JSE.MessageBus.csproj" />
     <ProjectReference Include="..\..\building blocks\JSE.WebAPI.Core\JSE.WebAPI.Core.csproj" />
   </ItemGroup>
 

src/services/JSE.Carrinho.API/Program.cs

@@ -16,6 +16,8 @@
 builder.Services.AddJwtConfiguration(configuration);
 builder.Services.AddSwaggerConfiguration();
 builder.Services.RegisterServices();
+builder.Services.AddMessageBusConfiguration(configuration);
+
 
 var app = builder.Build();
 var environment = app.Environment;

src/services/JSE.Carrinho.API/Services/CarrinhoIntegrationHandler.cs

@@ -0,0 +1,46 @@
+using JSE.Carrinho.API.Data;
+using JSE.Core.Messages.Integration;
+using JSE.MessageBus;
+using Microsoft.EntityFrameworkCore;
+
+namespace JSE.Carrinho.API.Services
+{
+    public class CarrinhoIntegrationHandler : BackgroundService
+    {
+        private readonly IMessageBus _bus;
+        private readonly IServiceProvider _serviceProvider;
+
+        public CarrinhoIntegrationHandler(IMessageBus bus, IServiceProvider serviceProvider)
+        {
+            _serviceProvider = serviceProvider;
+            _bus = bus;
+        }
+
+        protected override Task ExecuteAsync(CancellationToken stoppingToken)
+        {
+            SetSubscribers();
+            return Task.CompletedTask;
+        }
+
+        private void SetSubscribers()
+        {
+            _bus.SubscribeAsync<PedidoRealizadoIntegrationEvent>("PedidoRealizado", async request =>
+               await ApagarCarrinho(request));
+        }
+
+        private async Task ApagarCarrinho(PedidoRealizadoIntegrationEvent message)
+        {
+            using var scope = _serviceProvider.CreateScope();
+            var context = scope.ServiceProvider.GetRequiredService<CarrinhoContext>();
+
+            var carrinho = await context.CarrinhoCliente.FirstOrDefaultAsync(c => c.ClienteId == message.ClienteId);
+
+            if (carrinho != null)
+            {
+                context.CarrinhoCliente.Remove(carrinho);
+                await context.SaveChangesAsync();
+            }
+        }
+
+    }
+}

src/services/JSE.Carrinho.API/appsettings.Development.json

@@ -2,12 +2,18 @@
   "ConnectionStrings": {
     "DefaultConnection": "Server=.\\SQLEXPRESS;Database=JeffStoreEnterprise;User Id=sa;Password=Asd123!!;Trusted_Connection=true;MultipleActiveResultSets=true;TrustServerCertificate=True;"
   },
+
+  "MessageQueueConnection": {
+    "MessageBus": "host=localhost:5672;publisherConfirms=true;timeout=10"
+  },
+
   "Logging": {
     "LogLevel": {
       "Default": "Information",
       "Microsoft.AspNetCore": "Warning"
     }
   },
+
   "AppSettings": {
     "Secret": "F9F52344-59C3-4EAC-90E6-CB47935038BE",
     "ExpirationHours": 2,

src/services/JSE.Client.API/appsettings.Development.json

@@ -2,23 +2,19 @@
   "ConnectionStrings": {
     "DefaultConnection": "Server=.\\SQLEXPRESS;Database=JeffStoreEnterprise;User Id=sa;Password=Asd123!!;Trusted_Connection=true;MultipleActiveResultSets=true;TrustServerCertificate=True;"
   },
-
   "MessageQueueConnection": {
     "MessageBus": "host=localhost:5672;publisherConfirms=true;timeout=10"
   },
-
   "Logging": {
     "LogLevel": {
       "Default": "Information",
       "Microsoft.AspNetCore": "Warning"
-    },
-
-    "AppSettings": {
-      "Secret": "F9F52344-59C3-4EAC-90E6-CB47935038BE",
-      "ExpirationHours": 2,
-      "Issuer": "MeuSistema",
-      "ValidOn": "https://localhost"
     }
-
+  },
+  "AppSettings": {
+    "Secret": "F9F52344-59C3-4EAC-90E6-CB47935038BE",
+    "ExpirationHours": 2,
+    "Issuer": "MeuSistema",
+    "ValidOn": "https://localhost"
   }
-}
+}

src/services/JSE.Pedido.API/Application/Events/PedidoEventHandler.cs

@@ -0,0 +1,21 @@
+using JSE.Core.Messages.Integration;
+using JSE.MessageBus;
+using MediatR;
+
+namespace JSE.Pedido_API.Application.Events
+{
+    public class PedidoEventHandler : INotificationHandler<PedidoRealizadoEvent>
+    {
+        private readonly IMessageBus _bus;
+
+        public PedidoEventHandler(IMessageBus bus)
+        {
+            _bus = bus;
+        }
+
+        public async Task Handle(PedidoRealizadoEvent message, CancellationToken cancellationToken)
+        {
+            await _bus.PublishAsync(new PedidoRealizadoIntegrationEvent(message.ClienteId));
+        }
+    }
+}

src/services/JSE.Pedido.API/Configuration/MessageBusConfig.cs

@@ -1,7 +1,7 @@
 using JSE.Core.Utils;
 using JSE.MessageBus;
 
-namespace NSE.Pedidos.API.Configuration
+namespace JSE.Pedidos.API.Configuration
 {
     public static class MessageBusConfig
     {