PS-148 notification email

core/.editorconfig

@@ -176,6 +176,10 @@ csharp_style_prefer_top_level_statements = true:silent
 csharp_style_prefer_primary_constructors = true:suggestion
 
 #### Naming styles ####
+
+# CA1862: Use the 'StringComparison' method overloads to perform case-insensitive string comparisons
+dotnet_diagnostic.CA1862.severity = suggestion
+
 [*.{cs,vb}]
 
 # Naming rules

core/Controllers/OrganizersController.cs

@@ -19,7 +19,11 @@ namespace api.core.controllers;
 [Authorize(Policy = AuthPolicies.IsModerator)]
 [ApiController]
 [Route("api/moderator/organizer")]
-public class ModeratorUserController(IUserService userService, IAuthService authService, IEmailService emailService) : ControllerBase
+public class ModeratorUserController(
+    IUserService userService,
+    IAuthService authService,
+    IEmailService emailService,
+    IConfiguration configuration) : ControllerBase
 {
     [AllowAnonymous]
     [HttpGet("{organizerId}")]
@@ -41,7 +45,7 @@ public async Task<IActionResult> CreateOrganizer([FromBody] UserCreateDTO organi
         var supabaseUser = authService.SignUp(organizer.Email, strongPassword);
         Guid.TryParse(supabaseUser, out Guid userId);
         var created = userService.AddOrganizer(userId, organizer);
-        var frontBaseUrl = Environment.GetEnvironmentVariable("FRONTEND_BASE_URL") ?? throw new Exception("FRONTEND_BASE_URL is not set");
+        var frontBaseUrl = configuration.GetValue<string>("FRONTEND_BASE_URL") ?? throw new Exception("FRONTEND_BASE_URL is not set");
         await emailService.SendEmailAsync(
             organizer.Email,
             "Votre compte Hello!",

core/Controllers/SubscriptionController.cs

@@ -0,0 +1,32 @@
+using api.core.Data;
+using api.core.Data.requests;
+using api.core.Services.Abstractions;
+
+using Microsoft.AspNetCore.Mvc;
+
+namespace api.core.Controllers;
+
+[ApiController]
+[Route("api/subscriptions")]
+public class SubscriptionController(ISubscriptionService subscriptionService) : ControllerBase
+{
+    [HttpPost]
+    public IActionResult Subscribe([FromBody] SubscribeRequestDTO request)
+    {
+        subscriptionService.Subscribe(request);
+        return Ok(new Response<object>
+        {
+            Data = "Subscribed successfully to this organizer posts."
+        });
+    }
+
+    [HttpDelete]
+    public IActionResult Unsubcribe([FromBody] UnsubscribeRequestDTO request)
+    {
+        subscriptionService.Unsubscribe(request);
+        return Ok(new Response<object>
+        {
+            Data = "Unsubscribed successfully from this organizer posts."
+        });
+    }
+}

core/Data/Entities/Notification.cs

@@ -0,0 +1,23 @@
+using System.ComponentModel.DataAnnotations.Schema;
+
+using api.core.Data.Entities;
+
+namespace api.core.data.entities;
+
+[Table(nameof(Notification))]
+public partial class Notification : BaseEntity
+{
+    public Guid PublicationId { get; set; }
+
+    public Guid SubscriptionId { get; set; }
+
+    public bool IsSent { get; set; } = false;
+
+    [ForeignKey(nameof(PublicationId))]
+    [InverseProperty(nameof(Publication.Notifications))]
+    public virtual Publication Publication { get; set; } = null!;
+
+    [ForeignKey(nameof(SubscriptionId))]
+    [InverseProperty(nameof(Subscription.Notifications))]
+    public virtual Subscription Subscription { get; set; } = null!;
+}

core/Data/Entities/Organizer.cs

@@ -37,4 +37,7 @@ public partial class Organizer : User
     [ForeignKey("ActivityAreaId")]
     [InverseProperty("Organizers")]
     public virtual ActivityArea? ActivityArea { get; set; }
+
+    [InverseProperty(nameof(Subscription.Organizer))]
+    public virtual ICollection<Subscription> Subscriptions { get; set; } = new List<Subscription>();
 }

core/Data/Entities/Publication.cs

@@ -63,4 +63,7 @@ public partial class Publication
     [ForeignKey("PublicationsId")]
     [InverseProperty("Publications")]
     public virtual ICollection<Tag> Tags { get; set; } = new List<Tag>();
+
+    [InverseProperty(nameof(Notification.Publication))]
+    public virtual ICollection<Notification> Notifications { get; set; } = new List<Notification>();
 }

core/Data/Entities/Subscription.cs

@@ -0,0 +1,23 @@
+using System.ComponentModel.DataAnnotations.Schema;
+
+using api.core.Data.Entities;
+
+
+namespace api.core.data.entities;
+
+[Table(nameof(Subscription))]
+public partial class Subscription : BaseEntity
+{
+    public string Email { get; set; } = null!;
+
+    public Guid OrganizerId { get; set; }
+
+    public string SubscriptionToken { get; set; } = null!;
+
+    [ForeignKey(nameof(OrganizerId))]
+    [InverseProperty(nameof(entities.Organizer.Subscriptions))]
+    public virtual Organizer Organizer { get; set; } = null!;
+
+    [InverseProperty(nameof(Notification.Subscription))]
+    public virtual ICollection<Notification> Notifications { get; set; } = new List<Notification>();
+}

core/Data/EventManagementContext.cs

@@ -32,6 +32,10 @@ public EventManagementContext(DbContextOptions<EventManagementContext> options)
 
     public virtual DbSet<ActivityArea> ActivityAreas { get; set; }
 
+    public virtual DbSet<Subscription> Subscriptions { get; set; }
+
+    public virtual DbSet<Notification> Notifications { get; set; }
+
     protected override void OnModelCreating(ModelBuilder modelBuilder)
     {
         modelBuilder.Entity<Event>(entity =>
@@ -116,6 +120,10 @@ protected override void OnModelCreating(ModelBuilder modelBuilder)
                     });
         });
 
