Function sendTargetFeedback

bs/bs.ts:646–709

(options: {
  client: any;
  replyMessage: Api.Message;
  successes: ForwardSuccess[];
  sourceEntity: any;
  originalMessageIds: number[];
})

}

async function sendTargetFeedback(options: {
  client: any;
  replyMessage: Api.Message;
  successes: ForwardSuccess[];
  sourceEntity: any;
  originalMessageIds: number[];
}) {
  const { client, replyMessage, successes, sourceEntity, originalMessageIds } =
    options;
  if (!successes.length) return;

  const originEntity = sourceEntity ?? replyMessage.peerId;
  const sourceNameRaw = getEntityDisplayName(originEntity) ?? "来源对话";
  const sourceLink = buildEntityLink(originEntity);
  const sourceName = escapeHtml(sourceNameRaw);
  const sourceText = sourceLink
    ? `<a href="${escapeAttribute(sourceLink)}">${sourceName}</a>`
    : sourceName;

  for (const success of successes) {
    const forwardedMessages = success.forwarded;
    if (!forwardedMessages || forwardedMessages.length === 0) continue;
    const firstForwarded = forwardedMessages[0];
    if (!firstForwarded || typeof firstForwarded.id !== "number") continue;

    const forwardedLinks = buildForwardedLinkTags(
      success.entity,
      forwardedMessages
    );
    const originalLinks = buildMessageLinkTagsByIds(
      originEntity,
      (originalMessageIds || []).slice(0, forwardedMessages.length)
    );

    const textParts: string[] = [];
    textParts.push(`来源：${sourceText}`);
    if (originalLinks.length) {
      textParts.push(`\n原消息：${originalLinks.join(" ")}`);
    }
    if (forwardedLinks.length) {
      textParts.push(`\n消息：${forwardedLinks.join(" ")}`);
    }

    const replyToMsgId = firstForwarded.id;
    const topMsgId = success.target.topicId
      ? toInt(success.target.topicId) ?? undefined
      : undefined;

    try {
      await client.sendMessage(success.entity, {
        message: textParts.filter(Boolean).join("<br>"),
        parseMode: "html",
        linkPreview: false,
        replyTo: replyToMsgId,
        topMsgId,
      });
    } catch (error) {
      console.warn(