HackFlowy/lib/helperLib.js

var crypto = require('crypto')
  , express = require('express')
  , http = require('http')
  , ObjectID = require('mongodb').ObjectID, 
  cookie = require('cookie');
  
var mongoose = require('mongoose'); 
var User = mongoose.model('User'); 
var Node = require('../models/Node.js');

var io;
var online = [];
var lastExchangeData = {};
var makeCommit = require("./makeCommit.js").makeCommit; 
var getAndSendRevHistory = require("./revAlgorithm.js").getAndSendRevHistory; 

module.exports = {

  safeConnectToDB: function(){
    var url = require("../config/config.js").DB_URL; 
    try {  mongoose.connect(url); }
    catch(err) { console.log("Error: Sign In to MongoLab") }
  },

  createSocket: function(server) {
    io = require('socket.io').listen(server, {log: false});
    io.sockets.on('connection', function(socket){

      socket.AUTHOR = {}; //anonymous. 

      socket.on("logIn", function(data){
        socket.AUTHOR = data; 
        attachLogInListeners(socket); 
        console.log("logIn + attachLogInListeners")
      }); 

      socket.on('nodeRequest', function(data){
        var nodes = Node.findAndSocketSend(socket); //finds, then sends through socket. 
      }); 

      socket.on("revHistoryRequest", function(subRootId){
        getAndSendRevHistory(subRootId, socket); 
      }); 

    }); 

  },
  setUpDB: function(){
    Node.setUpDB();
    //getTimeHash();
  }
}













function attachLogInListeners(socket){
  socket.on("COMMIT", function(){
    makeCommit(); 
    socket.emit("commitReceived"); 
  }); 

  //Used when a node is split...
  socket.on("edit", function(data){
    var id = data[0];
    var newText = data[1];
    console.log("\n\n\n\n edit received:" + newText);
    Node.updateText(id, newText);
    socket.broadcast.emit("edit", [id, newText]);

  });

  //This works for all ids except negative ids. 
  socket.on("editing", function(data){ //data=[id, Author.name]
    socket.broadcast.emit("editing", data);
  });


  socket.on("blurred", function(data){
    socket.broadcast.emit("blurred", data);

    var id = data[0];
    var text = data[1];
    var author = data[2]; 

    Node.updateText(id, text, author._id);
  });




  // ADD AUTHOR INFORMATION
  // socket.on("transclude", function(data){
  //   var parId = data[0]; 
  //   var transcludeId = data[2]; 
  //   var newIndex = data[1]; 
  //   var now = Date.now();
  //    Node.updateParent(parId, transcludeId ,newIndex, now );
     
  // });



  socket.on("newNode", function(data){
    var modelJson = data[1]; //(includes the negative ID to find later);
    var parId = data[0][0];
    var newIndex = data[0][1];
    var Author = data[2]; 

    var now = Date.now();

    var callback = function(err, instance, now){
      socket.emit("updateReceived", [modelJson._id ,instance, data[0]]); 
      socket.broadcast.emit("newNode", [ [parId,newIndex]  , instance ]);

      
      Node.updateParent(parId, instance._id ,newIndex, now );
    }

    console.log("newNode"); 
    Node.addNode(modelJson.text, modelJson.children, modelJson.parents, modelJson.author._id ,callback);
    
  });
  //need to broadcast parentArray. 

  socket.on("removeNode", function(data){ 
    var thisId = data[0];
    var thisIndex = data[1];
    var parId = data[2];
    var author = data[3];
    // data[3] = null; //improve efficiency. 
    socket.broadcast.emit("removeNode", data);
    Node.removeNode(thisId, thisIndex, parId, author._id);

  });

  socket.on("movedNode", function(data){
    // var ids = [thisModel.get("_id"), oldParModel.get("_id"), newParModel.get("_id")];
    // var arrays = [thisModel.get("parents"), oldParModel.get("children"), newParModel.get("children")];
    // var indices = [dragIndex, dropIndex];
    // var data = [ids, arrays, indices, CurrentUser];

    Node.moveNode(data[0], data[1],data[3]._id);
    socket.broadcast.emit("movedNode", [data[0], data[2]]);

    

  });
  socket.on("getTimeHash", function(){
    var timeHash = getTimeHash();

    socket.emit("timeHash", timeHash);
  }) ;
}