NotificationController.cs

using DevDash.Attributes;
using DevDash.model;
using DevDash.Repository.IRepository;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using System.Net;
using System.Security.Claims;

namespace DevDash.Controllers
{
    [Route("api/[controller]")]
    [ApiController]
    [Authorize]
    public class NotificationController : ControllerBase
    {
        private readonly INotificationRepository _notificationRepository;
        private APIResponse _response;
        private readonly ITenantRepository _tenantRepository;
        public NotificationController(INotificationRepository notificationRepository,ITenantRepository tenantRepository)
        {
            _notificationRepository = notificationRepository;
            _tenantRepository = tenantRepository;
            _response = new APIResponse();
        }

        [HttpGet]
        [Cache(2000)]

        public async Task<ActionResult<APIResponse>> GetNotifications(string? search = null)
        {
            try
            {
                var userId = User.FindFirst(ClaimTypes.NameIdentifier)?.Value;
                if (string.IsNullOrEmpty(userId))
                {
                    _response.IsSuccess = false;
                    _response.StatusCode = HttpStatusCode.Unauthorized;
                    _response.ErrorMessages = new List<string> { "User ID not found" };
                    return Unauthorized(_response);
                }

              

                // Get notifications
                var notifications = await _notificationRepository.GetUserNotificationsAsync(int.Parse(userId));

                // Return both tenants and notifications
                _response.Result = new
                {
                    Notifications = notifications,
                    userId = int.Parse(userId)
                };
                _response.StatusCode = HttpStatusCode.OK;
                _response.IsSuccess = true;
                return Ok(_response);
            }
            catch (Exception ex)
            {
                _response.IsSuccess = false;
                _response.StatusCode = HttpStatusCode.InternalServerError;
                _response.ErrorMessages = new List<string> { ex.Message };
                return StatusCode((int)HttpStatusCode.InternalServerError, _response);
            }
        }


        [HttpPost("{notificationId}/mark-as-read")]
        public async Task<ActionResult<APIResponse>> MarkAsRead(int notificationId)
        {
            try
            {
                await _notificationRepository.MarkAsReadAsync(notificationId);
                _response.IsSuccess = true;
                _response.StatusCode = HttpStatusCode.NoContent;
                return Ok(_response);
            }
            catch (Exception ex)
            {
                _response.IsSuccess = false;
                _response.StatusCode = HttpStatusCode.InternalServerError;
                _response.ErrorMessages = new List<string> { ex.Message };
                return StatusCode(500, _response);
            }
        }

    }
}