:Ʉj&!ddlZddlZddlZddlZddlZddlZddlmZddlm Z ddl m Z m Z m Z ddlZddlmZddlmZddlmZej&eZGdd Zy) N)md5)PurePath)UnionBinaryIOCallable)StopTransmission)raw)Sessionc @eZdZ d dddeeefdedededef d Z y) SaveFileNselfzpyrogram.Clientpathfile_id file_partprogress progress_argsc K|j4d{| dddd{yfd}d}t|ttfr t |d}n(t|t j r|}n tdt|dd} |jdt j|j} |jd| dk(r td |jjrd nd } | | d zd zkDrtd | dttj | |z } | dkD} | rdnd}|du}|xs|j#}| s |s t%nd}t'||j(j+d{|j(j-d{|j(j/d{d}t1|Dcgc]#}|j2j5||%}}t7j8d |j;d{|j||z |j=|}|sN| sJ|sHdj?|jADcgc]}tC|ddjEd!c}}n| r.tFjHjJjM||| |}n,tFjHjJjO|||}jQ|d{|r |D]}jQdd{t7jR|d{|jUd{t|ttfr|jWdddd{y| s|s|jY||dz }|rxt[j\|t_||z| | g|}tajb|r|d{n.|j2je|jf|d{ | rtFjhjk|| | |D]}jQdd{t7jR|d{|jUd{t|ttfr|jWcdddd{StFjhjm|| | ||D]}jQdd{t7jR|d{|jUd{t|ttfr|jWcdddd{S77}777cc}w7cc}w777f7Q7777N757 7777|7G#tn$rtp$r}trju|Yd}~nd}~wwxYw |D]}jQdd{7t7jR|d{7|jUd{7t|ttfr|jWn#|D]}jQdd{7t7jR|d{7|jUd{7t|ttfr|jWwwxYwdddd{7y#1d{7swYyxYww)a Upload a file onto Telegram servers, without actually sending the message to anyone. Useful whenever an InputFile type is required. .. note:: This is a utility method intended to be used **only** when working with raw :obj:`functions ` (i.e: a Telegram API method you wish to use which is not available yet in the Client class as an easy-to-use method). .. include:: /_includes/usable-by/users-bots.rst Parameters: path (``str`` | ``BinaryIO``): The path of the file you want to upload that exists on your local machine or a binary file-like object with its attribute ".name" set for in-memory uploads. file_id (``int``, *optional*): In case a file part expired, pass the file_id and the file_part to retry uploading that specific chunk. file_part (``int``, *optional*): In case a file part expired, pass the file_id and the file_part to retry uploading that specific chunk. progress (``Callable``, *optional*): Pass a callback function to view the file transmission progress. The function must take *(current, total)* as positional arguments (look at Other Parameters below for a detailed description) and will be called back each time a new file chunk has been successfully transmitted. progress_args (``tuple``, *optional*): Extra custom arguments for the progress callback function. You can pass anything you need to be available in the progress callback scope; for example, a Message object or a Client instance in order to edit the message with the updated progress status. Other Parameters: current (``int``): The amount of bytes transmitted so far. total (``int``): The total size of the file. *args (``tuple``, *optional*): Extra custom arguments as defined in the ``progress_args`` parameter. You can either keep ``*args`` or add every single extra argument in your function signature. Returns: ``InputFile``: On success, the uploaded file is returned in form of an InputFile object. Raises: RPCError: In case of a Telegram RPC error. NcK jd{}|y |j|d{67"7#t$r}tj |Yd}~(d}~wwxYww)N)getinvoke Exceptionlog exception)sessiondataequeues Z/var/www/html/GAP/venv/lib/python3.12/site-packages/pyrogram/methods/advanced/save_file.pyworkerz"SaveFile.save_file..workeresc!&,D|)%nnT222, 3$) a(()s@A*;A*?=?A*? A'A"A*"A''A*irbzPInvalid file. Expected a file path as string or a binary (not text) file pointernamezfile.jpgrzFile size equals to 0 BiiizCan't upload files bigger than z MiBiT)is_media)rrfile_total_partsbytes)rrr()idpartsr!)r)r*r! md5_checksum);save_file_semaphore isinstancestrropenioIOBase ValueErrorgetattrseekSEEK_ENDtellme is_premiumintmathceilrnd_idrr storagedc_idauth_key test_moderangeloop create_taskasyncioQueuestartreadjoindigesthexzfillr functionsuploadSaveBigFilePart SaveFilePartputgatherstopcloseupdate functoolspartialmininspectiscoroutinefunctionrun_in_executorexecutortypes InputFileBig InputFilerrrr)r rrrrrr part_sizefp file_name file_sizefile_size_limit_mibr'is_big workers_countis_missing_partmd5_sumr_workerschunkirpcfuncrrs @r save_filezSaveFile.save_file'sxt++A A |A A A  )#I$h0$%D")), !sttFJ7I GGAr{{ # I GGAJA~ !:;;*.''*<*<$$ .5<< #BCVBWW[!\]]"499Y-B#CD !11F!'AQM%T1O.G#)/cetGDLL..00 8M8M8O2Oll,,..GHM]G[\!tyy,,VG_=\G\MM!$EM mmo%% I-.GGI.E %o&(ggGNNL\.]qs1vabz/?/?/B.]&^G!mm22BB$+&/-="' C"mm22??$+&/"'@  ))C.((&N!*A))D/))*nng...lln$$dS(O4HHJCA A A h"/u-NI(00$ I 5yA% +  #66x@"&&LL"&))";";DMM4"PPPW V9911".&2!*A))D/))*nng...lln$$dS(O4HHJCA A A d99..".&%, /!*A))D/))*nng...lln$$dS(O4HHJCA A A A \12O.\&/^")V*.$}A D)P,*.$}A t*.$}A J$  ! a   ! "!*A))D/))*nng...lln$$dS(O4HHJ!*A))D/))*nng...lln$$dS(O4HHJ5AA A A A A s\>V!\>\) \>V$\>E\)V' \))V** \) V- \)"(V0 \)"W%5V56A W%$V8 'A9W% V=!W%(\)W\)W\)5W6*\) \>+W ,\>1A W%W .W%WW%#Z+\)W \) W!\)8W9*\)# \>/W0\>5"Z\)0W 1\) W \)$W!%*\) \>W#\>$\>'\)*\)-\)0\)5W%8W%\)\)\) \> W%W%\)\)\)\>\)\)!\)#\>%X7X ZXZ\)3X64\)Y\))Y,*,\)\0Z3 1\ [ \&[) '-\\) \>"\%#\>)\;/\2 0\;7\>)NrN) __name__ __module__ __qualname__rr.rr9rtuplernrorr r &s]!! {{CM"{{ {  {  {rtr )rDrUrXr0loggingr:hashlibrpathlibrtypingrrrpyrogramrr pyrogram.sessionr getLoggerrprr rortrr|sO(  ,,%$g!||rt