ms/packages/plugins/src/MiaoScriptPackageManager.ts

import { plugin as pluginApi, task, server } from '@ms/api'

import * as fs from '@ms/common/dist/fs'
import { inject } from '@ms/container';
import { interfaces, plugin, cmd, tab } from '@ms/plugin'

let help = [
    '§6========= §6[§aMiaoScriptPackageManager§6] 帮助 §aBy §b喵♂呜 §6=========',
    '§6/mpm §ainstall §e<插件名称> §6- §3安装插件',
    '§6/mpm §alist [install]§6- §3列出仓库插件[已安装的插件]',
    '§6/mpm §aupdate §e<插件名称> §6- §3更新插件(无插件名称则更新源)',
    '§6/mpm §aupgrade §e<插件名称> §6- §3及时更新插件(update需要重启生效)',
    '§6/mpm §areload §e<插件名称> §6- §3重载插件(无插件名称则重载自身)',
    '§6/mpm §arun §e<JS代码> §6- §3运行JS代码',
    '§6/mpm §acreate §e<插件名称> [作者] [版本] [主命令] §6- §3通过模板创建名称',
    '§6/mpm §crestart §6- §4重启MiaoScript脚本引擎'
];

@plugin({ name: 'MiaoScriptPackageManager', prefix: 'PM', version: '1.0.0', author: 'MiaoWoo', source: __filename })
export class MiaoScriptPackageManager extends interfaces.Plugin {
    @inject(pluginApi.PluginManager)
    private pluginManager: pluginApi.PluginManager;
    @inject(task.TaskManager)
    private taskManager: task.TaskManager;
    @inject(server.ServerType)
    private serverType: string;
    @inject(server.Server)
    private server: server.Server

    private packageCache: any[] = [];
    private packageNameCache: any[] = [];

    load() {
        this.taskManager.create(() => {
        }).async().submit();
    }

    @cmd()
    mpm(sender: any, command: string, args: string[]) {
        this.taskManager.create(() => this.main(sender, command, args)).async().submit();
    }

    main(sender: any, command: string, args: string[]) {
        if (!args[0] || args[1] === 'help') {
            this.logger.sender(sender, help);
            return;
        }
        switch (args[0]) {
            case "list":
                if (args[1]) {
                    this.logger.sender(sender, '§6当前 §bMiaoScript §6已安装下列插件:');
                    this.pluginManager.getPlugins().forEach((plugin) => {
                        var desc = plugin.description;
                        this.logger.sender(sender, `§6插件名称: §b${desc.name} §6版本: §a${desc.version || '1.0'} §6作者: §3${desc.author || '未知'}`)
                    })
                } else {
                    this.logger.sender(sender, '§6当前 §bMiaoScriptPackageCenter §6中存在下列插件:');
                    for (var pkgName in this.packageCache) {
                        var pkg = this.packageCache[pkgName];
                        // console.sender(sender, '§6插件名称: §b%s §6版本: §a%s §6作者: §3%s'.format(pkg.name, pkg.version || '1.0', pkg.author || '未知'))
                    }
                }
                break;
            case "install":
                // if (args.length > 1) {
                //     download(sender, args[1]);
                // } else {
                //     console.sender(sender, '§c请输入插件名称!')
                // }
                break;
            case "update":
                // if (args.length > 1) {
                //     update(sender, args[1]);
                // } else {
                //     load();
                //     console.sender(sender, "§a仓库缓存刷新成功 共存在 §b" + Object.keys(packageCache).length + " §a个插件!")
                // }
                break;
            case "upgrade":
                if (args[3] === "engine") {
                    fs.del(fs.concat(root, '', ''))
                }
                break;
            case "delete":
                // if (args.length > 1) {
                //     del(sender, args[1]);
                // } else {
                //     console.sender(sender, '§c请输入插件名称!')
                // }
                break;
            case "reload":
                if (args.length > 1) {
                    var pname = args[1];
                    if (!this.pluginManager.getPlugins().has(pname)) {
                        this.logger.sender(sender, `§6插件 §b${pname} §c不存在!`)
                        return
                    }
                    this.pluginManager.reload(pname);
                    this.logger.sender(sender, `§6插件 §b${pname} §a重载完成!`)
                }
                break;
            case "restart":
                if (this.serverType === "sponge") {
                    setTimeout(() => this.server.dispatchConsoleCommand('sponge plugins reload'), 0)
                    return
                }
                try {
                    this.logger.sender(sender, '§6Reloading §3MiaoScript Engine...');
                    ScriptEngineContextHolder.disableEngine();
                    ScriptEngineContextHolder.enableEngine();
                    this.logger.sender(sender, '§3MiaoScript Engine §6Reload §aSuccessful...');
                } catch (ex) {
                    this.logger.sender(sender, "§3MiaoScript Engine §6Reload §cError! ERR: " + ex);
                    this.logger.sender(sender, this.logger.stack(ex));
                }
                break;
            case "run":
                args.shift();
                try {
                    var script = args.join(' ');
                    this.logger.sender(sender, '§b运行脚本:§r', script);
                    this.logger.sender(sender, '§a返回结果:§r', eval(script) || '§4没有返回结果!');
                } catch (ex) {
                    this.logger.sender(sender, this.logger.stack(ex));
                }
                break;
            case "create":
                this.logger.sender(sender, `§4当前暂不支持生成插件模板!`);
                // var name = args[1];
                // if (!name) {
                //     this.logger.sender(sender, '§4参数错误 /mpm create <插件名称> [作者] [版本] [主命令]');
                //     return;
                // }
                // // var result = template.create(http.get(self.config.template)).render({
                // //     name: name,
                // //     author: args[2] || 'MiaoWoo',
                // //     version: args[3] || '1.0',
                // //     command: args[4] || name.toLowerCase(),
                // // });
                // // fs.save(fs.file(__dirname, name + '.js'), result);
                // this.logger.sender(sender, '§6插件 §a' + name + ' §6已生成到插件目录...');
                break;
            default:
                this.logger.sender(sender, help);
                break;
        }
    }

    @tab()
    tabmpm(sender, command, args) {
        if (args.length === 1) return ['list', 'install', 'update', 'upgrade', 'reload', 'restart', 'run', 'help', 'create'];
        if (args.length > 1) {
            switch (args[0]) {
                case "install":
                    return this.packageNameCache;
                case "update":
                case "upgrade":
                case "reload":
                    return [...this.pluginManager.getPlugins().keys()];
            }
        }
    }
}