+6SrSSKJr SSKJr SSKJr SSKrSSKrSSKrSSKrSSK r SSK J r SSK J r SSK Jr SS K Jr SS KJr SSKrSS KJr "S S \R*5r"SS\5r"SS\5r"SS\5r"SS\5r"SS\5rSrSr\R R:4SjrSrSr Sr!Sr"S'Sjr#S(S jr$S!r%S"r&"S#S$\'5r("S%S&\'5r)g))z!Utility functions for gcloud app.)absolute_import)division)unicode_literalsN)client_deployinfo)config) exceptions)log) platforms)urllibc\rSrSrSrSrg)Error%z!Exceptions for the appcfg module.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r&lib/googlecloudsdk/api_lib/app/util.pyr r %s)rr c\rSrSrSrSrg)NoFieldsSpecifiedError)zFThe user specified no fields to a command which requires at least one.rNrrrrrr)sNrrc,^\rSrSrSrU4SjrSrU=r$)NoCloudSDKError-z(The module was unable to find Cloud SDK.c,>[[U] S5 g)Nz(Unable to find a Cloud SDK installation.)superr__init__self __class__s rr!NoCloudSDKError.__init__0s /4)24rrrrrrrr!r __classcell__r$s@rrr-s044rrc\rSrSrSrSrg)NoAppengineSDKError5z0The module was unable to find the appengine SDK.rNrrrrr*r*5s8rr*c,^\rSrSrSrU4SjrSrU=r$) TimeoutError9z[[U] S5 g)Nz0Timed out waiting for the operation to complete.)r r-r!r"s rr!TimeoutError.__init__<s ,&:[[U] SRUR[ USS5US95 Xlg)Nz9Server responded with code [{code}]: {reason}. {body}reasonz (unknown))coder5body)r r2r!formatr6getattr url_error)r#r:r7r$s rr!RPCError.__init__Ds@ (D"E Y^^y(K@   Nr)r:r&r(s@rr2r2As9rr2c[R"5RnU(d [5e[R "SU5 U$)zGets the directory of the root of the Cloud SDK, error if it doesn't exist. Raises: NoCloudSDKError: If there is no SDK root. Returns: str, The path to the root of the Cloud SDK. zFound Cloud SDK root: %s)rPathssdk_rootrr debug)r@s rGetCloudSDKRootrBMs5\\^ $ $(   )) &1 /rc[5n[RRUSS5n[RR U5(d [ 5e[ R"SU5 U$)zGets the directory of the GAE SDK directory in the SDK. Raises: NoCloudSDKError: If there is no SDK root. NoAppengineSDKError: If the GAE SDK cannot be found. Returns: str, The path to the root of the GAE SDK within the Cloud SDK. platformgoogle_appenginezFound App Engine SDK root: %s)rBospathjoinisdirr*r rA)r@ gae_sdk_dirs rGetAppEngineSDKRootrK]sT ( Xz3EF+ { # #  )) +[9 rcU"5R5R5RSS5RSS5SS$)zGenerates a version id based off the current time. Args: datetime_getter: A function that returns a datetime.datetime instance. Returns: A version string based. -r=:N) isoformatlowerreplace)datetime_getters rGenerateVersionIdrTpsH   $ $ & , , . 6 6sB ? G G 2  rcv[R"UR[RR 56$)zHConverts a native-OS path to /-separated: os.path.join('a', 'b')->'a/b'.) posixpathrHsplitrFrGsep)rGs rConvertToPosixPathrY}s" BGGKK0 11rcUS;aUS-$U$)zCConverts a App Engine region to the format used elsewhere in Cloud.> us-central europe-west1r)regions rConvertToCloudRegionr_s ,, C< Mrc:[U5nURU5$)a)Returns whether the given path should be skipped by the skip_files field. A user can specify a `skip_files` field in their .yaml file, which is a list of regular expressions matching files that should be skipped. By this point in the code, it's been turned into one mega-regex that matches any file to skip. Args: skip_files: A regular expression object for files/directories to skip. path: str, the path to the file/directory which might be skipped (relative to the application root) Returns: bool, whether the file/dir should be skipped. )rYmatch) skip_filesrGs r ShouldSkiprcs$ D !$   $ rc## S/nU(GaZUR5n[[R"[RR X555n[ U5Hn[RR X55n[RR X5n[RRU5(a/[X5(a[R"SU5 MUv M[RRU5(dM[X5(a[R"SU5 MURU5 M U(aGMYgg7f)zWalks a directory tree, returning all the files. Follows symlinks. Args: base: The base path to search for files under. skip_files: A regular expression object for files/directories to skip. Yields: Paths of files found, relative to base. r=z.Ignoring file [%s]: File matches ignore regex.z8Ignoring directory [%s]: Directory matches ignore regex.N) popsetrFlistdirrGrHsortedisfilercr inforIappend)baserbdirs current_direntriesentrynamefullnames r FileIteratorrss $ ((*K"**RWW\\$<=>G WW\\+ -dd)h  ! ! j ' ' ((CT J* 77== " " j ' ' ((M  ++d ! sDE)AE)'E)cUnUnSn US-nU"5upU (aSU 4$US::aU(a [5eSU 4$U"X5 [R"U5 [Xs-U5nMb)aHCalls a function multiple times, backing off more and more each time. Args: func: f() -> (bool, value), A function that performs some operation that should be retried a number of times upon failure. If the first tuple element is True, we'll immediately return (True, value). If False, we'll delay a bit and try again, unless we've hit the 'max_tries' limit, in which case we'll return (False, value). retry_notify_func: f(value, delay) -> None, This function will be called immediately before the next retry delay. 'value' is the value returned by the last call to 'func'. 'delay' is the retry delay, in seconds initial_delay: int, Initial delay after first try, in seconds. backoff_factor: int, Delay will be multiplied by this factor after each try. max_delay: int, Maximum delay, in seconds. max_tries: int, Maximum number of tries (the first one counts). raise_on_timeout: bool, True to raise an exception if the operation times out instead of returning False. Returns: What the last call to 'func' returned, which is of the form (done, value). If 'done' is True, you know 'func' returned True before we ran out of retries. If 'done' is False, you know 'func' kept returning False and we ran out of retries. Raises: TimeoutError: If raise_on_timeout is True and max_tries is exhausted. NTrF)r-timesleepmin) funcretry_notify_func initial_delaybackoff_factor max_delay max_triesraise_on_timeoutdelay try_countvaluedones rRetryWithBackoffrsy> %) %  NI&KD 5[A~ n E\e#JJu & 2E rc [XUSUU5$)auCalls a function multiple times, with the same delay each time. Args: callable_func: A function that performs some operation that should be retried a number of times upon failure. Signature: () -> (done, value) If 'done' is True, we'll immediately return (True, value) If 'done' is False, we'll delay a bit and try again, unless we've hit the 'max_tries' limit, in which case we'll return (False, value). retry_notify_func: This function will be called immediately before the next retry delay. Signature: (value, delay) -> None 'value' is the value returned by the last call to 'callable_func' 'delay' is the retry delay, in seconds delay: Delay between tries, in seconds. max_tries: Maximum number of tries (the first one counts). Returns: What the last call to 'callable_func' returned, which is of the form (done, value). If 'done' is True, you know 'callable_func' returned True before we ran out of retries. If 'done' is False, you know 'callable_func' kept returning False and we ran out of retries. Raises: Whatever the function raises--an exception will immediately stop retries. ru)r) callable_funcrzrr~s rRetryNoBackoffrs4 -E1e# %%rc@SR[R5$)z%Gets the name of this source version.zGoogle-appcfg-{0})r8rCLOUD_SDK_VERSIONrrr GetSourceNamers  # #F$<$< ==rcP/nUR[R5 UR[RR 5R 55 SRS[R55nURSU-5 SRU5$)zDetermines the value of the 'User-agent' header to use for HTTP requests. Returns: String containing the 'user-agent' header value. .c3N# UHn[R"U5v M g7f)N)six text_type).0is r GetUserAgent..#sG6FCMM!,,6Fs#%z Python/%s ) rkrCLOUDSDK_USER_AGENTr PlatformCurrentUserAgentFragmentrHsys version_info)product_tokenspython_versions r GetUserAgentrs .223 **224FFHI88Gc6F6FGG. n45 . !!rcT\rSrSrSr\R 4SjrS SjrSrSr Sr Sr g ) ClientDeployLoggingContexti)aaContext for sending and recording server rpc requests. Attributes: rpcserver: The AbstractRpcServer to use for the upload. requests: A list of client_deployinfo.Request objects to include with the client deploy log. time_func: Function to get the current time in milliseconds. request_params: A dictionary with params to append to requests cBXlX lX0lX@l/Ulg)aVCreates a new AppVersionUpload. Args: rpcserver: The RPC server to use. Should be an instance of HttpRpcServer or TestRpcServer. request_params: A dictionary with params to append to requests usage_reporting: Whether to actually upload data. time_func: Function to return the current time in millisecods (default time.time). N) rpcserverrequest_paramsusage_reporting time_funcrequests)r#rrrrs rr!#ClientDeployLoggingContext.__init__4s!N(*NDMrc UR5n[U5n[R"SR XR 55 UR UR 5 URR"U4SU0UD6nURUSUU5 U$![a-nURXRRUU5 eSnAff=f)z2Sends a request to the server, with common params.zSend: {0}, params={1}payloadN) GetCurrentTimeUseclenr rAr8rupdaterSend_RegisterReqestForLoggingr2r:r6)r#urlrkwargsstart_time_usecrequest_size_bytesresulterrs rrClientDeployLoggingContext.SendIs--/OW   ii'..s4G4GHI mmD''(~~""3BB6Bf $$S#%79 m   $$S--*<*B C&(CCcR[[UR5S-S-55$)z)Returns the current time in microseconds.i)introundr)r#s rr-ClientDeployLoggingContext.GetCurrentTimeUsecZs# uT^^%,t34 55rc UR5nURR[R"UUUUUS95 g)z7Registers a request for client deploy logging purposes.)rG response_coder end_time_usecrN)rrrkrRequest)r#rGrrrrs rr4ClientDeployLoggingContext._RegisterReqestForLogging^sA++-MMM*22 #'#- /0rc UR(d[R"S5 gUR5n[R "UUUUR U[RS9nURSUR55 g![a/n[R"SRU55 SnAgSnAff=f)zLogs a client deployment attempt. Args: runtime: The runtime for the app being deployed. start_time_usec: The start time of the deployment in micro seconds. success: True if the deployment succeeded otherwise False. zSkipping usage reporting.N)runtimerrrsuccess sdk_versionz/api/logclientdeployz.Exception logging deploy info continuing - {0})rr rjrrClientDeployInfoExternalrrrrToYAML BaseExceptionrAr8)r#rrrrrjes rLogClientDeploy*ClientDeployLoggingContext.LogClientDeployis    hh*+ ++-M L  7 7)%==.. 0d ii& 6 L ii@GGJKKLsAB C%CC)rrrrrNr<) rrrrrrvr!rrrrrrrrrr)s* * "6 0Lrrc$\rSrSrSrSrSrSrg) RPCServerizThis wraps the underlying RPC server so we can make a nice error message. This will go away once we switch to just using our own http object. cXlg)zJConstruct a new rpc server. Args: original_server: The server to wrap. N_server)r#original_servers rr!RPCServer.__init__s #LrcFURR"U0UD6n[R"SU5 U$![R R aKn[US5(aUR5nOSn[R"[XES95 SnAgSnAff=f)NzGot response: %sreadr=)r7) rrr rAr error HTTPErrorhasattrrrreraiser2)r#argsrresponserr7s rrRPCServer.Sends 1""D3F3h ii"H- o << ! !1 F  vvx!/00 1s47B ABB rN)rrrrrr!rrrrrrrs # 1rr)ru<T)r)*r __future__rrrdatetimerFrVrrvgooglecloudsdk.appengine.apirgooglecloudsdk.corerrr googlecloudsdk.core.utilr r six.movesr r rrr*r-r2rBrKnowrTrYr_rcrsrrrrobjectrrrrrrs (&'  :&*#. *J  *OUO4e49%9<5< u   &'/&7&7&;&; 2  ,B67BF.3b%<> "*VLVLr11r