+        modelBuilder.Entity<Subscription>()
+            .HasIndex(a => new { a.Email, a.OrganizerId })
+            .IsUnique();
+
         OnModelCreatingPartial(modelBuilder);
     }
 

core/Data/Requests/SubscriptionRequestDTO.cs

@@ -0,0 +1,15 @@
+namespace api.core.Data.requests;
+
+public class SubscribeRequestDTO
+{
+    public required string Email { get; set; }
+
+    public required Guid OrganizerId { get; set; }
+}
+
+
+public class UnsubscribeRequestDTO
+{
+    public required string SubscriptionToken { get; set; }
+
+}

core/Extensions/DependencyInjectionExtension.cs

@@ -29,6 +29,8 @@ public static IServiceCollection AddDependencyInjection(this IServiceCollection
         services.AddTransient<IModeratorRepository, ModeratorRepository>();
         services.AddTransient<IReportRepository, ReportRepository>();
         services.AddTransient<IActivityAreaRepository, ActivityAreaRepository>();
+        services.AddTransient<ISubscriptionRepository, SubscriptionRepository>();
+        services.AddTransient<INotificationRepository, NotificationRepository>();
 
         // Services
         services.AddTransient<IUserService, UserService>();
@@ -40,6 +42,8 @@ public static IServiceCollection AddDependencyInjection(this IServiceCollection
         services.AddTransient<IReportService, ReportService>();
         services.AddTransient<IActivityAreaService, ActivityAreaService>();
         services.AddTransient<IModeratorService, ModeratorService>();
+        services.AddTransient<ISubscriptionService, SubscriptionService>();
+        services.AddTransient<INotificationService, NotificationService>();
 
         return services;
     }