prod.js

function parseFile(callback) {
    U.logLn('parseFile - Number of files to process', FILES.length);
    if (FILES.length == 0) {
        callback(false);
        return;
    }
    DATA = [];

    function parse(file) {
        var csvFilePath = '/home/dperussina/apps/customer-api-connections/src/dania/queue/' + file;


        return function (cb) {
            try {
                CSV()
                    .fromFile(csvFilePath)
                    .on('json', (jsonObj) => {
                        DATA.push(jsonObj);
                    })
                    .on('done', (error) => {
                        if (error) {
                            ERRORS.push({
                                source: 'parseFile',
                                stack: error
                            });
                            cb(true, 'CSV error' + error);
                            return;
                        }
                        cb(false);
                    });
            } catch (err) {
                ERRORS.push({
                    stack: err,
                    file: csvFilePath
                });
                cb(true);
            }


        }
    }
    Q(FILES, parse, function (err, reply) {
        callback(err);
    });

}

function main() {
    ASYNC.series([getFile, parseFile, mapFields, exec, cleanUp], done);
}

testing.js

function parseFile(callback) {
    U.logLn('parseFile - Number of files to process', FILES.length);
    if (FILES.length == 0) {
        callback(false);
        return;
    }
    DATA = [];

    function parse(file) {
        //var csvFilePath = '/home/dperussina/apps/customer-api-connections/src/dania/queue/' + file;
        var csvFilePath = './<DirectoryOfChoice>/' + file;


        return function (cb) {
            try {
                CSV()
                    .fromFile(csvFilePath)
                    .on('json', (jsonObj) => {
                        DATA.push(jsonObj);
                    })
                    .on('done', (error) => {
                        if (error) {
                            ERRORS.push({
                                source: 'parseFile',
                                stack: error
                            });
                            cb(true, 'CSV error' + error);
                            return;
                        }
                        cb(false);
                    });
            } catch (err) {
                ERRORS.push({
                    stack: err,
                    file: csvFilePath
                });
                cb(true);
            }


        }
    }
    Q(FILES, parse, function (err, reply) {
        callback(err);
    });

}

function main() {
    //ASYNC.series([getFile, parseFile, mapFields, exec, cleanUp], done);
  ASYNC.series([parseFile, mapFields, exec, cleanUp], done);
}