Function shiftForwardMessage

shift/shift.ts:2216–2264

(
  client: TelegramClient,
  fromChatId: number,
  toChatId: number,
  messageId: number,
  depth: number = 0,
  options?: any
)

}

// Get chat ID from message
function getChatIdFromMessage(message: any, isEdited?: boolean): number | null {
  if (
    isEdited &&
    message.peerId?.channelId &&
    message.fwdFrom?.channelPost &&
    message.fwdFrom?.fromId?.channelId
  ) {
    message.id = message.fwdFrom?.channelPost;
    const channelId =
      message.fwdFrom.fromId.channelId.value ||
      message.fwdFrom.fromId.channelId;
    return ensureChannelId(channelId);
  }
  if (message.chatId) {
    return Number(message.chatId);
  }
  if (message.peerId) {
    if (message.peerId.channelId) {
      return ensureChannelId(message.peerId.channelId);
    } else if (message.peerId.chatId) {
      return -Number(message.peerId.chatId);
    } else if (message.peerId.userId) {
      return Number(message.peerId.userId);
    }
  }

  return null;
}

// Forward message using universal access hash handler
async function shiftForwardMessage(
  client: TelegramClient,
  fromChatId: number,
  toChatId: number,
  messageId: number,
  depth: number = 0,
  options?: any
): Promise<void> {
  if (depth > 5) {
    console.log(`[SHIFT] 转发深度超限: ${depth}`);
    return;
  }

  try {
    // 使用通用的安全转发函数
    await safeForwardMessage(client, fromChatId, toChatId, messageId, {
      maxRetries: 3,
      silent: options?.silent,
      replyTo: options?.replyTo,
    });