feat: Fixed errors

LctMonolith/Services/NotificationService.cs

@@ -1 +1,79 @@
+using LctMonolith.Database.UnitOfWork;
+using LctMonolith.Models;
+using LctMonolith.Services.Contracts;
+using Microsoft.EntityFrameworkCore;
 
+namespace LctMonolith.Services;
+
+/// <summary>
+/// In-app user notifications CRUD / read-state operations.
+/// </summary>
+public class NotificationService : INotificationService
+{
+    private readonly IUnitOfWork _uow;
+
+    public NotificationService(IUnitOfWork uow)
+    {
+        _uow = uow;
+    }
+
+    public async Task<Notification> CreateAsync(Guid userId, string type, string title, string message, CancellationToken ct = default)
+    {
+        if (string.IsNullOrWhiteSpace(type)) throw new ArgumentException("Required", nameof(type));
+        if (string.IsNullOrWhiteSpace(title)) throw new ArgumentException("Required", nameof(title));
+        if (string.IsNullOrWhiteSpace(message)) throw new ArgumentException("Required", nameof(message));
+
+        var n = new Notification
+        {
+            UserId = userId,
+            Type = type.Trim(),
+            Title = title.Trim(),
+            Message = message.Trim(),
+            CreatedAt = DateTime.UtcNow,
+            IsRead = false
+        };
+        await _uow.Notifications.AddAsync(n, ct);
+        await _uow.SaveChangesAsync(ct);
+        return n;
+    }
+
+    public async Task<IEnumerable<Notification>> GetUnreadAsync(Guid userId, CancellationToken ct = default)
+    {
+        var query = _uow.Notifications.Query(n => n.UserId == userId && !n.IsRead, q => q.OrderByDescending(x => x.CreatedAt));
+        return await query.Take(100).ToListAsync(ct);
+    }
+
+    public async Task<IEnumerable<Notification>> GetAllAsync(Guid userId, int take = 100, CancellationToken ct = default)
+    {
+        if (take <= 0) take = 1;
+        if (take > 500) take = 500;
+        var query = _uow.Notifications.Query(n => n.UserId == userId, q => q.OrderByDescending(x => x.CreatedAt));
+        return await query.Take(take).ToListAsync(ct);
+    }
+
+    public async Task MarkReadAsync(Guid userId, Guid notificationId, CancellationToken ct = default)
+    {
+        var notif = await _uow.Notifications.Query(n => n.Id == notificationId && n.UserId == userId).FirstOrDefaultAsync(ct)
+            ?? throw new KeyNotFoundException("Notification not found");
+        if (!notif.IsRead)
+        {
+            notif.IsRead = true;
+            notif.ReadAt = DateTime.UtcNow;
+            await _uow.SaveChangesAsync(ct);
+        }
+    }
+
+    public async Task<int> MarkAllReadAsync(Guid userId, CancellationToken ct = default)
+    {
+        var unread = await _uow.Notifications.Query(n => n.UserId == userId && !n.IsRead).ToListAsync(ct);
+        if (unread.Count == 0) return 0;
+        var now = DateTime.UtcNow;
+        foreach (var n in unread)
+        {
+            n.IsRead = true;
+            n.ReadAt = now;
+        }
+        await _uow.SaveChangesAsync(ct);
+        return unread.Count;
+    }
+}