(phkZSrSSKrSSKrSSKJr SSKrSSKJr SSKJr SSK J r SSK J r SSK Jr SS KJr SS KJr S rS rS rSrSr\R/\S9rSr\R4"\S5rSrSr\RR<r\R@RBr"Sr#Sr$Sr%S'Sjr&Sr'Sr(Sr)"SS\*5r+Sr,S(Sjr-S r.S!r/S"r0S#r1S)S$jr2S%r3S*S&jr4g)+zVHelper functions for Cloud Storage utility classes. These are *not* part of the API. N)md5)urlsplit) urlunsplit)uuid4)environment_vars)_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_matchifSourceMetagenerationNotMatchcJ[RR[S5$N)osenvirongetSTORAGE_EMULATOR_ENV_VARP/var/www/html/venv/lib/python3.13/site-packages/google/cloud/storage/_helpers.py_get_storage_emulator_overrider+Qs ::>>2D 99r)cN[R"[[[-5$r#)r$getenv_API_ENDPOINT_OVERRIDE_ENV_VAR_DEFAULT_SCHEME_TRUE_DEFAULT_STORAGE_HOSTr(r)r*_get_default_storage_base_urlr1Us 99&:T(T r)cJ[5[[-:wa [5$g)zIThis is an experimental configuration variable. Use api_endpoint instead.N)r1r/r0r(r)r*_get_api_endpoint_overrider3[s$&/[[F r)c0$)aReturn any encryption headers needed to fetch the object. .. note:: Defined here because :meth:`reload` calls it, but this method is really only relevant for :class:`~google.cloud.storage.blob.Blob`. :rtype: dict :returns: a mapping of encryption-related headers. r(r]s r*_encryption_headers"_PropertyMixin._encryption_headerss  r)cB0nURbURUS'U$)zDefault query parameters. userProject)re)rWparamss r* _query_params_PropertyMixin._query_paramss*    ($($5$5F= ! r)noAclc URU5nURn X,S'[U UUUUS9 U bXS'URU S'UR 5n [ XUS9 UR URU U U U US9nURU5 g)aReload properties from Cloud Storage. If :attr:`user_project` is set, bills the API request to that project. :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. :type projection: str :param projection: (Optional) If used, must be 'full' or 'noAcl'. Defaults to ``'noAcl'``. Specifies the set of properties to return. :type if_etag_match: Union[str, Set[str]] :param if_etag_match: (Optional) See :ref:`using-if-etag-match` :type if_etag_not_match: Union[str, Set[str]]) :param if_etag_not_match: (Optional) See :ref:`using-if-etag-not-match` :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. See: :ref:`configuring_retries` :type soft_deleted: bool :param soft_deleted: (Optional) If True, looks for a soft-deleted object. Will only return the object metadata if the object exists and is in a soft-deleted state. :attr:`generation` is required to be set on the blob if ``soft_deleted`` is set to True. See: https://cloud.google.com/storage/docs/soft-delete projectionrrrrN softDeleted generation)rr) query_paramsheaderstimeoutretry_target_object) rhrp _add_generation_match_parametersrwrk_add_etag_match_headers _get_resourcer^_set_properties)rWrbrtrrrrrrrzr{ soft_deletedrxry api_responses r*reload_PropertyMixin.reloadsD%%f-)) &0\"(  3$;$;(C    #*6 '*.L &**, DU ++ II% ,  \*r)cVURRU5 X RU'g)amUpdate field of this object's properties. This method will only update the field provided and will not touch the other fields. It **will not** reload the properties from the server. The behavior is local only and syncing occurs via :meth:`patch`. :type name: str :param name: The field name to update. :type value: object :param value: The value being updated. N)rVaddrT)rWrNvalues r*_patch_property_PropertyMixin._patch_property2s$ $!&r)c.Xl[5Ulg)zSet the properties for the current object. :type value: dict or :class:`google.cloud.storage.batch._FutureDict` :param value: The properties to be set. N)rTrUrV)rWrs r*r_PropertyMixin._set_propertiesDs ! r)Fc 2URU5nURn SU S'U(aXS'[U UUUUS9 URV s0sHoURU _M n n UR UR U U UUUS9n URU 5 gs sn f)ajSends all changed properties in a PATCH request. Updates the ``_properties`` with the response from the backend. If :attr:`user_project` is set, bills the API request to that project. :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. :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. See: :ref:`configuring_retries` :type override_unlocked_retention: bool :param override_unlocked_retention: (Optional) override_unlocked_retention must be set to True if the operation includes a retention property that changes the mode from Unlocked to Locked, reduces the retainUntilTime, or removes the retention configuration from the object. See: https://cloud.google.com/storage/docs/json_api/v1/objects/patch fullrtoverrideUnlockedRetentionru)rxr|rzr{N)rhrpr}rVrT_patch_resourcer^r) rWrbrrrrrzr{override_unlocked_retentionrxkeyupdate_propertiesrs r*patch_PropertyMixin.patchNsl%%f-)) &, \" &8S4 5(  3$;$;(C  DH==Q=C$"2"23"77=Q-- II % .  \*Rs Bc URU5nURn SU S'U(aXS'[U UUUUS9 URURUR U UUUS9n UR U 5 g)a`Sends all properties in a PUT request. Updates the ``_properties`` with the response from the backend. If :attr:`user_project` is set, bills the API request to that project. :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. :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. See: :ref:`configuring_retries` :type override_unlocked_retention: bool :param override_unlocked_retention: (Optional) override_unlocked_retention must be set to True if the operation includes a retention property that changes the mode from Unlocked to Locked, reduces the retainUntilTime, or removes the retention configuration from the object. See: https://cloud.google.com/storage/docs/json_api/v1/objects/patch rrtrru)rxrzr{r|N)rhrpr} _put_resourcer^rTr) rWrbrrrrrzr{rrxrs r*update_PropertyMixin.updatesl%%f-)) %+ \" &8S4 5(  3$;$;(C  ++ II   % ,  \*r))rVrTrNr#)__name__ __module__ __qualname____firstlineno____doc__rXpropertyr^rbrerhrkrprr rrrrr r__static_attributes__r(r)r*rQrQs  """"""   $ $$( _+B'$ $ $$( $)O+f $ $$( 7$)L+r)rQc2^U4SjnU4Sjn[X5$)zHCreate a property descriptor around the :class:`_PropertyMixin` helpers.c:>URRT5$)zScalar property getter.)rTr&)rW fieldnames r*_getter!_scalar_property.._getters##I..r)c*>URTU5 g)zScalar property setter.N)r)rWrrs r*_setter!_scalar_property.._setters Y.r))r)rrrs` r*_scalar_propertyrs// G %%r)cURU5n[U5S:a4URU5 URU5n[U5S:aM3gg)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)readlenr) buffer_objecthash_objdigest_block_sizeblocks r*_write_buffer_to_hashrsJ   0 1E e*q.""#45 e*q.r)cx[5n[X5 UR5n[R"U5$)zGet 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. )rrdigestbase64 b64encode)rr digest_bytess r*_base64_md5hashrs0uH-2??$L   L ))r)c [HFup#URU5nUcM[U[5(aU/nSR U5X'MH g)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& isinstancestrjoin)rymatch_parameterssnakecase_name header_namers r*r~r~!sL(># $$^4  %%%#'99U#3G (>r)c [Hhup#URU5nUcM[U[5(aUR X445 MD[U[ 5(aX@U'M_[ S5e g)aFAdd 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&rlistappenddictrM) parametersrrcamelcase_namers r*r}r}3sn+G& $$^4  *d++!!>"9:J---2>*!K+Gr)c [SUR555S:aPUR5Vs/sH nSUS3PM nnSRUSS5nUSnSUSU3n[ U5egs snf) 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(# UHoSLv M g7fr#r().0args r* ._raise_if_more_than_one_set..Ws 6osd?os'rNrJzPass at most one of z and )sumvalueskeysrrM)kwargsrN escaped_keys keys_but_lastlast_keymsgs r*_raise_if_more_than_one_setrOs 6fmmo 66:06 > !D6 > ,s"34 #$]O5 Co;>sA6cn[U5nUR(aUR(aU$USU3$)aHelper 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://)rr9r8)hostr9 url_partss r*_bucket_bound_hostname_urlrbs4II,, XS r)c.S[[55-$)Nzgccl-invocation-id/)rrr(r)r*_get_invocation_idrvs 3uw< //r)cbUS[53nU(aUSU3- nSSUUUU=(d US.$)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_headersrzsR(&,a(:(<'=>~gY77%* .$!6!F,  r))F)i r#)zapplication/json; charset=UTF-8NN)5rrdatetimehashlibrr$ urllib.parserruuidr google.authrgoogle.cloud.storage.constantsrgoogle.cloud.storage.retryr r r'r._API_VERSION_OVERRIDE_ENV_VAR_DEFAULT_UNIVERSE_DOMAIN_STORAGE_HOST_TEMPLATEformatr0r/r- _API_VERSIONrrnow_NOWtimezoneutc_UTCr+r1r3r@rDrHrOobjectrQrrrr~r}rrrrr(r)r*rs)  !#(;4P3>!8O 6O+43::,;yy6= - :  D$^+V^+B &6* * 4$8& (0 3  r)