//=============================================================================
// Salted Fish Plugins - Auto Update
// SF_AutoUpdate.js
//=============================================================================

"use strict";
var Imported = Imported || {};
Imported.SF_AutoUpdate = true;

var SF_Plugins = SF_Plugins || {};

//=============================================================================
/*:
    * @plugindesc v1.0.0 - Automatically update the game.
    * @author Salted Fish
    * 
    * @help
    * 
    * ===========================================================================
    * Introduction
    * ===========================================================================
    * 
    * This plugin automatically updates the game.
    * 
    * ===========================================================================
    * Requires
    * ===========================================================================
    * 
    * You need use ycrpg2-android-client to run on android.
    * otherwise, you can use ycrpg2-pc-client to run on pc.
    * This is not supported on ios and web, but web also use the newest version.
    * 
    * ===========================================================================
    * How to use
    * ===========================================================================
    * 
    * ycrpg2-android-client provide FileUtils and UpdateUtils.
    * FileUtils is used to read and write Text files, and UpdateUtils is used to
    * update the game.
    * 
    * FileUtils provide the following functions:
    *	public void evaluateJavascript(String script) 
    *	public boolean canExecute(String fileName) 
    *	public boolean canRead(String fileName) 
    *	public boolean canWrite(String fileName) 
    *	public boolean createNewFile(String fileName) 
    *	public boolean delete(String fileName) 
    *	public boolean exists(String fileName) 
    *	public String getAbsolutePath(String fileName) 
    *	public String getCanonicalPath(String fileName) 
    *	public String getName(String fileName) 
    *	public String getParent(String fileName) 
    *	public String getPath(String fileName) 
    *	public boolean isAbsolute(String fileName) 
    *	public boolean isDirectory(String fileName) 
    *	public boolean isFile(String fileName) 
    *	public long lastModified(String fileName) 
    *	public long length(String fileName) 
    *	public String list(String fileName) 
    *	public boolean mkdir(String fileName) 
    *	public boolean mkdirs(String fileName) 
    *	public boolean renameTo(String srcName, String dstName) 
    *	public String toString(String fileName) 
    *	public String readTextFile(String fileName) 
    *	public boolean writeTextFile(String fileName,String content)
    *	public String getFileHashHex(String fileName, String algorithm)
    *	public String getFileHashHex(String fileName)
    *
    * UpdateUtils provide the following functions:
    *   public void evaluateJavascript(String script) 
    *   public void downloadFullUrl(String fileName, String urlString, String success, String fail) 
    *   public void downloadRelativeUrl(String fileName, String urlString, String success, String fail) 
    *   public void startUpdateFiles()
    *   public void updateFileCompleted(boolean bool) 
    *   public String getHashInfoJson() 
    *   public void updateFile(String fileName, String success, String fail) 
    */
//=============================================================================

