Notifications Service: .NET 8 (#627)

Author: DedSec256

HwProj.Common/HwProj.Repositories.Net8/CrudRepository.cs

@@ -0,0 +1,67 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Linq.Expressions;
+using System.Threading.Tasks;
+using Microsoft.EntityFrameworkCore;
+using Z.EntityFramework.Plus;
+
+namespace HwProj.Repositories.Net8;
+
+public class CrudRepository<TEntity, TKey>(DbContext context) : ICrudRepository<TEntity, TKey>
+    where TEntity : class, IEntity<TKey>
+    where TKey : IEquatable<TKey>
+{
+    protected DbContext Context => context;
+
+    public async Task<TKey> AddAsync(TEntity item)
+    {
+        await context.AddAsync(item);
+        await context.SaveChangesAsync();
+        return item.Id;
+    }
+
+    public async Task<List<TKey>> AddRangeAsync(IEnumerable<TEntity> items)
+    {
+        items = items.ToList();
+        await context.AddRangeAsync(items);
+        await context.SaveChangesAsync();
+        return items.Select(item => item.Id).ToList();
+    }
+
+    public async Task DeleteAsync(TKey id)
+    {
+        await context.Set<TEntity>()
+                .Where(entity => entity.Id.Equals(id))
+                .DeleteAsync()
+            ;
+    }
+
+    public async Task UpdateAsync(TKey id, Expression<Func<TEntity, TEntity>> updateFactory)
+    {
+        await context.Set<TEntity>()
+                .Where(entity => entity.Id.Equals(id))
+                .UpdateAsync(updateFactory)
+            ;
+    }
+
+    public IQueryable<TEntity> GetAll()
+    {
+        return context.Set<TEntity>().AsNoTracking();
+    }
+
+    public IQueryable<TEntity> FindAll(Expression<Func<TEntity, bool>> predicate)
+    {
+        return context.Set<TEntity>().AsNoTracking().Where(predicate);
+    }
+
+    public async Task<TEntity> GetAsync(TKey id)
+    {
+        return await context.FindAsync<TEntity>(id);
+    }
+
+    public async Task<TEntity> FindAsync(Expression<Func<TEntity, bool>> predicate)
+    {
+        return await context.Set<TEntity>().AsNoTracking().FirstOrDefaultAsync(predicate);
+    }
+}

HwProj.Common/HwProj.Repositories.Net8/HwProj.Repositories.Net8.csproj

@@ -0,0 +1,11 @@
+<Project Sdk="Microsoft.NET.Sdk">
+    <PropertyGroup>
+        <TargetFramework>net8.0</TargetFramework>
+        <LangVersion>12</LangVersion>
+        <Nullable>disable</Nullable>
+    </PropertyGroup>
+    <ItemGroup>
+        <PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" Version="9.0.9" />
+        <PackageReference Include="Z.EntityFramework.Plus.EFCore" Version="9.104.0" />
+    </ItemGroup>
+</Project>

HwProj.Common/HwProj.Repositories.Net8/ICrudRepository.cs

@@ -0,0 +1,21 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Linq.Expressions;
+using System.Threading.Tasks;
+
+namespace HwProj.Repositories.Net8;
+
+public interface ICrudRepository<TEntity, TKey>
+    where TEntity : IEntity<TKey>
+    where TKey : IEquatable<TKey>
+{
+    Task<TKey> AddAsync(TEntity item);
+    Task<List<TKey>> AddRangeAsync(IEnumerable<TEntity> items);
+    Task DeleteAsync(TKey id);
+    Task UpdateAsync(TKey id, Expression<Func<TEntity, TEntity>> updateFactory);
+    IQueryable<TEntity> GetAll();
+    IQueryable<TEntity> FindAll(Expression<Func<TEntity, bool>> predicate);
+    Task<TEntity> GetAsync(TKey id);
+    Task<TEntity> FindAsync(Expression<Func<TEntity, bool>> predicate);
+}

HwProj.Common/HwProj.Repositories.Net8/IEntity.cs

@@ -0,0 +1,9 @@
+using System;
+
+namespace HwProj.Repositories.Net8;
+
+public interface IEntity<TKey>
+    where TKey : IEquatable<TKey>
+{
+    TKey Id { get; set; }
+}

HwProj.CoursesService/HwProj.CoursesService.API/Dockerfile

@@ -11,6 +11,7 @@ COPY ["HwProj.Common/HwProj.Repositories/", "HwProj.Common/HwProj.Repositories/"
 COPY ["HwProj.AuthService/HwProj.AuthService.Client/", "HwProj.AuthService/HwProj.AuthService.Client/"]
 COPY ["HwProj.ContentService/HwProj.ContentService.Client/", "HwProj.ContentService/HwProj.ContentService.Client/"]
 COPY ["HwProj.Common/HwProj.HttpUtils/", "HwProj.Common/HwProj.HttpUtils/"]
+COPY ["HwProj.NotificationsService/HwProj.NotificationService.Events/", "HwProj.NotificationsService/HwProj.NotificationService.Events/"]
 
 WORKDIR "/src/HwProj.CoursesService/HwProj.CoursesService.API"
 RUN dotnet publish "HwProj.CoursesService.API.csproj" -c Release -o /app/publish

HwProj.CoursesService/HwProj.CoursesService.API/HwProj.CoursesService.API.csproj

@@ -26,6 +26,7 @@
     <ProjectReference Include="..\..\HwProj.AuthService\HwProj.AuthService.Client\HwProj.AuthService.Client.csproj" />
     <ProjectReference Include="..\..\HwProj.Common\HwProj.Repositories\HwProj.Repositories.csproj" />
     <ProjectReference Include="..\..\HwProj.Common\HwProj.Utils\HwProj.Utils.csproj" />
+    <ProjectReference Include="..\..\HwProj.NotificationsService\HwProj.NotificationService.Events\HwProj.NotificationService.Events.csproj" />
   </ItemGroup>
   <ProjectExtensions><VisualStudio><UserProperties properties_4launchsettings_1json__JsonSchema="" /></VisualStudio></ProjectExtensions>
 </Project>

HwProj.CoursesService/HwProj.CoursesService.API/Services/CoursesService.cs

@@ -3,7 +3,6 @@
 using System.Linq;
 using System.Transactions;
 using System.Threading.Tasks;
-using HwProj.CoursesService.API.Events;
 using HwProj.CoursesService.API.Models;
 using HwProj.CoursesService.API.Repositories;
 using HwProj.CoursesService.API.Repositories.Groups;
@@ -14,6 +13,7 @@
 using HwProj.CoursesService.API.Domains;
 using HwProj.Models.CoursesService.DTO;
 using HwProj.Models.Roles;
+using HwProj.NotificationService.Events.CoursesService;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.EntityFrameworkCore.Internal;
 

HwProj.CoursesService/HwProj.CoursesService.API/Services/HomeworksService.cs

@@ -4,10 +4,10 @@
 using HwProj.CoursesService.API.Models;
 using HwProj.CoursesService.API.Repositories;
 using HwProj.EventBus.Client.Interfaces;
-using HwProj.CoursesService.API.Events;
 using HwProj.CoursesService.API.Domains;
 using HwProj.Models;
 using HwProj.Models.CoursesService.ViewModels;
+using HwProj.NotificationService.Events.CoursesService;
 
 namespace HwProj.CoursesService.API.Services
 {

HwProj.CoursesService/HwProj.CoursesService.API/Services/TasksService.cs

@@ -1,12 +1,12 @@
 using System;
 using System.Threading.Tasks;
-using HwProj.CoursesService.API.Events;
 using HwProj.CoursesService.API.Models;
 using HwProj.CoursesService.API.Repositories;
 using HwProj.EventBus.Client.Interfaces;
 using HwProj.CoursesService.API.Domains;
 using System.Linq;
 using HwProj.Models;
+using HwProj.NotificationService.Events.CoursesService;
 
 namespace HwProj.CoursesService.API.Services
 {

…PI/Events/LecturerAcceptToCourseEvent.cs …esService/LecturerAcceptToCourseEvent.csHwProj.CoursesService/HwProj.CoursesService.API/Events/LecturerAcceptToCourseEvent.cs renamed to HwProj.NotificationsService/HwProj.NotificationService.Events/CoursesService/LecturerAcceptToCourseEvent.cs HwProj.CoursesService/HwProj.CoursesService.API/Events/LecturerAcceptToCourseEvent.cs renamed to HwProj.NotificationsService/HwProj.NotificationService.Events/CoursesService/LecturerAcceptToCourseEvent.cs

@@ -1,6 +1,6 @@
 using HwProj.EventBus.Client;
 
-namespace HwProj.CoursesService.API.Events
+namespace HwProj.NotificationService.Events.CoursesService
 {
     public class LecturerAcceptToCourseEvent : Event
     {