b:fdZddlmZddlmZddlmZddlmZddlmZddl m Z ddl m Z dd l m Z dd lZdd lmZdd lmZd ZdZdZdZdZdZdZ d!dZej4j6fdZd ej4j6dd fdZdZd"dZdZ dZ!dZ"d"dZ#dZ$dZ%d Z&y )#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. )absolute_import)division)unicode_literals) apis_util)resource) properties) transport)apis_mapN)urljoin)urlparsecFtjj|||fSN)r_API_NAME_ALIASESget)api_names 0lib/googlecloudsdk/api_lib/util/apis_internal.py_GetApiNameAndAliasr#s  % % ) )(H =x HHct|\}}tjj|i}t j |D]\}}|j s|cSyr)rr MAPrsix iteritemsdefault_version)r_api_versverapi_defs r_GetDefaultVersionr(sP#H-+(A \\  h +(mmH-lc7 j. rcPttjjS)z6Returns list of avaiblable apis, ignoring the version.)sortedr rkeysrr _GetApiNamesr#1s  !!# $$rct|\}}tjj|d}|t j |t |jS)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(6sS$H-+(A   40+  # #H -- k !!rct|\}}|tjvrtj|t j jj}|jdj||}|s|j|d}|xs|}tj|}|||vrtj||||}|S)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 GetApiDefr4Is1:(N X\\!  # #H -- ''<<FFH'**7>> , (,,^TB /K+h',K|;  ' '+ >>;'G .rc0t||}t|S)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. )r4_GetClientClassFromDefrr/rs r_GetClientClassr8os h ,'  ((rc|jj}|jdd\}}t||g}t ||S)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)rr? module_pathclient_class_name module_objs rr6r6}sL"**@@#8#?#?Q#G + +1B0CD* . //rFcp|r|/J|+ddlm}|jtj|r|nd}t ||}|t |||d|}|||_tjjjj} | r#|jd| d} d |j| <|S) aGReturns 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. Returns: base_api.BaseApiClient, An instance of the specified API client. r) transportsunset)response_encodingtimeoutF)urlget_credentialshttpkeyzX-Google-Project-Overrideapikey)googlecloudsdk.core.credentialsrGGetApitoolsTransportr ENCODINGr8_GetEffectiveApiEndpointcheck_response_funcrr*coreapi_keyGetAddGlobalParamadditional_http_headers) rr/no_http http_clientrThttp_timeout_secrG client_classclient_instancerVheaders r_GetClientInstancer`s,   ;11#,,$4 '2CK!;7, "8[, G /$*=O'    " " * * . . 0' ""5'2 (F6>O++F3 rctt||}|tjjk(r|jj }nJ|tjj k(r|jj}n|jj}|jdd\}}t||g}t||S)a*Returns 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<) r4rGapicTransport GRPC_ASYNCIOgapicasync_client_full_classpathRESTrest_client_full_classpathr?r@rArB)rr/transport_choicerr?rCrDrEs r_GetGapicClientClassris h ,'11>>>#MMEE933888#MMDD#MM??#8#?#?Q#G + +1B0CD* . //rc\fd}t||}|||t|||S)ahReturns 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. Returns: An instance of the specified GAPIC API client. c  tjjjj }|rt |j}r|}||St|S#tj $rd}YGwxYwr) rr*api_endpoint_overridesPropertyrWNoSuchPropertyErrorr netlocUniversifyAddress)addressendpoint_overrideaddress_override_funcrs rAddressOverridez0_GetGapicClientInstance..AddressOverrides$++BBKK CE *+22g%g.g$ n W %%  ) )s7A**BB)rh)rs mtls_enabledattempt_direct_pathredact_request_body_reason)ri _MtlsEnabled) rr/ credentialsrsrhrvrwrtr]s ` ` r_GetGapicClientInstancerzsC@&$& .>@, ++6-!;  rctjjj}|j }|,|j |k7r|j |j |d}|S)z2Update a URL based on the current universe domain.r;)rr*rUuniverse_domainrWdefaultreplace)rquniverse_domain_propertyr|s rrprps]'..33CC,002/ &&/9oo6>>-q2G .rct||}|jr|xs t||}n|xs t||}|jxs |j S)zReturns mtls endpoint.)r4r>r8rimtls_endpoint_override MTLS_BASE_URL)rr/r]rs r_GetMtlsEndpointrsQ h ,' I?8[#ILN#7+#NL  ' ' E<+E+EErctjjjj rytjjj j syt ||}|jS)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_certificater4 enable_mtlsr7s rrxrx's^&$$==EEG     ( ( ? ? G G I  h ,'   rct|}t|}|jdk(s|jdk7r|Stdj|j|j |jS)zFConstructs a normalized endpoint URI depending on the client base_url./z{}://{})r pathr r-schemero)rrbase_urlurl_baseurl_endpoint_overrides r_BuildEndpointOverriderDsn h ("#45 ]]c2773>  ,33,3356>mm EErc@t||jr t||}n t||}t |dr|j }t|S t ||j }t|S#t$rdj||}Yt|SwxYw)zReturns base url for given api.BASE_URLzhttps://{}.googleapis.com/{}) r4r>r8rihasattrr_GetResourceModuleAttributeErrorr-rp)rr/r]client_base_urls r_GetBaseUrlFromApirOsx%.."8[9L'+>L \:&"++O ? ++ *8[AJJo ? ++ 6== Ko ? ++ sA55BBc tjjj|j }t ||}|jr|xs t||}n|xs t||}t||}|rt||}|St||rtt|||}|S|}|S#tj $rd}YwxYw)z)Returns effective endpoint for given api.N)rr*rlrmrWrnr4r>r8rirrrxrpr)rr/r]rrrrrqs rrSrSbs"))@@II#% h ,' I?8[#ILN#7+#NL&x=/$%6HG .Hk*; =G .G .%  ' 's7B66C Cc^t||}t|jjdgS)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<)r4rAr>messages_full_modulepathr7s r_GetMessagesModuler|s4 h ,'  //;- IIrct||}|jr(t|jjdzdzdgSt|jjdzdzdgS)z/Imports and returns given api resources module.r: resourcesrr<)r4r>rA class_pathrdr7s rrrso h ,'  ##c)K7;-   mm${2k] rc #0K t||}|jD]g}tj|||j|j |j |j|j|j|j iy#t$rYywxYww)z)Yields all collections for for given api.N) r Collections resource_utilCollectionInforDOCS_URLcollection_namer flat_pathsparamsenable_uri_parsing ImportError)rr/resources_module collections r_GetApiCollectionsrs)(K@'22  ( (    # #  # #  $ $ //        ' '  3   s(B BA7B BBBB)FNNNr)'__doc__ __future__rrrgooglecloudsdk.api_lib.utilrrrgooglecloudsdk.corerr %googlecloudsdk.generated_clients.apisr rsix.moves.urllib.parser r rrr#r(r4r8r6r`rbGRPCrirzrprrxrrrSrrrr"rrrs ''1A*): *+I % "&#L ) 0" %#'+/(, -d+4*B*B*G*G08--22#;|F:E,&4I"  r