ProPeler
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
opt
/
cpanel-ccs
/
txweb2
/
dav
/
Filename :
fileop.pyc
back
Copy
� �t�ac @ sZ d Z d d d d d d g Z d d l Z d d l Z d d l m Z d d l m Z d d l m Z m Z m Z d d l m Z d d l m Z d d l m Z d d l m Z m Z d d l m Z m Z d d l m Z m Z e � Z d d � Z d � Z e e � Z d � Z e e � Z d d � Z! e e! � Z! d � Z" d � Z# d � Z$ d S( si WebDAV file operations This API is considered private to static.py and is therefore subject to change. t deletet copyt movet putt mkcollectiont rmdiri����N( t urlsplit( t Failure( t succeedt deferredGeneratort waitForDeferred( t Logger( t CachingFilePath( t responsecode( t StatusResponset HTTPError( t FileStreamt readIntoFile( t ResponseQueuet statusForFailuret infinityc C s� | j � r)| d k rM d | f } t j | � t t t j | � � � n t j t | � d � } | d d k r� | d } n t j d | j f � | j t | � } t | d t j � } xt j | j d t �D]� \ } } } xQ | D]I } t j j | | � } y t j | � Wq� | j | t � � q� Xq� Wx� | D]� } t j j | | � } t j j | � r�y t j | � Wq�| j | t � � q�XqFy t j | � WqF| j | t � � qFXqFWq� Wy t j | j � Wn) t t t � d | j f � � � n X| j � } n` t j d | j f � y t j | j � Wn) t t t � d | j f � � � n Xt j } | j � t | � S( s� Perform a X{DELETE} operation on the given URI, which is backed by the given filepath. @param filepath: the L{FilePath} to delete. @param depth: the recursion X{Depth} for the X{DELETE} operation, which must be "infinity". @raise HTTPError: (containing a response with a status code of L{responsecode.BAD_REQUEST}) if C{depth} is not "infinity". @raise HTTPError: (containing an appropriate response) if the delete operation fails. If C{filepath} is a directory, the response will be a L{MultiStatusResponse}. @return: a deferred response with a status code of L{responsecode.NO_CONTENT} if the X{DELETE} operation succeeds. R s5 Client sent illegal depth header value for DELETE: %si i����t /s Deleting directory %st DELETEt topdowns deleting directory: %ss Deleting file %ss deleting file: %s( t isdirt logt errorR R R t BAD_REQUESTt urllibt unquoteR t infot patht lenR t NO_CONTENTt ost walkt Falset joint removet addR t islinkR R t responset changedR ( t urit filepatht deptht msgt uri_patht request_basenamet errorst dirt subdirst filest filenameR t subdirR) ( ( s$ /opt/cpanel-ccs/txweb2/dav/fileop.pyR : s\ ( c # s� | j � r� t j d | j | j f � y | j � } Wn) t t t � d | j f � � � n Xt | � } t t | | | � � } | Vz | j � } Wd | j � | j � Xt | d t j t j � | Vd S| j � r�| j � r5t t | | � � } | V| j � } t | d t j � t j } n t j } t j d | j | j f � | j � | j � t � d | � } | j � j � rft j j � � rt j � � } | d t j j k r�t j j � | � } n y t j � | � Wqc| j � t � � qcXq�y t j � � Wn& t t t � d � f � � � n X| d k r�| Vd Sn t t t j d | f � � � t � � � � � � f d � } x�t j! | j d t" �D]�\ } } } x� | D]� } | | | � \ } } t j j t j j# | � � s$| j | t j$ � q�t t% t& | � t& | � | | � � } | V| j � } t | d t j t j � q�Wx | D]} | | | � \ } } t j d | | f � t j j t j j# | � � s�| j | t j � q�t j j | � rit j | � } | d t j j k r5t j j | | � } n y t j | | � Wq�| j | t � � q�Xq�y t j | � Wq�| j | t � � q�Xq�Wq�W| j' � Vd St j( d | j f � t t t j) d � � � d S( sz Perform a X{COPY} from the given source and destination filepaths. This will perform a X{DELETE} on the destination if necessary; the caller should check and handle the X{overwrite} header before calling L{copy} (as in L{COPYMOVE.prepareForCopy}). @param source_filepath: a L{FilePath} for the file to copy from. @param destination_filepath: a L{FilePath} for the file to copy to. @param destination_uri: the URI of the destination resource. @param depth: the recursion X{Depth} for the X{COPY} operation, which must be one of "0", "1", or "infinity". @raise HTTPError: (containing a response with a status code of L{responsecode.BAD_REQUEST}) if C{depth} is not "0", "1" or "infinity". @raise HTTPError: (containing an appropriate response) if the operation fails. If C{source_filepath} is a directory, the response will be a L{MultiStatusResponse}. @return: a deferred response with a status code of L{responsecode.CREATED} if the destination already exists, or L{responsecode.NO_CONTENT} if the destination was created by the X{COPY} operation. s Copying file %s to %ss opening file for reading: %sNR R s Copying directory %s to %st COPYi s creating directory %st 0s3 Parent collection for destination %s does not existc sQ t j j | | � } | j � � s* t � t j j � | � d � } | | f S( Ni ( R" R R% t startswitht AssertionError( t basepatht subpatht source_patht destination_path( t destination_basenamet source_basenamet source_basename_len( s$ /opt/cpanel-ccs/txweb2/dav/fileop.pyt paths s R R s Unable to COPY to non-file: %ssB The requested resource exists but is not backed by a regular file.(* t isfileR R R t openR R R R R R t getResultt closet checkResponseR R! t CREATEDR t existsR R t parentR" R( t readlinkt sepR% t symlinkR' t mkdirR t CONFLICTR R# t Truet dirnamet NOT_FOUNDR t FilePathR) R t FORBIDDEN( t source_filepatht destination_filepatht destination_uriR- t source_filet source_streamR) t success_codeR1 t link_destinationRB R2 R3 R4 R5 R= R> R6 ( ( R? R@ RA s$ /opt/cpanel-ccs/txweb2/dav/fileop.pyR � s� ( ' c c s? t j d | j | j f � | j � rn t t | | � � } | V| j � } t | d t j � t j } n t j } y t j | j | j � Wn t k r� n X| j � | Vd St t | | | | � � } | V| j � } t | d t j t j � t t | | � � } | V| j � } t | d t j � | Vd S( s Perform a X{MOVE} from the given source and destination filepaths. This will perform a X{DELETE} on the destination if necessary; the caller should check and handle the X{overwrite} header before calling L{copy} (as in L{COPYMOVE.prepareForCopy}). Following the X{DELETE}, this will attempt an atomic filesystem move. If that fails, a X{COPY} operation followed by a X{DELETE} on the source will be attempted instead. @param source_filepath: a L{FilePath} for the file to copy from. @param destination_filepath: a L{FilePath} for the file to copy to. @param destination_uri: the URI of the destination resource. @param depth: the recursion X{Depth} for the X{MOVE} operation, which must be "infinity". @raise HTTPError: (containing a response with a status code of L{responsecode.BAD_REQUEST}) if C{depth} is not "infinity". @raise HTTPError: (containing an appropriate response) if the operation fails. If C{source_filepath} is a directory, the response will be a L{MultiStatusResponse}. @return: a deferred response with a status code of L{responsecode.CREATED} if the destination already exists, or L{responsecode.NO_CONTENT} if the destination was created by the X{MOVE} operation. s Moving %s to %sR NR ( R R R RI R R RE RG R R! RH R" t renamet OSErrorR* R ( RU t source_uriRV RW R- R) RZ ( ( s$ /opt/cpanel-ccs/txweb2/dav/fileop.pyR J s0 c c s� t j d | j f � | j � r� | d k r� y0 | j � rN t | j � n t j | j � Wq� t t t � d | j f � � � q� Xn9 t t | | � � } | V| j � } t | d t j � t j } n t j } y | j d � } Wn) t t t � d | j f � � � n Xy( t t | | � � } | V| j � Wn) t t t � d | j f � � � n X| j � | j � | Vd S( s� Perform a PUT of the given data stream into the given filepath. @param stream: the stream to write to the destination. @param filepath: the L{FilePath} of the destination file. @param uri: the URI of the destination resource. If the destination exists, if C{uri} is not C{None}, perform a X{DELETE} operation on the destination, but if C{uri} is C{None}, delete the destination directly. Note that whether a L{put} deletes the destination directly vs. performing a X{DELETE} on the destination affects the response returned in the event of an error during deletion. Specifically, X{DELETE} on collections must return a L{MultiStatusResponse} under certain circumstances, whereas X{PUT} isn't required to do so. Therefore, if the caller expects X{DELETE} semantics, it must provide a valid C{uri}. @raise HTTPError: (containing an appropriate response) if the operation fails. @return: a deferred response with a status code of L{responsecode.CREATED} if the destination already exists, or L{responsecode.NO_CONTENT} if the destination was created by the X{PUT} operation. s Writing to file %ss writing to file: %sR t ws opening file for writing: %sN( R R R RI t NoneR R R" R& R R R R R RE RG R R! RH RD R RF R* ( t streamR, R+ R) RZ t resource_filet x( ( s$ /opt/cpanel-ccs/txweb2/dav/fileop.pyR � sD c C sW y t j | j � | j � Wn) t t t � d | j f � � � n Xt t j � S( s� Perform a X{MKCOL} on the given filepath. @param filepath: the L{FilePath} of the collection resource to create. @raise HTTPError: (containing an appropriate response) if the operation fails. @return: a deferred response with a status code of L{responsecode.CREATED} if the destination already exists, or L{responsecode.NO_CONTENT} if the destination was created by the X{MKCOL} operation. s creating directory in MKCOL: %s( R" RN R R* R R R R R RH ( R, ( ( s$ /opt/cpanel-ccs/txweb2/dav/fileop.pyR � s c C s� x� t j | d t �D]� \ } } } x* | D]" } t j t j j | | � � q, WxR | D]J } t j j | | � } t j j | � r� t j | � qY t j | � qY Wq Wt j | � d S( s� Removes the directory with the given name, as well as its contents. @param dirname: the path to the directory to remove. R N( R" R# R$ R& R R% R( R ( RQ R2 R3 R4 R5 R6 R ( ( s$ /opt/cpanel-ccs/txweb2/dav/fileop.pyR � s % c G s) | | k s% t d | | | f � � d S( Ns< %s() returned %r, but should have returned one of %r instead( R: ( R) t methodt codes( ( s$ /opt/cpanel-ccs/txweb2/dav/fileop.pyRG s (% t __doc__t __all__R" R t urlparseR t twisted.python.failureR t twisted.internet.deferR R R t twext.python.logR t twext.python.filepathR RS t txweb2R t txweb2.httpR R t txweb2.streamR R t txweb2.dav.httpR R R R R R R` R R R RG ( ( ( s$ /opt/cpanel-ccs/txweb2/dav/fileop.pyt <module> s8 t � F I