':SrSSKrSSKrSSKJr SSKJr SSKJ r SSK Jr SSK J r SSK Jr SSK Jr SS KJr SS KJr SSKrS rS rS rS rSrSrSrSrSrSrSrS%Sjr S&Sjr!Sr"Sr#Sr$Sr%S%Sjr&Sr'Sr(Sr)S&Sjr*S r+S!r,S"r-S'S#jr.S$r/g)(z2Common helper methods for Runtime Config commands.N)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 ProjectPathr2s :w' ((c<SR[U5SU/5$)Nr configs)rr)rconfigs r ConfigPathr6s ;w'F; <[[T55R$Nr* ConfigNamer"argssr#ParseVariableName..eOJt,<=HHrc@>[[T55R$r-r*r/ configsIdr0srr2r3f?:d+;<FFrr"r7z(runtimeconfig.projects.configs.variablesr#rr'r() variable_namer1r%s ` rParseVariableNamer<Us< 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$r-r.r0srr2!ParseWaiterName..zr4rc@>[[T55R$r-r6r0srr2r?{r8rr9z&runtimeconfig.projects.configs.waitersr#r:) waiter_namer1r%s ` rParseWaiterNamerBos<IF &    ! !9  " rc|U(a)[USS5(d[R"SS5e[USS5$)Nr)rz$--config-name parameter is required.)getattrsdk_exceptionsRequiredArgumentException)r1requireds rr/r/s= gdM488  2 28 :: }d ++rcl[R"SS5nUbXRlUbXlU$N runtimeconfigv1beta1)rGetClientInstancehttptimeout num_retries)rNrOclients rClientrQs5  ! !/9 =& !KK$ -rc ,[S0UD6R$N)rQprojects_configskwargss r ConfigClientrXs  &  * **rc ,[S0UD6R$rS)rQprojects_configs_variablesrVs rVariableClientr[s  &  4 44rc ,[S0UD6R$rS)rQprojects_configs_waitersrVs r WaiterClientr^s  &  2 22rc0[R"SS5$rI)rGetMessagesModulerTrrMessagesras   ;;rcd[RRRR US9$)NrG)rVALUEScorerGetrcs rr&r&s(      ' ' + +X + >>rc"[USS5S:H$)N status_codeirDerrors rIsBadGatewayErrorrl  t , 33rc"[USS5S:H$)Nrhirirjs rIsDeadlineExceededErrorrormrc~[U[R5=(d [[R "U5;$r-) isinstancesocketrNTIMEOUT_ERR_TEXTsix text_typerjs rIsSocketTimeoutrvs- 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(+$r-)done)wss rr2WaitForWaiter..s aff*r)r1sleep_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_TIMEOUTr^r RetryerrPMESSAGES_MODULE-RuntimeconfigProjectsConfigsWaitersGetRequest RelativeNamer ProgressTrackerformatName RetryOnResultrf WaitExceptionrtc_exceptionsWaitTimeoutErrorrkmessager)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.Nrj)rs 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. rz 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$Nr splitrys rr2FormatConfig..$**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_LENGTHrys rr2 FormatVariable...s388DJJsO,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$rrrys rr2FormatWaiter..@rrrrs r FormatWaiterr;rr)T)NN)F)0__doc__rrrapitools.base.pyr%googlecloudsdk.api_lib.runtime_configrrgooglecloudsdk.api_lib.utilrgooglecloudsdk.callioperEgooglecloudsdk.corerrrgooglecloudsdk.core.consoler googlecloudsdk.core.utilr rtrsrrrrrrr r*r<rBr/rQrXr[r^rar&rlrorvrrrrrrrTrrrs 9 %N,@#*)8* ." )=* D 1"4*,+53<?447-`" BGBGr