abusix_stats.js

var lynx = require('lynx');
var metrics = new lynx('localhost', 8125);
var hostname = require('os').hostname();

// Connections per second
// Connections by source port (25, 80, ...)
exports.hook_lookup_rdns = function (next, conn) {
    // Ignore connections from localhost
    if (conn.remote_ip === '127.0.0.1' ||
        conn.remote_ip === '::1')
    {
        return next();
    }
    metrics.increment('haraka.connections,host=' + hostname + ',port=' + conn.local_port);
    
    return next();
}

// Messages per second
exports.hook_queue_ok = function (next, conn) {
    // Ignore connections from localhost
    if (conn.remote.ip === '127.0.0.1' ||
        conn.remote.ip === '::1')
    {
        return next();
    }
    metrics.increment('haraka.messages,host=' + hostname);
    
    return next();
}