B uf_@szdZddlZddlZddlmZddlZddlmZddlmZddl m Z ddl m Z ddl mZdd lmZdd lmZdd lmZd Zd ZdZdZdZejedZdZeedZdZdZdZ ejj!Z"ej#j$Z%ddZ&ddZ'ddZ(d>ddZ)d d!Z*d"d#Z+d$d%Z,Gd&d'd'e-Z.d(d)Z/d?d+d,Z0d-d.Z1d/d0Z2d1d2Z3d3d4Z4d@d5d6Z5dAd7d8Z6d9d:Z7dBdr r r rrrrArBZ soft_deletedr?r@ api_responserrrreloads,B  z_PropertyMixin.reloadcCs|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)r3addr1)r4r.valuerrr_patch_property6s z_PropertyMixin._patch_propertycCs||_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)r1r2r3)r4rJrrrrFHsz_PropertyMixin._set_propertiesFc sp|}j} d| d<|r$|| d<t| ||||dfddjD} |jj| | ||d} | 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 fullr>overrideUnlockedRetention)r rrrcsi|]}j||qSr)r1).0key)r4rr sz(_PropertyMixin.patch..)r?rCrArBN)r:r=rDr3Z_patch_resourcer7rF) r4r8r rrrrArBoverride_unlocked_retentionr?Zupdate_propertiesrGr)r4rpatchRs(6 z_PropertyMixin.patchc Cs^||}|j} d| d<|r$|| d<t| ||||d|j|j|j| |||d} || 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 rLr>rM)r rrr)r?rArBrCN)r:r=rDZ _put_resourcer7r1rF) r4r8r rrrrArBrQr?rGrrrupdates&6 z_PropertyMixin.update)N)__name__ __module__ __qualname____doc__r5propertyr7r8r9r:r;r=rr rHrKrFr rRrSrrrrr0sJ       R  Jr0cs"fdd}fdd}t||S)zHCreate a property descriptor around the :class:`_PropertyMixin` helpers.cs |jS)zScalar property getter.)r1r)r4) fieldnamerr_gettersz!_scalar_property.._gettercs||dS)zScalar property setter.N)rK)r4rJ)rYrr_settersz!_scalar_property.._setter)rX)rYrZr[r)rYr_scalar_propertys  r\ cCs4||}x$t|dkr.||||}q WdS)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)readlenrS) buffer_objecthash_objZdigest_block_sizeblockrrr_write_buffer_to_hashs  rccCs"t}t|||}t|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. )rrcdigestbase64 b64encode)r`raZ digest_bytesrrr_base64_md5hashs  rgcKsFx@tD]8\}}||}|dk rt|tr0|g}d|||<qWdS)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. Nz, )_ETAG_MATCH_PARAMETERSr isinstancestrjoin)r@match_parameterssnakecase_name header_namerJrrrrE%s   rEcKs^xXtD]P\}}||}|dk rt|tr:|||fqt|trN|||<qtdqWdS)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_PARAMETERSrrilistappenddictr-) parametersrlrmZcamelcase_namerJrrrrD7s     rDcKsbtdd|Ddkr^dd|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 css|]}|dk VqdS)Nr)rNargrrr [sz._raise_if_more_than_one_set..cSsg|]}d|dqS)'r)rNr.rrr \sz/_raise_if_more_than_one_set..z, Nr*zPass at most one of z and )sumvalueskeysrkr-)kwargsZ escaped_keysZ keys_but_lastlast_keymsgrrr_raise_if_more_than_one_setSs rcCs&t|}|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"Z url_partsrrr_bucket_bound_hostname_urlfs  rcCs`|dk r|dk rtdnB|dk rs`            `   "