feat: created posts

Living.Application/Living.Application.csproj

@@ -7,6 +7,7 @@
 	</PropertyGroup>
 
 	<ItemGroup>
+		<PackageReference Include="MassTransit" Version="8.2.5" />
 		<PackageReference Include="MediatR" Version="12.4.0" />
 		<PackageReference Include="Meziantou.Analyzer" Version="2.0.163">
 		  <PrivateAssets>all</PrivateAssets>
@@ -17,7 +18,7 @@
 		  <PrivateAssets>all</PrivateAssets>
 		  <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
 		</PackageReference>
-		<PackageReference Include="System.IdentityModel.Tokens.Jwt" Version="8.0.1" />
+		<PackageReference Include="System.IdentityModel.Tokens.Jwt" Version="8.0.2" />
 	</ItemGroup>
 
 	<ItemGroup>

Living.Application/UseCases/Users/Register/RegisterUserHandler.cs

@@ -1,10 +1,12 @@
 using Living.Domain.Features.Users;
 using Living.Domain.Features.Users.Constants;
+using Living.Domain.Features.Users.Events;
 using Living.Shared.Extensions;
+using MassTransit;
 using Microsoft.AspNetCore.Identity;
 
 namespace Living.Application.UseCases.Users.Register;
-public class RegisterUserHandler(UserManager<User> userManager, IUnitOfWork unitOfWork)
+public class RegisterUserHandler(UserManager<User> userManager, IUnitOfWork unitOfWork, IPublishEndpoint publish, IMessageScheduler messageScheduler)
     : Handler(unitOfWork), IRequestHandler<RegisterUserCommand, BaseResponse<Guid>>
 {
     public async Task<BaseResponse<Guid>> Handle(RegisterUserCommand request, CancellationToken cancellationToken)
@@ -22,6 +24,9 @@ public async Task<BaseResponse<Guid>> Handle(RegisterUserCommand request, Cancel
         if (!result.Succeeded)
             return new(result.Errors);
 
+        await publish.Publish(new UserCreatedEvent(user.Id), cancellationToken);
+        await messageScheduler.SchedulePublish(DateTime.Now.AddSeconds(10), new UserCreatedEvent(user.Id));
+
         return new(user.Id);
     }
-}
+}

Living.Domain/Base/Paginated.cs

@@ -0,0 +1,11 @@
+namespace Living.Domain.Base;
+public class Paginated<T>(IEnumerable<T> items, int pageIndex, int pageSize, long totalCount)
+{
+    public IEnumerable<T> Items { get; } = items;
+    public int PageIndex { get; } = pageIndex;
+    public int PageSize { get; } = pageSize;
+    public long TotalCount { get; } = totalCount;
+    public int TotalPages => (int)Math.Ceiling(TotalCount / (double)PageSize);
+    public bool HasPreviousPage => PageIndex > 1;
+    public bool HasNextPage => PageIndex < TotalPages;
+}

Living.Domain/Features/Posts/Enums/PostAccess.cs

@@ -4,6 +4,5 @@ public enum PostAccess
 {
     Public,
     Followers,
-    Group,
     Private
 }

Living.Domain/Features/Posts/Events/PostScheduledEvent.cs

@@ -0,0 +1,2 @@
+namespace Living.Domain.Features.Posts.Events;
+public record PostScheduledEvent(Guid PostId);

Living.Domain/Features/Posts/Post.cs

@@ -1,5 +1,4 @@
-using Living.Domain.Features.Groups;
-using Living.Domain.Features.Posts.Enums;
+using Living.Domain.Features.Posts.Enums;
 
 namespace Living.Domain.Features.Posts;
 public class Post : IEntity, ITimestamps, ISoftDelete
@@ -9,7 +8,6 @@ public class Post : IEntity, ITimestamps, ISoftDelete
     public required Guid AuthorId { get; set; }
     public required PostAccess Access { get; set; }
     public required PostType Type { get; set; }
-    public Guid? GroupId { get; set; }
     public Guid? PostParentId { get; set; }
     public Guid? PostChildId { get; set; }
 
@@ -24,7 +22,6 @@ public class Post : IEntity, ITimestamps, ISoftDelete
     public Post? PostChild { get; init; }
     public List<Post> PostsChildrens { get; init; } = [];
     public User Author { get; init; }
-    public Group? Group { get; init; }
     public List<PostLike> PostLikes { get; init; } = [];
 
     public void AddLike(Guid userId)

Living.Domain/Features/Users/Events/UserCreatedEvent.cs

@@ -0,0 +1,2 @@
+namespace Living.Domain.Features.Users.Events;
+public record UserCreatedEvent(Guid UserId);

Living.Domain/Features/Users/User.cs

