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

namespace FrameworkBLL.GOP.Worker
{
    // ============================================================
    // INodeExecutor — one implementation per NodeType.
    //
    // Registered as keyed scoped services:
    //   services.AddKeyedScoped<INodeExecutor, QualifierNodeExecutor>("Qualifier");
    //   services.AddKeyedScoped<INodeExecutor, MapperNodeExecutor>("Mapper");
    //   services.AddKeyedScoped<INodeExecutor, ApiCallNodeExecutor>("ApiCall");
    //
    // GopExecutionPipeline dispatches:
    //   sp.GetRequiredKeyedService<INodeExecutor>(step.NodeType)
    // ============================================================
    public interface INodeExecutor
    {
        /// <summary>"Qualifier", "Mapper", or "ApiCall".</summary>
        string NodeType { get; }

        /// <summary>
        /// Executes a single pipeline step.
        /// Returns the output payload JSON (stored in TGOPEXECUTIONNODELOG.RESPONSEPAYLOADJSON).
        /// Throws on unrecoverable failure (after all retries exhausted).
        /// </summary>
        Task<string?> ExecuteAsync(
            GopFlowSnapshotStepDTO step,
            GopExecutionHeaderDTO  header,
            string?                inputPayloadJson,
            LoginDTO               loginDTO,
            CancellationToken      ct);
    }
}