| | | 1 | | using Dapper; |
| | | 2 | | using System.Text.Json; |
| | | 3 | | |
| | | 4 | | namespace Estud.Back.Features.Notifications.GetNotifications; |
| | | 5 | | |
| | 6 | 6 | | public class GetNotificationsService(EstudDbContext ctx) : IEstudService |
| | | 7 | | { |
| | | 8 | | public async Task<OneOf<GetNotificationsOut, EstudError>> Get(GetNotificationsIn data) |
| | | 9 | | { |
| | 6 | 10 | | var connection = await ctx.GetOpenConnectionAsync(); |
| | | 11 | | |
| | 6 | 12 | | var unreadFilter = data.UnreadOnly ? "AND un.viewed_at IS NULL" : ""; |
| | | 13 | | |
| | 6 | 14 | | var sql = $@" |
| | 6 | 15 | | SELECT |
| | 6 | 16 | | n.id, |
| | 6 | 17 | | n.notification_type, |
| | 6 | 18 | | n.title, |
| | 6 | 19 | | n.description, |
| | 6 | 20 | | n.created_at, |
| | 6 | 21 | | un.viewed_at, |
| | 6 | 22 | | n.metadata::text AS metadata, |
| | 6 | 23 | | COUNT(*) OVER() AS total_rows |
| | 6 | 24 | | FROM |
| | 6 | 25 | | estud.user_notifications un |
| | 6 | 26 | | JOIN |
| | 6 | 27 | | estud.notifications n ON n.id = un.notification_id |
| | 6 | 28 | | WHERE |
| | 6 | 29 | | un.user_id = @UserId |
| | 6 | 30 | | {unreadFilter} |
| | 6 | 31 | | ORDER BY n.created_at DESC |
| | 6 | 32 | | LIMIT @PageSize |
| | 6 | 33 | | OFFSET @Offset |
| | 6 | 34 | | "; |
| | | 35 | | |
| | 6 | 36 | | var offset = (data.Page - 1) * data.PageSize; |
| | 6 | 37 | | var parameters = new { UserId = ctx.RequestUser.Id, data.PageSize, Offset = offset }; |
| | | 38 | | |
| | 6 | 39 | | var rows = (await connection.QueryAsync<NotificationRow>(sql, parameters)).ToList(); |
| | | 40 | | |
| | 8 | 41 | | var items = rows.Select(r => new GetNotificationsItemOut |
| | 8 | 42 | | { |
| | 8 | 43 | | Id = r.Id, |
| | 8 | 44 | | NotificationType = (NotificationType)r.NotificationType, |
| | 8 | 45 | | Title = r.Title, |
| | 8 | 46 | | Description = r.Description, |
| | 8 | 47 | | CreatedAt = r.CreatedAt, |
| | 8 | 48 | | ViewedAt = r.ViewedAt, |
| | 8 | 49 | | Metadata = r.Metadata != null ? JsonDocument.Parse(r.Metadata) : null, |
| | 8 | 50 | | }).ToList(); |
| | | 51 | | |
| | 6 | 52 | | return new GetNotificationsOut |
| | 6 | 53 | | { |
| | 6 | 54 | | Total = rows.FirstOrDefault()?.TotalRows ?? 0, |
| | 6 | 55 | | Page = data.Page, |
| | 6 | 56 | | PageSize = data.PageSize, |
| | 6 | 57 | | Items = items, |
| | 6 | 58 | | }; |
| | 6 | 59 | | } |
| | | 60 | | } |