Get Account Info endpoint

sagustavo · sagustavo · commit 6c68c0b7c748 · 2025-12-05T14:03:55.000-03:00
diff --git a/Directory.Packages.props b/Directory.Packages.props
@@ -20,6 +20,7 @@
     <PackageVersion Include="MassTransit.EntityFrameworkCore" Version="8.0.11" />
     <PackageVersion Include="MassTransit.RabbitMQ" Version="8.0.11" />
     <PackageVersion Include="MediatR" Version="13.1.0" />
+    <PackageVersion Include="Microsoft.AspNetCore.Authentication.JwtBearer" Version="8.0.22" />
     <PackageVersion Include="Microsoft.AspNetCore.Identity" Version="2.3.1" />
     <PackageVersion Include="Microsoft.AspNetCore.Identity.EntityFrameworkCore" Version="8.0.22" />
     <PackageVersion Include="Microsoft.AspNetCore.OpenApi" Version="8.0.21" />
diff --git a/src/Account/Business/UseCases/GetAccountInfoUseCase.cs b/src/Account/Business/UseCases/GetAccountInfoUseCase.cs
@@ -0,0 +1,47 @@
+using Kairos.Account.Infra;
+using Kairos.Shared.Contracts;
+using Kairos.Shared.Contracts.Account;
+using Kairos.Shared.Contracts.Account.GetAccountInfo;
+using MediatR;
+using Microsoft.Extensions.Logging;
+
+namespace Kairos.Account.Business.UseCases;
+
+internal sealed class GetAccountInfoUseCase(
+    ILogger<GetAccountInfoUseCase> logger,
+    AccountContext db) : IRequestHandler<GetAccountInfoQuery, Output<AccountInfo>>
+{
+    public async Task<Output<AccountInfo>> Handle(GetAccountInfoQuery input, CancellationToken cancellationToken)
+    {
+        try
+        {
+            var account = await db.Investors.FindAsync(input.Id, cancellationToken);
+
+            if (account is null)
+            {
+                logger.LogWarning(
+                    "Attempted to access non-existent account with ID {AccountId}", 
+                    input.Id);
+                return Output<AccountInfo>.PolicyViolation(["Conta não encontrada."]);
+            }
+
+            return Output<AccountInfo>.Ok(new AccountInfo(
+                account.Id,
+                account.Name,
+                account.Birthdate,
+                account.Gender,
+                account.PhoneNumber ?? string.Empty,
+                account.Document,
+                account.Email!,
+                Address: string.Empty
+            ));
+        }
+        catch (Exception ex)
+        {
+            logger.LogError(ex, "An unexpected error occurred.");
+            return Output<AccountInfo>.UnexpectedError([
+                "Um erro inesperado ocorreu...", 
+                ex.Message]);
+        }
+    }
+}
diff --git a/src/Account/DependencyInjection.cs b/src/Account/DependencyInjection.cs
@@ -1,14 +1,18 @@
 ﻿using System.Reflection;
+using System.Text;
 using Kairos.Account.Configuration;
 using Kairos.Account.Domain;
 using Kairos.Account.Infra;
 using Kairos.Account.Infra.Consumers;
 using Kairos.Shared.Contracts.Account;
 using MassTransit;
+using Microsoft.AspNetCore.Authentication.JwtBearer;
 using Microsoft.AspNetCore.Identity;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Options;
+using Microsoft.IdentityModel.Tokens;
 
 namespace Kairos.Account;
 
