package com.rnboat.framework.updatepluginlib.flow;

import com.rnboat.framework.updatepluginlib.base.CheckCallback;
import com.rnboat.framework.updatepluginlib.base.DownloadCallback;
import com.rnboat.framework.updatepluginlib.base.RestartHandler;
import com.rnboat.framework.updatepluginlib.model.Update;
import com.rnboat.framework.updatepluginlib.util.L;

import java.io.File;

/**
 * 更新回调的代理类，用于统一进行回调分发。并打印日志辅助调试
 *
 * @author haoge on 2017/9/26.
 */
public final class CallbackDelegate implements CheckCallback, DownloadCallback {

    private CheckCallback checkProxy;
    private DownloadCallback downloadProxy;
    private RestartHandler restartHandler;

    public void setCheckDelegate(CheckCallback checkProxy) {
        this.checkProxy = checkProxy;
    }

    public void setDownloadDelegate(DownloadCallback downloadProxy) {
        this.downloadProxy = downloadProxy;
    }

    @Override
    public void onDownloadStart() {
        L.d("start downloading。。。");
        if (downloadProxy != null) {
            downloadProxy.onDownloadStart();
        }

        if (restartHandler != null) {
            restartHandler.onDownloadStart();
        }
    }

    @Override
    public void onDownloadComplete(File file) {
        L.d("Download completed to file [%s]", file.getAbsoluteFile());
        if (downloadProxy != null) {
            downloadProxy.onDownloadComplete(file);
        }

        if (restartHandler != null) {
            restartHandler.onDownloadComplete(file);
        }
    }

    @Override
    public void onDownloadProgress(long current, long total) {
        L.d("Downloading... current is %s and total is %s", current, total);
        if (downloadProxy != null) {
            downloadProxy.onDownloadProgress(current, total);
        }

        if (restartHandler != null) {
            restartHandler.onDownloadProgress(current, total);
        }
    }

    @Override
    public void onDownloadError(Throwable t) {
        L.e(t, "Download task has occurs error: %s", t.getMessage());
        if (downloadProxy != null) {
            downloadProxy.onDownloadError(t);
        }

        if (restartHandler != null) {
            restartHandler.onDownloadError(t);
        }
    }
    @Override
    public void onCheckStart() {
        L.d("starting check update task.");
        if (checkProxy != null) {
            checkProxy.onCheckStart();
        }

        if (restartHandler != null) {
            restartHandler.onCheckStart();
        }
    }

    @Override
    public void hasUpdate(Update update) {
        L.d("Checkout that new version apk is exist: update is %s", update);
        if (checkProxy != null) {
            checkProxy.hasUpdate(update);
        }

        if (restartHandler != null) {
            restartHandler.hasUpdate(update);
        }
    }

    @Override
    public void noUpdate() {
        L.d("There are no new version exist");
        if (checkProxy != null) {
            checkProxy.noUpdate();
        }

        if (restartHandler != null) {
            restartHandler.noUpdate();
        }
    }

    @Override
    public void onCheckError(Throwable t) {
        L.e(t, "check update failed: cause by : %s", t.getMessage());
        if (checkProxy != null) {
            checkProxy.onCheckError(t);
        }

        if (restartHandler != null) {
            restartHandler.onCheckError(t);
        }
    }

    @Override
    public void onUserCancel() {
        L.d("update task has canceled by user");
        if (checkProxy != null) {
            checkProxy.onUserCancel();
        }

        if (restartHandler != null) {
            restartHandler.onUserCancel();
        }
    }

    @Override
    public void onCheckIgnore(Update update) {
        L.d("ignored for this update: " + update);
        if (checkProxy != null) {
            checkProxy.onCheckIgnore(update);
        }

        if (restartHandler != null) {
            restartHandler.onCheckIgnore(update);
        }
    }

    public void setRestartHandler(RestartHandler restartHandler) {
        this.restartHandler = restartHandler;
    }
}