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

namespace FrameworkBLL.GOP
{
    public interface IGopQueueBLL
    {
        // Main entry point: resolve binding → enqueue → fire worker
        Task<GopSubmitResponseDTO> SubmitExecution(GopSubmitRequestDTO RequestDTO, LoginDTO LoginDTO);

        // Re-submits a past execution's original payload as a brand-new execution
        // (ParentExecutionId links it back for lineage). Does not mutate the original.
        Task<GopSubmitResponseDTO> ReplayGopExecution(int ExecutionId, LoginDTO LoginDTO);

        // Approval gate
        Task<string> ApproveGopExecutionStep(int ExecutionId, string? ApproverNotes, LoginDTO LoginDTO);
        Task<string> RejectGopExecutionStep(int ExecutionId, string Reason, LoginDTO LoginDTO);

        // Query
        Task<object> GetExecutionStatus(int ExecutionId, LoginDTO LoginDTO);
        Task<IEnumerable<GopExecutionNodeLogDTO>> GetExecutionNodeLogs(int ExecutionId, LoginDTO LoginDTO);
        Task<IEnumerable<GopQueueDashboardDTO>> GetQueueDashboard(LoginDTO LoginDTO);

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

        // Remediation
        Task<int> OpenRemediation(GopOpenRemediationRequestDTO RequestDTO, LoginDTO LoginDTO);
        Task ResolveRemediation(GopResolveRemediationRequestDTO RequestDTO, LoginDTO LoginDTO);
        Task<IEnumerable<GopRemediationDTO>> GetOpenRemediations(LoginDTO LoginDTO);
    }
}