Function forwardToTarget

bs/bs.ts:443–531

(options: {
  client: any;
  fromPeer: any;
  target: TargetRecord;
  messageIds: number[];
})

}

async function forwardToTarget(options: {
  client: any;
  fromPeer: any;
  target: TargetRecord;
  messageIds: number[];
}) {
  const { client, fromPeer, target, messageIds } = options;
  const lookup = getTargetLookup(target);
  let entity: any;
  try {
    entity = await client.getEntity(lookup as any);
  } catch (error) {
    console.warn(`[bs] 获取对话 ${target.target} 失败`, error);
    return { success: false, error: getRpcErrorMessage(error) };
  }

  if (!entity) return { success: false, error: "未找到目标" };

  let updated = false;
  const resolvedId = toStrInt(entity.id);
  if (resolvedId && target.chatId !== resolvedId) {
    target.chatId = resolvedId;
    updated = true;
  }

  if (
    !target.display ||
    target.display === `<code>${escapeHtml(target.target)}</code>`
  ) {
    const info = await formatEntity(entity).catch(() => null);
    if (info?.display) {
      target.display = info.display;
      updated = true;
    }
  }

  let retryFlood = false;
  const toPeer = await client.getInputEntity(entity);

  while (true) {
    try {
      const result = await client.invoke(
        new Api.messages.ForwardMessages({
          fromPeer,
          id: messageIds,
          toPeer,
          ...(target.topicId
            ? { topMsgId: toInt(target.topicId) ?? undefined }
            : {}),
        })
      );
      return {
        success: true,
        entity,
        forwarded: extractForwardedMessages(result),
        updated,
      };
    } catch (error) {