a ñâÑ`³ã@sŠdZddlZddlZddlZddlmZdZdZdZdZ dZ e  e ¡Z d d „Zefd d „Zefd d„Zdd„Zdd„ZGdd„deƒZdS)z4Shared utilities used by both downloads and uploads.éN)ÚcommonÚrangez content-rangez¨Currently using crcmod in pure python form. This is a slow implementation. Python 3 has a faster implementation, `google-crc32c`, which will be used if it is installed.z x-goog-hashz·No {checksum_type} checksum was returned from the service while downloading {} (which happens for composite objects), so client-side content integrity checking is not being performed.cCsdS)zSimple default callback.N©rrrúElib/python3.9/site-packages/google/_async_resumable_media/_helpers.pyÚ do_nothing)srcCs,||ƒ}||vr$|ƒt |d|¡‚||S)ašChecks that a specific header is in a headers dictionary. Args: response (object): An HTTP response object, expected to have a ``headers`` attribute that is a ``Mapping[str, str]``. name (str): The name of a required header. get_headers (Callable[Any, Mapping[str, str]]): Helper to get headers from an HTTP response. callback (Optional[Callable]): A callback that takes no arguments, to be executed when an exception is being raised. Returns: str: The desired header. Raises: ~google.resumable_media.common.InvalidResponse: If the header is missing. z$Response headers must contain header©rZInvalidResponse)ÚresponseÚnameZ get_headersÚcallbackZheadersrrrÚheader_required-sÿr cCs2||ƒ}||vr.|ƒtj|d|dg|¢RŽ‚|S)a`Require a response has a status code among a list. Args: response (object): The HTTP response object. status_codes (tuple): The acceptable status codes. get_status_code (Callable[Any, int]): Helper to get a status code from a response. callback (Optional[Callable]): A callback that takes no arguments, to be executed when an exception is being raised. Returns: int: The status code. Raises: ~google.resumable_media.common.InvalidResponse: If the status code is not one of the values in ``status_codes``. zRequest failed with status codezExpected one ofr)rZ status_codesÚget_status_coder Z status_coderrrÚrequire_status_codeJsüûr cCs0d|}||kr|}t dd¡}||d|fS)aµCalculate the amount of time to wait before a retry attempt. Wait time grows exponentially with the number of attempts, until ``max_sleep``. A random amount of jitter (between 0 and 1 seconds) is added to spread out retry attempts from different clients. Args: base_wait (float): The "base" wait time (i.e. without any jitter) that will be doubled until it reaches the maximum sleep. max_sleep (float): Maximum value that a sleep time is allowed to be. Returns: Tuple[float, float]: The new base wait time as well as the wait time to be applied (with a random amount of jitter between 0 and 1 seconds added). g@riègü©ñÒMbP?)ÚrandomZrandint)Ú base_waitÚ max_sleepZ new_base_waitZ jitter_msrrrÚcalculate_retry_waitis  rc Ãs¤d}d}d}d}z|ƒIdH}Wn(tyH}z|}WYd}~nd}~00||ƒtjvr\|S| ||¡st|rp|‚|St||jƒ\}} |d7}|| 7}t | ¡q dS)a[Attempts to retry a call to ``func`` until success. Expects ``func`` to return an HTTP response and uses ``get_status_code`` to check if the response is retry-able. Will retry until :meth:`~.RetryStrategy.retry_allowed` (on the current ``retry_strategy``) returns :data:`False`. Uses :func:`calculate_retry_wait` to double the wait time (with jitter) after each attempt. Args: func (Callable): A callable that takes no arguments and produces an HTTP response which will be checked as retry-able. get_status_code (Callable[Any, int]): Helper to get a status code from a response. retry_strategy (~google.resumable_media.common.RetryStrategy): The strategy to use if the request fails and must be retried. Returns: object: The return value of ``func``. grgà?Né)ÚConnectionErrorrZ RETRYABLEZ retry_allowedrrÚtimeÚsleep) Úfuncr Zretry_strategyZ total_sleepZ num_retriesrÚerrorrÚeZ wait_timerrrÚwait_and_retry„s$ rc@seZdZdZdd„ZdS)Ú_DoNothingHashz«Do-nothing hash object. Intended as a stand-in for ``hashlib.md5`` or a crc32c checksum implementation in cases where it isn't necessary to compute the hash. cCsdS)z¸Do-nothing ``update`` method. Intended to match the interface of ``hashlib.md5`` and other checksums. Args: unused_chunk (bytes): A chunk of data. Nr)ÚselfZ unused_chunkrrrÚupdate¿sz_DoNothingHash.updateN)Ú__name__Ú __module__Ú __qualname__Ú__doc__rrrrrr¸sr)r ÚloggingrrZgoogle.resumable_mediarZ RANGE_HEADERZCONTENT_RANGE_HEADERZ_SLOW_CRC32C_WARNINGZ _HASH_HEADERZ_MISSING_CHECKSUMZ getLoggerrZ_LOGGERrr r rrÚobjectrrrrrÚs" ÿ   4