Dh*ddlmZddlZddlZddlZddlZddlZddlmZddlmZm Z m Z ddl Z d dZ d dZ d d dZ ddZed k(reyy)) annotationsN)Path)IOBinaryIOTextIOcdddddd}d}|jdr0tj|dd jjS|d j |vr||d j }|d d }t |d |zzS) a Convert a size string with suffixes 'k', 'm', etc., to bytes. Note: This function also supports '@' as a prefix to a file path to get the file size. >>> size_to_bytes('1024k') 1048576 >>> size_to_bytes('1024m') 1073741824 >>> size_to_bytes('1024g') 1099511627776 >>> size_to_bytes('1024') 1024 >>> size_to_bytes('1024p') 1125899906842624 )kmgtpr@N) startswithpathlibrstatst_sizelowerint)size_strsuffix_exponentexponents v/var/www/fastuser/data/www/generator.snapmosaic.io/flask_app/venv/lib/python3.12/site-packages/progressbar/__main__.py size_to_bytesr s*     OH3||HQRL)..0888|."8B<#5#5#78CR= x=D(N ++c$tjd}|jdddd|jdd dd |jd d dd |jdddd|jdddd|jdddd|jdddd|jdddd|jdddd|jd d!td"#|jd$d%td&#|jd'd(dd)|jd*d+dd,|jd-d.dd/|jd0d1t d2#|jd3d4td5#|jd6d7dd8|jd9d:dd;|jd#|jd?d@tdA#|jdBdCtdD#|jdEdFtdG#|jdHdItdJ#|jdKdLddM|jdNdOddP|jdQdRtdS#|jdTdUtdV#|jdWdXddY|jdZd[dd\|jd]d^td_#|jd`daddb|jdcdddde|jdfdgddh|jdidjddk|jdldmtdn#|jdodptdq#|jdrdst jdt#|jdudvdwdxy|jdzd{dwd|}|S)~zC Create the argument parser for the `progressbar` command. z Monitor the progress of data through a pipe. Note that this is a Python implementation of the original `pv` command that is functional but not yet feature complete. ) descriptionz-pz --progress store_truezTurn the progress bar on.)actionhelpz-tz--timerzTurn the timer on.z-ez--etazTurn the ETA timer on.z-Iz--finetaz)Display the ETA as local time of arrival.z-rz--ratezTurn the rate counter on.z-az--average-ratez!Turn the average rate counter on.z-bz--byteszTurn the total byte counter on.z-8z--bitsz$Display total bits instead of bytes.z-Tz--buffer-percentz/Turn on the transfer buffer percentage display.z-Az--last-writtenz Show the last NUM bytes written.)typer&z-Fz--formatz/Use the format string FORMAT for output format.z-nz --numericzNumeric output.z-qz--quietz No output.z-Wz--waitz/Wait until the first byte has been transferred.z-Dz --delay-startz Delay start.z-sz--sizezAssume total data size is SIZE.z-lz --line-modezCount lines instead of bytes.z-0z--nullz(Count lines terminated with a zero byte.z-iz --intervalzInterval between updates.z-mz--average-rate-windowz$Window for average rate calculation.z-wz--widthz)Assume terminal is WIDTH characters wide.z-Hz--heightz$Assume terminal is HEIGHT rows high.z-Nz--namez$Prefix output information with NAME.z-fz--forcez Force output.z-cz--cursorz(Use cursor positioning escape sequences.z-Lz --rate-limitz(Limit transfer to RATE bytes per second.z-Bz --buffer-sizez"Use transfer buffer size of BYTES.z-Cz --no-splicezNever use splice.z-Ez --skip-errorszIgnore read errors.z-Zz--error-skip-blockz%Skip block size when ignoring errors.z-Sz--stop-at-sizez#Stop transferring after SIZE bytes.z-Yz--syncz/Synchronise buffer caches to disk after writes.z-Kz --direct-ioz(Set O_DIRECT flag on all inputs/outputs.z-Xz --discardz.Discard input data instead of transferring it.z-dz --watchfdz!Watch file descriptor of process.z-Rz--remotez.Remote control another running instance of pv.z-Pz --pidfilezSave process ID in FILE.inputz-Input file path. Uses stdin if not specified.-*)r&defaultnargsz-oz--outputz/Output file path. Uses stdout if not specified.)r+r&)argparseArgumentParser add_argumentrstrfloatrr)parsers rcreate_argument_parserr3<s  $ $F   (    i 3G  gl1I   8    h|2M   0     .     3     >      /      >    k,5F       >   oEO  hS'H   ,     7    l-H    3      8    js)O  hS'M  i ?   7     7      1    mL7J  ol9N    4     2     >     7     =    k*M    =   k 3M  <     >  Mr!c t}|j|}tj5}t |j |j |}g}d}d}|jD]}|dk(r:|j rtj} ntjj} d}nbtj|} | js|jd||js|| j!j"z }|j%| |jrt'|j}d}|rRt)j*dt)j,dt)j.dt)j0g} n=t)j2dt)j4dt)j.g} |j6r4| j%d| j%t)j8t)j:|xsdd} |j<rt'|j<nd } d} | j?tj@tB5|D]} tE| tjr/|jG| jI|j rd nd }n| } |j r|jK| }n|jM| }|s|jO|| tQ|z } | jS| c ddd| jUd dddy#1swY$xYw#1swYyxYw) z Main function for the `progressbar` command. Args: argv (list[str] | None): Command-line arguments passed to the script. Returns: None rTr)FzFile not found:  N) max_value max_errorrrrb)dirty)+r3 parse_args contextlib ExitStack_get_output_streamoutput line_moder(sysstdinbufferrrexistserrorsizerrappendr progressbar PercentageBarTimerFileTransferSpeedSimpleProgressDataSizeeta AdaptiveETA ProgressBar buffer_sizestartsuppressKeyboardInterrupt isinstance enter_contextopenreadlinereadwritelenupdatefinish)argvr2argsstack output_stream input_paths total_sizefilesize_availablefilename input_pathwidgetsbarrRtotal_transferred input_streamdatas rmainrms'=&>F%006D    ]5/A KK0 HJ  #'  +H3>>!$J!$!1!1J%*"$\\(3 !((*LL#3H:!>?yy*//"3";";;J   z *# +( 99&tyy1J!%  &&(!!!#--/G**,$$&!!# G 88 NN3  NN;224 5%% (D 04/?/?M$** +T   !2 3 2) 2 j',,7#(#6#6"t~~4H$L$.L~~+44[A+00=!''-%T2%JJ01 2 2.  {]]L 2 2M]]s%IM8B6M/MM MM'c|r&|dk7r!|rdnd}|jt||S|rtjStjjS)Nr)wwb)rWrXrAstdoutrC)r?r@ramodes rr>r>sK &C-sT""4#566 zzzz   r!__main__)rr0returnr)rtzargparse.ArgumentParser)N)r_zlist[str] | NonertNone)r?z str | Noner@boolrazcontextlib.ExitStackrtztyping.IO[typing.Any]) __future__rr-r<rrAtypingrrrrrHr r3rmr>__name__r!rr{st" ''+,\TnjZ !  ! !  ! ! zFr!