ddZddlmZddlmZddlmZddlZddlZddlZddlm Z ddl m Z ddl m Zdd l mZdd l mZdd l mZdd lmZdd lmZddlmZddlmZddlmZddlZdZdZdZdZdZGddej@Z!Gdde!Z"Gdde!Z#Gdde!Z$Gdde!Z%Gd d!e!Z&Gd"d#e!Z'Gd$d%e!Z(d&Z)d'Z*d;d(Z+d;d)Z,d;d*Z-dd.Z1d/Z2d?d0Z3 d>d1Z4d2Z5d;d3Z6d;d4Z7 d@d5Z8d6Z9Gd7d8ejtejve<Z=Gd9d:ejtejve=Z>y)Az.Library for defining Binary backed operations.)absolute_import)division)unicode_literalsN)structured_messages)config) exceptions)execution_utils)log)yaml) console_io) local_state)update_manager)files) platformszdError executing command [{command}] (with context [{context}]). Process exited with code {exit_code}zExecutable [{}] not found.z3Expected structured message, logging as raw text:{}zThis command requires the `{binary}` component to be installed. Would you like to install the `{binary}` component to continue command execution?ctjtj|j|j |j y)N)commandcontext exit_code)r error_DEFAULT_FAILURE_ERROR_MESSAGEformatexecuted_commandrr) result_objects ?lib/googlecloudsdk/command_lib/util/anthos/binary_operations.py_LogDefaultOperationFailurer6s<))$++00''!++,-.ceZdZdZy)BinaryOperationErrorz'Base class for binary operation errors.N__name__ __module__ __qualname____doc__rrrr>s/rrc"eZdZdZfdZxZS)BinaryExecutionError5Raised if there is an error executing the executable.cLtt| dj||y)Nz$Error executing binary on [{}]: [{}])superr&__init__r)selforiginal_errorr __class__s rr*zBinaryExecutionError.__init__Es)  ?FF~'(rr r!r"r#r* __classcell__r-s@rr&r&Bs=((rr&ceZdZdZy)InvalidOperationForBinaryz8Raised when an invalid Operation is invoked on a binary.Nrr$rrr2r2Ks@rr2ceZdZdZy)StructuredOutputErrorz@Raised when there is a problem processing as sturctured message.Nrr$rrr4r4OsHrr4c$eZdZdZdfd ZxZS)MissingExecutableExceptionz5Raised if an executable can not be found on the path.c`|r|}ntj|}tt||yN)_DEFAULT_MISSING_EXEC_MESSAGErr)r6r*)r+ exec_namecustom_message error_msgr-s rr*z#MissingExecutableException.__init__Vs+ i/66yAi $d4Y?rr8r.r0s@rr6r6Ss=@@rr6c"eZdZdZfdZxZS)ExecutionErrorr'cLtt| dj||y)Nz%Error executing command on [{}]: [{}])r)r>r*r)r+rrr-s rr*zExecutionError.__init__cs( . @GGurr.r0s@rr>r>`s=rr>c"eZdZdZfdZxZS)InvalidWorkingDirectoryErrorzCRaised when an invalid path is passed for binary working directory.cLtt| dj||y)Nz2Error executing command on [{}]. Invalid Path [{}])r)rAr*r)r+rpathr-s rr*z%InvalidWorkingDirectoryError.__init__ls& &6<CC T rr.r0s@rrArAisKrrAceZdZdZy) ArgumentErrorz:Raised if there is an error parsing argument to a command.Nrr$rrrErErsBrrEcfd}|S)z.Default processing for stdout from subprocess.c:|j}|r|_yyr8)rstripstdout)rI result_holders r HandleStdOutz*DefaultStdOutHandler..HandleStdOuty ]]_F #mrr$)rJrKs` rDefaultStdOutHandlerrMv$ rcfd}|S)z.Default processing for stderr from subprocess.c:|j}|r|_yyr8)rHstderr)rQrJs r HandleStdErrz*DefaultStdErrHandler..HandleStdErrrLrr$)rJrRs` rDefaultStdErrHandlerrSrNrcf|jdk7rd|_|r|jr t|yyy)z1Default processing for subprocess failure status.rTN)rfailedrrJshow_exec_errors rDefaultFailureHandlerrXs2!M-- .._rcfd}|S)z8Default processing for streaming stdout from subprocess.c|r%|jtj|r/jsg_jj |yyr8)rHr PrintrIappendlinecapture_outputrJs rrKz-DefaultStreamOutHandler..HandleStdOutsG  kkm iio  ! !! !!$'rr$)rJr_rKs`` rDefaultStreamOutHandlerr`s( rcfd}|S)z8Default processing for streaming stderr from subprocess.c|rtjj|r/jsg_jj |yyr8)r statusr[rQr\r]s rrRz-DefaultStreamErrHandler..HandleStdErrsE  jjt  ! !! !!$'rr$)rJr_rRs`` rDefaultStreamErrHandlerrds( rc tjj|j|S#tjtj f$r!}t dj||d}~wwxYw)aProcess a line of structured output into an OutputMessgage. Args: msg_string: string, line JSON/YAML formatted raw output text. as_json: boolean, if True set default string representation for parsed message to JSON. If False (default) use YAML. Returns: OutputMessage, parsed Message Raises: StructuredOutputError is msg_string can not be parsed as an OutputMessage. )as_jsonz=Error processing message [{msg}] as an OutputMessage: {error})msgrN)sm OutputMessage FromStringstripMessageParsingErrorInvalidMessageErrorr4r) msg_stringrfes rReadStructuredOutputrpsrK   & &z'7'7'97 & KK ""8"8 9K !**0&Zq&*I KKKs.1#A5A00A5cHd}d}|r|j}t|}|jrItjj |j tj |jntj |j |j |fS)aParse and log stdout text as an OutputMessage. Attempts to parse line into an OutputMessage and log any resource output or status messages accordingly. If message can not be parsed, raises a StructuredOutputError. Args: line: string, line of output read from stdout. Returns: Tuple: (str, object): Tuple of parsed OutputMessage body and processed resources or None. Raises: StructuredOutputError, if line can not be parsed. N)rkrp resource_bodyr rcr[body)r^rg resourcesmsg_recs r_LogStructuredStdOutrvsx #) jjlG w 'C  jjsxx  ii!!" ii ((I rc|jsg|_|r|jj||r|jj||r|jj|yy)z8Update OperationResult from OutputMessage or plain text.N)rIr\)rJoutput_messageresource_output raw_outputs r_CaptureStdOutr{s_   M/0 +rcfd}|S)zBDefault processing for structured stdout from threaded subprocess.cD|r1|j} t|\}}rt||yyy#t$r`}r(t j t j|tjj|t|Yd}~yd}~wwxYw)zProcess structured stdout.)rxryrzN) rkrvr{r4r warning_STRUCTURED_TEXT_EXPECTED_ERRORroutr[)r^rurgrtsmer_rJwarn_if_not_stuctureds rrKz7DefaultStreamStructuredOutHandler..HandleStdOuts  g :-g6Y  C L   #: ++5<">"E"E"GH  +rcfd}|S)zBDefault processing for structured stderr from threaded subprocess.c|rZ|j} t|}|jr|jdk(r.t j |j jn|jdk(r.t j|j jn|jdk(r.t j|j jnf|jdk(rWt j|j jn)tjj|jrt|yyy#t$rg}r(t jt j#|tjj|rt|Yd}~yYd}~yd}~wwxYw)akHandle line as a structured message. Attempts to parse line into an OutputMessage and log any errors or warnings accordingly. If line cannot be parsed as an OutputMessage, logs it as plain text to stderr. If capture_output is True will capture any logged text to result_holder. Args: line: string, line of output read from stderr. inforrdebug)rxr~N)rkrprlevelr rrrrrrrcr[rsrr4rr)r^rurgrr_rJrs rrRz7DefaultStreamStructuredErrHandler..HandleStdErr@sH  g<"4( ;;= YY& HHS&&--/ 0yyG# IIc''..0 1yyI% KK))002 3yyG# IIc''..0 1 **  388 $  s ;  "#< ++5<*>M-- .._rc2tjjrtjj nd} t j|d}||j|vS#tj$rtjdYywxYw)NF)platform_filterwarn)include_hiddenz:Component check failed. Could not verify SDK install path.) rPathssdk_rootrPlatformCurrentr UpdateManagerGetCurrentVersionsInformationr Errorr r)component_name check_hiddenplatformmanagers rCheckBinaryComponentInstalledrs-3\\^-D-DY   ' ' )$(**8%PG WBB#C% %%   KKLM s*A++(BBc|t||}|r