Question

62

Reading file from SFTP server using Node.js and SSH2

rated 0 times [ 66] [ 4] / answers: 1 / hits: 20949 / 8 Years ago, sun, may 22, 2016, 12:00:00

I have a pretty strange problem working with read streams in Node.js. I'm using SSH2 to create a sftp connection between me and a sftp server. I then try to create a read stream from the sftp stream. From the read stream's emitted 'data' event I append the data to an array. When the read stream's 'close' event occurs I make a call to Buffer.concat to create concat all the chunks of data I have retrieved into one buffer. This is the same technique described in other questions asked here at stack overflow. For example here. However, I'm not able to use the data I retrieve. It seems like the buffer is 32 bytes less in size then the file that I'm trying to retrieve (from counting the length of the data retrieved). Could this have something to do with my SFTP connection? Or how I create my read stream?

If it matters, the file is of type zip. When I'm trying to unzip the file (in node.js and manually) after reading it to buffer it doesn't work.

After investigating I have found out that:

When I use readdir on the file, the size of the file is correct.

Using FTP (JSFTP) against my development FTP server works just fine using the same technique above.

Any advise is appreciated!

Here is my code:

        var Client = require('ssh2').Client;

        var m_ssh2Credentials = {

           host: config.ftpHostName,

           port: config.ftpPort,

           username: config.ftpUser,

           password: config.ftpPassword,

           readyTimeout: 20000,

           algorithms: { cipher: [3des-cbc, aes256-cbc, aes192-cbc,aes128-cbc]}

        };

        ...

        var conn = new Client();

        var dataLength = 0;

        conn.on('ready', function() {

            conn.sftp(function(err, sftp) {

                if (err) {

                    writeToErrorLog(downloadFile(): Failed to open SFTP connection.);

                } else {

                    writeToLog(downloadFile(): Opened SFTP connection.);

                }



                var streamErr = ;

                var dataLength = 0;

                var stream = sftp.createReadStream(config.ftpPath + / + m_fileName)

                stream.on('data', function(d){

                    data.push(d);

                    dataLength += d.length;

                });

                .on('error', function(e){

                    streamErr = e;

                })

                .on('close', function(){

                    if(streamErr) {

                        writeToErrorLog(downloadFile(): Error retrieving the file:  + streamErr);

                    } else {

                        writeToLog(downloadFile(): No error using read stream.);

                        m_fileBuffer = Buffer.concat(data, dataLength);

                        writeToLog(Data length:  + dataLength);



                        writeToLog(downloadFile(): File saved to buffer.);

                    }

                    conn.end();

                });

            })

        })

        .on('error', function(err) {

            writeToErrorLog(downloadFile(): Error connecting:  + err);

        }).connect(m_ssh2Credentials);

Answers

Only authorized users can answer the question. Please sign in first, or register a free account.

josefinap

Add To Favorites

Follow

Total Points: 548

Total Questions: 125

Total Answers: 106

Location: Angola

Member since Tue, May 5, 2020

4 Years ago

answered 8 Years ago zahrafrancisr · Accepted Answer

So after a lot of investigation I finally realized that there was something wrong with the last bits of data that was transmitted in the 'data' event. From my understanding it seems to be a bug in the implementation of the read stream. I was able to get around this problem by using the more simplistic functions (open, fstat, read) in the SSH2 library. This solution works for me. Wanted to share the solution if someone else comes across the same problem.

Working code:

sftp.open(config.ftpPath + / + m_fileName, r, function(err, fd) {

sftp.fstat(fd, function(err, stats) {

    var bufferSize = stats.size,

        chunkSize = 16384,

        buffer = new Buffer(bufferSize),

        bytesRead = 0,

        errorOccured = false;



    while (bytesRead < bufferSize && !errorOccured) {

        if ((bytesRead + chunkSize) > bufferSize) {

            chunkSize = (bufferSize - bytesRead);

        }

        sftp.read(fd, buffer, bytesRead, chunkSize, bytesRead, callbackFunc);

        bytesRead += chunkSize;

    }



    var totalBytesRead = 0;

    function callbackFunc(err, bytesRead, buf, pos) {

        if(err) {

            writeToErrorLog(downloadFile(): Error retrieving the file.);

            errorOccured = true;

            sftp.close(fd);

        }

        totalBytesRead += bytesRead;

        data.push(buf);

        if(totalBytesRead === bufferSize) {

            m_fileBuffer = Buffer.concat(data);

            writeToLog(downloadFile(): File saved to buffer.);

            sftp.close(fd);

            m_eventEmitter.emit(' downloadFile_Completed ');

        }

    }

})

});