dSrSSKJr SSKJr SSKJr SSKrSSKrSSKrSSKJ r SSK J r SSK J r SS K Jr SS K Jr SS K Jr SS KJr SS KJr SSKJr SSKJr SSKJr SSKrSrSrSrSrSr"SS\R@5r!"SS\!5r""SS\!5r#"SS\!5r$"SS\!5r%"S S!\!5r&"S"S#\!5r'"S$S%\!5r(S&r)S'r*S;S(jr+S;S)jr,S;S*jr-SS.jr1S/r2S?S0jr3S>S1jr4S2r5S;S3jr6S;S4jr7S@S5jr8S6r9"S7S8\Rt"\Rv\<55r="S9S:\Rt"\Rv\=55r>g)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?c[R"[RURUR UR S95 g)N)commandcontext exit_code)r error_DEFAULT_FAILURE_ERROR_MESSAGEformatexecuted_commandrr) result_objects ?lib/googlecloudsdk/command_lib/util/anthos/binary_operations.py_LogDefaultOperationFailurer6s<))$++00''!++,-.c\rSrSrSrSrg)BinaryOperationError>z'Base class for binary operation errors.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r rrrr>s/rrc,^\rSrSrSrU4SjrSrU=r$)BinaryExecutionErrorB5Raised if there is an error executing the executable.cJ>[[U] SRX!55 g)Nz$Error executing binary on [{}]: [{}])superr)__init__r)selforiginal_errorr __class__s rr.BinaryExecutionError.__init__Es'  ?FF'(rr r"r#r$r%r&r.r' __classcell__r1s@rr)r)Bs=((rr)c\rSrSrSrSrg)InvalidOperationForBinaryKz8Raised when an invalid Operation is invoked on a binary.r Nr!r rrr7r7Ks@rr7c\rSrSrSrSrg)StructuredOutputErrorOz@Raised when there is a problem processing as sturctured message.r Nr!r rrr:r:OsHrr:c0^\rSrSrSrSU4SjjrSrU=r$)MissingExecutableExceptionSz5Raised if an executable can not be found on the path.cj>U(aUnO[RU5n[[U]U5 gN)_DEFAULT_MISSING_EXEC_MESSAGErr-r=r.)r/ exec_namecustom_message error_msgr1s rr.#MissingExecutableException.__init__Vs+ i/66yAi $d4Y?rr r@r3r5s@rr=r=Ss=@@rr=c,^\rSrSrSrU4SjrSrU=r$)ExecutionError`r+cJ>[[U] SRX55 g)Nz%Error executing command on [{}]: [{}])r-rGr.r)r/rrr1s rr.ExecutionError.__init__cs& . @GGrr r3r5s@rrGrG`s=rrGc,^\rSrSrSrU4SjrSrU=r$)InvalidWorkingDirectoryErrorizCRaised when an invalid path is passed for binary working directory.cJ>[[U] SRX55 g)Nz2Error executing command on [{}]. Invalid Path [{}])r-rLr.r)r/rpathr1s rr.%InvalidWorkingDirectoryError.__init__ls$ &6<CC  rr r3r5s@rrLrLisKrrLc\rSrSrSrSrg) ArgumentErrorrz:Raised if there is an error parsing argument to a command.r Nr!r rrrRrRrsBrrRc^U4SjnU$)z.Default processing for stdout from subprocess.cD>UR5nU(aUTlggr@)rstripstdout)rW result_holders r HandleStdOut*DefaultStdOutHandler..HandleStdOuty ]]_F #mrr )rXrYs` rDefaultStdOutHandlerr\v$ rc^U4SjnU$)z.Default processing for stderr from subprocess.cD>UR5nU(aUTlggr@)rVstderr)r`rXs r HandleStdErr*DefaultStdErrHandler..HandleStdErrr[rr )rXras` rDefaultStdErrHandlerrcr]rc|URS:waSUlU(aUR(a [U5 ggg)z1Default processing for subprocess failure status.rTN)rfailedrrXshow_exec_errors rDefaultFailureHandlerrhs2!M-- .._rc^^UU4SjnU$)z8Default processing for streaming stdout from subprocess.c>U(a&UR5 [R"U5 T(a4TR(d/TlTRR U5 ggr@)rVr PrintrWappendlinecapture_outputrXs rrY-DefaultStreamOutHandler..HandleStdOutsG  kkm iio  ! !! !!$'rr )rXrorYs`` rDefaultStreamOutHandlerrqs( rc^^UU4SjnU$)z8Default processing for streaming stderr from subprocess.c>U(a[RRU5 T(a4TR(d/TlTRR U5 ggr@)r statusrkr`rlrms rra-DefaultStreamErrHandler..HandleStdErrsE  jjt  ! !! !!$'rr )rXroras`` rDefaultStreamErrHandlerrvs( rc[RRUR5US9$![R[R 4an[ SRXS95eSnAff=f)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 FromStringstripMessageParsingErrorInvalidMessageErrorr:r) msg_stringrxes rReadStructuredOutputrspK   & &z'7'7'97 & KK ""8"8 9K !**0&Z&*I KKKs+.$A/A**A/c`SnSnU(aUR5n[U5nUR(aJ[RR UR 5 [R "UR5 O [R "UR 5 UR U4$)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)r}r resource_bodyr rtrkbody)rnry resourcesmsg_recs r_LogStructuredStdOutrsx #) jjlG w 'C  jjsxx  ii!!" ii ((I rcUR(d/UlU(aURRU5 U(aURRU5 U(aURRU5 gg)z8Update OperationResult from OutputMessage or plain text.N)rWrl)rXoutput_messageresource_output raw_outputs r_CaptureStdOutrs_   M/0 +rc^^^UUU4SjnU$)zBDefault processing for structured stdout from threaded subprocess.cV>U(a1UR5n[U5up#T(a [TX#S9 ggg![acnT(a)[R "[ RU55 [RRU5 [TUS9 SnAgSnAff=f)zProcess structured stdout.)rrrN) r}rrr:r warning_STRUCTURED_TEXT_EXPECTED_ERRORroutrk)rnrryrsmerorXwarn_if_not_stuctureds rrY7DefaultStreamStructuredOutHandler..HandleStdOuts  g :-g6  C L   #: ++5<">"E"E"GH  +rc^^^UUU4SjnU$)zBDefault processing for structured stderr from threaded subprocess.c>U(GaiUR5n[U5nUR5(aURS:Xa/[R "UR R55 OURS:Xa/[R"UR R55 OURS:Xa/[R"UR R55 OhURS:Xa.[R"UR R55 O)[RRUR5 T(a [TUS9 ggg![aonT(a)[R"[ R#U55 [RRU5 T(a[TUS9 SnAgSnAgSnAff=f)aOHandle 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)rrN)r}rrlevelr rrrrrrrtrkrrr:rr)rnrryrrorXrs rra7DefaultStreamStructuredErrHandler..HandleStdErr@sH  g<"4( ;;== YY& HHS&&--/ 0yyG# IIc''..0 1yyI% KK))002 3yyG# IIc''..0 1 **  388 $  s ;  "#< ++5<A G((G-r )rXrorras``` r!DefaultStreamStructuredErrHandlerr;s !*>M-- .._rc8[R"5R(a[RR 5OSn[ R"USS9nXRUS9;$![Ra [R"S5 gf=f)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 BB#C% %%   KKLM s%A,,*BBc[X5nU(a=[RR[R "5R U5$[R"U5nU(a[R"SU5 U$U(a4[R"SU5 [U[RUS95$[X5e)alCheck if binary is installed and return path or raise error. Prefer the installed component over any version found on path. Args: binary_name: str, name of binary to search for. check_hidden: bool, whether to check hidden components for the binary. custom_message: str, custom message to used by MissingExecutableException if thrown. install_if_missing: bool, if true will prompt user to install binary if not found. Returns: Path to executable if found on path or installed component. Raises: MissingExecutableException: if executable can not be found or can not be installed as a component. zFound executable on path: %szInstalling %s...)binary)rosrOjoinrr sdk_bin_pathrFindExecutableOnPathr rInstallBinaryNoOverrides_INSTALL_MISSING_EXEC_PROMPTrr=) binary_namerrCinstall_if_missing is_componentpath_executables rCheckForInstalledBinaryrs./{I, 77<< 33[ AA..{;/II,o> II +. #188 8L NN #;??rcJ[R"SUSSRU5S9 [RR 5n[ R"US9nURU/5 [R"U5nU(aU$[USRU55e)zFHelper method for installing binary dependencies within command execs.zPausing command execution:Tz8Aborting component install for {} and command execution.)message prompt_string cancel_on_no cancel_string)rz{} binary not installed) r PromptContinuerrrrrrInstallrrr=)rpromptrupdate_manager_clientrs rrrs *N vk     ' ' )((66xP ...{;/ ",33K@ BBrc\rSrSrSr"SS\5rSSjr\S5r \S5r \S 5r SS jr \ RS 5rS rS rg)BinaryBackedOperationizBClass for declarative operations implemented as external binaries.c>\rSrSrSrS SjrSrSrSrSr g) %BinaryBackedOperation.OperationResultiz6Generic Holder for Operation return values and errors.NcLXlX lX0lX@lX`lXPlgr@)rrWr`rrre)r/ command_stroutputrrtreexecution_contexts rr..BinaryBackedOperation.OperationResult.__init__s#*kkn&lkrc [R"5nURUS'URUS'URUS'UR US'UR US'URUS'[R"U5$)NrrWr`rrer) collections OrderedDictrrWr`rrerr dump)r/rs r__str__-BinaryBackedOperation.OperationResult.__str__sw&&(f#'#8#8f  fXfX NNf[fX$(LLf ! YYv rc[U[R5(aURUR:H=(a URUR:H=(ay UR UR :H=(aY UR UR :H=(a9 URUR:H=(a URUR:H$g)NF) isinstancerOperationResultrrWr`rrer)r/others r__eq__,BinaryBackedOperation.OperationResult.__eq__s E0@@ A A%%)?)??N u||+N04 u||0KN%//1N u||+N15  0M Orc"UR5$r@)rr/s r__repr__.BinaryBackedOperation.OperationResult.__repr__ s \\^r)rrrrer`rW)NNrFN) r"r#r$r%r&r.rrrr'r rrrrs*@#' rrNc [UUU U(aUSOSS9UlXlX lXplU=(d [ UlU=(d [UlU=(d [Ul g)aVCreates the Binary Operation. Args: binary: executable, the name of binary containing the underlying operations that this class will invoke. binary_version: string, version of the wrapped binary. check_hidden: bool, whether to look for the binary in hidden components. std_out_func: callable(OperationResult, **kwargs), returns a function to call to process stdout from executable and build OperationResult std_err_func: callable(OperationResult, **kwargs), returns a function to call to process stderr from executable and build OperationResult failure_func: callable(OperationResult), function to call to determine if the operation result is a failure. Useful for cases where underlying binary can exit with non-zero error code yet still succeed. default_args: dict{str:str}, mapping of parameter names to values containing default/static values that should always be passed to the command. custom_errors: dict(str:str}, map of custom exception messages to be used for known errors. install_if_missing: bool, if True prompt for install on missing component. MISSING_EXECN)rrrrC) r _executable_binary_version _default_argsr\std_out_handlerrcstd_err_handlerrhset_failure_status) r/rbinary_versionr std_out_func std_err_func failure_func default_args custom_errorsrs rr.BinaryBackedOperation.__init__sc>/!-8E}^44 QD L"M%'?+?D'?+?D*C.CDrcUR$r@)rrs rr!BinaryBackedOperation.binary_name9s <<rcUR$r@)rrs r executable BinaryBackedOperation.executable=s   rcUR$r@)rrs rdefaultsBinaryBackedOperation.defaultsAs   rc VUUURS5S.nURXS9nURU5nURU5n[R R US5n URS5n U (a/[R RU 5(d [X5e[R"USUUUU US9n XlURXdRSS 55 U$![R[R4an [X5eSn A ff=f) Execute binary and return operation result. Will parse args from kwargs into a list of args to pass to underlying binary and then attempt to execute it. Will use configured stdout, stderr and failure handlers for this operation if configured or module defaults. Args: cmd: [str], command to be executed with args stdin: str, data to send to binary on stdin env: {str, str}, environment vars to send to binary. **kwargs: mapping of additional arguments to pass to the underlying executor. Returns: OperationResult: execution result for this invocation of the binary. Raises: ArgumentError, if there is an error parsing the supplied arguments. BinaryOperationError, if there is an error executing the binary. execution_direnvstdinexec_dirrrrTargsno_exitout_funcerr_funcin_strcwdr NrgF)getrrrrrObasenameisdirrLr ExecPermissionErrorInvalidCommandErrorrGrr r/cmdrr kwargs op_contextrXrrshort_cmd_name working_dirrrs r_ExecuteBinaryBackedOperation._ExecuteEs",JJ/J (()7M**=9O**=9OWW%%c!f-N.JJ/k RWW]];77*>GG!&&""i(M::6G+OP   + +  / / 1. > --.s*A!C44$D( D##D(c g)a:Parse and validate kwargs into command argument list. Will process any default_args first before processing kwargs, overriding as needed. Will also perform any validation on passed arguments. If calling a named sub-command on the underlying binary (vs. just executing the root binary), the sub-command should be the 1st argument returned in the list. Args: **kwargs: keyword arguments for the underlying command. Returns: list of arguments to pass to execution of underlying command. Raises: ArgumentError: if there is an error parsing or validating arguments. Nr )r/r s r_ParseArgsForCommand*BinaryBackedOperation._ParseArgsForCommandzs$ rc UR/nURUR"S0UD65 UR"U40UD6$)Nr )rextendr'r$)r/r rs r__call__BinaryBackedOperation.__call__s< ?? CJJt((2623 == ' ''r)rrrrrrr)NFNNNNNFr)r"r#r$r%r&objectrr.propertyrrrr$abcabstractmethodr'r+r'r rrrrsJ$$P#!    !"')DV      3j  &(rrcN^\rSrSrSrSU4SjjrSSjrSrU=r$)StreamingBinaryBackedOperationizEExtend Binary Operations for binaries which require streaming output.c >[[U] XX4XVUX5 XlU (a [n [ n O [ n [n U=(d U UlU=(d U Ul Xl gr@) r-r2r.rorrrqrvrrstructured_output)r/rrrrrrrrror4rdefault_out_handlerdefault_err_handlerr1s rr.'StreamingBinaryBackedOperation.__init__sj ( %\&<)==33'>+>D'>+>D.rc vUUURS5S.nURXS9nURX`RS9nUR X`RS9n[ R RUS5n URS5n U (a/[ R RU 5(d [X5e[R"USUUUU US9n XlUR!XdRS S 55 U$![R[R4an [X5eSn A ff=f) r r r r)rXrorTrNrgF)rrrrorrrOrrrLr ExecWithStreamingOutputrrrGrrrs rr$'StreamingBinaryBackedOperation._Executes@,JJ/J (()7M**#4G4G+IO**#4G4G+IOWW%%c!f-N.JJ/k RWW]];77*>GG!99""i(M::6G+OP   + +  / / 1. > --.s:A!D$D8( D33D8)rorrr4) NFNNNNNFFFr) r"r#r$r%r&r.r$r'r4r5s@rr2r2s5M#!    !#!&"'/644rr2)F)T)NNN)FTr)FNF)?r& __future__rrrr/rr&googlecloudsdk.command_lib.util.anthosrrzgooglecloudsdk.corerrcore_exceptionsr r r googlecloudsdk.core.consoler googlecloudsdk.core.updaterr rgooglecloudsdk.core.utilrrsixrrArrrrrr)r7r:r=rGrLrRr\rcrhrqrvrrrrrrrrrrrrwith_metaclassABCMetar-rr2r rrrEs5&'  L&=/#$236*. +!=$< .0?000(/(A 4AI0I @!5 @)#7C(C/  K.D#'#'" ,"6;<@.< ,6;<@(V@/.*/+//4&@RB(l(C..s{{FCl(^Ss{{$9:Sr