data.js

var getListeners = function (callback) {
    var listeners = [];
    var file = './data/listeners.inc';
    fs = require('fs');
    fs.readFile(file, 'utf8', function (err, data) {
        var items = data.split('\n');
        items.forEach(function (line) {
            line = line.replace(/\n$/, '').trim();
            var parts = line.split('|');
            if (parts.length > 1 && line[0] != ';') {
                if (typeof parts[3] != 'undefined' && parts[3].indexOf(",") != -1) {
                    senderList = parts[3].split(',');
                } else {
                    senderList = [parts[3]];
                }
                var listener = {
                    name: parts[0],
                    type: parts[1],
                    url: parts[2],
                    senders: senderList,
                };
                if (listener.type == 'AMQP') {
                    var amqpParts = parts[2].split(':');
                    listener.server = amqpParts[0];
                    listener.queue = amqpParts[1];
                    listener.key = amqpParts[2];
                    listener.exchange = amqpParts[3];
                }
                listeners.push(listener);
            }
        });
        if (err) {
            return console.log(err);
        }
        callback(listeners);
    });
    //return listeners;
};


var getSenders = function (callback) {
    var senders = [];
    var file = './data/senders.inc';
    //console.log('parse FIle');
    fs = require('fs');
    //console.log(fs);
    fs.readFile(file, 'utf8', function (err, data) {
        var items = data.split('\n');
        items.forEach(function (line) {
            line = line.replace(/\n$/, '').trim();
            var parts = line.split('|');
            if (parts.length > 0 && line[0] != ';') {
                var sender = {
                    name: parts[0],
                    type: parts[1],
                    url: parts[2],
                    dataType: parts[3],
                };
                if (sender.type == 'AMQP') {
                    var amqpParts = parts[2].split(':');
                    sender.queue = amqpParts[0];
                    sender.key = amqpParts[1];
                    sender.exchange = amqpParts[2];
                }
                senders.push(sender);
            }
        });
        callback(senders);
        if (err) {
            return console.log(err);
        }
    });
    //console.log(senders);
    //return senders;

};

module.exports = {
    getListeners: getListeners,
    getSenders: getSenders
};