Function forwardGroupMessages

shift/shift.ts:608–640

(
  client: TelegramClient,
  fromChatId: number,
  toChatId: number,
  messageIds: number[],
  options?: { silent?: boolean; replyTo?: number }
)

      new Api.messages.ForwardMessages({
        fromPeer: fromEntity,
        id: messageIds,
        toPeer: toEntity,
        silent: options?.silent,
        ...(options?.replyTo ? { topMsgId: options.replyTo } : {}),
      })
    );
    console.log(
      `[SHIFT] 组转发成功: ${fromChatId} -> ${toChatId}, msgs=${messageIds.join(
        ","
      )}`
    );
  } catch (error) {
    console.error(
      `[SHIFT] 组转发失败: ${fromChatId} -> ${toChatId}, msgs=${messageIds.join(
        ","
      )}`,
      error
    );
  }
}

function enqueueGroupMessage(
  message: any,
  sourceId: number,
  targetId: number,
  options?: { silent?: boolean; replyTo?: number },
  shouldForward?: boolean
): void {
  const key = getGroupKey(message);
  if (!key) return;
  const existed = groupBuffers.get(key) || {
    messages: [],
    timer: null,
    sourceId,
    targetId,
    options,