U W+dW@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_prefixmetadata_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-header storage-classz mfa-headerzserver-side-encryption-headerzversion-id-headerzrestore-headerZStorageCopyErrorZStorageCreateErrorZStorageDataErrorZStoragePermissionsErrorZStorageResponseErrorc@s eZdZdS)ProfileNotFoundErrorN)__name__ __module__ __qualname__rr1/tmp/pip-unpacked-wheel-dlxw5sjy/boto/provider.pyrJsrc#@s:eZdZdddZeedZeedZ dddZ dddZ dddZ e eeedeed ed eed eed eed eedeedeededeedeedeedeedeedeedie eeedeed edeed eed edeedeedeedeedeededeedeedededidZ 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#j1idZ2d:ddZ3ddZ4ddZ5e6e4e5Z7d d!Z8d"d#Z9e6e8e9Z:d$d%Z;d&d'Zd;d*d+Z?d,d-Z@d.d/ZAd0d1ZBd2d3ZCd4d5ZDd6d7ZEd8d9ZFdS)<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-rangedatez delete-markerzmetadata-directiveNzsecurity-tokenzserver-side-encryptionz version-idr ZmfarestoreZGOOG1Z resumablec Cs4d|_d|_d|_||_||_||_||_||_|j|j|_ |j |j|_ d|_ t jtdd|d}tdd|_t j|r|j||||||||d|j|j}td|rtd||_d|j|j}td|rtd||_d |j|j} td| r0td| |_dS) N~. credentialsF)Zdo_loadz%s_host Credentialsz%s_portz%s_host_header)hostportZ host_header access_key secret_keysecurity_token profile_namename AclClassMapZ acl_class CannedAclsMapZ canned_acls_credential_expiry_timeospathjoinrrshared_credentialsisfileZload_from_pathget_credentialsconfigure_headersconfigure_errors HostKeyMapr has_optiongetgetint) selfr"rrr r!Z shared_pathZ host_opt_nameZ port_opt_nameZhost_header_opt_namerrr__init__s6    zProvider.__init__cCs|r||jSN)_credentials_need_refresh#_populate_keys_from_metadata_server _access_keyr2rrrget_access_keyszProvider.get_access_keycCs ||_dSr4)r7r2valuerrrset_access_keyszProvider.set_access_keycCs|r||jSr4)r5r6 _secret_keyr8rrrget_secret_keyszProvider.get_secret_keycCs ||_dSr4)r=r:rrrset_secret_keyszProvider.set_secret_keycCs|r||jSr4)r5r6_security_tokenr8rrrget_security_tokenszProvider.get_security_tokencCs ||_dSr4)r@r:rrrset_security_tokenszProvider.set_security_tokencCs^|jdkrdS|jt}|j|j|jdddd}|dkrVtjddSdSdS)NFii@Bi,z!Credentials need to be refreshed.T) r%rutcnow microsecondssecondsdaysbotologdebug)r2deltaZ seconds_leftrrrr5s  z"Provider._credentials_need_refreshc Cs4|j|j\}}}}|dkr@|dk r@|tjkr@tj|}|j} |dk rb||_tj dn|tjkrtj||_tj dn|dk r| ||r| |||_tj d|n@t d||rt d|||_tj d|n t d|nR| d|r0| d||_tj dn(t d |rXt d ||_tj d |dk rx||_tj d nh|tjkrtj||_tj d n8|dk r$| ||r| |||_tj d |nBt d||rt d|||_tj d|n t d|n| d|rN| d||_tj dnt d |rxt d ||_tj dnht d drt d d} z ddl} Wn$tk rtjdYnX| | |j|_tj d|dk r||_tj dn|dk r|dkr|dkr|tjkrJtj||_tj dn| |pVd|r| |pjd||_tj dnt|dk rt d||rtj dt d|||_tj d|n(t d |rt 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)rrHrIrJr/r0rrrrM ImportErrorerror get_passwordr r7r=MetadataServiceSupportr6_convert_key_to_str) r2rrr r!Zaccess_key_nameZsecret_key_nameZsecurity_token_nameZprofile_name_nameZsharedZ keyring_namerMrrrr+ s                        zProvider.get_credentialscCstjdddlm}tddd}tddd}|||d d }|r||}|d|_ |d|_ |d |_ |d }t |d |_tjd|jt |dS)Nz,Retrieving credentials from metadata server.r)get_instance_metadataZBotoZmetadata_service_timeoutg?Zmetadata_service_num_attemptsz#meta-data/iam/security-credentials/)timeoutZ num_retriesdataz%Y-%m-%dT%H:%M:%SZz.Retrieved credentials will expire in %s at: %s)rHrIrJZ boto.utilsrVrgetfloatr1_get_credentials_from_metadatar7r=r@rstrptimer%now)r2rVrXattemptsmetadatacreds expires_atrrrr6|s.       z,Provider._populate_keys_from_metadata_serverc Cst|d}t|ts<|dkr(d}nd|}td|z*|d}||d}|d}|d }Wn.tk r}ztd |W5d}~XYnX||||fS) Nrzan empty stringztype: %sz7Expected a dict type of credentials instead received %sZ AccessKeyIdZSecretAccessKeyTokenZ Expirationz;Credentials from instance metadata missing required key: %s)listvalues isinstancedictrrUKeyError) r2rarbmsgrrr rcerrrr]s(  z'Provider._get_credentials_from_metadatacCst|tjrt|S|Sr4)rhr text_typestr)r2keyrrrrUs zProvider._convert_key_to_strcCs|j|j}|t|_|t|_|t|_|t|_ |t |_ |t |_ |t|_|t|_|t|_|t|_|t|_|t|_|t|_|t|_|t|_|t |_!|t"|_#dSr4)$ HeaderInfoMapr"METADATA_PREFIX_KEYr HEADER_PREFIX_KEYr ACL_HEADER_KEYZ acl_headerAUTH_HEADER_KEY auth_headerCOPY_SOURCE_HEADER_KEYZcopy_source_header!COPY_SOURCE_VERSION_ID_HEADER_KEYZcopy_source_version_idCOPY_SOURCE_RANGE_HEADER_KEYZcopy_source_range_headerDATE_HEADER_KEYZ date_headerDELETE_MARKER_HEADER_KEYZ delete_markerMETADATA_DIRECTIVE_HEADER_KEYZmetadata_directive_headerSECURITY_TOKEN_HEADER_KEYZsecurity_token_headerRESUMABLE_UPLOAD_HEADER_KEYZresumable_upload_headerSERVER_SIDE_ENCRYPTION_KEYZserver_side_encryption_headerSTORAGE_CLASS_HEADER_KEYZstorage_class_headerVERSION_ID_HEADER_KEY version_idMFA_HEADER_KEYZ mfa_headerRESTORE_HEADER_KEYZrestore_header)r2Zheader_info_maprrrr,s0             zProvider.configure_headerscCsB|j|j}|t|_|t|_|t|_|t|_ |t |_ dSr4) ErrorMapr"STORAGE_COPY_ERRORZstorage_copy_errorSTORAGE_CREATE_ERRORZstorage_create_errorSTORAGE_DATA_ERRORZstorage_data_errorSTORAGE_PERMISSIONS_ERRORZstorage_permissions_errorSTORAGE_RESPONSE_ERRORZstorage_response_error)r2Z error_maprrrr-s      zProvider.configure_errorscCs |j|jSr4)r.r"r8rrrget_provider_nameszProvider.get_provider_namecCs |j|jSr4)ChunkedTransferSupportr"r8rrrsupports_chunked_transfersz"Provider.supports_chunked_transfer)NNNN)NNNN)GrrrrNr rr#CannedS3ACLStringsCannedGSACLStringsr$r.rrTrrAWS_HEADER_PREFIXrqrsrtrvrwrxryrzr{r}r|r~rrrrGOOG_HEADER_PREFIXrprrH exceptionZ S3CopyErrorrZ S3CreateErrorrZ S3DataErrorrZS3PermissionsErrorrZS3ResponseErrorZ GSCopyErrorZ GSCreateErrorZ GSDataErrorZGSPermissionsErrorZGSResponseErrorrr3r9r<propertyrr>r?rrArBr r5r+r6r]rUr,r-rrrrrrrNs* 3 #    srcCstdS)Nr)rrrrr get_defaultsr)1__doc__r&Z boto.compatrrrHrrZboto.pyami.configrZboto.exceptionrZ boto.gs.aclrr rZ boto.s3.aclrr rrrqrrrsrtrvrwrxrzryr{r}r|rrr~rrrrrrrobjectZNO_CREDENTIALS_PROVIDED ValueErrorrrrrrrrsV