(ph9BSrSSKJr SSKrSSKrSSKrSSKrSSKrSSKJ r SSKJ r SSKJ r SSKJ r SSK Jr S rS rS rS rS rSrSrSr\R."\5rSr\4Sjr\4SjrS#SjrSrSrSr Sr!Sr"Sr#Sr$Sr%Sr&Sr'Sr(S r)"S!S"\*5r+g)$z4Shared utilities used by both downloads and uploads.)absolute_importN)parse_qs) urlencode)urlsplit) urlunsplit)commonrangez content-rangezcontent-encodingzCurrently 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.zx-goog-generationz x-goog-hashzx-goog-stored-content-encodingzNo {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.cg)zSimple default callback.Nr R/var/www/html/venv/lib/python3.13/site-packages/google/resumable_media/_helpers.py do_nothingr5r cbU"U5nX;aU"5 [R"USU5eXA$)abChecks 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)rInvalidResponse)responsename get_headerscallbackheaderss r header_requiredr9s>&(#G  $$ dict): returns response headers. media_url (str): The URL containing the media to be downloaded. checksum_type Optional(str): The checksum type to read from the headers, exactly as it will appear in the headers (case-sensitive). Must be "md5", "crc32c" or None. Returns: Tuple (Optional[str], object): The expected checksum of the response, if it can be detected from the ``X-Goog-Hash`` header, and the appropriate checksum object for the expected checksum. r@crc32cN4checksum must be ``'md5'``, ``'crc32c'`` or ``None``r@rNchecksum_labelNrBr@) ValueError_parse_checksum_headerget _HASH_HEADER_MISSING_CHECKSUMformatupper_LOGGERinfo_DoNothingHashhashlibr@r0)rr media_urlrCrexpected_checksummsgchecksum_objects r _get_expected_checksumrbs 33OPP + +h'2 KK %x   $#**)<)<)>+C LL ,.O  //%")++-  // #5"6  //!(*  //r cUS;a [S5eUS;a'U"U5n[UR[5XS9nU$SnU$)aUGet the computed checksum and checksum object from the response headers. Args: response (~requests.Response): The HTTP response object. get_headers (callable: response->dict): returns response headers. checksum_type Optional(str): The checksum type to read from the headers, exactly as it will appear in the headers (case-sensitive). Must be "md5", "crc32c" or None. Returns: Tuple (Optional[str], object): The checksum of the response, if it can be detected from the ``X-Goog-Hash`` header, and the appropriate checksum object for the expected checksum. rMrOrPrQN)rSrTrUrV)rrrCrremote_checksums r #_get_uploaded_checksum_from_headersresY33OPP + +h'0 KK %x   r cLUcg/nURS5H>nURSS5upVUR5U:XdM-URU5 M@ [U5S:Xag[U5S:XaUS$[R "USR U5UU5e)aParses the checksum header from an ``X-Goog-Hash`` value. .. _header reference: https://cloud.google.com/storage/docs/ xml-api/reference-headers#xgooghash Expects ``header_value`` (if not :data:`None`) to be in one of the three following formats: * ``crc32c=n03x6A==`` * ``md5=Ojk9c3dhfxgoKVVHYwFbHQ==`` * ``crc32c=n03x6A==,md5=Ojk9c3dhfxgoKVVHYwFbHQ==`` See the `header reference`_ for more information. Args: header_value (Optional[str]): The ``X-Goog-Hash`` header from a download response. response (~requests.Response): The HTTP response object. checksum_label (str): The label of the header value to read, as in the examples above. Typically "md5" or "crc32c" Returns: Optional[str]: The expected checksum of the response, if it can be detected from the ``X-Goog-Hash`` header; otherwise, None. Raises: ~google.resumable_media.common.InvalidResponse: If there are multiple checksums of the requested type in ``header_value``. N,=rz.X-Goog-Hash header had multiple ``{}`` values.)splitlstripappendlenrrrX) header_valuerrRmatcheschecksumrvalues r rTrTs<G &&s+nnS!,  ;;=N * NN5 ! ,  7|q W qz$$  < C CN S     r cvUS:Xa[R"5$US:Xa [5$Ucg[S5e)zvRespond with a checksum object for a supported type, if not None. Raises ValueError if checksum_type is unsupported. r@rNNrO)r]r@r0rSrBs r _get_checksum_objectrsGs> {{} ( "!##  OPPr c\U"U5nUR[S5nUcg[U5$)aeParses the generation header from an ``X-Goog-Generation`` value. Args: response (~requests.Response): The HTTP response object. get_headers (callable: response->dict): returns response headers. Returns: Optional[long]: The object generation from the response, if it can be detected from the ``X-Goog-Generation`` header; otherwise, None. N)rU_GENERATION_HEADERint)rrrobject_generations r _parse_generation_headerrxVs5(#G $6= $%%r c[U5u pn[U5nURSS5nUcg[US5$)zRetrieve the object generation query param specified in the media url. Args: media_url (str): The URL containing the media to be downloaded. Returns: long: The object generation from the media url if exists; otherwise, None. generationNr)rrrUrv)r^_query query_paramsrws r _get_generation_from_urlr~jsM!+Aq!AE?L$((t< $Q'((r c[U5S:XaU$[U5up#pEn[U5n0UEUEn[USS9n[ X#XEU45$)zAdd query parameters to a base url. Args: media_url (str): The URL containing the media to be downloaded. query_params (dict): Names and values of the query parameters to add. Returns: str: URL with additional query strings appended. rT)doseq)rmrrrr) r^r}schemenetlocpathr|fragparams new_paramss r add_query_parametersr~s^ <A(0(;%FD e_F+F+l+J j -E vtD9 ::r cU"U5nUR[5S:H=(a UR[5S:g$)aReturns True if the object was served decompressed. This happens when the "x-goog-stored-content-encoding" header is "gzip" and "content-encoding" header is not "gzip". See more at: https://cloud.google.com/storage/docs/transcoding#transcoding_and_gzip Args: response (~requests.Response): The HTTP response object. get_headers (callable: response->dict): returns response headers. Returns: bool: Returns True if decompressive transcoding has occurred; otherwise, False. gzip)rU_STORED_CONTENT_ENCODING_HEADERCONTENT_ENCODING_HEADER)rrrs r _is_decompressive_transcodingrs<(#G 34> ; KK/ 0F :r c\rSrSrSrSrSrg)r\izDo-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. cg)zDo-nothing ``update`` method. Intended to match the interface of ``hashlib.md5`` and other checksums. Args: unused_chunk (bytes): A chunk of data. Nr )self unused_chunks r update_DoNothingHash.updaterr r N)__name__ __module__ __qualname____firstlineno____doc__r__static_attributes__r r r r\r\s   r r\)g@),r __future__rrFr]loggingrr9 urllib.parserrrrgoogle.resumable_mediar RANGE_HEADERCONTENT_RANGE_HEADERrr;rurVrrW getLoggerrrZrrrr&r0r.rDrKrbrerTrsrxr~rrobjectr\r r r rs;&  !"!#) &,- ) "B$   H %#;E:KU@<8,  *'0T82 j Q&()(;*" V r