dZddlmZddlmZddlmZddlmZddlmZddlZddl m Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlZddl Z ddl!m"Z"ddl#m$Z$ddl#m%Z%ddl#m&Z&ddl#m'Z'ddl#m(Z(ddl#m)Z)ddl#m*Z*ddl#m+Z+ddl#m,Z,ddl#m-Z-ddl#m.Z.ddl#m/Z/ddl#m0Z0ddl#m1Z1ddl#m2Z2ddl3m4Z4dd l5m6Z6dd!l5m7Z7dd"l8m9Z9dd#l8m:Z:dd$l8m;Z;dd%l8mZ>dd(l8m?Z?dd)l@mAZAdd*lBmCZCdd+lDmEZEdd,lFmGZGdd-lHmIZJdd.lHmKZLdd/lMmNZNdd0lMmOZOdd1lMmPZPdd2lMmQZQdd3lMmRZRdd4lSmTZTdd5lSmUZUdd6lSmVZVdd7lSmWZWdd8lSmXZXdd9lSmYZYdd:lSmZZZdd;l[m\Z\ddl^m`Z`dd?l^maZadd@l^mbZbddAl^mcZcddBldmeZeddCldmfZfddDldmgZgddEldmhZhddFlimjZjddGlkmlZlddHlmmnZnmoZoddIlpmqZqddJlrmsZsddKlrmtZtddLlrmuZuddMlrmvZvddNlrmwZwddOlrmxZxddPlymzZzejre|Z}eLjZ~e~jZejZdQZejej ej ejfZejejejeje je je jej e j"j$ej&ej(ej*ej,efZegdRZddSdTdUdVdWdXZddSdYdZdTdUdVd[Zej;Zej?eed\d]gZd^Zd_Zd`ZdaZGdbdce'Zy)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 ZeZdZdZ dIfd ZdZdZdZdZd Z dJd Z dJd Z dKd Z dLd Z dKdZdJdZdZdKdZdZdZ dMdZdJdZ dNdZdKdZdLdZdZ dMdZdJdZdZedZdJdZ dKdZ dLd Z! dKd!Z"dJd"Z# dLd#Z$d$Z% dJd%Z&dJd&Z'dJd'Z(dddd(e)jTjVddddddf d)Z, dOd*Z- dOd+Z. dPd,Z/ddddddddde0jbdd(f d-Z2d.Z3 dQd/Z4 dRd0Z5 dSd1Z6 dTd2Z7 dLd3Z8 dNd4Z9 dLd5Z:dJd6Z;dKd7Zd:Z?d;Z@d<ZAd=ZBd>ZC dUd?ZDd@ZEdAZFdBZGdCZH dNdDZIdEZJdFZKdGZL dNdHZMxZNS)V GcsJsonApiz=Google Cloud Storage JSON implementation of gsutil Cloud API.Nrc tt| |||d|||| |  t|_t |_t||||j|_ |j|_ |jrU|jj|j|_|jj|j|_n"|j|_|j|_t!|jr?t#|jj t%|jj n*t#|jt%|jd|_t)j*ddd} t-j.rKt-j.j0r-| rt3dj5t6| t6|_n| xst:|_| s't)j*dd d} | rt3d | zt)j*dd d} | s/t)j*dd d}|rt3d |zd|_ndt)j*dd z|_t?|_ |j&|j8z|j<zdzdz|j@zdz|_!|rtEjFd|znd|_$i}t)j*ddd}|r| r||d<|jK||dk\}|dk\}tMjN|jB|j |||j|j@|jH||_(tS|_*|jT|jP_*tW|_,|jX|jP_,t[|j\|jP_/d|jP_0tc|jtdr|jPjgddyy)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_responserlversiondefault_global_paramsadditional_http_headers) status_queueTkey'AIzaSyDnacJHrKma0048b13sh8cgxNUwulubmJM)4superrc__init__r4 certs_filer8rzr _GetNewDownloadHttp download_http_GetNewUploadHttp upload_httprl 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_classloggerrrfrlrgrhrirjrkrnrorprqrrvr{r| __class__s %platform/gsutil/gslib/gcs_json_api.pyrzGcsJsonApi.__init__s8 *d$%=%+%1.2+02>1<6F2>%@#nDO DI v;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<$""O4 oo$$U%NP5ct|jtr|jjSt|jtr|jj St d)z%Returns the service account email id.zBCannot get service account email id for the given credential type.)rrlr)service_account_idrQservice_account_emailrrs rGetServiceAccountIdzGcsJsonApi.GetServiceAccountIdYsZ$""$<=    0 00 D$$&? @    3 33   rc|jr|j|j|jr|j|d<tjj t }|r ||t<yy)Ncookie)rhupdaterjosenvironrr?r@)rheadersrequest_reasons rrzGcsJsonApi._UpdateHeadersds^  nnT&&' //ghZZ^^$:;N+9g'(rc"ttS)N http_class)r8r$rs rrzGcsJsonApi._GetNewDownloadHttpqs !7 88rc"ttS)zCReturns an upload-safe Http object (by disabling httplib2 retries).r)r8r%rs rrzGcsJsonApi._GetNewUploadHttpts !2 33rcbt|jtrV|jj}|jj}|j ||}|j |jfSt|jtr|jj|Std)zReturns the Signed Content.zKAuthentication using a service account is required for signing the content.) rrlr)apirSignBlobkeyId signedBlobrQ sign_blobr)rstring_to_sign iam_cred_apirresponses r_GetSignedContentzGcsJsonApi._GetSignedContentxs$""$<=%%))l++>>&&'9>Jh ^^X00 00 D$$&? @    ' ' 77   rcJ|duxstjt|S)aChecks 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_FieldsContainsAclFieldz"GcsJsonApi._FieldsContainsAclFields" T> F_99#f+FFrct|r6tjt|rd|vrtdtzyyy)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._ValidateEncryptionFieldsForMetadataGetRequestz9GcsJsonApi._ValidateEncryptionFieldsForMetadataGetRequestsK (55c&kBF*  79N O PP +CrcZtj||jt}tj}|rdj t ||_ |jjj||S#t$r}|j||Yd}~yd}~wwxYw)N)bucket userProjectoptionsRequestedPolicyVersion,r bucket_name) r!StorageBucketsGetIamPolicyRequestrkr=rjoinrrrbuckets GetIamPolicy TRANSLATABLE_APITOOLS_EXCEPTIONS_TranslateExceptionAndRaise)rrrfrapitools_requestres rGetBucketIamPolicyzGcsJsonApi.GetBucketIamPolicys(JJ%%&8:&==?M  XXc&k2mC __ $ $ 1 12B@M2OO +C &&qk&BBCs&B B* B%%B*cr| t|}tj||||j}tj}|rdj t ||_ |jjj||S#t$r}|j||||Yd}~yd}~wwxYw)Nrobject generationrrrr object_namer) longr!StorageObjectsGetIamPolicyRequestrkrrrrrobjectsrrr) rrrrrfrrrrs rGetObjectIamPolicyzGcsJsonApi.GetObjectIamPolicys  #j(JJ%% ' &==?M  XXc&k2m> __ $ $ 1 12B@M2OO +> &&q3>3>2<'>>>s'&B B6B11B6c0| t|}tj|||||j}tj} |j j j||S#t$r}|j|||Yd}~yd}~wwxYw)N)rrrpolicyrrrr) rr!StorageObjectsSetIamPolicyRequestrkrrr SetIamPolicyrr) rrrrrrf api_requestrrs rSetObjectIamPolicyzGcsJsonApi.SetObjectIamPolicys  #j#EE%% 'K &==?M@ __ $ $ 1 1+@M2OO +@ &&q3>3>'@@@s&A.. B7BBctj|||j}tj} |jj j ||S#t$r}|j||Yd}~yd}~wwxYw)N)rrrrr) r!StorageBucketsSetIamPolicyRequestrkrrrrrr)rrrrfrrrs rSetBucketIamPolicyzGcsJsonApi.SetBucketIamPolicys(JJ6t7H7HJ%==?MC __ $ $ 1 12B@M2OO +C &&qk&BBCs&A B(BBc |j} t| |||||||| \} } tjr| j t } |j | \} } |jd| d| dt| |d|| S),See CloudApi class for function doc strings.) client_idmethoddurationpathrrregionsigned_headersstring_to_sign_debugz.Key ID used to sign blob for service account "z": ""host) rrHsixPY3encoderArrgrI)rrrrrrrrrrrcanonical_query_stringkey_id raw_signatures rSignUrlzGcsJsonApi.SignUrls113-:$ %1 .3*N* ww%,,T2n 22>BFM LL$f./ }nV&>--dd(AA%%'&==?M  XXc&k2m C __ $ $ ( ()97D)FF +C &&qk&BBCs2&C C?"C::C?c tj|}|jjj |S#t $r}|j ||Yd}~yd}~wwxYw)r)rrN)r&StorageBucketAccessControlsListRequestrbucketAccessControlsListrr)rrrequestrs rListBucketAccessControlsz#GcsJsonApi.ListBucketAccessControlss^C!HHg __ 1 1 6 6w ?? +C &&qk&BBCs:= A#AA#c tj||}|jjj |S#t $r}|j |||Yd}~yd}~wwxYw)r)rrrN)r&StorageObjectAccessControlsListRequestrobjectAccessControlsrrr)rrrrrs rListObjectAccessControlsz#GcsJsonApi.ListObjectAccessControls sl@!HH[2g __ 1 1 6 6w ?? +@ &&q3>3>'@@@s;> A%A  A%c 6tjjj}|j |r$tjjj }|} |s t }g} dD]F} t| | d} | stj| r)t| | d| j| H| jr+| jtk(rg| _ | jd| jr.| jdtk(rg| _| jdd} |r?| jdtjj!|j#|} d}|r?| jdtjj%|j'|}tj|| ||j(| ||j*}tj,}|rdj/t1||_|j4j7| 5 |j4j8j;|| cdddS#t<$r}|j?|Yd}~nd}~wwxYw dddy#1swYyxYw) r)billing encryption lifecycleloggingmetadataretentionPolicy versioningwebsiteNcorsrrSrR)rbucketResourcerifMetagenerationMatch predefinedAclpredefinedDefaultObjectAclrrr) rStorageBucketsPatchRequestr r rr rgetattrr MessageToDictsetattrappendr"rPrSrOPredefinedAclValueValuesEnum_BucketCannedAclToPredefinedAcl)PredefinedDefaultObjectAclValueValuesEnum_ObjectCannedAclToPredefinedAclmeta_gen_matchrkrrrrr IncludeFieldsrPatchrr)rrr canned_aclcanned_def_acl preconditionsrfrrbucket_metadataapitools_include_fieldsmetadata_fieldattrpredefined_aclpredefined_def_aclrrrs r PatchBucketzGcsJsonApi.PatchBucket+sV$>>++EE ##F+%@@--ddO #om! _nd ;d h,,T26&&~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 @ ?., ((++,+ @ ? ?s0,J.&I J'I=8J=JJJcX t|}tj|||j }tj } |jjj||S#t$r tdwxYw#t$r}|j||Yd}~yd}~wwxYw)Nz6LockRetentionPolicy Metageneration must be an integer.rr$rrr) r ValueErrorrr(StorageBucketsLockRetentionPolicyRequestrkrrrLockRetentionPolicyrr)rrmetagenerationrfrrrs rrAzGcsJsonApi.LockRetentionPolicy|sDN+n BB"0)) + &==?MC __ $ $ 8 8 -999 D  B DDD ,C &&qk&BBCs# A+&B+B B) B$$B)ctjjj}|j |r$tjjj }|stj }||_|jr|jj|_|jr|jj|_ t|}tj||||j}tj}|rdjt||_ |j"j$j'||S#t($r} |j+| |Yd} ~ yd} ~ wwxYw)r)rprojectrrrrrN)rStorageBucketsInsertRequestr r rr Bucketnamelocationlower storageClassr,rkrrrrrrInsertrr) rr project_idrrfrrrrrs r CreateBucketzGcsJsonApi.CreateBucketsG$??++EE ##F+%AA--dd "))+hHM"++113h&3399;h":.J(DD%% ' &==?M  XXc&k2mC __ $ $ + +,<:G,II +C &&qk&BBCs1&E E>!E99E>c|s t}tj||j|j} |j j j|y#t$r}t|j||trM|j|dg}|jr-|jjrtd|j|j!||Yd}~yd}~wwxYw)rr>rr rVersionedBucketNotEmptystatusN)rrStorageBucketsDeleteRequestr0rkrrDeleterr_TranslateApitoolsExceptionrrr enabled status_coder)rrr5rfrrr6s r DeleteBucketzGcsJsonApi.DeleteBuckets #om(DD+::%%' C oo$$%56 + C   * *1+ * F   ..l^.L  % %/*D*D*L*L!";)*8 8 &&qk&BB Cs%A C4)BC//C4c#Ktjjj}|j |r$tjjj }t |}tj|t||j}tj}|r4d|vr|jddjt||_ |jjj!||}|j'D]} | |j(rtj||j(t||j} |jjj!||}|j'|D]} | |j(ryy#t"$r}|j%|Yd}~d}~wwxYw#t"$r}|j%|Yd}~od}~wwxYww)r)rD maxResultsrr nextPageTokenrrN)rD pageTokenrZrr)rStorageBucketsListRequestr r rr r,NUM_BUCKETS_PER_LIST_PAGErkraddrrrrrrrr _YieldBucketsr[) rrLrfrrrr bucket_listrrs r ListBucketszGcsJsonApi.ListBucketss#==++EE ##F+%??--dd":.J(BB,%% ' &==?M  & ?# XXc&k2m*OO++001A?L1Nk $$[1 l2  # #*DD--.'' ) ,oo--223CAN3P &&{3& 4  # # ,* &&q))* ., ((++,saCG7'F)AG7'G&G7'G7) G 2GG7G  G7 G4G/*G7/G44G7c#PK|jr|jD]}|yyw)z0Yields buckets from a list returned by apitools.N)items)rrars rr`zGcsJsonApi._YieldBucketss)%%& &s$&c #Ktjjj}|j |r$tjjj }tj|||||t |j}tj} |rt|}d|vr|jdt|jtrD|jd|jd|jd|jddj|| _d } d } | rd } tj|||||| t |j } |j j"j%|| }  j*rd } | j*} |j-| D]i}|j.t0j2j4k(r<|j7||j8t|}|t:k(r[|r||_n |k| ry y #t&$r} |j)| |Yd } ~ d } ~ wwxYww)r)rprefix delimiterversionsrrZrr[ list_fieldszitems/customerEncryptionzitems/kmsKeyNamezitems/generationz items/namerTNF)rrfrgrhrr\rZrrrrO)rStorageObjectsListRequestr r rr r>rkrrr_r;rrrrrrrrrr[_YieldObjectsAndPrefixesdatatyperCsObjectOrPrefixTypeOBJECT_DecryptHashesIfPossibledata_SKIP_LISTING_OBJECT)rrrfrg all_versionsrfrrrr list_pagenext_page_token object_listrobject_or_prefixdecrypted_metadatas r ListObjectszGcsJsonApi.ListObjectss:$==++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 (( (DDEs7E&I)'H,BI*I, I5I I IIc t|}|j|s|j||yd}|j||r9t j |j ||j|j|}n|j||r|jj}tjr!t|ts|j!d}t#|t$}|rBt j |j ||j|j|t'|}|y |S#t($r t*cYSwxYw)a.Attempts 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. rirONrrasciirrdecryption_tuple)r;_ObjectIsEncrypted2_RaiseIfNoDesiredHashesPresentForUnencryptedObject _ObjectKMSEncryptedAndNeedHashes functoolspartial_GetObjectMetadataHelperrGr!_ObjectCSEKEncryptedAndNeedHashesr keySha256rrrbytesrrErrDrrr)rrobject_metadatar get_fieldsget_metadata_func key_sha256decryption_keys rrpz#GcsJsonApi._DecryptHashesIfPossibleLsV2!V4J  " "? 3 ==oEO>Q  ,,_4>-@$++  ' '    $//   / /7A 0 C #55??j *e,!((1*3JGn %--  ) )   &114^D F  "   ""!"s2D99E  E c#BK|jrA|jD]2}tj|tjj4|j rB|j D]2}tj|tjj 4yywN)rdrCsObjectOrPrefixrnroprefixesPREFIX)rrv cloud_objrfs rrlz#GcsJsonApi._YieldObjectsAndPrefixess"(()'' (0(E(E(L(LN N)((&''(0(E(E(L(LN N)sBBc#K|rI|jjj}|jjj|d|r|j_yyw)z@Wrapped code makes apitools requests with the specified headers.N)rrcopyr)rr old_headerss r_ApitoolsRequestHeadersz"GcsJsonApi._ApitoolsRequestHeaderssROO;;@@Bk oo--44W= 0;doo-sA%A'ci}|rS|jtjk(r6|j|d<|j|d<t |j|d<|S)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_EncryptionHeadersFromTuplez&GcsJsonApi._EncryptionHeadersFromTuples]G 00M4F4FF/;/F/Fg+,)5)@)@g%& -l.E.E F,- Nrc:i}|rJ|jtjk(r-|j|d<|j|d<|j |d<|rJ|jtjk(r-|j|d<|j|d<|j |d<|S)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)rr~encryption_tuplers r_RewriteCryptoHeadersFromTuplesz*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. r{rOrrNr) '_CreateApitoolsObjectMetadataGetRequest&_GetApitoolsObjectMetadataGlobalParamsrrrrr rr) rrrrrr~rrrs rrz#GcsJsonApi._GetObjectMetadataHelpers0CC[ZDH??v?NM>   ) )  , ,:J , KM((,,-=;H-JMM &&**+;9F+H H MM ,> &&q3>3>2<'>>>s;#B0 'B$3 B0=&B0$B-)B0-B00 C9CCc:|j|tjjj}|j |r$tjjj }|r t|}tj|||||jS)NrO)rrrrr) rrStorageObjectsGetRequestr r rr rrk)rrrrrrs rrz2GcsJsonApi._CreateApitoolsObjectMetadataGetRequests  77v7F#<<++EE ##F+%>>--dd #j  5 5%%  ''rcptj}|rdjt||_|S)Nr)rrrrr)rrrs rrz1GcsJsonApi._GetApitoolsObjectMetadataGlobalParams s.%==?M  XXc&k2m rc J |j||||}|j||s|S|jj}tj r!t |ts|jd}t|t}|s!td|d|jd|d|tj r%t |ts|jt}|j||||t|S#t$r} |j!| ||| Yd } ~ y d } ~ wwxYw) rr{rOr|z(Missing decryption key with SHA256 hash z#. No decryption key matches object z://rtr}rN)rrrrrrrrrrErrrfrArDrr) rrrrrfrrrrrs rGetObjectMetadatazGcsJsonApi.GetObjectMetadatas6#>55k6AAK=C6Eo 3 3O;A4C #55??j *e,!((1*3JGn ! [ BC C .%0)006.  * *  2>B +DD ,> &&q3>3>2<'>>>s)C:C C:: D"DD"cHt|jxs |jSr)boolr kmsKeyName)rrs rrzGcsJsonApi._ObjectIsEncrypted;s% 22+** ,,rc|yd|vxr |j }d|vxr |j }|r(|js|rtd|jzyyy)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_componentCountrrG)rrrmd5_requested_but_missingcrc32c_requested_but_missings rrz=GcsJsonApi._RaiseIfNoDesiredHashesPresentForUnencryptedObject?s~ !*f!4"=%4%<%(>$>! "/*H*H$  "$3$8$8 9 :: %+I!rc|tj|sy|jxr|j xr |j S)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 rrz+GcsJsonApi._ObjectKMSEncryptedAndNeedHashesRsJ"7"D"DV"L   & & (/E/E+E ('' ')rc|tj|sy|jxr|j xr |j S)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 rrz,GcsJsonApi._ObjectCSEKEncryptedAndNeedHashesesM~2??G   . . G&& & G/>/F/F+FHrFc|r t|}|}| r| dz}n-| r+tjtj| d}| r| t d| | |t }| |_t||| | }|j}||j_ d|i|j_ | r|jrWtjtj| }|dxxd|jzz cc<tj|} tj j#|| |j$j&|j(|j$ }n-tj j+|d ||j( }|j,|_t1j2||||j4 }t7d |j8|_ |t<j>j@k(r|jC||||||||| | | | S|jE|||||||| | | | S#tF$r}|jI||||Yd}~yd}~wwxYw)r total_sizeNz`Download size is required when callbacks are requested for a download, but no size was provided.)rprogress_callback digestershttpsryz&trace=token%%3A%s)rclientF) auto_transferrrrTis_data_transferr)compressed_encodingr start_byteend_byteserialization_datar~rrrrrr~r)%rjsonloadsr ensure_strrr"bytes_transferredr#GetConnectionClassrstream connectionsridumpsapitools_transferDownloadFromDatarrzr FromStreamr bytes_httprrrkrGrrrDownloadStrategy RESUMABLE_PerformResumableDownload_PerformDownloadrr)rrrdownload_streamrfr object_sizerdownload_strategyrrrrrr~outer_total_sizebytes_downloaded_containercallback_class_factorydownload_http_classserialization_dictapitools_downloadrrs rGetObjectMediazGcsJsonApi.GetObjectMediays$ #j #!A  ..+ ,..:<  !!,- - $45!:!<3=0C"#+  1CCE!0D&-/B%CD"   !ZZ7I(JK5!%9D",44??  && @( $(#@#@ (AA%% '$7D,=,=$? %> h77AA A--      & 3!!1-. / /$$[%0%4%5%60:9L0:.68J6F% H H" ,> &&q3>3>2<'>>>s!9H7H77 IIIc d} | }| |jkr |j|||||||| | | |  Syy#t$r}|j||j } | |_| |kDr| }d} | dz } | |jkDr#t d|jt|fztjt| |j|jjtjr9|jj!d| t|t#j$t'j(|j*Yd}~nd}~wwxYw| |jkrZ?)Nrrr5Transfer failed after %d retries. Final exception: %smax_waitz=Retrying download from byte %s after exception: %s. Trace: %s)rrHTTP_TRANSFER_EXCEPTIONS$_ValidateHttpAccessTokenRefreshErrortellrrrJtimesleepr rr isEnabledForrDEBUGrg traceback format_excapitools_http_wrapperRebuildHttpConnectionsr)rrrrrrrrrrrrr~retrieslast_progress_byters rrz$GcsJsonApi._PerformResumableDownloadsG# T%% %2*$$[%0%4%5%60:9L0:.68J6F% H H &&&* 11!4$))+ 7A"4 * *) '1  T%% %&+E!._NoOpCallbackTs r user-agent)rF)additional_headersstartend use_chunks)callbackfinish_callbackrr) rrr rr user_agentrFrrrGetRange StreamMediar )rrrrrrrrrrrr~rrrs rrzGcsJsonApi._PerformDownload=s- @ ##$4-> $ @  doo00""46IK *+ (()9:<X)  4F'1%-,1!3  % %% ##]4A7I/4$6  % %%S.@ ((5@5@4> ) @ @@s'C C2C--C2c Ztjjj} |j |r$tjjj } |s t }|r t|}d} g} |r?| jdtjj|j|} |jdk(r| jd|jdk(r| jd|jdk(r| jd|jdk(r| jdtj||||| |j|j | |j" } tj$}|rd j't)||_ |j,j/| 5|j,j0j3| | cdddS#1swYyxYw#t4$r}|j7|||| Yd}~yd}~wwxYw) rNrRrr cacheControlcontentDispositioncontentEncodingcontentLanguage) rrobjectResourcerrifGenerationMatchr$r%rrrr)rStorageObjectsPatchRequestr r rr rrr+r,r/rrrr gen_matchr0rkrrrrrr1rr2rr)rrrrr3rr5rfrrkrr:r7rrrs rPatchObjectMetadatazGcsJsonApi.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<'>>>s6*H'G6, H6G?;H?H H* H%%H*ct|d}|r.tjj|j |}t }| r |r |} | d|t || | |j|j}|j}||d|j_ d|jji}|j| d}d}d}| s|j}|st }|s t#}tj|j$||j&|j(||j*}tj,}|rdj/t1||_|j5|}| t6j8k(rt7j:|||d |j<| }| |_|j@|_!|jE|5|jjFjI||| cdddSd|jji}|jK||j||jM||j@||| | |||| || | S#1swYyxYw#tN$rS}tQ|jR|j$}|jU||j$|jV| Yd}~yd}~wwxYw) aUpload 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)rrrrg)rzrr)rrr r$r%rrrT)rrr gzip_encodeduploadrrrnot_found_exception),r<rStorageObjectsInsertRequestr,r/r"r&rrgrrrrrr contentTyperNrrr r0rkrrrrrr SIMPLE_UPLOADUploadrstrategyrrrrrKr_PerformResumableUploadrrLrfrrG)r upload_streamrr3sizer5rrfrrtracker_callbackrapitools_strategyrrr:bytes_uploaded_containerrupload_http_classr content_typerrencryption_headersapitools_uploadrrs r _UploadObjectzGcsJsonApi._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 ./++ 466 d  13C 35E  1< A A> =$ ,PA --//1 &&q3B3I3I3B3G3G;N'PPPs? DI;(I/ I;A I;/I84I;8I;; KA KKc z |rdtjj|||jj|j | |j}t |_||_n~tj|||t d|j | }||_ ||_|j| 5|jjj|||dddtd|j|_d}|j | _| r%| t%j&|j(d}|j }||j kr | s!|rt+s|j-||| }n|j/||| }|jjj1|jjj3d |}|| r| |j4|j4|Syy#1swY$xYw#t6$r}|j9|t;j<|j||j kr |j?|j }|| _n#t6$r}|j9|t;j<|j|d z }||j kDrtAd |j |fztCjDtG||jH Yd}~nd}~wwxYw||j kr|kDr|}d}na|d z }||j kDr#tAd |j tK|fztCjDtG||jH |jLjOtPjRr9|jLjUd|tK|tWjXYd}~nd}~wwxYw||j kr#tZ$r}|j]|}|r|d}~wwxYw)N)rrrF)r chunksizerrrrTrcyrr)runused_upload_objects rrz9GcsJsonApi._PerformResumableUpload.._NoOpCallback]s rr)rrrrKrrrz;Retrying upload from byte %s after exception: %s. Trace: %s)/rrrrrzrr6r%rrrrrKrGrrprogressrrrrr:rStreamInChunksProcessHttpResponseGetMethodConfigrrrrrRefreshResumableUploadStaterrrr rrJrrrrrgrrr*_TranslateApitoolsResumableUploadException)rrrr rrrrrrr addl_headersrrr"rrr http_responseprocessed_responserre2 resumable_exs rrz"GcsJsonApi._PerformResumableUpload6s ~ +22;;   OO ((%?? <$%>$?!%;",22  /1((%'$5 %;"  ) ), 7 // ! ! ( ()90?7D ) F8 $7d.?.?$Ao  4C3K3K0 O$F$FGHg*33 t'' 'I ($/L/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 KK  M7:$$& (I' (G t'' 'V ,DDQGl  sB3P5)HAmaxBytesRewrittenPerCallrr) src_providersrc_bucket_namesrc_object_namerAr)1r<rStorageObjectsRewriteRequest'DestinationPredefinedAclValueValuesEnumr/rrr r rr rrr_rrrrCrrCMEKrrr0rrGr1r r0r2rrrkrrRewriter?r+r=Progressr<r>r3r/resourcerrLrfr)rsrc_obj_metadatadst_obj_metadatarAr3r5rrBrr~rfrr:rr new_fieldsfielddec_key_sha256enc_key_sha256tracker_file_namerewrite_params_hashresume_rewrite_tokencrypto_headersprogress_cb_with_timeoutlast_bytes_writtenrrewrite_response bytes_writtenrrs r CopyObjectzGcsJsonApi.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'PP Ps3#N BM>B"N >NN P A,PP cH|s t}|r t|}tj||||j|j |j } |jjj|S#t$r}|j||||Yd}~yd}~wwxYw)r)rrrr r$rrN) rrrStorageObjectsDeleteRequestr r0rkrrrTrr)rrrr5rrfrrs r DeleteObjectzGcsJsonApi.DeleteObjects #om #j(DD'11+::%% '> __ $ $ + +,< == +> &&q3>3>2<'>>>s$A99 B!BB!c t||j}d|_|j}d|_|js t|_|s t }t j} |rdjt|| _ t j||} |j|} d} |r)|jtjk(r |j } |j#| 5t j$| |||j&|j(|j*| } |j,j.j1| | cdddS#t2$rO}t5|t6j8r|j:dk(r t=d|j?|Yd}~nd}~wwxYw dddy#1swYyxYw) rNr) sourceObjects destinationr)composeRequestrGrIr r$rrrz)One of the source objects does not exist.) r<rGrrrNrrrrrrComposeRequestrrrCrRrrStorageObjectsComposeRequestr r0rkrrComposerrapitools_exceptions HttpErrorrWrr)rsrc_objs_metadatarWr5rrfr dst_obj_namedst_bucket_namersrc_objs_compose_requestr!rrrs r ComposeObjectzGcsJsonApi.ComposeObjects./#((L &--O"  ' '%9" #om%==?M  XXc&k2m0??'5E G99%:'J  % %);); ;%00 % %&8 9*GG1+()33 - < <''! .&&../?=J/L : 9.. q-77 8 MMS !"MN N  * *1 - - . .% : 9 9s11;G-&E F5&AF0+G0F55GG ctjjj}tj|||d}tj||||j } tj } |rdjt|| _ |jjj| | S#t$r} |j| |Yd} ~ yd} ~ wwxYw)rWEB_HOOK)addressidtokentype)rchannelrrrrrN)rStorageObjectsWatchAllRequestr r ChannelrkrrrrrrWatchAllrr) rrry channel_idr{rfrrr}rrrs r WatchBucketzGcsJsonApi.WatchBuckets$AA++DD ''+5.3-79G )FF%% ' &==?M  XXc&k2mC __ $ $ - -.>> C$CC$ctj||} |jjj |y#t $r}|j |Yd}~yd}~wwxYw)r)rz resourceIdN)rrrchannelsStoprr)rr resource_idrfr}rs r StopChannelzGcsJsonApi.StopChannelsR'':+NG* oo##G, +* &&q))*s%? A#AA#ctj||j} |jjj |S#t $r}|j||Yd}~yd}~wwxYw)rrrrN)r!StorageBucketsListChannelsRequestrkrr ListChannelsrr)rrrfrrrs rrzGcsJsonApi.ListChannelssh(JJ(9(9;C __ $ $ 1 12B CC +C &&qk&BBCs$A A.A))A.c tjtj|}|jj j |S#t$r}|j|Yd}~yd}~wwxYw)r) projectIdN) r'StorageProjectsServiceAccountGetRequestr text_typerprojects_serviceAccountr rr)rproject_numberrrs rGetProjectServiceAccountz#GcsJsonApi.GetProjectServiceAccounts_*!IIMM.13g __ 4 4 8 8 AA +* &&q))*sA A A4A//A4c tj||}|r||_|r>|jD cgc]\}} t || } }} t | |_|r||_tj|||j} |jjj| Scc} }w#t$r} |j| Yd} ~ yd} ~ wwxYw)r)topicpayload_format)rvalue)additionalPropertiesr notificationrN)r Notification event_typesrdNotificationAdditionalProperty!NotificationCustomAttributesValuecustom_attributesobject_name_prefix!StorageNotificationsInsertRequestrkr notificationsrKrr) rr pubsub_topicrrrrrrradditional_propertiesrrs rCreateNotificationConfigz#GcsJsonApi.CreateNotificationConfigs*&33^=l #.  0557! 7 U +s% @7 ! *K!6*8 & *< '!CC#'')g__ * * 1 1' ::!  ,* &&q))*s)5B8B2A#B82B88 CCCc tj|||j}|jjj |S#t $r}|j|Yd}~yd}~wwxYw)rrN)r!StorageNotificationsDeleteRequestrkrrrTrr)rrrrrs rDeleteNotificationConfigz#GcsJsonApi.DeleteNotificationConfig:sd*!CC#'')g__ * * 1 1' :: +* &&q))*sAA A-A((A-c#K tj||j}|jjj |}|j D]}|y#t$r}|j|Yd}~yd}~wwxYww)rrN) rStorageNotificationsListRequestrkrrrrdrr)rrrrrrs rListNotificationConfigsz"GcsJsonApi.ListNotificationConfigsEst*!AA$*;*;=g..33G A"AA"c tj||}|jjj |S#t $r}|j |Yd}~yd}~wwxYwr)raccessIdN)r$StorageProjectsHmacKeysDeleteRequestrrrTrrrrL access_idrrs r DeleteHmacKeyzGcsJsonApi.DeleteHmacKeyYsX*!FF4g __ % % , ,W 55 +* &&q))*rc tj||}|jjj |S#t $r}|j |Yd}~yd}~wwxYwr)r!StorageProjectsHmacKeysGetRequestrrr rrrs r GetHmacKeyzGcsJsonApi.GetHmacKeybsX*!CC4g __ % % ) )' 22 +* &&q))*rc#TK tj|||t}|jjj |}|j D]}| jrqtj||||jt} |jjj |}|j D]}||jrpyy#t$r}|j|Yd}~d}~wwxYw#t$r}|j|Yd}~jd}~wwxYww)r)rrshowDeletedKeysrZN)rrrr\rZ) r"StorageProjectsHmacKeysListRequestr^rrrrdrrr[)rrLrshow_deleted_keysrrrrs r ListHmacKeyszGcsJsonApi.ListHmacKeysks  *!DD3+. 0g ))..w7h#   !DD3+**. 0g ,??++009#     ,* &&q))*., ((++,s_D(AC5D(%D6!D(D( C>#C94D(9C>>D( D% D D( D%%D(c  tj||}tj}||_|r||_||_|j jj|S#t$r}|j|Yd}~yd}~wwxYwr) r$StorageProjectsHmacKeysUpdateRequestHmacKeyMetadatastateetagrUrrUpdaterr)rrLrrrrrrs r UpdateHmacKeyzGcsJsonApi.UpdateHmacKeys *!FF4g"224hhn  !g __ % % , ,W 55 +* &&q))*sA&A)) B 2BB c@|tvr t|Std|z)aiTranslates the input string to a bucket PredefinedAcl string. Args: canned_acl_string: Canned ACL string. Returns: String that can be used as a query parameter with the JSON API. This corresponds to a flavor of *PredefinedAclValueValuesEnum and can be used as input to apitools requests that affect bucket access controls. Invalid canned ACL %s)._BUCKET_PREDEFINED_ACL_XML_TO_JSON_TRANSLATIONrrcanned_acl_strings rr-z*GcsJsonApi._BucketCannedAclToPredefinedAcl+JJ ;=A>c |jd}|jd}|dk\r||djdd}d|zSy#t$rYywxYw)Nzwww-authenticatezscope="rrrzAcceptable scopes: %s)rfindsplitr)rrwww_authenticate scope_idxscopess r!_GetAcceptableScopesFromHttpErrorz,GcsJsonApi._GetAcceptableScopesFromHttpErrorsr #,,-?@#'' 2i a!)*-33C8;&//     sAA AAc:t|tjr|j|}|jdk\rt |xsd|jS|jdk(rt |xsd|jS|jdk(rt |xsd|jS|jdk(rt |xsd|jS|jd k\rt|xsd|jSt|tjrtd t|zSt|tjrSd t|vs d t|vrtt|Sd t|vrtdt|zSyy)Nrz Server ErrorrQrzToo Many Requestsi Bad Requestrlza%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) rrprqrrWrrrStreamExhaustedstr TransferError)rrrs rr-z5GcsJsonApi._TranslateApitoolsResumableUploadExceptions!(223--a0g # '(A>/0}}> > ==C '(F3F/0}}> > ==C 01IM89 G G ==C 01IM89 G G ==C ,W-E 45MMC C!(889 * ,.1!f 566!(667 Q ' &#a& 0,SV44 ,A 6, M F   7 8rc&t|tjrE|j|}|jdk(rt |xsd|jS|jdk(radt |vrt|xsd|jSdt |vrtt|j|j|S|jd k(rcd t |vrt|xsd |jSd t |vrt|xsd |jSdt |vrtd|z|jSdt |vrtd|jSdt |vrtd|jSdt |vrtd|jSdt |vr+tt|j|j|Sdt |vrt||jSt|xs t ||jS|jdk(r|rt|d|j|S|rG|r$t|j|j|||St|j|j|St!|xs |j"|jS|jdk(rC|rAdt |vrtd|z|jSt%d|z|jS|jdk(rt'||jSt%||jSt|tj(rt%dt |zSy) a!Translates 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. rrrQizLogin RequiredzAccess denied: login required.insufficient_scope)rRbodyiz7The 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 messagesrlrR)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)rrprqrrWrrr"_INSUFFICIENT_OAUTH2_SCOPE_MESSAGErrrr*rMrfrKrrrrTransferInvalidError)rrrrrrrs rrUz&GcsJsonApi._TranslateApitoolsException s{&!(223--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&rrc)r __future__rrrr contextlibrr six.movesrrrrsocketsslrrrapitools.base.pyr r rpr 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_accountrQrintrrCustomAttributesValuerAdditionalPropertyrr^rqrrrrTransferRetryErrorBadStatusCodeErrorRetryAfterError RequestError BadStatusLineIncompleteReadResponseNotReadyServerNotFoundErrorrrrgaierrortimeoutSSLErrorr?rrrrrr+FULL_PREDEFINED_ACL_XML_TO_JSON_TRANSLATIONrrrrrrrrcrrrr%sE&%'%!   %>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