U W¨+dO£ã@sxddlZddlZddlZddlZddlmZddlmZddlmZGdd„de ƒZ Gdd„de ƒZ Gd d „d e ƒZ dS) éN)Ú DeleteMarker©ÚBotoClientError)ÚInvalidUriErrorc@sÐeZdZdZdZdZiZdd„Zdd„Zdd„Z d d „Z d d „Z d d„Z dd„Z d.dd„Zdd„Zd/dd„Zd0dd„Zd1dd„Zd2dd„Zd3dd „Zd4d!d"„Zd5d#d$„Zd6d&d'„Zd7d(d)„Zd*d+„Zd,d-„ZdS)8Ú StorageUrizæ Base class for representing storage provider-independent bucket and object name with a shorthand URI-like syntax. This is an abstract class: the constructor cannot be called (throws an exception if you try). NcCs tdƒ‚dS)zBUncallable constructor on abstract base StorageUri class. z0Attempt to instantiate abstract StorageUri classNr©Úself©r ú4/tmp/pip-unpacked-wheel-dlxw5sjy/boto/storage_uri.pyÚ__init__6szStorageUri.__init__cCs|jS)z%Returns string representation of URI.©Úurirr r r Ú__repr__<szStorageUri.__repr__cCs |j|jkS)z#Returns true if two URIs are equal.r )rr r r r Úequals@szStorageUri.equalscCs*|dkr&td t d||fd¡¡ƒ‚dS)NÚ zÉAttempt to get %s for "%s" failed. This can happen if the URI refers to a non-existent object or if you meant to operate on a directory (e.g., leaving off -R option on gsutil cp, mv, or ls of a bucket)éP)rÚjoinÚtextwrapÚwrap)rÚrespÚlevelr r r r Úcheck_responseDs ýüzStorageUri.check_responsecCs*tt|ƒtƒr&|js&td||jfƒ‚dS)Nz%s on bucket-less URI (%s))Ú issubclassÚtypeÚBucketStorageUriÚ bucket_namerr ©rÚ function_namer r r Ú_check_bucket_uriLs ÿzStorageUri._check_bucket_uricCs*tt|ƒtƒr&|js&td||jfƒ‚dS)Nz%s on object-less URI (%s))rrrÚ object_namerr rr r r Ú_check_object_uriQsÿzStorageUri._check_object_uric Ks4|D]*}||rtj d||t||ƒf¡qdS)Nz$Warning: %s ignores argument: %s=%s )ÚsysÚstderrÚwriteÚstr)rrÚargsÚargr r r Ú_warn_about_argsVsÿÿzStorageUri._warn_about_argsc Kst|jp dƒ}t|dƒr*d|kr*|j|d<| |¡|js |j|jkrX|j|j|_n²|jdkrŽddlm }|||f|Ž|_|j|j|j<n||jdkrÚddl m }ddlm }|ƒ|d <|||f|Ž|_|j|j|j<n0|jd krüdd l m}||ƒ|_ntd |jƒ‚|j|j_|jS) aË Opens a connection to appropriate provider, depending on provider portion of URI. Requires Credentials defined in boto config file (see boto/pyami/config.py). @type storage_uri: StorageUri @param storage_uri: StorageUri specifying a bucket or a bucket+object @rtype: L{AWSAuthConnection} @return: A connection to storage service provider of the given URI. r Úsuppress_consec_slashesÚs3r)Ú S3ConnectionÚgs)Ú GSConnection)ÚOrdinaryCallingFormatZcalling_formatÚfile)ÚFileConnectionzUnrecognized scheme "%s")ÚdictÚconnection_argsÚhasattrr(ÚupdateÚ connectionÚschemeÚ provider_poolZboto.s3.connectionr*Zboto.gs.connectionr,r-Zboto.file.connectionr/rÚdebug) rZ access_key_idZsecret_access_keyÚkwargsr1r*r,r-r/r r r Úconnect]sH  ÿÿ    ÿþ    ÿþ   ÿ zStorageUri.connectcCs"tt|ƒtƒo |jdk p |jdk S©N)rrrÚ version_idÚ generationrr r r Ú has_version—s þzStorageUri.has_versionFcCs(| d¡| ||¡}| |j|||¡S)NÚ delete_key)r Ú get_bucketr>r©rÚvalidateÚheadersr;Z mfa_tokenÚbucketr r r r>œs    ÿzStorageUri.delete_keyÚcCsH| d¡|j|d}|r4dd„|j|||dDƒS|j|||dSdS)NÚ list_bucket©rBcss|]}t|tƒs|VqdSr:)Ú isinstancer)Ú.0Úvr r r Ú ¨s þz)StorageUri.list_bucket..)ÚprefixÚ delimiterrB)rr?Z list_versionsÚlist)rrKrLrBZ all_versionsrCr r r rE£s   ÿ ÿzStorageUri.list_bucketcCs| ||¡}| |¡Sr:)r?Ú get_all_keys)rrArBrKrCr r r rN¯s zStorageUri.get_all_keyscCs6| d¡| ¡}| |j||¡}| |d|j¡|S)Nr?rC)rr9r?rrr )rrArBÚconnrCr r r r?³s  zStorageUri.get_bucketcCs:| d¡| ||¡}| |j||¡}| |d|j¡|S)NÚget_keyÚkey)r r?rPrrr ©rrArBr;rCrQr r r rPºs   zStorageUri.get_keycCs"| d¡| ||¡}| |j¡S)NÚnew_key)r r?rSr©rrArBrCr r r rSÁs  zStorageUri.new_keycCsD| d¡|jddd| d|¡}| |d|j¡|j|||dS)NrPF)rArQ©r;)r r'rPrr Úget_contents_to_file)rÚfprBr;rQr r r Úget_contents_to_streamÆs   z!StorageUri.get_contents_to_streamé c Csd| d¡| d|¡} | | d|j¡| rH| j||||||||| d n|  ||||||||¡dS)NrVrQ)Ú hash_algs)r rPrr rV) rrWrBÚcbÚnum_cbÚtorrentr;Zres_download_handlerÚresponse_headersrZrQr r r rVÍs  ýþzStorageUri.get_contents_to_filecCs8| d¡| ||¡}| |d|j¡| |||||¡S)NÚget_contents_as_stringrQ)r rPrr r_)rrArBr[r\r]r;rQr r r r_Þs    ÿz!StorageUri.get_contents_as_stringcCs$| ¡}|jj}| |d|j¡|S)NÚ acl_class)r9Úproviderr`rr )rrOr`r r r r`æszStorageUri.acl_classcCs$| ¡}|jj}| |d|j¡|S)NÚ canned_acls)r9rarbrr )rrOrbr r r rbìszStorageUri.canned_acls)NN)FNNN)rDrDNF)FNN)FN)FNN)FN)NN)NNrYFNNNN)FNNrYFN)Ú__name__Ú __module__Ú __qualname__Ú__doc__r4r1r6r rrrrr r'r9r=r>rErNr?rPrSrXrVr_r`rbr r r r r sL :ÿ ÿ     ý ÿ rc @s^eZdZdZdZegƒZd„dd„Zd d „Zd d „Z d d„Z d…dd„Z d†dd„Z dd„Z dd„Zd‡dd„Zdˆdd„Zd‰dd„ZdŠdd„Zd‹dd „ZdŒd!d"„Zdd#d$„ZdŽd%d&„Zdd'd(„Zdd)d*„Zd‘d+d,„Zd’d-d.„Zd/d0„Zd1d2„Zd3d4„Zd5d6„Zd7d8„Zd9d:„Z d;d<„Z!d=d>„Z"d?d@„Z#dAdB„Z$d“dDdE„Z%d”dFdG„Z&d•dHdI„Z'dJdK„Z(d–dLdM„Z)d—dNdO„Z*d˜dPdQ„Z+d™dRdS„Z,dšdTdU„Z-d›dVdW„Z.dœdXdY„Z/dd[d\„Z0džd]d^„Z1dŸd_d`„Z2d dbdc„Z3d¡ddde„Z4d¢dfdg„Z5d£dhdi„Z6d¤djdk„Z7d¥dldm„Z8d¦dndo„Z9d§dpdq„Z:d¨drds„Z;d©dtdu„Zd¬dzd{„Z?d­d|d}„Z@d®d~d„ZAd¯d€d„ZBd°d‚dƒ„ZCdS)±rz StorageUri subclass that handles bucket storage providers. Callers should instantiate this class by calling boto.storage_uri(). ú/NrTFc Csb||_||_||_||_|r"||_||_||_|o8t|ƒ|_| |_ t |jƒpRt |ƒ|_ |  ¡dS)aÐInstantiate a BucketStorageUri from scheme,bucket,object tuple. @type scheme: string @param scheme: URI scheme naming the storage provider (gs, s3, etc.) @type bucket_name: string @param bucket_name: bucket name @type object_name: string @param object_name: object name, excluding generation/version. @type debug: int @param debug: debug level to pass in to connection (range 0..2) @type connection_args: map @param connection_args: optional map containing args to be passed to {S3,GS}Connection constructor (e.g., to override https_connection_factory). @param suppress_consec_slashes: If provided, controls whether consecutive slashes will be suppressed in key paths. @param version_id: Object version id (S3-specific). @param generation: Object generation number (GCS-specific). @param is_latest: boolean indicating that a versioned object is the current version After instantiation the components are available in the following fields: scheme, bucket_name, object_name, version_id, generation, is_latest, versionless_uri, version_specific_uri, uri. Note: If instantiated without version info, the string representation for a URI stays versionless; similarly, if instantiated with version info, the string representation for a URI stays version-specific. If you call one of the uri.set_contents_from_xyz() methods, a specific object version will be created, and its version-specific URI string can be retrieved from version_specific_uri even if the URI was instantiated without version info. N) r5rrr7r1r(r;Úintr<Ú is_latestÚboolÚis_version_specificÚ_build_uri_strings) rr5rrr7r1r(r;r<rir r r r üs$zBucketStorageUri.__init__cCs˜|jrn|jrnd|j|j|jf|_|jr|j|j||p6|jd}n"| ¡jdkr`|j|j||jd}| |d|j ¡|S)NrPÚawsrUÚgoogle©r<rQ) r r?Ú get_providerÚnamerPrr;r<rr rRr r r rPNs   ÿ ÿzBucketStorageUri.get_keycCsf| d¡| ||¡}| ¡jdkr@|p,|j}| |j|||¡S| ¡jdkrb|j|j||jdSdS)Nr>rqrrrs)r r?rtrur;r>rr<r@r r r r>Zs    ÿ ÿzBucketStorageUri.delete_keycCs$| d¡t|j|j||j|jdS)zºInstantiate a BucketStorageUri from the current BucketStorageUri, but replacing the object_name. @type new_name: string @param new_name: new object name Úclone_replace_name)rrr7r()rrr5rr7r(©rÚnew_namer r r rvfs ýz#BucketStorageUri.clone_replace_namec Csn| d¡d}d}d}t|dƒr&|j}t|dƒr6|j}t|dƒrF|j}t|j ¡|jj |j |j |j |||dS)a)Instantiate a BucketStorageUri from the current BucketStorageUri, by replacing the object name with the object name and other metadata found in the given Key object (including generation). @type key: Key @param key: key for the new StorageUri to represent Úclone_replace_keyNFr;r<ri)rrr7r(r;r<ri) rr2r;r<rirraZget_provider_namerCrur7r()rrQr;r<rir r r ryss(    øz"BucketStorageUri.clone_replace_keycCsn| d¡| ||¡}|jpd}| ¡jdkrH|p6|j}| |||¡}n|j|||jd}| |d|j ¡|S)zreturns a bucket's aclÚget_aclrDrqrsÚacl) rr?rrtrur;rzr<rr )rrArBr;rCÚkey_namer{r r r rzs    zBucketStorageUri.get_aclcCs4| d¡| ||¡}| |¡}| |d|j¡|S)z%returns a bucket's default object aclÚ get_def_aclr{)rr?r}rr )rrArBrCr{r r r r}Ÿs    zBucketStorageUri.get_def_aclcCs4| d¡| ||¡}| |¡}| |d|j¡|S)zreturns a bucket's CORS XMLÚget_corsÚcors)rr?r~rr )rrArBrCrr r r r~§s    zBucketStorageUri.get_corscCsB| d¡| ||¡}|jdkr.| ||¡n| | ¡|¡dS)z#sets or updates a bucket's CORS XMLz set_cors r)N)rr?r5Úset_corsZto_xml)rrrArBrCr r r r€¯s    zBucketStorageUri.set_corscCs | d¡| ||¡}| |¡S)NÚ get_location)rr?rrTr r r r¸s  zBucketStorageUri.get_locationcCs8| d¡|jdkr"td|jƒ‚| ||¡}| |¡S)NÚget_storage_classr+z.get_storage_class() not supported for %s URIs.)rr5Ú ValueErrorr?r‚rTr r r r‚½s  ÿ z"BucketStorageUri.get_storage_classcCs>| d¡|jdkr"td|jƒ‚| ||¡}| ||¡dS)z!Updates a bucket's storage class.Úset_storage_classr+z.set_storage_class() not supported for %s URIs.N)rr5rƒr?r„)rÚ storage_classrArBrCr r r r„Çs  ÿ z"BucketStorageUri.set_storage_classcCs(| d¡| ||¡}| ||j||¡S)NÚget_subresource)rr?r†r)rÚ subresourcerArBr;rCr r r r†Òs    ÿz BucketStorageUri.get_subresourcecCs–| d¡|jdkr"td|jƒ‚|jr`|r4tdƒ‚| ||¡}| |d|j¡| |||¡n2|jr„|  ||¡}| ||||¡nt d|jƒ‚dS)NÚadd_group_email_grantr+z2add_group_email_grant() not supported for %s URIs.zDadd_group_email_grant() on key-ful URI cannot specify recursive=TruerQz-add_group_email_grant() on bucket-less URI %s) rr5rƒrrPrr rˆrr?r)rÚ permissionÚ email_addressÚ recursiverArBrQrCr r r rˆÙs&  ÿ   ÿÿz&BucketStorageUri.add_group_email_grantcCsZ| d¡|js.| ||¡}| ||||¡n(| ||¡}| |d|j¡| ||¡dS)NÚadd_email_grantrQ)rrr?rŒrPrr )rr‰rŠr‹rArBrCrQr r r rŒîs   ÿ z BucketStorageUri.add_email_grantcCsZ| d¡|js.| ||¡}| ||||¡n(| ||¡}| |d|j¡| ||¡dS)NÚadd_user_grantrQ)rrr?rrPrr )rr‰Zuser_idr‹rArBrCrQr r r rús   zBucketStorageUri.add_user_grantcCs| d¡| |¡}| |¡S)Nz list_grants )rr?Ú list_grants©rrBrCr r r rŽs  zBucketStorageUri.list_grantscCsdS)ú3Returns True if this URI names a file or directory.Fr rr r r Ú is_file_uri szBucketStorageUri.is_file_uricCsdS)ú2Returns True if this URI names a bucket or object.Tr rr r r Ú is_cloud_uriszBucketStorageUri.is_cloud_uricCs t|j ƒS)zÒ Returns True if this URI names a directory or bucket. Will return False for bucket subdirs; providing bucket subdir semantics needs to be done by the caller (like gsutil does). ©rjrrr r r Únames_containersz BucketStorageUri.names_containercCs t|jƒS)z0Returns True if this URI names a file or object.r”rr r r Únames_singletonsz BucketStorageUri.names_singletoncCsdS©z+Returns True if this URI names a directory.Fr rr r r Únames_directorysz BucketStorageUri.names_directorycCs t|j ƒS)ú*Returns True if this URI names a provider.)rjrrr r r Únames_provider"szBucketStorageUri.names_providercCst|jƒot|j ƒS)ú(Returns True if this URI names a bucket.)rjrrrr r r Ú names_bucket&szBucketStorageUri.names_bucketcCsdS)ú&Returns True if this URI names a file.Fr rr r r Ú names_file*szBucketStorageUri.names_filecCs| ¡S)ú)Returns True if this URI names an object.©r–rr r r Ú names_object.szBucketStorageUri.names_objectcCsdS)z8Returns True if this URI represents input/output stream.Fr rr r r Ú is_stream2szBucketStorageUri.is_streamrDcCsF| d¡| ¡}|jdkr0| |j||||¡S| |j|||¡SdS)Nzcreate_bucket r+)rr9r5Ú create_bucketr)rrBÚlocationÚpolicyr…rOr r r r£6s  ÿzBucketStorageUri.create_bucketcCs | d¡| ¡}| |j|¡S)NÚ delete_bucket)rr9r¦r©rrBrOr r r r¦Bs zBucketStorageUri.delete_bucketcCs| ¡}| |¡Sr:)r9Úget_all_bucketsr§r r r r¨Gsz BucketStorageUri.get_all_bucketscCs"| ¡}|j}| |d|j¡|S)Nra)r9rarr )rrOrar r r rtKszBucketStorageUri.get_providerc Csb| d¡|p|jpd}| ||¡}|jrD|j||||j||dn|pL|j}| ||||¡dS)zSets or updates a bucket's ACL.Úset_aclrD©r<Ú if_generationÚif_metagenerationN)rrr?r<r©r;) rÚ acl_or_strr|rArBr;r«r¬rCr r r r©Qs  þ zBucketStorageUri.set_aclc Csd| d¡|p|jpd}| ||¡}|jrD|j||||j||dn|pL|j}|j||||ddS)z2Sets or updates a bucket's ACL with an XML string.Ú set_xml_aclrDrªrUN)rrr?r<r®r;) rÚ xmlstringr|rArBr;r«r¬rCr r r r®_s   þ  ÿzBucketStorageUri.set_xml_aclcCs"| d¡| ||¡ ||¡dS)zASets or updates a bucket's default object ACL with an XML string.Úset_def_xml_aclN)rr?r°)rr¯rArBr r r r°ns z BucketStorageUri.set_def_xml_aclcCs"| d¡| ||¡ ||¡dS)z.Sets or updates a bucket's default object ACL.Ú set_def_aclN)rr?r±)rr­rArBr;r r r r±ss zBucketStorageUri.set_def_aclcCsD| d¡|jd|d| ||¡}| |d|j¡| ||¡dS)z>Sets or updates a bucket's acl to a predefined (canned) value.Úset_canned_aclrUrQN)r r'rPrr r²©rZacl_strrArBr;rQr r r r²ys   zBucketStorageUri.set_canned_aclcCs8| d¡| ||¡}| |d|j¡| |||¡dS)zXSets or updates a bucket's default object acl to a predefined (canned) value.zset_def_canned_acl rQN)rrPrr Úset_def_canned_aclr³r r r r´‚s  z#BucketStorageUri.set_def_canned_aclcCs.| d¡| ||¡}| |||j||¡dS)NÚset_subresource)rr?rµr)rr‡ÚvaluerArBr;rCr r r rµ‹s   ÿz BucketStorageUri.set_subresourcerYc Csn| d¡|j|d} |jdkrH|r0tj d¡|  |||||||¡} n|  ||||||||¡} | | ¡| S)NÚset_contents_from_stringrFr+z^Warning: GCS does not support reduced_redundancy; argument ignored by set_contents_from_string)r rSr5r!r"r#r·rp) rÚsrBÚreplacer[r\r¥rmÚreduced_redundancyrQÚresultr r r r·’s4    ÿþ z)BucketStorageUri.set_contents_from_stringc CsŽ| d¡|j|d} |jdkrV| j||||||||| | d } | r€| d| jd|¡n*|jd| d| j||||||||| d } | | ¡| S)NÚset_contents_from_filerFr+)ÚsizeÚrewindÚres_upload_handler)r¿)r½r¾)r rSr5r¼rnr<r'rp) rrWrBr¹r[r\r¥rmr½r¾r¿rQr»r r r r¼¥sH   þ ÿÿþ z'BucketStorageUri.set_contents_from_filec Cs:| d¡| d|¡}|j||||||d}| |¡|S)NÚset_contents_from_streamF)r¥rº)r rSrÀrp) rrWrBr¹r[r¥rºZdst_keyr»r r r rÀºs  þ z)BucketStorageUri.set_contents_from_streamÚSTANDARDc Cs`| d¡|jd|d} | r<| j|j|||||||| | d S| j|j||||||||| d SdS)zReturns newly created key.Úcopy_keyF)rArB) Ú new_key_nameÚsrc_bucket_nameÚ src_key_nameÚmetadatar…Ú preserve_aclÚ encrypt_keyrBÚ query_argsÚsrc_generation) rÃrÄrÅrÆÚsrc_version_idr…rÇrÈrBrÉN)r r?rÂr) rrÄrÅrÆrËr…rÇrÈrBrÉrÊZ dst_bucketr r r rÂÄs6 úûzBucketStorageUri.copy_keycCs*| d¡| ||¡}|j|||ddS)NÚenable_loggingrF)rr?rÌ)rZ target_bucketZ target_prefixrArBr;rCr r r rÌÛs  zBucketStorageUri.enable_loggingcCs&| d¡| ||¡}|j|ddS)NÚdisable_loggingrF)rr?rÍ©rrArBr;rCr r r rÍás  z BucketStorageUri.disable_loggingcCs"| d¡| ||¡}|j|dS)NÚget_logging_configrF)rr?rÏrÎr r r rÏæs  z#BucketStorageUri.get_logging_configcCs<| d¡| ||¡}|s*|s*| |¡n| |||¡dS)NÚset_website_config)rr?Zdelete_website_configurationZconfigure_website)rZmain_page_suffixZ error_keyrArBrCr r r rÐës    z#BucketStorageUri.set_website_configcCs | d¡| ||¡}| |¡S)NÚget_website_config)rr?Zget_website_configurationrTr r r rÑôs  z#BucketStorageUri.get_website_configcCs | d¡| d|¡}| |¡S)NÚget_versioning_configF)rr?Zget_versioning_statusrr r r rÒùs  z&BucketStorageUri.get_versioning_configcCs"| d¡| d|¡}| ||¡S)NÚconfigure_versioningF)rr?rÓ)rZenabledrBrCr r r rÓþs  z%BucketStorageUri.configure_versioningcCs| d¡j||||dS)NFrF)rPZset_remote_metadata)rZ metadata_plusZmetadata_minusrÇrBr r r Ú set_metadatas  ýzBucketStorageUri.set_metadatacCsT| d¡g}|D]}| | ¡¡|j|d_q| ¡j|||d|_| ¡|S)NÚcomposeéÿÿÿÿ)Ú content_typerB)r ÚappendrSr<rÕrl)rÚ componentsr×rBZcomponent_keysZsurir r r rÕ s ÿzBucketStorageUri.composecCs4| d¡| ||¡}| |¡}| |d|j¡|S)z+Returns a bucket's lifecycle configuration.Úget_lifecycle_configZ lifecycle)rr?rÚrr )rrArBrCÚlifecycle_configr r r rÚs    z%BucketStorageUri.get_lifecycle_configcCs&| d¡| ||¡}| ||¡dS)z3Sets or updates a bucket's lifecycle configuration.Úconfigure_lifecycleN)rr?rÜ)rrÛrArBrCr r r rÜs  z$BucketStorageUri.configure_lifecyclecCs8| d¡|jdkr"td|jƒ‚| d|¡}| |¡S)NÚget_billing_configr+z/get_billing_config() not supported for %s URIs.F)rr5rƒr?rÝrr r r rÝ$s  ÿ z#BucketStorageUri.get_billing_configcCs@| d¡|jdkr"td|jƒ‚| ||¡}|j||ddS)z1Sets or updates a bucket's billing configuration.Úconfigure_billingr+z.configure_billing() not supported for %s URIs.)Úrequester_paysrBN)rr5rƒr?rÞ)rrßrArBrCr r r rÞ-s  ÿ z"BucketStorageUri.configure_billingcCs:| d¡|jdkr"td|jƒ‚| ||¡}|j|dS)z0Returns a GCS bucket's encryption configuration.Úget_encryption_configr+z2get_encryption_config() not supported for %s URIs.rF)rr5rƒr?ràrTr r r rà8s  ÿ z&BucketStorageUri.get_encryption_configcCs(| d¡| ||¡}|j||ddS)z-Sets a GCS bucket's encryption configuration.Úset_encryption_config)Údefault_kms_key_namerBN)rr?rá)rrârArBrCr r r ráCs   ÿz&BucketStorageUri.set_encryption_configcCs6|jstd|jƒ‚| |¡}|j|j|d}t|ƒS)z8Returns True if the object exists or False if it doesn'tzexists on object-less URI (%s)rF)rrr r?rPrj)rrBrCrQr r r ÚexistsKs  zBucketStorageUri.exists)NNrNTNNF)FNN)FNNN)FNN)FN)FN)FN)FN)FN)FN)FNN)FFN)FFN)FFN)N)NrDNN)N)N)rDFNNNN)rDFNNNN)FN)FNN)FNN)FNN)FNN)NTNrYNNF) NTNrYNNNFN)NTNNF)NNrÁFFNNN)NFNN)FNN)FNN)NNFN)FN)N)N)N)NN)FN)FN)N)FFN)FN)NFN)N)DrcrdrerfÚdelimÚsetZ capabilitiesr rlrprnrPr>rvryrzr}r~r€rr‚r„r†rˆrŒrrŽr‘r“r•r–r˜ršrœržr¡r¢r£r¦r¨rtr©r®r°r±r²r´rµr·r¼rÀrÂrÌrÍrÏrÐrÑrÒrÓrÔrÕrÚrÜrÝrÞràrárãr r r r rósþ 1 ÿ       ÿ ÿ ÿ ÿ ÿ  ÿ ÿ  ÿ ÿ ÿ ÿ þ þ ÿ ý ÿ   ÿ   ÿ  ÿ  ÿ ÿ rc@sŠeZdZdZejZd dd„Zdd„Zdd„Z d d „Z d d „Z d d„Z dd„Z dd„Zdd„Zdd„Zdd„Zdd„Zdd„Zd!dd„ZdS)"ÚFileStorageUrizã StorageUri subclass that handles files in the local file system. Callers should instantiate this class by calling boto.storage_uri(). See file/README about how we map StorageUri operations onto a file system. FcCs,d|_d|_||_d||_||_||_dS)a™Instantiate a FileStorageUri from a path name. @type object_name: string @param object_name: object name @type debug: boolean @param debug: whether to enable debugging on this StorageUri After instantiation the components are available in the following fields: uri, scheme, bucket_name (always blank for this "anonymous" bucket), object_name. r.rDzfile://N)r5rrr r7Ústream)rrr7r¢r r r r ^s  zFileStorageUri.__init__cCst||j|jƒS)z¶Instantiate a FileStorageUri from the current FileStorageUri, but replacing the object_name. @type new_name: string @param new_name: new object name )rær7rçrwr r r rvrsz!FileStorageUri.clone_replace_namecCsdS)rTr rr r r r‘{szFileStorageUri.is_file_uricCsdS)r’Fr rr r r r“szFileStorageUri.is_cloud_uricCs| ¡S)z5Returns True if this URI names a directory or bucket.)r˜rr r r r•ƒszFileStorageUri.names_containercCs | ¡ S)zs   Te