o Fh_@sdZddlZddlZddlmZddlZddlmZddlmZddl m Z ddl m Z ddl mZdd lmZdd lmZdd lmZd Z d Z dZ dZdZejedZdZeedZ dZdZdZ 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@d5d6Z5d@d7d8Z6d9d:Z7 ;  dAdz(_PropertyMixin.patch..)r`rdrbrcN)rWr[rerL_patch_resourcerSrh) rMrUrrrrrbrcoverride_unlocked_retentionr`update_propertiesrjr'rRr(patchRs, 6z_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 rpr]rqr^)r`rbrcrdN)rWr[re _put_resourcerSrJrh) rMrUrrrrrbrcrwr`rjr'r'r(updates* 6z_PropertyMixin.updater")__name__ __module__ __qualname____doc__rNpropertyrSrUrVrWrXr[rr rkrnrhr ryr{r'r'r'r(rIsZ       ^  SrIcs"fdd}fdd}t||S)zHCreate a property descriptor around the :class:`_PropertyMixin` helpers.cs |jS)zScalar property getter.)rJr%rR fieldnamer'r(_getters z!_scalar_property.._gettercs||dS)zScalar property setter.N)rnrorr'r(_settersz!_scalar_property.._setter)r)rrrr'rr(_scalar_propertys   r cCs>||}t|dkr||||}t|dks 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_sizeblockr'r'r(_write_buffer_to_hashs   rcCs"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. )rrdigestbase64 b64encode)rr digest_bytesr'r'r(_base64_md5hashs  rcKsBtD]\}}||}|durt|tr|g}d|||<qdS)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)ramatch_parameterssnakecase_name header_namermr'r'r(rf%s  rfcKsZtD](\}}||}|dur*t|tr|||fqt|tr&|||<qtdqdS)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%rlistappenddictrF) parametersrrcamelcase_namermr'r'r(re7s    recKsbtdd|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|]}|duVqdSr"r')rrargr'r'r( [sz._raise_if_more_than_one_set..cSsg|]}d|dqS)'r')rrrGr'r'r( \ruz/_raise_if_more_than_one_set..rNrCzPass at most one of z and )sumvalueskeysrrF)kwargs escaped_keys keys_but_lastlast_keymsgr'r'r(_raise_if_more_than_one_setSsrcCs&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://)rr5r4)hostr5 url_partsr'r'r(_bucket_bound_hostname_urlfs rcCsZ|dur |dur td|durtj|j|j|j|jdS|dur'tj|dStjddS)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)rFr RetryStrategy_maximum _deadline_initial _multiplier)rc num_retriesr'r'r((_api_core_retry_to_resumable_media_retryzs  rcCsdttS)Nzgccl-invocation-id/)rrr'r'r'r(_get_invocation_idr*rapplication/json; charset=UTF-8cCs8|dt}|r|d|7}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_clientr'r'r(_get_default_headerssr)F)rr")rNN)9rrdatetimehashlibrr# urllib.parserruuidrgoogler google.authrgoogle.cloud.storage.constantsrgoogle.cloud.storage.retryr r r&r,_API_VERSION_OVERRIDE_ENV_VAR_DEFAULT_UNIVERSE_DOMAIN_STORAGE_HOST_TEMPLATEformatr.r-r+ _API_VERSIONrr_NUM_RETRIES_MESSAGEnow_NOWtimezoneutc_UTCr)r/r0r<r?rBrHobjectrIrrrrfrerrrrrr'r'r'r(sp             `   "