Tukukkk

I want to copy data from FTP A to FTP B.
I use stream instead of the local temp file.
But i cannot read the data from stream.

transformComponent.js

const Transform = require('stream').Transform;

const util = require('util');



const transformComponent = module.exports = function(options) {

    if (!(this instanceof transformComponent))

        return new Parser(options);

    Transform.call(this, options);

};



util.inherits(transformComponent, Transform);    



transformComponent.prototype._transform = function(data, encoding, callback) {

    this.push(data);

    callback();

};



transformComponent.prototype._flush = function(callback) {

    callback();

};

ftpComponent.js

const Client = require('ftp');

var ftp = new Client();



var ftpComponent = function(host){

    this.host = host;

    this.port = 21;

    this.user = "";

    this.password = "";

};



function connectionProperties(){

    let properties ={

        host: this.host,

        port: this.port

    };

    if(this.user && this.user!== "")

        properties.user = this.user;

    if(this.password && this.password !== "")

        properties.password = this.password;



    return properties;

}



function download(filepath, target){

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

      ftp.get(filepath, function(err, stream) {

        if (err) throw err;

        stream.once('close', function() { ftp.end(); });

        stream.pipe(target);

      });

    });



    ftp.connect(this.connectionProperties());

}



function upload(source, filename){

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

        // Upload files to the server:

        ftp.put(source, filename, function(err) {

            if (err) throw err;

            ftp.end();

        });

    });



    ftp.connect(this.connectionProperties());

}



ftpComponent.prototype = {

    connectionProperties: connectionProperties,

    pull : download,

    push : upload

}



module.exports = ftpComponent;

My usage :

const ftp = require('./node_component/ftpComponent.js');

const transform = require('./node_component/transformComponent.js');



var ftpSourceObject = new ftp('host A');

var ftpTargetObject = new ftp('host B');



ftpSourceObject.user = usernameA;

ftpSourceObject.password = passwordA;



ftpTargetObject.user = usernameB;

ftpTargetObject.password = passwordB;



var temp = new transform();

ftpTargetObject.push(temp, 'file-cp.txt');

ftpSourceObject.pull('file.txt', temp);

I can write data into stream from FTP A.
But when reading data from stream and put on FTP B.
It shows the error like below.

Error: Unable to parse PASV server response

    at Object.reentry [as cb] (/home/locadmin/fileshareservice/app/node_modules/ftp/lib/connection.js:857:19)

    at Parser.<anonymous> (/home/locadmin/fileshareservice/app/node_modules/ftp/lib/connection.js:117:20)

    at Parser.emit (events.js:182:13)

    at Parser._write (/home/locadmin/fileshareservice/app/node_modules/ftp/lib/parser.js:59:10)

    at doWrite (_stream_writable.js:410:12)

    at writeOrBuffer (_stream_writable.js:394:5)

    at Parser.Writable.write (_stream_writable.js:294:11)

    at Socket.ondata (/home/locadmin/fileshareservice/app/node_modules/ftp/lib/connection.js:273:20)

    at Socket.emit (events.js:182:13)

    at addChunk (_stream_readable.js:283:12)

But when i run just a single line

var temp = new transform();

ftpTargetObject.push(temp, 'file-cp.txt');

temp.write('123');

temp.end();

//ftpSourceObject.pull('file.txt', temp);

It work successful.
How can I pass the stream as parameter to function??
Sorry for my poor English...

My source code reference source is https://bountify.co/node-js-script-for-copying-files-between-two-ftp-locations.

I fix it.

transformComponent.js

const Transform = require('stream').Transform;

const util = require('util');



const transformComponent = module.exports = function(options) {

    if (!(this instanceof transformComponent))

        return new Parser(options);

    Transform.call(this, options);

};



util.inherits(transformComponent, Transform);    



transformComponent.prototype._transform = function(data, encoding, callback) {

    this.push(data);

    callback();

};



transformComponent.prototype._flush = function(callback) {

    callback();

};

ftpComponent.js

const Client = require('ftp');



var ftpComponent = function(host){

    this.host = host;

    this.port = 21;

    this.user = "";

    this.password = "";

};



function connectionProperties(){

    let properties ={

        host: this.host,

        port: this.port

    };

    if(this.user && this.user!== "")

        properties.user = this.user;

    if(this.password && this.password !== "")

        properties.password = this.password;



    return properties;

}



function download(filepath, target){

    var ftp = new Client();

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

      ftp.get(filepath, function(err, stream) {

        if (err) throw err;

        stream.once('close', function() { ftp.end(); });

        stream.pipe(target);

      });

    });



    ftp.connect(this.connectionProperties());

}



function upload(source, filename){

    var ftp = new Client();

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

        // Upload files to the server:

        ftp.put(source, filename, function(err) {

            if (err) throw err;

            ftp.end();

        });

    });



    ftp.connect(this.connectionProperties());

}



ftpComponent.prototype = {

    connectionProperties: connectionProperties,

    pull : download,

    push : upload

}



module.exports = ftpComponent;

My usage :

const ftp = require('./node_component/ftpComponent.js');

const transform = require('./node_component/transformComponent.js');



var ftpSourceObject = new ftp('host A');

var ftpTargetObject = new ftp('host B');



ftpSourceObject.user = usernameA;

ftpSourceObject.password = passwordA;



ftpTargetObject.user = usernameB;

ftpTargetObject.password = passwordB;



var temp = new transform();

ftpTargetObject.push(temp, 'file-cp.txt');

ftpSourceObject.pull('file.txt', temp);