using Fitness_core_BE.Models.IOs; using Fitness_core_BE.Services.CustomerPlanService; using Fitness_core_BE.Interfaces.Services; namespace Fitness_core_BE.Services.FunctionHandler { public class CustomerPlanFunctionHandler { public readonly Dictionary>> _functionHandler; public CustomerPlanFunctionHandler(ICustomerPlanService customerPlanService) { _functionHandler = new() { { "GetAllCustomerPlans", customerPlanService.GetAllCustomerPlans }, { "GetCustomerPlanById", customerPlanService.GetCustomerPlanById }, { "CreateCustomerPlan", customerPlanService.CreateCustomerPlan }, { "UpdateCustomerPlan", customerPlanService.UpdateCustomerPlan }, { "SetCustomerPlanStatus", customerPlanService.SetCustomerPlanStatus }, { "DeleteCustomerPlan", customerPlanService.DeleteCustomerPlan } }; } public async Task> Execute(ApiRequest request, HttpContext httpContext) { if (!_functionHandler.TryGetValue(request.FunctionName, out var handler)) { return new ApiResponse { StatusCode = 404, Message = $"Function '{request.FunctionName}' not found.", Data = null! }; } try { var results = await handler(request.Payload, httpContext); return new ApiResponse { StatusCode = 200, Message = "success", Data = results }; } catch (UnauthorizedAccessException ex) { return new ApiResponse { StatusCode = 401, Message = ex.Message, Data = null! }; } catch (KeyNotFoundException ex) { return new ApiResponse { StatusCode = 400, Message = ex.Message, Data = null! }; } catch (InvalidOperationException ex) { return new ApiResponse { StatusCode = 400, Message = ex.Message, Data = null! }; } catch (Exception ex) { return new ApiResponse { StatusCode = 500, Message = $"An error occurred: {ex.Message}", Data = null! }; } } } }