SrSSKJr SSKJr SSKJr SSKJr SSKJr SSKrSSK J r SSK r SSK r SSK r SSKrSSKrSSKrSSKrSSKrSS KJr SS KJr SS KJr SS KJr SS KJr SSKJr SSKrSSK r SSK!J"r" SSK#J$r$ SSK#J%r% SSK#J&r& SSK#J'r' SSK#J(r( SSK#J)r) SSK#J*r* SSK#J+r+ SSK#J,r, SSK#J-r- SSK#J.r. SSK#J/r/ SSK#J0r0 SSK#J1r1 SSK#J2r2 SSK3J4r4 SS K5J6r6 SS!K5J7r7 SS"K8J9r9 SS#K8J:r: SS$K8J;r; SS%K8Jr> SS(K8J?r? SS)K@JArA SS*KBJCrC SS+KDJErE SS,KFJGrG SS-KHJIrJ SS.KHJKrL SS/KMJNrN SS0KMJOrO SS1KMJPrP SS2KMJQrQ SS3KMJRrR SS4KSJTrT SS5KSJUrU SS6KSJVrV SS7KSJWrW SS8KSJXrX SS9KSJYrY SS:KSJZrZ SS;K[J\r\ SSK^J`r` SS?K^Jara SS@K^Jbrb SSAK^Jcrc SSBKdJere SSCKdJfrf SSDKdJgrg SSEKdJhrh SSFKiJjrj SSGKkJlrl SSHKmJnrnJoro SSIKpJqrq SSJKrJsrs SSKKrJtrt SSLKrJuru SSMKrJvrv SSNKrJwrw SSOKrJxrx SSPKyJzrz \R(a\|r}\LRr~\~Rr\GRrSQr\GR\GR \GR \GR4r\GR\GR\GR\GR\ GR\ GR\ GR\GR \ GR"GR$\GR&\GR(\GR*\GR,\4r\"/SRQ5rSSSSTSUSVSWSX.rSSSSYSZSTSUSVS[.r\GR;5r\GR?\5 \"S\S]/5rS^rS_rS`rSar"SbSc\'5rg)dz>JSON gsutil Cloud API implementation for Google Cloud Storage.)absolute_import)print_function)division)unicode_literals)contextmanagerN) http_client)encoding) exceptions) http_wrapper)transfer)CalculateWaitForRetry)config)context_config)AccessDeniedException)ArgumentException)BadRequestException)CloudApi)EncryptionException)NotEmptyException)NotFoundException)PreconditionException) Preconditions) PublishPermissionDeniedException)ResumableDownloadException)ResumableUploadAbortException)ResumableUploadException)!ResumableUploadStartOverException)ServiceException)CommandException)SetUpJsonCredentialsAndCache)isP12Credentials)BytesTransferredContainer)&DownloadCallbackConnectionClassFactory)HttpWithDownloadStream)HttpWithNoRetries)$UploadCallbackConnectionClassFactory)WrapDownloadHttpRequest)WrapUploadHttpRequest)ImpersonationCredentials)NoOpCredentials)ProgressCallbackWithTimeout)PopulateProjectId)storage_v1_client)storage_v1_messages)DeleteTrackerFile)GetRewriteTrackerFilePath)HashRewriteParameters)ReadRewriteTrackerFile)WriteRewriteTrackerFile) GetCertsFile)GetGcsJsonApiVersion)GetJsonResumableChunkSize)GetMaxRetryDelay) GetNewHttp) GetNumRetries)JsonResumableChunkSizeDefined)ListToGetFields)ValidateDstObjectMetadata)IAM_POLICY_VERSION)NUM_OBJECTS_PER_LIST_PAGE)REQUEST_REASON_ENV_VAR)REQUEST_REASON_HEADER_KEY)UTF8)#Base64Sha256FromBase64EncryptionKey) CryptoKeyType)CryptoKeyWrapperFromKey)FindMatchingCSEKInBotoConfig)AddAcceptEncodingGzipIfNeeded)LogAndHandleRetries) CreatePayload GetFinalUrl)GetPrintableExceptionString)CreateBucketNotFoundException)%CreateNotFoundExceptionForObjectWrite)CreateObjectNotFoundException)DEFAULT_CONTENT_TYPE)PRIVATE_DEFAULT_OBJ_ACL)REMOVE_CORS_CONFIG)ServiceAccountCredentialsi)acldefaultObjectAclz items/aclzitems/defaultObjectAclz items/ownerownerauthenticatedReadprivateprojectPrivate publicReadpublicReadWrite)Nauthenticated-readrVproject-private public-readzpublic-read-writebucketOwnerReadbucketOwnerFullControl)NrZzbucket-owner-readzbucket-owner-full-controlrVr[r\crc32cmd5Hashskipz4Insufficient OAuth2 scope to perform this operation.zstorage.googleapis.comzstorage.mtls.googleapis.comc ^\rSrSrSrSKU4SjjrSrSrSrS r S r SLS jr SLS jr SMS jr SNSjrSMSjrSLSjrSrSMSjrSrSrSOSjrSLSjrSPSjrSMSjrSNSjrSrSOSjrSLSjrSr\S5rSLSjr SMS jr!SNS!jr"SMS"jr#SLS#jr$SNS$jr%S%r&SLS&jr'SLS'jr(SLS(jr)SSSS)\*RVRXSSSSSS4 S*jr-SQS+jr.SQS,jr/SRS-jr0SSSSSSSSS\1RdSS)4 S.jr3S/r4SSS0jr5STS1jr6SUS2jr7SVS3jr8SNS4jr9SPS5jr:SNS6jr;SLS7jrSNS:jr?S;r@S<rAS=rBS>rCS?rDSWS@jrESArFSBrGSCrHSDrISPSEjrJSFrKSGrLSHrMSPSIjrNSJrOU=rP$)X GcsJsonApiz=Google Cloud Storage JSON implementation of gsutil Cloud API.Nrc * >[[U] UUUSUUUU U S9 [5Ul[ 5Ul[XUS9 UR5Ul UR5Ul UR(aUURRUR5UlURRUR5UlO"URUlURUl[!UR5(a?[#URR 5 [%URR 5 O*[#UR5 [%UR5 SUl[(R*"SSS5n [,R."5(aV[,R."5R0(a2U (a[3SR5[6U 55e[6UlOU =(d [:UlU (d-[(R*"SS S5n U (a[3S U -5e[(R*"SS S5n U (d5[(R*"SS S5nU(a[3S U-5eSUlOS[(R*"SS 5-Ul[?5Ul UR&UR8-UR<-S-S-UR@-S-Ul!U(a[DRF"SU-S9OSUl$0n[(R*"SSS5nU(a U (aUUS'URKU5 US:nUS:n[LRN"URBUR UUURUR@URHUS9Ul([S5Ul*URTURPl*[W5Ul,URXURPl,[[UR\S9URPl/SURPl0[cUR[d5(aURPRgSS5 gg)aPerforms necessary setup for interacting with Google Cloud Storage. Args: bucket_storage_uri_class: Unused. logger: logging.logger for outputting log messages. status_queue: Queue for relaying status to UI. provider: Unused. This implementation supports only Google Cloud Storage. credentials: Credentials to be used for interacting with Google Cloud Storage. debug: Debug level for the API implementation (0..3). http_headers (dict|None): Arbitrary headers to be included in every request. trace_token: Trace token to pass to the API implementation. perf_trace_token: Performance trace token to use when making API calls. user_project: Project to be billed for this request. gs)providerdebug http_headers trace_tokenperf_trace_token user_project) credentialszhttps:// Credentials gs_json_hostNz"use_client_certificate" is enabled, which sets gsutil to use the host {}. However, a custom host was set using "gs_json_host": {}. Please set "use_client_certificate" to "False" or comment out the "gs_json_host" line in the Boto config.gs_hostzJSON API is selected but gs_json_host is not configured, while gs_host is configured to %s. Please also configure gs_json_host and gs_json_port to match your desired endpoint. gs_json_portgs_portzJSON API is selected but gs_json_port is not configured, while gs_port is configured to %s. Please also configure gs_json_host and gs_json_port to match your desired endpoint.:/zstorage/ztoken:%s)tracegs_json_host_headerHost)urlhttp log_request log_responsermversiondefault_global_paramsadditional_http_headers) status_queueTkey'AIzaSyDnacJHrKma0048b13sh8cgxNUwulubmJM)4superrc__init__r4 certs_filer8r{r _GetNewDownloadHttp download_http_GetNewUploadHttp upload_httprm authorizeauthorized_download_httpauthorized_upload_httpr!r'r( http_basergetrget_context_configuse_client_certificaterformat MTLS_HOST host_base DEFAULT_HOST host_portr5 api_versionurl_baseapitools_messagesStandardQueryParameters global_params_UpdateHeadersapitools_client StorageV1 api_clientr7max_retry_waitr9 num_retriesrGr retry_func(overwrite_transfer_urls_with_client_base isinstancer*AddGlobalParam)selfbucket_storage_uri_classloggerrrgrmrhrirjrkrlrorprqrrrrwr|r} __class__s %platform/gsutil/gslib/gcs_json_api.pyrGcsJsonApi.__init__s8 *d$%=%+%1.2+02>1<6F2>%@#nDO DI ;G113D--/D &*&6&6&@&@   'd#$($4$4$>$>t?O?O$Pd!&*&8&8d#$($4$4d!(())d;;@@AD77<<=d;;<D778DN::m^TBL))++))+BB  vi6 8 8 !dn#3|dn  =)T:g  L    ::m^TBL  =)T:g  L    dnVZZ ~FFdn+-D^^dnn4t~~EK "&"2"23589DM,7+BB;&(<@ ! **]4I4P|(;f%/0A:KQJL%// MM YY!$$  "00 79DO+,D%)%8%8DOO"$D"&"2"2DOO!4&&"(DOO?CDOO<$""O44 oo$$U%NP5c[UR[5(aURR$[UR[5(aURR $[ S5e)z%Returns the service account email id.zBCannot get service account email id for the given credential type.)rrmr)service_account_idrQservice_account_emailrrs rGetServiceAccountIdGcsJsonApi.GetServiceAccountIdYs`$""$<==    0 00 D$$&? @ @    3 33   rcUR(aURUR5 UR(aURUS'[RR [ 5nU(a X!['gg)Ncookie)riupdaterkosenvironrr?r@)rheadersrequest_reasons rrGcsJsonApi._UpdateHeadersds\  nnT&&' //ghZZ^^$:;N+9'(rc[[S9$)N http_class)r8r$rs rrGcsJsonApi._GetNewDownloadHttpqs !7 88rc[[S9$)zCReturns an upload-safe Http object (by disabling httplib2 retries).r)r8r%rs rrGcsJsonApi._GetNewUploadHttpts !2 33rct[UR[5(aUURRnURRnUR X15nUR UR4$[UR[5(aURRU5$[S5e)zReturns the Signed Content.zKAuthentication using a service account is required for signing the content.) rrmr)apirSignBlobkeyId signedBlobrQ sign_blobr)rstring_to_sign iam_cred_apirresponses r_GetSignedContentGcsJsonApi._GetSignedContentxs$""$<==%%))l++>>&&'9Jh ^^X00 00 D$$&? @ @    ' ' 77   rcTUSL=(d [R[U55$)zChecks Returns true if ACL related values are in fields set. Args: fields: list or set of fields. May be in GET ['acl'] or List ['items/acl'] call format. Returns: True if an ACL value is requested in the input fields, False otherwise. N)_ACL_FIELDS_SET intersectionsetrfieldss r_FieldsContainsAclField"GcsJsonApi._FieldsContainsAclFields" T> F_99#f+FFrcU(a=[R[U55(aSU;a[S[-5eggg)zEEnsures customerEncryption field is included if hashes are requested.customerEncryptionzhgsutil client error: customerEncryption must be included when requesting potentially encrypted fields %sN)_ENCRYPTED_HASHES_SETrrrrs r._ValidateEncryptionFieldsForMetadataGetRequest9GcsJsonApi._ValidateEncryptionFieldsForMetadataGetRequestsN (55c&kBBF*  79N O PP +CrcV[R"UUR[S9n[R"5nU(aSR [ U55UlURRRUUS9$![anURXaS9 SnAgSnAff=f)N)bucket userProjectoptionsRequestedPolicyVersion,r bucket_name) r!StorageBucketsGetIamPolicyRequestrlr=rjoinrrrbuckets GetIamPolicy TRANSLATABLE_APITOOLS_EXCEPTIONS_TranslateExceptionAndRaise)rrrgrapitools_requestres rGetBucketIamPolicyGcsJsonApi.GetBucketIamPolicys(JJ%%&8:&==?M  XXc&k2mC __ $ $ 1 12B@M2OO +C &&q&BCs!#B B(B##B(crUb [U5n[R"UUUURS9n[R"5nU(aSR [ U55UlURRRUUS9$![anURUUUUS9 SnAgSnAff=f)Nrobject generationrrrr object_namer) longr!StorageObjectsGetIamPolicyRequestrlrrrrrobjectsrrr) rrrrrgrrrrs rGetObjectIamPolicyGcsJsonApi.GetObjectIamPolicys  #j(JJ%% ' &==?M  XXc&k2m> __ $ $ 1 12B@M2OO +> &&q3>3>2<'>>s,#B B6B11B6c&Ub [U5n[R"UUUUURS9n[R"5nUR R RUUS9$![anURUUUS9 SnAgSnAff=f)N)rrrpolicyrrrr) rr!StorageObjectsSetIamPolicyRequestrlrrr SetIamPolicyrr) rrrrrrg api_requestrrs rSetObjectIamPolicyGcsJsonApi.SetObjectIamPolicys  #j#EE%% 'K &==?M@ __ $ $ 1 1+@M2OO +@ &&q3>3>'@@s#A++ B5B  Bc[R"XURS9n[R"5nURR R UUS9$![anURXaS9 SnAgSnAff=f)N)rrrrr) r!StorageBucketsSetIamPolicyRequestrlrrrrrr)rrrrgrrrs rSetBucketIamPolicyGcsJsonApi.SetBucketIamPolicys(JJt7H7HJ%==?MC __ $ $ 1 12B@M2OO +C &&q&BCs#A A=$A88A=c UR5n [U UUUUUUUUS9 up[R(aU R [ 5n UR U 5upURSU <SU <S35 [XSUU 5$),See CloudApi class for function doc strings.) client_idmethoddurationpathrrregionsigned_headersstring_to_sign_debugz.Key ID used to sign blob for service account "z": ""host) rrHsixPY3encoderArrhrI)rrrrrrrr r rrcanonical_query_stringkey_id raw_signatures rSignUrlGcsJsonApi.SignUrls113-:$ %1 .3*N ww%,,T2n 22>BF LL$f./ }V&>--dd(AA%%'&==?M  XXc&k2m C __ $ $ ( ()97D)FF +C &&q&BCs;#C D)C==Dc[R"US9nURRR U5$![ anUR X1S9 SnAgSnAff=f)r)rrN)r&StorageBucketAccessControlsListRequestrbucketAccessControlsListrr)rrrequestrs rListBucketAccessControls#GcsJsonApi.ListBucketAccessControlssYC!HHg __ 1 1 6 6w ?? +C &&q&BCs8; AAAc[R"XS9nURRR U5$![ anUR UUUS9 SnAgSnAff=f)r)rrrN)r&StorageObjectAccessControlsListRequestrobjectAccessControlsr!rr)rrrr"rs rListObjectAccessControls#GcsJsonApi.ListObjectAccessControls sd@!HH2g __ 1 1 6 6w ?? +@ &&q3>3>'@@8; A AA c [RRRnUR U5(a$[RRR nUn U(d [ 5n/n SHRn [XS5n U (dM[R"U 5(aM5[XS5 U RU 5 MT U R(a,U R[:Xa/U l U RS5 U R(a/U RS[:Xa/U lU RS5 Sn U(a?U RS5 [RR!UR#U55n SnU(a?U RS5 [RR%UR'U55n[R"UU UUR(U UUR*S9n[R,"5nU(aSR/[1U55UlUR4R7U 5 UR4R8R;UUS 9sSSS5 $![<anUR?U5 SnAOSnAff=fSSS5 g!,(df  g=f) r)billing encryption lifecycleloggingmetadataretentionPolicy versioningwebsiteNcorsrrSrR)rbucketResourcerifMetagenerationMatch predefinedAclpredefinedDefaultObjectAclrrr) rStorageBucketsPatchRequestrrrrrgetattrr MessageToDictsetattrappendr4rPrSrOPredefinedAclValueValuesEnum_BucketCannedAclToPredefinedAcl)PredefinedDefaultObjectAclValueValuesEnum_ObjectCannedAclToPredefinedAclmeta_gen_matchrlrrrrr IncludeFieldsrPatchrr)rrr0 canned_aclcanned_def_acl preconditionsrgrrbucket_metadataapitools_include_fieldsmetadata_fieldattrpredefined_aclpredefined_def_aclrrrs r PatchBucketGcsJsonApi.PatchBucket+sZ$>>++EE ##F++%@@--ddO #om! _d ;d h,,T226&&~6  4 48J Jo$$V,((((+/FF)+o&$$%78N$$U+)DD44 @@LN$$%78  6 6 3 322>B D )CC&+::$#5%%'&==?M  XXc&k2m  & &'> ?,&&,,-=;H-J @ ?., ((++,+ @ ? ?s0J>#J  J1J,'J>,J11J>> K cJ[U5n[R"UUUR S9n[R "5nURRRXES9$![a [S5ef=f![anURXaS9 SnAgSnAff=f)Nz6LockRetentionPolicy Metageneration must be an integer.rr6rrr) r ValueErrorrr(StorageBucketsLockRetentionPolicyRequestrlrrrLockRetentionPolicyrr)rrmetagenerationrgrrrs rrTGcsJsonApi.LockRetentionPolicy|sDN+n BB"0)) + &==?MC __ $ $ 8 8 999 D  B DDD ,C &&q&BCs# A&"A?&A<? B" BB"c&[RRRnUR U5(a$[RRR nU(d[R "5nXlUR(aURR5UlUR(aURR5Ul [U5n[R"UUUURS9n[R"5nU(aSR[U55UlUR"R$R'UUS9$![(an UR+XS9 Sn A gSn A ff=f)r)rprojectrrrrrN)rStorageBucketsInsertRequestrrrrBucketnamelocationlower storageClassr,rlrrrrrrInsertrr) rr project_idr0rgrrrrrs r CreateBucketGcsJsonApi.CreateBucketsC$??++EE ##F++%AA--dd "))+hM"++113h&3399;h":.J(DD%% ' &==?M  XXc&k2mC __ $ $ + +,<:G,II +C &&q&BCs #E-- F7F  FcU(d [5n[R"UURURS9nUR R RU5 g![an[URXQS9[5(aQURUS/S9nUR(a/URR(a[SURS9eUR!XQS9 SnAgSnAff=f)rrQrr2rVersionedBucketNotEmptystatusN)rrStorageBucketsDeleteRequestrBrlrrDeleterr_TranslateApitoolsExceptionrrr2enabled status_coder)rrrGrgrrrHs r DeleteBucketGcsJsonApi.DeleteBuckets #om(DD+::%%' C oo$$%56 + C   * *1 * F    ..l^.L  % %/*D*D*L*L!";)*8 8 &&q&B Cs%A## C9-BC44C9c## [RRRnUR U5(a$[RRR n[ U5n[R"U[UURS9n[R"5nU(a6SU;aURS5 SR[U55Ul URRR!UUS9nUR'W5Hn U v M UR((a[R"UUR([UURS9nURRR!UUS9nUR'U5Hn U v M UR((aMgg!["anUR%U5 SnANSnAff=f!["anUR%U5 SnANySnAff=f7f)r)rX maxResultsrr nextPageTokenrrN)rX pageTokenrprr)rStorageBucketsListRequestrrrrr,NUM_BUCKETS_PER_LIST_PAGErlraddrrrrrr!rr _YieldBucketsrq) rr`rgrrrr bucket_listrrs r ListBucketsGcsJsonApi.ListBucketss#==++EE ##F++%??--dd":.J(BB,%% ' &==?M  & ?# XXc&k2m*OO++001A?L1Nk $$[1 l2  # #*DD--.'' ) ,oo--223CAN3P &&{3& 4  # # # ,* &&q))* ., ((++,saC!H $$F;AH &$G# -H 9H ; G GH G  H # H-H>H HH c#^# UR(aURHnUv M gg7f)z0Yields buckets from a list returned by apitools.N)items)rrwrs rrvGcsJsonApi._YieldBucketss(%%& &s+-c ## [RRRnUR U5(a$[RRR n[R"UUUUU[ URS9n[R"5n U(a[U5nSU;aURS5 [US9R[5(aDURS5 URS5 URS5 URS5 SRU5U lS n S n U (aS n [R"UUUUUU [ URS 9nUR R"R%UU S 9n W R*(aS n U R*n UR-U 5HnnUR.[0R2R4:Xa?UR7UUR8[U5S9nU[::XaM[U(aXlOUv Mp U (aMg g ![&an UR)XS9 S n A NS n A ff=f7f)r)rprefix delimiterversionsrrprrq list_fieldszitems/customerEncryptionzitems/kmsKeyNamezitems/generationz items/namerTNF)rr~rrrrrrprrrrd)rStorageObjectsListRequestrrrrr>rlrrrur;rrrrrrr!rrrq_YieldObjectsAndPrefixesdatatyperCsObjectOrPrefixTypeOBJECT_DecryptHashesIfPossibledata_SKIP_LISTING_OBJECT)rrr~r all_versionsrgrrrr list_pagenext_page_token object_listrobject_or_prefixdecrypted_metadatas r ListObjectsGcsJsonApi.ListObjectss6$==++EE ##F++%??--dd(BB,%%'&==?M 6{f  & ?#  *l+@A B  -. %& %& <  XXf-mIO i*DD#.'')Eoo--223CAN3P  " " %33";;KH   $ $(E(E(L(L L#<<##$V, = .  #7 7 !$6 ! I+ ).E (((DEs7E6I09$I B)I0I0 I-I(#I0(I--I0c [US9nURU5(dURUUS9 gSnURUUS9(a7[R "UR UURURUS9nOURUUS9(aURRn[R(a&[U[5(dUR!S5n[#U[$5nU(a@[R "UR UURURU['U5S9nUcgU"5$![(a [*s$f=f)aAttempts to decrypt object metadata. Helps fetch encrypted object metadata fields (if requested) for API method calls that requested them but did not receive them; this occurs for ListObjects(), along with GetObjectMetadata() calls for which the object is CSEK-encrypted but no decryption information was supplied. This method issues a StorageObjectsGetRequest (if object hash fields were requested but not retrieved), formatted appropriately depending on the encryption method. Args: bucket_name: String of bucket containing the object. object_metadata: apitools Object describing the object. Must include name, generation, and customerEncryption fields. fields: ListObjects-format fields to return. Returns: - apitools_messages.Object with decrypted hash fields if decryption was performed. - None if the object was not encrypted, or CSEK-encrypted but we could not find a matching decryption key. - gcs_json_api._SKIP_LISTING_OBJECT if the object no longer exists. rrdNrrasciirrdecryption_tuple)r;_ObjectIsEncrypted2_RaiseIfNoDesiredHashesPresentForUnencryptedObject _ObjectKMSEncryptedAndNeedHashes functoolspartial_GetObjectMetadataHelperr[r!_ObjectCSEKEncryptedAndNeedHashesr keySha256r rrbytesrrErrDrr)rrobject_metadatar get_fieldsget_metadata_func key_sha256decryption_keys rr#GcsJsonApi._DecryptHashesIfPossibleLs\2!V4J  " "? 3 3 ==oEO>Q  ,,_4>-@$++  ' '    $//   / /7A 0 C #55??j *e,,!((1*3JGn %--  ) )   &114^D F  "   ""!"sEEEc#b# UR(aDURH4n[R"U[RR5v M6 UR (aEUR H4n[R"U[RR 5v M6 gg7fN)r{rCsObjectOrPrefixrrprefixesPREFIX)rr cloud_objr~s rr#GcsJsonApi._YieldObjectsAndPrefixess"(()'' (0(E(E(L(LN N)((&''(0(E(E(L(LN N)sB-B/c## U(aIURRR5nURRRU5 Sv U(aWURlgg7f)z@Wrapped code makes apitools requests with the specified headers.N)rrcopyr)rr old_headerss r_ApitoolsRequestHeaders"GcsJsonApi._ApitoolsRequestHeaderssQOO;;@@Bk oo--44W= 0;doo-sA/A1c0nU(aTUR[R:Xa6URUS'URUS'[ UR5US'U$)z:Returns headers dict matching crypto_tuple, or empty dict.x-goog-encryption-algorithmx-goog-encryption-keyx-goog-encryption-key-sha256) crypto_typerCCSEK crypto_alg crypto_keyrB)r crypto_tuplers r_EncryptionHeadersFromTuple&GcsJsonApi._EncryptionHeadersFromTuples]G 00M4F4FF/;/F/Fg+,)5)@)@g%& -l.E.E F,- NrcR0nU(aKUR[R:Xa-URUS'URUS'UR US'U(aKUR[R:Xa-URUS'URUS'UR US'U$)zAReturns headers dict matching the provided tuples, or empty dict.z'x-goog-copy-source-encryption-algorithmz!x-goog-copy-source-encryption-keyz(x-goog-copy-source-encryption-key-sha256rrr)rrCrrrcrypto_key_sha256)rrencryption_tuplers r_RewriteCryptoHeadersFromTuples*GcsJsonApi._RewriteCryptoHeadersFromTuplessG,88M) If present, return only these Object metadata fields, for example: ['acl', 'updated']. decryption_tuple: (gslib.utils.encryption_helper.CryptoKeyWrapper) The CryptoKeyWrapper for the desired decryption key. Raises: ArgumentException for errors during input validation. ServiceException for errors interacting with cloud storage providers. Returns: (apitools_message.Object) The retrieved object metadata. rrdrrNr) '_CreateApitoolsObjectMetadataGetRequest&_GetApitoolsObjectMetadataGlobalParamsrrrrrrr) rrrrrrrrrs rr#GcsJsonApi._GetObjectMetadataHelpers0CCZDH??v?NM>   ) )  , ,:J , KM((,,-=;H-JMM &&**+;9F+H H MM ,> &&q3>3>2<'>>s;%B)$B* B)4#B) B&"B)&B)) C3C  CcDURUS9 [RRRnUR U5(a$[RRR nU(a [U5n[R"UUUUURS9$)Nrd)rrrrr) rrStorageObjectsGetRequestrrrrrrl)rrrrrrs rr2GcsJsonApi._CreateApitoolsObjectMetadataGetRequests  77v7F#<<++EE ##F++%>>--dd #j  5 5%%  ''rc|[R"5nU(aSR[U55UlU$)Nr)rrrrr)rrrs rr1GcsJsonApi._GetApitoolsObjectMetadataGlobalParams s.%==?M  XXc&k2m rc xURUUUUS9nURUUS9(dU$URRn[R (a&[ U[5(dURS5n[U[5nU(d%[SU<SUR<SU<SU<35e[R (a*[ U[5(dUR[5nURUUUU[U5S9$![an UR!U UUUS 9 S n A g S n A ff=f) rrrdrz(Missing decryption key with SHA256 hash z#. No decryption key matches object z://rurrN)rrrrr rrrrrErrrgrArDrr) rrrrrgrrrrrs rGetObjectMetadataGcsJsonApi.GetObjectMetadatas7#>55k6AAK=C6Eo 3 3O;A4C #55??j *e,,!((1*3JGn ! [ BC C .%00)006.  * *  2>B +DD ,> &&q3>3>2<'>>s(DC'D D9D44D9cR[UR=(d UR5$r)boolr kmsKeyName)rrs rrGcsJsonApi._ObjectIsEncrypted;s% 22+** ,,rcUcgSU;=(a UR(+nSU;=(a UR(+nU(a2UR(d U(a[SUR-5eggg)zBRaise an exception if none of the desired hash fields are present.Nr`r_zNService did not provide requested hashes in metadata for unencrypted object %s)r`r_componentCountrr[)rrrmd5_requested_but_missingcrc32c_requested_but_missings rr=GcsJsonApi._RaiseIfNoDesiredHashesPresentForUnencryptedObject?s~ !*f!4"=%4%<%(>$>! "/*H*H$  "$3$8$8 9 :: %+I!rcUbU5(dgUR=(a) UR(+=(a UR(+$)aChecks if an object is KMS-encrypted and lacking requested hash fields. Args: object_metadata: (apitools_messages.Object) Object metadata returned from an API call; may or may not contain hash-related metadata fields. fields: (list) Requested object metadata fields. Returns: True if a GetObjectMetadata request should be issued on the KMS-encrypted object in order to retrieve encrypted hash fields, False otherwise. F)rrrr_r`rrrs rr+GcsJsonApi._ObjectKMSEncryptedAndNeedHashesRsM"7"D"DV"L"L   & & (/E/E+E ('' ')rcUb[RU5(dgUR=(a) UR(+=(a UR(+$)aChecks if an object is CSEK-encrypted and lacking requested hash fields. Args: object_metadata: (apitools_messages.Object) Object metadata returned from an API call; may or may not contain hash-related metadata fields. fields: (list) Requested object metadata fields. Returns: True if a GetObjectMetadata request including a decryption key should be issued on the CSEK-encrypted object in order to retrieve encrypted hash fields, False otherwise. F)rrrr_r`rs rr,GcsJsonApi._ObjectCSEKEncryptedAndNeedHashesesP~2??GG   . . G&& & G/>/F/F+FHrFcU(a [U5nUnU (aU S-nO4U (a-[R"[R"U 55SnU (aUc [ S5eU "X5 [ 5nU Ul[UUU U S9nUR5nX0Rl SU0URl U (aUR(aZ[R"[R"U 55nUS==SUR-- ss'[R"U5n [R R#UU UR$R&UR(UR$S 9nO*[R R+US UUR(S 9nUR,Ul[0R2"UUUUR4S 9n[7S UR8S9UlU[<R>R@:XaURCUUUUUUUUU U U US9 $UREUUUUUUUU U U US9 $![FanURIUUUUS9 SnAgSnAff=f)r total_sizeNz`Download size is required when callbacks are requested for a download, but no size was provided.)rprogress_callback digestershttpsrzz&trace=token%%3A%s)rclientF) auto_transferrrrTis_data_transferr)compressed_encodingr start_byteend_byteserialization_datarrrrrrrr)%rjsonloadsr  ensure_strrr"bytes_transferredr#GetConnectionClassrstream connectionsrjdumpsapitools_transferDownloadFromDatarr{r FromStreamr bytes_httprrrlrGrrrDownloadStrategy RESUMABLE_PerformResumableDownload_PerformDownloadrr)rrrdownload_streamrgr object_sizerdownload_strategyrrrrrrouter_total_sizebytes_downloaded_containercallback_class_factorydownload_http_classserialization_dictapitools_downloadrrs rGetObjectMediaGcsJsonApi.GetObjectMediays$ #j #!A  ..+ ,..:<  !!,- - 5!:!<3=0C"#+  1CCE!0&-/B%CD"   !ZZ7I(JK5!%9D",44??  && @( $(#@#@ (AA%% '$7D,=,=$? %> h77AA A--      & 3!!1-. / /$$[%0%4%5%60:9L0:.68J6F% H H" ,> &&q3>3>2<'>>s57I-I I,I''I,c Sn U nXR::aURUUUUUUUU U U U S9 $g![Ga nURU5 UR 5n XlX:aU nSn U S- n XR:a#[ SUR[U54-5e[R"[XRS95 URR[R5(a:URR!SU [U5["R$"55 [&R("UR*5 SnAOSnAff=fXR::aGM[g)Nrrr5Transfer failed after %d retries. Final exception: %smax_waitz=Retrying download from byte %s after exception: %s. Trace: %s)rrHTTP_TRANSFER_EXCEPTIONS$_ValidateHttpAccessTokenRefreshErrortellrrrJtimesleepr rr isEnabledForr/DEBUGrh traceback format_excapitools_http_wrapperRebuildHttpConnectionsr)rrrrrrrrrrrrrretrieslast_progress_byters rr$GcsJsonApi._PerformResumableDownloadssG# %% %2*$$[%0%4%5%60:9L0:.68J6F% H H &&&* 11!4$))+ 7A4  *) '1  %% %&+E!._NoOpCallbackTs r user-agent)rF)additional_headersstartend use_chunks)callbackfinish_callbackr$r') rrrrr user_agentrFrrrGetRange StreamMediar )rrrrrrrrrrrrrr!r$s rrGcsJsonApi._PerformDownload=s' @ ##$4-> $ @  doo00""46IK *+ (()9:<X)  4F'1%-,1!3  % %% ##]4A7I/4$6  % %%S.@ ((5@5@4> ) @@s$C C/C**C/c [RRRn UR U5(a$[RRR n U(d [ 5nU(a [U5nSn /n U(a?U RS5 [RRURU55n URS:XaU RS5 URS:XaU RS5 URS:XaU RS5 URS:XaU RS5 [R"UUUUU URUR U UR"S9 n [R$"5nU(aS R'[)U55UlUR,R/U 5 UR,R0R3U US 9sSSS5 $!,(df  g=f![4anUR7UUUUS 9 SnAgSnAff=f) rNrRrs cacheControlcontentDispositioncontentEncodingcontentLanguage) rrobjectResourcerrifGenerationMatchr6r7rrrr)rStorageObjectsPatchRequestrrrrrrr=r>rAr/r0r1r2 gen_matchrBrlrrrrrrCrrDrr)rrrr0rErrGrgrrlrrLrIrrrs rPatchObjectMetadataGcsJsonApi.PatchObjectMetadataxs$>>++EE ##F++%@@--dd #om #jN $$U+)DD44 @@LN "$$^4""b($$%9:2%$$%672%$$%67(CC'11+::$%% '&==?M  XXc&k2m> ?? ( ()@ A&&,,-=;H-J B A A ,> &&q3>3>2<'>>s6H !$H H  HH H I*IIc[U5 SnU(a.[RRUR U55n[ 5nU (aU(a Un U "SU5 [ UU U URURS9nUR5nUUS.URl SURR0nURU5 SnSnSnU (dURnU(d[ nU(d [#5n[R"UR$UUR&UR(UUR*S9n[R,"5nU(aSR/[1U55UlUR5US9nU [6R8:Xa{[6R:"UUUS UR<US 9nU UlUR@Ul!UREU5 URRFRIUUUS 9sSSS5 $SURR0nURKU5 URU5 URMXR@UUXUUUU UX5 $!,(df  g=f![NaPn[QURRUR$5nURUUUR$URVUS 9 SnAgSnAff=f) zUpload implementation. Cloud API arguments, plus two more. Additional args: apitools_strategy: SIMPLE_UPLOAD or RESUMABLE_UPLOAD. total_size: Total size of the upload; None if it is unknown (streaming). Returns: Uploaded object metadata. Nr)rrrrh)r{rr#)rrr4r6r7rrrT)rrr gzip_encodeduploadrrrnot_found_exception),r<rStorageObjectsInsertRequestr>rAr"r&rrhrrrrr*r contentTyperNrrr6rBrlrrrrrr SIMPLE_UPLOADUploadrstrategyrrrrr_r_PerformResumableUploadrrLrgrr[)r upload_streamrrEsizerGrrgrrtracker_callbackrapitools_strategyrr:rLbytes_uploaded_containerrupload_http_classr$ content_typerrencryption_headersapitools_uploadrr>s r _UploadObjectGcsJsonApi._UploadObjects4o.N)EE44 @@LN 9:Tj4 A +{{jj /AAC!"$D  doo00 *+?Plm &22 -,'/-,HH"))"+55"/">">()) +*AAC !$#f+!6- ;;'<) /== =+22=3?>BAE?C?O?O@L N $5 %)%@%@"  ) )*< =((//0@7F>K0M> = $//44  !!"45 ./++ 66 d 3C 35E  1 A A> =$ ,PA --//1 &&q3B3I3I3B3G3G;N'PPs?D"J7%J J&AJ JJJ K/AK**K/c U(a`[RRUUURRUR U URS9n[ 5UlX.lOw[R"UUU[ 5SUR U S9nXnl X.lURU 5 URRRUUUS9 SSS5 [SURS9UlSnUR U lU (a&U "[$R&"UR(55 SnUR nUUR ::aU (d(U(a![+5(dUR-UUU S 9nOUR/UUU S 9nURRR1URRR3S 5U5nUc$U (aU "UR4UR45 U$g!,(df  GN;=f![6GanUR9U5 [:R<"UR5 UUR ::aUR?5 UR nUU lO![6anUR9U5 [:R<"UR5 US - nUUR :a[AS UR U4-5e[BRD"[GUURHS 95 SnAOSnAff=fUUR ::aMWU:aUnSnO`US - nUUR :a#[AS UR [KU54-5e[BRD"[GUURHS 95 URLRO[PRR5(a:URLRUSU[KU5[VRX"55 SnAOSnAff=fUUR ::aGMg![Za nUR]U5nU(aUeeSnAff=f)N)rr:rF)r chunksizerrr:r;Trcgrr)runused_upload_objects rr!9GcsJsonApi._PerformResumableUpload.._NoOpCallback]s rr)r(r)r$r_rr r z;Retrying upload from byte %s after exception: %s. Trace: %s)/rrBrrr{rr6rQrrCrrr_rGrrprogressrrrrr:r,StreamInChunksProcessHttpResponseGetMethodConfigrr rrrRefreshResumableUploadStaterrrr rrJrrr/rrhrrr*_TranslateApitoolsResumableUploadException)rrErrKrFrrHrrrIrG addl_headersrr:rMr!rr http_responseprocessed_responserre2 resumable_exs rrD"GcsJsonApi._PerformResumableUpload6s ~ +22;;   OO ((%?? <$%>$?!%;",22  /1((%'$5 %;"  ) ), 7 // ! ! ( ()90?7D ) F8 $7d.?.?$Ao  4C3K3K0 O$F$FGHg*33 t'' 'I ($/L/N/N,77& -#/81M,::& -#/;1M $66JJoo%%55h? P  \/ o88-88 :# #E (-8 7r(' (  3 3A 6  6 6(( *4+++ P99;*33j;E&8+ P77;#::!,,.lg4+++.K%%r*+,,jj'$:M:MNPP P4+++&, ,!+ G qLG))),I##%@%CDEFF JJ%g8K8KL N [[ % %gmm 4 4 KK  M7:$$& (I' (G t'' 'V ,DDQGl  sB0P42&H BP4B1H HP4 P)AP+#JP L+BL&!P&L++PCPP4PP44 Q>QQc NURUUUUUUUU [RU S9 $)r)rErFrGrrrrHr:)rNrrA) rrErrErFrGrrrgrr:s r UploadObjectGcsJsonApi.UploadObjects?   m-)3#',90A/?%+0A0O0O+7  9 9rc NURUUUUUUU[RSU S9 $)rN)rErGrrrrHrr:rNrRESUMABLE_UPLOAD) rrErrErGrrrgrr:s rUploadObjectStreaming GcsJsonApi.UploadObjectStreamings@   #+)+<<!  # #rc RURUUUUU UUUUU [RU S9 $)r) rErGrrFrrGrrrHr:re) rrErrErGrFrrGrrrgrr:s rUploadObjectResumable GcsJsonApi.UploadObjectResumablesF   # -)+)+<<!  # #rc [U5 Sn U(a.[RRUR U55n U(a [ U5nU(d [ 5n[RRRn URU 5(a$[RRRn [R"5nU (aI[/SQ5nU HnURSU-5 M SR[U55UlSnU (a*U R ["R$:Xa U R&nSnU(aZUR ["R$:Xa UR&nO/UR ["R(:XaUR*Ul[/UR0UR2UR0UR2S5n[5UUU UUR6UR8U UUUURS9 n[;UU5nUR=XS9nSn[ S5nUR?U5 [R"UR0UR2UR0UR,UR2U UUUR6UR8U UUUR@S 9nURBRDRGUUS 9nSSS5 [ WRH5nU(a&U(d[K[ URL5U5nU(aUROUU- 5 URP(aO/U(d#URRn[UUUURR5 UnGMM[WU5 URX$!,(df  N=f![Zapn[]UR^UR0UR^UR0UR2US 9nURaUUR0UR2US 9 SnAgSnAff=f) rN)done objectSize rewriteTokentotalBytesRewrittenz resource/rJSON)src_generationr6rBrEmax_bytes_per_callsrc_dec_key_sha256dst_enc_key_sha256r)rrr) sourceBucket sourceObjectdestinationBucketdestinationKmsKeyNamedestinationObjectrrsourceGenerationr4r6destinationPredefinedAclromaxBytesRewrittenPerCallrr) src_providersrc_bucket_namesrc_object_namerrr=)1r<rStorageObjectsRewriteRequest'DestinationPredefinedAclValueValuesEnumrArrrrrrrrrurrrrCrrCMEKrrr0rr[r1r6rBr2rrrlrrRewriterpr+rnProgressrmror3r/resourcerrLrgr)rsrc_obj_metadatadst_obj_metadatarrrErGrrsrrrgrrLrr new_fieldsfielddec_key_sha256enc_key_sha256tracker_file_namerewrite_params_hashresume_rewrite_tokencrypto_headersprogress_cb_with_timeoutlast_bytes_writtenrrewrite_response bytes_writtenrr>s r CopyObjectGcsJsonApi.CopyObject s./N)FF?? @@LNN+n #om#@@++EE ##F++%BB--dd%==?M  j %{U*+ XXc*o6mN,88M!>  !"35H"2"?"? A*G J)*  & &&K: 9L , PA --  ! !}}*11*//' ) &&q3C3J3J3C3H3H;N'P Ps3O"BN58B __ $ $ + +,< == +> &&q3>3>2<'>>s$B B' B""B'c [U5 URnSUlURnSUlUR(d [UlU(d [ 5n[ R"5n U(aSR[U55U l [ R"XS9n URUS9n Sn U(a*UR[R:Xa UR n UR#U 5 [ R$"U UUUR&UR(UR*U S9n UR,R.R1U U S9sSSS5 $![2aUn[5U[6R85(aUR:S:Xa [=S5eUR?U5 SnAOSnAff=fSSS5 g!,(df  g=f) rNr) sourceObjects destinationr)composeRequestrxrzr4r6rrrz)One of the source objects does not exist.) r<r[rr@rNrrrrrrComposeRequestrrrCrrrStorageObjectsComposeRequestr6rBrlrrComposerrapitools_exceptions HttpErrorrlrr)rsrc_objs_metadatarrGrrgr dst_obj_namedst_bucket_namersrc_objs_compose_requestrLrrrs r ComposeObjectGcsJsonApi.ComposeObjects./#((L &--O"  ' '%9" #om%==?M  XXc&k2m0??' G99%:'J  % %);); ;%00 % %&8 9*GG1+()33 - < <''! .&&../?=J/L : 9.. q-77 8 8 MMS !"MN N  * *1 - - . .% : 9 9s19G;#E(( G2A G=GGG G"c[RRRn[R"UUUSS9n[R"UUUUR S9n [R "5n U(aSR[U55U l URRRU U S9$![an URXS9 Sn A gSn A ff=f)rWEB_HOOK)addressidtokentype)rchannelrrrrrN)rStorageObjectsWatchAllRequestrrChannelrlrrrrrrWatchAllrr) rrr channel_idrrgrrrrrrs r WatchBucketGcsJsonApi.WatchBuckets$AA++DD ''+5.3-79G )FF%% ' &==?M  XXc&k2mC __ $ $ - -.>)rrr/rrhrrrj)rrrrrr>translated_exceptions rr&GcsJsonApi._TranslateExceptionAndRaisesq& {{ .. kk8!,,.0;; / <1    rc$[U[R5(aa[USS5(aN[R "[ R"UR55nSU;aSUS;aUSS$gggg![a gf=f)Ncontenterrormessage) rrrr:rrr rr Exception)r http_errorjson_objs r_GetMessageFromHttpError#GcsJsonApi._GetMessageFromHttpErrors*1;;<< Y - - ZZz/A/A BC(  Y(72C%CG$Y/ /&D  .=    sA B BBcURSnURS5nUS:aX#SRS5SnSU-$g![a gf=f)Nzwww-authenticatezscope="rr rzAcceptable scopes: %s)rfindsplitr)rr www_authenticate scope_idxscopess r!_GetAcceptableScopesFromHttpError,GcsJsonApi._GetAcceptableScopesFromHttpErrorsp #,,-?@#'' 2i a!*-33C8;&//     sAA AAc[U[R5(aURU5nURS:a[ U=(d SURS9$URS:Xa[ U=(d SURS9$URS:Xa[ U=(d SURS9$URS:Xa[ U=(d SURS9$URS :a[U=(d SURS9$[U[R5(a[S [U5-5$[U[R5(aYS [U5;dS [U5;a[[U55$S [U5;a[S[U5-5$gg)Nrz Server ErrorrfrzToo Many Requestsi Bad Requestrza%s; if this issue persists, try deleting the tracker files present under ~/.gsutil/tracker-files/zAborting transferzNot enough bytes in streamzadditional bytes left in streamz?%s; this can happen if a file changes size while being uploaded) rrrr"rlrrrStreamExhaustedstr TransferError)rrrs rrZ5GcsJsonApi._TranslateApitoolsResumableUploadExceptions!(2233--a0g # '(A>/0}}> > ==C '(F3F/0}}> > ==C 01IM89 G G ==C 01IM89 G G ==C ,W-E 45MMC C!(8899 * ,.1!f 566!(6677 Q ' &#a& 0,SV44 ,A 6, M F   7 8rcf[U[R5(Ga[URU5nURS:Xa[ U=(d SURS9$URS:XaeS[ U5;a[U=(d SURS9$S[ U5;a([[URURU5S9$GOURS :XGafS [ U5;a[U=(d S URS9$S [ U5;a[U=(d S URS9$S[ U5;a[SU-URS9$S[ U5;a[SURS9$S[ U5;a[SURS9$S[ U5;a[SURS9$S[ U5;a([[URURU5S9$S[ U5;a[XaRS9$[U=(d [ U5URS9$URS:XaU(a[USUR5 U$U(aIU(a![URURUUUS9$[URURU5$[!U=(d UR"URS9$URS:XaDU(a=S[ U5;a[SU-URS9$[%SU-URS9$URS:Xa['XaRS9$[%XaRS9$[U[R(5(a[%S[ U5-5$g) aTranslates apitools exceptions into their gsutil Cloud Api equivalents. Args: e: Any exception in TRANSLATABLE_APITOOLS_EXCEPTIONS. bucket_name: Optional bucket name in request that caused the exception. object_name: Optional object name in request that caused the exception. generation: Optional generation in request that caused the exception. not_found_exception: Optional exception to raise in the not-found case. Returns: ServiceException for translatable exceptions, None otherwise. r.r-rfizLogin RequiredzAccess denied: login required.insufficient_scope)rgbodyiz7The account for the specified project has been disabledzAccount disabled.z,Daily Limit for Unauthenticated Use Exceededz8Access denied: quota exceeded. Is your project ID valid?z-The bucket you tried to delete was not empty.zBucketNotEmpty (%s)zFThe bucket you tried to create requires domain ownership verification.zThe bucket you tried to create requires domain ownership verification. Please see https://cloud.google.com/storage/docs/naming?hl=en#verification for more details.zUser Rate Limit Exceededz5Rate limit exceeded. Please retry this request later.zAccess Not ConfiguredzAccess Not Configured. Please go to the Google Cloud Platform Console (https://cloud.google.com/console#/project) for your project, select APIs and Auth and enable the Google Cloud Storage JSON API.z,does not have permission to publish messagesrrg)riz,The bucket you tried to delete is not empty.zA Cloud Storage bucket named '%s' already exists. Try another name. Bucket names must be globally unique across all Google Cloud projects, including those outside of your organization.iz.Transfer invalid (possible encoding error: %s)N)rrrr"rlrr0r"_INSUFFICIENT_OAUTH2_SCOPE_MESSAGEr*rrr<rMrgrKrrrrTransferInvalidError)rrrrrr>rs rrj&GcsJsonApi._TranslateApitoolsException s&!(2233--a0g # #7#;m*+--9 9 ==C  s1v %&w(H'G./mm= ="SV +'0]]99!<> >, ==C  DA N&w'E2E./mm= = ;s1v E&w(C(C./mm= ==A F"#8;#F*+--9 9!$Q(&6]] $ $ (3q6 1&]]$ $%A .&/]] $ $ "SV +'0]]99!<> >:%)"& @.C/0C0C @"!% $O,bC*#   #CJC0*X # L\F"P N<<8<7;0+/&*04 *>^:>59 '*$(!%# *>X, %):&)&H0# $!%).'/'@'@'I'I !"'+(,#&*~>N,049+,)-3715B*T#'+0"# $*.(,9&~&*%)(,#'!%'+@>J $"&%)!'+%)&*&7&E&E !&zPxDR#!%%)$(  %94(,*..2-1%)#').#:(,*.!%/3-1.2-1%)#').#>!% ##'$("&"&BPN"&" >>#'%)! 5.v C@*C*,01526 *> * ****&*B * I I /3.2-16:  B  (B/3.2-16: r&r&rrc)r= __future__rrrr contextlibrr six.movesrrr/rsocketsslrrr apitools.base.pyr r rr rr rapitools.base.py.utilr botorhttplib2rgslibrgslib.cloud_apirrrrrrrrrrrrrrrgslib.exceptionrgslib.gcs_json_credentialsr r!gslib.gcs_json_mediar"r#r$r%r&r'r(gslib.impersonation_credentialsr)gslib.no_op_credentialsr*gslib.progress_callbackr+gslib.project_idr,"gslib.third_party.storage_apitoolsr-rr.rgslib.tracker_filer/r0r1r2r3gslib.utils.boto_utilr4r5r6r7r8r9r:gslib.utils.cloud_api_helperr;r<gslib.utils.constantsr=r>r?r@rAgslib.utils.encryption_helperrBrCrDrEgslib.utils.metadata_utilrFgslib.utils.retry_utilrGgslib.utils.signurl_helperrHrIgslib.utils.text_utilrJgslib.utils.translation_helperrKrLrMrNrOrPoauth2client.service_accountrQrintrrCustomAttributesValuerAdditionalPropertyrrtrr/r1r7rTransferRetryErrorBadStatusCodeErrorRetryAfterError RequestError BadStatusLineIncompleteReadResponseNotReadyServerNotFoundErrorrrrgaierrortimeoutSSLErrorrRr rrr rr+FULL_PREDEFINED_ACL_XML_TO_JSON_TRANSLATIONrrrr6rrrcrrrrnsE&%'%!   %>B:7 1-/$/--1)<694=,,C7:G72E86D3?.SW08456.6;2,/?8B4;8;&M7AFC6A=HPH?B=B77 $!-- $0$F$F!%88 !$7$A$A$7$G$G$7$E$E$7$L$L$N ****''$$     33 LL OO NNLL& -'* 2. -*!9'2./].a.a/++2224Xy12;#( ) G#&G#&r