(^SrSSKJr SSKJr SSKJr SSKrSSKrSSKJr SSK J r SSK J r SSKJ r SS KJr SS KJr SS KJr SS KJr SS KJr SSKrSrSrSrSrSrSrSrSr Sr!Sr"Sr#S(Sjr$S)Sjr%Sr&Sr'Sr(Sr)S(Sjr*Sr+S r,S!r-S)S"jr.S#r/S$r0S%r1S*S&jr2S'r3g)+z2Common helper methods for Runtime Config commands.)absolute_import)division)unicode_literalsN)encoding) exceptions)apis)log) properties) resources)progress_tracker)retryzread operation timed outic(SRSU/5$)N/projects)join)projects 1lib/googlecloudsdk/api_lib/runtime_config/util.py ProjectPathr5s :w' ((c<SR[U5SU/5$)Nrconfigs)rr)rconfigs r ConfigPathr9s ;w'F; <[[T55R$Nr- ConfigNamer%argssr#ParseVariableName..hOJt,<=HHrc@>[[T55R$r0r-r2 configsIdr3srr5r6i?:d+;<FFrr%r:z(runtimeconfig.projects.configs.variablesr&r r*r+) variable_namer4r(s ` rParseVariableNamer?Xs< IF &    ! !;  " rc\^U4SjU4SjS.n[RRUSUS9$)zParse a waiter name or URL, and return a resource. Args: waiter_name: The waiter name. args: CLI arguments, possibly containing a config name. Returns: The parsed resource. c@>[[T55R$r0r1r3srr5!ParseWaiterName..}r7rc@>[[T55R$r0r9r3srr5rB~r;rr<z&runtimeconfig.projects.configs.waitersr&r=) waiter_namer4r(s ` rParseWaiterNamerErs<IF &    ! !9  " rc|U(a)[USS5(d[R"SS5e[USS5$)Nr,rz$--config-name parameter is required.)getattrsdk_exceptionsRequiredArgumentException)r4requireds rr2r2s= gdM488  2 28 :: }d ++rcl[R"SS5nUbXRlUbXlU$N runtimeconfigv1beta1)rGetClientInstancehttptimeout num_retries)rQrRclients rClientrTs5  ! !/9 =& !KK$ -rc ,[S0UD6R$N)rTprojects_configskwargss r ConfigClientr[s  &  * **rc ,[S0UD6R$rV)rTprojects_configs_variablesrYs rVariableClientr^s  &  4 44rc ,[S0UD6R$rV)rTprojects_configs_waitersrYs r WaiterClientras  &  2 22rc0[R"SS5$rL)rGetMessagesModulerWrrMessagesrds   ;;rcd[RRRR US9$)NrJ)r VALUEScorerGetrfs rr)r)s(      ' ' + +X + >>rc"[USS5S:H$)N status_codeirGerrors rIsBadGatewayErrorro  t , 33rc"[USS5S:H$)Nrkirlrms rIsDeadlineExceededErrorrrrprc~[U[R5=(d [[R "U5;$r0) isinstancesocketrQTIMEOUT_ERR_TEXTsix text_typerms rIsSocketTimeoutrys- UFNN + 6 u!5 57rcjUbUO[nUbUO[n[5n[R"US-S9nUR R RUR5S9n[R"SRUR555 URURU/US-SS9nSSS5 WR$bUR$R&b5S RUR5UR$R&5nOS RUR55n[(R$"U5 U$![Ra5 [ R""SRUR5U55ef=f!,(df  N=f) azWait for a waiter to finish. Args: waiter_resource: The waiter resource to wait for. sleep: The number of seconds to sleep between status checks. max_wait: The maximum number of seconds to wait before an error is raised. Returns: The last retrieved value of the Waiter. Raises: WaitTimeoutError: If the wait operation takes longer than the maximum wait time. Ni) max_wait_msnamez"Waiting for waiter [{0}] to finishc$UR(+$r0)done)wss rr5WaitForWaiter..s aff*r)r4sleep_msshould_retry_ifz/Waiter [{0}] did not finish within {1} seconds.z(Waiter [{0}] finished with an error: {1}z$Waiter [{0}] finished with an error.)DEFAULT_WAITER_SLEEPMAX_WAITER_TIMEOUTrar RetryerrSMESSAGES_MODULE-RuntimeconfigProjectsConfigsWaitersGetRequest RelativeNamer ProgressTrackerformatName RetryOnResultri WaitExceptionrtc_exceptionsWaitTimeoutErrorrnmessager )waiter_resourcesleepmax_wait waiter_clientretryerrequestresultrs r WaitForWaiterrs$%*>%!-X3E(.- MMho 6'  ! ! 1 1;;%224<6 ''*11/2F2F2HIK1$$]%6%6+2).3dl5L%NfK \\ ||':AA    &,,"6"68g7==    "gIIg -   1  + + ; B B""$h 0 111KKsF$!EA F!!F$$ F2cURSL$)z0Returns True if the specified waiter has failed.Nrm)r"s rIsFailedWaiterrs T !!rc[R"U5nSU;a'SU;a [S5eUSUS'U"US5US'U$)a/Returns a dict representation of the message with a shortened name value. This method does three things: 1. converts message to a dict. 2. shortens the value of the name field using name_converter 3. sets atomicName to the original value of name. Args: message: A protorpclite message. name_converter: A function that takes an atomic name as a parameter and returns a shortened name. Returns: A dict representation of the message with a shortened name field. Raises: ValueError: If the original message already contains an atomicName field. r} atomicNamez4Original message cannot contain an atomicName field.)r MessageToDict ValueError)rname_converter message_dicts r_DictWithShortNamers[&''0, ||# M NN!-f!5L),v*>?L rc[US5$)z;Returns the config message as a dict with a shortened name.c*URS5S$Nrsplitr|s rr5FormatConfig..$**S/"2Errrs r FormatConfigr G%E FFrc[US5nU(a,SU;a USUS'U$[R"US5US'U$)aReturns the variable message as a dict with a shortened name. This method first converts the variable message to a dict with a shortened name and an atomicName. Then, decodes the variable value in the dict if the output_value flag is True. Args: message: A protorpclite message. output_value: A bool flag indicates whether we want to decode and output the values of the variables. The default value of this flag is False. Returns: A dict representation of the message with a shortened name field. cPSRURS5[S5$)Nr)rrVARIABLE_NAME_PREFIX_LENGTHr|s rr5 FormatVariable..1s388DJJsO,G,HIJrtextvalue)rbase64 b64decode)r output_valuers rFormatVariablers]$$ JL,*62l7 %..|G/DEl7 rc[US5$)z;Returns the waiter message as a dict with a shortened name.c*URS5S$rrr|s rr5FormatWaiter..Crrrrs r FormatWaiterr>rr)T)NN)F)4__doc__ __future__rrrrruapitools.base.pyr%googlecloudsdk.api_lib.runtime_configrrgooglecloudsdk.api_lib.utilrgooglecloudsdk.callioperHgooglecloudsdk.corer r r googlecloudsdk.core.consoler googlecloudsdk.core.utilr rwrvrrrrrrr#r-r?rEr2rTr[r^rardr)rorrryrrrrrrrWrrrs 9&' %N,@#*)8* ." )=* D 1"4*,+53<?447-`" BGBGr