59 lines
1.7 KiB
C#
59 lines
1.7 KiB
C#
using System.Security.Claims;
|
|
using LctMonolith.Services;
|
|
using LctMonolith.Services.Contracts;
|
|
using Microsoft.AspNetCore.Authorization;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
|
|
namespace LctMonolith.Controllers;
|
|
|
|
/// <summary>
|
|
/// In-app user notifications API.
|
|
/// </summary>
|
|
[ApiController]
|
|
[Route("api/notifications")]
|
|
[Authorize]
|
|
public class NotificationsController : ControllerBase
|
|
{
|
|
private readonly INotificationService _notifications;
|
|
|
|
public NotificationsController(INotificationService notifications)
|
|
{
|
|
_notifications = notifications;
|
|
}
|
|
|
|
private Guid GetUserId() => Guid.Parse(User.FindFirstValue(ClaimTypes.NameIdentifier)!);
|
|
|
|
/// <summary>Get up to 100 unread notifications.</summary>
|
|
[HttpGet("unread")]
|
|
public async Task<IActionResult> GetUnread(CancellationToken ct)
|
|
{
|
|
var list = await _notifications.GetUnreadAsync(GetUserId(), ct);
|
|
return Ok(list);
|
|
}
|
|
|
|
/// <summary>Get recent notifications (paged by take).</summary>
|
|
[HttpGet]
|
|
public async Task<IActionResult> GetAll([FromQuery] int take = 100, CancellationToken ct = default)
|
|
{
|
|
var list = await _notifications.GetAllAsync(GetUserId(), take, ct);
|
|
return Ok(list);
|
|
}
|
|
|
|
/// <summary>Mark a notification as read.</summary>
|
|
[HttpPost("mark/{id:guid}")]
|
|
public async Task<IActionResult> MarkRead(Guid id, CancellationToken ct)
|
|
{
|
|
await _notifications.MarkReadAsync(GetUserId(), id, ct);
|
|
return NoContent();
|
|
}
|
|
|
|
/// <summary>Mark all notifications as read.</summary>
|
|
[HttpPost("mark-all")]
|
|
public async Task<IActionResult> MarkAll(CancellationToken ct)
|
|
{
|
|
var cnt = await _notifications.MarkAllReadAsync(GetUserId(), ct);
|
|
return Ok(new { updated = cnt });
|
|
}
|
|
}
|
|
|