package cn.reactnative.modules.update;

import androidx.annotation.Nullable;
import com.facebook.react.bridge.Promise;
import com.facebook.react.bridge.ReactApplicationContext;
import com.facebook.react.bridge.ReadableMap;
import org.json.JSONException;
import org.json.JSONObject;
import org.json.JSONTokener;

public class UpdateModuleImpl {

    public static final String NAME = "Pushy";

    private UpdateModuleImpl() {
    }

    private static boolean isValidHashInfo(@Nullable String json) {
        if (json == null) {
            return false;
        }
        try {
            return new JSONTokener(json).nextValue() instanceof JSONObject;
        } catch (JSONException e) {
            return false;
        }
    }

    public static void downloadFullUpdate(
        UpdateContext updateContext,
        final ReadableMap options,
        final Promise promise
    ) {
        String url = options.getString("updateUrl");
        String hash = options.getString("hash");
        updateContext.downloadFullUpdate(url, hash, new UpdateContext.DownloadFileListener() {
            @Override
            public void onDownloadCompleted(DownloadTaskParams params) {
                promise.resolve(null);
            }

            @Override
            public void onDownloadFailed(Throwable error) {
                promise.reject(error);
            }
        });
    }

    public static void downloadAndInstallApk(
        final ReactApplicationContext reactContext,
        UpdateContext updateContext,
        final ReadableMap options,
        final Promise promise
    ) {
        String url = options.getString("url");
        String hash = options.getString("hash");
        String target = options.getString("target");
        updateContext.downloadFile(url, hash, target, new UpdateContext.DownloadFileListener() {
            @Override
            public void onDownloadCompleted(DownloadTaskParams params) {
                UpdateModuleSupport.installApk(reactContext, params.targetFile);
                promise.resolve(null);
            }

            @Override
            public void onDownloadFailed(Throwable error) {
                promise.reject(error);
            }
        });
    }

    public static void downloadPatchFromPackage(
        UpdateContext updateContext,
        final ReadableMap options,
        final Promise promise
    ) {
        String url = options.getString("updateUrl");
        String hash = options.getString("hash");
        updateContext.downloadPatchFromApk(url, hash, new UpdateContext.DownloadFileListener() {
            @Override
            public void onDownloadCompleted(DownloadTaskParams params) {
                promise.resolve(null);
            }

            @Override
            public void onDownloadFailed(Throwable error) {
                promise.reject(error);
            }
        });
    }

    public static void downloadPatchFromPpk(
        UpdateContext updateContext,
        final ReadableMap options,
        final Promise promise
    ) {
        try {
            String url = options.getString("updateUrl");
            String hash = options.getString("hash");
            String originHash = options.getString("originHash");

            updateContext.downloadPatchFromPpk(url, hash, originHash, new UpdateContext.DownloadFileListener() {
                @Override
                public void onDownloadCompleted(DownloadTaskParams params) {
                    promise.resolve(null);
                }

                @Override
                public void onDownloadFailed(Throwable error) {
                    promise.reject(error);
                }
            });
        } catch (Exception e) {
            promise.reject("downloadPatchFromPpk failed: " + e.getMessage());
        }
    }

    public static void reloadUpdate(
        final UpdateContext updateContext,
        final ReactApplicationContext reactContext,
        final ReadableMap options,
        final Promise promise
    ) {
        restartApp(updateContext, reactContext, options.getString("hash"), promise);
    }

    public static void restartApp(
        final UpdateContext updateContext,
        final ReactApplicationContext reactContext,
        @Nullable final String hash,
        final Promise promise
    ) {
        UiThreadRunner.run(promise, "restartApp", new UiThreadRunner.Operation() {
            @Override
            public void run() throws Throwable {
                ReactReloadManager.restartApp(updateContext, reactContext, hash);
                promise.resolve(true);
            }
        });
    }

    private static void setNeedUpdateInternal(UpdateContext updateContext, String hash) {
        updateContext.switchVersion(hash);
    }

    public static void setNeedUpdate(
        final UpdateContext updateContext,
        final ReadableMap options,
        final Promise promise
    ) {
        final String hash = options.getString("hash");
        UiThreadRunner.run(promise, "switchVersionLater", new UiThreadRunner.Operation() {
            @Override
            public void run() {
                setNeedUpdateInternal(updateContext, hash);
                promise.resolve(true);
            }
        });
    }

    public static void setNeedUpdate(final UpdateContext updateContext, final ReadableMap options) {
        final String hash = options.getString("hash");
        UiThreadRunner.run(null, "switchVersionLater", new UiThreadRunner.Operation() {
            @Override
            public void run() {
                setNeedUpdateInternal(updateContext, hash);
            }
        });
    }

    private static void markSuccessInternal(UpdateContext updateContext) {
        updateContext.markSuccess();
    }

    public static void markSuccess(final UpdateContext updateContext, final Promise promise) {
        UiThreadRunner.run(promise, "markSuccess", new UiThreadRunner.Operation() {
            @Override
            public void run() {
                markSuccessInternal(updateContext);
                promise.resolve(true);
            }
        });
    }

    public static void markSuccess(final UpdateContext updateContext) {
        UiThreadRunner.run(null, "markSuccess", new UiThreadRunner.Operation() {
            @Override
            public void run() {
                markSuccessInternal(updateContext);
            }
        });
    }

    private static void setUuidInternal(UpdateContext updateContext, String uuid) {
        updateContext.setKv("uuid", uuid);
    }

    public static void setUuid(
        final UpdateContext updateContext,
        final String uuid,
        final Promise promise
    ) {
        UiThreadRunner.run(promise, "setUuid", new UiThreadRunner.Operation() {
            @Override
            public void run() {
                setUuidInternal(updateContext, uuid);
                promise.resolve(true);
            }
        });
    }

    public static void setUuid(final UpdateContext updateContext, final String uuid) {
        UiThreadRunner.run(null, "setUuid", new UiThreadRunner.Operation() {
            @Override
            public void run() {
                setUuidInternal(updateContext, uuid);
            }
        });
    }

    private static void setLocalHashInfoInternal(
        UpdateContext updateContext,
        String hash,
        String info
    ) {
        if (!isValidHashInfo(info)) {
            throw new IllegalArgumentException("invalid json string");
        }
        updateContext.setKv("hash_" + hash, info);
    }

    public static void setLocalHashInfo(
        final UpdateContext updateContext,
        final String hash,
        final String info,
        final Promise promise
    ) {
        UiThreadRunner.run(promise, "setLocalHashInfo", new UiThreadRunner.Operation() {
            @Override
            public void run() {
                setLocalHashInfoInternal(updateContext, hash, info);
                promise.resolve(true);
            }
        });
    }

    public static void setLocalHashInfo(
        final UpdateContext updateContext,
        final String hash,
        final String info
    ) {
        UiThreadRunner.run(null, "setLocalHashInfo", new UiThreadRunner.Operation() {
            @Override
            public void run() {
                setLocalHashInfoInternal(updateContext, hash, info);
            }
        });
    }

    public static void getLocalHashInfo(
        UpdateContext updateContext,
        final String hash,
        final Promise promise
    ) {
        String value = updateContext.getKv("hash_" + hash);
        if (!isValidHashInfo(value)) {
            promise.reject("getLocalHashInfo failed: invalid json string");
            return;
        }

        promise.resolve(value);
    }
}