Method resolveUserFromReplyOrArg

tmp_admin/tmp_admin.ts:918–1000

(
    msg: Api.Message,
    channel: any,
    arg?: string
  )

    const client = await getGlobalClient();
    if (!client) throw new Error("Telegram 客户端未初始化");

    if (messageHasReply(msg)) {
      const reply = await safeGetReplyMessage(msg);
      if (!reply) return {};

      let sender: any;
      try {
        sender = await (reply as any).getSender?.();
      } catch {
        sender = undefined;
      }

      if (sender instanceof Api.User) {
        const input = await client.getInputEntity(sender.id);
        return { id: Number(sender.id), entity: input };
      }

      const fromId: any = reply.fromId as any;
      const uid = Number(fromId?.userId);
      if (!uid) return {};

      try {
        const input = await client.getInputEntity(uid);
        const full = await client.getEntity(input);
        if (full instanceof Api.User) {
          return { id: Number(full.id), entity: input };
        }
      } catch {
        return {};
      }
    }

    if (!arg) return {};

    try {
      const full = await client.getEntity(arg as any);
      if (!(full instanceof Api.User)) return {};
      const input = await client.getInputEntity(full.id);
      return { id: Number(full.id), entity: input };
    } catch {
      const numericId = Number(arg);
      if (!Number.isFinite(numericId)) return {};

      try {
        let offset = 0;
        const limit = 200;
        for (let i = 0; i < 5; i++) {
          const result: any = await client.invoke(
            new Api.channels.GetParticipants({
              channel,
              filter: new Api.ChannelParticipantsRecent(),
              offset,
              limit,
              hash: 0 as any,
            })
          );
          const participants: any[] = result?.participants || [];
          const users: any[] = result?.users || [];