Function fetchOneBotMessage

src/server.js:5547–5586

(messageId, selfId)

}

async function fetchOneBotMessage(messageId, selfId) {
  if (!messageId) return null;
  const response = await fetch(`${oneBotApiBase}/get_msg`, {
    method: "POST",
    headers: { "content-type": "application/json" },
    body: JSON.stringify({ message_id: Number(messageId) })
  });
  const body = await response.json().catch(() => ({}));
  if (!response.ok || body.status !== "ok" || !body.data) {
    throw new Error(`Unable to fetch quoted QQ message ${messageId}`);
  }

  const data = body.data;
  const senderId = data.user_id == null ? undefined : String(data.user_id);
  const segments = Array.isArray(data.message) ? data.message : [];
  const forwardSegment = segments.find((segment) => segment?.type === "forward");
  const textFromSegments = segments
    .filter((segment) => segment?.type === "text")
    .map((segment) => segment.data?.text ?? "")
    .join("")
    .trim();
  const forwardContext = forwardSegment?.data?.id
    ? await fetchOneBotForwardContent(forwardSegment.data.id).catch(() => null)
    : null;
  const images = dedupeQqImages([
    ...extractOneBotImageInputs(data),
    ...((forwardContext?.images) || [])
  ]);
  return {
    messageId: String(data.message_id ?? messageId),
    senderId,
    senderName: data.sender?.card || data.sender?.nickname || senderId || "群友",
    text: forwardContext?.text
      ? `[合并转发]\n${forwardContext.text}`
      : (data.raw_message || textFromSegments),
    images,
    isSelf: selfId != null && senderId === String(selfId),
    raw: data
  };
}

async function fetchOneBotForwardContent(forwardId) {
  const response = await fetch(`${oneBotApiBase}/get_forward_msg`, {