U y^<@sddlmZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z m Z ddl mZmZmZmZmZmZmZmZGdd d e ZdS) )unicode_literalsN)FileDownloader) compat_strcompat_urllib_error)ContentTooShortErrorencodeFilename int_or_none sanitize_opensanitized_Request write_xattrXAttrMetadataErrorXAttrUnavailableErrorc@seZdZddZdS)HttpFDc s2d Gdddt}||_ |_d_ddid}|rV| jddrn jn d id p jd pd d _ d _ d_ jd d_ t _d_ jddrtjtjrtjtj_ j d k_d  jdd  GdddtGdddtGdddtdd  f dd} fdd} kr z||WSk r}z0d7 krЈ |j WYqW5d}~XYn2k rYqYnk rYdSXq d dS) Nurlc@seZdZejZejZejZ dS)z-HttpFD.real_download..DownloadContextN) __name__ __module__ __qualname__dictget __getattr__ __setitem__ __setattr__ __delitem__ __delattr__rrMC:\Users\TaGoRe\Desktop\beinconnect-dl\binaries\youtube_dl\downloader\http.pyDownloadContextsrzYoutubedl-no-compressionTrue http_headerstestFZdownloader_optionshttp_chunk_sizerwb buffersizei continuedlTretriesc@s eZdZdS)z-HttpFD.real_download..SucceedDownloadNrrrrrrrSucceedDownloadFsr(c@seZdZddZdS)z+HttpFD.real_download..RetryDownloadcSs ||_dS)N) source_error)selfr)rrr__init__Jsz4HttpFD.real_download..RetryDownload.__init__N)rrrr+rrrr RetryDownloadIsr,c@s eZdZdS)z*HttpFD.real_download..NextFragmentNr'rrrr NextFragmentMsr-cSs(d|}|r|t|7}|d|dS)Nz bytes=%d-ZRange)r add_header)reqstartendZ range_headerrrr set_rangePs z'HttpFD.real_download..set_rangec s.srttdn_jdkrLj}jrDjd_njdkr\d}nd}d_jrz|jdnd}|rjdk r|jkrjd}|dk }|_ t d}|rʈ|||zʈj |_ |rxj jd}|rdtd|}|rd|t|dkrdt|d}t|d }j pP||kpP||k}|rd|_WdSd_d _tj d d_WdStjfk r} z2| jd krz(j t d_ j d } WnBtjfk r$} z| jdks| jdkrW5d} ~ XYnX| dk rjdt| krXjdkrnn>jjjjdjjdnd_d _WY,dSn| jdks| jdkrԂ| W5d} ~ XYn>tjk r(} z| j t j!kr| W5d} ~ XYnXdS)Ngffffff?rabFrz Content-Rangezbytes (\d+)-(\d+)?(?:/(\d+))?rr#Content-lengthizContent-LengthiiXdfinished)filenamestatusdownloaded_bytes total_bytes)"randomrandintint chunk_size resume_len is_resumereport_resuming_byte open_modedata_len has_ranger ydlurlopendataheadersrresearchgroupr report_unable_to_resumeinfor HTTPErrorcodereport_file_already_downloadedr8 try_rename tmpfilename_hook_progresssocketerrorerrno ECONNRESET) Z range_startZ range_endrErequestZ content_rangeZcontent_range_mZcontent_range_endZ content_lenZaccept_content_lenerrcontent_length) r,r(r?ctxrIis_testr*r2rrrestablish_connectionVs              z2HttpFD.real_download..establish_connectionc sjdd}r2|dks,t|jkr2j}|dk rt|j}jd}jd}|dk r||krd||fdS|dk r||krd||fdSdjj}t }d}|}fdd }z"j s|n t ||}Wnpt j k r,} z || W5d} ~ XYnDt jk rn} z"| jtjtjfkrV|| W5d} ~ XYnXt|7t|dkrqjdkrzDtjj\__jdk stj_jWn@ttfk r} zd t| WYdSd} ~ XYnXjd dr|dk rztjd t| d Wn:t!t"fk r} zdt| W5d} ~ XYnXzj#|WnJttfk r} z&$ddt| WYdSd} ~ XYnX%||jt }|} jdds2&| |t|}| }'||j} j(dkr\d} n")|t j(jj} *dj(jj| | |j+dr܈|krܐqq܈sj,rj(dk rj(kr_jdkr$dddSjdkr$j-|dk r\|kr\t.t|} krX|| | /jjjddr0jjddd<*jdt j+ddS)Nr5 min_filesize max_filesizezN [download] File is smaller than min-filesize (%s bytes < %s bytes). Aborting.FzM [download] File is larger than max-filesize (%s bytes > %s bytes). Aborting.rcsFjdk}|sjd_|r&ntjtj_|dS)N-)rSstreamcloseospathgetsizer r@)eZ to_stdout)r, byte_counterr\rrretrys   z5HttpFD.real_download..download..retryzunable to open for writing: %sxattr_set_filesizezuser.ytdl.filesizezutf-8z unable to set filesize xattr: %s zunable to write data: %snoresizebuffer downloading)r9r:r;rSr8etaspeedelapsedzDid not get any data blocksra updatetimeTz last-modifiedfiletimer7)r:r;r8r9rp)1rHrNrr>_TEST_FILE_SIZEr@params to_screen block_sizetimereadminrUtimeoutrVrWrXZ ETIMEDOUTlenrbr rSrCAssertionErrorundo_temp_namer8report_destinationOSErrorIOError report_errorstrr encoderrwrite to_stderr slow_downbest_block_size calc_speedrDcalc_etarT start_timer?rcrrR try_utime)rDZ min_data_lenZ max_data_lenrvr0nowZbeforeriZ data_blockrgrZZafterrorn)r-r,countr\ info_dictr]r&r*)rhrdownloads    "   $  " &        z&HttpFD.real_download..downloadrzgiving up after %s retries)rr8 temp_namerSrbrupdatertrsrCr@rDrvrwrr?rdreisfiler rfrA Exception report_retryr)r)r*r8rrZ add_headersr^rrgr) r-r,r(r?rr\rIrr]r&r*r2rr real_downloadsj       g    zHttpFD.real_downloadN)rrrrrrrrrsr) __future__rrWrdrUrwr<rJcommonrcompatrrutilsrr r r r r rrrrrrrs  (