using System.Collections.Generic;
using System.Data.Common;
using System.Threading.Tasks;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.DTO.GOP;

namespace FrameworkDAL.CustomCode.GOP
{
    public interface IGopQueueDAL
    {
        // Queue + Header (atomic, returns both IDs)
        Task<(int QueueId, int ExecutionId)> SubmitToQueue(
            GopExecutionQueueDTO QueueDTO,
            GopExecutionHeaderDTO HeaderDTO,
            LoginDTO LoginDTO);

        // Queue status
        Task UpdateQueueStatus(int ClientId, int QueueId, string Status, string? ErrorMessage, LoginDTO LoginDTO);

        // Execution header
        Task UpdateExecutionStatus(int ClientId, int ExecutionId, string Status, string? ErrorMessage, long? TotalDurationMs, LoginDTO LoginDTO, string? LastOutputPayloadJson = null);
        Task UpdateExecutionCurrentNode(int ClientId, int ExecutionId, int NodeId, string NodeCode, LoginDTO LoginDTO);

        /// <summary>Pauses an execution at an Approval-gate node — Status becomes 'PendingApproval'.</summary>
        Task UpdateExecutionApprovalPending(int ClientId, int ExecutionId, int NodeId, string NodeCode, string? LastOutputPayloadJson, string? AssignedRole, int? AssignedToUserId, LoginDTO LoginDTO);

        /// <summary>Resumes a 'PendingApproval' execution by setting Status back to 'Queued' so the worker re-picks it up.</summary>
        Task<bool> ResumeExecutionAfterApproval(int ClientId, int ExecutionId, LoginDTO LoginDTO);

        Task<GopExecutionHeaderDTO?> GetExecutionById(int ClientId, int ExecutionId, LoginDTO LoginDTO);
        Task<IEnumerable<GopExecutionHeaderDTO>> GetExecutionsByStatus(int ClientId, string? Status, int Page, int PageSize, LoginDTO LoginDTO);

        // Node logs
        Task<int> InsertNodeLog(GopExecutionNodeLogDTO NodeLogDTO, LoginDTO LoginDTO);
        Task UpdateNodeLog(int ClientId, int NodeLogId, string Status, string? ResponsePayload, int? HttpStatusCode, long DurationMs, string? ErrorCode, string? ErrorMessage, LoginDTO LoginDTO);
        Task<IEnumerable<GopExecutionNodeLogDTO>> GetNodeLogsByExecution(int ClientId, int ExecutionId, LoginDTO LoginDTO);

        // State log
        Task InsertStateLog(int ClientId, int ExecutionId, string? PreviousStatus, string NewStatus, string? ReasonCode, string ChangedBy, LoginDTO LoginDTO);
        Task<IEnumerable<GopExecutionStateLogDTO>> GetStateLogsByExecution(int ClientId, int ExecutionId, LoginDTO LoginDTO);

        // Metrics
        Task InsertExecutionMetrics(GopExecutionMetricsDTO MetricsDTO, LoginDTO LoginDTO);
        Task InsertNodeMetrics(GopExecutionNodeMetricsDTO NodeMetricsDTO, LoginDTO LoginDTO);

        // Dead letter
        Task<int> InsertDeadLetter(GopDeadLetterDTO DlqDTO, LoginDTO LoginDTO);
        Task<IEnumerable<GopDeadLetterDTO>> GetDeadLetters(int ClientId, LoginDTO LoginDTO);
        Task ResolveDeadLetter(int ClientId, int DlqId, string ResolvedBy, LoginDTO LoginDTO);

        // Remediation
        Task<int> InsertRemediation(GopRemediationDTO RemediationDTO, LoginDTO LoginDTO);
        Task UpdateRemediation(int ClientId, int RemediationId, string Status, string ResolutionNotes, string ResolvedBy, LoginDTO LoginDTO);
        Task<IEnumerable<GopRemediationDTO>> GetOpenRemediations(int ClientId, LoginDTO LoginDTO);

        // Lock
        Task<bool> AcquireLock(int ClientId, int ExecutionId, string LockedBy, int LockDurationSeconds, LoginDTO LoginDTO);
        Task ReleaseLock(int ClientId, int ExecutionId, LoginDTO LoginDTO);

        // Worker polling
        Task<IEnumerable<GopExecutionHeaderDTO>> GetPendingExecutions(int limit, LoginDTO loginDTO);
        Task ResetExpiredLocks(LoginDTO loginDTO);

        // Dashboard
        Task<IEnumerable<GopQueueDashboardDTO>> GetQueueDashboard(int ClientId, LoginDTO LoginDTO);

        // Source file
        Task<int> InsertSourceFile(GopSourceFileDTO FileDTO, LoginDTO LoginDTO);
        Task UpdateSourceFileStatus(int ClientId, int FileId, string Status, int? QueueId, LoginDTO LoginDTO);
    }
}