using Asp.Versioning; using Core.Cerberos.Adapters; using Core.Cerberos.Adapters.Attributes; using Core.Cerberos.Adapters.Common.Constants; using Core.Cerberos.External.Clients.Cerberos.Requests.Permissions; using Lib.Architecture.BuildingBlocks; using LSA.Dashboard.External.Clients.Dashboard; using Microsoft.AspNetCore.Authorization; using Microsoft.AspNetCore.Mvc; using Microsoft.Graph; using System.Text.Json; namespace Core.Cerberos.BFF.Api.Controllers { /// /// Handles all requests for permission authentication. /// [ApiVersion("1.0")] [Route("api/v{version:apiVersion}/[controller]")] [Consumes("application/json")] [Produces("application/json")] [ApiController] [Authorize(AuthenticationSchemes = Schemes.HeathScheme)] public class PermissionController(ICerberosServiceClient cerberosServiceClient, ILogger logger) : BaseController(logger) { /// /// Gets all the permissions. /// [HttpGet("GetAll")] [ProducesResponseType(StatusCodes.Status200OK)] [ProducesResponseType(StatusCodes.Status400BadRequest)] [ProducesResponseType(StatusCodes.Status401Unauthorized)] [ProducesResponseType(typeof(Notification), StatusCodes.Status412PreconditionFailed)] [ProducesResponseType(typeof(Notification), StatusCodes.Status422UnprocessableEntity)] [ProducesResponseType(StatusCodes.Status500InternalServerError)] [Permission("PermissionManagement.Read, RoleManagement.Read")] public async Task GetAllPermissionsService(CancellationToken cancellationToken) { try { logger.LogInformation($"{nameof(GetAllPermissionsService)} - Request received - Payload: "); return await Handle(() => cerberosServiceClient.GetAllPermissionsService(new GetAllPermissionsRequest { }, cancellationToken)).ConfigureAwait(false); } catch (Exception ex) { logger.LogError($"{nameof(GetAllPermissionsService)} - An Error Occurred- {ex.Message} - {ex.InnerException} - {ex.StackTrace} - with payload"); throw; } } /// /// Gets all the permissions by permission identifiers. /// /// The request containing the list of permission identifiers. /// Cancellation token for the asynchronous operation. /// The representing the result of the service call. /// The permissions found. /// No content if no permissions are found. /// Bad request if the permission identifiers are missing or invalid. /// Unauthorized if the user is not authenticated. /// Internal server error if an unexpected error occurs. [HttpPost("GetAllByList")] [ProducesResponseType(typeof(IEnumerable), StatusCodes.Status200OK)] [ProducesResponseType(StatusCodes.Status204NoContent)] [ProducesResponseType(StatusCodes.Status400BadRequest)] [ProducesResponseType(StatusCodes.Status401Unauthorized)] [ProducesResponseType(StatusCodes.Status500InternalServerError)] [Permission("PermissionManagement.Read")] public async Task GetAllPermissionsByListAsync([FromBody] GetAllPermissionsByListRequest request, CancellationToken cancellationToken) { try { logger.LogInformation($"{nameof(GetAllPermissionsByListAsync)} - Request received - Payload: {request}"); if (request == null || request.Permissions == null || !request.Permissions.Any()) { return BadRequest("Permission identifiers are required."); } return await Handle(() => cerberosServiceClient.GetAllPermissionsByListService(request, cancellationToken)).ConfigureAwait(false); } catch (Exception ex) { logger.LogError(ex, $"{nameof(GetAllPermissionsByListAsync)} - An error occurred - {ex.Message} - {ex.InnerException} - {ex.StackTrace} - with payload: {request}"); return StatusCode(StatusCodes.Status500InternalServerError, "Internal server error"); } } /// /// Creates a new permission. /// [HttpPost("Create")] [ProducesResponseType(StatusCodes.Status200OK)] [ProducesResponseType(StatusCodes.Status400BadRequest)] [ProducesResponseType(StatusCodes.Status401Unauthorized)] [ProducesResponseType(typeof(Notification), StatusCodes.Status412PreconditionFailed)] [ProducesResponseType(typeof(Notification), StatusCodes.Status422UnprocessableEntity)] [ProducesResponseType(StatusCodes.Status500InternalServerError)] [Permission("PermissionManagement.Write")] public async Task CreatePermissionService(CreatePermissionRequest newPermission, CancellationToken cancellationToken) { try { logger.LogInformation($"{nameof(CreatePermissionService)} - Request received - Payload: {JsonSerializer.Serialize(newPermission)}"); if (newPermission == null) return BadRequest("Invalid permission object"); if (string.IsNullOrEmpty(newPermission.Name)) return BadRequest("Invalid permission name"); if (string.IsNullOrEmpty(newPermission.Description)) return BadRequest("Invalid permission description"); return await Handle(() => cerberosServiceClient.CreatePermissionService(newPermission, cancellationToken)).ConfigureAwait(false); } catch (Exception ex) { logger.LogError($"{nameof(CreatePermissionService)} - An Error Occurred- {ex.Message} - {ex.InnerException} - {ex.StackTrace} - with payload {JsonSerializer.Serialize(newPermission)}"); throw; } } /// /// Gets the permission by identifier. /// [HttpPost("GetById")] [ProducesResponseType(StatusCodes.Status200OK)] [ProducesResponseType(StatusCodes.Status400BadRequest)] [ProducesResponseType(StatusCodes.Status401Unauthorized)] [ProducesResponseType(typeof(Notification), StatusCodes.Status412PreconditionFailed)] [ProducesResponseType(typeof(Notification), StatusCodes.Status422UnprocessableEntity)] [ProducesResponseType(StatusCodes.Status500InternalServerError)] [Permission("PermissionManagement.Read")] public async Task GetPermissionByIdService(GetPermissionRequest request, CancellationToken cancellationToken) { try { logger.LogInformation($"{nameof(GetPermissionByIdService)} - Request received - Payload: {JsonSerializer.Serialize(request)}"); if (string.IsNullOrEmpty(request.Id)) return BadRequest("Invalid permission identifier"); return await Handle(() => cerberosServiceClient.GetPermissionByIdService(request, cancellationToken)).ConfigureAwait(false); } catch (Exception ex) { logger.LogError($"{nameof(GetPermissionByIdService)} - An Error Occurred- {ex.Message} - {ex.InnerException} - {ex.StackTrace} - with payload {JsonSerializer.Serialize(request)}"); throw; } } /// /// Updates a full permission by identifier. /// [HttpPut("Update")] [ProducesResponseType(StatusCodes.Status200OK)] [ProducesResponseType(StatusCodes.Status400BadRequest)] [ProducesResponseType(StatusCodes.Status401Unauthorized)] [ProducesResponseType(typeof(Notification), StatusCodes.Status412PreconditionFailed)] [ProducesResponseType(typeof(Notification), StatusCodes.Status422UnprocessableEntity)] [ProducesResponseType(StatusCodes.Status500InternalServerError)] [Permission("PermissionManagement.Write")] public async Task UpdatePermissionService(UpdatePermissionRequest newPermission, CancellationToken cancellationToken) { try { logger.LogInformation($"{nameof(UpdatePermissionService)} - Request received - Payload: {JsonSerializer.Serialize(newPermission)}"); if (newPermission == null) return BadRequest("Invalid permission object"); if (string.IsNullOrEmpty(newPermission.Name)) return BadRequest("Invalid permission name"); if (string.IsNullOrEmpty(newPermission.Description)) return BadRequest("Invalid permission description"); return await Handle(() => cerberosServiceClient.UpdatePermissionService(newPermission, cancellationToken)).ConfigureAwait(false); } catch (Exception ex) { logger.LogError($"{nameof(UpdatePermissionService)} - An Error Occurred- {ex.Message} - {ex.InnerException} - {ex.StackTrace} - with payload {JsonSerializer.Serialize(newPermission)}"); throw; } } /// /// Changes the status of the permission. /// [HttpPatch] [Route("ChangeStatus")] [ProducesResponseType(StatusCodes.Status200OK)] [ProducesResponseType(StatusCodes.Status204NoContent)] [ProducesResponseType(StatusCodes.Status400BadRequest)] [ProducesResponseType(StatusCodes.Status401Unauthorized)] [ProducesResponseType(typeof(Notification), StatusCodes.Status412PreconditionFailed)] [ProducesResponseType(typeof(Notification), StatusCodes.Status422UnprocessableEntity)] [ProducesResponseType(StatusCodes.Status500InternalServerError)] [Permission("PermissionManagement.Write")] public async Task ChangePermissionStatusService([FromBody] ChangePermissionStatusRequest request, CancellationToken cancellationToken) { try { logger.LogInformation($"{nameof(ChangePermissionStatusService)} - Request received - Payload: {JsonSerializer.Serialize(request)}"); if (string.IsNullOrEmpty(request.Id)) { return BadRequest("Invalid permission identifier"); } return await Handle(() => cerberosServiceClient.ChangePermissionStatusService(request, cancellationToken)).ConfigureAwait(false); } catch (Exception ex) { logger.LogError($"{nameof(ChangePermissionStatusService)} - An Error Occurred- {ex.Message} - {ex.InnerException} - {ex.StackTrace} - with payload {JsonSerializer.Serialize(request)}"); throw; } } } }