&g14dZddlZddlmZddlZddlZddlZddlm Z ddl m Z ddl m Z ddl m Z ddl mZddl mZdd lmZejeZeje jdZeseje jd Zd eZd eje jd ZdZdZeeiZ e ejddZ!n #e"$rdZ!YnwxYwdZ#dZ$dZ%dZ&e!dfdZ'edddddfdZ(dZ)dZ*ddZ+ddZ,dS) zProvides helper methods for talking to the Compute Engine metadata server. See https://cloud.google.com/compute/docs/metadata for more details. N)urljoin)_helpers)environment_vars) exceptions)metrics) transport)ExponentialBackoffzmetadata.google.internalzhttp://{}/computeMetadata/v1/z http://{}z169.254.169.254zmetadata-flavorGoogleGCE_METADATA_TIMEOUTz/sys/class/dmi/id/product_namecdt|rdStjdkrdStS)aChecks to see if the code runs on Google Compute Engine Args: request (google.auth.transport.Request): A callable used to make HTTP requests. Returns: bool: True if the code runs on Google Compute Engine, False otherwise. TntF)pingosnamedetect_gce_residency_linuxrequests V/var/www/api/venv/lib/python3.11/site-packages/google/auth/compute_engine/_metadata.py is_on_gcerDs5 G}}t w$u & ' ''c ttd5}|}dddn #1swxYwYn#t$rYdSwxYw|t S)zDetect Google Compute Engine residency by smbios check on Linux Returns: bool: True if the GCE product name file is detected, False otherwise. rNF)open_GCE_PRODUCT_NAME_FILEreadstrip Exception startswith_GOOGLE)file_objcontents rrrYs  (# . . .(mmoo++--G . . . . . . . . . . . . . . . uu   g & &&s3A'A  A AAAA A$#A$ct}tj|tj<t |}|D]} |t d||}|jt}|j tj ko |tkcS#tj$r'}t d|||Yd}~d}~wwxYwdS)aChecks to see if the metadata server is available. Args: request (google.auth.transport.Request): A callable used to make HTTP requests. timeout (int): How long to wait for the metadata server to respond. retry_count (int): How many times to attempt connecting to metadata server using above timeout. Returns: bool: True if the metadata server is reachable, False otherwise. total_attemptsGET)urlmethodheaderstimeoutJCompute Engine Metadata server unavailable on attempt %s of %s. Reason: %sNF)_METADATA_HEADERScopyrmds_pingAPI_CLIENT_HEADERr _METADATA_IP_ROOTr)get_METADATA_FLAVOR_HEADERstatus http_clientOK_METADATA_FLAVOR_VALUErTransportError_LOGGERwarning) rr* retry_countr)backoffattemptresponsemetadata_flavores rrris& $$&&G)0)9););GG %& <<1>#'==    (    OO/           5sAB$$C3CCFct||}|in|} t} |r| ||rd| d<t j|| } t |} d} | D]} || d| }|jtj vrYt d|||jt|j dr|j d n|j } }nc#tj$r)}t d ||||} Yd}~d}~wwxYwtjd | | t j|j }|jt&jkr|rdS|jt&jkrvt j|jd d krQ t1j|S#t4$r/}tjd|}||d}~wwxYw|Stjd| |j|j |)aFetch a resource from the metadata server. Args: request (google.auth.transport.Request): A callable used to make HTTP requests. path (str): The resource to retrieve. For example, ``'instance/service-accounts/default'``. root (str): The full path to the metadata server root. params (Optional[Mapping[str, str]]): A mapping of query parameter keys to values. recursive (bool): Whether to do a recursive query of metadata. See https://cloud.google.com/compute/docs/metadata#aggcontents for more details. retry_count (int): How many times to attempt connecting to metadata server using above timeout. headers (Optional[Mapping[str, str]]): Headers for the request. return_none_for_not_found_error (Optional[bool]): If True, returns None for 404 error instead of throwing an exception. Returns: Union[Mapping, str]: If the metadata server returns JSON, a mapping of the decoded JSON is returned. Otherwise, the response content is returned as a string. Raises: google.auth.exceptions.TransportError: if an error occurred while retrieving metadata. Ntrue recursiver$r&)r'r(r)zSCompute Engine Metadata server unavailable on attempt %s of %s. Response status: %sdecodezutf-8r+z{Failed to retrieve {} from the Google Compute Engine metadata service. Compute Engine Metadata server unavailable due to {}z content-typezapplication/jsonzMReceived invalid JSON from the Google Compute Engine metadata service: {:.20}z^Failed to retrieve {} from the Google Compute Engine metadata service. Status: {} Response: {})rr,r-updater update_queryr r3rDEFAULT_RETRYABLE_STATUS_CODESr8r9hasattrdatarDrr7format from_bytesr4 NOT_FOUNDr5parse_content_typer)jsonloads ValueError)rpathrootparamsrCr:r)return_none_for_not_found_errorbase_url query_paramsheaders_to_user'r;failure_reasonr<r=r?r" caught_excnew_excs rr1r1sLtT""H22VL&++--N'g&&&+$* [!  , 7 7C <<JJJJ?$$x'9<((((L n %| 33r)ra)raN)-__doc__rp http.clientclientr4rNloggingr urllib.parser google.authrrrrr google.auth._exponential_backoffr getLogger__name__r8getenvGCE_METADATA_HOST_GCE_METADATA_HOSTGCE_METADATA_ROOTrJ_METADATA_ROOTGCE_METADATA_IPr0r2r6r,int_METADATA_DEFAULT_TIMEOUTrPr rrrrr1r]r`rdrurrrs !!!!!!  ((((((""""""!!!!!!?????? ' H % % RY/A4HH"*,F1778JKK && BI.0ABB,!,.DE" #IBI.Da$H$H I I""" !" 9(((* ' ' ' 4----f   $)ttttn...".<<<<:"4"4"4"4"4"4sC##C-,C-