SrSSKJr SSKJr SSKJs Jr SSK Js J r SSK r SSKrSSKrSSKrSSKrSSKrSSKJr SSKJr SSKJr SSKJr SSKJr SS KJr SS KJr /S QrS rS rSrSr Sr!Sr"Sr#"SS\$5r%"SS\%5r&\RN(a"SS\RP5r)"SS\%5r*g)z)Upload and download support for apitools.)print_functionN) http_client)buffered_stream) compression) exceptions) http_wrapper) stream_slice)util)DownloadUploadRESUMABLE_UPLOAD SIMPLE_UPLOADDownloadProgressPrinterDownloadCompletePrinterUploadProgressPrinterUploadCompletePrinteriPsimple resumablecSUR;a[SURS-5 g[SUR-5 g)z*Print download progress based on response. content-rangez Received %szReceived %d bytesN)infoprintlength)responseunused_downloads ,lib/third_party/apitools/base/py/transfer.pyrr7s6(--' mhmmO<<= !HOO34c[S5 g)z-Print information about a completed download.zDownload completeNr)unused_responsers rrr?s  rc:[SURS-5 g)z(Print upload progress based on response.zSent %srangeN)rr)r unused_uploads rrrDs )hmmG, ,-rc[S5 g)z+Print information about a completed upload.zUpload completeNr)r r#s rrrIs  rc\rSrSrSrSSjrSr\S5r\S5r \S5r \ RS 5r \S 5r \ RS 5r \S 5r \S 5rSr\S5r\S5rSrSrSrSrSrg) _TransferNz-Generic bits common to Uploads and Downloads.NcSUlX lXPlXlSUlSUlX`l[RUl X@l U=(d SUl g)Ni) _Transfer__bytes_http_Transfer__close_stream_Transfer__http_Transfer__stream_Transfer__url_Transfer__num_retries num_retriesr)HandleExceptionsAndRebuildHttpConnections retry_func auto_transfer chunksize)selfstream close_streamr4r3httpr0s r__init___Transfer.__init__RsS *   &  B B *"-grc[U5$N)strr5s r__repr___Transfer.__repr__cs 4yrcUR$r<)r+r>s rr7_Transfer.close_streamfs"""rcUR$r<)r,r>s rr8_Transfer.httpjs {{rc@UR=(d UR$r<)r*r8r>s r bytes_http_Transfer.bytes_httpns  -DII-rcXlgr<)r*r5values rrFrGrs!rcUR$r<)r/r>s rr0_Transfer.num_retriesvs!!!rc[R"U[R5 US:a[R "S5eXlg)Nrz*Cannot have negative value for num_retries)r Typechecksix integer_typesrInvalidDataErrorr/rIs rr0rLzs9 uc//0 19--<> >"rcUR$r<)r-r>s rr6_Transfer.streams }}rcUR$r<)r.r>s rurl _Transfer.urls zzrcUR5 URc#U=(d [R"5UlX lg)a>Initialize this download by setting self.http and self.url. We want the user to be able to override self.http by having set the value in the constructor; in that case, we ignore the provided http. Args: http: An httplib2.Http instance or None. url: The url for this transfer. Returns: None. Initializes self. N)EnsureUninitializedr8rGetHttpr,r.)r5r8rUs r _Initialize_Transfer._Initializes4   " 99 8,"6"6"8DK rcHURSL=(a URSL$r<)rUr8r>s r initialized_Transfer.initializedsxxt#= (==rc,[U5R$r<)type__name__r>s r _type_name_Transfer._type_namesDz"""rclUR(d#[R"SUR-5eg)NzCannot use uninitialized %sr]rTransferInvalidErrorrbr>s rEnsureInitialized_Transfer.EnsureInitializeds111-?A A rclUR(a#[R"SUR-5eg)NzCannot re-initialize %srer>s rrX_Transfer.EnsureUninitializeds/   11)DOO;= = rc\UR(aURR5 ggr<)r+r-closer>s r__del___Transfer.__del__s    MM   ! rcTUb%[R"XU4S9R5 gg)N)targetargs) threadingThreadstart)r5callbackrs r_ExecuteCallback_Transfer._ExecuteCallbacks)     Hd3C D J J L r) __bytes_http__close_stream__http __num_retries__stream__urlr3r4r0r2)FNTNr))ra __module__ __qualname____firstlineno____doc__r9r?propertyr7r8rFsetterr0r6rUrZr]rbrgrXrmrv__static_attributes__rrr&r&Ns7=A<=."##..""""##&>>##A = "Mrr&c^\rSrSrSr\"\R\R\R\R45r \"S5r SU4Sjjr \S5r\S5r\SSj5r\SSj5r\SS j5r\S 5r\S 5rS rS rSrSSjrSSjrSSjrSSjrSSjrSrSSjr SSjr!S Sjr"Sr#U=r$$)!r zeData for a single download. Public attributes: chunksize: default chunksize to use for transfers. r3progress total_sizerUc >URSS5n[[U]"U40UD6 SUlSUlXPlSUlX lX0l g)Nrr) popsuperr r9_Download__initial_response_Download__progress_Download__total_size_Download__encodingprogress_callbackfinish_callback)r5r6rrkwdsr __class__s rr9Download.__init__sOXXlD1  h&v66"&&!2.rcUR$r<)rr>s rrDownload.progress rcUR$r<)rr>s rencodingDownload.encodingrrc [RRU5n[RRU5(a U(d[R "SU-5eU"[ US54SUS.UD6$)z-Create a new download object from a filename.z*File %s exists and overwrite not specifiedwbT)r7r3)ospath expanduserexistsrInvalidUserInputErroropen)clsfilename overwriter3rrs rFromFileDownload.FromFilesrww!!(+ 77>>$   22IIl+-. .>>&1D1  $%2 "%)/%:H "  ,,T%[9Cu+C/j1AB14 3EF  rcUR5 URURURURS.$)Nr)rgr3rrrUr>s rserialization_dataDownload.serialization_datas6  !// //88   rcUR$r<)rr>s rrDownload.total_size   rcrUR(dgSURURUR4-$)NzDownload (uninitialized)z1Download with %d/%s bytes transferred from url %sr]rrrUr>s r__str__Download.__str__s4-B MM4??DHHF66 6rcbSURS'SURS- 4-URS'g)Nmediaaltz bytes=0-%dRange) query_paramsr4headers)r5 http_request url_builders rConfigureRequestDownload.ConfigureRequests5*1   ' )58J7L(L W%rcSU;a-USRS5u p#US:wa[U5UlURcSUlgg)z;Sets the total size based off info if possible otherwise 0.r/*Nr) rpartitionintrr)r5r_totals r __SetTotalDownload.__SetTotal#sO d "/::3?KAq|$'J! ?? " !D  #rc0UR5 UcUc[R"S5eU=(d URnUb UR UR 5UlUR nUR (aURS5nURUSU5 [R"UR=(d UU5nURUR;a[RRU5eX`lUR#UR$5 UR$R'SUR(5nUbUR U5nUR+X$5 UR (aUR-5 gg)ahInitialize this download by making a request. Args: http_request: The HttpRequest to use to initialize this download. http: The httplib2.Http instance for this request. client: If provided, let this client process the final URL before sending any additional requests. If client is provided and http is not, client.http will be used instead. NMust provide client or http.rzcontent-location)rXr UserErrorr8rrUr3_Download__ComputeEndByte_Download__SetRangeHeaderr MakeRequestrF status_code_ACCEPTABLE_STATUSES HttpError FromResponser_Download__SetTotalrget request_urlrZStreamInChunks)r5rr8rrUend_byters rInitializeDownloadDownload.InitializeDownload0sJ   " #,,X8B-DHx:L'NH* .%)%=%=e%I"*.'--h7H  'H!#'';>>9  33KMM)+*h.>#rc&URXUSS9 g)z%Stream the entire download in chunks.TrurrrN) StreamMediar5rurrs rrDownload.StreamInChunkss (,>$(  *rcRU=(d URnU=(d URnUR5 URbURnSUlO5UR UR US9nUR UR UUS9nURcURUR5 URU5nURX5 UR[R:XdUR UR:aOMURX%5 g)aStream the entire download. Args: callback: (default: None) Callback to call as each chunk is completed. finish_callback: (default: None) Callback to call when the download is complete. additional_headers: (default: None) Additional headers to include in fetching bytes. use_chunks: (bool, default: True) If False, ignore self.chunksize and stream this download in a single request. Returns: None. Streams bytes into self.stream. N)rr)rrrgrrrrrrrrrvrrr )r5rurrrrrs rrDownload.StreamMedias"5t55)AT-A-A  &&222*.'008<&9&9rr c(\rSrSrSrSrSr\rSrg)MultipartBytesGeneratori)aGGenerates a bytes Message object tree for multipart messages This is a BytesGenerator that has been modified to not attempt line termination character modification in the bytes payload. Known to work with the compat32 policy only. It may work on others, but not tested. The outfp object must accept bytes in its write method. cVURcgURUR5 gr<)_payloadr )r5msgs r _handle_text$MultipartBytesGenerator._handle_text1s!||# JJs|| $rc&URSS5$)Nasciisurrogateescape)encode)r5ss r_encodeMultipartBytesGenerator._encode8s88G%67 7rrN) rar~rrrr3r: _writeBodyrrrrr/r/)s  % 8" rr/c^\rSrSrSr\"S5rS#U4Sjjr\S5r \ S$Sj5r \ S$Sj5r \ S%Sj5r \S 5r\S 5r\S 5rS r\S 5r\R&S5r\S5r\R&S5rSrSrSrSrSrSrSrS&SjrSrS'SjrSrS(Sjr S)Sjr!S)Sjr"Sr#S'S jr$S'S!jr%S"r&U=r'$)*r i?awData for a single Upload. Fields: stream: The stream to upload. mime_type: MIME type of the upload. total_size: (optional) Total upload size for the stream. close_stream: (default: False) Whether or not we should close the stream when finished with the upload. auto_transfer: (default: True) If True, stream all bytes as soon as the upload is created. r3 mime_typerrUc  >[[U] "U4XVXtS.U D6 SUlSUlX lSUlSUlSUlSUl Xl Xl Xl X0l g)N)r7r4r3r8Fr)rr r9_Upload__complete_Upload__final_response_Upload__mime_type_Upload__progress!_Upload__server_chunk_granularity_Upload__strategy_Upload__total_size_Upload__gzip_encodedrrr) r5r6r?rr8r7r4r3rr gzip_encodedrrs rr9Upload.__init__Osv fd$  s rrUpload.progresscrrc [RRU5n[RRU5(d[R "SU-5eU(d4[ R"U5up'Uc[R"SU-5e[R"U5RnU"[US5U4USUUS.UD6$)z+Create a new Upload object from a filename.zCould not find file %sz Could not guess mime type for %srbTrr7r3rI) rrrrr NotFoundError mimetypes guess_typerstatst_sizer) rrr?r3rIrrrsizes rrUpload.FromFilegsww!!(+ww~~d##**+Cd+JK K$//5LI  666=??wwt}$$4d#Y64 $M ,6046 6rc PUc[R"S5eU"X4USUUS.UD6$)z)Create a new Upload object from a stream.z!No mime_type specified for streamFrO)rr)rr6r?rr3rIrs rrUpload.FromStreamxsF  2235 566 %] ,6046 6rc [R"U5nUR[UR 55- n U (a([ R "SSRU 5-5eSU;a[ R"S5eUR"XS4URS5US.UD6n [U[R5(a+UR5(d[ R"S5eUbXJlO USU lUbUR!US 5n OUS n ["U lU R'X;5 U R)5 U R+5 U R(aU R-5 U $) zACreate a new Upload of stream from serialized json_data and http.rrrz/Cannot override total_size on serialized Uploadr?)rrIz6Cannot restart resumable upload on non-seekable streamr3rU)rrrrrrrQrrrr isinstanceioIOBaseseekabler3rr strategyrZRefreshResumableUploadStatergr) rr6rr8r3rIrrrruploadrUs rrUpload.FromDatasjzz)$77#diik:JJ -->IIl+-. . 4 22AC C[(9C+/88L+A-9C=AC fbii ( (1B1B22HJ J  $#0 #'#8F  **4;7#U #*  **,  "     ! ! # rcUR5 UR[:wa[R"S5eUR UR URURS.$)Nz2Serialization only supported for resumable uploadsr>) rgr^r rrQr3r?rrUr>s rrUpload.serialization_datas]  ==, ,--DF F"////88   rcUR$r<)rAr>s rcompleteUpload.completerrcUR$r<)rCr>s rr?Upload.mime_typesrcUR(dgSURUR=(d SUR4-$)NzUpload (uninitialized)z.Upload with %d/%s bytes transferred for url %sz???rr>s rrUpload.__str__s9+? MM4??3eTXXC?? ?rcUR$r<)rFr>s rr^Upload.strategyrrcbU[[4;a[R"SU-5eXlg)NzOInvalid value "%s" for upload strategy, must be one of "simple" or "resumable".)rr rrrFrIs rr^rls7 (89 9&&+.3(45 5 rcUR$r<)rGr>s rrUpload.total_sizerrc0UR5 Xlgr<)rXrGrIs rrros   "!rc4URc [UlURbg[nURbUR[:a[ nUR (aUR(d[ nUR(d[ nX0lg)aDetermine and set the default upload strategy for this upload. We generally prefer simple or multipart, unless we're forced to use resumable. This happens when any of (1) the upload is too large, (2) the simple endpoint doesn't support multipart requests and we have metadata, or (3) there is no simple upload endpoint. Args: upload_config: Configuration for the upload endpoint. http_request: The associated http request. Returns: None. N) resumable_pathrr^r_RESUMABLE_UPLOAD_THRESHOLDr bodysimple_multipart simple_path)r5 upload_configrr^s r__SetDefaultUploadStrategy!Upload.__SetDefaultUploadStrategysn  ' ' /)DM == $   OO '"=='H   ]%C%C'H(('H rcUR(a]UR(aLURUR:a2[R"SUR<SUR<35e[R "UR UR5(d2[R"SUR<SUR <35eURX5 UR[:XaURUl UR(a!SURS'URU5 O SURS'UR!U5 UR"(aZSUR$S '[&R("[*R,"UR55S R/5Ul g g UR0Ul S URS'UR3U5 g ) z.Configure the request and url for this upload.zUpload too big: z larger than max size z MIME type z) does not match any accepted MIME ranges multipart uploadTypergzipContent-EncodingrrN)rmax_sizerrr AcceptableMimeTypeacceptr?!_Upload__SetDefaultUploadStrategyr^rrv relative_pathrtr"_Upload__ConfigureMultipartRequest_Upload__ConfigureMediaRequestrHrrCompressStreamrOBytesIOreadrr"_Upload__ConfigureResumableRequest)r5rwrrs rrUpload.ConfigureRequests OO 6 6-"8"8822OO]%;%;=> >&&}';';T^^LL22NNM$8$8:; ; '' D ==M )(5(A(AK %  9D ((600>9@ ((6,,\:"";A $$%78 .. L$5$56889;;?46!#)6(D(DK %5@K $ $\ 2  , ,\ :rcURURS'URR5UlSUlg)z;Configure http_request as a simple request for this upload. content-type N)r?rr6rrt loggable_bodyr5rs r__ConfigureMediaRequestUpload.__ConfigureMediaRequest"s3/3~~ ^, KK,,. %3 "rc[R"S5n[USS5 [R"UR SR S56nURUR5 URU5 [R"URR S56nSUS'URURR55 URU5 [R"5n[R(a[ nO["R$nU"USS 9nUR'USS 9 UR)5UlUR+5nS U-UR S'[-U[R.5(aUR1S 5nURR U5nUS R3S5un n SR5U S/5US 'UR5U5Ulg)z>Configure http_request as a multipart request for this upload.related_write_headerscgr<rr>s r4Upload.__ConfigureMultipartRequest..-srrrbinaryzContent-Transfer-EncodingF) mangle_from_)unixfromzmultipart/related; boundary=%rr6s s --N)mime_multipart MIMEMultipartrmime_nonmultipartMIMENonMultipartrsplit set_payloadrtattachr?r6rrOrPY3r/email_generator Generatorflattengetvalue get_boundaryrZ text_typer8 partitionrr) r5rmsg_rootr2fpgenerator_classgmultipart_boundarybody_componentsrrs r__ConfigureMultipartRequest"Upload.__ConfigureMultipartRequest(s"// :*,=> 00  ! !. 1 7 7 <>  ))* 00$..2F2Fs2KL+3 '(  ((*+ [[] 775O-77O BU 3 (U +KKM %224 ,/A A ^, (#-- 8 8!3!:!:7!C &++112DE'+55g> A%llG5J+KL%7%<%<_%M "rcURURS'URb#[UR5URS'gg)NzX-Upload-Content-TypezX-Upload-Content-Length)r?rrr=rs r__ConfigureResumableRequest"Upload.__ConfigureResumableRequestRsE8< 45 ?? &-0-A  ) + 'rcUR[:wagUR5 [R"UR SSS0S9n[R "URUSURS9nURU5nUR[R[R4;aDSUlURUlUR"R%UR&5 X lgUR[R*:XaJUcSUlOUR-U5S -UlUR"R%UR&5 g[.R0R3U5e) zsTalk to the server and refresh the state of this resumable upload. Returns: Response if the upload is complete. NPUT Content-Rangez bytes */*)rU http_methodrr) redirectionsrTr)r^r rgrrrUrr8r0_GetRangeHeaderFromResponserrr CREATEDrArrDr6seekrrBRESUME_INCOMPLETE_Upload__GetLastByterrr)r5refresh_requestrefresh_response range_headers rr_"Upload.RefreshResumableUploadStateXs5 ==, ,   &..e$k24(33 IIQ$$&778HI  ' 'KNN,7,?,?,A A"DO"ooDO KK  T]] +%5 !  ) )\-K-K K#"#"&"4"4\"BQ"F KK  T]] +&&334DE ErclURRSURRS55$)Nrr")rrrs rr"Upload._GetRangeHeaderFromResponsezs(}}  (--*;*;G*DEErcURc[R"S5eUcUc[R"S5eUR[:wagU=(d URnUb UR UR 5UlUR5 [R"X!URS9nUR[R:wa[RRU5eUR R#S5UlUR SnUbUR U5nUR'X%5 UR((aUR+5$U$)z3Initialize this upload from the given http_request.Nz6No upload strategy set; did you call ConfigureRequest?r)rzX-Goog-Upload-Chunk-Granularitylocation)r^rrr r8rrUrXrrr0rrr rrrrrErZr3r)r5rr8r http_responserUs rInitializeUploadUpload.InitializeUpload}s= == &&HJ J TRUTS9$Nr)_Upload__SendChunkrtrr5s r CallSendChunk+Upload.__StreamMedia..CallSendChunks!##*<$> >rc$>TRUTS9$r)_Upload__SendMediaBodyrs rCallSendMediaBody/Upload.__StreamMedia..CallSendMediaBodys!''*<(> >rz%Cannot gzip encode non-chunked uploadTrz?Failed to transfer all bytes in chunk, upload paused at byte %drrz7Upload complete with %s additional bytes left in stream)%r^r rrrrrBrH_Upload__ValidateChunksizer4rgrer6tellrrr rrArr_Upload__IsRetryablerrr_rvrrrDrCommunicationErrorhasattrrrSEEK_ENDrfr) r5rurrrrrr send_func current_posend_poss ` ` r __StreamMediaUpload.__StreamMedias ==, ,2246 65t55)AT-A-A(( > >&0M5F d112279 9   $ $T^^ 4  --- !1!1!34H##  8K8K'LL"&##NNK$7$7 22,44 MM%55 ..x88$..;;HEE002%%h9"0000:.CheckResponse s3!--B(()** r)r2rcheck_response_funcr) rrrFr2r0rrrrr6r)r5rrrr last_bytes r__SendMediaRequestUpload.__SendMediaRequest s * ++ OOW$$-I   <#A#A A**00: >".. KK502 &&488,79*...' OO #'$//9L $05doo6I/3@L,8(  OO " "#5 6&&w@@rcBUR5 URSLn[R"URSS9nUR (a\SUR S'[R"URUR5upVnX-nURc U(aXl OURcj[R"URXR5nURnUR(aXl UR!UR5nOE[#XR-UR5n[$R&"URX- 5nXTlUR*UR S'U(aSUlURcSU<S US - <S 3n O0X:XaS UR-n OSU<S US - <S UR<3n XR S'U(aUR R/U5 UR1XH5$)zSend the specified chunk.Nr)rUrr}r~rrrrrz/*rrr)rgrrrrUrHrrrr6r4rGrBufferedStreamstream_end_positionstream_exhaustedrrr rrtr?rrr) r5rtr no_log_bodyrr read_length exhaustedrrs r __SendChunkUpload.__SendChunk7s  oo- &&488G   28GOO. /2=2L2L T^^3- /Ki%C&9$'! __ $*88 UNN4K11C++$'! &**4>>:Kenn,doo>C&224;; LK# *...' %3G ! ?? ".3S1W=L \'$//9L 05cAgtOL+7(  OO " "#5 6&&w44r) __complete__final_response__gzip_encoded __mime_typer%__server_chunk_granularity __strategyr&rrr^r)NNFNTNNF)NTF)NFNr'r<r)r()(rar~rrrrrr9rrr+rrrrrer?rr^rrrrrrrr_rrrrrrrrrrrrr,r-s@rr r ?s $'(;$< AECG9=#%(>B#66 JN %66=A,0""H      ? __  !!""!:+;Z4 (NTB FDF> 1& <@:>@D:>'+E&=A*.3&A26565rr )+r __future__remail.generator generatorremail.mime.multipartmimer{remail.mime.nonmultipart nonmultipartrr[rrQrrrrO six.movesrapitools.base.pyrrrrr r __all__rsrr rrrrobjectr&r rBytesGeneratorr/r rrrr"s"0%)--33   !,('))! & 5 .  hMhMVl9yl9^ 77"/"@"@",n5Yn5r