Feat/organizer send messages

TickAPI/TickAPI/Common/Mail/Abstractions/IMailService.cs

@@ -5,8 +5,7 @@ namespace TickAPI.Common.Mail.Abstractions;
 
 public interface IMailService
 {
-    public Task<Result> SendTicketAsync(string toEmail, string toLogin, string eventName, byte[] pdfData);
+    public Task<Result> SendTicketAsync(MailRecipient recipient, string eventName, byte[] pdfData);
 
-    public Task<Result> SendMailAsync(string toEmail, string toLogin, string subject, string content,
-        List<MailAttachment>? attachments);
+    public Task<Result> SendMailAsync(IEnumerable<MailRecipient> recipients, string subject, string content, List<MailAttachment>? attachments);
 }

TickAPI/TickAPI/Common/Mail/Models/MailAttachment.cs

@@ -1,8 +1,7 @@
 namespace TickAPI.Common.Mail.Models;
 
-public class MailAttachment
-{
-    public string fileName { get; set; }
-    public string base64Content { get; set; }
-    public string fileType  { get; set; }
-}
+public record MailAttachment(
+    string FileName,
+    string Base64Content,
+    string FileType
+);

TickAPI/TickAPI/Common/Mail/Models/MailRecipient.cs

@@ -0,0 +1,6 @@
+namespace TickAPI.Common.Mail.Models;
+
+public record MailRecipient(
+    string Email,
+    string Login
+);

TickAPI/TickAPI/Common/Mail/Services/MailService.cs

@@ -20,35 +20,29 @@ public MailService(IConfiguration configuration)
         _fromEmailAddress = new EmailAddress(fromEmail, fromName);
     }
 
-    public async Task<Result> SendTicketAsync(string toEmail, string toLogin, string eventName, byte[] pdfData)
+    public async Task<Result> SendTicketAsync(MailRecipient recipient, string eventName, byte[] pdfData)
     {
         var subject = $"Ticket for {eventName}";
         var htmlContent = "<strong>Download your ticket from attachments</strong>";
         var base64Content = Convert.ToBase64String(pdfData);
-        List<MailAttachment> attachments =
-        [
-            new MailAttachment
-            {
-                base64Content = base64Content,
-                fileName = "ticket.pdf",
-                fileType = "application/pdf"
-            }
+        List<MailAttachment> attachments = [
+            new MailAttachment("ticket.pdf", base64Content, "application/pdf")
         ];
-        var res = await SendMailAsync(toEmail, toLogin, subject, htmlContent, attachments);
+        var res = await SendMailAsync([recipient], subject, htmlContent, attachments);
         return res;
     }
 
-    public async Task<Result> SendMailAsync(string toEmail, string toLogin, string subject, string content,
+    public async Task<Result> SendMailAsync(IEnumerable<MailRecipient> recipients, string subject, string content,
         List<MailAttachment>? attachments = null)
     {
-        var toEmailAddress = new EmailAddress(toEmail, toLogin);
-        var msg = MailHelper.CreateSingleEmail(_fromEmailAddress, toEmailAddress, subject, 
-            null, content);
+        var toEmailAddresses = recipients.Select(r => new EmailAddress(r.Email, r.Login)).ToList();
+        var msg = MailHelper.CreateSingleEmailToMultipleRecipients(_fromEmailAddress, toEmailAddresses, subject, null, content);
+
         if (attachments != null)
         {
             foreach (var a in attachments)
             {
-                msg.AddAttachment(a.fileName, a.base64Content, a.fileType);
+                msg.AddAttachment(a.FileName, a.Base64Content, a.FileType);
             }
         }
 

TickAPI/TickAPI/Customers/Abstractions/ICustomerRepository.cs

@@ -7,4 +7,5 @@ public interface ICustomerRepository
 {
     Task<Result<Customer>> GetCustomerByEmailAsync(string customerEmail);
     Task AddNewCustomerAsync(Customer customer);
+    IQueryable<Customer> GetCustomersWithTicketForEvent(Guid eventId);
 }

TickAPI/TickAPI/Customers/Repositories/CustomerRepository.cs

@@ -32,4 +32,10 @@ public async Task AddNewCustomerAsync(Customer customer)
         _tickApiDbContext.Customers.Add(customer);
         await _tickApiDbContext.SaveChangesAsync();
     }
+
+    public IQueryable<Customer> GetCustomersWithTicketForEvent(Guid eventId)
+    {
+        return _tickApiDbContext.Customers
+            .Where(c => c.Tickets.Any(t => t.Type.Event.Id == eventId));
+    }
 }

TickAPI/TickAPI/Events/Abstractions/IEventService.cs

@@ -1,6 +1,7 @@
 using TickAPI.Addresses.DTOs.Request;
 using TickAPI.Common.Pagination.Responses;
 using TickAPI.Categories.DTOs.Request;
+using TickAPI.Common.Results;
 using TickAPI.Events.Models;
 using TickAPI.Common.Results.Generic;
 using TickAPI.Events.DTOs.Request;
@@ -21,4 +22,5 @@ public Task<Result<Event>> CreateNewEventAsync(string name, string description,
     public Task<Result<PaginationDetails>> GetEventsPaginationDetailsAsync(int pageSize);
     public Task<Result<GetEventDetailsResponseDto>> GetEventDetailsAsync(Guid eventId);
     public Task<Result<Event>> EditEventAsync(Organizer organizer, Guid eventId, string name, string description, DateTime startDate, DateTime endDate, uint? minimumAge, CreateAddressDto editAddress, List<EditEventCategoryDto> categories, EventStatus eventStatus);
+    public Task<Result> SendMessageToParticipants(Organizer organizer, Guid eventId, string subject, string message);
 }

TickAPI/TickAPI/Events/Controllers/EventsController.cs

@@ -141,4 +141,26 @@ public async Task<ActionResult<EditEventResponseDto>> EditEvent([FromRoute] Guid
 
         return Ok("Event edited succesfully");
     }
+
+    [AuthorizeWithPolicy(AuthPolicies.VerifiedOrganizerPolicy)]
+    [HttpPost("{id:guid}/message-to-participants")]
+    public async Task<ActionResult> SendMessageToEventParticipants([FromRoute] Guid id, [FromBody] SendMessageToParticipantsDto request)
+    {
+        var emailResult = _claimsService.GetEmailFromClaims(User.Claims);
+        if (emailResult.IsError)
+        {
+            return emailResult.ToObjectResult();
+        }
+        var email = emailResult.Value!;
+
+        var organizerResult = await _organizerService.GetOrganizerByEmailAsync(email);
+        if (organizerResult.IsError)
+        {
+            return organizerResult.ToObjectResult();
+        }
+        var organizer = organizerResult.Value!;
+
+        var result = await _eventService.SendMessageToParticipants(organizer, id, request.Subject, request.Message);
+        return result.ToObjectResult();
+    }
 }

