udp relaying machine

relayUPD.js

var dgram = require('dgram');


var relay = function(port, dest){
    var server = dgram.createSocket('udp4');
    var client = dgram.createSocket('udp4');
    var clients = [];

    if(!Array.isArray(dest)){
      dest = [ dest ];
    }

    dest.forEach(function(v){
        var conn = {};
        conn.port = Number(v.port) || 123;
        if(!v.host){
            console.log('skipping', v);
            return;
        }
        conn.host = v.host;
        clients.push(conn);
    });

    server.on('listening', function(){
        var address = server.address();
        console.log("Server listening on " + address.address + ":" + address.port);
        console.log("Relaying to:");
        clients.forEach(function(v){
            console.log("\t" + v.host + ":" +v.port);
        });
    });

    server.on('message', function(msg, rinfo){
        clients.forEach(function(v){
            client.send(msg, 0, msg.length, v.port, v.host, function(err){
                console.log("Sent " + msg.length + " bytes to " + v.host + ":" + v.port);
                if(err){
                    console.log('Error', err);
                }
            });
        });
    });

    server.bind(port);
};

relay( 62267, [
    {host: 'localhost', port: 62268},
    {host: 'localhost', port: 62269}
]);