Aastu.web.g1.yoseph.shemeles.homepage

.github/workflows/pr_title_check.yml

@@ -11,7 +11,7 @@ on:
 jobs:
   publish:
     name: PR Title Check
-    runs-on: ubuntu-18.04
+    runs-on: ubuntu-22.04
     steps:
       - uses: actions/checkout@v1
       - uses: dylanvann/check-pull-request-title@v1

aait/backend/group-1B/Application/Contracts/Persistence/IPostLikesRepository.cs

@@ -8,7 +8,7 @@ public interface IPostLikesRepository
     Task<bool> Exists(int userId, int postId);
     Task Delete(PostLike like);
     Task<PostLike> Add(PostLike like);
-    Task ChangeLike(PostLike like);
+    Task<int> ChangeLike(PostLike like);
     Task<List<PostLike>> GetLikesByPostId(int postId);
     Task<List<PostLike>> GetLikesByUserId(int userId);
 }

aait/backend/group-1B/Application/Features/Comments/Handlers/Commands/CreateCommentRequestHandler.cs

@@ -11,27 +11,46 @@ namespace Application.Features.Comments.Handlers.Commands;
 
 public class CreateCommentRequestHandler : IRequestHandler<CreateCommentRequest, CommentContentDto>
 {
-    private readonly ICommentRepository _commentRepository;
-    private readonly IPostRepository _postRepository;
+    private readonly IUnitOfWork _unitOfWork;
     private readonly IMapper _mapper;
 
-    public CreateCommentRequestHandler(ICommentRepository commentRepository, IPostRepository postRepository, IMapper mapper)
+    public CreateCommentRequestHandler(IUnitOfWork unitOfWork, IMapper mapper)
     {
-        _commentRepository = commentRepository;
-        _postRepository = postRepository;
+        _unitOfWork = unitOfWork;
         _mapper = mapper;
     }
 
     public async Task<CommentContentDto> Handle(CreateCommentRequest request, CancellationToken token)
     {
-        var validator = new CreateCommentDtoValidator(_postRepository);
+        var validator = new CreateCommentDtoValidator(_unitOfWork.PostRepository);
         var validationResult = await validator.ValidateAsync(request.Comment, token);
-
+
+        Console.WriteLine("Trying to create comment");
         if (validationResult.IsValid == false)
+        {
+            foreach (var error in validationResult.Errors)
+            {
+                Console.WriteLine(error.ErrorMessage);
+            }
+
             throw new ValidationException(validationResult);
+        }
+
+        Console.WriteLine("Here");
+        var comment = await _unitOfWork.CommentRepository.Add(_mapper.Map<Comment>(request.Comment));
+
+        var recievingPost = await _unitOfWork.PostRepository.Get(request.Comment.PostId);
+
+        var notif = new Notification()
+        {
+            UserId = recievingPost.UserId,
+            NotificationType = NotificationType.Comment,
+            Message = $"User {request.Comment.UserId} has commented on your post with Id {request.Comment.PostId}."
+        };
 
-        var comment = await _commentRepository.Add(_mapper.Map<Comment>(request.Comment));
+        await _unitOfWork.NotificationRepository.Add(notif);
 
+        await _unitOfWork.Save();
         return _mapper.Map<CommentContentDto>(comment);
     }
 }

aait/backend/group-1B/Application/Features/PostLikes/Handlers/Commands/ChangeLikeRequestHandler.cs

