3 b`<@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)HttpFDcs*d Gdddt}||_ j|_d_ddijd}|rVj| jjddrn jn jd ijd p jjd pd d _ d _ d_ jjd d_ t j _d_ jjddrtjjtjrtjjtj_ j d k_d  jjdd  GdddtGdddtGdddtdd  f dd} fdd}x kry ||Sk r}z,d7 krЈ j|j wWYdd}~Xn.k rwYnk rdSXqW jd dS) Nurlc@seZdZejZejZejZ dS)z-HttpFD.real_download..DownloadContextN) __name__ __module__ __qualname__dictget __getattr__ __setitem__ __setattr__ __delitem__ __delattr__rrFC:\Users\Broad\Desktop\All-Down\binaries\youtube_dl\downloader\http.pyDownloadContextsrzYoutubedl-no-compressionTrue http_headerstestFZdownloader_optionshttp_chunk_sizerwb buffersizei continuedlTretriesc@s eZdZdS)z-HttpFD.real_download..SucceedDownloadN)rrrrrrrSucceedDownloadFsr'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..NextFragmentN)rrrrrrr NextFragmentMsr,cSs(d|}|r|t|7}|jd|dS)Nz bytes=%d-ZRange)r add_header)reqstartendZ range_headerrrr set_rangePs z'HttpFD.real_download..set_rangec s& rrtjtdn_jdkrNj}jrFjjd_njdkr^d}nd}d_jr||jdnd}|rjdk r|jkrjd}|dk }|_ t d}|r̈|||yƈj j |_ |rxj jjd}|rdtjd|}|rd|t|jdkrdt|jd}t|jd }j pR||kpR||k}|rd|_dSjd_d _tj jjd d_dStjfk r} z.| jd kry(j j t d_ j jd } WnBtjfk r"} z | jdks| jdkrWYdd} ~ XnX| dk rjdt| koRjdknrjjjjjjjdjjdnjd_d _dSn| jdks| jdkr̂| WYdd} ~ Xn>tjk r } z| j t j!kr| WYdd} ~ XnXdS)Ngffffff?rabFrz Content-Rangezbytes (\d+)-(\d+)?(?:/(\d+))?rr#zContent-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_downloadedr6 try_rename tmpfilename_hook_progresssocketerrorerrno ECONNRESET) Z range_startZ range_endrCrequestZ content_rangeZcontent_range_mZcontent_range_endZ content_lenZaccept_content_lenerrcontent_length) r+r'r=ctxrGis_testr)r1rrrestablish_connectionVs$           ,  z2HttpFD.real_download..establish_connectioncBsjjjdd}r2|dks,t|jkr2j}|dk rt|j}jjd}jjd}|dk r||krjd||fdS|dk r||krjd||fdSdjj}t j }d}|}fdd }xy"jj s|n t ||}Wnpt j k r0} z|| WYdd} ~ XnDt jk rr} z$| jtjtjfkrZ|| WYdd} ~ XnXt|7t|dkrPjdkryDtjj\__jdk stjj_jjWn8ttfk r} zjd t| dSd} ~ XnXjjd dr|dk rytjd t|j d Wn:t!t"fk r} zjdt| WYdd} ~ XnXyjj#|WnBttfk r} z j$djdt| dSd} ~ XnXj%||jt j }|} jjdds$j&| |t|}| }j'||j} j(dkrNd} n"j)|t j j(jj} j*dj(jj| | |j+dr|krPqW rވj,rވj(dk rވj(krވ_jdkrj$djddSjdkrjj-|dk rP|krPt.t|} krL|| | j/jjjjddrj0jjjjddd<j*jdt j j+ddS)NzContent-length 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}|sjjd_|r&ntjjtj_|dS)N-)rQstreamcloseospathgetsizer r>)eZ to_stdout)r+ byte_counterrZrrretrys   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)r7r8r9rQr6etaspeedelapsedzDid not get any data blocksr_ updatetimeTz last-modifiedfiletimer5)r8r9r6r7rn)1rFrLrr<_TEST_FILE_SIZEr>params to_screen block_sizetimereadminrStimeoutrTrUrVZ ETIMEDOUTlenr`r rQrAAssertionErrorundo_temp_namer6report_destinationOSErrorIOError report_errorstrr encoderrwrite to_stderr slow_downbest_block_size calc_speedrBcalc_etarR start_timer=rarrP try_utime)rBZ min_data_lenZ max_data_lenrtr/nowZbeforergZ data_blockrerXafterrmrl)r,r+countrZ info_dictr[r&r))rfrdownloads   "  $  " (       z&HttpFD.real_download..downloadrzgiving up after %s retries)rr6 temp_namerQr`rupdaterrrqrAr>rBrtrurr=rbrcisfiler rdr? Exception report_retryr(r)r)r6rr add_headersr\rrer) r,r+r'r=rrZrGrr[r&r)r1rr real_downloadsb      g   zHttpFD.real_downloadN)rrrrrrrrrsr) __future__rrUrbrSrur:rHcommonrcompatrrutilsrr r r r r rrrrrrrs  (