TickAPI/TickAPI/Events/DTOs/Request/SendMessageToParticipantsDto.cs

@@ -0,0 +1,6 @@
+namespace TickAPI.Events.DTOs.Request;
+
+public record SendMessageToParticipantsDto(
+    string Subject,
+    string Message
+);

TickAPI/TickAPI/Events/Services/EventService.cs

@@ -1,14 +1,18 @@
-using TickAPI.Addresses.Abstractions;
+using Microsoft.EntityFrameworkCore;
+using TickAPI.Addresses.Abstractions;
 using TickAPI.Addresses.DTOs.Request;
 using TickAPI.Common.Pagination.Abstractions;
 using TickAPI.Common.Pagination.Responses;
 using TickAPI.Categories.Abstractions;
 using TickAPI.Categories.DTOs.Request;
+using TickAPI.Common.Mail.Abstractions;
+using TickAPI.Common.Mail.Models;
 using TickAPI.Common.Results;
 using TickAPI.Common.Time.Abstractions;
 using TickAPI.Events.Abstractions;
 using TickAPI.Events.Models;
 using TickAPI.Common.Results.Generic;
+using TickAPI.Customers.Abstractions;
 using TickAPI.Events.DTOs.Request;
 using TickAPI.Events.DTOs.Response;
 using TickAPI.Events.Filters;
@@ -29,8 +33,10 @@ public class EventService : IEventService
     private readonly IPaginationService _paginationService;
     private readonly ICategoryService _categoryService;
     private readonly ITicketService _ticketService;
+    private readonly ICustomerRepository _customerRepository;
+    private readonly IMailService _mailService;
 
-    public EventService(IEventRepository eventRepository, IOrganizerService organizerService, IAddressService addressService, IDateTimeService dateTimeService, IPaginationService paginationService, ICategoryService categoryService, ITicketService ticketService)
+    public EventService(IEventRepository eventRepository, IOrganizerService organizerService, IAddressService addressService, IDateTimeService dateTimeService, IPaginationService paginationService, ICategoryService categoryService, ITicketService ticketService, ICustomerRepository customerRepository, IMailService mailService)
     {
         _eventRepository = eventRepository;
         _organizerService = organizerService;
@@ -39,6 +45,8 @@ public EventService(IEventRepository eventRepository, IOrganizerService organize
         _paginationService = paginationService;
         _categoryService = categoryService;
         _ticketService = ticketService;
+        _customerRepository = customerRepository;
+        _mailService = mailService;
     }
 
     public async Task<Result<Event>> CreateNewEventAsync(string name, string  description, DateTime startDate, DateTime endDate, 
@@ -221,6 +229,21 @@ public async Task<Result<Event>> EditEventAsync(Organizer organizer, Guid eventI
         return Result<Event>.Success(existingEvent);
     }
 
+    public async Task<Result> SendMessageToParticipants(Organizer organizer, Guid eventId, string subject, string message)
+    {
+        var eventResult = await _eventRepository.GetEventByIdAndOrganizerAsync(eventId, organizer);
+        if (eventResult.IsError)
+        {
+            return Result.PropagateError(eventResult);
+        }
+        var ev = eventResult.Value!;
+
+        var eventParticipants = await _customerRepository.GetCustomersWithTicketForEvent(ev.Id).ToListAsync();
+        var recipients = eventParticipants.Select(p => new MailRecipient(p.Email, $"{p.FirstName} {p.LastName}"));
+
+        return await _mailService.SendMailAsync(recipients, subject, message, null);
+    }
+
     private async Task<Result<PaginatedData<GetEventResponseDto>>> GetPaginatedEventsAsync(IQueryable<Event> events, int page, int pageSize)
     {
         var paginatedEventsResult = await _paginationService.PaginateAsync(events, pageSize, page);