NodeJS raw process output JSONifying (processes line-by-line)

output_jsonify.js

// Usage: ~$ some-process | node output_jsonify.js

const pump = require('pump');
const split = require('split2');
const through = require('through2');

const dope = msg => ({
  pid: process.pid,
  time: new Date().getTime(),
  level: /Error/.test(msg) ? 3 : 30,
  msg
});

pump(
  process.stdin,
  split(),
  through((chunk, enc, cb) => {
    const msg = chunk.toString();

    // Avoiding stack trace
    if (/^\s+/.test(msg) || msg.indexOf('}') !== -1) {
      return cb();
    }

    console.log(JSON.stringify(dope(msg)));

    cb();
  })
);