using Mediator; using Musify.Application.Users.Commands; using Musify.Application.Users.Queries; using WebApi.DataTransferObjects.Users; using WebApi.Extensions; using WebApi.Filters; namespace WebApi.Endpoints; public static class UserEndpoints { public static IEndpointRouteBuilder MapUserEndpoints(this IEndpointRouteBuilder app) { var group = app.MapGroup("/users") .WithTags("Users") .AddEndpointFilter(); group.MapGet("/", GetUsers) .WithName("GetUsers") .WithSummary("Get paginated users."); group.MapGet("/{id}", GetUserById) .WithName("GetUserById") .WithSummary("Get a user by ID."); group.MapGet("/keycloak/{id}", GetUserByKeycloak) .WithName("GetUserByKeycloak") .WithSummary("Get a user by Keycloak ID."); group.MapPost("/", CreateUser) .WithName("CreateUser") .WithSummary("Create a new user."); return app; } private static async Task GetUsers( IMediator mediator, CancellationToken cancellationToken, int pageNumber = 1, int pageSize = 10, string? usernameSearch = null) { var result = await mediator.Send(new GetUsersQuery(pageNumber, pageSize, usernameSearch), cancellationToken); return result.ToHttpResult(); } private static async Task GetUserById( IMediator mediator, Guid id, CancellationToken cancellationToken) { var result = await mediator.Send(new GetUserByIdQuery(id), cancellationToken); return result.ToHttpResult(); } private static async Task GetUserByKeycloak( IMediator mediator, Guid id, CancellationToken cancellationToken) { var result = await mediator.Send(new GetUserByKeycloakQuery(id), cancellationToken); return result.ToHttpResult(); } private static async Task CreateUser( IMediator mediator, CreateUserRequest request, CancellationToken cancellationToken) { var result = await mediator.Send( new CreateUserCommand(request.Id, request.Name, request.FirstName, request.SecondName), cancellationToken); if (!result.IsSuccess) return result.ToHttpResult(); return Results.Created($"/users/{result.Value.Id}", result.Value); } }