using Indotalent.ConfigBackEnd.Interfaces; using Indotalent.ConfigFrontEnd.Common; using Indotalent.Features.Pipeline.Campaign.Cqrs; using Indotalent.Infrastructure.Authentication.Identity; using Indotalent.Shared.Models; using Microsoft.AspNetCore.Components; using MudBlazor; using RestSharp; namespace Indotalent.Features.Pipeline.Campaign; public class CampaignService : BaseService { private readonly RestClient _client; public CampaignService( IHttpClientFactory clientFactory, NavigationManager nav, ISnackbar snackbar, ICurrentUserService currentUserService, TokenProvider tokenProvider) : base(clientFactory, nav, snackbar, currentUserService, tokenProvider) { _client = new RestClient(nav.BaseUri); } public async Task?> GetLookupDataAsync() { var request = new RestRequest("api/campaign/lookup", Method.Get); return await ExecuteWithResponseAsync(_client, request); } public async Task>?> GetCampaignListAsync() { var request = new RestRequest("api/campaign", Method.Get); return await ExecuteWithResponseAsync>(_client, request); } public async Task?> GetCampaignByIdAsync(string id) { var request = new RestRequest($"api/campaign/{id}", Method.Get); return await ExecuteWithResponseAsync(_client, request); } public async Task?> CreateCampaignAsync(CreateCampaignRequest data) { var request = new RestRequest("api/campaign", Method.Post); request.AddJsonBody(data); return await ExecuteWithResponseAsync(_client, request); } public async Task?> UpdateCampaignAsync(UpdateCampaignRequest data) { var request = new RestRequest("api/campaign/update", Method.Post); request.AddJsonBody(data); return await ExecuteWithResponseAsync(_client, request); } public async Task DeleteCampaignAsync(string id) { var request = new RestRequest($"api/campaign/delete/{id}", Method.Post); var response = await ExecuteWithResponseAsync(_client, request); return response?.IsSuccess ?? false; } public async Task?> AddBudgetAsync(CreateBudgetRequest data) { var request = new RestRequest("api/campaign/budget", Method.Post); request.AddJsonBody(data); return await ExecuteWithResponseAsync(_client, request); } public async Task?> UpdateBudgetAsync(UpdateBudgetRequest data) { var request = new RestRequest("api/campaign/budget/update", Method.Post); request.AddJsonBody(data); return await ExecuteWithResponseAsync(_client, request); } public async Task DeleteBudgetAsync(string id) { var request = new RestRequest($"api/campaign/budget/delete/{id}", Method.Post); var response = await ExecuteWithResponseAsync(_client, request); return response?.IsSuccess ?? false; } public async Task?> AddExpenseAsync(CreateExpenseRequest data) { var request = new RestRequest("api/campaign/expense", Method.Post); request.AddJsonBody(data); return await ExecuteWithResponseAsync(_client, request); } public async Task?> UpdateExpenseAsync(UpdateExpenseRequest data) { var request = new RestRequest("api/campaign/expense/update", Method.Post); request.AddJsonBody(data); return await ExecuteWithResponseAsync(_client, request); } public async Task DeleteExpenseAsync(string id) { var request = new RestRequest($"api/campaign/expense/delete/{id}", Method.Post); var response = await ExecuteWithResponseAsync(_client, request); return response?.IsSuccess ?? false; } }