logfmtToJson

#!/usr/bin/env node

var readline = require('readline'),
    unflatten = require('flat').unflatten,
    logfmt = require('logfmt');

var rl = readline.createInterface({
    input: process.stdin,
    output: process.stdout
});

rl.on('line', function(line) {
    line = 'request.ip' + line.split('- request.ip')[1];
    process.stdout.write(JSON.stringify(unflatten(logfmt.parse(line))));
});