Function sendSourceFeedback

bs/bs.ts:592–644

(options: {
  msg: Api.Message;
  client: any;
  fromPeer: any;
  replyMessage: Api.Message;
  successes: ForwardSuccess[];
  messageCount: number;
})

}

async function sendSourceFeedback(options: {
  msg: Api.Message;
  client: any;
  fromPeer: any;
  replyMessage: Api.Message;
  successes: ForwardSuccess[];
  messageCount: number;
}) {
  const { msg, client, fromPeer, replyMessage, successes, messageCount } =
    options;
  if (!successes.length) return;

  const responses: string[] = [];

  for (const success of successes) {
    const forwardedCount = success.forwarded?.filter(
      (item) => item && typeof item.id === "number"
    ).length;
    const countText =
      forwardedCount && forwardedCount > 0 ? forwardedCount : messageCount;

    const targetNameRaw =
      getEntityDisplayName(success.entity) ??
      (typeof success.target.target === "string"
        ? success.target.target
        : "目标");
    const targetName = escapeHtml(targetNameRaw);
    const targetLink = buildEntityLink(success.entity);
    const targetHtml = targetLink
      ? `<a href="${escapeAttribute(targetLink)}">${targetName}</a>`
      : targetName;

    responses.push(`${countText} 条消息已被保送到 ${targetHtml}`);
  }

  if (!responses.length) return;

  try {
    // await client.sendMessage(fromPeer, {
    //   message: `亲爱的被观察者 您的 ${responses.join("\n")}`,
    //   parseMode: "html",
    //   linkPreview: false,
    //   replyTo: buildReplyToForMessage(replyMessage),
    // });
    await msg.edit({
      text: `亲爱的被观察者 您的 ${responses.join("\n")}`,
      parseMode: "html",
      linkPreview: false,
    });
  } catch (error) {
    console.warn("[bs] 回复原消息失败", error);
  }
}

async function sendTargetFeedback(options: {
  client: any;