exabugs/node-searcher

/*
 * GET users listing.
 */

var _ = require('underscore')
  , fs = require('fs')
  , async = require('async')
  , spawn = require('child_process').spawn
  , MeCab = require('node-wakame')
  , extend = require('../extend')
  , vector = require('../vector')
  , frequency = require('./frequency')
  , Util = require('../vector/util')
  ;

/**
 *
 * @param db
 * @param collection
 * @param condition
 * @param option
 * @param freq
 * @param field
 * @param callback
 */
exports.search = function (db, target, freq, field, callback) {

  var tasks = [];
  tasks.push(function (done) {
    var condition2 = [];
    var c = 0;
    var conditions = target.option.condition;
    // target.option.condition は $and オペレータを使うこともできる
    conditions = conditions['$and'] ? conditions['$and'] : [conditions];
    _.each(conditions, function (condition) {
      _.each(freq, function (value, key) {
        var text = condition[key];
        if (text) {
          ++c;
          delete condition[key];
          exports.tf(text, field, function (err, keyword) {
            frequency.to_tfiof(keyword, field, db.collection(value), 0, function (err, keyword) {
              condition2.push({attribute: key, keyword: keyword});
              if (--c === 0) {
                done(err, condition2);
              }
            });
          });
        }
      });
    });
    if (c === 0) {
      done(null, condition2);
    }
  });
  tasks.push(function (condition2, done) {
    var condition = target.option.condition || {};
    var collection = db.collection(target.collection);

    vector.cosine(collection, condition, condition2, target.option, field, function (err, result) {
      done(err, result);
    });
  });
  async.waterfall(tasks, function (err, result) {
    callback(err, result);
  });

};

exports.batch = function (db, source, field, callback) {
  var collection = db.collection(source.collection);
  var index = {};
  index[[source.attribute, field[0]].join('.')] = 1;
  collection.ensureIndex(index, function (err) {
    var fileds = source.fields || {_id: 1};
    var cursor = collection.find(source.option.condition, fileds);
    cursor.count(function (err, count) {
      if (count == 0) {
        return callback(err, count);
      }
      var c = count;
      cursor.each(function (err, item) {
        if (item) {
          exports.patch(db, source.fields, item, collection, source.attribute, field, function (err) {
            if (--c == 0) {
              return callback(err, count);
            }
          });
        }
      });
    });
  });
};

/**
 *
 * @param db
 * @param src src.files の src 部分の名前
 * @param _id src.files の _id
 * @param out
 * @param callback
 */
exports.patch = function (db, info, item, out, attribute, field, callback) {
  var result = [];
  var util = new Util(field);
  async.eachSeries(Object.keys(info), function (key, next) {
    var input = extend.getValue(item, key) || '';
    exports.tf(input, field, function (err, tf) {
      result = util.sum(result, util.multiply(tf, info[key]));
      next();
    })
  }, function (err) {
    var data = {};
    data[attribute] = result;
    out.update({_id: item._id}, {$set: data}, function (err, result) {
      callback(err, result);
    });
  });
};

/**
 * TF
 * @param input 文字列 or ストリーム
 * @param callback
 */
exports.tf = function (input, field, callback) {
  exports.parse(input, function (err, result) {
    if (err) {
      callback(err);
    } else {
      var tf = _.map(result, function (value, key) {
        var item = {};
        item[field[0]] = key;
        item[field[1]] = value;
        return item;
      });
      tf = _.sortBy(tf, function (v) {
        return v[field[0]];
      });
      callback(err, tf);
    }
  });
};

/**
 *
 * @param input 文字列 or ストリーム
 * @param callback [ { 名詞 : 個数 }, ... ]
 */
exports.parse = function (input, callback) {

  var info = {
    "名詞": {"一般": 1, "固有名詞": 1, "数": 1, "サ変接続": 1, "形容動詞語幹": 1, "副詞可能": 1}
  };

  var result = {};

  var mecab = MeCab.parse(input);

  mecab.on('record', function (record, index) {
    if (1 < record.length) {
      var term = record[0];
      var cond1 = record[1];
      var cond2 = record[2];
      if (info[cond1] && info[cond1][cond2]) {
        var count = result[term];
        result[term] = count ? count + 1 : 1;
      }
    }
  });

  mecab.on('error', function (error) {
    callback(error);
  });

  mecab.on('end', function (count) {
    callback(null, result);
  });

};

/**
 * DocCat
 *
 * @param req
 * @param res
 */
exports.doccat = function (req, res) {

  // アップロードファイル
  var file = req.files.file.path;

  _doccat(file, '/opt/doccat/', 1000, function (err, result) {

    // ファイル削除
    fs.unlink(file);

    res.send(result);

  });
};

/**
 * DocCat
 *
 * @param file    処理対象ファイル
 * @param dir     実行形式フォルダ
 * @param timeout 最大処理時間(msec)
 * @param callback
 * @private
 */
function _doccat(file, dir, timeout, callback) {

  // 実行形式一蘭
  var processes = _.map(fs.readdirSync(dir), function (exe) {
    return dir + exe;
  });

  // 処理開始時刻
  var start = new Date().getTime();

  async.map(processes, function (process, done) {

    var result = {process: process, data: ""};
    var process = spawn(process, [file]);

    process.stdout.on('data', function (data) {
      result.data += data;
    });

    process.on('close', function (code) {
      result.time = new Date().getTime() - start; // 処理時間
      result.code = code; // リターンコード
      done(null, result);
    });

    setTimeout(function () {
      process.kill('SIGHUP');
    }, timeout);

  }, function (err, results) {

    callback(err, _.max(results, function (result) {
      return result.data.length;
    }));

  });

}