rbl-server.js

var dns = require('dns')
    , db = require('./list.json')
    , nDNS = require('native-dns')
    , server = nDNS.createServer()
    , winston = require('winston')
    , redis = require("redis")
    , config = require("./config.json")
    , async = require('async')
    ;

redisClient = redis.createClient();

var log = new (winston.Logger)({
    transports: [
        new (winston.transports.Console)({ timestamp: true, colorize: true }),
        new (winston.transports.File)({ filename: config.logfile, timestamp: true })
    ]
});

server.on('request', function (request, response) {
/*    redisClient.get(request.question[0].name, function (err, data) {
        if(data) {
            data = JSON.parse(data);
            console.log(data);
            if(data.answer.length < 1) {
               response.header.rcode = nDNS.consts.NAME_TO_RCODE.NOTFOUND;
               response.send();
            }
            else {
            response.answer.push(data.answer);
            response.answer.push(data.additional);
            response.send();
            }
        }
        else {
*/
            ip = request.question[0].name.replace(config.hostBase, '');
            async.each(db, function (rbl, callback) {
                dns.resolve(ip + rbl.dns, function (err, domain) {
                    if(err) {
                        callback(null);
                    }
                    else {
                        response.answer.push(nDNS.A({
                            name: request.question[0].name,
                            address: config.standardResponse,
                            ttl: 300,
                        }));
                        response.answer.push(nDNS.TXT({
                        name: request.question[0].name,
                        data: rbl.dns,
                        ttl: 300,
                        }));
                        callback(null);
                    }
                });
            },
            function (err) {
                if(response.answer.length < 1) {
                    response.header.rcode = nDNS.consts.NAME_TO_RCODE.NOTFOUND;
                    response.send();
                    res = {};
                    res.answer = response.answer;
                    res.answer.push(response.additional);
                    redisClient.set(request.question[0].name, JSON.stringify(res), function (err, data) {
                        if (err) { log.error('REDIS: ' + err); }
                        redisClient.expire(request.question[0].name, 1800);
                    });
                }
                else {
                    response.send();
                    res = {};
                    res.answer = response.answer;
                    res.answer.push(response.additional);
                    redisClient.set(request.question[0].name, JSON.stringify(res), function (err, data) {
                        if (err) { log.error('REDIS: ' + err); }
                        redisClient.expire(request.question[0].name, 1800);
                    });
                }
            });
        //}
    //});
    log.info(request.address.address + '\t' + request.question[0].name);
});

server.on('error', function ( err, buff, req, res) {
    log.error('DNS' + err);
});

redisClient.on('error', function (err) {
    log.error('REDIS: ' + err);
});


server.serve(config.listenPort, config.listenHost);