rc-plugin/apps/update.js

// 主库
import Version from "../model/version.js";
import config from "../model/index.js";
import puppeteer from "../../../lib/puppeteer/puppeteer.js";

import { exec, execSync } from "node:child_process";

const _path = process.cwd();

/**
 * 处理插件更新
 */
export class update extends plugin {
    constructor() {
        super({
            name: "更新插件",
            dsc: "更新插件代码",
            event: "message",
            priority: 4000,
            rule: [
                {
                    reg: "^#*R(插件)?版本$",
                    fnc: "version",
                },
                {
                    /** 命令正则匹配 */
                    reg: "^#(R更新|R强制更新)$",
                    /** 执行方法 */
                    fnc: "rconsoleUpdate",
                },
            ],
        });

        this.versionData = config.getConfig("version");
    }

    /**
     * rule - 插件版本信息
     */
    async version() {
        const data = await new Version(this.e).getData(this.versionData.slice(0, 3));
        let img = await puppeteer.screenshot("version", data);
        this.e.reply(img);
    }

    /**
     *
     * @param e oicq传递的事件参数e
     */
    async rconsoleUpdate(e) {
        if (!this.e.isMaster) {
            await this.e.reply("您无权操作");
            return true;
        }

        let isForce = !!this.e.msg.includes("强制");

        let command = "git pull";

        if (isForce) {
            command = "git checkout . && git pull";
            await this.e.reply("正在执行强制更新操作，请稍等");
        } else {
            await this.e.reply("正在执行更新操作，请稍等");
        }
        const th = this;
        exec(
            command,
            { cwd: `${_path}/plugins/rconsole-plugin/` },
            async function (error, stdout, stderr) {
                if (error) {
                    let isChanges = error
                        .toString()
                        .includes(
                            "Your local changes to the following files would be overwritten by merge"
                        );

                    let isNetwork = error.toString().includes("fatal: unable to access");

                    if (isChanges) {
                        //git stash && git pull && git stash pop stash@{0}
                        //需要设置email和username，暂不做处理
                        await me.e.reply(
                            "失败！\nError code: " +
                                error.code +
                                "\n" +
                                error.stack +
                                "\n\n本地代码与远程代码存在冲突,上面报错信息中包含冲突文件名称及路径，请尝试处理冲突\n如果不想保存本地修改请使用【#强制更新】\n(注意：强制更新命令会忽略所有本地对R插件本身文件的修改，本地修改均不会保存，请注意备份)"
                        );
                    } else if (isNetwork) {
                        await e.reply(
                            "失败！\nError code: " +
                                error.code +
                                "\n" +
                                error.stack +
                                "\n\n可能是网络问题，请关闭加速器之类的网络工具，或请过一会尝试。"
                        );
                    } else {
                        await e.reply(
                            "失败！\nError code: " +
                                error.code +
                                "\n" +
                                error.stack +
                                "\n\n出错了。请尝试处理错误"
                        );
                    }
                } else {
                    if (/Already up to date/.test(stdout)) {
                        e.reply("目前已经是最新了~");
                        return true;
                    }
                    await th.restartApp();
                }
            }
        );
    }

    async restartApp() {
        if (!this.e.isMaster) {
            await this.e.reply("您无权操作");
            return true;
        }
        await this.e.reply("开始执行重启，请稍等...");
        Bot.logger.mark("开始执行重启，请稍等...");

        let data = JSON.stringify({
            isGroup: !!this.e.isGroup,
            id: this.e.isGroup ? this.e.group_id : this.e.user_id,
        });

        try {
            await redis.set("Yunzai:rconsole:restart", data, { EX: 120 });

            let cm = `npm run start`;
            if (process.argv[1].includes("pm2")) {
                cm = `npm run restart`;
            }

            exec(cm, async (error, stdout, stderr) => {
                if (error) {
                    await redis.del(`Yunzai:rconsole:restart`);
                    await this.e.reply(`操作失败！\n${error.stack}`);
                    Bot.logger.error(`重启失败\n${error.stack}`);
                } else if (stdout) {
                    Bot.logger.mark("重启成功，运行已转为后台，查看日志请用命令：npm run log");
                    Bot.logger.mark("停止后台运行命令：npm stop");
                    process.exit();
                }
            });
        } catch (error) {
            redis.del(`Yunzai:rconsole:restart`);
            await this.e.reply(`操作失败！\n${error.stack}`);
        }

        return true;
    }
}