S"jZ2ddlZddlZddlZddlmZmZmZddlmZddl m Z ddl m Z dZ d ZiZd ZGd d ZeGd deZy)N) EventBuilder EventCommonname_inner_event)utils)types) SenderGetterdg?c"eZdZdZdZdZdZy) AlbumHacka When receiving an album from a different data-center, they will come in separate `Updates`, so we need to temporarily remember them for a while and only after produce the event. Of course events are not designed for this kind of wizardy, so this is a dirty hack that gets the job done. When cleaning up the code base we may want to figure out a better way to do this, or just leave the album problem to the users; the update handling code is bad enough as it is. ctj||_||_|jj t z|_|jj|jyN) weakrefref_client_eventlooptime _HACK_DELAY_due create_task deliver_event)selfclientevents V/var/www/api.ozpay.ru/ozpay/venv/lib/python3.12/site-packages/telethon/events/album.py__init__zAlbumHack.__init__#sO{{6*  KK$$&4   2 2 45c|j}|rL|jjj||jj t z|_yyr)rrmessagesextendrrrr)rr"rs rr#zAlbumHack.extend,sF  KK ' ' 1 ((*[8DI r cK |j}|y|j|jjz }|dkr$|j |j d{y~t j|d{7$7w)Nr)rrrr_dispatch_eventrasynciosleep)rrdiffs rrzAlbumHack.deliver_event2s\\^F~99v{{//11Dqy,,T[[999--% % %: &s$AB !B"B BB B N)__name__ __module__ __qualname____doc__rr#rr rrrs 69 &r rcbeZdZdZ d dddfd Zed dZfdZGdd ee Z xZ S) Albuma Occurs whenever you receive an album. This event only exists to ease dealing with an unknown amount of messages that belong to the same album. Example .. code-block:: python from telethon import events @client.on(events.Album) async def handler(event): # Counting how many photos or videos the album has print('Got an album with', len(event), 'items') # Forwarding the album as a whole to some chat event.forward_to(chat) # Printing the caption print(event.text) # Replying to the fifth item in the album await event.messages[4].reply('Cool!') NFblacklist_chatsfuncc*t||||y)Nr0)superr)rchatsr1r2 __class__s rrzAlbum.__init__^s dKr c b|g}t|tjtjfrvt|jtj sy|jj }|ytjt|drytj}tttkDr@tjDcgc]\}}||z tkDs|c}}D] }t|= |D]}||us|tt|<|j|Dcgc]u}t|tjtjfrIt|jtj r%|jj |k(r |jwc}Sycc}}wcc}wr) isinstancer UpdateNewMessageUpdateNewChannelMessagemessageMessage grouped_id _IGNORE_DICTpopidrlen_IGNORE_MAX_SIZEitems_IGNORE_MAX_AGEEvent) clsupdateothersself_idgroupnowitus rbuildz Album.buildbsf  f--u/L/LM Ofnnemm<NN--E} 6 D1))+C< #33(4(:(:(<Z1a/@Y!Z(A$Q( .F?*-LA' . 99#)q5#9#95;X;X"YZ"199emm< ,,5  9 O&[sF&#F&$A:F,cTt|jdkDrt| |SyNr)rAr"r4filter)rrr6s rrRz Album.filters( u~~  "7>%( ( #r ceZdZdZfdZfdZedZedZedZ edZ edZ d Z d Z d Zd Zd ZdZdZdddZdZdZdZxZS) Album.Eventz Represents the event of a new album. Members: messages (Sequence[`Message `]): The list of messages belonging to the same album. c|d}t||j|jt |j t j||j||_y)Nr) chat_peermsg_id broadcast) r4rpeer_idr@boolpostr sender_idr")rr"r;r6s rrzAlbum.Event.__init__sTqkG G w$+JJ$w||:L  N  ! !$(9(9 :$DMr ct||tj|j|j |j \|_|_|jD]}|j||j d!t|jdk(rg|jj|j}|$t|||j|j<y|j!|jyyrQ)r4 _set_clientr_get_entity_pairr\ _entities_mb_entity_cache_sender _input_senderr" _finish_initrA_albumsgetr=rr#)rrmsghackr6s rr^zAlbum.Event._set_clients G  '/4/E/E0G0G0I ,DL$,}} ?  > ?4==!Q&~~))$//:<6?6MFNN4??3KK . 'r c4|jdjS)zM The shared ``grouped_id`` between all the messages. r)r"r=rs rr=zAlbum.Event.grouped_ids ==#.. .r c<td|jDdS)z The message text of the first photo with a caption, formatted using the client's default parse mode. c3NK|]}|js|jywr)text.0ms r z#Album.Event.text..sAA!&&A%%nextr"rjs rrmzAlbum.Event.texts AA2F Fr c<td|jDdS)zv The raw message text of the first photo with a caption, ignoring any formatting. c3NK|]}|js|jywr)raw_textrns rrqz'Album.Event.raw_text..sIajjIrrrsrtrjs rrxzAlbum.Event.raw_texts IT]]I2N Nr c4|jdjS)a `True` if the album is a reply to some other message. Remember that you can access the ID of the message this one is replying to through `reply_to_msg_id`, and the `Message` object with `get_reply_message()`. r)r"is_replyrjs rrzzAlbum.Event.is_replys==#,, ,r c4|jdjS)z The `Forward ` information for the first message in the album if it was forwarded. r)r"forwardrjs rr|zAlbum.Event.forwards==#++ +r cXK|jdjd{S7w)z The `Message ` that this album is replying to, or `None`. The result will be cached after its first use. rN)r"get_reply_messagerjs rr~zAlbum.Event.get_reply_messages&q);;== ==s !*(*c\K|jdj|i|d{S7w)z Responds to the album (not as a reply). Shorthand for `telethon.client.messages.MessageMethods.send_message` with ``entity`` already set. rN)r"respondrargskwargss rrzAlbum.Event.responds/ 2q)114B6BB BB #,*,c\K|jdj|i|d{S7w)z Replies to the first photo in the album (as a reply). Shorthand for `telethon.client.messages.MessageMethods.send_message` with both ``entity`` and ``reply_to`` already set. rN)r"replyrs rrzAlbum.Event.replys/ 0q)//@@@ @@rcK|jrN|j|d<|jd{|d<|jj|i|d{Sy7,7w)z Forwards the entire album. Shorthand for `telethon.client.messages.MessageMethods.forward_messages` with both ``messages`` and ``from_peer`` already set. r"N from_peer)rr"get_input_chatforward_messagesrs r forward_tozAlbum.Event.forward_tos^ ||%)]]z",0,?,?,A&A{#:T\\::DKFKKK&AKs!/A"A&A"A A" A"cK|jD]*}|js|j|i|d{cS|jdj|i|d{S7.7w)a Edits the first caption or the message, or the first messages' caption if no caption is set, iff it's outgoing. Shorthand for `telethon.client.messages.MessageMethods.edit_message` with both ``entity`` and ``message`` already set. Returns `None` if the message was incoming, or the edited `Message` otherwise. .. note:: This is different from `client.edit_message ` and **will respect** the previous state of the message. For example, if the message didn't have a link preview, the edit won't add one by default, and you should force it by setting it to `True` if you want it. This is generally the most desired and convenient behaviour, and will work for link previews and message buttons. Nr)r"rxedit)rrrrgs rrzAlbum.Event.editsj,}} ;<` with both ``entity`` and ``message`` already set. N)max_id)rsend_read_acknowledgerr"r@rjs r mark_readzAlbum.Event.mark_read.sb||ll88--// b8I8L8L9NNN/Ns!5A'A#$A'A%A'%A'Fnotifyc\K|jdj|d{S7w)z Pins the first photo in the album. Shorthand for `telethon.client.messages.MessageMethods.pin_message` with both ``entity`` and ``message`` already set. rrN)r"pin)rrs rrzAlbum.Event.pin9s+ q)--V-<< < C A L @8  N', = & ' $r rEr)NN) r)r*r+r,r classmethodrOrRrr rErrs@rr/r/CsN4L16TL''R) F$ \F$F$r r/)r&rrcommonrrrrsrtlr tl.custom.sendergetterr rBrDr>rrr/r-r rrs_ ??1   *&*&ZS$LS$S$r