@@ -1,5 +1,4 @@
-using Living.Domain.Features.Groups;
-using Living.Domain.Features.Posts;
+using Living.Domain.Features.Posts;
 using Living.Domain.Features.Roles;
 using Living.Domain.Features.Users.Constants;
 using Microsoft.AspNetCore.Identity;
@@ -26,9 +25,6 @@ public class User : IdentityUser<Guid>, IEntity, ITimestamps, IValidit
     public List<UserFollow> UsersFollowers { get; set; } = [];
     public List<UserFollow> UsersFollowing { get; set; } = [];
 
-    public List<GroupUser> GroupsUser { get; set; } = [];
-    public List<Group> GroupsOwned { get; set; } = [];
-
     public List<UserRole> UserRoles { get; set; } = [];
     public List<UserClaim> UserClaims { get; set; } = [];
     public List<UserLogin> UserLogins { get; set; } = [];

Living.Infraestructure/Configuration/PostConfiguration.cs

@@ -29,9 +29,6 @@ public void Configure(EntityTypeBuilder<Post> builder)
         builder.Property(x => x.PostChildId)
             .IsRequired(false);
 
-        builder.Property(x => x.GroupId)
-            .IsRequired(false);
-
         builder.HasOne(x => x.Author)
             .WithMany(x => x.Posts)
             .HasForeignKey(x => x.AuthorId);
@@ -40,10 +37,6 @@ public void Configure(EntityTypeBuilder<Post> builder)
             .WithOne(x => x.Post)
             .HasForeignKey(x => x.PostId);
 
-        builder.HasOne(x => x.Group)
-            .WithMany(x => x.Posts)
-            .HasForeignKey(x => x.GroupId);
-
         builder.HasOne(x => x.PostChild)
             .WithMany(x => x.PostsParent)
             .HasForeignKey(x => x.PostChildId);

Living.Infraestructure/Configuration/UserConfiguration.cs

@@ -37,14 +37,6 @@ public void Configure(EntityTypeBuilder<User> builder)
             .WithOne(e => e.Following)
             .HasForeignKey(e => e.FollowingId);
 
-        builder.HasMany(e => e.GroupsUser)
-            .WithOne(e => e.User)
-            .HasForeignKey(e => e.UserId);
-
-        builder.HasMany(e => e.GroupsOwned)
-            .WithOne(e => e.Owner)
-            .HasForeignKey(e => e.OwnerId);
-
         builder.HasMany(e => e.UserClaims)
             .WithOne(p => p.User)
             .HasForeignKey(e => e.UserId);

Living.Infraestructure/Context/DatabaseContext.cs

@@ -1,5 +1,4 @@
-using Living.Domain.Features.Groups;
-using Living.Domain.Features.Posts;
+using Living.Domain.Features.Posts;
 using Living.Domain.Features.Roles;
 using Living.Domain.Features.Users;
 using Microsoft.AspNetCore.Identity.EntityFrameworkCore;
@@ -13,8 +12,6 @@ public class DatabaseContext(DbContextOptions options)
     public DbSet<UserFollow> UserFollows => Set<UserFollow>();
     public DbSet<Post> Posts => Set<Post>();
     public DbSet<PostLike> PostLikes => Set<PostLike>();
