analyze_comment_wrapper.js

analyze_comment_wrapper.js

#!/usr/bin/env node
var utf8 = require('utf8');
var msgpack = require('msgpack');
var module = require('./analyze');
var key = 'message';

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

rl.on('line', function (msgline) {
  var msg = JSON.parse(msgline);
  msg.classified = module.analyzeComment(msg[key]);
  process.stdout.write(msgpack.pack(msg));
});