using GB5Shared.DTO.Framework.Login;
using JobEngineDAL.DTOs;

namespace JobEngineDAL.Interfaces
{
    public interface IJobQueueDAL
    {
        Task<long>  EnqueueAsync(JobQueueItemDTO item, LoginDTO login, CancellationToken ct);
        Task<IEnumerable<JobQueueItemDTO>> ClaimBatchAsync(int tenantId, IReadOnlyList<string> messageTypes, int batchSize, LoginDTO login, CancellationToken ct);
        Task        CompleteAsync(long queueId, LoginDTO login, CancellationToken ct);
        Task        RetryAsync(long queueId, TimeSpan delay, string errorDetails, LoginDTO login, CancellationToken ct);
        Task        MoveToDLQAsync(long queueId, string errorDetails, LoginDTO login, CancellationToken ct);
        Task        RequeueItemAsync(long queueId, LoginDTO login, CancellationToken ct);
        Task        CancelItemAsync(long queueId, LoginDTO login, CancellationToken ct);
        Task<int>   PurgeDLQAsync(int daysOld, LoginDTO login, CancellationToken ct);
        Task<(IEnumerable<JobQueueItemDTO> Items, int TotalCount)> GetQueuePagedAsync(
            int tenantId, string? status, string? messageType, int page, int pageSize, LoginDTO login, CancellationToken ct);
        Task<IEnumerable<QueueStatDTO>> GetQueueStatsAsync(LoginDTO login, CancellationToken ct);
        Task<int> GetDLQTotalAsync(LoginDTO login, CancellationToken ct);
        Task<int> GetPendingTotalAsync(LoginDTO login, CancellationToken ct);
    }
}