CODEWITHSUNDEEP
node.jssftpssh2-sftp
GeorgeBT1902
GeorgeBT1902

Reputation: 305

SFTP in Node.js uploading empty files

I'm having an issue with a project I'm working on whereby I'm downloading files from my FTP server using a node module called sftp-ssh2-client and then trying to pass the stream back into my FTP server but into a different directory.

The code looks like this:

const stream = sftp.get(`path/to/file.csv.gz`).then(() => {

}).catch((err) => {

});

sftp.put(stream, 'path/to/new/file.csv.gz').then(() => {

}).catch((err) => {

})

However, when I dial into my FTP server to the location where the file has been PUT to, the file size is 0 and when downloaded is corrupted. Can anyone tell me what I'm doing wrong here?

Many thanks,

G

Upvotes: 0

Views: 2439

Answers (2)

vasudev.p
vasudev.p

Reputation: 467

 function uploadFile(req, res) {
    req.pipe(req.busboy);
    req.busboy.on('file', function(fieldname, file, filename) {
        // debug("Uploading: " + filename);
        filename = (new Date()).getTime() + '-' + filename;

        //Path where file will be uploaded
        var fstream = fs.createWriteStream(FILE_STORE + filename);

        file.pipe(fstream);

        fstream.on('close', function() {
            //   debug("Upload Finished of " + filename);
            var newFileName = FILE_STORE + filename;
            if (!fs.existsSync(newFileName)) {

                res.status(404).json({ 'message': 'file not found' })
                return;
            }
            res.status(200).json({ file: filename });
        })
    })

}

Upvotes: 1

robertklep
robertklep

Reputation: 203241

sftp.get() doesn't return a stream, it returns a promise that resolves to a stream, so your code should look something like this:

sftp.get('path/to/file.csv.gz').then(stream => {
  return sftp.put(stream, 'path/to/new/file.csv.gz');
}).catch(err => {
  ...
});

However, it seems to me that you could just use sftp.rename(), which wouldn't require downloading and uploading the entire file:

sftp.rename('path/to/file.csv.gz', 'path/to/new/file.csv.gz').then(...);

Also, if you do want to take the download-then-upload route, make sure you read the documentation regarding encoding.

Upvotes: 3

Related Questions