B f_dZddlZddlZddlmZddlZddlmZddlmZddl m Z ddl m Z ddl mZdd lmZdd lmZdd lmZd Z d Z dZ dZdZeeZdZejedZ dZdZdZ ejj!Z"ej#j$Z%dZ&dZ'dZ(d-dZ)dZ*dZ+dZ,Gdd e-Z.d!Z/d.d#Z0d$Z1d%Z2d&Z3d'Z4d/d(Z5d/d)Z6d*Z7 d0d,Z8dS)1zVHelper functions for Cloud Storage utility classes. These are *not* part of the API. N)md5)urlsplit) urlunsplit)uuid4)resumable_media)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_matchifSourceMetagenerationNotMatchz`num_retries` has been deprecated and will be removed in a future release. Use the `retry` argument with a Retry or ConditionalRetryPolicy object, or None, instead.cLtjtdSN)osenvirongetSTORAGE_EMULATOR_ENV_VARl/home/panchajanya/Development/work/volatility3/lib/python3.11/site-packages/google/cloud/storage/_helpers.py_get_storage_emulator_overrider,Xs :>>2D 9 99r*cPtjtttzSr$)r%getenv_API_ENDPOINT_OVERRIDE_ENV_VAR_DEFAULT_SCHEME_TRUE_DEFAULT_STORAGE_HOSTr)r*r+_get_default_storage_base_urlr2\s! 9&:T(T  r*c`tttzkrtSdS)zIThis is an experimental configuration variable. Use api_endpoint instead.N)r2r0r1r)r*r+_get_api_endpoint_overrider4bs*$&&/[F r*ciS)a@Return 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_headersz"_PropertyMixin._encryption_headerss  r*c,i}|j |j|d<|S)zDefault query parameters.N userProject)rb)rWparamss r+ _query_paramsz_PropertyMixin._query_paramss$   ($($5F= ! r*noAclc 4||}|j} || d<t| ||||| | | d<|} t | ||||j| | | | |}||dS)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)rr) query_paramsheaderstimeoutretry_target_object)rdrj _add_generation_match_parametersrf_add_etag_match_headers _get_resourcer]_set_properties)rWr`rmrrrrrrrrrs soft_deletedrprq api_responses r+reloadz_PropertyMixin.reloadsD%%f--) &0 \"(  3$;$;(C       #*6L '**,, =DU    ++ I% ,   \*****r*cN|j|||j|<dS)aUpdate 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)rWrOvalues r+_patch_propertyz_PropertyMixin._patch_property6s- $!&r*c:||_t|_dS)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)rWr~s r+rxz_PropertyMixin._set_propertiesHs ! r*Fc |}j} d| d<|r|| d<t| ||||fdjD} |j| | ||} | dS)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 fullrmoverrideUnlockedRetentionrnc,i|]}|j|Sr))rT).0keyrWs r+ z(_PropertyMixin.patch..s#QQQCS$"23"7QQQr*)rprtrrrsN)rdrjrurV_patch_resourcer]rx) rWr`rrrrrrrsoverride_unlocked_retentionrpupdate_propertiesrzs ` r+patchz_PropertyMixin.patchRsl%%f--) &, \" & T8SL4 5(  3$;$;(C     RQQQ4=QQQ-- I % .   \*****r*c ||}|j} d| d<|r|| d<t| ||||||j|j| |||} || dS)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 rrmrrn)rprrrsrtN)rdrjru _put_resourcer]rTrx) rWr`rrrrrrrsrrprzs r+updatez_PropertyMixin.updatesl%%f--) %+ \" & T8SL4 5(  3$;$;(C     ++ I  % ,   \*****r*r$)__name__ __module__ __qualname____doc__rXpropertyr]r`rbrdrfrjr r r{rrxr rrr)r*r+rRrRs}   ""X"""X"""X"      X $ $$( \+\+\+\+|'''$ $ $$( 7$)O+O+O+O+f $ $$( 7$)L+L+L+L+L+L+r*rRc8fd}fd}t||S)zHCreate a property descriptor around the :class:`_PropertyMixin` helpers.c8|jS)zScalar property getter.)rTr')rW fieldnames r+_getterz!_scalar_property.._getters##I...r*c4||dS)zScalar property setter.N)r)rWr~rs r+_setterz!_scalar_property.._setters Y.....r*)r)rrrs` r+_scalar_propertyrsG////////// GW % %%r* c||}t|dkr?||||}t|dk=dSdS)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_hashrsf   0 1 1E e**q..""#455 e**q......r*ct}t|||}tj|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. )rrdigestbase64 b64encode)rr digest_bytess r+_base64_md5hashrs=uuH-222??$$L  L ) ))r*c tD]L\}}||}|0t|tr|g}d|||<MdS)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)rqmatch_parameterssnakecase_name header_namer~s r+rvrv%sk(>44#  $$^44  %%% #'99U#3#3GK 44r*c tD]s\}}||}|Wt|tr|||fIt|t r|||<dt dtdS)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'rlistappenddictrN) parametersrrcamelcase_namer~s r+ruru7s+G  & $$^44  *d++ !!>5"9::::J-- -2 >**!K   r*c td|DdkrZd|D}d|dd}|d}d|d|}t |dS) 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 c3K|]}|duV dSr$r))rargs r+ z._raise_if_more_than_one_set..[s& 6 6s3d? 6 6 6 6 6 6r*cg|]}d|d S)'r))rrOs r+ z/_raise_if_more_than_one_set..\s >>> D >>>r*rNrKzPass at most one of z and )sumvalueskeysrrN)kwargs escaped_keys keys_but_lastlast_keymsgs r+_raise_if_more_than_one_setrSs 6 6fmmoo 6 6 666::>> >>>  ,ss"344 #C]CCCCoo;:r*cNt|}|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:r9)hostr: url_partss r+_bucket_bound_hostname_urlrfs=II,     r*c||td|,tj|j|j|j|jS|tj|StjdS)a~Convert google.api.core.Retry to google.resumable_media.RetryStrategy. Custom predicates are not translated. :type retry: google.api_core.Retry :param retry: (Optional) The google.api_core.Retry object to translate. :type num_retries: int :param num_retries: (Optional) The number of retries desired. This is supported for backwards compatibility and is mutually exclusive with `retry`. :rtype: google.resumable_media.RetryStrategy :returns: A RetryStrategy with all applicable attributes copied from input, or a RetryStrategy with max_retries set to 0 if None was input. Nz6num_retries and retry arguments are mutually exclusive) max_sleepmax_cumulative_retry initial_delay multiplier) max_retriesr)rNr RetryStrategy_maximum _deadline_initial _multiplier)rs num_retriess r+(_api_core_retry_to_resumable_media_retryrzs$ [4QRRR  ,n!&.(      ,EEEE,;;;;r*c>dttzS)Nzgccl-invocation-id/)rrr)r*r+_get_invocation_idrs 3uww<< //r*application/json; charset=UTF-8cR|dt}|r|d|z }dd||||p|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_headersrsc(&>>(:(<(<>>87g777%* .$!6!F,   r*)F)rr$)rNN)9rrdatetimehashlibrr% urllib.parserruuidrgoogler google.authrgoogle.cloud.storage.constantsr google.cloud.storage.retryr r r(r/_API_VERSION_OVERRIDE_ENV_VAR_DEFAULT_UNIVERSE_DOMAIN_STORAGE_HOST_TEMPLATEformatr1r0r. _API_VERSIONrr_NUM_RETRIES_MESSAGEnow_NOWtimezoneutc_UTCr,r2r4rArErIrPobjectrRrrrrvrurrrrrr)r*r+rs   !!!!!!######""""""((((((;;;;;;444444PPPPPP3>!8O 6O+43::,;ry6== -  :::     DDD$[+[+[+[+[+V[+[+[+| & & &6666* * * * 444$8&    (<<<