using AmpDAL.DTO.ApiRequestSubscriber;
using AMPDAL.Query.ApiRequestSubscriber;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.QueryExecutor;

namespace AmpDAL.CustomCode.ApiRequestSubscriber;

public class ApiRequestSubscriberDAL(IQueryExecutor _qe) : IApiRequestSubscriberDAL
{
    public async Task<List<ApiRequestSubscriberDTO>> GetByRequestAsync(int apiRequestId, int tenantId, LoginDTO login, CancellationToken ct)
    {
        var result = await _qe.QueryAsync<ApiRequestSubscriberDTO>(
            login,
            ApiRequestSubscriberQB.GET_BY_REQUEST,
            new { ApiRequestId = apiRequestId, TenantId = tenantId },
            null,
            false,
            ct).ConfigureAwait(false);
        return result.ToList();
    }

    public async Task<List<ApiRequestSubscriberDTO>> GetByStatusAsync(int apiRequestId, byte notifyOnStatus, int tenantId, LoginDTO login, CancellationToken ct)
    {
        var result = await _qe.QueryAsync<ApiRequestSubscriberDTO>(
            login,
            ApiRequestSubscriberQB.GET_BY_STATUS,
            new { ApiRequestId = apiRequestId, NotifyOnStatus = notifyOnStatus, TenantId = tenantId },
            null,
            false,
            ct).ConfigureAwait(false);
        return result.ToList();
    }

    public async Task<int> SaveSubscriberAsync(ApiRequestSubscriberSaveDTO dto, LoginDTO login, CancellationToken ct)
        => await _qe.ExecuteScalarAsync<int>(
            login,
            ApiRequestSubscriberQB.SAVE_SUBSCRIBER,
            new
            {
                dto.SubscriberId,
                TenantId = login.ClientId,
                dto.ApiRequestId,
                dto.SubscriberUserId,
                dto.NotifyOnStatus,
                CreatedById = login.UserId
            }).ConfigureAwait(false);

    public async Task DeleteSubscriberAsync(int subscriberId, int apiRequestId, LoginDTO login, CancellationToken ct)
        => await _qe.ExecuteAsync(
            login,
            ApiRequestSubscriberQB.DELETE_SUBSCRIBER,
            new { SubscriberId = subscriberId, ApiRequestId = apiRequestId, TenantId = login.ClientId }).ConfigureAwait(false);
}