(function () {
    var SF_AutoUpdate = {};
    SF_Plugins.SF_AutoUpdate = SF_AutoUpdate;

    SF_AutoUpdate.version = 1.0;

    SF_AutoUpdate.remoteFileInfoName = "file_info_remote.json";
    SF_AutoUpdate.localFileInfoName = "file_info_local.json";
    SF_AutoUpdate.remoteFileInfoUrl = "https://ycrpg.xyzzgame.com/ycrpg2/file_info_remote.json";
    SF_AutoUpdate.remoteUrlRoot = "https://ycrpg.xyzzgame.com/YCrpg2/";
    SF_AutoUpdate.emptyFileInfoStr = `{"is_file":false,"is_dir":true,"children":[],"sha_512":"","file_name":""}`;
    SF_AutoUpdate.workerFileName = "js/plugins/SF_AutoUpdateWorker.js";
    SF_AutoUpdate.localStorageKey = "SF_AutoUpdate_UpdateFileCompleted";

    SF_AutoUpdate.enableAutoUpdate = true;

    SF_AutoUpdate.isAndroid = function () {
        return !!window.FileUtils && !!window.UpdateUtils && !SF_AutoUpdate.isPC();
    }

    SF_AutoUpdate.isPC = function () {
        return !!Utils.isNwjs();
    }

    SF_AutoUpdate.isWeb = function () {
        return !SF_AutoUpdate.isPC() && !SF_AutoUpdate.isAndroid();
    }

    SF_AutoUpdate.isSupported = function () {
        return SF_AutoUpdate.enableAutoUpdate && (SF_AutoUpdate.isAndroid() || SF_AutoUpdate.isPC()) && !Utils.isOptionValid('test');
    }

    if (!SF_AutoUpdate.isSupported()) { return; }

    SF_AutoUpdate.FileUtils = window.FileUtils || {};
    SF_AutoUpdate.UpdateUtils = window.UpdateUtils || {};

    if (SF_AutoUpdate.isPC()) {
        window.FileUtils = SF_AutoUpdate.FileUtils;
        window.UpdateUtils = SF_AutoUpdate.UpdateUtils;

        var fs = require('fs');
        var path = require('path');
        var os = require('os');
        var crypto = require('crypto');
        var https = require('https');

        var httpsAgent = new https.Agent({
            keepAlive: true,
        });

        var options = {
            agent: httpsAgent,
        };

        SF_AutoUpdate.FileUtils.evaluateJavascript = function (script) {
            (new Function(script)).call(window);
        }

        SF_AutoUpdate.FileUtils.canExecute = function (fileName) {
            try {
                fs.accessSync(fileName, fs.X_OK);
                return true;
            } catch (e) {
                return false;
            }
        }

        SF_AutoUpdate.FileUtils.canRead = function (fileName) {
            try {
                fs.accessSync(fileName, fs.R_OK);
                return true;
            } catch (e) {
                return false;
            }
        }

        SF_AutoUpdate.FileUtils.canWrite = function (fileName) {
            try {
                fs.accessSync(fileName, fs.W_OK);
                return true;
            } catch (e) {
                return false;
            }
        }

        SF_AutoUpdate.FileUtils.createNewFile = function (fileName) {
            try {
                fs.writeFileSync(fileName, "");
                return true;
            } catch (e) {
                return false;
            }
        }

        SF_AutoUpdate.FileUtils.delete = function (fileName) {
            try {
                fs.unlinkSync(fileName);
                return true;
            } catch (e) {
                return false;
            }
        }

        SF_AutoUpdate.FileUtils.exists = function (fileName) {
            try {
                fs.accessSync(fileName, fs.F_OK);
                return true;
            } catch (e) {
                return false;
            }
        }

        SF_AutoUpdate.FileUtils.getAbsolutePath = function (fileName) {
            return path.resolve(fileName);
        }

        SF_AutoUpdate.FileUtils.getCanonicalPath = function (fileName) {
            return path.resolve(fileName);
        }

        SF_AutoUpdate.FileUtils.getName = function (fileName) {
            return path.basename(fileName);
        }

        SF_AutoUpdate.FileUtils.getParent = function (fileName) {
            return path.dirname(fileName);
        }

        SF_AutoUpdate.FileUtils.getPath = function (fileName) {
            return path.resolve(fileName);
        }

        SF_AutoUpdate.FileUtils.isAbsolute = function (fileName) {
            return path.isAbsolute(fileName);
        }

        SF_AutoUpdate.FileUtils.isDirectory = function (fileName) {
            return fs.statSync(fileName).isDirectory();
        }

        SF_AutoUpdate.FileUtils.isFile = function (fileName) {
            return fs.statSync(fileName).isFile();
        }

        SF_AutoUpdate.FileUtils.lastModified = function (fileName) {
            return fs.statSync(fileName).mtime.getTime();
        }

        SF_AutoUpdate.FileUtils.length = function (fileName) {
            return fs.statSync(fileName).size;
        }

        SF_AutoUpdate.FileUtils.mkdir = function (fileName) {
            try {
                fs.mkdirSync(fileName);
                return true;
            } catch (e) {
                return false;
            }
        }

        SF_AutoUpdate.FileUtils.mkdirs = function (fileName) {
            try {
                fs.mkdirSync(fileName, { recursive: true });
                return true;
            } catch (e) {
                return false;
            }
        }

        SF_AutoUpdate.FileUtils.reanmeTo = function (srcName, dstName) {
            try {
                fs.renameSync(oldFileName, newFileName);
                return true;
            } catch (e) {
                return false;
            }
        }

        SF_AutoUpdate.FileUtils.toString = function (fileName) {
            return path.resolve(fileName);
        }

        SF_AutoUpdate.FileUtils.readTextFile = function (fileName) {
            return fs.readFileSync(fileName, 'utf-8');
        }

        SF_AutoUpdate.FileUtils.writeTextFile = function (fileName, text) {
            return fs.writeFileSync(fileName, text, 'utf-8');
        }

        SF_AutoUpdate.FileUtils.getFileHashHex = function (fileName, algorithm) {
            var hash = crypto.createHash(algorithm || 'SHA512');
            var data = fs.readFileSync(fileName);
            hash.update(data);
            return hash.digest('hex');
        }

        SF_AutoUpdate.UpdateUtils.evaluateJavascript = function (script) {
            (new Function(script)).call(window);
        }

        SF_AutoUpdate.UpdateUtils.downloadFullUrl = function (fileName, url, success, fail) {
            var file = fs.createWriteStream(fileName);
            https.get(url, options, function (response) {
                response.pipe(file);
                file.on('finish', function () {
                    file.close(SF_AutoUpdate.UpdateUtils.evaluateJavascript.bind(SF_AutoUpdate.UpdateUtils, success));
                });
            }).on('error', function (err) {
                SF_AutoUpdate.UpdateUtils.evaluateJavascript.bind(SF_AutoUpdate.UpdateUtils, fail)(err.message);
            });
        }

        SF_AutoUpdate.UpdateUtils.downloadRelativeUrl = function (fileName, url, success, fail) {
            SF_AutoUpdate.UpdateUtils.downloadFullUrl(fileName, SF_AutoUpdate.remoteUrlRoot + url, success, fail);
        }

        SF_AutoUpdate.UpdateUtils.updateFileCompleted = function (isSuccess, needReload) {
            localStorage.setItem(SF_AutoUpdate.localStorageKey, JsonEx.stringify(isSuccess));
            if (isSuccess && needReload) {
                nw.Window.open(`chrome-extension://${chrome.runtime.id}/index.html`, { new_instance: true });
                nw.Window.get().close();
            }
        }

        SF_AutoUpdate.UpdateUtils.getHashInfoJson = function () {
            try {
                return fs.readFileSync(SF_AutoUpdate.localFileInfoName) || SF_AutoUpdate.emptyFileInfoStr;
            } catch (e) {
                return SF_AutoUpdate.emptyFileInfoStr;
            }
        }

        SF_AutoUpdate.UpdateUtils.updateFile = function (fileName, success, fail) {
            SF_AutoUpdate.UpdateUtils.downloadRelativeUrl(fileName, fileName, success, fail);
        }

        SF_AutoUpdate.UpdateUtils.startUpdateFiles = function () {
            localStorage.setItem(SF_AutoUpdate.localStorageKey, 'false');
        }

    }

    //=============================================================================
    // Scene_AutoUpdate
    //=============================================================================

    function Scene_AutoUpdate() {
        this.initialize.apply(this, arguments);
    }
    window.Scene_AutoUpdate = Scene_AutoUpdate;
    SF_AutoUpdate.Scene_AutoUpdate = Scene_AutoUpdate;

    Scene_AutoUpdate.prototype = Object.create(Scene_Base.prototype);
    Scene_AutoUpdate.prototype.constructor = Scene_AutoUpdate;

    Scene_AutoUpdate.prototype.initialize = function () {
        Scene_Base.prototype.initialize.call(this);
        this._localFileInfo = JsonEx.parse(UpdateUtils.getHashInfoJson());
        this._remoteFileInfo = {};

        this._updateFileList = [];
        this._updateFileIndex = 0;
        this._updateFileCount = 0;
        this._updateFile = {};

        this._updateSuccess = false;

        this._deleteFileList = [];

        this._status = "completed"; // "working", "completed"
        this._job = ""; // "fetch remote file info", "compare file info", "delete file", "update file"
        this._nextJob = "fetched remote file info";

        this._compareWorker = new Worker(SF_AutoUpdate.workerFileName);
        this._compareWorker.onmessage = this._onCompareWorkerMessage.bind(this);
    };

    Scene_AutoUpdate.prototype.create = function () {
        Scene_Base.prototype.create.call(this);
    }

    Scene_AutoUpdate.prototype.start = function () {
        Scene_Base.prototype.start.call(this);
    }

    Scene_AutoUpdate.prototype.update = function () {
        Scene_Base.prototype.update.call(this);
        this.updateJob();
        this.updateLoading();
    }

    Scene_AutoUpdate.prototype.updateLoading = function () {
        console.log(this._job, this._status);
    }

    Scene_AutoUpdate.prototype.updateJob = function () {
        if (this._status === "working") { return; }
        if (this._nextJob === "") {
            CallBack.clear();
            SceneManager.pop();
        }
        this._job = this._nextJob;
        this._status = "working";
        switch (this._job) {
            case "fetched remote file info":
                this.fetchRemoteFileInfo();
                this._nextJob = "compare file info";
                break;
            case "compare file info":
                this.compareFileInfo();
                this._nextJob = "delete file";
                break;
            case "delete file":
                this.deleteFile();
                this._nextJob = "update file";
                break;
            case "update file":
                this.updateFile();
                this._nextJob = "update completed";
                break;
            case "update completed":
                this._status = "completed";
                this._nextJob = "";
                FileUtils.writeTextFile(SF_AutoUpdate.localFileInfoName, JsonEx.stringify(this._remoteFileInfo));
                UpdateUtils.updateFileCompleted(this._updateSuccess, this._updateFileCount > 0);
                break;
        }
    }

    Scene_AutoUpdate.prototype.fetchRemoteFileInfo = function () {
        var success = (function () {
            this._remoteFileInfo = JsonEx.parse(FileUtils.readTextFile(SF_AutoUpdate.remoteFileInfoName));
            this._status = "completed";
        }).bind(this);

        var fail = (function () {
            this._status = "completed";
            this._nextJob = "";
        }).bind(this);

        var callBacks = CallBack.registerOneTimeList([success, fail]);

        UpdateUtils.downloadRelativeUrl(
            SF_AutoUpdate.remoteFileInfoName,
            SF_AutoUpdate.remoteFileInfoName,
            callBacks[0],
            callBacks[1]
        );
    }

    Scene_AutoUpdate.prototype.compareFileInfo = function () {
        this._compareWorker.postMessage({
            "command": "compare",
            "local_file_info": this._localFileInfo,
            "remote_file_info": this._remoteFileInfo
        });
    }

    Scene_AutoUpdate.prototype._onCompareWorkerMessage = function (e) {
        var result = e.data;
        if (result.command === 'delete') {
            this._deleteFileList = this._deleteFileList.concat(result.file_list);
        } else if (result.command === 'update') {
            this._updateFileList = this._updateFileList.concat(result.file_list);
        } else {
            this._status = "completed";
        }
    }

    Scene_AutoUpdate.prototype.deleteFile = function () {
        UpdateUtils.startUpdateFiles();

        this._deleteFileList.forEach(function (file_info) {
            FileUtils.delete(file_info.file_name)
        });

        this._status = "completed";
    }

    Scene_AutoUpdate.prototype.updateFile = function () {
        this._updateFileIndex = 0;
        this._updateFileCount = this._updateFileList.length;
        if (this._updateFileCount === 0) {
            this._status = "completed";
            return;
        }
        this._updateFile = this._updateFileList[this._updateFileIndex];
        this.updateFileNext();
    }

    Scene_AutoUpdate.prototype.updateFileNext = function () {
        var success = (function () {
            this._updateFileIndex++;
            if (this._updateFileIndex >= this._updateFileCount) {
                this._status = "completed";
                this._updateSuccess = true;
            } else {
                this._updateFile = this._updateFileList[this._updateFileIndex];
                this.updateFileNext();
            }
        }).bind(this);

        var fail = (function () {
            // auto try again
            this.updateFileNext();
        }).bind(this);

        var file = this._updateFile;
        if (file.is_dir) {
            success();
            return;
        }

        if (!FileUtils.exists(FileUtils.getParent(file.file_name))) {
            FileUtils.mkdirs(FileUtils.getParent(file.file_name));
        }

        var callBacks = CallBack.registerOneTimeList([success, fail]);

        UpdateUtils.downloadRelativeUrl(
            file.file_name,
            file.file_name,
            callBacks[0],
            callBacks[1]
        );
    }
    //=============================================================================
    // SceneManager
    //=============================================================================

    SF_AutoUpdate.SceneManager_initialize = SceneManager.initialize;
    SceneManager.initialize = function () {
        SF_AutoUpdate.SceneManager_initialize.call(this);
        this.addSceneBefore(Scene_AutoUpdate, Scene_Title);
    }

})();