@@ -11,25 +11,38 @@ namespace Application.Features.PostLikes.Handlers.Commands;
 
 public class ChangeLikeRequestHandler : IRequestHandler<ChangeLikeRequest, Unit>
 {
-    private readonly IPostRepository _postRepository;
-    private readonly IPostLikesRepository _likesRepository;
+    private readonly IUnitOfWork _unitOfWork;
     private readonly IMapper _mapper;
 
-    public ChangeLikeRequestHandler(IPostLikesRepository postLikesRepository, IPostRepository postRepository, IMapper mapper)
+    public ChangeLikeRequestHandler(IUnitOfWork unitOfWork, IMapper mapper)
     {
-        _postRepository = postRepository;
-        _likesRepository = postLikesRepository;
+        _unitOfWork = unitOfWork;
         _mapper = mapper;
     }
 
     public async Task<Unit> Handle(ChangeLikeRequest request, CancellationToken token)
     {
-        var validator = new ChangeLikeDtoValidator(_postRepository);
+        var validator = new ChangeLikeDtoValidator(_unitOfWork.PostRepository);
         var validationResult = await validator.ValidateAsync(request.ChangeLike, token);
         if (validationResult.IsValid == false)
             throw new ValidationException(validationResult);
 
-        await _likesRepository.ChangeLike(_mapper.Map<PostLike>(request.ChangeLike));
+        var liked = await _unitOfWork.PostLikesRepository.ChangeLike(_mapper.Map<PostLike>(request.ChangeLike));
+        if (liked == 1)
+        {
+            var recievingPost = await _unitOfWork.PostRepository.Get(request.ChangeLike.PostId);
+
+            var notif = new Notification()
+            {
+                UserId = recievingPost.UserId,
+                NotificationType = NotificationType.Like,
+                Message = $"User {request.ChangeLike.UserId} has liked your post with Id {request.ChangeLike.PostId}."
+            };
+
+            await _unitOfWork.NotificationRepository.Add(notif);
+        }
+
+        await _unitOfWork.Save();
         return Unit.Value;
     }
 

aait/backend/group-1B/Application/Features/Posts/Handlers/Commands/UpdatePostRequestHandler.cs

@@ -9,6 +9,7 @@ namespace Application.Features.Posts.Handlers.Commands;
 
 public class UpdatePostRequestHandler : IRequestHandler<UpdatePostRequest, Post>
 {
+
     private readonly IMapper _mapper;
     private readonly IUnitOfWork _unitOfWork;
 

aait/backend/group-1B/Persistence/Repositories/PostLikesRepository.cs

@@ -40,18 +40,19 @@ public async Task<PostLike> Add(PostLike like)
         return like;
     }
 
-    public async Task ChangeLike(PostLike like)
+    // Returns 1 if it likes and 0 if it dislikes
+    public async Task<int> ChangeLike(PostLike like)
     {
         var exists = await Exists(like.UserId, like.PostId);
         if (exists)
         {
-            Console.WriteLine($"Deleted Like {like.UserId} {like.PostId}");
             await Delete(like);
+            return 0;
         }
         else
         {
-            Console.WriteLine($"Created Like {like.UserId} {like.PostId}");
             await Add(like);
+            return 1;
         }
     }
 

aait/backend/group-1B/Persistence/SocialSyncDbContext.cs

@@ -38,6 +38,9 @@ public override Task<int> SaveChangesAsync(CancellationToken cancellationToken =
                 {
                     entry.Entity.DateCreated = DateTime.UtcNow;
                 }
+
+
+
             }
 
             return base.SaveChangesAsync(cancellationToken);

aait/backend/group-1B/WebApi/Controllers/CommentsController.cs

@@ -3,7 +3,6 @@
 using Application.Features.Comments.Requests.Commands;
 using Application.Features.Comments.Requests.Queries;
 using MediatR;
-using Microsoft.AspNetCore.Identity;
 using Microsoft.AspNetCore.Mvc;
 
 namespace WebApi.Controllers;
@@ -62,7 +61,7 @@ public async Task<IActionResult> Update(UpdateCommentDto commentDto)
         return Ok(comment);
     }
 
