Notification System Implementation

AskFm/AskFm.API/AskFm.API.csproj

@@ -21,12 +21,39 @@
         <PackageReference Include="Microsoft.Extensions.Caching.StackExchangeRedis" Version="9.0.0" />
         <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="9.0.0" />
         <PackageReference Include="StackExchange.Redis" Version="2.9.11" />
-        <PackageReference Include="Swashbuckle.AspNetCore" Version="6.6.2" />
+        <PackageReference Include="Microsoft.AspNetCore.SignalR" Version="1.2.0" />
+        <PackageReference Include="Swashbuckle.AspNetCore" Version="9.0.4" />
+        <PackageReference Include="Swashbuckle.AspNetCore.SwaggerUI" Version="9.0.4" />
+
     </ItemGroup>
 
     <ItemGroup>
         <ProjectReference Include="..\AskFm.BLL\AskFm.BLL.csproj" />
         <ProjectReference Include="..\Shared\Shared.csproj" />
     </ItemGroup>
 
+  <PropertyGroup>
+    <TargetFramework>net9.0</TargetFramework>
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+  </PropertyGroup>
+  <ItemGroup>
+    <PackageReference Include="DotNetEnv" Version="3.1.1" />
+    <PackageReference Include="Microsoft.AspNetCore.Identity.EntityFrameworkCore" Version="9.0.0" />
+    <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="9.0.0" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore" Version="9.0.0" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore.Design" Version="9.0.0">
+      <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
+      <PrivateAssets>all</PrivateAssets>
+    </PackageReference>
+    <PackageReference Include="Microsoft.EntityFrameworkCore.Proxies" Version="9.0.0" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" Version="9.0.0" />
+    <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="9.0.0" />
+    <PackageReference Include="Microsoft.AspNetCore.SignalR" Version="1.2.0" />
+    <PackageReference Include="Swashbuckle.AspNetCore.SwaggerUI" Version="9.0.3" />
+  </ItemGroup>
+  <ItemGroup>
+    <ProjectReference Include="..\AskFm.BLL\AskFm.BLL.csproj" />
+    <ProjectReference Include="..\Shared\Shared.csproj" />
+  </ItemGroup>
 </Project>

AskFm/AskFm.API/Controllers/NotificationController.cs

@@ -0,0 +1,120 @@
+using System.Security.Claims;
+using AskFm.BLL.DTO;
+using AskFm.BLL.Services;
+using AskFm.DAL.Enums;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Mvc;
+
+namespace AskFm.API.Controllers
+{
+    [ApiController]
+    [Route("api/[controller]")]
+    [Authorize]
+    public class NotificationController : ControllerBase
+    {
+        private readonly INotificationService _notificationService;
+
+        public NotificationController(INotificationService notificationService)
+        {
+            _notificationService = notificationService;
+        }
+
+        [HttpGet]
+        public async Task<IActionResult> GetUserNotifications([FromQuery] int pageNumber = 1, [FromQuery] int pageSize = 10)
+        {
+            try
+            {
+                var userId = GetCurrentUserId();
+                var notifications = await _notificationService.GetUserNotifications(userId, pageNumber, pageSize);
+                return Ok(notifications);
+            }
+            catch (Exception ex)
+            {
+                return BadRequest(ex.Message);
+            }
+        }
+
+        [HttpGet("type/{category}")]
+        public async Task<IActionResult> GetNotificationsByType(string category, [FromQuery] int pageNumber = 1, [FromQuery] int pageSize = 10)
+        {
+            try
+            {
+                var userId = GetCurrentUserId();
+                var response = await _notificationService.GetNotificationsByType(userId, category, pageNumber, pageSize);
+                return Ok(response);
+            }
+            catch (ArgumentException ex)
+            {
+                return BadRequest(ex.Message);
+            }
+            catch (Exception ex)
+            {
+                return StatusCode(500, ex.Message);
+            }
+        }
+
+        [HttpPut("{notificationId}/read")]
+        public async Task<IActionResult> MarkNotificationAsRead(int notificationId)
+        {
+            try
+            {
+                var userId = GetCurrentUserId();
+                var result = await _notificationService.MarkNotificationAsRead(notificationId, userId);
+                return Ok(new { message = result });
+            }
+            catch (InvalidOperationException ex)
+            {
+                return NotFound(ex.Message);
+            }
+            catch (UnauthorizedAccessException ex)
+            {
+                return Forbid(ex.Message);
+            }
+            catch (Exception ex)
+            {
+                return BadRequest(ex.Message);
+            }
+        }
+
+        [HttpPut("read-all")]
+        public async Task<IActionResult> MarkAllNotificationsAsRead()
+        {
+            try
+            {
+                var userId = GetCurrentUserId();
+                var result = await _notificationService.MarkAllNotificationsAsRead(userId);
+                return Ok(new { message = result });
+            }
+            catch (Exception ex)
+            {
+                return BadRequest(ex.Message);
+            }
+        }
+
+        [HttpPost]
+        [Authorize(Roles = "Admin")]
+        public async Task<IActionResult> CreateNotification([FromBody] CreateNotificationRequest request)
+        {
+            try
+            {
+                await _notificationService.CreateNotification(request.UserId, request.Type, request.ResourceId, request.Message);
+                return Ok(new { message = "Notification created successfully" });
+            }
+            catch (Exception ex)
+            {
+                return BadRequest(ex.Message);
+            }
+        }
+
+        private int GetCurrentUserId()
+        {
+            // Use the standard NameIdentifier claim
+            var userIdClaim = User.FindFirst(ClaimTypes.NameIdentifier)?.Value;
+            if (string.IsNullOrEmpty(userIdClaim) || !int.TryParse(userIdClaim, out int userId))
+            {
+                throw new UnauthorizedAccessException("Invalid user token");
+            }
+            return userId;
+        }
+    }
+}

