refactor: vertical-slice feature folders (Notifications pilot)

modules/Notifications/src/SimpleModule.Notifications.Contracts/QueryNotificationsRequest.cs → modules/Notifications/src/SimpleModule.Notifications.Contracts/Features/Notifications/List/QueryNotificationsRequest.cs

@@ -1,6 +1,6 @@
 using SimpleModule.Core;
 
-namespace SimpleModule.Notifications.Contracts;
+namespace SimpleModule.Notifications.Contracts.Features.Notifications.List;
 
 [Dto]
 public class QueryNotificationsRequest

modules/Notifications/src/SimpleModule.Notifications.Contracts/INotificationsContracts.cs

@@ -1,4 +1,5 @@
 using SimpleModule.Core;
+using SimpleModule.Notifications.Contracts.Features.Notifications.List;
 using SimpleModule.Users.Contracts;
 
 namespace SimpleModule.Notifications.Contracts;

modules/Notifications/src/SimpleModule.Notifications/Features/Notifications/GetById/NotificationService.GetById.cs

@@ -0,0 +1,13 @@
+using Microsoft.EntityFrameworkCore;
+using SimpleModule.Notifications.Contracts;
+using SimpleModule.Users.Contracts;
+
+namespace SimpleModule.Notifications.Infrastructure;
+
+public sealed partial class NotificationService
+{
+    public async Task<Notification?> GetByIdAsync(NotificationId id, UserId userId) =>
+        await db
+            .Notifications.AsNoTracking()
+            .FirstOrDefaultAsync(n => n.Id == id && n.UserId == userId);
+}

modules/Notifications/src/SimpleModule.Notifications/Endpoints/Notifications/ListNotificationsEndpoint.cs → modules/Notifications/src/SimpleModule.Notifications/Features/Notifications/List/ListNotificationsEndpoint.cs

@@ -5,9 +5,10 @@
 using SimpleModule.Core.Authorization;
 using SimpleModule.Core.Extensions;
 using SimpleModule.Notifications.Contracts;
+using SimpleModule.Notifications.Contracts.Features.Notifications.List;
 using SimpleModule.Users.Contracts;
 
-namespace SimpleModule.Notifications.Endpoints.Notifications;
+namespace SimpleModule.Notifications.Features.Notifications.List;
 
 public class ListNotificationsEndpoint : IEndpoint
 {
@@ -20,8 +21,7 @@ public void Map(IEndpointRouteBuilder app) =>
                     [AsParameters] QueryNotificationsRequest request,
                     HttpContext context,
                     INotificationsContracts notifications
-                ) =>
-                    notifications.ListAsync(UserId.From(context.User.GetUserId()!), request)
+                ) => notifications.ListAsync(UserId.From(context.User.GetUserId()!), request)
             )
             .RequirePermission(NotificationsPermissions.ViewOwn);
 }

modules/Notifications/src/SimpleModule.Notifications/Features/Notifications/List/NotificationService.List.cs

@@ -0,0 +1,50 @@
+using Microsoft.EntityFrameworkCore;
+using SimpleModule.Core;
+using SimpleModule.Notifications.Contracts;
+using SimpleModule.Notifications.Contracts.Features.Notifications.List;
+using SimpleModule.Users.Contracts;
+
+namespace SimpleModule.Notifications.Infrastructure;
+
+public sealed partial class NotificationService
+{
+    public async Task<PagedResult<Notification>> ListAsync(
+        UserId userId,
+        QueryNotificationsRequest request
+    )
+    {
+        var query = db.Notifications.AsNoTracking().Where(n => n.UserId == userId);
+
+        if (request.UnreadOnly == true)
+        {
+            query = query.Where(n => n.ReadAt == null);
+        }
+        if (!string.IsNullOrWhiteSpace(request.Channel))
+        {
+            query = query.Where(n => n.Channel == request.Channel);
+        }
+        if (!string.IsNullOrWhiteSpace(request.Type))
+        {
+            query = query.Where(n => n.Type == request.Type);
+        }
+
+        var totalCount = await query.CountAsync();
+        var page = request.EffectivePage;
+        var pageSize = request.EffectivePageSize;
+
+        var items = await query
+            .OrderByDescending(n => n.CreatedAt)
+            .ThenByDescending(n => n.Id)
+            .Skip((page - 1) * pageSize)
+            .Take(pageSize)
+            .ToListAsync();
+
+        return new PagedResult<Notification>
+        {
+            Items = items,
+            TotalCount = totalCount,
+            Page = page,
+            PageSize = pageSize,
+        };
+    }
+}

