(phvSrSSKrSSKrSSKJr SSKJr SSKJr SSKJ r Sr Sr S r "S S \ R\R5r"S S \ R\R5r"SS\ R\R"5r"SS\ R\R"5rSr"SS\R(R*5r\"\R(S5(a "SS5rgSrg)z/Support for downloading media from Google APIs.N) _download)common)_helpers)_request_helperszChecksum mismatch while downloading: {} The X-Goog-Hash header indicated an {checksum_type} checksum of: {} but the actual {checksum_type} checksum of the downloaded contents was: {} zIncomplete download for: {} Error writing to stream while handling a gzip-compressed file download. Please restart the download. z The X-Goog-Stored-Content-Length is {}. The X-Goog-Stored-Content-Encoding is {}. The download request read {} bytes of data. If the download was incomplete, please check the network connection and restart the download. cV\rSrSrSrSr\R\R44Sjr Sr g)Download8adHelper to manage downloading a resource from a Google API. "Slices" of the resource can be retrieved by specifying a range with ``start`` and / or ``end``. However, in typical usage, neither ``start`` nor ``end`` is expected to be provided. Args: media_url (str): The URL containing the media to be downloaded. stream (IO[bytes]): A write-able stream (i.e. file-like object) that the downloaded resource can be written to. start (int): The first byte in a range to be downloaded. If not provided, but ``end`` is provided, will download from the beginning to ``end`` of the media. end (int): The last byte in a range to be downloaded. If not provided, but ``start`` is provided, will download from the ``start`` to the end of the media. headers (Optional[Mapping[str, str]]): Extra headers that should be sent with the request, e.g. headers for encrypted data. checksum Optional([str]): The type of checksum to compute to verify the integrity of the object. The response headers must contain a checksum of the requested type. If the headers lack an appropriate checksum (for instance in the case of transcoded or ranged downloads where the remote service does not know the correct checksum) an INFO-level log will be emitted. Supported values are "md5", "crc32c" and None. The default is "md5". Attributes: media_url (str): The URL containing the media to be downloaded. start (Optional[int]): The first byte in a range to be downloaded. end (Optional[int]): The last byte in a range to be downloaded. cURcPURcC[R"XRUR UR S9up#X lX0lOURnURnU [URU5nUR[RSS9nUHMnURRU5 U=R[U5- slUR!U5 MO SSS5 UGb*UR"[$R&R(:wGa[R*"UR-55nXr:waUR U5nUR/S5n UR/S5n [0R3XUR5n U (a*UR[5U 5:aU S:wa [7U 5e[8R3UR UUUR R;5S9n X- n [<R>"X5eggg!,(df  GN>=f)bWrite response body to a write-able stream. .. note: This method assumes that the ``_stream`` attribute is set on the current download. Args: response (~requests.Response): The HTTP response object. Raises: ~google.resumable_media.common.DataCorruption: If the download's checksum doesn't agree with server-computed checksum. N checksum_typeF) chunk_sizedecode_unicodex-goog-stored-content-encodingx-goog-stored-content-lengthgzip) _expected_checksum_checksum_objectr_get_expected_checksum _get_headers media_urlchecksum _add_decoderraw iter_contentr_SINGLE_GET_CHUNK_SIZE_streamwrite_bytes_downloadedlenupdate status_codehttpclientPARTIAL_CONTENTprepare_checksum_digestdigestget_RESPONSE_HEADERS_INFOformatintConnectionError_CHECKSUM_MISMATCHupperrDataCorruption) selfresponseexpected_checksumchecksum_objectlocal_checksum_object body_iterchunkactual_checksumheadersx_goog_encoding x_goog_lengthcontent_length_msgmsgs [/var/www/html/venv/lib/python3.13/site-packages/google/resumable_media/requests/download.py_write_to_streamDownload._write_to_streamYs(  " " *t/D/D/L2:1P1P++T^^4==2 . '8 #$3 ! $ 7 7 "33O  %1$O ! --+BBSX.I# ""5)&&#e*4&%,,U3#  )$$ (C(CC&>>?U?U?WXO3++H5")++.N"O ' ,J K %;%B%B!D4J4J&""..]1CC'61 **<==,33)'&*mm&9&9&; 4C -C //>>14 D *!Xs 8BH77 Ic0^^^^TR5ump4nUUUS.mTRbSTS'TRc%[R"TR 5TlUUUU4Sjn[ R"UTRTR5$)Consume the resource to be downloaded. If a ``stream`` is attached to this download, then the downloaded resource will be written to the stream. Args: transport (~requests.Session): A ``requests`` object which can make authenticated requests. timeout (Optional[Union[float, Tuple[float, float]]]): The number of seconds to wait for the server response. Depending on the retry strategy, a request may be repeated several times using the same timeout each time. Can also be passed as a tuple (connect_timeout, read_timeout). See :meth:`requests.Session.request` documentation for details. Returns: ~requests.Response: The HTTP response returned by ``transport``. Raises: ~google.resumable_media.common.DataCorruption: If the download's checksum doesn't agree with server-computed checksum. ValueError: If the current :class:`Download` has already finished. datar8timeoutTstreamc>TRnTRS:a[R"TR=(d STR-TR TR 5 TR TS'TRbP[R"TR5c/STR0n[R"TRU5nTR"TU40TD6nTRc&[R"UTR5TlTRU5 TRbZ[R "UTR5(a#TRR#S5 STlTR+U5 U$![$a&n[&R)U5n[%U5UeSnAff=fNrr8 generationrrradd_bytes_rangestartend_headers_object_generationr_get_generation_from_urladd_query_parametersrequest_parse_generation_headerr_process_responser_is_decompressive_transcodingseek Exception_STREAM_SEEK_ERRORr*r> url query_paramresultexcr<methodrequest_kwargsr0 transports r=retriable_request+Download.consume..retriable_request..C%%)))ZZ_1(>(>>$---1MMy)++7 99$..IQ#/1H1H"IK"77 TC&&vsEnEF&&.*2*K*KD--+'  " "6 * ||'99&$BSBSTT6 ))!,./D*%%f-M%6077<'n#56"F G!!GG) _prepare_requestrrNrrOrrwait_and_retry_get_status_code_retry_strategy r0r_rD_payloadr8r`r]r^s `` @@r=consumeDownload.consumesB'+&;&;&=#G  << #'+N8 $  " " *&.&G&G&WD #, , \ .. t44d6J6J  rrrrNN __name__ __module__ __qualname____firstlineno____doc__r>r_DEFAULT_CONNECT_TIMEOUT_DEFAULT_READ_TIMEOUTrk__static_attributes__rmr=rr8s.@N?h  5 5  2 2 ` rmrcV\rSrSrSrSr\R\R44Sjr Sr g) RawDownloadi agHelper to manage downloading a raw resource from a Google API. "Slices" of the resource can be retrieved by specifying a range with ``start`` and / or ``end``. However, in typical usage, neither ``start`` nor ``end`` is expected to be provided. Args: media_url (str): The URL containing the media to be downloaded. stream (IO[bytes]): A write-able stream (i.e. file-like object) that the downloaded resource can be written to. start (int): The first byte in a range to be downloaded. If not provided, but ``end`` is provided, will download from the beginning to ``end`` of the media. end (int): The last byte in a range to be downloaded. If not provided, but ``start`` is provided, will download from the ``start`` to the end of the media. headers (Optional[Mapping[str, str]]): Extra headers that should be sent with the request, e.g. headers for encrypted data. checksum Optional([str]): The type of checksum to compute to verify the integrity of the object. The response headers must contain a checksum of the requested type. If the headers lack an appropriate checksum (for instance in the case of transcoded or ranged downloads where the remote service does not know the correct checksum) an INFO-level log will be emitted. Supported values are "md5", "crc32c" and None. The default is "md5". Attributes: media_url (str): The URL containing the media to be downloaded. start (Optional[int]): The first byte in a range to be downloaded. end (Optional[int]): The last byte in a range to be downloaded. cURcPURcC[R"XRUR UR S9up#X lX0lOURnURnU URR[RSS9nUHMnURRU5 U=R[U5- sl URU5 MO SUlSSS5 UGb*UR"[$R&R(:wGa[R*"UR-55nXb:waUR U5nUR/S5nUR/S5n [0R3XUR5n U (a*UR[5U 5:aUS:wa [7U 5e[8R3UR UUUR R;5S9n X- n [<R>"X5eggg!,(df  GN>=f) r Nr F)decode_contentTrrr) rrrrrrrrrErrrrrr r!_content_consumedr"r#r$r%r&r'r(r)r*r+r,r-r.rr/) r0r1r2r3r5r6r7r8r9r:r;r<s r=r>RawDownload._write_to_stream,s&  " " *t/D/D/L2:1P1P++T^^4==2 . '8 #$3 ! $ 7 7 "33O  ++ 77,I# ""5)&&#e*4&&&u-#*.H &  )$$ (C(CC&>>?U?U?WXO3++H5")++.N"O ' ,J K %;%B%B!D4J4J&""..]1CC'61 **<==,33)'&*mm&9&9&; 4C -C //>>14 D *Xs 8BH22 Ic^^^^TR5ump4nUUUSS.mTRc%[R"TR5TlUUUU4Sjn[ R "UTRTR5$)rAT)rCr8rDrEc>TRnTRS:a[R"TR=(d STR-TR TR 5 TR TS'TRbP[R"TR5c/STR0n[R"TRU5nTR"TU40TD6nTRc&[R"UTR5TlTRU5 TRbZ[R "UTR5(a#TRR#S5 STlTR+U5 U$![$a&n[&R)U5n[%U5UeSnAff=frGrIrXs r=r`.RawDownload.consume..retriable_requestrbrc) rdrNrrOrrrerfrgrhs `` @@r=rkRawDownload.consumewsB'+&;&;&=#G    " " *&.&G&G&WD #, , \ .. t44d6J6J  rmrnNrorxrmr=rzrz s->I?^  5 5  2 2 _ rmrzcP\rSrSrSr\R \R44SjrSr g)ChunkedDownloadiaNDownload a resource in chunks from a Google API. Args: media_url (str): The URL containing the media to be downloaded. chunk_size (int): The number of bytes to be retrieved in each request. stream (IO[bytes]): A write-able stream (i.e. file-like object) that will be used to concatenate chunks of the resource as they are downloaded. start (int): The first byte in a range to be downloaded. If not provided, defaults to ``0``. end (int): The last byte in a range to be downloaded. If not provided, will download to the end of the media. headers (Optional[Mapping[str, str]]): Extra headers that should be sent with each request, e.g. headers for data encryption key headers. Attributes: media_url (str): The URL containing the media to be downloaded. start (Optional[int]): The first byte in a range to be downloaded. end (Optional[int]): The last byte in a range to be downloaded. chunk_size (int): The number of bytes to be retrieved in each request. Raises: ValueError: If ``start`` is negative. c^^^^^^^TR5ummmmUUUUUUU4Sjn[R"UTRTR5$)Consume the next chunk of the resource to be downloaded. Args: transport (~requests.Session): A ``requests`` object which can make authenticated requests. timeout (Optional[Union[float, Tuple[float, float]]]): The number of seconds to wait for the server response. Depending on the retry strategy, a request may be repeated several times using the same timeout each time. Can also be passed as a tuple (connect_timeout, read_timeout). See :meth:`requests.Session.request` documentation for details. Returns: ~requests.Response: The HTTP response returned by ``transport``. Raises: ValueError: If the current download has finished. cP>TRTTTTTS9nTRU5 U$)NrBrQrSr[r8r]rjr0rDr_rYs r=r`=ChunkedDownload.consume_next_chunk..retriable_requests<&& 'F  " "6 *Mrmrdrrerfrgr0r_rDr`r8r]rjrYs``` @@@@r=consume_next_chunk"ChunkedDownload.consume_next_chunksN6)-(=(=(?%Wg   .. t44d6J6J  rmrxN rprqrrrsrtrrurvrrwrxrmr=rrs%>  5 5  2 2 , rmrcP\rSrSrSr\R \R44SjrSr g)RawChunkedDownloadi$aRDownload a raw resource in chunks from a Google API. Args: media_url (str): The URL containing the media to be downloaded. chunk_size (int): The number of bytes to be retrieved in each request. stream (IO[bytes]): A write-able stream (i.e. file-like object) that will be used to concatenate chunks of the resource as they are downloaded. start (int): The first byte in a range to be downloaded. If not provided, defaults to ``0``. end (int): The last byte in a range to be downloaded. If not provided, will download to the end of the media. headers (Optional[Mapping[str, str]]): Extra headers that should be sent with each request, e.g. headers for data encryption key headers. Attributes: media_url (str): The URL containing the media to be downloaded. start (Optional[int]): The first byte in a range to be downloaded. end (Optional[int]): The last byte in a range to be downloaded. chunk_size (int): The number of bytes to be retrieved in each request. Raises: ValueError: If ``start`` is negative. c^^^^^^^TR5ummmmUUUUUUU4Sjn[R"UTRTR5$)rc R>TRTTTTSTS9nTRU5 U$)NT)rCr8rErDrrs r=r`@RawChunkedDownload.consume_next_chunk..retriable_request^s?&& 'F  " "6 *Mrmrrs``` @@@@r=r%RawChunkedDownload.consume_next_chunk@sN6)-(=(=(?%Wg   .. t44d6J6J  rmrxNrrxrmr=rr$s%>  5 5  2 2 - rmrcURRSS5R5nUS:Xa%[U5Ul[ R "5$US:Xa0[(a%[U5Ul[ R "5$U$)aNPatch the ``_decoder`` on a ``urllib3`` response. This is so that we can intercept the compressed bytes before they are decoded. Only patches if the content encoding is ``gzip`` or ``br``. Args: response_raw (urllib3.response.HTTPResponse): The raw response for an HTTP request. checksum (object): A checksum which will be updated with compressed bytes. Returns: object: Either the original ``checksum`` if ``_decoder`` is not patched, or a ``_DoNothingHash`` if the decoder is patched, since the caller will no longer need to hash to decoded bytes. zcontent-encodingrbr)r8r(lower _GzipDecoder_decoderr_DoNothingHash_BrotliDecoder) response_rawrencodings r=rrpsw&##''(:B?EEGH6 ,X 6 &&(( T nn .x 8 &&((rmc8^\rSrSrSrU4SjrU4SjrSrU=r$)ria,Custom subclass of ``urllib3`` decoder for ``gzip``-ed bytes. Allows a checksum function to see the compressed bytes before they are decoded. This way the checksum of the compressed value can be computed. Args: checksum (object): A checksum which will be updated with compressed bytes. c.>[TU]5 XlgN)super__init__ _checksum)r0r __class__s r=r_GzipDecoder.__init__s !rmcX>URRU5 [TU] U5$zDecompress the bytes. Args: data (bytes): The compressed bytes to be decompressed. Returns: bytes: The decompressed bytes from ``data``. )rr!r decompress)r0rCrs r=r_GzipDecoder.decompresss' d#w!$''rm)r) rprqrrrsrtrrrw __classcell__)rs@r=rrs" ( (rmr BrotliDecoderc*\rSrSrSrSrSrSrSrg)riaHandler for ``brotli`` encoded bytes. Allows a checksum function to see the compressed bytes before they are decoded. This way the checksum of the compressed value can be computed. Because BrotliDecoder's decompress method is dynamically created in urllib3, a subclass is not practical. Instead, this class creates a captive urllib3.requests.BrotliDecoder instance and acts as a proxy. Args: checksum (object): A checksum which will be updated with compressed bytes. cV[RR5UlXlgr)urllib3r1rrr)r0rs r=r_BrotliDecoder.__init__s#,,::rs6 ,)+< Q --y/A/AQ hJ "33Y5G5GJ ZH &44i6O6OH VI )::I(7##//(< 7  _-- ) )FNrm