AskFm/AskFm.API/Program.cs

@@ -1,5 +1,4 @@
 using System.Text;
-using AskFm.BLL.Services;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.AspNetCore.Identity;
 using AskFm.DAL;
@@ -9,10 +8,13 @@
 using DotNetEnv;
 using Microsoft.AspNetCore.Authentication.JwtBearer;
 using Microsoft.EntityFrameworkCore.Proxies;
+using AskFm.BLL.Hub;
+using AskFm.BLL.Services;
 using Microsoft.Extensions.Options;
 using Microsoft.IdentityModel.Tokens;
 using Microsoft.OpenApi.Models;
 using AskFm.BLL.Services.UserIdentityService;
+using Swashbuckle.AspNetCore.SwaggerGen;
 using Castle.Components.DictionaryAdapter.Xml;
 
 namespace AskFm.API;
@@ -43,6 +45,9 @@ public static void Main(string[] args)
                 .UseSqlServer(ConnectionString));
 
         builder.Services.AddScoped<IUnitOfWork, UnitOfWork>();
+        builder.Services.AddScoped<INotificationRepository, NotificationRepository>();
+        builder.Services.AddScoped<INotificationService, NotificationService>();
+
         builder.Services.AddScoped<IAuthService, AuthService>();
         builder.Services.AddScoped<IUserService, UserService>();
         builder.Services.AddScoped<ICommentLikeService, CommentLikeService>();
@@ -91,6 +96,39 @@ public static void Main(string[] args)
             throw new Exception("jwtOptions is null");
         }
 
+        // Enhanced SignalR Configuration
+        builder.Services.AddSignalR(options =>
+        {
+            options.EnableDetailedErrors = true;
+            options.KeepAliveInterval = TimeSpan.FromSeconds(15);
+            options.ClientTimeoutInterval = TimeSpan.FromSeconds(30);
+            options.HandshakeTimeout = TimeSpan.FromSeconds(15);
+        });
+
+        // CORS Configuration for SignalR
+        builder.Services.AddCors(options =>
+        {
+            options.AddPolicy("SignalRPolicy", policy =>
+            {
+                // Option 1: Allow any origin (for development only)
+                policy.AllowAnyOrigin()
+                      .AllowAnyMethod()
+                      .AllowAnyHeader();
+
+                // Option 2: Specific origins (uncomment and modify when you know frontend URLs)
+                // policy.WithOrigins(
+                //     "http://localhost:3000",    // React default
+                //     "http://localhost:4200",    // Angular default
+                //     "http://localhost:8080",    // Vue default
+                //     "http://localhost:5173",    // Vite default
+                //     "https://yourdomain.com"    // Production domain
+                // )
+                // .AllowAnyMethod()
+                // .AllowAnyHeader()
+                // .AllowCredentials();
+            });
+        });
+
         builder.Services.Configure<JwtOptions>(Options =>
         {
             Options.Issuer = Environment.GetEnvironmentVariable("ISSUER");
@@ -120,6 +158,21 @@ public static void Main(string[] args)
                     ClockSkew = TimeSpan.FromMinutes(0)
                 };
 
+                // Enable JWT authentication for SignalR
+                Options.Events = new JwtBearerEvents
+                {
+                    OnMessageReceived = context =>
+                    {
+                        var accessToken = context.Request.Query["access_token"];
+                        var path = context.HttpContext.Request.Path;
+
+                        if (!string.IsNullOrEmpty(accessToken) && path.StartsWithSegments("/notificationHub"))
+                        {
+                            context.Token = accessToken;
+                        }
+                        return Task.CompletedTask;
+                    }
+                };
             });
         builder.Services.AddAuthorization();
         builder.Services.AddIdentity<ApplicationUser, IdentityRole<int>>(options =>
@@ -167,17 +220,26 @@ public static void Main(string[] args)
         if (app.Environment.IsDevelopment())
         {
             app.UseSwagger();
-            app.UseSwaggerUI();
             app.MapOpenApi();
+            app.UseSwaggerUI(options =>
+            {
+                options.SwaggerEndpoint("/openapi/v1.json", "api");
+            });
         }
 
         app.UseHttpsRedirection();
+
+        // Apply CORS before authentication
+        app.UseCors("SignalRPolicy");
+
         app.UseAuthentication();
         app.UseAuthorization();
-
 
         app.MapControllers();
 
+        // Map SignalR Hub
+        app.MapHub<NotificationHub>("/notificationHub");
+
         app.Run();
     }
 }

