;Si;9TdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Z GddejZej eZddZdZd Zd Zdd d Zd ZddZdZdZdZdZdZdZGdde Z!GddejDZ#dZ$y)z6Various helpers not related to the Telegram API itselfN)Path)sha1ceZdZdZdZdZy) _EntityTyperN)__name__ __module__ __qualname__USERCHATCHANNELU/var/www/OnlineNewsSite/project/venv/lib/python3.12/site-packages/telethon/helpers.pyrrs D DGrrcXtjtjd|dS)zEGenerates a random long integer (8 bytes), which is optionally signedlittle)signed byteorder)int from_bytesosurandomrs rgenerate_random_longrs >>"**Q-(> KKrcvtjj|}|rtj|dyy)z(Ensures that the parent directory existsT)exist_okN)rpathdirnamemakedirs) file_pathparents rensure_parent_dir_existsr$ s* WW__Y 'F  FT*rc2djd|DS)Nc 3K|]X}dt|cxkrdkr>nn;djdtjd|j dDn|Zyw)iir&c32K|]}t|ywN)chr).0ys r z*add_surrogate...+sK1AKz.(sU78Gs1v ) ) K eQXXj5I JKK01 2sAA )r0texts r add_surrogater8's# 77<@  rcD|jddjdS)Nzutf-16 surrogatepass)r3decoder6s r del_surrogater<0s ;;x 1 8 8 BBr)lengthc| t|}d|cxkxrt|kncxr+d||dz cxkxrdkncxrd||cxkxrdkScS)zS `True` if ``index`` is within a surrogate (before and after it, not at!). ruuu)len)r7indexr=s rwithin_surrogaterA4sd~T  !D ! 0 UQY 38 3 0 U /x / 0rc|s|jSt|}|j}|t|z }|j}t|}t t t|D]}||}|j dk(r||=|j|j z|kDrN|j|k\r|xj|zc_n-|j|j z|z |_d|_n||=|j|j z|kr|j|k\r||=||jz |_|S)z Strips whitespace from the given surrogated text modifying the provided entities, also removing any empty (0-length) entities. This assumes that the length of entities is greater or equal to 0, and that no entity is out of bounds. r)stripr?lstriprstripreversedranger=offset)r7entitieslen_ori left_offset len_finalies r strip_textrOBs- zz|$iG ;;=DCI%K ;;=DD I eCM* +1, QK 88q=  88ahh  ,xx;&K'88ahh.<  88ahh ) +  88y  !188+AHc1,l Krc#VK|r | |dks|dz }d}||k7r|dz }|||k7ryyw)z Generates an integer sequence starting from 1. If `retries` is not a zero or a positive integer value, the sequence will be infinite, otherwise it will end at `retries + 1`. Nrrr)retries force_retryattempts r retry_rangerTsCGOw{1 G W 1   W s$))cPKtj|r |d{S|S7wr))inspect isawaitable)values r _maybe_awaitrYs&5!{ s &$&c K|jD]#\}}|s |j |d{%y7#tj$rY>t$rYHt $r6}|j dk7r|jd|t||Yd}~d}~wt$r |jd|t||YwxYww)zL Helper to cancel one or more tasks gracefully, logging exceptions. N)z"yield from wasn't used with futurez4Unhandled exception from %s after cancelling %s (%s)) itemscancelasyncioCancelledError RuntimeErrorAssertionErrorargs exceptiontype Exception)logtasksnametaskrNs r_cancelriskkm= d   =JJ = %%     Avv@@ ()-tDz4A = MM$%)4:t = =s[*C<:<C<CCCCC#,BC)C=C?CCct|dr |j}n|jj}|jr t d|j |j S)za Helps to cut boilerplate on async context managers that offer synchronous variants. loopz[You must use "async with" if the event loop is running (i.e. you are inside an "async def"))hasattrrk_client is_runningr_run_until_complete __aenter__)selfrks r _sync_enterrrs\ tVyy||    >   " "4??#4 55rct|dr |j}n|jj}|j|j|S)Nrk)rlrkrmro __aexit__)rqrarks r _sync_exitrus@tVyy||    " ">4>>4#8 99rc |jdvrtdj| |jj }d|vrt jSd|vrt jSd|vrt jSd|vrt jStdj|#t$rtdj|wxYw)N)iVl9lF?Li@iwy-l]^ iaFl&4)z {} does not have any entity typez2{} is not a TLObject, cannot determine entity typeUserChatChannelSelf) SUBCLASS_OF_ID TypeErrorformatAttributeError __class__r rr r r)entityrgs r _entity_typers ]  ) >EEfMN N     $ $D ~ 4 d """ 4 6==fE FF ]LSSTZ[\\]s (B++$Cc.|jddd}|jddd}t||zj}t||zj}t||zj}||ddz}|dd|z|dd z}||fS) z7Generates the key data corresponding to the given noncerTr N )to_bytesrdigest) server_nonce new_noncehash1hash2hash3keyivs rgenerate_key_data_from_noncers((Xd(CL""2x"=I \) * 1 1 3E  ) * 1 1 3E Y& ' . . 0E %* C r"  "1 -B 7Nrc.eZdZdZfdZdZdZxZS) TotalLista A list with an extra `total` property, which may not match its `len` since the total represents the total amount of items *available* somewhere else, not the items *in this list*. Examples: .. code-block:: python # Telethon returns these lists in some cases (for example, # only when a chunk is returned, but the "total" count # is available). result = await client.get_messages(chat, limit=10) print(result.total) # large number print(len(result)) # 10 print(result[0]) # latest message for x in result: # show the 10 messages print(x.text) c2t||i|d|_y)Nr)super__init__total)rqrakwargsrs rrzTotalList.__init__8s $)&) rcfdjdjd|D|jS)N[{}, total={}], c32K|]}t|ywr))strr4s rr-z$TotalList.__str__..>s+c!f+r.r}r0rrqs r__str__zTotalList.__str__<s-&& II+d+ +TZZ9 9rcfdjdjd|D|jS)Nrrc32K|]}t|ywr))reprr4s rr-z%TotalList.__repr__..Bs,!d1g,r.rrs r__repr__zTotalList.__repr__@s-&& II,t, ,djj: :r)r r r __doc__rrr __classcell__)rs@rrr!s,9:rrceZdZdZdddZdZdZedZedZ d Z d Z d Z d Z d ZdZdZdZdZdZdZdZdZdZdZdZy) _FileStreama: Proxy around things that represent a file and need to be used as streams which may or not need to be closed. This will handle `pathlib.Path`, `str` paths, in-memory `bytes`, and anything IO-like (including `aiofiles`). It also provides access to the name and file size (also necessary). N) file_sizect|trt|j}||_d|_||_d|_d|_yr)) isinstancerrabsolute_file_name_size_stream _close_stream)rqfilers rrz_FileStream.__init__Os@ dD !t}}'D    !rc Kt|jtrtjj |j|_tjj|j|_t|jd|_ d|_ |St|jtrGt|j|_tj|j|_ d|_ |St!t#|jdds t%dt#|jdd|_|j|_ d|_ |jt!t#|jddr,t'|jj)d{}nd}|rt'|jj+d{}t'|jj-dtj.d{t'|jj+d{|_t'|jj-|tj0d{|St2j5d t'|jj7d{}t||_tj||_ d|_ |S7P7#7777Cw) NrbTreadz,file description should have a `read` methodrgFseekablerzRCould not determine file size beforehand so the entire file will be read in-memory)rrrrrbasenamergetsizeropenrrbytesr?ioBytesIOcallablegetattrr|rYrtellseekSEEK_ENDSEEK_SET_logwarningr)rqrposdatas rrpz_FileStream.__aenter__Ys djj# &))$**5DJ4DJ D1DL!%D K djj% (TZZDJ::djj1DL!%D K FD9:JK KTZZ6 zz " ::  J=>!-djj.A.A.C!DD ():;;"4::??1bkk#BCCC#/ 0A#BB "4::??3 #DEEE  23*$**//*;<< Y !zz$/ %)" 'E <CBE =smF.L0L1/L L!:LL*LL?LL ALL  8LLLL L LcK|jr9|jr,t|jjd{yyy7wr))rrrYclose)rqexc_typeexc_valexc_tbs rrtz_FileStream.__aexit__s;   $,,t||1134 4 4#/  4s?A A A c|jSr))rrs rrz_FileStream.file_size zzrc|jSr))rrs rrgz_FileStream.namerrc:|jj|i|Sr))rrrqrars rrz_FileStream.read,=DLL,=,=t,Nv,N%Nrc:|jj|i|Sr))rreadintors rrz_FileStream.readinto0E 0E0Et0Vv0V)Vrc:|jj|i|Sr))rwriters rrz_FileStream.write-?T\\-?-?-P-P&Prc:|jj|i|Sr))rfilenors rrz_FileStream.fileno.Adll.A.A4.R6.R'Rrc:|jj|i|Sr))rflushrs rrz_FileStream.flushrrc:|jj|i|Sr))risattyrs rrz_FileStream.isattyrrc:|jj|i|Sr))rreadablers rrz_FileStream.readablerrc:|jj|i|Sr))rreadliners rrz_FileStream.readlinerrc:|jj|i|Sr))r readlinesrs rrz_FileStream.readliness1G1G1G1XQW1X*Xrc:|jj|i|Sr))rrrs rrz_FileStream.seekrrc:|jj|i|Sr))rrrs rrz_FileStream.seekablerrc:|jj|i|Sr))rrrs rrz_FileStream.tellrrc:|jj|i|Sr))rtruncaters rrz_FileStream.truncaterrc:|jj|i|Sr))rwritablers rrz_FileStream.writablerrc:|jj|i|Sr))r writelinesrs rrz_FileStream.writeliness2I$,,2I2I42ZSY2Z+Zrcyr)rrs rrz_FileStream.closes r)r r r rrrprtpropertyrrgrrrrrrrrrrrrrrrrrrrrrEsy+/"*X5OVPRPRVVXNVNVVZ  rrctjdk\r tjStj S#t$r%tj j cYSwxYw)N))sys version_infor]get_running_loopr_get_event_loop_policyget_event_looprrrrrsa 6! D++- -%%'' D002AAC C Ds=+A+*A+)T)%rr]renumrr1rVlogging functoolsrpathlibrhashlibrEnumr getLoggerr rrr$r8r<rArOrTrYrirrrurrlistrIOBaserrrrrrs<  $)) w" L +C-1 GT&"=J6&:!GP $!:!:Hb "))b L(r