Class SubStorePlugin

sub/sub.ts:147–555

• <code>${mainPrefix}sub restore</code> - 恢复`;

class SubStorePlugin extends Plugin {

  description = `Sub-Store 管理\n\n${help}`;

  cmdHandlers: Record<string, (msg: Api.Message) => Promise<void>> = {
    sub: async (msg) => {
      const parts = msg.text?.split(/\s+/) || [];
      const cmd = (parts[1] || "help").toLowerCase();
      const arg = parts[2];

      // // 检查是否在收藏夹
      // if (!(await isSavedMessages(msg))) {
      //   await msg.edit({ text: "⚠️ 此插件仅限在「收藏夹」中使用" });
      //   return;
      // }
      if ((msg as any).isGroup || (msg as any).isChannel) {
        await msg.edit({
          text: "❌ 为保护用户隐私，禁止在公共对话环境使用",
          parseMode: "html",
        });
        return;
      }

      // 检查root权限
      if (
        os.platform() !== "linux" ||
        !process.getuid ||
        process.getuid() !== 0
      ) {
        await msg.edit({ text: "❌ 需要Linux root权限" });
        return;
      }

      try {
        switch (cmd) {
          case "help":
            await msg.edit({ text: help, parseMode: "html" });
            break;

          case "up":
            // 检查Docker完整性
            await msg.edit({ text: "🔍 检查Docker完整性..." });
            const dockerCheck = await checkDockerIntegrity();
            if (!dockerCheck.valid) {
              await msg.edit({
                text: `❌ Docker检查失败: ${dockerCheck.error}\n\n🔧 请先执行: <code>${mainPrefix}sub fix-docker</code>`,
                parseMode: "html",
              });
              return;
            }

            const secret = crypto.randomBytes(16).toString("hex");

            // 分步骤部署，每步单独执行和检查
            try {
              await msg.edit({ text: "✅ Docker检查通过\n🛠 创建目录..." });
              await sh("mkdir -p /root/sub-store /root/sub-store-data");