search.js

var data = {},
  index = {},
  masterParser = require('./masterParser'),
  fs = require('fs'),
  pending = 0;

function add(userAddress, obj) {
  console.log(obj);
  data[userAddress] = {
    userAddress: userAddress,
    textFields: obj.textFields || {},
    images: obj.images || {},
    tools: obj.tools || {},
    type: 'row'
  }
  var words = [];
  if(data[userAddress].textFields.fullName) {
    word = data[userAddress].textFields.fullName.split(' ');
  }
  if(data[userAddress].textFields.nick) {
    words.push(data[userAddress].textFields.nick);
  }
  for(var i in words) {
    for(var j=3; j<=words[i].length; j++) {
      var prefix = words[i].substring(0, j);
      if(!index[prefix.toLowerCase()]) {
        index[prefix.toLowerCase()]={};
      }
      index[prefix.toLowerCase()][userAddress]=true;
    }
  }
  dumpDb();
}
function dumpDb() {
  fs.writeFile("./dump.json", JSON.stringify({data: data, index: index}), function(err) {
      if(err) {
          console.log(err);
      } else {
          console.log("The file was saved!");
      }
  });
}
function readDb() {
  fs.readFile("./dump.json", function(err, str) {
      if(err) {
          console.log(err);
      } else {
        try {
          var parsed = JSON.parse(str);
          data = parsed.data;
          index = parsed.index;
          console.log("The file was loaded!");
        } catch(e) {
        }
      }
  });
}
readDb();
var sessions = [];
exports.getSession = function() {
  return (function() {
    var rowCb = function(row) {
      console.log(row);
    };
    var statusCb = function(status) {
      console.log(status);
    };
    return {
      on: function(eventType, cb) {
        if(eventType == 'row') {
          rowCb = cb;
        } else if(eventType == 'status') {
          statusCb = cb;
        }
      },
      search: function search(str) {
        if(index[str]) {
          for(var i in index[str]) {
            if(data[i]) {
              var obj = data[i];
              obj.from = 'index';
              obj.query = str;
              console.log('result from index');
              rowCb(obj);
            }
          }
        }
        pending++;
        console.log('pending++: '+pending+' '+data);
        statusCb(pending>0?'busy':'idle');
        masterParser.parse(str, 'input', function(err, obj) {
          pending--;
          console.log('pending--: '+pending);
          statusCb(pending>0?'busy':'idle');
          if(obj) {
            obj.userAddress = str;
            add(str, obj);
            obj.from='live';
            obj.query=str;
            console.log('result from live:');
            console.log(obj);
            rowCb(obj);
          }
        });
      },
      close: function() {
      }
    };
  })();
};