@@ -21,6 +25,7 @@ public static IServiceCollection AddAccount(
         services.Configure<Settings>(config);
 
         return services
+            .AddAuth()
             .AddIdentity(config)
             .AddMediatR(cfg =>
             {
@@ -89,4 +94,45 @@ static IServiceCollection AddIdentity(
 
         return services;
     }
+
+    static IServiceCollection AddAuth(this IServiceCollection services)
+    {
+        var jwt = services
+            .BuildServiceProvider()
+            .GetRequiredService<IOptions<Settings>>()
+            .Value.Jwt;
+
+        services
+            .AddAuthentication(o =>
+            {
+                o.DefaultAuthenticateScheme = JwtBearerDefaults.AuthenticationScheme;
+                o.DefaultChallengeScheme = JwtBearerDefaults.AuthenticationScheme;
+            })
+            .AddJwtBearer(o =>
+            {
+                o.TokenValidationParameters = new TokenValidationParameters
+                {
+                    ValidateIssuer = true,
+                    ValidateAudience = true,
+                    ValidateLifetime = true,
+                    ValidateIssuerSigningKey = true,
+                    ValidIssuer = jwt.Issuer,
+                    ValidAudience = jwt.Audience,
+                    IssuerSigningKey = new SymmetricSecurityKey(Encoding.UTF8.GetBytes(jwt.Secret))
+                };
+
+                o.Events = new JwtBearerEvents
+                {
+                    OnMessageReceived = context =>
+                    {
+                        context.Token = context.Request.Cookies[jwt.CookieName];
+                        return Task.CompletedTask;
+                    }
+                };
+            });
+
+        services.AddAuthorization();
+
+        return services;
+    }
 }
diff --git a/src/Account/Domain/Investor.cs b/src/Account/Domain/Investor.cs
@@ -12,7 +12,7 @@ internal sealed class Investor : KairosAccount
     public string Name { get; private set; }
     public string Document { get; private set; }
     public DateTime Birthdate { get; private set; }
-    public Gender Gender { get; private set; }
+    public Gender Gender { get; }
     public PersonType Type { get; private set; }
 
     Investor(
diff --git a/src/Account/Infra/Configuration/JwtOptions.cs b/src/Account/Infra/Configuration/JwtOptions.cs
diff --git a/src/Account/Infra/Configuration/Settings.cs b/src/Account/Infra/Configuration/Settings.cs
diff --git a/src/Account/Kairos.Account.csproj b/src/Account/Kairos.Account.csproj
@@ -11,6 +11,7 @@
     <InternalsVisibleTo Include="DynamicProxyGenAssembly2" />
   </ItemGroup>
   <ItemGroup>
+    <PackageReference Include="Microsoft.AspNetCore.Authentication.JwtBearer" />
     <PackageReference Include="Microsoft.AspNetCore.Identity" />
     <PackageReference Include="Microsoft.AspNetCore.Identity.EntityFrameworkCore" />
   </ItemGroup>
diff --git a/src/Gateway/DependencyInjection.cs b/src/Gateway/DependencyInjection.cs
@@ -20,17 +20,14 @@ public static IServiceCollection AddGateway(
         IConfiguration configuration)
     {
         services
-            .AddAuthorization()
             .AddHealthChecksUI(options =>
             {
                 options.SetEvaluationTimeInSeconds(30);
                 options.AddHealthCheckEndpoint("Kairos", "/health/ready");
             })
             .AddInMemoryStorage();
 
-        services
-            .AddCarter()
-            .AddAuthentication();
+        services.AddCarter();
 
         return services
             .AddMapper()
diff --git a/src/Gateway/Filters/ResponseFormatter.cs b/src/Gateway/Filters/ResponseFormatter.cs
@@ -29,6 +29,7 @@ internal sealed class ResponseFormatter(ILogger<ResponseFormatter> logger) : IEn
                 OutputStatus.InvalidInput => StatusCodes.Status400BadRequest,
                 OutputStatus.NotFound => StatusCodes.Status404NotFound,
                 OutputStatus.PolicyViolation => StatusCodes.Status422UnprocessableEntity,
+                OutputStatus.CredentialsRequired => StatusCodes.Status401Unauthorized,
                 _ => StatusCodes.Status500InternalServerError,
             };
 
diff --git a/src/Gateway/Modules/Account/AccountModule.cs b/src/Gateway/Modules/Account/AccountModule.cs
@@ -1,8 +1,11 @@
+using System.Security.Claims;
 using Carter;
 using Kairos.Account.Configuration;
+using Kairos.Gateway.Filters;
 using Kairos.Gateway.Modules.Account.Request;
 using Kairos.Shared.Contracts;
 using Kairos.Shared.Contracts.Account;
+using Kairos.Shared.Contracts.Account.GetAccountInfo;
 using MediatR;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Extensions.Options;
@@ -120,5 +123,32 @@ public override void AddRoutes(IEndpointRouteBuilder app)
                 e.Responses["500"].Description = "An unexpected server error occurred.";
                 return e;
             });
+
+        app.MapGet("/me", 
+            async (HttpContext ctx) =>
+            {
+                var accountIdValue = ctx.User.FindFirstValue(ClaimTypes.NameIdentifier);
+
+                if (long.TryParse(accountIdValue, out var accountId) is false)
+                {
+                    return Output.CredentialsRequired(["Acesse sua conta para visualizar os dados cadastrais."]);
+                }
+                
+                var output = await _mediator.Send(new GetAccountInfoQuery(accountId));
+
+                return output;
+            })
+            .RequireAuthorization()
+            .WithSummary("Get the authenticated account's data")
+            .Produces<Response<AccountInfo>>(StatusCodes.Status200OK)
+            .Produces<Response>(StatusCodes.Status401Unauthorized)
+            .Produces<Response>(StatusCodes.Status500InternalServerError)
+            .WithOpenApi(e =>
+            {
+                e.Responses["200"].Description = "Returns the account details for the authenticated user.";
+                e.Responses["401"].Description = "Unauthorized if the auth cookie is missing or invalid.";
+                e.Responses["500"].Description = "An unexpected server error occurred.";
+                return e;
+            });
     }
 }
