Split Features to create space for more projects

2026-05-24 13:19:09 +02:00
parent 032b9e1818
commit 70c6e0bfbc
95 changed files with 621 additions and 314 deletions
@@ -0,0 +1,113 @@
+using LiteCharms.Features.Email;
+using LiteCharms.Features.TechShop.Notifications.Models;
+using LiteCharms.Features.TechShop.Postgres;
+
+namespace LiteCharms.Features.TechShop.Notifications.Events.Handlers;
+
+public class ProcessEmailNotificationsEventHandler(IDbContextFactory<ShopDbContext> contextFactory, ILogger<ProcessEmailNotificationsEvent> logger, 
+    EmailService emailService) : INotificationHandler<ProcessEmailNotificationsEvent>
+{
+    private bool dropBatch = false;
+
+    public async ValueTask Handle(ProcessEmailNotificationsEvent message, CancellationToken cancellationToken)
+    {
+        try
+        {
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            if (emailService.Status != EmailStatuses.Connected)
+                await emailService.ConnectAsync(cancellationToken);
+
+            var notifications = await context.Notifications
+                .OrderByDescending(o => o.CreatedAt)
+                .ThenBy(o => o.Priority)
+                .Where(n => n.Platform == NotificationPlatforms.Email && 
+                    n.Direction == NotificationDirection.Outgoing && n.Processed == false)
+                .Take(message.MaxRecords)
+                .ToListAsync(cancellationToken);
+
+            foreach (var notification in notifications)
+            {
+                if (dropBatch) break;
+
+                var sendResult = await SendEmailAsync(notification,emailService, cancellationToken);
+
+                if(sendResult.IsFailed)
+                {
+                    var errors = new List<string>(1000);
+
+                    errors.AddRange(sendResult.Errors.Select(e => e.Message));
+
+                    if (sendResult.Reasons?.Count > 0)
+                        errors.AddRange(sendResult.Reasons.Select(e => e.Message));
+
+                    notification.HasError = true;                    
+                    notification.Errors = [.. errors];
+                }
+
+                notification.Processed = true;
+                notification.UpdatedAt = DateTime.UtcNow;
+            }
+
+            await context.SaveChangesAsync(cancellationToken);            
+        }
+        catch (Exception ex)
+        {
+            logger.LogError(ex, ex.Message);
+        }
+        finally
+        {
+            await emailService.DisconnectAsync(cancellationToken);
+        }
+    }
+
+    private async Task<Result> SendEmailAsync(Notification notification, EmailService service, CancellationToken cancellationToken = default)
+    {
+        try
+        {
+            using Email.Models.Message message = CreateMessage(notification);
+
+            var sendResult = await service.SendEmailAsync(message, cancellationToken);
+
+            if (sendResult.IsFailed)
+            {
+                if (emailService.Status != EmailStatuses.Success && emailService.Status != EmailStatuses.Connected) dropBatch = true;
+
+                return Result.Fail(sendResult.Errors);
+            }
+
+            return sendResult.IsFailed
+                ? Result.Fail(sendResult.Errors)
+                : Result.Ok();
+        }
+        catch (Exception ex)
+        {
+            return Result.Fail(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+
+    private static Email.Models.Message CreateMessage(Notification notification) =>
+        new()
+        {
+            Sender = new Email.Models.Party
+            {
+                Name = notification.SenderName,
+                Address = notification.SenderAddress
+            },
+            Recipient = new Email.Models.Party
+            {
+                Name = notification.RecipientName,
+                Address = notification.RecipientAddress
+            },
+            Subject = notification.Subject,
+            Body = new Email.Models.Body
+            {
+                Properties = new Email.Models.BodyProperties
+                {
+                    HasAttachments = false,
+                    IsHtml = notification.IsHtml
+                },
+                Message = notification.Message
+            }
+        };
+}