YSrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSKJ r SS K J r SS KJr SS K r SS KrSS KJr SS KJr SSKJr SS KrSrSrSrSrSrSrSrS'Sjr\R<R>4Sjr S \R<R>SS S S S 4Sjr!Sr"Sr#"SS\RH5r%Sr&S(Sjr'S r(S!r)S"r*S)S#jr+S$r,S%r-S&r.g )*zLibrary for obtaining API clients and messages. This should only be called by api_lib.util.apis, core.resources, gcloud meta commands, and module tests. ) apis_util)resource) exceptions)log) properties)requests) transport)regional)apis_mapN)urljoin)urlparse) urlunparsecD[RRX5U4$N)r_API_NAME_ALIASESget)api_names 0lib/googlecloudsdk/api_lib/util/apis_internal.py_GetApiNameAndAliasr's  % % ) )( =x HHc[U5up[RRU05n[R "U5Hup4UR (dMUs $ gr)rr MAPrsix iteritemsdefault_version)r_api_versverapi_defs r_GetDefaultVersionr ,sO#H-+( \\  h +(mmH-lc j. rcP[[RR55$)z6Returns list of avaiblable apis, ignoring the version.)sortedr rkeysrr _GetApiNamesr%5s  !!# $$rc[U5up[RRUS5nUc[R "U5e[ UR55$)zReturn available versions for given api. Args: api_name: str, The API name (or the command surface name, if different). Raises: apis_util.UnknownAPIError: If api_name does not exist in the APIs map. Returns: list, of version names. N)rr rrrUnknownAPIErrorlistr#)rr version_maps r _GetVersionsr*:sQ$H-+(   40+  # #H -- k !!rc[U5upU[R;a[R"U5e[ R RR5nURSRX55nU(dURUS5nU=(d Un[RUnUbX;a[R"X5eXQnU$)aReturns the APIDef for the specified API and version. Args: api_name: str, The API name (or the command surface name, if different). api_version: str, The version of the API. Raises: apis_util.UnknownAPIError: If api_name does not exist in the APIs map. apis_util.UnknownVersionError: If api_version does not exist for given api_name in the APIs map. Returns: APIDef, The APIDef for the specified API and version. z{}/{}N) rr rrr'rVALUESapi_client_overrides AllValuesrformatUnknownVersionError)r api_versionapi_name_aliasversion_overridesversion_override api_versionsrs r GetApiDefr6Ms1:( X\\!  # #H -- ''<<FFH'**7>>, (,,^TB /K+h',K;  ' ' >>'G .rc.[X5n[U5$)aReturns the client class for the API specified in the args. Args: api_name: str, The API name (or the command surface name, if different). api_version: str, The version of the API. Returns: base_api.BaseApiClient, Client class for the specified API. )r6_GetClientClassFromDefrr1rs r_GetClientClassr:ss h ,'  ((rcURRnURSS5up#[X#/S9n[ XC5$)zReturns the apitools client class for the API definition specified in args. Args: api_def: apis_map.APIDef, The definition of the API. Returns: base_api.BaseApiClient, Client class for the specified API. .fromlist)apitoolsclient_full_classpathrsplit __import__getattr)rrA module_pathclient_class_name module_objs rr8r8sC"**@@#8#?#?Q#G ++0CD*  //rFc^^U(aUbeOUcSSKJn UR[RU(aUOSS9nT(az[ XT5(ai[ X5mTTR;aNUU4Sjn[R"5RUR/U[RRS9 [X5n U(a U R n O [#XU T5n U "U SUS9n UbXKl[&R(R*R,R/5n U (a#U R1S U 5 S n S U R2U 'U $) a{Returns an instance of the API client specified in the args. Args: api_name: str, The API name (or the command surface name, if different). api_version: str, The version of the API. no_http: bool, True to not create an http object for this client. http_client: bring your own http client to use. Incompatible with no_http=True. check_response_func: error handling callback to give to apitools. http_timeout_sec: int, seconds of http timeout to set, defaults if None. region: str, Region (or multi-region) for regionalized endpoints (REP). Returns: base_api.BaseApiClient, An instance of the specified API client. r) transportsunset)response_encodingtimeoutc >UR(a[URS[RR5(a[URSR [RR 5(aI[R"SRUTSR[TR5555eUe)Nrzc{} Note: the region [{}] may not be available for this service. Known available regions are: [{}].z, ) args isinstanceurllib3r MaxRetryErrorreasonNameResolutionErrorr UnavailableRegionErrorr/joinr"regional_endpoints)erregions r%_UnavailableRegionDnsExceptionHandlerA_GetClientInstance.._UnavailableRegionDnsExceptionHandlers ffQVVAY(:(:(H(HII&&)""G$6$6$J$JLL11>>Dfvtyy0J0J)KL?NO O'r) exc_handlerexc_typeF)urlget_credentialshttpkeyzX-Google-Project-Overrideapikey)googlecloudsdk.core.credentialsrIGetApitoolsTransportr ENCODING_ShouldUseRegionalEndpointsr6rV core_requestsRequestWrapper WrapRequestsessionrrConnectionErrorr:BASE_URL_GetEffectiveApiEndpointcheck_response_funcrr,coreapi_keyGetAddGlobalParamadditional_http_headers)rr1no_http http_clientrmhttp_timeout_secrXrIrY client_classendpointclient_instanceroheaderrs ` @r_GetClientInstancerzsM0   ;11#,,$4 '2CK -hVLL(0g w11 1  $$&22    =((88 3 !7, $$H'|V5H!  /$*='    " " * * . . 0' ""5'2 (F6>O++F3 rcj[X5nU[RR:XaURR nOKU[RR :XaURRnOURRnURSS5upV[XV/S9n[Xv5$)aReturns the GAPIC client class for the API def specified by the args. Args: api_name: str, The API name (or the command surface name, if different). api_version: str, The version of the API. transport_choice: apis_util.GapicTransport, The transport to be used by the client. r<r=r>) r6rGapicTransport GRPC_ASYNCIOgapicasync_client_full_classpathRESTrest_client_full_classpathrArBrCrD)rr1transport_choicerrArErFrGs r_GetGapicClientClassrs h ,'11>>>#MMEE933888#MMDD#MM??#8#?#?Q#G ++0CD*  //rc F^^^^UUUU4Sjn /n T(a_[TTT5(aMSSKJn [TT5n TU R;a+U R TU RS9nU R U5 [TTUS9nU"UU [TT5UUU=(d /U -U S9$)aRReturns an instance of the GAPIC API client specified in the args. For apitools API clients, the API endpoint override is something like http://compute.googleapis.com/v1/. For GAPIC API clients, the DEFAULT_ENDPOINT is something like compute.googleapis.com. To use the same endpoint override property for both, we use the netloc of the API endpoint override. Args: api_name: str, The API name (or the command surface name, if different). api_version: str, The version of the API. credentials: google.auth.credentials.Credentials, the credentials to use. address_override_func: function, function to call to override the client host. It takes a single argument which is the original host. transport_choice: apis_util.GapicTransport, The transport to be used by the client. attempt_direct_path: bool, True if we want to attempt direct path gRPC where possible. redact_request_body_reason: str, the reason why the request body must be redacted if --log-http is used. If None, the body is not redacted. custom_interceptors: list[grpc interceptor], a list of custom interceptors to add to the channel. region: str, Region (or multi-region) for regionalized endpoints (REP). channel_options: dict, optional channel arguments to pass to the underlying gRPC channel. Returns: An instance of the specified GAPIC API client. c^>[RRRT5R 5nU(a[ U5RnT(aT"U5nUbU$[TTT5(a [UT5$[U5$![R a SnNqf=fr) rr,api_endpoint_overridesPropertyrpNoSuchPropertyErrorr netlocre_GetRegionalizedEndpointUniversifyAddress)addressendpoint_overrideaddress_override_funcrr1rXs rAddressOverride0_GetGapicClientInstance..AddressOverride!s$++BBKK CE *+22g%g.g$ n#8[&AA %gv 66 W %%#  ) )s7BB,+B,r)gapic_util_internal)known_available_regions)r)r mtls_enabledattempt_direct_pathredact_request_body_reasoncustom_interceptorschannel_options) regooglecloudsdk.corerr6rV$UnavailableRegionDnsErrorInterceptorappendr _MtlsEnabled)rr1 credentialsrrrrrrXrrregion_interceptorsrr interceptorrvs`` ` ` r_GetGapicClientInstancersP&&2 +Hk6JJ7+.G W///'LL '*D*DMFk  -% .>@, ++6-!;.4"8KK% rc[RRRnUR 5nUb-UR U:waUR UR US5nU$)z2Update a URL based on the current universe domain.r=)rr,rnuniverse_domainrpdefaultreplace)runiverse_domain_propertyrs rrrSs]'..33CC,002/ &&/9oo6>>-q2G .rcUc [S5eURS5S:a[SUS35eURSS5up#USUSU3$)aReturns regionalized domain. Regional endpoints (REPs) have the following format: {service}.{region}.rep.googleapis.com Args: domain: Domain for the API in form {service}.googleapis.com. region: REP region (or multi-region). Returns: str, Regionalized domain. zRegion must be provided.r<z@Base URLs should have form {service}.googleapis.com; received: [z].r=z.rep.) ValueErrorcountsplit)domainrXservice base_domains rrr^sp ^ / 00 \\#  hb " ## c1-' 9AfXU;- 00rc\rSrSrSrSrg)UnsupportedEndpointModeErroriuzGError when regional/endpoint_mode property is unsupported by a command.r$N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r$rrrrusOrrc[RRRR 5n[RRR R 5nU[RRR :XaUc[SUS35eU[RRR:Xa7U[RRR:Xa[SUS35eUbSU[RRR:Xd+Uc)U[RRR:Xag[X5RnU[RRR:Xa,U[RRR:XaX%;$X%;a[R"SX5 g)aReturns whether or not regional endpoint should be used. Depending on the user-specified regional/endpoint_mode setting and the developer-specified command annotation, this function calculates whether or not to use regional endpoints. In case of an invalid combination, an error will be raised. The full matrix is as follows: +--------------+-------------------------------------------------------------+ | | Command compatibility | | User mode +---------------+---------------+-----------------------------+ | | Only supports | Only supports | Supports both | | | global | regional | | +--------------+---------------+---------------+-----------------------------+ | regional | Error | Regional | Regional client | | | | client | | +--------------+---------------+---------------+-----------------------------+ | global | Global client | Error | Global client | +--------------+---------------+---------------+-----------------------------+ | regional- | Global client | Regional | If region available: | | preferred | | client | Regional client | | | | | Otherwise: Global client | +--------------+---------------+---------------+-----------------------------+ | (unset) | Global client | Regional | Global client | | | | client | | +--------------+---------------+---------------+-----------------------------+ Args: api_name: str, The API name. api_version: str, The version of the API. region: The region (or multi-region). Returns: bool, Whether to use regional endpoints. Raises: UnsupportedEndpointModeError: If the command does not support the given endpoint mode. z9The regional/endpoint_mode property is currently set to [z8], but this command does not support regional endpoints.z5], but this command only supports regional endpoints.FzDAPI [%s] does not contain a known regional endpoint for region [%s].T)rr,r endpoint_moderpendpoint_compatibilityREGIONALrGLOBALREQUIRED SUPPORTEDr6rVREGIONAL_PREFERREDrinfo)rr1rXmode compatibilityrs rrereysJ    # # 1 1 5 5 7$##,,CCGGI- Z   ' ' 0 00]5J & CD6J= = >> j((///z((11::: & CD6J: : ;;  ""++22 2 ,z0099CCC &h<OO j((;;; :,,55?? ?  ,, *HHN rc[X5nUR(aU=(d [X5nOU=(d [X5nUR=(d UR $)zReturns mtls endpoint.)r6r@r:rmtls_endpoint_override MTLS_BASE_URL)rr1rvrs r_GetMtlsEndpointrsK h ,' I?8#ILN#7#NL  ' ' E<+E+EErc[RRRR 5(ag[RRR R 5(dg[ X5nUR$)aChecks if the API of the given version should use mTLS. If context_aware/always_use_mtls_endpoint is True, then mTLS will always be used. If context_aware/use_client_certificate is True, then mTLS will be used only if the API version is in the mTLS allowlist. gcloud maintains a client-side allowlist for the mTLS feature (go/gcloud-rollout-mtls). Args: api_name: str, The API name. api_version: str, The version of the API. Returns: True if the given service and version is in the mTLS allowlist. TF)rr, context_awarealways_use_mtls_endpointGetBooluse_client_certificater6 enable_mtlsr9s rrrsb&$$==EEGG     ( ( ? ? G G I I  h ,'   rc[U5n[U5nURS:XdURS:waU$[SRURUR 5UR5$)zFConstructs a normalized endpoint URI depending on the client base_url./z{}://{})r pathr r/schemer)rbase_urlurl_baseurl_endpoint_overrides r_BuildEndpointOverridersn h ("#45 ]]c2773>  ,33,3356>mm EErc$[X5R(a [X5nO [X5n[ US5(a UR nO[ X5R n[U5$![a SRX5nN(f=f)zReturns base url for given api.rkzhttps://{}.googleapis.com/{}) r6r@r:rhasattrrk_GetResourceModuleAttributeErrorr/r)rr1rvclient_base_urls r_GetBaseUrlFromApirsx%.."89L'>L \:&&"++O*8AJJo ? ++ 6== osA11BBc`[RRRU5R 5n[ X5nUR(aU=(d [X5nOU=(d [X5n[X5nU(a [XF5nU$[X5(a[[XU55nU$[XU5(a;[!U5n[#UR$U5n ['UR)U S95nU$UnU$![R a SnNf=f)z)Returns effective endpoint for given api.N)r)rr,rrrprr6r@r:rrrrrrrer rrr_replace) rr1rvrXrrrrrregionalized_domains rrlrls"))@@II#% h ,' I?8#ILN#7#NL&x=/$%6HG .H** =G .#8&AA(H28??FK**2E*FGG .G .1  ' 's7DD-,D-cV[X5n[URRS/S9$)aReturns the messages module for the API specified in the args. Args: api_name: str, The API name (or the command surface name, if different). api_version: str, The version of the API. Returns: Module containing the definitions of messages for the specified API. somethingr>)r6rCr@messages_full_modulepathr9s r_GetMessagesModuler0s2 h ,'  //;- IIrc[X5nUR(a%[URRS-S-S/S9$[URRS-S-S/S9$)z/Imports and returns given api resources module.r< resourcesrr>)r6r@rC class_pathr~r9s rrrAsm h ,'  ##c)K7;-   mm${2k] rc #6# [X5nURHin[R"UUURUR UR URURURUR5 v Mk g![a gf=f7f)z)Yields all collections for for given api.N) r Collections resource_utilCollectionInforkDOCS_URLcollection_namer flat_pathsparamsenable_uri_parsing ImportError)rr1resources_module collections r_GetApiCollectionsrQs)(@'22  ( (    # #  # #  $ $ //        ' '  3   s(B B A:B BBBB)FNNNNr)NN)/rgooglecloudsdk.api_lib.utilrrrrrrrrrfr googlecloudsdk.core.utilr %googlecloudsdk.generated_clients.apisr rsix.moves.urllib.parser r rrPrr r%r*r6r:r8rzr|GRPCrrrrErrorrrerrrrrlrrrr$rrrs 2A*#*9)-: *+-I % "&#L ) 0" %#'+/(," Nf+4*B*B*G*G08--22# Wt1.P:#3#3PNbF:E,(6:BI"  r