package tv.samim.iptv.cmts.client.listener;

import org.apache.http.HttpRequest;
import org.apache.http.client.HttpResponseException;
import org.camunda.bpm.engine.variable.VariableMap;
import tv.samim.iptv.cmts.client.exception.ExternalTaskClientException;
import tv.samim.iptv.cmts.client.impl.EngineClientException;
import tv.samim.iptv.cmts.client.task.ExternalTask;
import tv.samim.iptv.cmts.client.topic.impl.dto.TopicRequestDto;

import java.io.IOException;
import java.util.List;
import java.util.Map;

public interface ExternalTaskClientListener {
    public void exceptionWhileClosingResourceStream(Object response, IOException e);
    public void requestInterceptorException(Throwable e);
    public void exceptionWhileExecutingExternalTaskHandler(String topicName, Throwable e);
    public void exceptionWhileShuttingDown(InterruptedException e);
    public void exceptionOnExternalTaskServiceMethodInvocation(String topicName, ExternalTaskClientException e);
    public void exceptionWhileExecutingBackoffStrategyMethod(Throwable e);
    public void exceptionWhileAcquiringTasks(Throwable e);
    public void exceptionWhileReceivingResponse(HttpRequest httpRequest, HttpResponseException e);
    public void exceptionWhileEstablishingConnection(HttpRequest httpRequest, IOException e);
    public void exceptionWhileParsingJsonObject(Class<?> responseDtoClass, Throwable t);
    public void exceptionWhileMappingJsonObject(Class<?> responseDtoClass, Throwable t);
    public void exceptionWhileDeserializingJsonObject(Class<?> responseDtoClass, Throwable t);
    public void exceptionWhileSerializingJsonObject(Object dto, Throwable t);
    public void taskHandlerIsNull(String topicName);

    public void onFetchAndLock(List<TopicRequestDto> topics);
    public void fetchAndLockDone(List<TopicRequestDto> topics, List<ExternalTask> externalTasks);
    public void fetchAndLockFail(List<TopicRequestDto> topics, EngineClientException e);

    public void onUnlock(String taskId);
    public void unlockDone(String taskId);
    public void unlockFail(String taskId, EngineClientException e);

    public void onSetVariable(String processInstanceId, VariableMap variables);
    public void setVariableDone(String processInstanceId, VariableMap variables);
    public void setVariableFail(String processInstanceId, VariableMap variables, EngineClientException e);

    public void onComplete(String taskId, Map<String, Object> variables, Map<String, Object> localVariables);
    public void completeDone(String taskId, Map<String, Object> variables, Map<String, Object> localVariables);
    public void completeFail(String taskId, Map<String, Object> variables, Map<String, Object> localVariables, EngineClientException e);

    public void onFailure(String taskId, String errorMessage, String errorDetails, int retries, long retryTimeout);
    public void failureDone(String taskId, String errorMessage, String errorDetails, int retries, long retryTimeout);
    public void failureFail(String taskId, String errorMessage, String errorDetails, int retries, long retryTimeout, EngineClientException e);

    public void onBpmnError(String taskId, String errorCode, String errorMessage, Map<String, Object> variables);
    public void bpmnErrorDone(String taskId, String errorCode, String errorMessage, Map<String, Object> variables);
    public void bpmnErrorFail(String taskId, String errorCode, String errorMessage, Map<String, Object> variables, EngineClientException e);

    public void onExtendLock(String taskId, long newDuration);
    public void extendLockDone(String taskId, long newDuration);
    public void extendLockFail(String taskId, long newDuration, EngineClientException e);

    public void onSendMessage(String taskId, String message, VariableMap correlationKeys, VariableMap processVariables, Boolean all);
    public void sendMessageDone(String taskId, String message, VariableMap correlationKeys, VariableMap processVariables, Boolean all);
    public void sendMessageFail(String taskId, String message, VariableMap correlationKeys, VariableMap processVariables, Boolean all, EngineClientException e);
    public void onStartProcess(String taskId, String id, String processKey, String tenantId, VariableMap variables, String caseInstanceId);
    public void startProcessDone(String taskId, String id, String processKey, String tenantId, VariableMap variables, String caseInstanceId);
    public void startProcessFail(String taskId, String id, String processKey, String tenantId, VariableMap variables, String caseInstanceId, EngineClientException e);

    public void onLogin();
    public void loginDone();
    public void loginFail(EngineClientException e);

    public void onXsrf();
    public void xsrfDone(String xsrf);
    public void xsrfFail(EngineClientException e);

    public void unAuthorizedException(EngineClientException e);
}