Class ParseHubPlugin

parsehub/parsehub.ts:374–478

      Date.now() - lastProgressActivity >= RESULT_IDLE_MS * 3 &&
      Date.now() - lastFinalActivity >= RESULT_IDLE_MS
    ) {
      break;
    }
  }

  if (finalMessages.size === 0) {
    return { lastId, forwarded: false, reason: "timeout" };
  }

  const sortedMessages = Array.from(finalMessages.values()).sort(
    (a, b) => a.id - b.id,
  );

  let forwarded = false;
  const fallbackTexts: string[] = [];

  for (let i = 0; i < sortedMessages.length; i += 100) {
    const chunk = sortedMessages.slice(i, i + 100);
    const ids = chunk.map((m) => m.id);

    try {
      await forwardChunk(client, originMsg.peerId, ids);
      forwarded = true;
    } catch {
      const snippet = chunk
        .map((m) => m.message?.trim())
        .filter(Boolean)
        .join("\n\n");
      fallbackTexts.push(
        snippet.length
          ? snippet
          : `⚠️ 未能转发 @${BOT_USERNAME} 的多媒体结果，请前往私聊机器人查看。`,
      );
    }
  }

  if (!forwarded && fallbackTexts.length) {
    try {
      await client.sendMessage(originMsg.peerId, {
        message: `📨 @${BOT_USERNAME} 返回内容：\n\n${fallbackTexts.join("\n\n")}`,
        replyTo: originMsg.id,
      });
      forwarded = true;
    } catch {}
  }

  return {
    lastId,
    forwarded,
    reason: forwarded ? undefined : "timeout",
  };
}

class ParseHubPlugin extends Plugin {

  description: string = `\n${pluginName}\n\n${helpText}`;
  cmdHandlers: Record<string, (msg: Api.Message) => Promise<void>> = {
    parsehub: async (msg: Api.Message) => {