modules/Notifications/src/SimpleModule.Notifications/Endpoints/Notifications/MarkAllReadEndpoint.cs → modules/Notifications/src/SimpleModule.Notifications/Features/Notifications/MarkAllRead/MarkAllReadEndpoint.cs

@@ -7,7 +7,7 @@
 using SimpleModule.Notifications.Contracts;
 using SimpleModule.Users.Contracts;
 
-namespace SimpleModule.Notifications.Endpoints.Notifications;
+namespace SimpleModule.Notifications.Features.Notifications.MarkAllRead;
 
 public class MarkAllReadEndpoint : IEndpoint
 {

modules/Notifications/src/SimpleModule.Notifications/Features/Notifications/MarkAllRead/NotificationService.MarkAllRead.cs

@@ -0,0 +1,15 @@
+using Microsoft.EntityFrameworkCore;
+using SimpleModule.Users.Contracts;
+
+namespace SimpleModule.Notifications.Infrastructure;
+
+public sealed partial class NotificationService
+{
+    public async Task<int> MarkAllReadAsync(UserId userId)
+    {
+        var now = DateTimeOffset.UtcNow;
+        return await db
+            .Notifications.Where(n => n.UserId == userId && n.ReadAt == null)
+            .ExecuteUpdateAsync(s => s.SetProperty(n => n.ReadAt, now));
+    }
+}

modules/Notifications/src/SimpleModule.Notifications/Endpoints/Notifications/MarkReadEndpoint.cs → modules/Notifications/src/SimpleModule.Notifications/Features/Notifications/MarkRead/MarkReadEndpoint.cs

@@ -7,7 +7,7 @@
 using SimpleModule.Notifications.Contracts;
 using SimpleModule.Users.Contracts;
 
-namespace SimpleModule.Notifications.Endpoints.Notifications;
+namespace SimpleModule.Notifications.Features.Notifications.MarkRead;
 
 public class MarkReadEndpoint : IEndpoint
 {

modules/Notifications/src/SimpleModule.Notifications/Features/Notifications/MarkRead/NotificationService.MarkRead.cs

@@ -0,0 +1,28 @@
+using Microsoft.EntityFrameworkCore;
+using SimpleModule.Notifications.Contracts;
+using SimpleModule.Users.Contracts;
+
+namespace SimpleModule.Notifications.Infrastructure;
+
+public sealed partial class NotificationService
+{
+    public async Task<bool> MarkReadAsync(NotificationId id, UserId userId)
+    {
+        var notification = await db.Notifications.FirstOrDefaultAsync(n =>
+            n.Id == id && n.UserId == userId
+        );
+        if (notification is null)
+        {
+            return false;
+        }
+
+        if (notification.ReadAt is not null)
+        {
+            return true;
+        }
+
+        notification.ReadAt = DateTimeOffset.UtcNow;
+        await db.SaveChangesAsync();
+        return true;
+    }
+}

modules/Notifications/src/SimpleModule.Notifications/Features/Notifications/UnreadCount/NotificationService.UnreadCount.cs

@@ -0,0 +1,13 @@
+using Microsoft.EntityFrameworkCore;
+using SimpleModule.Users.Contracts;
+
+namespace SimpleModule.Notifications.Infrastructure;
+
+public sealed partial class NotificationService
+{
+    public Task<int> GetUnreadCountAsync(
+        UserId userId,
+        CancellationToken cancellationToken = default
+    ) =>
+        db.Notifications.CountAsync(n => n.UserId == userId && n.ReadAt == null, cancellationToken);
+}

modules/Notifications/src/SimpleModule.Notifications/Endpoints/Notifications/UnreadCountEndpoint.cs → modules/Notifications/src/SimpleModule.Notifications/Features/Notifications/UnreadCount/UnreadCountEndpoint.cs

@@ -7,7 +7,7 @@
 using SimpleModule.Notifications.Contracts;
 using SimpleModule.Users.Contracts;
 
-namespace SimpleModule.Notifications.Endpoints.Notifications;
+namespace SimpleModule.Notifications.Features.Notifications.UnreadCount;
 
 public class UnreadCountEndpoint : IEndpoint
 {

modules/Notifications/src/SimpleModule.Notifications/Channels/DatabaseChannel.cs → modules/Notifications/src/SimpleModule.Notifications/Infrastructure/Channels/DatabaseChannel.cs

@@ -4,7 +4,7 @@
 using SimpleModule.Notifications.Contracts.Events;
 using Wolverine.EntityFrameworkCore;
 
-namespace SimpleModule.Notifications.Channels;
+namespace SimpleModule.Notifications.Infrastructure.Channels;
 
 public partial class DatabaseChannel(
     NotificationsDbContext db,

modules/Notifications/src/SimpleModule.Notifications/Channels/INotificationChannel.cs → modules/Notifications/src/SimpleModule.Notifications/Infrastructure/Channels/INotificationChannel.cs

@@ -1,6 +1,6 @@
 using SimpleModule.Notifications.Contracts;
 
-namespace SimpleModule.Notifications.Channels;
+namespace SimpleModule.Notifications.Infrastructure.Channels;
 
 /// <summary>
 /// A delivery channel — mail, database, sms, slack, push, etc. Each channel

modules/Notifications/src/SimpleModule.Notifications/Channels/INotificationChannelRegistry.cs → modules/Notifications/src/SimpleModule.Notifications/Infrastructure/Channels/INotificationChannelRegistry.cs

@@ -1,6 +1,6 @@
 using SimpleModule.Notifications.Contracts;
 
-namespace SimpleModule.Notifications.Channels;
+namespace SimpleModule.Notifications.Infrastructure.Channels;
 
 public interface INotificationChannelRegistry
 {

modules/Notifications/src/SimpleModule.Notifications/Channels/LogSmsChannel.cs → modules/Notifications/src/SimpleModule.Notifications/Infrastructure/Channels/LogSmsChannel.cs

@@ -1,7 +1,7 @@
 using Microsoft.Extensions.Logging;
 using SimpleModule.Notifications.Contracts;
 
-namespace SimpleModule.Notifications.Channels;
+namespace SimpleModule.Notifications.Infrastructure.Channels;
 
 /// <summary>
 /// Default SMS channel: writes the message to the log. A real provider (Twilio, etc.)

modules/Notifications/src/SimpleModule.Notifications/Channels/MailChannel.cs → modules/Notifications/src/SimpleModule.Notifications/Infrastructure/Channels/MailChannel.cs

@@ -2,7 +2,7 @@
 using SimpleModule.Email.Contracts;
 using SimpleModule.Notifications.Contracts;
 
-namespace SimpleModule.Notifications.Channels;
+namespace SimpleModule.Notifications.Infrastructure.Channels;
 
 /// <summary>
 /// Forwards a notification's mail payload to the Email module. Skips silently when the

modules/Notifications/src/SimpleModule.Notifications/EntityConfigurations/NotificationConfiguration.cs → modules/Notifications/src/SimpleModule.Notifications/Infrastructure/EntityConfigurations/NotificationConfiguration.cs

@@ -2,7 +2,7 @@
 using Microsoft.EntityFrameworkCore.Metadata.Builders;
 using SimpleModule.Notifications.Contracts;
 
-namespace SimpleModule.Notifications.EntityConfigurations;
+namespace SimpleModule.Notifications.Infrastructure.EntityConfigurations;
 
 public class NotificationConfiguration : IEntityTypeConfiguration<Notification>
 {
@@ -20,7 +20,12 @@ public void Configure(EntityTypeBuilder<Notification> builder)
 
         // Covers the inbox list query (filter UserId + order CreatedAt DESC, Id as tiebreaker)
         // and the unread-count query (predicate on UserId + ReadAt).
-        builder.HasIndex(n => new { n.UserId, n.CreatedAt, n.Id });
+        builder.HasIndex(n => new
+        {
+            n.UserId,
+            n.CreatedAt,
+            n.Id,
+        });
         builder.HasIndex(n => new { n.UserId, n.ReadAt });
     }
 }

modules/Notifications/src/SimpleModule.Notifications/Jobs/DispatchNotificationJob.cs → modules/Notifications/src/SimpleModule.Notifications/Infrastructure/Jobs/DispatchNotificationJob.cs

@@ -1,14 +1,13 @@
 using System.Text.Json;
 using Microsoft.Extensions.Logging;
 using SimpleModule.BackgroundJobs.Contracts;
-using SimpleModule.Notifications.Channels;
 using SimpleModule.Notifications.Contracts;
 using SimpleModule.Notifications.Contracts.Events;
-using SimpleModule.Notifications.Services;
+using SimpleModule.Notifications.Infrastructure.Channels;
 using SimpleModule.Users.Contracts;
 using Wolverine;
 
-namespace SimpleModule.Notifications.Jobs;
+namespace SimpleModule.Notifications.Infrastructure.Jobs;
 
 public sealed record DispatchNotificationJobData(
     string UserId,

modules/Notifications/src/SimpleModule.Notifications/Infrastructure/NotificationService.cs

@@ -0,0 +1,6 @@
+using SimpleModule.Notifications.Contracts;
+
+namespace SimpleModule.Notifications.Infrastructure;
+
+public sealed partial class NotificationService(NotificationsDbContext db)
+    : INotificationsContracts { }

modules/Notifications/src/SimpleModule.Notifications/NotificationsDbContext.cs → modules/Notifications/src/SimpleModule.Notifications/Infrastructure/NotificationsDbContext.cs

@@ -3,10 +3,10 @@
 using Microsoft.Extensions.Options;
 using SimpleModule.Database;
 using SimpleModule.Notifications.Contracts;
-using SimpleModule.Notifications.EntityConfigurations;
+using SimpleModule.Notifications.Infrastructure.EntityConfigurations;
 using SimpleModule.Users.Contracts;
 
-namespace SimpleModule.Notifications;
+namespace SimpleModule.Notifications.Infrastructure;
 
 public class NotificationsDbContext(
     DbContextOptions<NotificationsDbContext> options,

modules/Notifications/src/SimpleModule.Notifications/Services/NotificationsLog.cs → modules/Notifications/src/SimpleModule.Notifications/Infrastructure/NotificationsLog.cs

@@ -1,6 +1,6 @@
 using Microsoft.Extensions.Logging;
 
-namespace SimpleModule.Notifications.Services;
+namespace SimpleModule.Notifications.Infrastructure;
 
 internal static partial class NotificationsLog
 {

modules/Notifications/src/SimpleModule.Notifications/Services/Notifier.cs → modules/Notifications/src/SimpleModule.Notifications/Infrastructure/Notifier.cs

@@ -1,12 +1,12 @@
 using Microsoft.Extensions.Logging;
 using SimpleModule.BackgroundJobs.Contracts;
-using SimpleModule.Notifications.Channels;
 using SimpleModule.Notifications.Contracts;
 using SimpleModule.Notifications.Contracts.Events;
-using SimpleModule.Notifications.Jobs;
+using SimpleModule.Notifications.Infrastructure.Channels;
+using SimpleModule.Notifications.Infrastructure.Jobs;
 using Wolverine;
 
-namespace SimpleModule.Notifications.Services;
+namespace SimpleModule.Notifications.Infrastructure;
 
 public class Notifier(
     INotificationChannelRegistry channels,

modules/Notifications/src/SimpleModule.Notifications/NotificationsModule.cs

@@ -5,10 +5,10 @@
 using SimpleModule.Core;
 using SimpleModule.Core.Settings;
 using SimpleModule.Database;
-using SimpleModule.Notifications.Channels;
 using SimpleModule.Notifications.Contracts;
-using SimpleModule.Notifications.Jobs;
-using SimpleModule.Notifications.Services;
+using SimpleModule.Notifications.Infrastructure;
+using SimpleModule.Notifications.Infrastructure.Channels;
+using SimpleModule.Notifications.Infrastructure.Jobs;
 
 namespace SimpleModule.Notifications;
 

modules/Notifications/src/SimpleModule.Notifications/Pages/InboxEndpoint.cs

@@ -6,6 +6,7 @@
 using SimpleModule.Core.Extensions;
 using SimpleModule.Core.Inertia;
 using SimpleModule.Notifications.Contracts;
+using SimpleModule.Notifications.Contracts.Features.Notifications.List;
 using SimpleModule.Users.Contracts;
 
 namespace SimpleModule.Notifications.Pages;