diff --git a/src/MarketData/Infra/Configuration/BrapiHealthCheck.cs b/src/MarketData/Infra/Configuration/BrapiHealthCheck.cs
diff --git a/src/MarketData/Infra/Configuration/Settings.cs b/src/MarketData/Infra/Configuration/Settings.cs
diff --git a/src/Shared/Contracts/Account/Gender.cs b/src/Shared/Contracts/Account/Gender.cs
diff --git a/src/Shared/Contracts/Account/GetAccountInfo/AccountInfo.cs b/src/Shared/Contracts/Account/GetAccountInfo/AccountInfo.cs
@@ -0,0 +1,14 @@
+using Kairos.Account.Domain.Enum;
+
+namespace Kairos.Shared.Contracts.Account.GetAccountInfo;
+
+public sealed record AccountInfo(
+    long Id,
+    string Name,
+    DateTime Birthdate,
+    Gender Gender,
+    string PhoneNumber,
+    string Document,
+    string Email,
+    string Address
+);
diff --git a/src/Shared/Contracts/Account/GetAccountInfo/GetAccountInfoQuery.cs b/src/Shared/Contracts/Account/GetAccountInfo/GetAccountInfoQuery.cs
@@ -0,0 +1,11 @@
+using Kairos.Shared.Abstractions;
+using Kairos.Shared.Contracts.Account.GetAccountInfo;
+
+namespace Kairos.Shared.Contracts.Account;
+
+public sealed record GetAccountInfoQuery(
+    long Id,
+    Guid CorrelationId) : IQuery<AccountInfo>
+{
+    public GetAccountInfoQuery(long id) : this(id, Guid.NewGuid()) { }
+}
diff --git a/src/Shared/Contracts/Account/PersonType.cs b/src/Shared/Contracts/Account/PersonType.cs
diff --git a/src/Shared/Contracts/Output.cs b/src/Shared/Contracts/Output.cs
@@ -45,6 +45,9 @@ public static Output Created(IEnumerable<string>? messages = null) =>
     public static Output UnexpectedError(IEnumerable<string> messages) =>
         new(OutputStatus.UnexpectedError, messages);
 
+    public static Output CredentialsRequired(IEnumerable<string> messages) =>
+        new(OutputStatus.CredentialsRequired, messages);
+
     public static Output PolicyViolation(IEnumerable<string> messages) =>
         new(OutputStatus.PolicyViolation, messages);
 
diff --git a/src/Shared/Contracts/OutputStatus.cs b/src/Shared/Contracts/OutputStatus.cs
@@ -39,5 +39,10 @@ public enum OutputStatus
     /// Unexpected internal error
     /// </summary>
     UnexpectedError,
+
+    /// <summary>
+    /// Unauthorized
+    /// </summary>
+    CredentialsRequired,
     #endregion
 }
