B He#@sxddlZddlZddlZddlZddlmZmZmZmZm Z m Z m Z m Z ddl mZddlmZmZddlmZddlmZmZddlmZerddlmZe e eefZe eeefed d d Ze e eefed d d Ze e eefe ed ddZde e eefee ede ee e e eefe eee ee ee eeed ddZ!eeddddZ"dS)N) TYPE_CHECKINGAnyCallableIterableListMappingOptionalUnion)escape)SpinnerInterface open_spinner)InstallationSubprocessError)VERBOSEsubprocess_logger) HiddenText)Literal)argsreturncGs6g}x,|D]$}t|tr$||q ||q W|S)z& Create a CommandArgs object. ) isinstancelistextendappend)r command_argsargrr/var/www/downstreamdata.science/rtclock/rtclock-venv/lib/python3.7/site-packages/pip/_internal/utils/subprocess.py make_command s    rcCsddd|DS)z/ Format command arguments for display.  css0|](}t|trtt|nt|VqdS)N)rrshlexquotestr).0rrrr ;sz&format_command_args..)join)rrrrformat_command_args1s r$cCsdd|DS)z= Return the arguments in their raw, unredacted form. cSs g|]}t|tr|jn|qSr)rrsecret)r!rrrr Dsz'reveal_command_args..r)rrrrreveal_command_args@sr'FraiseTz"Literal["raise", "warn", "ignore"]) cmd show_stdoutcwd on_returncodeextra_ok_returncodes extra_environ unset_environspinnerlog_failed_cmd stdout_only command_descrc  Cs|dkr g}|dkrg}|r*tj} tj} n tj} t} t| k} | oL|dk }| d| tj }|rp| |x|D]}| |dqvWy0t j t|t jt j| st jnt j||dd}Wn6tk r}z|rtd|| Wdd}~XYnXg}| s|jst|jst|jxN|j}|s2P|}||d| ||r |s`t|q Wz |Wd|jr|jXd|}n\|\}}x|D]}| |qW||x|D]}| |qW|||}|jo|j|k}|r6|st|r,| dn | d |r|d krt!| |j| sX|ndd }|rt"d |tjd t#t$|ddidtjdt#|pdddid|n8|dkrt%d| |j|n|dkrnt&d||S)a Args: show_stdout: if true, use INFO to log the subprocess's stderr and stdout streams. Otherwise, use DEBUG. Defaults to False. extra_ok_returncodes: an iterable of integer return codes that are acceptable, in addition to 0. Defaults to None, which means []. unset_environ: an iterable of environment variable names to unset prior to calling subprocess.Popen(). log_failed_cmd: if false, failed commands are not logged, only raised. stdout_only: if true, return only stdout, else return both. When true, logging of both stdout and stderr occurs when the subprocess has terminated, else logging occurs as subprocess output is produced. NzRunning command %sbackslashreplace)stdinstdoutstderrr+enverrorsz#Error %s while executing command %s errordoner()command_description exit_code output_linesz[present-rich] %sz*[bold magenta]full command[/]: [blue]%s[/]markupT)extraz[bold magenta]cwd[/]: %sz [inherit]warnz$Command "%s" had error code %s in %signorezInvalid value: on_returncode=)'rinfologgingINFOverbosergetEffectiveLevelosenvironcopyupdatepop subprocessPopenr'PIPESTDOUT Exceptioncriticalr6AssertionErrorr5closereadlinerstriprspinwaitr# communicate splitlines returncodefinishr r<r r$warning ValueError)r)r*r+r,r-r.r/r0r1r2r3log_subprocess used_levelshowing_subprocess use_spinnerr8nameprocexc all_outputlineoutputouterrout_lineerr_lineproc_had_errorr<rrrcall_subprocessGs                            rp).N)messagercs2dttttttttfddfdd }|S)zProvide a subprocess_runner that shows a spinner message. Intended for use with for BuildBackendHookCaller. Thus, the runner has an API that matches what's expected by BuildBackendHookCaller.subprocess_runner. N)r)r+r.rc s*t}t||||dWdQRXdS)N)r3r+r.r0)r rp)r)r+r.r0)rqrrrunners z+runner_with_spinner_message..runner)NN)rr rrr)rqrrr)rqrrunner_with_spinner_messages  rs) FNr(NNNNTF)#rFrJrrOtypingrrrrrrrr Zpip._vendor.rich.markupr pip._internal.cli.spinnersr r pip._internal.exceptionsr pip._internal.utils.loggingrrpip._internal.utils.miscrrr CommandArgsrr$r'boolintrprsrrrrs8(     N