-    [HttpDelete("{id:int}")]
+    [HttpDelete]
     public async Task<IActionResult> Delete(int id)
     {
         var request = new DeleteCommentRequest() { Id = id };

aait/backend/group-1B/WebApi/Controllers/NotificationsController.cs

@@ -0,0 +1,70 @@
+using System.Security.Claims;
+using Application.DTOs.Notifications;
+using Application.Features.Notifications.Requests.Commands;
+using Application.Features.Notifications.Requests.Queries;
+using MediatR;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Mvc;
+
+namespace WebApi.Controllers;
+
+[ApiController]
+[Authorize]
+[Route("api/[controller]")]
+public class NotificationsController : ControllerBase
+{
+    private readonly IMediator _mediator;
+
+    public NotificationsController(IMediator mediator)
+    {
+        _mediator = mediator;
+    }
+
+    [HttpGet]
+    public async Task<IActionResult> GetAll()
+    {
+        // Get user Id from the verified token
+        var userId = int.Parse(User.FindFirst(ClaimTypes.NameIdentifier).Value);
+
+        var request = new GetAllNotificationsRequest() { UserId = userId };
+        var notifications = await _mediator.Send(request);
+
+        return Ok(notifications);
+    }
+
+    [HttpGet("{id:int}")]
+    public async Task<IActionResult> Get(int id)
+    {
+        var request = new GetNotificationRequest() { Id = id };
+        var notification = await _mediator.Send(request);
+
+        return Ok(notification);
+    }
+
+    [HttpPatch("seen/{id:int}")]
+    public async Task<IActionResult> MarkAsSeen(int id)
+    {
+        // Get user Id from the verified token
+        var userId = int.Parse(User.FindFirst(ClaimTypes.NameIdentifier).Value);
+
+        var request = new MarkNotificationAsSeenRequest()
+            { UpdateDto = new UpdateNotificationDto() { UserId = userId, Id = id } };
+        await _mediator.Send(request);
+
+        return NoContent();
+    }
+
+    [HttpDelete("{id:int}")]
+    public async Task<IActionResult> Delete(int id)
+    {
+        // Get user Id from the verified token
+        var userId = int.Parse(User.FindFirst(ClaimTypes.NameIdentifier).Value);
+
+        var request = new DeleteNotificationRequest()
+            { DeleteDto = new UpdateNotificationDto() { UserId = userId, Id = id } };
+        await _mediator.Send(request);
+
+        return NoContent();
+    }
+
+}

aait/backend/group-1B/WebApi/Controllers/PostsController.cs

@@ -47,7 +47,7 @@ public async Task<IActionResult> GetByUserId(int userId)
         return Ok(posts);
     }
 
-    [HttpGet("tag/{tagName}")]
+    [HttpGet("search/{tagName}")]
     public async Task<IActionResult> GetByTag(string tagName)
     {
         var request = new GetPostsByTagRequest() { Tag = tagName };
@@ -65,7 +65,7 @@ public async Task<IActionResult> GetFeed()
         return Ok(posts);
     }
 
-    [HttpGet("like/{postId:int}")]
+    [HttpGet("{postId:int}/likes")]
     public async Task<IActionResult> GetLikes(int postId)
     {
         var request = new GetLikesByPostIdRequest() { PostId = postId };

aait/backend/group-2B/Application.Tests/Application.Tests.csproj

@@ -10,8 +10,8 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.5.0"/>
-        <PackageReference Include="xunit" Version="2.4.2"/>
+        <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.5.0" />
+        <PackageReference Include="xunit" Version="2.4.2" />
         <PackageReference Include="xunit.runner.visualstudio" Version="2.4.5">
             <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
             <PrivateAssets>all</PrivateAssets>
@@ -20,8 +20,12 @@
             <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
             <PrivateAssets>all</PrivateAssets>
         </PackageReference>
-        <PackageReference Include="Moq" Version="4.18.4"/>
-        <PackageReference Include="Shouldly" Version="4.2.1"/>
+        <PackageReference Include="Moq" Version="4.18.4" />
+        <PackageReference Include="Shouldly" Version="4.2.1" />
+    </ItemGroup>
+
+    <ItemGroup>
+      <ProjectReference Include="..\Application\Application.csproj" />
     </ItemGroup>
 
 </Project>

aait/backend/group-2B/Application.Tests/Mocks/Persistence/MockUnitOfWork.cs

@@ -0,0 +1,18 @@
+using Moq;
+using SocialSync.Application.Contracts.Persistence;
+
+namespace SocialSync.Application.Tests.Mocks;
+
+
+public class MockUnitOfWork {
+  public static Mock<IUnitOfWork> GetMockUnitOfWork() {
+    var unitOfWork = new Mock<IUnitOfWork>();
+
+    var mockUserRepository = MockUserRepository.GetUserRepository();
+
+    unitOfWork.Setup(uow => uow.UserRepository).Returns(mockUserRepository.Object);
+    unitOfWork.Setup(uow => uow.SaveAsync()).ReturnsAsync(1);
+
+    return unitOfWork;
+  }
+}