!FtpURI methodsFor:'file operations'!

ftp:aFtpClient copyContentsOfStream:aReadStream toDestFilePath:aDestiantionPath

    |writestream buffer n|

    writestream := aFtpClient putStreamFor:aDestiantionPath.

    (writestream notNil and:[writestream isWritable]) ifTrue:[

        buffer := ByteArray new:(self class transferBufferSize).

        [aReadStream atEnd] whileFalse:[

            n := aReadStream nextBytes:(buffer size) into:buffer.

            writestream isExternalStream ifTrue:[

                writestream writeWait.

            ].

            writestream nextPutBytes:n from:buffer.

        ].

    ] ifFalse:[ 

        OperatingSystem fileNotFoundErrorSignal

            raiseRequestWith:aDestiantionPath

            errorString:('Write: %1' bindWith:aDestiantionPath asString)

    ].

! !

!FtpURI methodsFor:'ftp requests'!

connectThenDo:aOneArgBlock

    |ftp|

    ftp := FTPClient new.

    [

        ftp connectTo:self host 

            port:self port 

            user:(self user ? self defaultUser)

            password:(self password ? self defaultPassword).

        aOneArgBlock value:ftp

    ] ensure:[

        ftp notNil ifTrue:[

            ftp close.

        ].

    ]

!

    "establish a connection for try to get a readSteream"

    self connectThenDo:[:aFtpClient|

        exists := self pathExistsFtp:aFtpClient.

    ^ exists ? false

"

    |pwd uri|

    pwd := Dialog requestPassword:'Password:'. 

    uri := (URI fromString:('ftp://tm:%1@exept/home/tm/tmp/test.txt' bindWith:pwd) ).

    uri pathExists

"

!

pathExists:aPathname ftpClient:aFtpClient

    |list|

    list := aFtpClient list:aPathname.

    ^ list contains:[:aLine| (aLine asCollectionOfWords last) = aPathname ] 

!

pathExistsFtp:aFtpClient

    ^ self pathExists:self path ftpClient:aFtpClient

! !

!FtpURI methodsFor:'private'!

ftp:aFtpClient moveStream:anOpenedStream ofPath:aSourcePath baseName:aBasename intoDir:aDirectoryPathName

    |path dir|

    dir := aDirectoryPathName asFilename.

    path := (dir construct:aBasename) asString.

    (self pathExists:path ftpClient:aFtpClient) ifTrue:[

        path := AbsoluteTime now printString.

        path := (dir construct:(aBasename, '-', path)) asString.

    ].

    anOpenedStream resetPosition.

    self ftp:aFtpClient copyContentsOfStream:anOpenedStream toDestFilePath:path.

    anOpenedStream close.

    aFtpClient delete:aSourcePath.

    self readStreamsDo:aBlock thenRemove:false

!

readStreamsDo:aBlock thenRemove:doRemoveSource

    "evaluate the block with a Collection of streams as first argument

     and a dictionary containing attributes as second argument,

     - a collection with a stream on a single file,

     - or a collection with streams on a directorie's files, but not recursive

     The streams are closed after aBlock has been evaluated.

     Attributes may be the mime type (key #MIME)"

                "/ skip subdirectories and the summary of the list

                requestDirectory 

                    ifTrue:[  baseName := aPathName ] 

                    ifFalse:[ baseName := self pathSegements last ].

            stream notNil ifTrue:[ |src srcPath|

                (self pathSegements includes:baseName) ifTrue:[ 

                    srcPath := self path.

                    attributes at:#uriInfo put:self.  

                    src := ((self copy) addComponent:baseName).

                    srcPath := src path.

                    attributes at:#uriInfo put:src.  

                [ aBlock value:stream value:attributes ] 

                    ensure:[ stream close ].

                doRemoveSource == true ifTrue:[ 

                    ftp delete:srcPath.

                ].

    ^ '$Header: /cvs/stx/stx/libbasic2/FtpURI.st,v 1.3 2003-07-09 12:55:24 tm Exp $'