%9jjHdZddlZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z m Z ddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lmZdd lmZmZej@e!Z"dZ# dZ$ dZ% dZ&dZ'e'jQe&Z)dZ*ejVe%dZ, dZ-dZ.ejj^Z0ejbjdZ3dZ4dZ5dZ6d+dZ7dZ8dZ9ed,dZ:Gdd e;Zd#Z?d$Z@d%ZAd&ZBd,d'ZCd(ZD d.d)ZEd*ZFy)/zVHelper functions for Cloud Storage utility classes. These are *not* part of the API. N)contextmanager)md5)urlsplit urlunsplit)uuid4) exceptions)environment_vars)NotFound)_is_bucket_metadata_disabled)create_trace_span)_DEFAULT_TIMEOUT) DEFAULT_RETRY)DEFAULT_RETRY_IF_METAGENERATION_SPECIFIEDSTORAGE_EMULATOR_HOSTAPI_ENDPOINT_OVERRIDEAPI_VERSION_OVERRIDEzgoogleapis.comzstorage.{universe_domain})universe_domainzhttps://v1)) if_etag_matchzIf-Match)if_etag_not_matchz If-None-Match))if_generation_matchifGenerationMatch)if_generation_not_matchifGenerationNotMatch)if_metageneration_matchifMetagenerationMatch)if_metageneration_not_matchifMetagenerationNotMatch)if_source_generation_matchifSourceGenerationMatch)if_source_generation_not_matchifSourceGenerationNotMatch)if_source_metageneration_matchifSourceMetagenerationMatch)"if_source_metageneration_not_matchifSourceMetagenerationNotMatchcJtjjtdSN)osenvirongetSTORAGE_EMULATOR_ENV_VARY/var/www/html/truck-me/venv/lib/python3.12/site-packages/google/cloud/storage/_helpers.py_get_storage_emulator_overrider0`s ::>>2D 99r.cLtjtttzSr()r)getenv_API_ENDPOINT_OVERRIDE_ENV_VAR_DEFAULT_SCHEME_TRUE_DEFAULT_STORAGE_HOSTr-r.r/_get_default_storage_base_urlr6ds 99&:T(T r.cHtttzk7r tSy)zIThis is an experimental configuration variable. Use api_endpoint instead.N)r6r4r5r-r.r/_get_api_endpoint_overrider8js$&/=@v&!x  G* G G4 J  S MMMaSQ R R S.112 {C0F$<=1111AA+N  !MMTUVTWX    sAF5 A4C&=F5F)D F5& D/D F5 DF5AF&E65F&6 F!?FF&F!!F&&F))F2.F5c eZdZdZddZedZedZedZdZ e ddZ d Z ed Z dd ddddddeedf d Zd ZdZdddddeedfdZdddddeedfdZy)_PropertyMixina1Abstract mixin for cloud storage classes with associated properties. Non-abstract subclasses should implement: - path - client - user_project :type name: str :param name: The name of the object. Bucket names must start and end with a number or letter. Nc>||_i|_t|_yr()rO _propertiesset_changes)selfrOs r/__init__z_PropertyMixin.__init__s  r.ct)z$Abstract getter for the object path.NotImplementedErrorrss r/pathz_PropertyMixin.path "!r.ct)z&Abstract getter for the object client.rvrxs r/rTz_PropertyMixin.clientrzr.ct)z,Abstract getter for the object user_project.rvrxs r/ user_projectz_PropertyMixin.user_projectrzr.c"| |j}|S)aCheck client or verify over-ride. :type client: :class:`~google.cloud.storage.client.Client` or ``NoneType`` :param client: the client to use. If not passed, falls back to the ``client`` stored on the current object. :rtype: :class:`google.cloud.storage.client.Client` :returns: The client passed in or the currently bound client. )rT)rsrTs r/_require_clientz_PropertyMixin._require_clients >[[F r.c+ Kddlm}ddlm}t ||r|j }|j }nLt ||rFailed callable bucket_name resolution in _create_trace_span: rU)google.cloud.storage.blobrgoogle.cloud.storage.bucketrrWrTrOgetattrrYcallabler^r_r`poprl) rsrOrUrerrrTrdr@rjclient_override active_clientrks r/_create_trace_spanz!_PropertyMixin._create_trace_spans"26 dF #[[F))K d #T8T2Fgfh7$/  ._getterYs##I..r.c*|j|y)zScalar property setter.N)r)rsrrs r/_setterz!_scalar_property.._setter]s Y.r.)r)rrrs` r/_scalar_propertyrVs// GW %%r.c|j|}t|dkDr2|j||j|}t|dkDr1yy)aRead blocks from a buffer and update a hash with them. :type buffer_object: bytes buffer :param buffer_object: Buffer containing bytes used to update a hash object. :type hash_obj: object that implements update :param hash_obj: A hash object (MD5 or CRC32-C). :type digest_block_size: int :param digest_block_size: The block size to write to the hash. Defaults to 8192. rN)readr\r]) buffer_objecthash_objdigest_block_sizeblocks r/_write_buffer_to_hashrdsJ   0 1E e*q.""#45 e*q.r.ctjdk\r td}n t}t|||j }t j |S)a Get MD5 hash of bytes (as base64). :type buffer_object: bytes buffer :param buffer_object: Buffer containing bytes used to compute an MD5 hash (as base64). :rtype: str :returns: A base64 encoded digest of the MD5 hash. ) F)usedforsecurity)sys version_inforrdigestbase64 b64encode)rr digest_bytess r/_base64_md5hashrysJ 6!u-5-2??$L   L ))r.c tD]@\}}|j|}|t|tr|g}dj |||<By)zAdd generation match parameters into the given parameters list. :type headers: dict :param headers: Headers dict. :type match_parameters: dict :param match_parameters: if*etag*match parameters to add. N, )_ETAG_MATCH_PARAMETERSr+rWrXjoin)rmatch_parameterssnakecase_name header_namers r/rrsR(>4#  $$^4  %%#'99U#3GK 4r.c tD]]\}}|j|}|t|tr|j ||f>t|t r|||<Tt dy)abAdd generation match parameters into the given parameters list. :type parameters: list or dict :param parameters: Parameters list or dict. :type match_parameters: dict :param match_parameters: if*generation*match parameters to add. :raises: :exc:`ValueError` if ``parameters`` is not a ``list()`` or a ``dict()``. Nz5`parameters` argument should be a dict() or a list().)_GENERATION_MATCH_PARAMETERSr+rWlistappendrVrN) parametersrrcamelcase_namers r/rrsr+G & $$^4  *d+!!>5"9:J--2 >*!K r.c td|jDdkDrM|jDcgc]}d|d }}dj|dd}|d}d|d|}t |ycc}w) zRaise ``ValueError`` exception if more than one parameter was set. :type error: :exc:`ValueError` :param error: Description of which fields were set :raises: :class:`~ValueError` containing the fields that were set c3$K|]}|du ywr(r-).0args r/ z._raise_if_more_than_one_set..s 6s3d? 6s'rNrKzPass at most one of z and )sumvalueskeysrrN)rerO escaped_keys keys_but_lastlast_keymsgs r/_raise_if_more_than_one_setrs 6fmmo 66:06 >!D6 > > ,s"34 #$]O5 Co;>s A2cZt|}|jr|jr|S|d|S)a!Helper to build bucket bound hostname URL. :type host: str :param host: Host name. :type scheme: str :param scheme: (Optional) Web scheme. If passed, use it as a scheme in the result URL. :rtype: str :returns: A bucket bound hostname URL. z://)rr>r=)hostr> url_partss r/_bucket_bound_hostname_urlrs4II,, XS r.c.dttzS)Nzgccl-invocation-id/)rXrr-r.r/_get_invocation_idrs 3uw< //r.cN|dt}|r|d|z }dd||||xs|dS)aGet the headers for a request. :type user_agent: str :param user_agent: The user-agent for requests. :type command: str :param command: (Optional) Information about which interface for the operation was used, to be included in the X-Goog-API-Client header. Please leave as None unless otherwise directed. :rtype: dict :returns: The headers to be used for the request.  z gccl-gcs-cmd/zapplication/jsonz gzip, deflate)AcceptzAccept-Encodingz User-AgentzX-Goog-API-Clientz content-typezx-upload-content-type)r) user_agent content_typex_upload_content_typecommandx_goog_api_clients r/_get_default_headersrsR(&,a(:(<'=>~gY77%* .$!6!F,  r.cXtjd}tj|dS)aGenerates a secure 56 bit random integer. If 64 bit int is used, sometimes the random int generated is greater than max positive value of signed 64 bit int which is 2^63 -1 causing overflow issues. :rtype: int :returns: A secure random 56 bit integer. big)secrets token_bytesint from_bytes) random_bytess r/generate_random_56_bit_integerrs%&&q)L >>, ..r.)Fr()i )zapplication/json; charset=UTF-8NN)Grrdatetimeloggingr)rr contextlibrhashlibr urllib.parserruuidrgoogle.api_corerrb google.authr google.cloud.exceptionsr +google.cloud.storage._opentelemetry_tracingr r ragoogle.cloud.storage.constantsr google.cloud.storage.retryrr getLoggerrr_r,r3_API_VERSION_OVERRIDE_ENV_VAR_DEFAULT_UNIVERSE_DOMAIN_STORAGE_HOST_TEMPLATEformatr5r4r2 _API_VERSIONrrnow_NOWtimezoneutc_UTCr0r6r8rErIrPrlobjectrnrrrrrrrrrrr-r.r/rsl   %-8(,< '  H %2>!8O 6O+43::,;ryy6= - :  $55pB+VB+J &6**&4$8& (0 3  F/r.