-    public DbSet<Group> Groups => Set<Group>();
-    public DbSet<GroupUser> GroupUsers => Set<GroupUser>();
 
     protected override void OnModelCreating(ModelBuilder builder)
     {

Living.Infraestructure/Extensions/DependencyInjectionExtensions.cs

@@ -0,0 +1,83 @@
+using Living.Domain.Features.Posts.Interface;
+using Living.Domain.Features.Users.Interfaces;
+using Living.Domain.Services;
+using Living.Infraestructure.Context;
+using Living.Infraestructure.Context.Interceptors;
+using Living.Infraestructure.Repositories;
+using Living.Infraestructure.Services;
+using Living.Infraestructure.Settings;
+using Living.Infraestructure.UnitOfWorks;
+using Living.Shared.Extensions;
+using Living.Shared.Handlers;
+using MassTransit;
+using Microsoft.Extensions.DependencyInjection;
+
+namespace Living.Infraestructure.Extensions;
+
+public static class DependencyInjectionExtensions
+{
+    public static void AddDatabase(this IServiceCollection services)
+    {
+        var connectionStrings = services.GetOptions<ConnectionStrings>();
+
+        services.AddDbContext<DatabaseContext>(options =>
+        {
+            options.AddInterceptors(new SavingChangesInterceptor());
+            options.UseNpgsql(connectionStrings.PostgresConnection);
+        });
+    }
+
+    public static void AddMessaging(this IServiceCollection services)
+    {
+        services.AddMessaging((e) => { });
+    }
+
+    public static void AddMessaging(this IServiceCollection services, Action<IBusRegistrationConfigurator> action)
+    {
+        var connectionStrings = services.GetOptions<ConnectionStrings>();
+
+        services.AddMassTransit(x =>
+        {
+            action(x);
+
+            x.ConfigureTeste(connectionStrings.RabbitMqConnection);
+        });
+    }
+
+    public static void ConfigureTeste(this IBusRegistrationConfigurator busRegistrationConfigurator, string connectionString)
+    {
+        busRegistrationConfigurator.AddDelayedMessageScheduler();
+
+
+
+        busRegistrationConfigurator.UsingRabbitMq((context, cfg) =>
+        {
+            cfg.Host(new Uri(connectionString), "Living");
+
+            cfg.UseDelayedMessageScheduler();
+
+            cfg.ConfigureEndpoints(context);
+
+            cfg.UseMessageRetry(retry => { retry.Interval(3, TimeSpan.FromSeconds(5)); });
+        });
+    }
+
+    public static void AddApplication(this IServiceCollection services)
+    {
+        services.AddScoped<IUnitOfWork, UnitOfWork>();
+
+        services.AddRepositories();
+        services.AddServices();
+    }
+
+    private static void AddRepositories(this IServiceCollection services)
+    {
+        services.AddScoped<IUserRepository, UserRepository>();
+        services.AddScoped<IPostRepository, PostRepository>();
+    }
+
+    private static void AddServices(this IServiceCollection services)
+    {
+        services.AddScoped<ITokenService, TokenService>();
+    }
+}

Living.Infraestructure/Living.Infraestructure.csproj

@@ -9,6 +9,8 @@
 	<ItemGroup>
 		<PackageReference Include="FluentMigrator" Version="5.2.0" />
 		<PackageReference Include="FluentMigrator.Runner.Postgres" Version="5.2.0" />
+		<PackageReference Include="MassTransit" Version="8.2.5" />
+		<PackageReference Include="MassTransit.RabbitMQ" Version="8.2.5" />
 		<PackageReference Include="Meziantou.Analyzer" Version="2.0.163">
 		  <PrivateAssets>all</PrivateAssets>
 		  <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
@@ -18,13 +20,13 @@
 		  <PrivateAssets>all</PrivateAssets>
 		  <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
 		</PackageReference>
-		<PackageReference Include="Microsoft.IdentityModel.Tokens" Version="8.0.1" />
+		<PackageReference Include="Microsoft.IdentityModel.Tokens" Version="8.0.2" />
 		<PackageReference Include="Npgsql.EntityFrameworkCore.PostgreSQL" Version="8.0.4" />
 		<PackageReference Include="SonarAnalyzer.CSharp" Version="9.32.0.97167">
 		  <PrivateAssets>all</PrivateAssets>
 		  <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
 		</PackageReference>
-		<PackageReference Include="System.IdentityModel.Tokens.Jwt" Version="8.0.1" />
+		<PackageReference Include="System.IdentityModel.Tokens.Jwt" Version="8.0.2" />
 	</ItemGroup>
 
 	<ItemGroup>

Living.Infraestructure/Settings/ConnectionStrings.cs

@@ -5,4 +5,7 @@ public class ConnectionStrings
 {
     [Required]
     public string PostgresConnection { get; set; }
+
+    [Required]
+    public string RabbitMqConnection { get; set; }
 }

Living.Shared/Extensions/IServiceCollectionExtensions.cs

@@ -0,0 +1,27 @@
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Options;
+using IServiceCollection = Microsoft.Extensions.DependencyInjection.IServiceCollection;
+using IServiceProvider = Microsoft.Extensions.DependencyInjection.IServiceCollection;
+
+namespace Living.Shared.Extensions;
+public static class IServiceCollectionExtensions
+{
+    public static TOptions GetOptions<TOptions>(this IServiceProvider services)
+        where TOptions : class
+    {
+        using var serviceProvider = services.BuildServiceProvider();
+        return serviceProvider.GetRequiredService<IOptions<TOptions>>().Value;
+    }
+
+    public static IServiceCollection AddOptionsConfiguration<T>(this IServiceCollection services, IConfiguration configuration)
+        where T : class
+    {
+        services.AddOptions<T>()
+            .Bind(configuration.GetSection(typeof(T).Name))
+            .ValidateDataAnnotations()
+            .ValidateOnStart();
+
+        return services;
+    }
+}

Living.Shared/Living.Shared.csproj

@@ -11,6 +11,11 @@
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
     </PackageReference>
+    <PackageReference Include="Microsoft.Extensions.Configuration" Version="8.0.0" />
+    <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="8.0.0" />
+    <PackageReference Include="Microsoft.Extensions.Options" Version="8.0.2" />
+    <PackageReference Include="Microsoft.Extensions.Options.ConfigurationExtensions" Version="8.0.0" />
+    <PackageReference Include="Microsoft.Extensions.Options.DataAnnotations" Version="8.0.0" />
     <PackageReference Include="SonarAnalyzer.CSharp" Version="9.32.0.97167">
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>