Method resolveParticipantFromContext

aban/aban.ts:283–357

(
    client: TelegramClient,
    message: Api.Message,
    userId: number,
    knownEntity?: any
  )

  private static async resolveParticipantFromContext(
    client: TelegramClient,
    message: Api.Message,
    userId: number,
    knownEntity?: any
  ): Promise<any | undefined> {
    const chat = (message as any).peerId;
    if (!chat) {
      return undefined;
    }

    if ((message as any).isChannel) {
      try {
        // 优先 getParticipant(accessHash=0)：目标是成员/可解析时一次成功，且不要求“当前页”
        const viaPart = await this.resolveUserViaGetParticipant(client, chat, userId);
        if (viaPart) return viaPart;

        let offset = 0;
        const limit = 200;
        for (let i = 0; i < 5; i++) {
          const res: any = await client.invoke(
            new Api.channels.GetParticipants({
              channel: chat,
              filter: new Api.ChannelParticipantsRecent(),
              offset,
              limit,
              hash: 0 as any,
            })
          );

          const participants: any[] = res?.participants || [];
          const users: any[] = res?.users || [];
          const matchedUser = users.find((u) => Number(u?.id) === userId);
          if (matchedUser) {
            const input = await this.safeGetInputEntity(client, matchedUser);
            if (input) {
              return input;
            }
          }

          if (!participants.length) break;
          offset += participants.length;
        }
      } catch {
        return undefined;
      }
    }

    if ((message as any).isGroup) {
      try {
        const peer: any = knownEntity || await this.safeGetEntity(client, chat);
        const chatId = Number(peer?.chatId ?? peer?.id ?? (chat as any)?.chatId);
        if (!Number.isFinite(chatId)) {
          return undefined;
        }

        const full: any = await client.invoke(
          new Api.messages.GetFullChat({
            chatId: bigInt(chatId),