B è?F[ãWã@sdZddlZddlmZddlmZddlZddlmZddlmZddlm Z ddl m Z dd l m Z dd l mZdd lmZdd lmZd Zd ZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!dZ"dZ#dZ$dZ%dZ&d Z'd!Z(d"Z)d#Z*e+ƒZ,Gd$d%„d%e-ƒZ.Gd&d'„d'e+ƒZ/d(d)„Z0dS)*zC This class encapsulates the provider-specific header differences. éN)Úsix)Údatetime)Úconfig)Ú expanduser)ÚConfig)ÚInvalidInstanceMetadataError)ÚACL)ÚCannedACLStrings)ÚPolicyÚ header_prefixÚmetadata_prefixzx-amz-zx-goog-z acl-headerz auth-headerzcopy-source-headerzcopy-source-version-id-headerzcopy-source-range-headerzdelete-marker-headerz date-headerzmetadata-directive-headerzresumable-upload-headerzsecurity-token-headerz storage-classz mfa-headerzserver-side-encryption-headerzversion-id-headerzrestore-headerZStorageCopyErrorZStorageCreateErrorZStorageDataErrorZStoragePermissionsErrorZStorageResponseErrorc@s eZdZdS)ÚProfileNotFoundErrorN)Ú__name__Ú __module__Ú __qualname__©rrú,lib/python3.7/site-packages/boto/provider.pyr Jsr c#@s:eZdZdddœZeedœZeedœZ dddœZ dddœZ dddœZ e eeedeed ed eed eed eed eedeedeededeedeedeedeedeedeedie eeedeed edeed eed edeedeedeedeedeededeedeedededidœZ e!e"j#j$e%e"j#j&e'e"j#j(e)e"j#j*e+e"j#j,ie!e"j#j-e%e"j#j.e'e"j#j/e)e"j#j0e+e"j#j1idœZ2d:dd„Z3dd„Z4dd„Z5e6e4e5ƒZ7d d!„Z8d"d#„Z9e6e8e9ƒZ:d$d%„Z;d&d'„Zd;d*d+„Z?d,d-„Z@d.d/„ZAd0d1„ZBd2d3„ZCd4d5„ZDd6d7„ZEd8d9„ZFdS)<ÚProvider)Zaws_access_key_idZaws_secret_access_keyZaws_security_tokenZ aws_profile)Zgs_access_key_idZgs_secret_access_keyNN)ÚawsZgoogleZs3ZgsFTzmeta-ZaclZAWSz copy-sourcezcopy-source-version-idzcopy-source-rangeZdatez delete-markerzmetadata-directiveNzsecurity-tokenzserver-side-encryptionz version-idz storage-classZmfaZrestoreZGOOG1Z resumablec Cs4d|_d|_d|_||_||_||_||_||_|j|j|_ |j |j|_ d|_ t j tdƒd|d¡}tdd|_t j |¡rŽ|j |¡| ||||¡| ¡| ¡d|j|j}t d|¡rØt d|¡|_d|j|j}t d|¡rt d|¡|_d |j|j} t d| ¡r0t d| ¡|_dS) Nú~Ú.Z credentialsF)Zdo_loadz%s_hostÚ Credentialsz%s_portz%s_host_header)ZhostZportZ host_headerÚ access_keyÚ secret_keyÚsecurity_tokenÚ profile_nameÚnameÚ AclClassMapZ acl_classÚ CannedAclsMapZ canned_aclsÚ_credential_expiry_timeÚosÚpathÚjoinrrÚshared_credentialsÚisfileZload_from_pathÚget_credentialsÚconfigure_headersÚconfigure_errorsÚ HostKeyMaprÚ has_optionÚgetÚgetint) ÚselfrrrrrZ shared_pathZ host_opt_nameZ port_opt_nameZhost_header_opt_namerrrÚ__init__µs6    zProvider.__init__cCs| ¡r| ¡|jS)N)Ú_credentials_need_refreshÚ#_populate_keys_from_metadata_serverÚ _access_key)r,rrrÚget_access_keyØszProvider.get_access_keycCs ||_dS)N)r0)r,ÚvaluerrrÚset_access_keyÝszProvider.set_access_keycCs| ¡r| ¡|jS)N)r.r/Ú _secret_key)r,rrrÚget_secret_keyâszProvider.get_secret_keycCs ||_dS)N)r4)r,r2rrrÚset_secret_keyçszProvider.set_secret_keycCs| ¡r| ¡|jS)N)r.r/Ú_security_token)r,rrrÚget_security_tokenìszProvider.get_security_tokencCs ||_dS)N)r7)r,r2rrrÚset_security_tokenñszProvider.set_security_tokencCs^|jdkrdS|jt ¡}|j|j|jdddd}|dkrVtj d¡dSdSdS)NFéii@Bi,z!Credentials need to be refreshed.T) rrZutcnowZ microsecondsZsecondsZdaysÚbotoÚlogÚdebug)r,ZdeltaZ seconds_leftrrrr.ös   z"Provider._credentials_need_refreshc Cs4|j|j\}}}}|dkr@|dk r@| ¡tjkr@tj| ¡}|j} |dk rb||_tj  d¡nö| ¡tjkrŽtj| ¡|_tj  d¡nÊ|dk r|   ||¡rÄ|   ||¡|_tj  d|¡n@t   d||¡røt   d||¡|_tj  d|¡n t d|ƒ‚nR|   d|¡r0|   d|¡|_tj  d¡n(t   d |¡rXt   d |¡|_tj  d ¡|dk rx||_tj  d ¡nh| ¡tjkr¨tj| ¡|_tj  d ¡n8|dk r$|   ||¡rà|   ||¡|_tj  d |¡nBt   d||¡rt   d||¡|_tj  d|¡n t d|ƒ‚n¼|   d|¡rN|   d|¡|_tj  d¡n’t   d |¡rxt   d |¡|_tj  d¡nht   d d¡ràt   d d¡} y ddl} Wn$tk rÂtj d¡‚YnX|  | |j¡|_tj  d¡|dk rþ||_tj  d¡nö|dk rô|dkrô|dkrô| ¡tjkrJtj| ¡|_tj  d¡nª|   |pVd|¡r€|   |pjd|¡|_tj  d¡nt|dk rÌt   d||¡rôtj  d¡t   d||¡|_tj  d|¡n(t   d |¡rôt   d |¡|_tj  d¡|jdks |jdkr"|j|jr"| ¡| |j¡|_dS)Nz$Using access key provided by client.z/Using access key found in environment variable.z@Using access key found in shared credential file for profile %s.z profile %sz2Using access key found in config file: profile %s.zProfile "%s" not found!Údefaultz1Using access key found in shared credential file.rz&Using access key found in config file.z$Using secret key provided by client.z/Using secret key found in environment variable.z@Using secret key found in shared credential file for profile %s.z2Using secret key found in config file: profile %s.z1Using secret key found in shared credential file.z&Using secret key found in config file.ÚkeyringrzZThe keyring module could not be imported. For keyring support, install the keyring module.z"Using secret key found in keyring.z(Using security token provided by client.z3Using security token found in environment variable.z5Using security token found in shared credential file.zconfig has optionz6Using security token found in config file: profile %s.z*Using security token found in config file.)Ú CredentialMaprÚupperr Úenvironr#rr;r<r=r)r*rr rr?Ú ImportErrorÚerrorZ get_passwordrr0r4ÚMetadataServiceSupportr/Ú_convert_key_to_str) r,rrrrZaccess_key_nameZsecret_key_nameZsecurity_token_nameZprofile_name_nameZsharedZ keyring_namer?rrrr% sº                             zProvider.get_credentialscCs¢tj d¡ddlm}t ddd¡}t ddd¡}|||d d }|rž| |¡}|d|_ |d|_ |d |_ |d }t   |d ¡|_tj d|jt  ¡|¡dS)Nz,Retrieving credentials from metadata server.r)Úget_instance_metadataZBotoZmetadata_service_timeoutgð?Zmetadata_service_num_attemptséz#meta-data/iam/security-credentials/)ÚtimeoutZ num_retriesÚdataééz%Y-%m-%dT%H:%M:%SZz.Retrieved credentials will expire in %s at: %s)r;r<r=Z boto.utilsrGrZgetfloatr+Ú_get_credentials_from_metadatar0r4r7rZstrptimerZnow)r,rGrIZattemptsÚmetadataÚcredsÚ expires_atrrrr/|s$        z,Provider._populate_keys_from_metadata_serverc Cs¢t| ¡ƒd}t|tƒs<|dkr(d}nd|}td|ƒ‚y*|d}| |d¡}|d}|d }Wn.tk r”}ztd |ƒ‚Wdd}~XYnX||||fS) NrÚzan empty stringztype: %sz7Expected a dict type of credentials instead received %sZ AccessKeyIdZSecretAccessKeyÚTokenZ Expirationz;Credentials from instance metadata missing required key: %s)ÚlistÚvaluesÚ isinstanceÚdictrrFÚKeyError) r,rNrOÚmsgrrrrPÚerrrrM–s"  z'Provider._get_credentials_from_metadatacCst|tjƒrt|ƒS|S)N)rUrZ text_typeÚstr)r,ÚkeyrrrrF´s zProvider._convert_key_to_strcCsº|j|j}|t|_|t|_|t|_|t|_ |t |_ |t |_ |t|_|t|_|t|_|t|_|t|_|t|_|t|_|t|_|t|_|t |_!|t"|_#dS)N)$Ú HeaderInfoMaprÚMETADATA_PREFIX_KEYr ÚHEADER_PREFIX_KEYr ÚACL_HEADER_KEYZ acl_headerÚAUTH_HEADER_KEYZ auth_headerÚCOPY_SOURCE_HEADER_KEYZcopy_source_headerÚ!COPY_SOURCE_VERSION_ID_HEADER_KEYZcopy_source_version_idÚCOPY_SOURCE_RANGE_HEADER_KEYZcopy_source_range_headerÚDATE_HEADER_KEYZ date_headerÚDELETE_MARKER_HEADER_KEYZ delete_markerÚMETADATA_DIRECTIVE_HEADER_KEYZmetadata_directive_headerÚSECURITY_TOKEN_HEADER_KEYZsecurity_token_headerÚRESUMABLE_UPLOAD_HEADER_KEYZresumable_upload_headerÚSERVER_SIDE_ENCRYPTION_KEYZserver_side_encryption_headerÚSTORAGE_CLASS_HEADER_KEYZstorage_class_headerÚVERSION_ID_HEADER_KEYZ version_idÚMFA_HEADER_KEYZ mfa_headerÚRESTORE_HEADER_KEYZrestore_header)r,Zheader_info_maprrrr&»s(               zProvider.configure_headerscCsB|j|j}|t|_|t|_|t|_|t|_ |t |_ dS)N) ÚErrorMaprÚSTORAGE_COPY_ERRORZstorage_copy_errorÚSTORAGE_CREATE_ERRORZstorage_create_errorÚSTORAGE_DATA_ERRORZstorage_data_errorÚSTORAGE_PERMISSIONS_ERRORZstorage_permissions_errorÚSTORAGE_RESPONSE_ERRORZstorage_response_error)r,Z error_maprrrr'Ós      zProvider.configure_errorscCs |j|jS)N)r(r)r,rrrÚget_provider_nameÛszProvider.get_provider_namecCs |j|jS)N)ÚChunkedTransferSupportr)r,rrrÚsupports_chunked_transferÞsz"Provider.supports_chunked_transfer)NNNN)NNNN)Grrrr@r rrÚCannedS3ACLStringsÚCannedGSACLStringsrr(rurEr^ÚAWS_HEADER_PREFIXr]r_r`rarbrcrdrerfrhrgrirkrjrlrmÚGOOG_HEADER_PREFIXr\ror;Z exceptionZ S3CopyErrorrpZ S3CreateErrorrqZ S3DataErrorrrZS3PermissionsErrorrsZS3ResponseErrorZ GSCopyErrorZ GSCreateErrorZ GSDataErrorZGSPermissionsErrorZGSResponseErrorrnr-r1r3Úpropertyrr5r6rr8r9rr.r%r/rMrFr&r'rtrvrrrrrNs¦    "    rrcCstdƒS)Nr)rrrrrÚ get_defaultãsr|)1Ú__doc__r Z boto.compatrrr;rrZboto.pyami.configrZboto.exceptionrZ boto.gs.aclrr rxZ boto.s3.aclrwr r^r]ryrzr_r`rarbrcrerdrfrhrgrjrlrirkrmrorprqrrrsÚobjectZNO_CREDENTIALS_PROVIDEDÚ ValueErrorr rr|rrrrÚsV