;Sid%ddlZddlZddlZddlmZddlmZmZddlm Z m Z ejrddl m Z Gdd ZGd d Zy) N)_NOT_A_REQUEST)helpersutils) functions TLRequest)TelegramClientceZdZdZdZdZedZejdZdZ dZ e jZ e jZd dZfd Zd Zfd ZxZS) _TakeoutClientz' Proxy object over the client. ) __enter____exit__ __aenter__ __aexit__c<||_||_||_d|_yN)_TakeoutClient__finalize_TakeoutClient__client_TakeoutClient__request_TakeoutClient__success)selffinalizeclientrequests \/var/www/OnlineNewsSite/project/venv/lib/python3.12/site-packages/telethon/client/account.py__init__z_TakeoutClient.__init__s #  c|jSrr)rs rsuccessz_TakeoutClient.successs ~~rc||_yrr)rvalues rr z_TakeoutClient.success"s rcK|j}|jj5||jd{j|j_|S|j t d|S78w)NzgCan't send a takeout request while another takeout for the current session still not been finished yet.)rsession takeout_idrid ValueError)rrs rrz_TakeoutClient.__aenter__&sp >> $ $ ,/5dnn/E)E(I(IFNN % ^^ 'OP P *Fs8A5A39A5cK|j|jr |du|_|jV|tjj |jd{}|s t dd|j _yy7$w)NzFailed to finish the takeout.)rrraccountFinishTakeoutSessionRequestr'r$r%)rexc_type exc_value tracebackresults rrz_TakeoutClient.__aexit__0sz >> !doo%-DN >> % 1 1 M M! !!F !@AA&*DLL # &!sA B "B#%B cK|jjj}| tdt j | }|r|fn|}g}|D]_}t |ts t|j|td{|jtj||a|j|r|dn||d{S7M7w)NzJTakeout mode has not been initialized (are you calling outside of "with"?)r)ordered) rr$r%r'r is_list_like isinstancer rresolveappendrInvokeWithTakeoutRequest)rrr0r%singlerequestswrappedrs r__call__z_TakeoutClient.__call__>s]]**55  78 8''00"(WJg NAa+$&&))D%( ( ( NN9==j!L M  N ]] GAJgw#@@ @ )@s%BCCACCCCc~|jdr|t|jvrtt||S)N__) startswithtype_TakeoutClient__PROXY_INTERFACEAttributeErrorsuper__getattribute__)rname __class__s rrBz_TakeoutClient.__getattribute__Ps: ??4 Td1M1M%M w'--rct|j|}tj|r4t j t|jj ||S|Sr)getattrrinspectismethod functoolspartialrD)rrCr"s r __getattr__z_TakeoutClient.__getattr__]sR t,   E "$$ //6> > rc|jdjt|jj drt |||St|j||S)Nz_{}___) r=formatr>__name__lstriprA __setattr__setattrr)rrCr"rDs rrQz_TakeoutClient.__setattr__gsR ??7>>$t**=*=*D*DS*IJ K7&tU3 3t}}dE22r)F)rO __module__ __qualname____doc__r?rpropertyr setterrrr _sync_enterr _sync_exitrr:rBrKrQ __classcell__)rDs@rr r s~M ^^ +##I!!H@$ .33rr cfeZdZ ddddddddddddedededed ed ed ed ed dfdZddded efdZy)AccountMethodsN)contactsuserschats megagroupschannelsfiles max_file_sizerr rr]r^r_r`rarbrcreturnc t|||||||} d| jD} |jj t | r t j jdi| } nd} t||| S)a~ Returns a :ref:`telethon-client` which calls methods behind a takeout session. It does so by creating a proxy object over the current client through which making requests will use :tl:`InvokeWithTakeoutRequest` to wrap them. In other words, returns the current client modified so that requests are done as a takeout: Some of the calls made through the takeout session will have lower flood limits. This is useful if you want to export the data from conversations or mass-download media, since the rate limits will be lower. Only some requests will be affected, and you will need to adjust the `wait_time` of methods like `client.iter_messages `. By default, all parameters are `None`, and you need to enable those you plan to use by setting them to either `True` or `False`. You should ``except errors.TakeoutInitDelayError as e``, since this exception will raise depending on the condition of the session. You can then access ``e.seconds`` to know how long you should wait for before calling the method again. There's also a `success` property available in the takeout proxy object, so from the `with` body you can set the boolean result that will be sent back to Telegram. But if it's left `None` as by default, then the action is based on the `finalize` parameter. If it's `True` then the takeout will be finished, and if no exception occurred during it, then `True` will be considered as a result. Otherwise, the takeout will not be finished and its ID will be preserved for future usage as `client.session.takeout_id `. Arguments finalize (`bool`): Whether the takeout session should be finalized upon exit or not. contacts (`bool`): Set to `True` if you plan on downloading contacts. users (`bool`): Set to `True` if you plan on downloading information from users and their private conversations with you. chats (`bool`): Set to `True` if you plan on downloading information from small group chats, such as messages and media. megagroups (`bool`): Set to `True` if you plan on downloading information from megagroups (channels), such as messages and media. channels (`bool`): Set to `True` if you plan on downloading information from broadcast channels, such as messages and media. files (`bool`): Set to `True` if you plan on downloading media and you don't only wish to export messages. max_file_size (`int`): The maximum file size, in bytes, that you plan to download for each message with media. Example .. code-block:: python from telethon import errors try: async with client.takeout() as takeout: await client.get_messages('me') # normal call await takeout.get_messages('me') # wrapped through takeout (less limits) async for message in takeout.iter_messages(chat, wait_time=0): ... # Do something with the message except errors.TakeoutInitDelayError as e: print('Must wait', e.seconds, 'before takeout') )r] message_users message_chatsmessage_megagroupsmessage_channelsrb file_max_sizec3$K|]}|du ywr).0args r z)AccountMethods.takeout..sLSDLsNrl) dictvaluesr$r%anyrr)InitTakeoutSessionRequestr ) rrr]r^r_r`rarbrcrequest_kwargs arg_specifiedrs rtakeoutzAccountMethods.takeoutosx)%' MN4I4I4KL << " " *c-.@''AA" "GGhg66rr cK td|d4d{}||_dddd{y77#1d{7swYyxYw#t$rYywxYww)ap Finishes the current takeout session. Arguments success (`bool`): Whether the takeout completed successfully or not. Returns `True` if the operation was successful, `False` otherwise. Example .. code-block:: python await client.end_takeout(success=False) TNF)r r r')rr rvs r end_takeoutzAccountMethods.end_takeoutsl  %dD$7 * *7") * *  * * * * *  slAA 2A 6 A 4A AA A A? AA AA AAAA)T)rOrSrTboolrvrxrlrrr\r\ns"m7"#!"&m7"m7m7 m7  m7  m7m7m7m7 m7,<m7^ 04Drr\)rIrGtypingr^rrrtlrr TYPE_CHECKINGtelegramclientr r r\rlrrrs< !% . \3\3~EEr