From 6abe0e18f6fab9133201af0510df44c7de6c92dd Mon Sep 17 00:00:00 2001
From: TekH <h.tek@digitaldata.works>
Date: Thu, 13 Aug 2026 16:48:22 +0200
Subject: [PATCH] feat(application): add EmailSyncResult DTO, Folder/AccountId
 to ReceivedEmailDto, rename CreateRangeAsync in IRepository, update
 IImapEmailService signature, add AutoMapper profiles for ReceivedEmail and
 EmailAttachment

---
 .../Common/Dto/EmailSyncResult.cs             |  5 +++++
 .../Common/Dto/ReceivedEmailDto.cs            | 15 +++++++++++++
 .../Common/Interfaces/IImapEmailService.cs    | 22 ++++++++-----------
 .../Interfaces/Repositories/IRepository.cs    |  2 +-
 .../Common/Mappings/EmailMappingProfile.cs    | 13 +++++++++++
 5 files changed, 43 insertions(+), 14 deletions(-)
 create mode 100644 src/core/DigitalData.MessagingService.Application/Common/Dto/EmailSyncResult.cs

diff --git a/src/core/DigitalData.MessagingService.Application/Common/Dto/EmailSyncResult.cs b/src/core/DigitalData.MessagingService.Application/Common/Dto/EmailSyncResult.cs
new file mode 100644
index 0000000..bd7144b
--- /dev/null
+++ b/src/core/DigitalData.MessagingService.Application/Common/Dto/EmailSyncResult.cs
@@ -0,0 +1,5 @@
+#if NET
+namespace DigitalData.MessagingService.Application.Common.Dto;
+
+public record EmailSyncResult(int ProcessedCount = 0, int FailedCount = 0);
+#endif
\ No newline at end of file
diff --git a/src/core/DigitalData.MessagingService.Application/Common/Dto/ReceivedEmailDto.cs b/src/core/DigitalData.MessagingService.Application/Common/Dto/ReceivedEmailDto.cs
index 4fe877e..8be26c7 100644
--- a/src/core/DigitalData.MessagingService.Application/Common/Dto/ReceivedEmailDto.cs
+++ b/src/core/DigitalData.MessagingService.Application/Common/Dto/ReceivedEmailDto.cs
@@ -14,6 +14,15 @@ public sealed record ReceivedEmailDto
     public long Uid { get; set; }
 #endif
 
+    /// <summary>
+    /// ID of the email account this message belongs to.
+    /// </summary>
+#if NET
+    public int AccountId { get; init; }
+#else
+    public int AccountId { get; set; }
+#endif
+
     /// <summary>
     /// Sender address (From header).
     /// </summary>
@@ -94,4 +103,10 @@ public sealed record ReceivedEmailDto
 #else
     public bool IsSeen { get; set; }
 #endif
+
+#if NET
+    public required string Folder { get; init; }
+#else
+    public string Folder { get; set; } = null!;
+#endif
 }
diff --git a/src/core/DigitalData.MessagingService.Application/Common/Interfaces/IImapEmailService.cs b/src/core/DigitalData.MessagingService.Application/Common/Interfaces/IImapEmailService.cs
index fdf7cc8..834cc8f 100644
--- a/src/core/DigitalData.MessagingService.Application/Common/Interfaces/IImapEmailService.cs
+++ b/src/core/DigitalData.MessagingService.Application/Common/Interfaces/IImapEmailService.cs
@@ -1,6 +1,5 @@
 #if NET
 using DigitalData.MessagingService.Application.Common.Dto;
-using DigitalData.MessagingService.Application.Common.Dto.MailSearch;
 using DigitalData.MessagingService.Domain.Entities;
 
 namespace DigitalData.MessagingService.Application.Common.Interfaces;
@@ -11,19 +10,16 @@ namespace DigitalData.MessagingService.Application.Common.Interfaces;
 public interface IImapEmailService
 {
     /// <summary>
-    /// Fetches emails from the specified mailbox folder.
+    /// 
     /// </summary>
-    /// <param name="account">Account whose IMAP settings will be used.</param>
-    /// <param name="date"></param>
-    /// When <see langword="true"/> (default), fetched messages are marked as <c>\Seen</c> on the server.
-    /// Set to <see langword="false"/> for a non-destructive read (uses <c>BODY.PEEK</c> internally).
-    /// </param>
-    /// <param name="cancellationToken">Cancellation token.</param>
-    public Task SyncEmailsAsync(
-        EmailAccount account,
-        DateFilter date,
-        string folder = "INBOX",
-        CancellationToken cancel = default);
+    /// <param name="account"></param>
+    /// <param name="folder"></param>
+    /// <param name="cancel"></param>
+    /// <returns></returns>
+    Task<EmailSyncResult> SyncEmailsAsync(
+            EmailAccount account,
+            string folder = "INBOX",
+            CancellationToken cancel = default);
 
     /// <summary>
     /// Marks a message as seen (read) on the server.
diff --git a/src/core/DigitalData.MessagingService.Application/Common/Interfaces/Repositories/IRepository.cs b/src/core/DigitalData.MessagingService.Application/Common/Interfaces/Repositories/IRepository.cs
index ea85f14..7a04480 100644
--- a/src/core/DigitalData.MessagingService.Application/Common/Interfaces/Repositories/IRepository.cs
+++ b/src/core/DigitalData.MessagingService.Application/Common/Interfaces/Repositories/IRepository.cs
@@ -11,7 +11,7 @@ public interface IRepository<TEntity> where TEntity : class
     // CREATE
     Task<TEntity> CreateAsync<TDto>(TDto dto, CancellationToken cancellationToken = default);
 
-    Task<IEnumerable<TEntity>> CreateAsync<TDto>(IEnumerable<TDto> dtos, CancellationToken cancellationToken = default);
+    Task<IEnumerable<TEntity>> CreateRangeAsync<TDto>(IEnumerable<TDto> dtos, CancellationToken cancellationToken = default);
 
     // READ
     Task<TEntity?> GetByIdAsync(int id, CancellationToken cancellationToken = default);
diff --git a/src/core/DigitalData.MessagingService.Application/Common/Mappings/EmailMappingProfile.cs b/src/core/DigitalData.MessagingService.Application/Common/Mappings/EmailMappingProfile.cs
index c778f7c..1c79029 100644
--- a/src/core/DigitalData.MessagingService.Application/Common/Mappings/EmailMappingProfile.cs
+++ b/src/core/DigitalData.MessagingService.Application/Common/Mappings/EmailMappingProfile.cs
@@ -23,6 +23,19 @@ public class EmailMappingProfile : Profile
         // EmailAccountDto -> EmailAccount
         CreateMap<EmailAccount, EmailAccountDto>();
         CreateMap<EmailAccountModificationDto, EmailAccount>();
+
+        // ReceivedEmailDto <-> ReceivedEmail
+        CreateMap<ReceivedEmailDto, ReceivedEmail>()
+            .ForMember(dest => dest.Id, opt => opt.Ignore())
+            .ForMember(dest => dest.Account, opt => opt.Ignore());
+        CreateMap<ReceivedEmail, ReceivedEmailDto>();
+
+        // EmailAttachmentDto <-> EmailAttachment
+        CreateMap<EmailAttachmentDto, EmailAttachment>()
+            .ForMember(dest => dest.Id, opt => opt.Ignore())
+            .ForMember(dest => dest.EmailId, opt => opt.Ignore())
+            .ForMember(dest => dest.Email, opt => opt.Ignore());
+        CreateMap<EmailAttachment, EmailAttachmentDto>();
     }
 }
 #endif
\ No newline at end of file