Class BsPlugin

bs/bs.ts:713–1091

const helpResponse = `🛰️ <b>保送插件</b>\n\n${escapeHtml(helpText)}`;

class BsPlugin extends Plugin {

  description: string = `保送被回复的消息至指定目标\n\n${helpText}`;

  cmdHandlers: Record<string, (msg: Api.Message) => Promise<void>> = {
    [pluginName]: async (msg: Api.Message) => {
      const client = await getGlobalClient();
      if (!client) {
        await msg.edit({ text: "❌ <b>客户端未初始化</b>", parseMode: "html" });
        return;
      }

      const text = msg.message || msg.text || "";
      const lines = text.trim().split(/\r?\n/);
      const head = lines[0] || "";
      const parts = head.trim().split(/\s+/).filter(Boolean);
      const args = parts.slice(1);
      const command = (args[0] || "").toLowerCase();

      if (!command || /^\d+$/.test(command)) {
        const count = command ? Number(command) : 1;
        if (!count || count <= 0) {
          await msg.edit({
            text: `❌ <b>消息数必须是正整数</b>\n示例：<code>${commandName} 3</code>`,
            parseMode: "html",
            linkPreview: false,
          });
          return;
        }

        if (!msg.isReply) {
          await msg.edit({
            text: "❌ <b>请先回复需要保送的消息</b>",
            parseMode: "html",
          });
          return;
        }

        const replyMessage = await safeGetReplyMessage(msg);
        if (!replyMessage) {
          await msg.edit({
            text: "❌ <b>无法获取被回复的消息</b>",
            parseMode: "html",
          });
          return;
        }

        await msg.edit({
          text: "🚚 <b>正在保送消息...</b>",
          parseMode: "html",
        });

        const peerForFetch = msg.peerId ?? replyMessage.peerId;
        const { messageIds } = await collectMessages(
          client,
          peerForFetch,
          replyMessage.id,
          count