Function fetchOneBotForwardContent

src/server.js:5588–5630

(forwardId)

}

async function fetchOneBotForwardContent(forwardId) {
  const response = await fetch(`${oneBotApiBase}/get_forward_msg`, {
    method: "POST",
    headers: { "content-type": "application/json" },
    body: JSON.stringify({ id: String(forwardId) })
  });
  const body = await response.json().catch(() => ({}));
  const messages = Array.isArray(body.data?.messages)
    ? body.data.messages
    : Array.isArray(body.data)
      ? body.data
      : [];
  if (!response.ok || body.status !== "ok" || messages.length === 0) {
    throw new Error(`Unable to fetch forward QQ message ${forwardId}`);
  }

  const lines = [];
  const images = [];
  for (const node of messages) {
    const senderName = node?.sender?.card || node?.sender?.nickname || node?.nickname || "群友";
    const segments = Array.isArray(node?.content)
      ? node.content
      : Array.isArray(node?.message)
        ? node.message
        : Array.isArray(node?.data?.content)
          ? node.data.content
          : [];
    const text = segments
      .filter((segment) => segment?.type === "text")
      .map((segment) => segment.data?.text ?? "")
      .join("")
      .trim();
    const nodeImages = extractOneBotImageInputs({ message: segments });
    if (text) lines.push(`${senderName}：${text}`);
    else if (nodeImages.length > 0) lines.push(`${senderName}：[图片]`);
    images.push(...nodeImages);
  }

  return {
    text: lines.join("\n").trim(),
    images: dedupeQqImages(images)
  };
}

function dedupeQqImages(images) {
  const seen = new Set();