AskFm/AskFm.API/Properties/launchSettings.json

@@ -5,7 +5,7 @@
       "commandName": "Project",
       "dotnetRunMessages": true,
       "launchBrowser": true,
-      "launchUrl": "swagger",
+        "launchUrl": "swagger",
       "applicationUrl": "http://localhost:5180",
       "environmentVariables": {
         "ASPNETCORE_ENVIRONMENT": "Development"

AskFm/AskFm.BLL/AskFm.BLL.csproj

@@ -1,19 +1,19 @@
 <Project Sdk="Microsoft.NET.Sdk">
-
-    <PropertyGroup>
-        <TargetFramework>net9.0</TargetFramework>
-        <ImplicitUsings>enable</ImplicitUsings>
-        <Nullable>enable</Nullable>
-    </PropertyGroup>
-
-    <ItemGroup>
-        <ProjectReference Include="..\AskFm.DAL\AskFm.DAL.csproj"/>
-        <ProjectReference Include="..\Shared\Shared.csproj"/>
-    </ItemGroup>
-
-    <ItemGroup>
-      <PackageReference Include="AutoMapper" Version="15.0.1" />
+  <PropertyGroup>
+    <TargetFramework>net9.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+  <ItemGroup>
+    <ProjectReference Include="..\AskFm.DAL\AskFm.DAL.csproj"/>
+    <ProjectReference Include="..\Shared\Shared.csproj"/>
+  </ItemGroup>
+  <ItemGroup>
+    <PackageReference Include="Microsoft.AspNetCore.SignalR" Version="1.2.0"/>
+    <PackageReference Include="AutoMapper" Version="15.0.1"/>
+    <PackageReference Include="AutoMapper.Extensions.Microsoft.DependencyInjection" Version="12.0.1"/>
       <PackageReference Include="Microsoft.AspNetCore.Authentication.JwtBearer" Version="9.0.0" />
-    </ItemGroup>
+
+  </ItemGroup>
 
 </Project>

AskFm/AskFm.BLL/DTO/ActorDto.cs

@@ -0,0 +1,8 @@
+namespace AskFm.BLL.DTO;
+
+public class ActorDto
+{
+    public int Id { get; set; }
+    public string Username { get; set; }
+    public string AvatarPath { get; set; }
+}

AskFm/AskFm.BLL/DTO/CreateNotificationRequest.cs

@@ -0,0 +1,16 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using AskFm.DAL.Enums;
+
+namespace AskFm.BLL.DTO
+{
+    public class CreateNotificationRequest
+    {
+        public int UserId { get; set; }
+        public NotificationStatus Type { get; set; }
+        public int ResourceId { get; set; }
+        public string Message { get; set; }
+    }
+}

AskFm/AskFm.BLL/DTO/NotificationDto.cs

@@ -0,0 +1,19 @@
+using AskFm.BLL.DTO;
+
+public class NotificationDto
+{
+    public int Id { get; set; }
+    public string Type { get; set; }
+
+    public string Message { get; set; }
+
+    public bool IsRead { get; set; }
+    public DateTime CreatedAt { get; set; }
+
+    public int ResourceId { get; set; }
+    public int UserId { get; set; }
+    public ActorDto? Actor { get; set; }
+    public PaginationDto Pagination { get; set; }
+
+
+}

AskFm/AskFm.BLL/DTO/PaginationDto.cs

@@ -0,0 +1,10 @@
+namespace AskFm.BLL.DTO;
+
+public class PaginationDto
+{
+    public int CurrentPage { get; set; }
+    public int TotalPages { get; set; }
+    public int TotalCount { get; set; }
+    public bool HasNext { get; set; }
+    public bool HasPrevious { get; set; }
+}