/**
 * This class is the base class for all loop task type.
 * <p>
 * The loop task type means, we will submit a task, and loop the task status until the task is finished.
 */
public abstract class BaseLoopTaskExecutor<SubmitTaskMethodT extends LoopTaskSubmitTaskMethodDefinition, QueryTaskMethodT extends LoopTaskQueryStatusMethodDefinition>
    extends AbstractTaskExecutor {

    protected final LoopTaskDefinition<SubmitTaskMethodT, QueryTaskMethodT> loopTaskDefinition;
    // init this parameters in init method(todo: we need to refactor the init method)
    protected AbstractParameters loopTaskParameters;

    protected BaseLoopTaskExecutor(@NonNull TaskExecutionContext taskExecutionContext,
                                   @NonNull LoopTaskDefinition<SubmitTaskMethodT, QueryTaskMethodT> loopTaskDefinition) {
        super(taskExecutionContext);
        this.loopTaskDefinition = loopTaskDefinition;
    }

    @Override
    public void handle() throws TaskException {
        try {
            LoopTaskSubmitTaskMethodDefinition submitTaskMethod = loopTaskDefinition.getSubmitTaskMethod();
            LoopTaskQueryStatusMethodDefinition queryTaskStateMethod = loopTaskDefinition.getQueryTaskStateMethod();
            long loopInterval = queryTaskStateMethod.getTaskInstanceStatusQueryInterval().toMillis();

            LoopTaskInstanceInfo loopTaskInstanceInfo = submitTaskMethod.submitLoopTaskInstance();
            this.appIds = loopTaskInstanceInfo.getTaskInstanceId();
            while (!queryTaskStateMethod.queryTaskInstanceStatus(loopTaskInstanceInfo).isFinished()) {
                Thread.sleep(loopInterval);
            }
        } catch (InterruptedException e) {
            setExitStatusCode(TaskConstants.EXIT_CODE_FAILURE);
            logger.error("The current loop thread has been interrupted", e);
            Thread.currentThread().interrupt();
            throw new TaskException("The current loop thread has been interrupted");
        } catch (Exception ex) {
            setExitStatusCode(TaskConstants.EXIT_CODE_FAILURE);
            logger.error("Loop task execute error", ex);
            throw new TaskException("Loop task execute error", ex);
        }
    }
}