Add gender endpoind from Idenitty api.

a-sharifov · Feb 7, 2024 · 5c81ec7 · 5c81ec7
1 parent 79ee950
commit 5c81ec7
Show file tree

Hide file tree

Showing 8 changed files with 34 additions and 7 deletions.
diff --git a/crs/Services/Email/Email.App/Configurations/MessageBusServiceInstaller.cs b/crs/Services/Email/Email.App/Configurations/MessageBusServiceInstaller.cs
@@ -2,12 +2,10 @@
 
 internal sealed class MessageBusServiceInstaller : IServiceInstaller
 {
-    public void Install(IServiceCollection services, IConfiguration configuration)
-    {
+    public void Install(IServiceCollection services, IConfiguration configuration) => 
         services.AddMassTransit(configure =>
         {
             configure.SetKebabCaseEndpointNameFormatter();
-            configure.AddConsumers(MessageBus.AssemblyReference.Assembly);
             configure.UsingRabbitMq((context, configurator) =>
             {
                 configurator.Host("rabbitmq", "/", hostConfigurator =>
@@ -19,7 +17,6 @@ public void Install(IServiceCollection services, IConfiguration configuration)
                 configurator.ConfigureEndpoints(context);
             });
 
-            configure.AddConsumers(App.AssemblyReference.Assembly);
+            configure.AddConsumers(MessageBus.AssemblyReference.Assembly);
         });
-    }
 }
diff --git a/crs/Services/Identity/Identity.App/Configurations/MessageBusServiceInstaller.cs b/crs/Services/Identity/Identity.App/Configurations/MessageBusServiceInstaller.cs
@@ -19,7 +19,7 @@ public void Install(IServiceCollection services, IConfiguration configuration)
                 configurator.ConfigureEndpoints(context);
             });
 
-            configure.AddConsumers(App.AssemblyReference.Assembly);
+            configure.AddConsumers(MessageBus.AssemblyReference.Assembly);
         });
 
         services.AddTransient<IMessageBus, EventBusRabitMQ>();

diff --git a/crs/Services/Identity/Identity.App/Identity.App.csproj b/crs/Services/Identity/Identity.App/Identity.App.csproj
@@ -51,6 +51,7 @@
 		<ProjectReference Include="..\Identity.Application\Identity.Application.csproj" />
 		<ProjectReference Include="..\Identity.Domain\Identity.Domain.csproj" />
 		<ProjectReference Include="..\Identity.Infrastructure\Identity.Infrastructure.csproj" />
+		<ProjectReference Include="..\Identity.MessageBus\Identity.MessageBus.csproj" />
 		<ProjectReference Include="..\Identity.Persistence\Identity.Persistence.csproj" />
 		<ProjectReference Include="..\Identity.Presentation\Identity.Presentation.csproj" />
 	</ItemGroup>

diff --git a/crs/Services/Identity/Identity.Application/Users/Queries/GetGenders/GetGendersQuery.cs b/crs/Services/Identity/Identity.Application/Users/Queries/GetGenders/GetGendersQuery.cs
@@ -0,0 +1,3 @@
+namespace Identity.Application.Users.Queries.GetGenders;
+
+public sealed record GetGendersQuery() : IQuery<GetGendersQueryResponse>;
diff --git a/...Services/Identity/Identity.Application/Users/Queries/GetGenders/GetGendersQueryHandler.cs b/...Services/Identity/Identity.Application/Users/Queries/GetGenders/GetGendersQueryHandler.cs
@@ -0,0 +1,12 @@
+
+namespace Identity.Application.Users.Queries.GetGenders;
+
+internal sealed class GetRolesQueryHandler : IQueryHandler<GetGendersQuery, GetGendersQueryResponse>
+{
+    public Task<Result<GetGendersQueryResponse>> Handle(GetGendersQuery request, CancellationToken cancellationToken)
+    {
+        var roles = Gender.GetNames();
+        var response = Result.Success(new GetGendersQueryResponse(roles));
+        return Task.FromResult(response);
+    }
+}
diff --git a/...ervices/Identity/Identity.Application/Users/Queries/GetGenders/GetGendersQueryResponse.cs b/...ervices/Identity/Identity.Application/Users/Queries/GetGenders/GetGendersQueryResponse.cs
@@ -0,0 +1,3 @@
+namespace Identity.Application.Users.Queries.GetGenders;
+
+public sealed record GetGendersQueryResponse(IEnumerable<string> Genders)
diff --git a/crs/Services/Identity/Identity.Application/Users/Queries/GetRoles/GetRolesQuery.cs b/crs/Services/Identity/Identity.Application/Users/Queries/GetRoles/GetRolesQuery.cs
@@ -1,3 +1,3 @@
 namespace Identity.Application.Users.Queries.GetRoles;
 
-public sealed class GetRolesQuery() : IQuery<GetRolesQueryResponse>;
+public sealed record GetRolesQuery() : IQuery<GetRolesQueryResponse>;
diff --git a/crs/Services/Identity/Identity.Presentation/V1/Controllers/UserController.cs b/crs/Services/Identity/Identity.Presentation/V1/Controllers/UserController.cs
@@ -3,6 +3,7 @@
 using Identity.Application.Users.Commands.Register;
 using Identity.Application.Users.Commands.RetryConfirmEmailSend;
 using Identity.Application.Users.Commands.UpdateRefreshToken;
+using Identity.Application.Users.Queries.GetGenders;
 using Identity.Application.Users.Queries.GetRoles;
 using Identity.Presentation.V1.Models;
 
@@ -89,4 +90,14 @@ public async Task<IActionResult> GetRoles()
         return result.IsSuccess ? Ok(result.Value)
             : HandleFailure(result);
     }
+
+    [HttpGet("genders")]
+    public async Task<IActionResult> GetGenders()
+    {
+        var query = new GetGendersQuery();
+
+        var result = await _sender.Send(query);
+        return result.IsSuccess ? Ok(result.Value)
+            : HandleFailure(result);
+    }
 }